Add SCTP support and update test scripts in import-test

Author: shinyoshiaki

import-test/package.json

@@ -5,13 +5,14 @@
   "main": "index.js",
   "type": "module",
   "scripts": {
-    "test": "cd ../packages/webrtc && npm run build && cd ../../ && npm i && cd import-test && node test.mjs"
+    "test": "cd ../packages/webrtc && npm run build && cd ../sctp && npm run build && cd ../../ && npm i && cd import-test && node test.mjs"
   },
   "keywords": [],
   "author": "",
   "license": "ISC",
   "dependencies": {
     "werift": "0.22.7",
-    "werift-dev": "file:../packages/webrtc"
+    "werift-dev": "file:../packages/webrtc",
+    "werift-sctp": "file:../packages/sctp"
   }
 }

import-test/sctp.mjs

@@ -0,0 +1,43 @@
+import { createSocket } from "dgram";
+import { SCTP, WEBRTC_PPID, createUdpTransport } from "werift-sctp";
+
+const port = 5555;
+
+const socket = createSocket("udp4");
+socket.bind(port);
+
+const server = SCTP.server(createUdpTransport(socket));
+server.onReceive.subscribe((streamId, ppId, data) => {
+    console.log(data.toString());
+    server.send(0, WEBRTC_PPID.STRING, Buffer.from("pong"));
+});
+
+const client = SCTP.client(
+    createUdpTransport(createSocket("udp4"), {
+        port,
+        address: "127.0.0.1",
+    })
+);
+const promise = new Promise(r => {
+    client.onReceive.subscribe((streamId, ppId, data) => {
+        console.log(data.toString());
+        r();
+    });
+})
+
+await Promise.all([client.start(5000), server.start(5000)]);
+await Promise.all([
+    client.stateChanged.connected.asPromise(),
+    server.stateChanged.connected.asPromise(),
+]);
+
+client.send(0, WEBRTC_PPID.STRING, Buffer.from("ping"));
+
+await promise;
+
+await server.stop();
+await client.stop();
+server.transport.close();
+client.transport.close();
+
+console.log("sctp done");

import-test/test.mjs

@@ -1,38 +1,2 @@
-import { equal } from 'node:assert';
-import { RTCPeerConnection } from 'werift-dev';
-
-const pcA = new RTCPeerConnection();
-const pcB = new RTCPeerConnection();
-
-
-const dcA = pcA.createDataChannel("test");
-const dcBPromise = new Promise((resolve) => {
-    pcB.ondatachannel = (event) => {
-        console.log("data channel event");
-        resolve(event.channel);
-    };
-});
-
-
-const offer = await pcA.createOffer();
-await pcB.setRemoteDescription(await pcA.setLocalDescription(offer));
-console.log("offer set");
-
-const answer = await pcB.createAnswer();
-await pcA.setRemoteDescription(await pcB.setLocalDescription(answer));
-console.log("answer set");
-
-const dcB = await dcBPromise;
-console.log("data channel created");
-
-const message = "Hello, World!";
-setImmediate(() => {
-    dcA.send(message);
-});
-
-const [msg] = await dcB.onMessage.asPromise()
-console.log("message received:", msg);
-
-equal(msg, message);
-
-process.exit(0);
+import "./webrtc.mjs"
+import "./sctp.mjs"

import-test/webrtc.mjs

@@ -0,0 +1,39 @@
+import { equal } from 'node:assert';
+import { RTCPeerConnection } from 'werift-dev';
+
+const pcA = new RTCPeerConnection();
+const pcB = new RTCPeerConnection();
+
+
+const dcA = pcA.createDataChannel("test");
+const dcBPromise = new Promise((resolve) => {
+    pcB.ondatachannel = (event) => {
+        console.log("data channel event");
+        resolve(event.channel);
+    };
+});
+
+
+const offer = await pcA.createOffer();
+await pcB.setRemoteDescription(await pcA.setLocalDescription(offer));
+console.log("offer set");
+
+const answer = await pcB.createAnswer();
+await pcA.setRemoteDescription(await pcB.setLocalDescription(answer));
+console.log("answer set");
+
+const dcB = await dcBPromise;
+console.log("data channel created");
+
+const message = "Hello, World!";
+setImmediate(() => {
+    dcA.send(message);
+});
+
+const [msg] = await dcB.onMessage.asPromise()
+console.log("message received:", msg);
+
+equal(msg, message);
+
+pcA.close();
+pcB.close();