wrtc

import { RTCPeerConnection } from 'wrtc'; async function createPeerConnectionDemo() { const pc1 = new RTCPeerConnection(); const pc2 = new RTCPeerConnection(); // Exchange ICE candidates pc1.onicecandidate = e => { if (e.candidate) { console.log('PC1 ICE Candidate:', e.candidate.candidate); pc2.addIceCandidate(e.candidate).catch(err => console.error('Error adding ICE candidate to PC2:', err)); } }; pc2.onicecandidate = e => { if (e.candidate) { console.log('PC2 ICE Candidate:', e.candidate.candidate); pc1.addIceCandidate(e.candidate).catch(err => console.error('Error adding ICE candidate to PC1:', err)); } }; // Log connection state changes pc1.onconnectionstatechange = () => console.log('PC1 connection state:', pc1.connectionState); pc2.onconnectionstatechange = () => console.log('PC2 connection state:', pc2.connectionState); // Setup DataChannel communication const dc1 = pc1.createDataChannel('chat'); dc1.onopen = () => console.log('PC1 DataChannel open!'); dc1.onmessage = e => console.log('PC1 received:', e.data); dc1.onclose = () => console.log('PC1 DataChannel closed.'); pc2.ondatachannel = e => { const dc2 = e.channel; console.log('PC2 received DataChannel:', dc2.label); dc2.onopen = () => console.log('PC2 DataChannel open!'); dc2.onmessage = e => console.log('PC2 received:', e.data); dc2.onclose = () => console.log('PC2 DataChannel closed.'); dc2.send('Hello from PC2: Initial message!'); }; try { // Create offer from PC1 const offer = await pc1.createOffer(); await pc1.setLocalDescription(offer); console.log('PC1 Local Description (Offer) set.'); // Set offer on PC2 and create answer await pc2.setRemoteDescription(pc1.localDescription); console.log('PC2 Remote Description (Offer) set.'); const answer = await pc2.createAnswer(); await pc2.setLocalDescription(answer); console.log('PC2 Local Description (Answer) set.'); // Set answer on PC1 await pc1.setRemoteDescription(pc2.localDescription); console.log('PC1 Remote Description (Answer) set.'); console.log('Offer/Answer exchange complete. Waiting for ICE candidates and DataChannel open...'); // Send a message from PC1 after channels are likely open setTimeout(() => { if (dc1.readyState === 'open') { dc1.send('Hello from PC1: How are you?'); } else { console.warn('PC1 DataChannel not yet open to send message.'); } }, 5000); } catch (error) { console.error('WebRTC setup failed:', error); } } createPeerConnectionDemo();