const Koa = require('koa');
// const Vue = require('vue');
const {getRequestFromURL, App} = require('./main');
// const { createBundleRenderer } = require('vue-server-renderer')

// const JSONResponse = require('../apijson/JSONResponse');
const StringUtil = require('../apijson/StringUtil');

var isCrossEnabled = true; // false;
var isLoading = false;
var startTime = 0;
var endTime = 0;
var message = '';
var error = null;
var timeMsg = '';
var progressMsg = '';

var progress = 0;
var accountProgress = 0;
var testCaseProgress = 0;
var deepProgress = 0;
var randomProgress = 0;

function update() {
 if (isLoading != true) {
 return;
 }

 if (error != null) {
 isLoading = false;
 }

 var curTime = isLoading ? (new Date()).getTime() : null;
 if (endTime <= 0 || isLoading) {
 endTime = curTime;
 }
 var duration = endTime - startTime;
 var dd = new Date(duration + 60000*(new Date().getTimezoneOffset()));

 timeMsg = '\n\nStart Time: ' + startTime + ' = ' + new Date(startTime).toLocaleString()
 + (isLoading ? '; \nCurrent' : '\nEnd') + ' Time: ' + endTime + ' = ' + new Date(endTime).toLocaleString()
 + '; \nTime Spent: ' + duration + ' = ' + dd.getHours() + ":" + dd.getMinutes() + ":" + dd.getSeconds() + "." + dd.getMilliseconds();

 var accountDoneCount = App.currentAccountIndex + 1;
 var accountAllCount = App.accounts.length;

 accountProgress = isCrossEnabled != true || accountAllCount <= 0 || accountDoneCount >= accountAllCount ? 1 : (accountDoneCount/accountAllCount).toFixed(2);
 testCaseProgress = App.doneCount >= App.allCount ? 1 : (App.doneCount/App.allCount).toFixed(2);
 deepProgress = App.deepDoneCount >= App.deepAllCount ? 1 : (App.deepDoneCount/App.deepAllCount).toFixed(2);
 randomProgress = App.randomDoneCount >= App.randomAllCount ? 1 : (App.randomDoneCount/App.randomAllCount).toFixed(2);
 // progress = accountProgress*testCaseProgress*deepProgress*randomProgress;
 progress = accountProgress >= 1 ? 1 : (accountProgress + (accountAllCount <= 0 ? 1 : 1/accountAllCount)*(testCaseProgress
 + (App.allCount <= 0 ? 1 : 1/App.allCount)*(deepProgress + (App.deepAllCount <= 0 ? 1 : 1/App.deepAllCount)*randomProgress)));

 if (progress >= 1) {
 isLoading = false;
 }

 progressMsg = '\n\nProgress: ' + (100*progress) + '%'
 + '\nTest Account: ' + accountDoneCount + ' / ' + accountAllCount + ' = ' + (100*accountProgress) + '%'
 + '\nTest Case: ' + App.doneCount + ' / ' + App.allCount + ' = ' + (100*testCaseProgress) + '%'
 + '\nDeep Test Case: ' + App.deepDoneCount + ' / ' + App.deepAllCount + ' = ' + (100*deepProgress) + '%'
 + '\nRandom & Order: ' + App.randomDoneCount + ' / ' + App.randomAllCount + ' = ' + (100*randomProgress) + '%';
};

const PORT = 3002;

const app = new Koa();
app.use(async ctx => {
 console.log(ctx)

 if (ctx.path == '/test/start' || (isLoading != true && ctx.path == '/test')) {
 if (isLoading && ctx.path == '/test/start') {
 ctx.body = 'Already started auto testing in node, please wait for minutes...';
 ctx.status = 200
 return
 }

 App.isCrossEnabled = isCrossEnabled; // isCrossEnabled = App.isCrossEnabled;
 if (isCrossEnabled) {
 App.currentAccountIndex = -1;
 }

 isLoading = true;
 startTime = (new Date()).getTime();
 endTime = startTime;
 message = '';
 error = null;
 timeMsg = '';
 progressMsg = '';

 progress = 0;
 accountProgress = 0;
 testCaseProgress = 0;
 deepProgress = 0;
 randomProgress = 0;

 update();

 App.key = ctx.query.key;
 if (StringUtil.isNotEmpty(App.key, true)) {
 App.testCaseCount = App.data.testCaseCount = 1000;
 App.randomCount = App.data.randomCount = 200;
 App.randomSubCount = App.data.randomSubCount = 500;
 }

 App.autoTest(function (msg, err) {
 message = msg;
 error = err;
 update();
 console.log('autoTest callback(' + msg + ')' + timeMsg + progressMsg);
 return Number.isNaN(progress) != true && progress >= 1;
 });
 isLoading = true;
 isCrossEnabled = App.isCrossEnabled;

 ctx.status = ctx.response.status = 200; // 302;
 ctx.body = 'Auto testing in node...';

 // setTimeout(function () { // 延迟无效
 ctx.redirect('/test/status');
 // }, 1000)
 }
 else if (ctx.path == '/test/status' || (isLoading && ctx.path == '/test')) {
 update();
 if (isLoading) {
 // ctx.response.header['refresh'] = "1";
 // ctx.redirect('/status');
 }

 ctx.status = ctx.response.status = 200; // progress >= 1 ? 200 : 302;
 ctx.body = (message || (progress < 1 || isLoading ? 'Auto testing in node...' : 'Done auto testing in node.')) + timeMsg + progressMsg;
 }
});

app.listen(PORT);

console.log(`已启动 Node HTTP 服务,可以
GET http://localhost:${PORT}/test/start
来启动后台回归测试,或者
GET http://localhost:${PORT}/test/status
来查询测试进度。`);