wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Sending a new signalling message peerLeft.

Browse Source
This commit is contained in:
Filipi Fuchter
2025-04-11 15:35:50 -03:00
parent 6378a8ccd3
commit 255666925b
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/pipecat/transports/network/webrtc_connection.py
View File

@@ -43,6 +43,8 @@ class TrackStatusMessage(BaseModel):
class RenegotiateMessage(BaseModel): class RenegotiateMessage(BaseModel):
type: Literal["renegotiate"] = "renegotiate" type: Literal["renegotiate"] = "renegotiate"
class PeerLeftMessage(BaseModel):
type: Literal["peerLeft"] = "peerLeft"
class SignallingMessage: class SignallingMessage:
Inbound = Union[TrackStatusMessage] # in case we need to add new messages in the future Inbound = Union[TrackStatusMessage] # in case we need to add new messages in the future
@@ -272,9 +274,9 @@ class SmallWebRTCConnection(BaseObject):
logger.warning("Video transceiver not found. Cannot replace video track.") logger.warning("Video transceiver not found. Cannot replace video track.")
async def disconnect(self): async def disconnect(self):
# TODO: we should trigger something to know we are leaving self.send_app_message(
# so the client does not try to reconnect {"type": SIGNALLING_TYPE, "message": PeerLeftMessage().model_dump()}
# Like participant left )
await self._close() await self._close()
async def _close(self): async def _close(self):