Merge pull request #687 from SuperViz/feat/http-message

SuperViz · Jun 3, 2024 · fe993bb · fe993bb
2 parents b16ad68 + 181255b
commit fe993bb
Show file tree

Hide file tree

Showing 5 changed files with 11 additions and 10 deletions.
diff --git a/package.json b/package.json
@@ -78,7 +78,7 @@
     "yargs": "^17.7.2"
   },
   "dependencies": {
-    "@superviz/socket-client": "1.4.0",
+    "@superviz/socket-client": "1.5.1",
     "ably": "^1.2.45",
     "bowser": "^2.11.0",
     "bowser-jr": "^1.0.6",

diff --git a/src/components/realtime/channel.ts b/src/components/realtime/channel.ts
@@ -133,9 +133,10 @@ export class Channel extends Observable {
       this.logger.log('message received', event);
       this.publishEventToClient(event.data.name, {
         data: event.data.payload,
-        participantId: event.presence.id,
+        participantId: event?.presence?.id || null,
         name: event.data.name,
         timestamp: event.timestamp,
+        connectionId: event.connectionId,
       } as RealtimeMessage);
     });
   }
@@ -174,9 +175,9 @@ export class Channel extends Observable {
                 data: event.data.payload,
                 connectionId: event.connectionId,
                 name: event.data.name,
-                participantId: event.presence.id,
+                participantId: event.presence?.id,
                 timestamp: event.timestamp,
-              });
+              } as RealtimeMessage);
 
               return group;
             },

diff --git a/src/components/realtime/types.ts b/src/components/realtime/types.ts
@@ -25,7 +25,7 @@ export type RealtimeData = {
 export type RealtimeMessage = {
   name: string;
   connectionId: string;
-  participantId: string;
+  participantId: string | null;
   data: unknown;
   timestamp: number;
 };
diff --git a/src/core/index.ts b/src/core/index.ts
@@ -141,7 +141,7 @@ const init = async (apiKey: string, options: SuperVizSdkOptions): Promise<Launch
   ApiService.createOrUpdateParticipant({
     name: participant.name,
     participantId: participant.id,
-    avatar: participant.avatar?.imageUrl,
+    avatar: participant.avatar?.imageUrl, 
   });
 
   return LauncherFacade(options);

diff --git a/yarn.lock b/yarn.lock
@@ -2481,10 +2481,10 @@
   resolved "https://registry.yarnpkg.com/@socket.io/component-emitter/-/component-emitter-3.1.0.tgz#96116f2a912e0c02817345b3c10751069920d553"
   integrity sha512-+9jVqKhRSpsc591z5vX+X5Yyw+he/HCB4iQ/RYxw35CEPaY1gnsNE43nf9n9AaYjAQrTiI/mOwKUKdUs9vf7Xg==
 
-"@superviz/socket-client@1.4.0":
-  version "1.4.0"
-  resolved "https://registry.yarnpkg.com/@superviz/socket-client/-/socket-client-1.4.0.tgz#374326131dd4a89f2d8f71e8be1305ed55311921"
-  integrity sha512-Ue66/5dxhGaPxqiFE3KWjusfp2FCBmT8vPJfq8FMD/ZCR6ac/tqnKqLrMtpz3oA6/51CQW9tfoSuqaXC+hrKWw==
+"@superviz/socket-client@1.5.1":
+  version "1.5.1"
+  resolved "https://registry.yarnpkg.com/@superviz/socket-client/-/socket-client-1.5.1.tgz#db1d14f6fbd29ac5e8cf3241dcf8b80cc42e814e"
+  integrity sha512-T+9vbYsKDPuHHrtKWZHLqHJTQ9uL4rQm8xm9OqqIr2E+c6kXkSIZsW40BKK6r45BTX4FT2i8rIS31BxptG5PRQ==
   dependencies:
     "@reactivex/rxjs" "^6.6.7"
     debug "^4.3.4"