From dae6e9a43114509e57dcd054ca24c52e8dbd85d1 Mon Sep 17 00:00:00 2001 From: yumoqing Date: Mon, 2 Sep 2024 10:36:07 +0800 Subject: [PATCH] bugfix --- rtcllm/rtc.py | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/rtcllm/rtc.py b/rtcllm/rtc.py index 276e037..885930d 100644 --- a/rtcllm/rtc.py +++ b/rtcllm/rtc.py @@ -84,7 +84,7 @@ class RTCLLM: pc = peer.pc print(f'************************************{pc.connectionState=}') if pc.connectionState == 'connected': - peer.dc = await pc.createDataChannel(peer.info.name) + peer.dc = pc.createDataChannel(peer.info.name) return if pc.connectionState == 'closed': await pc.close() @@ -103,9 +103,14 @@ class RTCLLM: if pc is None: print(f'{self.peers=}, {data=}') return - pc.on("connectionstate", partial(self.pc_connectionState_changed, data['from'].id)) + pc.on("connectionstatechange", partial(self.pc_connectionState_changed, data['from'].id)) pc.on('track', partial(self.pc_track, data['from'].id)) pc.on('icecandidate', partial(self.on_icecandidate, pc)) + player = MediaPlayer('/Users/ymq/v/1.mp4') + if player: + pc.addTrack(player.audio) + pc.addTrack(player.video) + offer = RTCSessionDescription(** data.offer) await pc.setRemoteDescription(offer) answer = await pc.createAnswer()