From 9c5b60a19ee22955edfb62f9da25c89dec4b4d2e Mon Sep 17 00:00:00 2001 From: lebaudantoine Date: Fri, 10 Oct 2025 15:18:55 +0200 Subject: [PATCH] wip listen to participant rename event --- src/agents/metadata_extractor.py | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/src/agents/metadata_extractor.py b/src/agents/metadata_extractor.py index 314a458f..2ed5d804 100644 --- a/src/agents/metadata_extractor.py +++ b/src/agents/metadata_extractor.py @@ -119,6 +119,7 @@ class MetadataAgent: """Start listening for participant connection events.""" self.ctx.room.on("participant_connected", self.on_participant_connected) self.ctx.room.on("participant_disconnected", self.on_participant_disconnected) + self.ctx.room.on("participant_name_changed", self.on_participant_name_changed) logger.info("Started listening for participant events") @@ -171,6 +172,7 @@ class MetadataAgent: self.ctx.room.off("participant_connected", self.on_participant_connected) self.ctx.room.off("participant_disconnected", self.on_participant_disconnected) + self.ctx.room.off("participant_name_changed", self.on_participant_name_changed) logger.info("All VAD sessions closed") self.save() @@ -234,6 +236,11 @@ class MetadataAgent: task.add_done_callback(on_close_done) + def on_participant_name_changed(self, participant: rtc.RemoteParticipant): + """Wip.""" + logger.info("Participant's name changed: %s", participant.identity) + self.participants[participant.identity] = participant.name + async def _start_session(self, participant: rtc.RemoteParticipant) -> AgentSession: """Create and start VAD monitoring session for participant.""" if participant.identity in self._sessions: