From 61bff05919251d5c35615753f48aacb4a3ebd9b8 Mon Sep 17 00:00:00 2001 From: "rosetta-livekit-bot[bot]" <282703043+rosetta-livekit-bot[bot]@users.noreply.github.com> Date: Thu, 25 Jun 2026 19:13:08 +0000 Subject: [PATCH] fix(agents): stop forwarding frame processor info --- .changeset/frame-processor-client-sdk-info.md | 5 +++++ agents/src/voice/room_io/_input.ts | 20 ------------------- 2 files changed, 5 insertions(+), 20 deletions(-) create mode 100644 .changeset/frame-processor-client-sdk-info.md diff --git a/.changeset/frame-processor-client-sdk-info.md b/.changeset/frame-processor-client-sdk-info.md new file mode 100644 index 000000000..bc43de371 --- /dev/null +++ b/.changeset/frame-processor-client-sdk-info.md @@ -0,0 +1,5 @@ +--- +'@livekit/agents': patch +--- + +Stop forwarding frame processor stream info and LiveKit credentials from room input handling. diff --git a/agents/src/voice/room_io/_input.ts b/agents/src/voice/room_io/_input.ts index 6ede89e2f..9552c3992 100644 --- a/agents/src/voice/room_io/_input.ts +++ b/agents/src/voice/room_io/_input.ts @@ -52,7 +52,6 @@ export class ParticipantAudioInputStream extends AudioInput { this.room.on(RoomEvent.TrackSubscribed, this.onTrackSubscribed); this.room.on(RoomEvent.TrackUnpublished, this.onTrackUnpublished); - this.room.on(RoomEvent.TokenRefreshed, this.onTokenRefreshed); } setParticipant(participant: RemoteParticipant | string | null) { @@ -153,27 +152,9 @@ export class ParticipantAudioInputStream extends AudioInput { outputRate: this.sampleRate, }), ); - this.frameProcessor?.onStreamInfoUpdated({ - participantIdentity: participant.identity, - roomName: this.room.name!, - publicationSid: publication.sid!, - }); - this.frameProcessor?.onCredentialsUpdated({ - token: this.room.token!, - url: this.room.serverUrl!, - }); return true; }; - private onTokenRefreshed = () => { - if (this.room.token && this.room.serverUrl) { - this.frameProcessor?.onCredentialsUpdated({ - token: this.room.token, - url: this.room.serverUrl, - }); - } - }; - private createStream(track: RemoteTrack): ReadableStream { return new AudioStream(track, { sampleRate: this.sampleRate, @@ -186,7 +167,6 @@ export class ParticipantAudioInputStream extends AudioInput { override async close() { this.room.off(RoomEvent.TrackSubscribed, this.onTrackSubscribed); this.room.off(RoomEvent.TrackUnpublished, this.onTrackUnpublished); - this.room.off(RoomEvent.TokenRefreshed, this.onTokenRefreshed); this.closeStream(); await super.close();