basic.js

var common = require('./common')
var Peer = require('../')
var test = require('tape')

var config
test('get config', function (t) {
  common.getConfig(function (err, _config) {
    if (err) return t.fail(err)
    config = _config
    t.end()
  })
})

test('detect WebRTC support', function (t) {
  t.equal(Peer.WEBRTC_SUPPORT, typeof window !== 'undefined', 'builtin webrtc support')
  t.end()
})

test('create peer without options', function (t) {
  t.plan(1)

  if (process.browser) {
    var peer
    t.doesNotThrow(function () {
      peer = new Peer()
    })
    peer.destroy()
  } else {
    t.pass('Skip no-option test in Node.js, since the wrtc option is required')
  }
})

test('can detect error when RTCPeerConstructor throws', function (t) {
  t.plan(1)

  var peer = new Peer({ wrtc: { RTCPeerConnection: null } })
  peer.once('error', function () {
    t.pass('got error event')
    peer.destroy()
  })
})

test('signal event gets emitted', function (t) {
  t.plan(2)

  var peer = new Peer({ config, initiator: true, wrtc: common.wrtc })
  peer.once('signal', function () {
    t.pass('got signal event')
    peer.on('close', function () { t.pass('peer destroyed') })
    peer.destroy()
  })
})

test('signal event does not get emitted by non-initiator', function (t) {
  var peer = new Peer({ config, initiator: false, wrtc: common.wrtc })
  peer.once('signal', function () {
    t.fail('got signal event')
    peer.on('close', function () { t.pass('peer destroyed') })
    peer.destroy()
  })

  setTimeout(() => {
    t.pass('did not get signal after 1000ms')
    t.end()
  }, 1000)
})

test('signal event does not get emitted by non-initiator with stream', function (t) {
  var peer = new Peer({
    config,
    stream: common.getMediaStream(),
    initiator: false,
    wrtc: common.wrtc
  })
  peer.once('signal', function () {
    t.fail('got signal event')
    peer.on('close', function () { t.pass('peer destroyed') })
    peer.destroy()
  })

  setTimeout(() => {
    t.pass('did not get signal after 1000ms')
    t.end()
  }, 1000)
})

test('data send/receive text', function (t) {
  t.plan(10)

  var peer1 = new Peer({ config, initiator: true, wrtc: common.wrtc })
  var peer2 = new Peer({ config, wrtc: common.wrtc })

  var numSignal1 = 0
  peer1.on('signal', function (data) {
    numSignal1 += 1
    peer2.signal(data)
  })

  var numSignal2 = 0
  peer2.on('signal', function (data) {
    numSignal2 += 1
    peer1.signal(data)
  })

  peer1.on('connect', tryTest)
  peer2.on('connect', tryTest)

  function tryTest () {
    if (!peer1.connected || !peer2.connected) return

    t.ok(numSignal1 >= 1)
    t.ok(numSignal2 >= 1)
    t.equal(peer1.initiator, true, 'peer1 is initiator')
    t.equal(peer2.initiator, false, 'peer2 is not initiator')

    peer1.send('sup peer2')
    peer2.on('data', function (data) {
      t.ok(Buffer.isBuffer(data), 'data is Buffer')
      t.equal(data.toString(), 'sup peer2', 'got correct message')

      peer2.send('sup peer1')
      peer1.on('data', function (data) {
        t.ok(Buffer.isBuffer(data), 'data is Buffer')
        t.equal(data.toString(), 'sup peer1', 'got correct message')

        peer1.on('close', function () { t.pass('peer1 destroyed') })
        peer1.destroy()
        peer2.on('close', function () { t.pass('peer2 destroyed') })
        peer2.destroy()
      })
    })
  }
})

test('sdpTransform function is called', function (t) {
  t.plan(3)

  var peer1 = new Peer({ config, initiator: true, wrtc: common.wrtc })
  var peer2 = new Peer({ config, sdpTransform, wrtc: common.wrtc })

  function sdpTransform (sdp) {
    t.equal(typeof sdp, 'string', 'got a string as SDP')
    setTimeout(function () {
      peer1.on('close', function () { t.pass('peer1 destroyed') })
      peer1.destroy()
      peer2.on('close', function () { t.pass('peer2 destroyed') })
      peer2.destroy()
    }, 0)
    return sdp
  }

  peer1.on('signal', function (data) {
    peer2.signal(data)
  })

  peer2.on('signal', function (data) {
    peer1.signal(data)
  })
})

test('old constraint formats are used', function (t) {
  t.plan(3)

  var constraints = {
    mandatory: {
      OfferToReceiveAudio: true,
      OfferToReceiveVideo: true
    }
  }

  var peer1 = new Peer({ config, initiator: true, wrtc: common.wrtc, constraints })
  var peer2 = new Peer({ config, wrtc: common.wrtc, constraints })

  peer1.on('signal', function (data) {
    peer2.signal(data)
  })

  peer2.on('signal', function (data) {
    peer1.signal(data)
  })

  peer1.on('connect', function () {
    t.pass('peers connected')
    peer1.on('close', function () { t.pass('peer1 destroyed') })
    peer1.destroy()
    peer2.on('close', function () { t.pass('peer2 destroyed') })
    peer2.destroy()
  })
})

test('new constraint formats are used', function (t) {
  t.plan(3)

  var constraints = {
    offerToReceiveAudio: true,
    offerToReceiveVideo: true
  }

  var peer1 = new Peer({ config, initiator: true, wrtc: common.wrtc, constraints })
  var peer2 = new Peer({ config, wrtc: common.wrtc, constraints })

  peer1.on('signal', function (data) {
    peer2.signal(data)
  })

  peer2.on('signal', function (data) {
    peer1.signal(data)
  })

  peer1.on('connect', function () {
    t.pass('peers connected')
    peer1.on('close', function () { t.pass('peer1 destroyed') })
    peer1.destroy()
    peer2.on('close', function () { t.pass('peer2 destroyed') })
    peer2.destroy()
  })
})

test('ensure remote address and port are available right after connection', function (t) {
  if (common.isBrowser('safari') || common.isBrowser('ios')) {
    t.pass('Skip on Safari and iOS which do not support modern getStats() calls')
    t.end()
    return
  }
  if (common.isBrowser('chrome')) {
    t.pass('Skip on Chrome which hides local IPs with mDNS')
    t.end()
    return
  }

  t.plan(7)

  var peer1 = new Peer({ config, initiator: true, wrtc: common.wrtc })
  var peer2 = new Peer({ config, wrtc: common.wrtc })

  peer1.on('signal', function (data) {
    peer2.signal(data)
  })

  peer2.on('signal', function (data) {
    peer1.signal(data)
  })

  peer1.on('connect', function () {
    t.pass('peers connected')

    t.ok(peer1.remoteAddress, 'peer1 remote address is present')
    t.ok(peer1.remotePort, 'peer1 remote port is present')

    peer2.on('connect', function () {
      t.ok(peer2.remoteAddress, 'peer2 remote address is present')
      t.ok(peer2.remotePort, 'peer2 remote port is present')

      peer1.on('close', function () { t.pass('peer1 destroyed') })
      peer1.destroy()
      peer2.on('close', function () { t.pass('peer2 destroyed') })
      peer2.destroy()
    })
  })
})