simplewebrtc.js

/* Interop testing using apprtc.appspot.com using selenium
 * Copyright (c) 2016, Philipp Hancke
 */

const test = require('tape');
const fs = require('fs');
const os = require('os');
const webdriver = require('selenium-webdriver');
const buildDriver = require('./webdriver').buildDriver;

const TIMEOUT = 30000;
function waitNPeerConnectionsExist(driver, n) {
    return driver.wait(() => driver.executeScript(n => webrtc.getPeers().length === n, n), TIMEOUT);
}

function waitAllPeerConnectionsConnected(driver) {
    return driver.wait(() => driver.executeScript(() => {
        var peers = webrtc.getPeers();
        var states = [];
        peers.forEach(peer => {
            console.log(peer, peer.pc);
            states.push(peer.pc.iceConnectionState);
        });
        return states.length === states.filter((s) => s === 'connected' || s === 'completed').length;
    }), TIMEOUT);
}

function waitNVideosExist(driver, n) {
    return driver.wait(() => driver.executeScript(n => document.querySelectorAll('video').length === n, n), TIMEOUT);
}

function waitAllVideosHaveEnoughData(driver) {
    return driver.wait(() => driver.executeScript(() => {
        var videos = document.querySelectorAll('video');
        var ready = 0;
        for (var i = 0; i < videos.length; i++) {
            if (videos[i].readyState >= videos[i].HAVE_ENOUGH_DATA) {
                ready++;
            }
        }
        return ready === videos.length;
    }), TIMEOUT);
}

// Edge Webdriver resolves quit slightly too early, wait a bit.
function maybeWaitForEdge(browserA, browserB) {
    if (browserA === 'MicrosoftEdge' || browserB === 'MicrosoftEdge') {
        return new Promise(resolve => {
            setTimeout(resolve, 2000);
        });
    }
    return Promise.resolve();
}

// Helper function for basic interop test.
function interop(t, browserA, browserB) {
  var driverA = buildDriver(browserA, {h264: true});
  var driverB = buildDriver(browserB, {h264: true});

  var baseURL = 'https://simplewebrtc.com/video?';
  var roomName = 'interop-' + Math.random().toString(36).substr(2, 10);

  driverA.manage().timeouts().setScriptTimeout(TIMEOUT);

  return driverA.get(baseURL + roomName)
  .then(() => driverB.get(baseURL + roomName))
  .then(() => {
    t.pass('joined room');
    return waitNPeerConnectionsExist(driverA, 1);
  })
  .then(() => {
    t.pass('peerconnections exist');
    return waitAllPeerConnectionsConnected(driverA);
  })
  .then(() => {
    t.pass('peerconnections connected or completed');
    return waitNVideosExist(driverA, 2);
  })
  .then(() => {
    t.pass('videos exist');
    return waitAllVideosHaveEnoughData(driverA);
  })
  .then(() => {
    t.pass('videos are in HAVE_ENOUGH_DATA state');
    return waitNVideosExist(driverB, 2);
  })
  .then(() => {
    t.pass('videos exist');
    return waitAllVideosHaveEnoughData(driverB);
  })
  .then(() => {
    t.pass('videos are in HAVE_ENOUGH_DATA state');
  })
  .then(() => Promise.all([driverA.quit(), driverB.quit()]))
  .then(() => maybeWaitForEdge(browserA, browserB))
  .then(() => {
    t.end();
  });
}

test('Chrome-Chrome', t => {
  interop(t, 'chrome', 'chrome')
});

// geckodriver does not find Firefox binary on Win10?
test('Firefox-Firefox', t => {
  interop(t, 'firefox', 'firefox')
});

test('Chrome-Firefox', t => {
  interop(t, 'chrome', 'firefox')
});

test('Firefox-Chrome', t => {
  interop(t, 'firefox', 'chrome')
});

// Edge does not support two browser windows yet
/*
test('Edge-Edge', {skip: true}, function(t) {
  interop(t, 'MicrosoftEdge', 'MicrosoftEdge')
});
*/

test('Chrome-Edge', {skip: os.platform() !== 'win32'}, t => {
  interop(t, 'chrome', 'MicrosoftEdge')
});

test('Edge-Chrome', {skip: os.platform() !== 'win32'}, t => {
  interop(t, 'MicrosoftEdge', 'chrome')
});

test('Firefox-Edge', {skip: os.platform() !== 'win32'}, t => {
  interop(t, 'firefox', 'MicrosoftEdge')
});

test('Edge-firefox', {skip: os.platform() !== 'win32'}, t => {
  interop(t, 'MicrosoftEdge', 'firefox')
});