multistream.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('multistream', function (t) {
  if (common.isBrowser('ios')) {
    t.pass('Skip on iOS emulator which does not support this reliably') // iOS emulator issue #486
    t.end()
    return
  }
  t.plan(20)

  var peer1 = new Peer({
    config,
    initiator: true,
    wrtc: common.wrtc,
    streams: (new Array(10)).fill(null).map(function () { return common.getMediaStream() })
  })
  var peer2 = new Peer({
    config,
    wrtc: common.wrtc,
    streams: (new Array(10)).fill(null).map(function () { return common.getMediaStream() })
  })

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

  var receivedIds = {}

  peer1.on('stream', function (stream) {
    t.pass('peer1 got stream')
    if (receivedIds[stream.id]) {
      t.fail('received one unique stream per event')
    } else {
      receivedIds[stream.id] = true
    }
  })
  peer2.on('stream', function (stream) {
    t.pass('peer2 got stream')
    if (receivedIds[stream.id]) {
      t.fail('received one unique stream per event')
    } else {
      receivedIds[stream.id] = true
    }
  })

  t.on('end', () => {
    peer1.destroy()
    peer2.destroy()
  })
})

test('multistream (track event)', function (t) {
  t.plan(20)

  var peer1 = new Peer({
    config,
    initiator: true,
    wrtc: common.wrtc,
    streams: (new Array(5)).fill(null).map(function () { return common.getMediaStream() })
  })
  var peer2 = new Peer({
    config,
    wrtc: common.wrtc,
    streams: (new Array(5)).fill(null).map(function () { return common.getMediaStream() })
  })

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

  var receivedIds = {}

  peer1.on('track', function (track) {
    t.pass('peer1 got track')
    if (receivedIds[track.id]) {
      t.fail('received one unique track per event')
    } else {
      receivedIds[track.id] = true
    }
  })
  peer2.on('track', function (track) {
    t.pass('peer2 got track')
    if (receivedIds[track.id]) {
      t.fail('received one unique track per event')
    } else {
      receivedIds[track.id] = true
    }
  })

  t.on('end', () => {
    peer1.destroy()
    peer2.destroy()
  })
})

test('multistream on non-initiator only', function (t) {
  t.plan(30)

  var peer1 = new Peer({
    config,
    initiator: true,
    wrtc: common.wrtc,
    streams: []
  })
  var peer2 = new Peer({
    config,
    wrtc: common.wrtc,
    streams: (new Array(10)).fill(null).map(function () { return common.getMediaStream() })
  })

  peer1.on('signal', function (data) {
    if (data.transceiverRequest) t.pass('got transceiverRequest')
    if (!peer2.destroyed) peer2.signal(data)
  })
  peer2.on('signal', function (data) {
    if (data.transceiverRequest) t.pass('got transceiverRequest')
    if (!peer1.destroyed) peer1.signal(data)
  })

  var receivedIds = {}

  peer1.on('stream', function (stream) {
    t.pass('peer1 got stream')
    if (receivedIds[stream.id]) {
      t.fail('received one unique stream per event')
    } else {
      receivedIds[stream.id] = true
    }
  })

  t.on('end', () => {
    peer1.destroy()
    peer2.destroy()
  })
})

test('delayed stream on non-initiator', function (t) {
  if (common.isBrowser('ios')) {
    t.pass('Skip on iOS which does not support this reliably')
    t.end()
    return
  }
  t.timeoutAfter(15000)
  t.plan(1)

  var peer1 = new Peer({
    config,
    trickle: true,
    initiator: true,
    wrtc: common.wrtc,
    streams: [common.getMediaStream()]
  })
  var peer2 = new Peer({
    config,
    trickle: true,
    wrtc: common.wrtc,
    streams: []
  })

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

  setTimeout(() => {
    peer2.addStream(common.getMediaStream())
  }, 10000)
  peer1.on('stream', function () {
    t.pass('peer1 got stream')
  })

  t.on('end', () => {
    peer1.destroy()
    peer2.destroy()
  })
})

test('incremental multistream', function (t) {
  if (common.isBrowser('ios')) {
    t.pass('Skip on iOS emulator which does not support this reliably') // iOS emulator issue #486
    t.end()
    return
  }
  t.plan(12)

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

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

  peer1.on('connect', function () {
    t.pass('peer1 connected')
    peer1.addStream(common.getMediaStream())
  })
  peer2.on('connect', function () {
    t.pass('peer2 connected')
    peer2.addStream(common.getMediaStream())
  })

  var receivedIds = {}

  var count1 = 0
  peer1.on('stream', function (stream) {
    t.pass('peer1 got stream')
    if (receivedIds[stream.id]) {
      t.fail('received one unique stream per event')
    } else {
      receivedIds[stream.id] = true
    }
    count1++
    if (count1 < 5) {
      peer1.addStream(common.getMediaStream())
    }
  })

  var count2 = 0
  peer2.on('stream', function (stream) {
    t.pass('peer2 got stream')
    if (receivedIds[stream.id]) {
      t.fail('received one unique stream per event')
    } else {
      receivedIds[stream.id] = true
    }
    count2++
    if (count2 < 5) {
      peer2.addStream(common.getMediaStream())
    }
  })

  t.on('end', () => {
    peer1.destroy()
    peer2.destroy()
  })
})

test('incremental multistream (track event)', function (t) {
  t.plan(22)

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

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

  peer1.on('connect', function () {
    t.pass('peer1 connected')
    peer1.addStream(common.getMediaStream())
  })
  peer2.on('connect', function () {
    t.pass('peer2 connected')
    peer2.addStream(common.getMediaStream())
  })

  var receivedIds = {}

  var count1 = 0
  peer1.on('track', function (track) {
    t.pass('peer1 got track')
    if (receivedIds[track.id]) {
      t.fail('received one unique track per event')
    } else {
      receivedIds[track.id] = true
    }
    count1++
    if (count1 % 2 === 0 && count1 < 10) {
      peer1.addStream(common.getMediaStream())
    }
  })

  var count2 = 0
  peer2.on('track', function (track) {
    t.pass('peer2 got track')
    if (receivedIds[track.id]) {
      t.fail('received one unique track per event')
    } else {
      receivedIds[track.id] = true
    }
    count2++
    if (count2 % 2 === 0 && count2 < 10) {
      peer2.addStream(common.getMediaStream())
    }
  })

  t.on('end', () => {
    peer1.destroy()
    peer2.destroy()
  })
})

test('incremental multistream on non-initiator only', function (t) {
  if (common.isBrowser('ios')) {
    t.pass('Skip on iOS emulator which does not support this reliably') // iOS emulator issue #486
    t.end()
    return
  }
  t.plan(7)

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

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

  peer1.on('connect', function () {
    t.pass('peer1 connected')
  })
  peer2.on('connect', function () {
    t.pass('peer2 connected')
    peer2.addStream(common.getMediaStream())
  })

  var receivedIds = {}

  var count = 0
  peer1.on('stream', function (stream) {
    t.pass('peer1 got stream')
    if (receivedIds[stream.id]) {
      t.fail('received one unique stream per event')
    } else {
      receivedIds[stream.id] = true
    }
    count++
    if (count < 5) {
      peer2.addStream(common.getMediaStream())
    }
  })

  t.on('end', () => {
    peer1.destroy()
    peer2.destroy()
  })
})

test('incremental multistream on non-initiator only (track event)', function (t) {
  t.plan(12)

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

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

  peer1.on('connect', function () {
    t.pass('peer1 connected')
  })
  peer2.on('connect', function () {
    t.pass('peer2 connected')
    peer2.addStream(common.getMediaStream())
  })

  var receivedIds = {}

  var count = 0
  peer1.on('track', function (track) {
    t.pass('peer1 got track')
    if (receivedIds[track.id]) {
      t.fail('received one unique track per event')
    } else {
      receivedIds[track.id] = true
    }
    count++
    if (count % 2 === 0 && count < 10) {
      peer2.addStream(common.getMediaStream())
    }
  })

  t.on('end', () => {
    peer1.destroy()
    peer2.destroy()
  })
})

test('addStream after removeStream', function (t) {
  if (common.isBrowser('ios')) {
    t.pass('Skip on iOS which does not support this reliably')
    t.end()
    return
  }
  t.plan(2)

  var stream1 = common.getMediaStream()
  var stream2 = common.getMediaStream()

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

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

  peer1.once('stream', () => {
    t.pass('peer1 got first stream')
    peer2.removeStream(stream1)
    setTimeout(() => {
      peer1.once('stream', () => {
        t.pass('peer1 got second stream')
      })
      peer2.addStream(stream2)
    }, 1000)
  })

  t.on('end', () => {
    peer1.destroy()
    peer2.destroy()
  })
})

test('removeTrack immediately', function (t) {
  t.plan(2)

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

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

  var stream1 = common.getMediaStream()
  var stream2 = common.getMediaStream()

  peer1.addTrack(stream1.getTracks()[0], stream1)
  peer2.addTrack(stream2.getTracks()[0], stream2)

  peer1.removeTrack(stream1.getTracks()[0], stream1)
  peer2.removeTrack(stream2.getTracks()[0], stream2)

  peer1.on('track', function (track, stream) {
    t.fail('peer1 did not get track event')
  })
  peer2.on('track', function (track, stream) {
    t.fail('peer2 did not get track event')
  })

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

  t.on('end', () => {
    peer1.destroy()
    peer2.destroy()
  })
})

test('replaceTrack', function (t) {
  t.plan(4)

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

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

  var stream1 = common.getMediaStream()
  var stream2 = common.getMediaStream()

  peer1.addTrack(stream1.getTracks()[0], stream1)
  peer2.addTrack(stream2.getTracks()[0], stream2)

  peer1.replaceTrack(stream1.getTracks()[0], stream2.getTracks()[0], stream1)
  peer2.replaceTrack(stream2.getTracks()[0], stream1.getTracks()[0], stream2)

  peer1.on('track', function (track, stream) {
    t.pass('peer1 got track event')
    peer2.replaceTrack(stream2.getTracks()[0], null, stream2)
  })
  peer2.on('track', function (track, stream) {
    t.pass('peer2 got track event')
    peer1.replaceTrack(stream1.getTracks()[0], null, stream1)
  })

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

  t.on('end', () => {
    peer1.destroy()
    peer2.destroy()
  })
})