Function cancel_task_controller

apps/backend/controller/task_controller.js:237–409

* @brief Cancel an existing transcription task * * @param req [in] Express request object containing: * - body.label Task label * - body.sso_account User account * - body.token Authorization token * - body.task_objid Task identifier * @param res [out] Express response objec

(req, res)

 * @note Logs all file cleanup operations
 */
async function cancel_task_controller(req, res) {
  const route = '/api/v1/rest/CancelTask';
  const { label, sso_account, token, task_objid } = req.body || {};
  //const ip_address = req.ip;
  const ip_address = translate_ipv4_to_ipv6(req.headers['x-forwarded-for'] || req.connection.remoteAddress);

  const memo = operation_memo({
    route: route,
    token: token,
    sso_account: sso_account,
    ip_address: ip_address,
    ref: task_objid
  });
  if (!sso_account || !token || !label || !task_objid) {
    logger(LOG_LEVEL.ERROR, `The task cacellation failed because sso_account=${sso_account}, token=${token}, label=${label}, objid=${task_objid} were not provided.`, memo);
    return res.status(400).json({
      message: 'The task cancellation failed becasue sso_account, token, label, objid were not provided.',
      task_objid,
      status: NOTIFY_STATUS.ERROR
    });
  }

  // Check if the task belongs to the SSO account
  const is_valid = await is_authorized_to_access_task({task_objid, sso_account});
  if (!is_valid) {
    logger(LOG_LEVEL.WARNING, `${route}: This task ${task_objid} does not belong to the sso account ${sso_account}, or ${task_objid} is duplicated.`, memo);
    return res.status(401).json({
      message: 'This task objid does not belong to the sso account, or objid is duplicated.',
      task_objid,
      status: NOTIFY_STATUS.ERROR
    });
  }

  try {
    const start_time = process.hrtime();

    let result = await check_task_status({
      objid: task_objid
    });

    if (result?.recordset?.length === 1 && result.recordset[0].STATUS !== 1) {
      result = await cancel_task({
        objid: task_objid
      });
    } else {
      /* Force to cancel the runnning process, if status == 1 kill child_process or delete from 
      if (child_process && !child_process.killed) {
        child_process.kill('SIGINT');  
        res.status(200).send({ message: 'Cancellation initiated successfully.' });
      } else {
        res.status(200).send({ message: 'No active task found or task already terminated.' });
      }
      */
      logger(LOG_LEVEL.WARNING, `${route}: This task ${task_objid} does not exists or is currently executing.`, memo);
      return res.status(200).json({
        message: 'The task does not exists or is currently executing.',
        task_objid,
        status: NOTIFY_STATUS.ERROR