Express

import express from "express";
import {
  createReplayStackClient,
  getReplayStackErrorCapture,
  replayStackExpressErrorMiddleware,
  replayStackExpressMiddleware,
} from "@replaystack/sdk";

const app = express();
app.use(express.json());

const replayStack = createReplayStackClient({
  apiKey: process.env.REPLAYSTACK_API_KEY!,
  endpoint: process.env.REPLAYSTACK_ENDPOINT,
  serviceName: process.env.REPLAYSTACK_SERVICE_NAME ?? "api",
  environment: process.env.NODE_ENV ?? "development",
  appVersion: process.env.APP_VERSION,
  commitHash: process.env.COMMIT_HASH,
  captureSuccess: true,
});

app.use(
  replayStackExpressMiddleware(replayStack, {
    captureRequestBody: true,
    captureResponseBody: true,
    captureHeaders: true,
    ignoredPaths: ["/health"],
  }),
);

// …your routes…

app.use(replayStackExpressErrorMiddleware(replayStack));

// Return JSON; use captureFailure() in routes for rich error bodies on failed events.
app.use((err: unknown, _req: express.Request, res: express.Response, _next: express.NextFunction) => {
  if (res.headersSent) return;
  const capture = getReplayStackErrorCapture(err);
  const status =
    typeof capture?.statusCode === "number" && capture.statusCode >= 400 ? capture.statusCode : 500;
  if (capture?.responsePayload != null && typeof capture.responsePayload === "object") {
    return res.status(status).json(capture.responsePayload);
  }
  const message = err instanceof Error ? err.message : String(err);
  res.status(status).json({ error: message });
});