fix: minor fixes

push-protocol · Sep 29, 2023 · 12e3ca5 · 12e3ca5
1 parent aa93fea
commit 12e3ca5
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 4 deletions.
diff --git a/packages/examples/sdk-backend-node/package.json b/packages/examples/sdk-backend-node/package.json
@@ -11,7 +11,7 @@
   "author": "",
   "license": "ISC",
   "dependencies": {
-    "@pushprotocol/restapi": "@latest",
+    "@pushprotocol/restapi": "0.0.1-alpha.36",
     "@pushprotocol/socket": "^0.5.2"
   }
 }
diff --git a/packages/restapi/src/lib/pushstream/DataModifier.ts b/packages/restapi/src/lib/pushstream/DataModifier.ts
@@ -270,8 +270,17 @@ export class DataModifier {
       Reject: MessageEventType.Reject,
     };
 
-    const eventType: MessageEventType | undefined =
-      eventTypeMap[data.eventType || data.messageCategory];
+  const key = data.eventType || data.messageCategory;
+
+  if (!eventTypeMap[key]) {
+    console.error(
+      'Error in handleChatEvent: Invalid eventType or messageCategory',
+      JSON.stringify(data)
+    );
+    throw new Error('Invalid eventType or messageCategory in data');
+  }
+
+  const eventType: MessageEventType = eventTypeMap[key];
 
     if (eventType) {
       return this.mapToMessageEvent(

diff --git a/packages/restapi/tests/lib/pushstream/initialize.test.ts b/packages/restapi/tests/lib/pushstream/initialize.test.ts
@@ -12,7 +12,7 @@ import { STREAM } from '../../../src/lib/pushstream/pushStreamTypes';
 import * as util from 'util';
 import { ConditionType } from '../../../src/lib';
 
-describe.only('PushStream.initialize functionality', () => {
+describe('PushStream.initialize functionality', () => {
   it('Should initialize new stream and listen to events', async () => {
     const MESSAGE = 'Hey There!!!';