feat: polyfill WebRTC in Node

Author: ThaUnknown

index.js

@@ -28,7 +28,7 @@ class Peer extends Lite {
   /**
    * Add a Transceiver to the connection.
    * @param {String} kind
-   * @param {Object} init
+   * @param {Object=} init
    */
   addTransceiver (kind, init) {
     if (this._destroying) return

package.json

@@ -1,7 +1,7 @@
 {
   "name": "@thaunknown/simple-peer",
   "description": "Simple one-to-one WebRTC video/voice and data channels",
-  "version": "9.12.1",
+  "version": "10.0.0",
   "type": "module",
   "author": {
     "name": "ThaUnknown",
@@ -18,8 +18,10 @@
     "debug": "^4.3.4",
     "err-code": "^3.0.1",
     "streamx": "^2.16.1",
-    "uint8-util": "^2.1.9",
-    "webrtc-polyfill": "^1.0.12"
+    "uint8-util": "^2.1.9"
+  },
+  "optionalDependencies": {
+    "webrtc-polyfill": "^1.0.14"
   },
   "devDependencies": {
     "@babel/core": "^7.20.12",
@@ -28,6 +30,7 @@
     "airtap-manual": "^1.0.0",
     "babelify": "^10.0.0",
     "bowser": "^2.11.0",
+    "cross-env": "^7.0.3",
     "prettier-bytes": "^1.0.4",
     "speedometer": "^1.1.0",
     "string-to-stream": "^3.0.1",
@@ -59,7 +62,8 @@
   "scripts": {
     "test": "npm run test-node && npm run test-browser",
     "test-browser-local": "airtap --preset local -- test/*.js",
-    "test-node": "tape test/*.js"
+    "test-node": "tape test/*.js",
+    "test-node-debug": "cross-env DEBUG=* tape test/negotiation.js"
   },
   "contributors": [
     {

test/basic.js

@@ -2,6 +2,8 @@ import common from './common.js'
 import Peer from '../index.js'
 import test from 'tape'
 
+process.on('uncaughtException', console.error) // User-Initiated Abort, reason=Close called
+
 test('detect WebRTC support', function (t) {
   t.equal(Peer.WEBRTC_SUPPORT, true, 'builtin webrtc support')
   t.end()
@@ -239,7 +241,7 @@ test('ensure iceStateChange fires when connection failed', (t) => {
   t.plan(1)
   const peer = new Peer({ initiator: true })
 
-  peer.on('iceStateChange', (connectionState, gatheringState) => {
+  peer.once('iceStateChange', (connectionState, gatheringState) => {
     t.pass('got iceStateChange')
     t.end()
   })

test/multistream.js

@@ -3,6 +3,7 @@ import Peer from '../index.js'
 import test from 'tape'
 
 test('multistream', function (t) {
+  if (!process.browser) return t.end()
   if (common.isBrowser('ios')) {
     t.pass('Skip on iOS emulator which does not support this reliably') // iOS emulator issue #486
     t.end()
@@ -47,6 +48,7 @@ test('multistream', function (t) {
 })
 
 test('multistream (track event)', function (t) {
+  if (!process.browser) return t.end()
   t.plan(20)
 
   const peer1 = new Peer({
@@ -88,6 +90,7 @@ test('multistream (track event)', function (t) {
 })
 
 test('multistream on non-initiator only', function (t) {
+  if (!process.browser) return t.end()
   t.plan(30)
 
   const peer1 = new Peer({
@@ -126,6 +129,7 @@ test('multistream on non-initiator only', function (t) {
 })
 
 test('delayed stream on non-initiator', function (t) {
+  if (!process.browser) return t.end()
   if (common.isBrowser('ios')) {
     t.pass('Skip on iOS which does not support this reliably')
     t.end()
@@ -162,6 +166,7 @@ test('delayed stream on non-initiator', function (t) {
 })
 
 test('incremental multistream', function (t) {
+  if (!process.browser) return t.end()
   if (common.isBrowser('ios')) {
     t.pass('Skip on iOS emulator which does not support this reliably') // iOS emulator issue #486
     t.end()
@@ -226,6 +231,7 @@ test('incremental multistream', function (t) {
 })
 
 test('incremental multistream (track event)', function (t) {
+  if (!process.browser) return t.end()
   t.plan(22)
 
   const peer1 = new Peer({
@@ -285,6 +291,7 @@ test('incremental multistream (track event)', function (t) {
 })
 
 test('incremental multistream on non-initiator only', function (t) {
+  if (!process.browser) return t.end()
   if (common.isBrowser('ios')) {
     t.pass('Skip on iOS emulator which does not support this reliably') // iOS emulator issue #486
     t.end()
@@ -334,6 +341,7 @@ test('incremental multistream on non-initiator only', function (t) {
 })
 
 test('incremental multistream on non-initiator only (track event)', function (t) {
+  if (!process.browser) return t.end()
   t.plan(12)
 
   const peer1 = new Peer({
@@ -378,6 +386,7 @@ test('incremental multistream on non-initiator only (track event)', function (t)
 })
 
 test('addStream after removeStream', function (t) {
+  if (!process.browser) return t.end()
   if (common.isBrowser('ios')) {
     t.pass('Skip on iOS which does not support this reliably')
     t.end()
@@ -412,6 +421,7 @@ test('addStream after removeStream', function (t) {
 })
 
 test('removeTrack immediately', function (t) {
+  if (!process.browser) return t.end()
   t.plan(2)
 
   const peer1 = new Peer({ initiator: true })
@@ -450,6 +460,7 @@ test('removeTrack immediately', function (t) {
 })
 
 test('replaceTrack', function (t) {
+  if (!process.browser) return t.end()
   t.plan(4)
 
   const peer1 = new Peer({ initiator: true })

test/negotiation.js

@@ -3,6 +3,7 @@ import Peer from '../index.js'
 import test from 'tape'
 
 test('single negotiation', function (t) {
+  if (!process.browser) return t.end()
   t.plan(10)
 
   const peer1 = new Peer({ initiator: true, stream: common.getMediaStream() })
@@ -50,6 +51,7 @@ test('single negotiation', function (t) {
 })
 
 test('manual renegotiation', function (t) {
+  if (!process.browser) return t.end()
   t.plan(2)
 
   const peer1 = new Peer({ initiator: true })
@@ -71,6 +73,7 @@ test('manual renegotiation', function (t) {
 })
 
 test('repeated manual renegotiation', function (t) {
+  if (!process.browser) return t.end()
   t.plan(6)
 
   const peer1 = new Peer({ initiator: true })
@@ -107,6 +110,7 @@ test('repeated manual renegotiation', function (t) {
 })
 
 test('renegotiation after addStream', function (t) {
+  if (!process.browser) return t.end()
   if (common.isBrowser('ios')) {
     t.pass('Skip on iOS which does not support this reliably')
     t.end()
@@ -137,6 +141,7 @@ test('renegotiation after addStream', function (t) {
 })
 
 test('add stream on non-initiator only', function (t) {
+  if (!process.browser) return t.end()
   t.plan(3)
 
   const peer1 = new Peer({