Skip to content

Commit 7c42549

Browse files
committed
feat: emit session ready signal
1 parent fc95a5d commit 7c42549

File tree

4 files changed

+8
-1
lines changed

4 files changed

+8
-1
lines changed

src/modules/StreamingClient.ts

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -282,9 +282,13 @@ export class StreamingClient {
282282
chatMessage.correlationId,
283283
);
284284
break;
285+
case SignalMessageAction.SESSION_READY:
286+
const sessionId = signalMessage.sessionId as string;
287+
this.publicEventEmitter.emit(AnamEvent.SESSION_READY, sessionId);
288+
break;
285289
default:
286290
console.error(
287-
'StreamingClient - onSignalMessage: unknown signal message action type',
291+
'StreamingClient - onSignalMessage: unknown signal message action type. Is your anam-sdk version up to date?',
288292
signalMessage,
289293
);
290294
}

src/types/events/public/AnamEvent.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,4 +8,5 @@ export enum AnamEvent {
88
VIDEO_PLAY_STARTED = 'VIDEO_PLAY_STARTED',
99
AUDIO_STREAM_STARTED = 'AUDIO_STREAM_STARTED',
1010
TALK_STREAM_INTERRUPTED = 'TALK_STREAM_INTERRUPTED',
11+
SESSION_READY = 'SESSION_READY',
1112
}

src/types/events/public/EventCallbacks.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,4 +12,5 @@ export type EventCallbacks = {
1212
[AnamEvent.VIDEO_PLAY_STARTED]: () => void;
1313
[AnamEvent.AUDIO_STREAM_STARTED]: (audioStream: MediaStream) => void;
1414
[AnamEvent.TALK_STREAM_INTERRUPTED]: (correlationId: string) => void;
15+
[AnamEvent.SESSION_READY]: (sessionId: string) => void;
1516
};

src/types/signalling/SignalMessage.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@ export enum SignalMessageAction {
77
WARNING = 'warning',
88
TALK_STREAM_INTERRUPTED = 'talkinputstreaminterrupted',
99
TALK_STREAM_INPUT = 'talkstream',
10+
SESSION_READY = 'sessionready',
1011
}
1112

1213
export interface SignalMessage {

0 commit comments

Comments
 (0)