server.ts

/// <reference types="node" />

import { Hono } from 'hono';
import { routePath } from 'hono/route';
import { serve } from '@hono/node-server';
import { createEmitter, type HonoXrayEnv } from '@stainlessdev/xray-emitter/hono';

const app = new Hono<HonoXrayEnv>();

const xray = createEmitter(
  {
    serviceName: 'xray-example',
    endpointUrl: process.env.STAINLESS_XRAY_ENDPOINT_URL,
    // Read from response headers when finalized (default: Request-Id).
    requestId: { header: 'request-id' },
  },
  { routePath },
);

app.use('*', xray);
app.use('*', async (c, next) => {
  c.get('xray')?.setActor('tenant-123', 'user-123');
  await next();
});

app.post('/hello/:subject', (c) => {
  const subject = c.req.param('subject');
  return c.json({ message: `Hello ${subject}` });
});

const port = Number(process.env.PORT) || 3000;
const server = serve({ fetch: app.fetch, port });

const shutdown = async () => {
  server.close();
  await xray.shutdown();
};

process.once('SIGINT', () => void shutdown());
process.once('SIGTERM', () => void shutdown());