This kinda works but there's an error now?
This commit is contained in:
@@ -42,6 +42,7 @@ from pipecat.frames.frames import (
|
|||||||
SystemFrame,
|
SystemFrame,
|
||||||
TranscriptionFrame,
|
TranscriptionFrame,
|
||||||
TTSSpeakFrame,
|
TTSSpeakFrame,
|
||||||
|
TTSTextFrame,
|
||||||
UserStartedSpeakingFrame,
|
UserStartedSpeakingFrame,
|
||||||
UserStoppedSpeakingFrame,
|
UserStoppedSpeakingFrame,
|
||||||
VADUserStartedSpeakingFrame,
|
VADUserStartedSpeakingFrame,
|
||||||
@@ -608,7 +609,7 @@ async def run_bot(room_url: str, token: str, body: dict) -> None:
|
|||||||
|
|
||||||
human_tts = CartesiaTTSService(
|
human_tts = CartesiaTTSService(
|
||||||
api_key=os.getenv("CARTESIA_API_KEY", ""),
|
api_key=os.getenv("CARTESIA_API_KEY", ""),
|
||||||
voice_id="b7d50908-b17c-442d-ad8d-810c63997ed9",
|
voice_id="a0e99841-438c-4a64-b679-ae501e7d6091",
|
||||||
)
|
)
|
||||||
|
|
||||||
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
|
stt = DeepgramSTTService(api_key=os.getenv("DEEPGRAM_API_KEY"))
|
||||||
@@ -756,13 +757,8 @@ async def run_bot(room_url: str, token: str, body: dict) -> None:
|
|||||||
await super().process_frame(frame, direction)
|
await super().process_frame(frame, direction)
|
||||||
# Log all frame types for comprehensive debugging
|
# Log all frame types for comprehensive debugging
|
||||||
frame_type = type(frame).__name__
|
frame_type = type(frame).__name__
|
||||||
if hasattr(frame, "text") and frame.text:
|
if isinstance(frame, TTSTextFrame):
|
||||||
logger.info(f"🔊 TTS DEBUG ({self._name}): {frame_type} - {frame.text}")
|
logger.info(f"🔊 TTS DEBUG ({self._name}): {frame_type} - {frame.text}")
|
||||||
elif "TTS" in frame_type or "Audio" in frame_type or "Text" in frame_type:
|
|
||||||
logger.info(f"🔊 TTS DEBUG ({self._name}): {frame_type} (no text content)")
|
|
||||||
# Log a few more frame types that might be relevant
|
|
||||||
elif frame_type in ["StartFrame", "EndFrame", "OutputTransportReadyFrame"]:
|
|
||||||
logger.debug(f"🔊 TTS DEBUG ({self._name}): {frame_type}")
|
|
||||||
await self.push_frame(frame, direction)
|
await self.push_frame(frame, direction)
|
||||||
|
|
||||||
voicemail_tts_debug = TTSDebugProcessor("VOICEMAIL")
|
voicemail_tts_debug = TTSDebugProcessor("VOICEMAIL")
|
||||||
@@ -806,7 +802,8 @@ async def run_bot(room_url: str, token: str, body: dict) -> None:
|
|||||||
],
|
],
|
||||||
),
|
),
|
||||||
transport.output(),
|
transport.output(),
|
||||||
# post_transport_debug, # Debug what survives transport.output()
|
post_transport_debug, # Debug what survives transport.output()
|
||||||
|
# human_context_aggregator.assistant(),
|
||||||
]
|
]
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user