wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Improving the video transform feedback when we are connecting, and cleaning the pc_id when disconnected.

Browse Source
This commit is contained in:
Filipi Fuchter
2025-03-12 11:49:33 -03:00
parent f24c5b0aa7
commit f8e33d8b7b
2 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
examples/aiortc/video-transform/client/typescript/src/app.ts
View File

@@ -129,6 +129,9 @@ class WebRTCApp {
private async start(): Promise<void> { private async start(): Promise<void> {
this.clearAllLogs() this.clearAllLogs()
this.connectBtn.disabled = true;
this.updateStatus("Connecting")
const audioDevice = this.audioInput.value; const audioDevice = this.audioInput.value;
const audioCodec = this.audioCodec.value; const audioCodec = this.audioCodec.value;
const videoDevice = this.videoInput.value; const videoDevice = this.videoInput.value;

9
examples/aiortc/video-transform/client/typescript/src/smallWebRTCTransport.ts
View File

@@ -74,7 +74,7 @@ export class SmallWebRTCTransport {
if (connectionState == 'connected') { if (connectionState == 'connected') {
this._callbacks.onConnected() this._callbacks.onConnected()
} else if (connectionState == 'disconnected') { } else if (connectionState == 'disconnected') {
this._callbacks.onDisconnected() this.handleDisconnected()
} }
} }
@@ -167,6 +167,11 @@ export class SmallWebRTCTransport {
return this.pc!.getTransceivers()[1]; return this.pc!.getTransceivers()[1];
} }
private handleDisconnected() {
this.pc_id = null
this._callbacks.onDisconnected()
}
async start(audioDevice: string | undefined, audioCodec: string, videoCodec: string, videoDevice: string | undefined): Promise<void> { async start(audioDevice: string | undefined, audioCodec: string, videoCodec: string, videoDevice: string | undefined): Promise<void> {
this.pc = this.createPeerConnection(); this.pc = this.createPeerConnection();
this.addInitialTransceivers(); this.addInitialTransceivers();
@@ -299,7 +304,7 @@ export class SmallWebRTCTransport {
this.pc.close(); this.pc.close();
// For some reason after we close the peer connection, it is not triggering the listeners // For some reason after we close the peer connection, it is not triggering the listeners
this._callbacks.onDisconnected() this.handleDisconnected()
} }
private async getAllDevices() { private async getAllDevices() {