From 98fba525adc0667898ea9a72ca1f6aa4ba5f8231 Mon Sep 17 00:00:00 2001 From: lebaudantoine Date: Fri, 10 Oct 2025 16:45:51 +0200 Subject: [PATCH] wip lint the metadata agent --- src/agents/metadata_extractor.py | 15 +++++++++++---- 1 file changed, 11 insertions(+), 4 deletions(-) diff --git a/src/agents/metadata_extractor.py b/src/agents/metadata_extractor.py index aca32e57..d324da3c 100644 --- a/src/agents/metadata_extractor.py +++ b/src/agents/metadata_extractor.py @@ -67,6 +67,7 @@ class VADAgent(Agent): async def on_enter(self) -> None: """Initialize VAD monitoring for this participant.""" + @self.session.on("user_state_changed") def on_user_state(event): timestamp = datetime.now(timezone.utc) @@ -128,23 +129,29 @@ class MetadataAgent: logger.info("Started listening for participant events") - async def on_chat_message_received(self, reader: rtc.TextStreamReader, participant_identity: str): + async def on_chat_message_received( + self, reader: rtc.TextStreamReader, participant_identity: str + ): """Wip.""" full_text = await reader.read_all() - logger.info("Received chat message from %s: '%s'", participant_identity, full_text) + logger.info( + "Received chat message from %s: '%s'", participant_identity, full_text + ) self.events.append( MetadataEvent( participant_id=participant_identity, type="chat_received", timestamp=datetime.now(timezone.utc), - data=full_text + data=full_text, ) ) def handle_chat_stream(self, reader, participant_identity): """Wip.""" - task = asyncio.create_task(self.on_chat_message_received(reader, participant_identity)) + task = asyncio.create_task( + self.on_chat_message_received(reader, participant_identity) + ) self._tasks.add(task) task.add_done_callback(lambda _: self._tasks.remove(task))