refactor(user): update interceptor

Author: ycdzj

src/app/app.module.ts

@@ -48,7 +48,7 @@ import { ScanResourceAttachments1755504936756 } from 'omniboxd/migrations/175550
 import { SharesAllResources1754471311959 } from 'omniboxd/migrations/1754471311959-shares-all-resources';
 import { ResourcesModule } from 'omniboxd/resources/resources.module';
 import { TraceModule } from 'omniboxd/trace/trace.module';
-import { TracingUserInterceptor } from 'omniboxd/interceptor/tracing-user.interceptor';
+import { UserInterceptor } from 'omniboxd/interceptor/user.interceptor';
 
 @Module({})
 export class AppModule implements NestModule {
@@ -75,7 +75,7 @@ export class AppModule implements NestModule {
         },
         {
           provide: APP_INTERCEPTOR,
-          useClass: TracingUserInterceptor,
+          useClass: UserInterceptor,
         },
       ],
       imports: [

src/interceptor/tracing-user.interceptor.ts renamed to src/interceptor/user.interceptor.ts

@@ -3,25 +3,24 @@ import {
   NestInterceptor,
   ExecutionContext,
   CallHandler,
-  Logger,
 } from '@nestjs/common';
 import { Observable } from 'rxjs';
 import { trace, context } from '@opentelemetry/api';
 
 @Injectable()
-export class TracingUserInterceptor implements NestInterceptor {
-  private readonly logger = new Logger(TracingUserInterceptor.name);
-
+export class UserInterceptor implements NestInterceptor {
   intercept(
     executionContext: ExecutionContext,
     next: CallHandler,
   ): Observable<any> {
     const req = executionContext.switchToHttp().getRequest();
-    const span = trace.getSpan(context.active());
-    if (req.user?.id && span) {
-      span.setAttribute('user.id', req.user.id);
-    }
-    this.logger.log(`span ${span?.spanContext().spanId} user ${req.user?.id}`);
+    const tracer = trace.getTracer('user-interceptor');
+    tracer.startActiveSpan('UserInterceptor', {}, context.active(), (span) => {
+      if (req.user?.id) {
+        span.setAttribute('user.id', req.user.id);
+      }
+      span.end();
+    });
     return next.handle();
   }
 }

src/tracing.ts

@@ -8,8 +8,6 @@ import { ExpressInstrumentation } from '@opentelemetry/instrumentation-express';
 import { NestInstrumentation } from '@opentelemetry/instrumentation-nestjs-core';
 import { TypeormInstrumentation } from '@opentelemetry/instrumentation-typeorm';
 import { isEmpty } from 'omniboxd/utils/is-empty';
-import { Span } from '@opentelemetry/api';
-import { ServerResponse } from 'http';
 
 const env = process.env.ENV || 'unknown';
 const serviceName = `omnibox-backend`;
@@ -45,15 +43,6 @@ if (isTracingEnabled()) {
         ignoreIncomingRequestHook: (req) => {
           return excludedUrls.some((url) => req.url?.includes(url)) || false;
         },
-        responseHook: (span: Span, response: ServerResponse) => {
-          const req = response.req as any;
-          if (req.user?.id) {
-            span.setAttribute('user.id', req.user.id);
-          }
-          console.log(
-            `resp span ${span.spanContext().spanId} user ${req.user?.id}`,
-          );
-        },
       }),
       new ExpressInstrumentation(),
       new NestInstrumentation(),