Remove dead code related to the TTS Event publishing

Author: kPatch

coffee_ws/src/coffee_voice_agent/coffee_voice_agent/voice_agent_bridge.py

@@ -21,7 +21,7 @@
 from rclpy.callback_groups import ReentrantCallbackGroup
 from std_msgs.msg import String, Bool
 from geometry_msgs.msg import Twist
-from coffee_voice_agent_msgs.msg import TtsEvent, AgentState, EmotionState, ConversationItem, AgentStatus, ToolEvent
+from coffee_voice_agent_msgs.msg import AgentState, EmotionState, ConversationItem, AgentStatus, ToolEvent
 
 try:
     import websockets
@@ -77,13 +77,6 @@ def __init__(self):
             callback_group=self.callback_group
         )
 
-        self.tts_events_pub = self.create_publisher(
-            TtsEvent,
-            'voice_agent/tts_events',
-            10,
-            callback_group=self.callback_group
-        )
-        
         self.agent_status_pub = self.create_publisher(
             AgentStatus,
             'voice_agent/status',
@@ -243,36 +236,6 @@ async def _handle_websocket_message(self, message: str):
                 # Handle startup/ready events from voice agent
                 self.get_logger().info(f"Voice agent startup: {data.get('message', 'Ready')} (version: {data.get('version', 'unknown')})")
 
-            elif message_type == 'TTS_EVENT':
-                # Handle TTS started/finished events - parse nested data structure
-                event_data = data.get('data', {})
-                event = event_data.get('event', 'unknown')
-                emotion = event_data.get('emotion', 'unknown')
-                source = event_data.get('source', 'unknown')
-                text = event_data.get('text', '')
-                text_preview = text[:50] + "..." if len(text) > 50 else text
-                
-                self.get_logger().info(f"TTS {event}: emotion={emotion}, source={source}, text='{text_preview}'")
-                
-                # Publish TTS event to ROS2 topic
-                tts_msg = TtsEvent()
-                tts_msg.event = event
-                tts_msg.emotion = emotion
-                tts_msg.text = text_preview  # Use truncated text for efficiency
-                tts_msg.source = source
-                # Parse timestamp if provided, otherwise use current time
-                timestamp_str = event_data.get('timestamp')
-                if timestamp_str:
-                    try:
-                        dt = datetime.datetime.fromisoformat(timestamp_str.replace('Z', '+00:00'))
-                        tts_msg.timestamp.sec = int(dt.timestamp())
-                        tts_msg.timestamp.nanosec = int((dt.timestamp() % 1) * 1e9)
-                    except:
-                        tts_msg.timestamp = self.get_clock().now().to_msg()
-                else:
-                    tts_msg.timestamp = self.get_clock().now().to_msg()
-                self.tts_events_pub.publish(tts_msg)
-                
             elif message_type == 'AGENT_STATUS':
                 # Handle unified agent status events
                 status_data = data.get('data', {})

coffee_ws/src/coffee_voice_agent/scripts/state/state_manager.py

@@ -574,20 +574,6 @@ def get_random_greeting(self) -> str:
 
         return get_random_greeting()
 
-    async def _send_tts_event(self, event: str, text: str, emotion: str, source: str):
-        """Send TTS event through agent's WebSocket connection"""
-        if self.agent and hasattr(self.agent, '_send_websocket_event'):
-            event_data = {
-                "event": event,
-                "text": text[:100] + "..." if len(text) > 100 else text,  # Truncate long text
-                "emotion": emotion,
-                "source": source,
-                "timestamp": datetime.now().isoformat()
-            }
-            await self.agent._send_websocket_event("TTS_EVENT", event_data)
-        else:
-            logger.debug(f"Cannot send TTS {event} event - no agent WebSocket connection")
-
     async def _send_agent_status(self, behavioral_mode: str, speech_status: str, conversation_phase: str = ""):
         """Send unified agent status through agent's WebSocket connection"""
         if self.agent and hasattr(self.agent, '_send_websocket_event'):