WebRTC client & server

bin/wasm-node/javascript/src/webrtc/index.ts

@@ -210,20 +210,30 @@ export default function(targetIp: string, protocol: 'tcp' | 'udp', targetPort: n
             // The maximum SCTP user message size (in bytes) (RFC8841)
             "a=max-message-size:100000" + "\n" +
             // A transport address for a candidate that can be used for connectivity checks (RFC8839).
-            "a=candidate:0 1 " + (protocol == 'tcp' ? "TCP" : "UDP") + " 2113667327 " + targetIp + " " + targetPort + " typ host" + "\n";
+            "a=candidate:1 1 " + (protocol == 'tcp' ? "TCP" : "UDP") + " 2113667327 " + targetIp + " " + targetPort + " typ host" + "\n" +
+            // Indicate that there will be no further candidates.
+            "a=end-of-candidates" + "\n";
 
-        await webrtc.setRemoteDescription({ type: "answer", sdp: remoteSdp });
+        await pc.setRemoteDescription({ type: "answer", sdp: remoteSdp });
 
-        console.log(webrtc.remoteDescription!.sdp);
-    });
+        console.log(pc.remoteDescription!.sdp);
+    };
 
     dataChannel.onopen = () => {
-        console.log('open!');
+        console.log(`'${dataChannel.label}' opened`);
     };
 
     dataChannel.onerror = (error) => {
-        console.log('error! ' + error);
+        console.log(`'${dataChannel.label}' errored: ${error}`);
+    };
+
+    dataChannel.onclose = () => {
+        console.log(`'${dataChannel.label}' closed`);
     };
+
+    dataChannel.onmessage = (m) => {
+        console.log(`new message on '${dataChannel.label}': '${m.data}'`);
+    }
 }
 
 /**

bin/webrtc-server/src/main.rs

@@ -153,13 +153,12 @@ async fn main() -> Result<()> {
     se.set_ice_credentials(ICE_USER.to_string(), ICE_PASSWD.to_string());
     let api = APIBuilder::new().with_setting_engine(se).build();
     let certificate = load_certificate().expect("failed to load certificate");
-    debug!("EXPIRES {:?}", certificate.get_fingerprints());
     let config = RTCConfiguration {
         certificates: vec![certificate],
         ..Default::default()
     };
 
-    let peer_connection = Arc::new(api.new_peer_connection(config).await?);
+    let peer_connection = api.new_peer_connection(config).await?;
 
     let (done_tx, done_rx) = async_channel::bounded(1);