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

rtvi: add on_bot_ready event

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-09-25 16:35:49 -07:00
parent c4e94e280e
commit f06aa300d0
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/pipecat/processors/frameworks/rtvi.py
View File

@@ -324,6 +324,8 @@ class RTVIProcessor(FrameProcessor):
self._message_task = self.get_event_loop().create_task(self._message_task_handler()) self._message_task = self.get_event_loop().create_task(self._message_task_handler())
self._message_queue = asyncio.Queue() self._message_queue = asyncio.Queue()
self._register_event_handler("on_bot_ready")
def register_action(self, action: RTVIAction): def register_action(self, action: RTVIAction):
id = self._action_id(action.service, action.action) id = self._action_id(action.service, action.action)
self._registered_actions[id] = action self._registered_actions[id] = action
@@ -624,8 +626,9 @@ class RTVIProcessor(FrameProcessor):
async def _maybe_send_bot_ready(self): async def _maybe_send_bot_ready(self):
if self._pipeline_started and self._client_ready: if self._pipeline_started and self._client_ready:
await self._send_bot_ready()
await self._update_config(self._config, False) await self._update_config(self._config, False)
await self._send_bot_ready()
await self._call_event_handler("on_bot_ready")
async def _send_bot_ready(self): async def _send_bot_ready(self):
if not self._params.send_bot_ready: if not self._params.send_bot_ready: