Update main.py

main.py

@@ -5,7 +5,7 @@ import time
 import logging
 from pipecat.frames.frames import (
     TextFrame, UserStartedSpeakingFrame, UserStoppedSpeakingFrame,
-    TTSStartedFrame, TTSEndFrame
+    TTSStartedFrame, BotStoppedSpeakingFrame
 )
 from pipecat.pipeline.pipeline import Pipeline
 from pipecat.pipeline.runner import PipelineRunner
@@ -61,12 +61,12 @@ class SilenceAndCallLogicProcessor(FrameProcessor):
         self.last_activity_ts = time.time()
         self.silence_prompts_count = 0
 
-    async def process_frame(self, frame: Frame, direction: FrameDirection):
+    async def process_frame(self, frame, direction: FrameDirection):
         if isinstance(frame, (UserStartedSpeakingFrame, TextFrame)) and direction == FrameDirection.UPSTREAM:
             self._reset_activity_timer()
         if isinstance(frame, TTSStartedFrame) and direction == FrameDirection.DOWNSTREAM:
             self._bot_is_speaking = True
-        elif isinstance(frame, TTSEndFrame) and direction == FrameDirection.DOWNSTREAM:
+        elif isinstance(frame, BotStoppedSpeakingFrame) and direction == FrameDirection.DOWNSTREAM:
             self._bot_is_speaking = False
             self.last_activity_ts = time.time()
         await self.push_frame(frame, direction)
@@ -152,16 +152,12 @@ class PhoneChatbotApp:
             return False
 
     async def run(self):
-        # Validate environment variables (Hugging Face Secrets)
-        required_keys = [
-            "deepgram", "elevenlabs", "dailyco", "azure_openai"
-        ]
+        required_keys = ["deepgram", "elevenlabs", "dailyco", "azure_openai"]
         missing_keys = [key for key in required_keys if not os.environ.get(key)]
         if missing_keys:
             logger.error(f"Missing Hugging Face Secrets: {', '.join(missing_keys)}")
             sys.exit(1)
 
-        # Validate ElevenLabs voice ID
         voice_id = os.environ.get("ELEVENLABS_VOICE_ID", "cgSgspJ2msm6clMCkdW9")
         if not self.validate_voice_id(voice_id):
             logger.error(f"Invalid ElevenLabs voice ID: {voice_id}")
@@ -212,4 +208,4 @@ async def main():
     await app.run()
 
 if __name__ == "__main__":
-    asyncio.run(main())
+    asyncio.run(main())