transports(daily): expose on_app_message

CHANGELOG.md

@@ -9,6 +9,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Added
 
+- Exposed Daily transport `on_app_message` event.
+
 - Added Daily transport `on_call_state_updated` event.
 
 - Added Daily transport `start_recording()`, `stop_recording` and

src/pipecat/transports/services/daily.py

@@ -671,6 +671,7 @@ class DailyTransport(BaseTransport):
         # these handlers.
         self._register_event_handler("on_joined")
         self._register_event_handler("on_left")
+        self._register_event_handler("on_app_message")
         self._register_event_handler("on_call_state_updated")
         self._register_event_handler("on_dialout_connected")
         self._register_event_handler("on_dialout_stopped")
@@ -752,6 +753,7 @@ class DailyTransport(BaseTransport):
     def _on_app_message(self, message: Any, sender: str):
         if self._input:
             self._input.push_app_message(message, sender)
+        self.on_app_message(message, sender)
 
     def _on_call_state_updated(self, state: str):
         self.on_call_state_updated(state)
@@ -828,6 +830,9 @@ class DailyTransport(BaseTransport):
     def on_left(self):
         pass
 
+    def on_app_message(self, message, sender):
+        pass
+
     def on_call_state_updated(self, state):
         pass