Function sigHandler

src/api/index.ts:329–357

(signal: NodeJS.Signals)

let stopping = false;

function sigHandler(signal: NodeJS.Signals) {
  if (stopping) {
    logger.info(`Another ${signal} detected, forcing shutdown...`);
    process.exit();
  }
  stopping = true;
  logger.info(`${signal} detected, finishing jobs and shutting down...`);
  httpServer.removeAllListeners("upgrade");
  const closeResponse = Buffer.concat([Buffer.from([Rclose])]);
  for (const client of wss.clients) {
    client.send(closeResponse);
  }
  wss.close((e) => {
    if (e) {
      error(e);
      process.exit(1);
    }
    logger.info("Stopped WS server");
    if (jobs.size > 0) {
      jobs.delListen((size) => {
        if (size > 0) return;
        logger.info("All jobs finished");
        stopHTTPServer();
      });
    } else {
      stopHTTPServer();
    }
  });
}

process.on("SIGINT", (s) => sigHandler(s));
process.on("SIGTERM", (s) => sigHandler(s));