result.js

import nconf from 'nconf';

import { Router } from 'express';
import { getConfigByTestId } from '../../configs.js';
import { getQueueById } from '../../queuehandler.js';
import { getText } from '../../util/text.js';

import { getTest } from '../../database/index.js';

export const result = Router();

result.get('/:id', async function (request, response) {
  const id = request.params.id;
  const workQueue = getQueueById(id);
  if (workQueue) {
    const job = await workQueue.getJob(id);
    if (job) {
      const status = await job.getState();
      if (status === 'completed') {
        return response.redirect(job.returnvalue.pageSummaryUrl);
      } else if (status === 'failed') {
        const { logs } = await workQueue.getJobLogs(id);
        return response.render('error', {
          status: status,
          id: id,
          logs: logs,
          nconf,
          message: getText('error.testfailed'),
          getText
        });
      } else {
        const testConfig = getConfigByTestId(id);
        const count = await workQueue.count();
        let placeInQueue = 1;
        if (count > 1) {
          const jobs = await workQueue.getWaiting(0, 500);
          for (let job of jobs) {
            if (job.opts.jobId === id) {
              break;
            } else {
              placeInQueue++;
            }
          }
        }
        response.header('Cache-Control', 'no-cache, no-store, must-revalidate');
        response.header('Pragma', 'no-cache');
        response.header('Expires', 0);
        return response.render('running', {
          status: status,
          message:
            count > 1
              ? getText('index.inqueue', count, placeInQueue)
              : getText('index.waitingtorunnext'),
          id: id,
          url: testConfig.url,
          nconf,
          getText
        });
      }
    } else {
      return response.render('error', {
        id: id,
        nconf,
        message: getText('error.validation.nomatchingtestwithid', id),
        getText
      });
    }
  } else {
    const testResult = await getTest(id);
    if (!testResult) {
      return response.render('error', {
        id: id,
        nconf,
        message: getText('error.validation.nomatchingtestwithid', id),
        getText
      });
    } else if (testResult.status === 'completed') {
      return response.redirect(testResult.result_url);
    } else if (testResult.status === 'failed') {
      return response.render('error', {
        status: testResult,
        id: id,
        logs: [],
        nconf,
        message: getText('error.testfailed'),
        getText
      });
    }
  }
});