Function bootDebugRoutes

apps/worker/src/boot-debug.ts:80–256

(app: Express)

// Returns clickable links: an HTML page in a browser, full URLs in JSON for
// curl. Only mounted when NODE_ENV !== 'production'.
export function bootDebugRoutes(app: Express) {
  app.get('/debug/cron', (req, res) => {
    const jobs = buildJobs(req);
    if (wantsHtml(req)) {
      res.type('html').send(renderHtml(jobs));
      return;
    }
    res.json({
      message: 'Run a cron job now with GET or POST /debug/cron/:type',
      jobs,
    });
  });

  app.all('/debug/cron/:type', async (req, res) => {
    const type = req.params.type;
    const jobs = buildJobs(req);
    const html = wantsHtml(req);

    if (!CRON_TYPES.includes(type as CronQueueType)) {
      const message = `Unknown cron type "${type}"`;
      if (html) {
        res.status(400).type('html').send(renderHtml(jobs, message));
        return;
      }
      res.status(400).json({ ok: false, error: message, jobs });
      return;
    }

    logger.info({ type }, 'Manually triggering cron job');

    try {
      const result = await cronJob({
        data: { type: type as CronQueueType, payload: undefined },
      } as Job<CronQueuePayload>);
      if (html) {
        res
          .type('html')
          .send(
            renderHtml(
              jobs,
              `${type} ran. Result: ${JSON.stringify(result ?? null)}. Check the worker logs for details.`,
            ),
          );
        return;
      }
      res.json({ ok: true, type, result: result ?? null });
    } catch (error) {
      const message = error instanceof Error ? error.message : String(error);
      logger.error({ err: error, type }, 'Manual cron trigger failed');
      if (html) {
        res
          .status(500)
          .type('html')
          .send(renderHtml(jobs, `Error running ${type}: ${message}`));
        return;
      }
      res.status(500).json({ ok: false, type, error: message });
    }