aiortc_webrtc_data_channel_messaging_with_asyncio.py

1import asyncio
2from aiortc import RTCPeerConnection, RTCSessionDescription
3
4async def run():
5    # create peer connection
6    pc = RTCPeerConnection()
7
8    # create a data channel
9    channel = pc.createDataChannel("chat")
10    print(f"Created channel: {channel.label}")
11
12    @channel.on("open")
13    def on_open():
14        print("Channel is open, sending message...")
15        channel.send("Hello from aiortc!")
16
17    @channel.on("message")
18    def on_message(message):
19        print(f"Received message: {message}")
20
21    # create offer
22    offer = await pc.createOffer()
23    await pc.setLocalDescription(offer)
24
25    # In a real application, you would send the offer to the remote peer
26    # and receive an answer. For this local example, we just print the SDP.
27    print("Local SDP offer created:")
28    print(pc.localDescription.sdp)
29
30    # Clean up (in a real app, keep the loop running to handle events)
31    await pc.close()
32
33if __name__ == "__main__":
34    asyncio.run(run())