fix: skip non json messages (#53)

Author: obeaudet-ueat

lib/gc-pubsub.server.spec.ts

@@ -183,6 +183,23 @@ describe('GCPubSubServer', () => {
       });
       expect(handler.calledOnce).to.be.true;
     });
+
+    it('should return undefined when data is not in JSON format', async () => {
+      const result = await server.handleMessage({
+        ackId: 'id',
+        // @ts-ignore
+        publishTime: new Date(),
+        attributes: {},
+        id: 'id',
+        received: 0,
+        deliveryAttempt: 1,
+        ack: () => {},
+        modAck: () => {},
+        nack: () => {},
+        data: Buffer.from('text'),
+      });
+      expect(result).to.be.undefined;
+    });
   });
 
   describe('sendMessage', () => {

lib/gc-pubsub.server.ts

@@ -155,7 +155,15 @@ export class GCPubSubServer
 
   public async handleMessage(message: Message) {
     const { data, attributes } = message;
-    const rawMessage = JSON.parse(data.toString());
+    let rawMessage;
+    try {
+      rawMessage = JSON.parse(data.toString());
+    } catch (error: any) {
+      this.logger.error(
+        `Unsupported JSON message data format for message '${message.id}'`,
+      );
+      return;
+    }
 
     let packet;
     if (attributes.pattern) {