🔧 propagate pubsub tracing

Author: LemonaOna

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

@@ -1,5 +1,6 @@
 import { PubSub } from '@google-cloud/pubsub';
 import { timeout } from '../../util/timeout';
+import { context, propagation } from '@opentelemetry/api';
 
 const PUBLISH_TIMEOUT = 10_000;
 
@@ -17,6 +18,8 @@ export class PubSubClient<T> {
       throw new Error('No pubsub topic name provided.');
     }
 
+    propagation.inject(context.active(), message);
+
     const json = JSON.stringify(message);
     const dataBuffer = Buffer.from(json);
     const topic = this.client.topic(this.topicName);