Function bind

src/tasks/background-scheduled-task/daemon.ts:131–165

()

export function bind(){
  let task: ScheduledTask;

  process.on('message', async (message: any) => {
    switch(message.command){
    case 'task:start':
        try {
          task = await startDaemon(message);
        } catch (error: any) {
          // Report the failure to the parent so it can reject start() with the
          // real cause, instead of crashing the daemon with an opaque exit.
          if (process.send) process.send({ event: 'daemon:error', jsonError: serializeError(error) });
        }
        return task;
    case 'task:stop':
      if(task) task.stop();
      return task;
    case 'task:destroy':
      if(task) task.destroy();
      return task;
    case 'task:execute':
      try {
        if (task) await task.execute();
      } catch(error: any){
        logger.debug('Daemon task:execute falied:', error);
      }
      return task;
    }
  });

  // When the parent dies the IPC channel disconnects. Exit instead of lingering
  // as an orphan: an orphaned daemon would keep running the schedule on its own,
  // and a distributed task's IPC coordination would hang with no parent to reply.
  process.on('disconnect', () => process.exit(0));
}

bind();