fix: add conversationId to transcriptions

README.md

@@ -37,6 +37,9 @@ activateTranscriptions({
             sentiment: false,
         },
     },
+    symblStreamingMessageCallback: (event) => { // optional. If you need it for a custom use case
+        console.log('event from symbl')
+    },
 });
 ```
 
@@ -61,7 +64,10 @@ activateTranscriptions({
         speaker: {
             email: '[email protected]',
         }
-    }
+    },
+    symblStreamingMessageCallback: (event) => { // optional. If you need it for a custom use case
+        console.log('event from symbl')
+    },
 });
 ```
 

demo/index.ts

@@ -12,23 +12,20 @@
 const init = async () => {
     try {
         const params = new URLSearchParams(window.location.search);
-        const roomName = params.get('roomName') || '';
         const authToken = params.get('authToken') || '';
         const symblAccessToken = params.get('symblAccessToken') || '';
 
-        if (!authToken || (roomName && !authToken)) {
-            alert('Please pass authToken (and roomName, if you are using v1 APIs) in query params');
+        if (!authToken) {
+            alert('Please pass authToken in query params');
             return;
         }
         if (!symblAccessToken) {
             alert('Please pass symblAccessToken in query params');
             return;
         }
 
         const meeting = await DyteClient.init({
             authToken,
-            roomName,
-            apiBase: 'https://api.dyte.io',
             defaults: {
                 audio: false,
                 video: false,
@@ -84,7 +81,7 @@
             removeTranscriptionsListener({ meeting });
         });
     } catch (e) {
         console.log(e);
     }
 };
 

src/param_types.ts

@@ -10,6 +10,7 @@ export interface ActivateTranscriptionsConfig {
     symblStartRequestParams?: { // https://docs.symbl.ai/reference/streaming-api-reference#start_request
         [key:string]: any,
     },
+    symblStreamingMessageCallback?: (event: any) => void,
 }
 
 export interface DeactivateTranscriptionsConfig {

src/symbl_transcriptions.ts

@@ -2,8 +2,10 @@
 import audioTranscriptionMiddleware from './audio_middleware';
 import { ActivateTranscriptionsConfig, DeactivateTranscriptionsConfig } from './param_types';
 import {
+    getConversationId,
     getPeerIdBySymblId,
     getWebSocket,
+    setConversationId,
     setPeerIdForSymblId,
     setTranscriptions,
     setWebSocket,
@@ -22,6 +24,7 @@
     connectionId,
     speakerUserId,
     symblStartRequestParams = {},
+    symblStreamingMessageCallback,
 }: ActivateTranscriptionsConfig) {
     // As a fail-safe, deactivateTranscriptions if activateTranscriptions function is called twice
     // eslint-disable-next-line no-use-before-define
@@ -37,9 +40,14 @@
     ws.onmessage = async (event) => {
         const data = JSON.parse(event.data);
         if (data.type === 'error') {
             console.error('Symbl error: ', data);
             return;
         }
+        if (data.type === 'message' && data.message.type === 'conversation_created') {
+            // console.log('Symbl conversation created: ', data);
+            setConversationId(data.message.data.conversationId);
+        }
+
         if (data.type === 'message_response') {
             data.messages?.forEach((message: any) => {
                 // console.log('Live transcript (more accurate): ', message.payload.content, data);
@@ -56,6 +64,7 @@
                             peerId: meeting.self.id,
                             displayName: meeting.self.name,
                             id: message.id,
+                            conversationId: getConversationId(),
                         },
                     );
                 }
@@ -80,10 +89,16 @@
                         endTimeISO: data.message.duration?.endTime || new Date().toISOString(),
                         peerId: meeting.self.id,
                         displayName: meeting.self.name,
+                        conversationId: getConversationId(),
                     },
                 );
             }
         }
+
+        // Call the callback
+        if (symblStreamingMessageCallback) {
+            symblStreamingMessageCallback(data);
+        }
     };
 
     // Fired when the WebSocket closes unexpectedly due to an error or lost connetion

src/transcriptions_building_blocks.ts

@@ -3,6 +3,7 @@ import type { BroadcastMessagePayload } from '@dytesdk/web-core';
 let ws: WebSocket;
 
 let transcriptions: BroadcastMessagePayload[] = [];
+let conversationId: string = '';
 
 const symblIdToPeerIdMap: {[key: string]: string} = {};
 
@@ -29,11 +30,21 @@ function setPeerIdForSymblId(symblId: string, peerId: string) {
     symblIdToPeerIdMap[symblId] = peerId;
 }
 
+function getConversationId() {
+    return conversationId;
+}
+
+function setConversationId(newConversationId: string) {
+    conversationId = newConversationId;
+}
+
 export {
     getWebSocket,
     setWebSocket,
     getTranscriptions,
     setTranscriptions,
     getPeerIdBySymblId,
     setPeerIdForSymblId,
+    getConversationId,
+    setConversationId,
 };