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()