fix: JOIN-31071 Update pubsub library to publish and consume avro enc…

…oded messages
join-com · May 4, 2023 · 64288f7 · 64288f7
1 parent 14e5cf9
commit 64288f7
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 1 deletion.
diff --git a/packages/pubsub/package.json b/packages/pubsub/package.json
@@ -21,6 +21,7 @@
     "test": "jest",
     "test:watch": "jest --watch",
     "test:coverage": "jest --collect-coverage",
+    "test:debug": "export NODE_OPTIONS=\"$NODE_OPTIONS --inspect-brk\" && jest --forceExit",
     "lint": "yarn lint:tsc && yarn lint:eslint",
     "lint:eslint": "eslint . --ext .ts --max-warnings 0",
     "lint:tsc": "tsc --noEmit",

diff --git a/packages/pubsub/src/Publisher.ts b/packages/pubsub/src/Publisher.ts
@@ -63,7 +63,7 @@ export class Publisher<T = unknown> {
   private async getTopicType(topic: Topic) {
     // const schemaName = topic.metadata?.schemaSettings?.schema
     const metadata = await topic.getMetadata()
-    const schemaName = metadata[0].schemaSettings?.schema
+    const schemaName = metadata?.[0].schemaSettings?.schema
     if (!schemaName) {
       return undefined
     }

diff --git a/packages/pubsub/src/__tests__/support/pubsubMock.ts b/packages/pubsub/src/__tests__/support/pubsubMock.ts
@@ -56,6 +56,7 @@ export const getTopicMock = ({ subscriptionMock, iamMock }: ITopicMockOption = {
   publishMessage: jest.fn(),
   subscription: jest.fn(() => subscriptionMock),
   iam: iamMock,
+  getMetadata: jest.fn()
 })
 
 export interface IClientMockOption {