Listory/src/main.ts

import { otelSDK } from "./open-telemetry/sdk"; // needs to be loaded first - always -
import { ValidationPipe } from "@nestjs/common";
import { ConfigService } from "@nestjs/config";
import { NestFactory } from "@nestjs/core";
import { NestExpressApplication } from "@nestjs/platform-express";
import { DocumentBuilder, SwaggerModule } from "@nestjs/swagger";
import { context, trace } from "@opentelemetry/api";
import * as Sentry from "@sentry/node";
import { RavenInterceptor } from "nest-raven";
import { AppModule } from "./app.module";
import { Logger } from "nestjs-pino";
import { Scope } from "@sentry/node";

function setupSentry(
  app: NestExpressApplication,
  configService: ConfigService,
) {
  Sentry.init({
    dsn: configService.get<string>("SENTRY_DSN"),
    integrations: [
      new Sentry.Integrations.OnUncaughtException(),
      new Sentry.Integrations.OnUnhandledRejection(),
    ],
  });

  app.useGlobalInterceptors(
    new RavenInterceptor({
      transformers: [
        (scope: Scope) => {
          const span = trace.getSpan(context.active());
          if (span) {
            const { spanId, traceId } = span.spanContext();
            scope.setContext("trace", { span_id: spanId, trace_id: traceId });
          }
        },
      ],
    }),
  );
}

async function bootstrap() {
  await otelSDK.start();

  const app = await NestFactory.create<NestExpressApplication>(AppModule, {
    bufferLogs: true,
    rawBody: true,
  });
  app.useLogger(app.get(Logger));
  app.useGlobalPipes(
    new ValidationPipe({
      transform: true,
      transformOptions: { enableImplicitConversion: true },
    }),
  );
  app.useBodyParser("json", {
    limit:
      "10mb" /* Need large bodies for Spotify Extended Streaming History */,
  });
  app.enableShutdownHooks();

  const configService = app.get<ConfigService>(ConfigService);

  if (configService.get<boolean>("SENTRY_ENABLED")) {
    setupSentry(app, configService);
  }

  // Setup API Docs
  const options = new DocumentBuilder()
    .setTitle("Listory")
    .setDescription("Track and analyze your Spotify Listens")
    .setVersion("1.0")
    .addBearerAuth()
    .build();
  const document = SwaggerModule.createDocument(app, options);
  SwaggerModule.setup("api/docs", app, document);

  await app.listen(configService.get<number>("PORT"));
}

bootstrap();