Function main

server/src/index.ts:12–72

()

validateEnvironment();

async function main() {
  // Run migrations on startup if RUN_MIGRATIONS is set
  if (process.env.RUN_MIGRATIONS === 'true') {
    logger.info('RUN_MIGRATIONS=true, running database migrations');
    try {
      const dbConfig = getDatabaseConfig();
      if (!dbConfig) {
        throw new Error('DATABASE_URL not configured');
      }
      await runMigrations(dbConfig);
    } catch (error) {
      logger.fatal({ err: error }, 'Migration failed');
      process.exit(1);
    }
  }

  // GCP KMS signing provider initializes lazily on first signed AdCP call
  // (see security/gcp-kms-signer.ts). Eager-init at boot was tried and
  // pulled — when KMS auth is misconfigured, the gRPC client retries
  // forever and the app never binds port 8080, taking down the whole
  // deploy instead of just the signing path. Lazy is the safer default.

  // Start HTTP server first, then initialize Addie in the background.
  // initializeAddieBolt uses execSync (git clone) which blocks the event loop,
  // so it must not run before the server starts listening.
  const httpServer = new HTTPServer();
  const port = parseInt(process.env.PORT || process.env.CONDUCTOR_PORT || "3000", 10);
  await httpServer.start(port);

  // Periodic sweep of expired RFC 9421 nonce-cache rows. Postgres has no
  // native TTL, so the replay-store table grows unboundedly without this.
  // Safe after `httpServer.start` because the underlying pool is initialized
  // by then; sweep failures log-warn but never crash.
  const { startReplayCacheSweeper } = await import('./training-agent/request-signing.js');
  startReplayCacheSweeper();

  // Log memory usage every 60s so PostHog/OTEL can chart heap trends.
  // On 1GB Fly machines this is critical for spotting leaks early.
  setInterval(() => {
    const mem = process.memoryUsage();
    logger.info(
      {
        heap_used_mb: Math.round(mem.heapUsed / 1024 / 1024),
        heap_total_mb: Math.round(mem.heapTotal / 1024 / 1024),
        rss_mb: Math.round(mem.rss / 1024 / 1024),
        external_mb: Math.round(mem.external / 1024 / 1024),
      },
      "Memory usage"
    );
  }, 60_000).unref();

  // Addie (AAO Community Agent) with Bolt SDK — initialized after server is running.
  // The router is stored in the Bolt app and retrieved via getAddieBoltRouter().
  initializeAddieBolt().then((result) => {
    if (result) {
      logger.info('Addie Bolt initialized successfully');
    }
  }).catch((error) => {