NestJS リクエストとワークフロー Telemetry

@Injectable()
export class OutcomeInterceptor implements NestInterceptor {
  intercept(context: ExecutionContext, next: CallHandler) {
    const request = context.switchToHttp().getRequest();
    const response = context.switchToHttp().getResponse();
    const startedAt = performance.now();
    let errorType: string | undefined;

    return next.handle().pipe(
      catchError((error) => {
        errorType = classifyError(error);
        throw error;
      }),
      finalize(() => {
        const statusCode = response.statusCode;
        void telemetry.log("api_request_completed", {
          request_id: request.id,
          controller: context.getClass().name,
          handler: context.getHandler().name,
          route_template: resolveRouteTemplate(context),
          method: request.method,
          status_code: statusCode,
          status: statusCode >= 500 ? "failed" : "success",
          latency_ms: Math.round(performance.now() - startedAt),
          error_type: errorType,
          release: process.env.APP_RELEASE,
        }).catch(recordTelemetryFailure);
      }),
    );
  }
}