fix: expose enabled use attributes feature for server

lib/gc-pubsub.client.spec.ts

@@ -209,6 +209,7 @@ describe('GCPubSubClient', () => {
         expect(message.json).to.be.eql(msg.data);
         expect(message.attributes.pattern).to.be.eql(pattern);
         expect(message.attributes.id).to.be.not.empty;
+        expect(message.attributes.useAttributes).to.be.eql('true');
       });
     });
   });
@@ -355,6 +356,7 @@ describe('GCPubSubClient', () => {
         const message = topicMock.publishMessage.getCall(0).args[0];
         expect(message.json).to.be.eql(msg.data);
         expect(message.attributes.pattern).to.be.eql(msg.pattern);
+        expect(message.attributes.useAttributes).to.be.eql('true');
       });
 
       it('should throw error', async () => {

lib/gc-pubsub.client.ts

@@ -180,6 +180,7 @@ export class GCPubSubClient extends ClientProxy {
         json: serializedPacket.data,
         attributes: {
           pattern: serializedPacket.pattern,
+          useAttributes: 'true',
         },
       });
     } else {
@@ -206,6 +207,7 @@ export class GCPubSubClient extends ClientProxy {
                 replyTo: this.replyTopicName,
                 pattern: serializedPacket.pattern,
                 id: serializedPacket.id,
+                useAttributes: 'true',
               },
             })
             .catch((err) => callback({ err }));

lib/gc-pubsub.server.ts

@@ -151,7 +151,14 @@ export class GCPubSubServer extends Server implements CustomTransportStrategy {
       : JSON.stringify(packet.pattern);
 
     const context = new GCPubSubContext([message, pattern]);
-    const correlationId = packet.id || attributes.id;
+
+    let correlationId: string;
+
+    if (attributes.useAttibutes === 'true') {
+      correlationId = attributes.id;
+    } else {
+      correlationId = packet.id;
+    }
 
     if (isUndefined(correlationId)) {
       return this.handleEvent(pattern, packet, context);

tests/src/gc-pubsub.controller.ts

@@ -88,11 +88,14 @@ export class GCPubSubController implements OnApplicationShutdown {
 
   @Post('notify')
   async sendNotification(): Promise<any> {
-    return this.client.emit<number>('notification', true);
+    return this.client.emit<{ notification: boolean; id: string }>(
+      'notification',
+      { notification: true, id: 'id' },
+    );
   }
 
   @EventPattern('notification')
-  eventHandler(data: boolean) {
-    GCPubSubController.IS_NOTIFIED = data;
+  eventHandler(data: { notification: boolean; id: string }) {
+    GCPubSubController.IS_NOTIFIED = data.notification;
   }
 }