Merge pull request #1850 from pipecat-ai/aleix/transcription-message-user-id

TranscriptionMessage: add user_id field

src/pipecat/frames/frames.py

@@ -288,6 +288,7 @@ class TranscriptionMessage:
 
     role: Literal["user", "assistant"]
     content: str
+    user_id: Optional[str] = None
     timestamp: Optional[str] = None
 
 

src/pipecat/processors/transcript_processor.py

@@ -62,7 +62,7 @@ class UserTranscriptProcessor(BaseTranscriptProcessor):
 
         if isinstance(frame, TranscriptionFrame):
             message = TranscriptionMessage(
-                role="user", content=frame.text, timestamp=frame.timestamp
+                role="user", user_id=frame.user_id, content=frame.text, timestamp=frame.timestamp
             )
             await self._emit_update([message])