Function cleanup_task

apps/backend/services/task_service.js:223–271

* @brief Clean up abandoned or stale tasks in the system * * @note No input parameters - uses global worker PIDs * @return void - Logs results or errors * * Operation Flow: * 1. Get active worker PIDs * 2. Build SQL query with PID filter * 3. Clean tasks that are: * - Not finished (FIN

()

 * @note Logs cleanup count on success
 */
async function cleanup_task() {
  let query_cleanup_task = TASK_QUERIES.CLEANUP_TASK;
  let pids_for_query = get_worker_pids().join(',');

  if (__MSSQL_TEST__) {
    pids_for_query = get_worker_pids()
      .join(',')
      .split(',')
      .map(id => parseInt(id, 10))
      .filter(Number.isFinite);
    logger(LOG_LEVEL.INFO, 'pids_for_query: ' + pids_for_query);

    // TODO: self-defined table is SQL Server CREATE TYPE IntList AS TABLE (value INT);
    const table = new sql.Table();
    table.columns.add('value', sql.Int);
    pids_for_query.forEach(pid => table.rows.add(pid));
  }

  if (pids_for_query.length > 0) {
    if (__MSSQL_TEST__) {
      query_cleanup_task += 'AND (PID IS NULL OR PID NOT IN (SELECT value FROM @pids))';
    } else {
      query_cleanup_task += `AND (PID IS NULL OR PID NOT IN (${pids_for_query}))`;
    }
  } else {
    return logger(LOG_LEVEL.ERROR, `cleanup_task pids_for_query ${pids_for_query} is empty.`, memo);
  }

  const memo = operation_memo({});
  try {
    const pool = await pool_promise;
    const request = pool.request();
    if (__MSSQL_TEST__) {
      request
      .input('pid', sql.Int, process.pid)
      .input('pids', table);
    } else {
      request
      .input('pid', sql.Int, process.pid);
    }
    const result = await request.query(query_cleanup_task);
      
    if (result.rowsAffected[0] > 0) {
      logger(LOG_LEVEL.INFO, `cleanup_task clean up ${result.rowsAffected[0]} records.`, memo);
    } 
  } catch (err) {
    logger(LOG_LEVEL.ERROR, `cleanup_task ${err}.`, memo);
  }
}      

/**
 * @brief Query current status of a transcription task