📈 add pubsub instrumentation library

Author: LemonaOna

package-lock.json

@@ -89,6 +89,7 @@
     "lodash": "^4.17.21",
     "lru-cache": "^7.13.1",
     "moment": "^2.29.4",
+    "opentelemetry-instrumentation-pubsub": "^2.1.0",
     "rate-limiter-flexible": "^2.3.11",
     "redis": "^4.2.0",
     "zod": "^3.23.8"

package.json

@@ -29,7 +29,7 @@ export class PubSubClient<T> {
     });
 
     await Promise.race([
-      topic.publishMessage({ data: dataBuffer, orderingKey }),
+      topic.publishMessage({ data: dataBuffer, orderingKey, attributes: {} }),
       timeout(
         PUBLISH_TIMEOUT,
         'Could not publish message in time. Did you forget to authenticate with GCP? (gcloud auth application-default login)',

src/models/pubsub/pubsub-client.model.ts

@@ -4,6 +4,7 @@ import { SimpleSpanProcessor } from '@opentelemetry/sdk-trace-base';
 import { HttpInstrumentation } from '@opentelemetry/instrumentation-http';
 import { ExpressInstrumentation } from '@opentelemetry/instrumentation-express';
 import { getNodeAutoInstrumentations } from '@opentelemetry/auto-instrumentations-node';
+import { PubSubInstrumentation } from 'opentelemetry-instrumentation-pubsub';
 const apikey = process.env.BACKEND_TRACING_API_KEY;
 const tracingEnabledEnv = process.env.BACKEND_TRACING_ENABLED;
 
@@ -19,6 +20,7 @@ export const otelSDK = new NodeSDK({
   instrumentations: [
     new HttpInstrumentation(),
     new ExpressInstrumentation(),
+    new PubSubInstrumentation(),
     getNodeAutoInstrumentations({
       '@opentelemetry/instrumentation-fs': { enabled: false },
     }),