Function start

apps/worker/src/index.ts:33–174

()

sourceMapSupport.install();

async function start() {
  const collectDefaultMetrics = client.collectDefaultMetrics;
  collectDefaultMetrics({ register });

  const PORT = Number.parseInt(process.env.WORKER_PORT || '3000', 10);
  const app = express();

  // Local-only: trigger cron jobs on demand. Disabled in production. Mounted
  // before bull-board so its routes take precedence.
  if (process.env.NODE_ENV !== 'production') {
    bootDebugRoutes(app);
  }

  if (
    process.env.DISABLE_BULLBOARD !== '1' &&
    process.env.DISABLE_BULLBOARD !== 'true'
  ) {
    const serverAdapter = new ExpressAdapter();
    serverAdapter.setBasePath('/');
    createBullBoard({
      queues: [
        ...eventsGroupQueues.map(
          (queue) => new BullBoardGroupMQAdapter(queue) as any
        ),
        new BullMQAdapter(sessionsQueue),
        new BullMQAdapter(cronQueue),
        new BullMQAdapter(notificationQueue),
        new BullMQAdapter(importQueue),
        new BullMQAdapter(insightsQueue),
        new BullMQAdapter(gscQueue),
        new BullMQAdapter(cohortComputeQueue),
      ],
      serverAdapter,
    });

    app.use('/', serverAdapter.getRouter());
  }

  app.get('/metrics', (req, res) => {
    res.set('Content-Type', register.contentType);
    register
      .metrics()
      .then((metrics) => {
        res.end(metrics);
      })
      .catch((error) => {
        res.status(500).end(error);
      });
  });

  app.get('/healthcheck', async (req, res) => {
    const [redisResult, dbResult, chResult] = await Promise.all([
      tryCatch(async () => (await getRedisCache().ping()) === 'PONG'),
      tryCatch(async () => !!(await db.$executeRaw`SELECT 1`)),
      tryCatch(async () => (await chQuery('SELECT 1')).length > 0),
    ]);

    const dependencies = {