123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909
#!/usr/bin/env node'use strict';
/** Environment shortcut. */var env = process.env;
/** Load Node.js modules. */var EventEmitter = require('events').EventEmitter,    http = require('http'),    path = require('path'),    url = require('url'),    util = require('util');
/** Load other modules. */var _ = require('../lodash.js'),    chalk = require('chalk'),    ecstatic = require('ecstatic'),    request = require('request'),    SauceTunnel = require('sauce-tunnel');
/** Used for Sauce Labs credentials. */var accessKey = env.SAUCE_ACCESS_KEY,    username = env.SAUCE_USERNAME;
/** Used as the default maximum number of times to retry a job and tunnel. */var maxJobRetries = 3,    maxTunnelRetries = 3;
/** Used as the static file server middleware. */var mount = ecstatic({  'cache': 'no-cache',  'root': process.cwd()});
/** Used as the list of ports supported by Sauce Connect. */var ports = [  80, 443, 888, 2000, 2001, 2020, 2109, 2222, 2310, 3000, 3001, 3030, 3210,  3333, 4000, 4001, 4040, 4321, 4502, 4503, 4567, 5000, 5001, 5050, 5555, 5432,  6000, 6001, 6060, 6666, 6543, 7000, 7070, 7774, 7777, 8000, 8001, 8003, 8031,  8080, 8081, 8765, 8777, 8888, 9000, 9001, 9080, 9090, 9876, 9877, 9999, 49221,  55001];
/** Used by `logInline` to clear previously logged messages. */var prevLine = '';
/** Method shortcut. */var push = Array.prototype.push;
/** Used to detect error messages. */var reError = /(?:\be|E)rror\b/;
/** Used to detect valid job ids. */var reJobId = /^[a-z0-9]{32}$/;
/** Used to display the wait throbber. */var throbberDelay = 500,    waitCount = -1;
/** * Used as Sauce Labs config values. * See the [Sauce Labs documentation](https://docs.saucelabs.com/reference/test-configuration/) * for more details. */var advisor = getOption('advisor', false),    build = getOption('build', (env.TRAVIS_COMMIT || '').slice(0, 10)),    commandTimeout = getOption('commandTimeout', 90),    compatMode = getOption('compatMode', null),    customData = Function('return {' + getOption('customData', '').replace(/^\{|}$/g, '') + '}')(),    deviceOrientation = getOption('deviceOrientation', 'portrait'),    framework = getOption('framework', 'qunit'),    idleTimeout = getOption('idleTimeout', 60),    jobName = getOption('name', 'unit tests'),    maxDuration = getOption('maxDuration', 180),    port = ports[Math.min(_.sortedIndex(ports, getOption('port', 9001)), ports.length - 1)],    publicAccess = getOption('public', true),    queueTimeout = getOption('queueTimeout', 240),    recordVideo = getOption('recordVideo', true),    recordScreenshots = getOption('recordScreenshots', false),    runner = getOption('runner', 'test/index.html').replace(/^\W+/, ''),    runnerUrl = getOption('runnerUrl', 'http://localhost:' + port + '/' + runner),    statusInterval = getOption('statusInterval', 5),    tags = getOption('tags', []),    throttled = getOption('throttled', 10),    tunneled = getOption('tunneled', true),    tunnelId = getOption('tunnelId', 'tunnel_' + (env.TRAVIS_JOB_ID || 0)),    tunnelTimeout = getOption('tunnelTimeout', 120),    videoUploadOnPass = getOption('videoUploadOnPass', false);
/** Used to convert Sauce Labs browser identifiers to their formal names. */var browserNameMap = {  'googlechrome': 'Chrome',  'iehta': 'Internet Explorer',  'ipad': 'iPad',  'iphone': 'iPhone',  'microsoftedge': 'Edge'};
/** List of platforms to load the runner on. */var platforms = [  ['Linux', 'android', '5.1'],  ['Windows 10', 'chrome', '54'],  ['Windows 10', 'chrome', '53'],  ['Windows 10', 'firefox', '50'],  ['Windows 10', 'firefox', '49'],  ['Windows 10', 'microsoftedge', '14'],  ['Windows 10', 'internet explorer', '11'],  ['Windows 8', 'internet explorer', '10'],  ['Windows 7', 'internet explorer', '9'],  ['macOS 10.12', 'safari', '10'],  ['OS X 10.11', 'safari', '9']];
/** Used to tailor the `platforms` array. */var isAMD = _.includes(tags, 'amd'),    isBackbone = _.includes(tags, 'backbone'),    isModern = _.includes(tags, 'modern');
// The platforms to test IE compatibility modes.if (compatMode) {  platforms = [    ['Windows 10', 'internet explorer', '11'],    ['Windows 8', 'internet explorer', '10'],    ['Windows 7', 'internet explorer', '9'],    ['Windows 7', 'internet explorer', '8']  ];}// The platforms for AMD tests.if (isAMD) {  platforms = _.filter(platforms, function(platform) {    var browser = browserName(platform[1]),        version = +platform[2];
    switch (browser) {      case 'Android': return version >= 4.4;      case 'Opera': return version >= 10;    }    return true;  });}// The platforms for Backbone tests.if (isBackbone) {  platforms = _.filter(platforms, function(platform) {    var browser = browserName(platform[1]),        version = +platform[2];
    switch (browser) {      case 'Firefox': return version >= 4;      case 'Internet Explorer': return version >= 7;      case 'iPad': return version >= 5;      case 'Opera': return version >= 12;    }    return true;  });}// The platforms for modern builds.if (isModern) {  platforms = _.filter(platforms, function(platform) {    var browser = browserName(platform[1]),        version = +platform[2];
    switch (browser) {      case 'Android': return version >= 4.1;      case 'Firefox': return version >= 10;      case 'Internet Explorer': return version >= 9;      case 'iPad': return version >= 6;      case 'Opera': return version >= 12;      case 'Safari': return version >= 6;    }    return true;  });}
/** Used as the default `Job` options object. */var jobOptions = {  'build': build,  'command-timeout': commandTimeout,  'custom-data': customData,  'device-orientation': deviceOrientation,  'framework': framework,  'idle-timeout': idleTimeout,  'max-duration': maxDuration,  'name': jobName,  'public': publicAccess,  'platforms': platforms,  'record-screenshots': recordScreenshots,  'record-video': recordVideo,  'sauce-advisor': advisor,  'tags': tags,  'url': runnerUrl,  'video-upload-on-pass': videoUploadOnPass};
if (publicAccess === true) {  jobOptions['public'] = 'public';}if (tunneled) {  jobOptions['tunnel-identifier'] = tunnelId;}
/*----------------------------------------------------------------------------*/
/** * Resolves the formal browser name for a given Sauce Labs browser identifier. * * @private * @param {string} identifier The browser identifier. * @returns {string} Returns the formal browser name. */function browserName(identifier) {  return browserNameMap[identifier] || _.startCase(identifier);}
/** * Gets the value for the given option name. If no value is available the * `defaultValue` is returned. * * @private * @param {string} name The name of the option. * @param {*} defaultValue The default option value. * @returns {*} Returns the option value. */function getOption(name, defaultValue) {  var isArr = _.isArray(defaultValue);  return _.reduce(process.argv, function(result, value) {    if (isArr) {      value = optionToArray(name, value);      return _.isEmpty(value) ? result : value;    }    value = optionToValue(name, value);
    return value == null ? result : value;  }, defaultValue);}
/** * Checks if `value` is a job ID. * * @private * @param {*} value The value to check. * @returns {boolean} Returns `true` if `value` is a job ID, else `false`. */function isJobId(value) {  return reJobId.test(value);}
/** * Writes an inline message to standard output. * * @private * @param {string} [text=''] The text to log. */function logInline(text) {  var blankLine = _.repeat(' ', _.size(prevLine));  prevLine = text = _.truncate(text, { 'length': 40 });  process.stdout.write(text + blankLine.slice(text.length) + '\r');}
/** * Writes the wait throbber to standard output. * * @private */function logThrobber() {  logInline('Please wait' + _.repeat('.', (++waitCount % 3) + 1));}
/** * Converts a comma separated option value into an array. * * @private * @param {string} name The name of the option to inspect. * @param {string} string The options string. * @returns {Array} Returns the new converted array. */function optionToArray(name, string) {  return _.compact(_.invokeMap((optionToValue(name, string) || '').split(/, */), 'trim'));}
/** * Extracts the option value from an option string. * * @private * @param {string} name The name of the option to inspect. * @param {string} string The options string. * @returns {string|undefined} Returns the option value, else `undefined`. */function optionToValue(name, string) {  var result = string.match(RegExp('^' + name + '(?:=([\\s\\S]+))?$'));  if (result) {    result = _.get(result, 1);    result = result ? _.trim(result) : true;  }  if (result === 'false') {    return false;  }  return result || undefined;}
/*----------------------------------------------------------------------------*/
/** * The `Job#remove` and `Tunnel#stop` callback used by `Jobs#restart` * and `Tunnel#restart` respectively. * * @private */function onGenericRestart() {  this.restarting = false;  this.emit('restart');  this.start();}
/** * The `request.put` and `SauceTunnel#stop` callback used by `Jobs#stop` * and `Tunnel#stop` respectively. * * @private * @param {Object} [error] The error object. */function onGenericStop(error) {  this.running = this.stopping = false;  this.emit('stop', error);}
/** * The `request.del` callback used by `Jobs#remove`. * * @private */function onJobRemove(error, res, body) {  this.id = this.taskId = this.url = null;  this.removing = false;  this.emit('remove');}
/** * The `Job#remove` callback used by `Jobs#reset`. * * @private */function onJobReset() {  this.attempts = 0;  this.failed = this.resetting = false;  this._pollerId = this.id = this.result = this.taskId = this.url = null;  this.emit('reset');}
/** * The `request.post` callback used by `Jobs#start`. * * @private * @param {Object} [error] The error object. * @param {Object} res The response data object. * @param {Object} body The response body JSON object. */function onJobStart(error, res, body) {  this.starting = false;
  if (this.stopping) {    return;  }  var statusCode = _.get(res, 'statusCode'),      taskId = _.first(_.get(body, 'js tests'));
  if (error || !taskId || statusCode != 200) {    if (this.attempts < this.retries) {      this.restart();      return;    }    var na = 'unavailable',        bodyStr = _.isObject(body) ? '\n' + JSON.stringify(body) : na,        statusStr = _.isFinite(statusCode) ? statusCode : na;
    logInline();    console.error('Failed to start job; status: %s, body: %s', statusStr, bodyStr);    if (error) {      console.error(error);    }    this.failed = true;    this.emit('complete');    return;  }  this.running = true;  this.taskId = taskId;  this.timestamp = _.now();  this.emit('start');  this.status();}
/** * The `request.post` callback used by `Job#status`. * * @private * @param {Object} [error] The error object. * @param {Object} res The response data object. * @param {Object} body The response body JSON object. */function onJobStatus(error, res, body) {  this.checking = false;
  if (!this.running || this.stopping) {    return;  }  var completed = _.get(body, 'completed', false),      data = _.first(_.get(body, 'js tests')),      elapsed = (_.now() - this.timestamp) / 1000,      jobId = _.get(data, 'job_id', null),      jobResult = _.get(data, 'result', null),      jobStatus = _.get(data, 'status', ''),      jobUrl = _.get(data, 'url', null),      expired = (elapsed >= queueTimeout && !_.includes(jobStatus, 'in progress')),      options = this.options,      platform = options.platforms[0];
  if (_.isObject(jobResult)) {    var message = _.get(jobResult, 'message');  } else {    if (typeof jobResult == 'string') {      message = jobResult;    }    jobResult = null;  }  if (isJobId(jobId)) {    this.id = jobId;    this.result = jobResult;    this.url = jobUrl;  } else {    completed = false;  }  this.emit('status', jobStatus);
  if (!completed && !expired) {    this._pollerId = _.delay(_.bind(this.status, this), this.statusInterval * 1000);    return;  }  var description = browserName(platform[1]) + ' ' + platform[2] + ' on ' + _.startCase(platform[0]),      errored = !jobResult || !jobResult.passed || reError.test(message) || reError.test(jobStatus),      failures = _.get(jobResult, 'failed'),      label = options.name + ':',      tunnel = this.tunnel;
  if (errored || failures) {    if (errored && this.attempts < this.retries) {      this.restart();      return;    }    var details = 'See ' + jobUrl + ' for details.';    this.failed = true;
    logInline();    if (failures) {      console.error(label + ' %s ' + chalk.red('failed') + ' %d test' + (failures > 1 ? 's' : '') + '. %s', description, failures, details);    }    else if (tunnel.attempts < tunnel.retries) {      tunnel.restart();      return;    }    else {      if (message === undefined) {        message = 'Results are unavailable. ' + details;      }      console.error(label, description, chalk.red('failed') + ';', message);    }  }  else {    logInline();    console.log(label, description, chalk.green('passed'));  }  this.running = false;  this.emit('complete');}
/** * The `SauceTunnel#start` callback used by `Tunnel#start`. * * @private * @param {boolean} success The connection success indicator. */function onTunnelStart(success) {  this.starting = false;
  if (this._timeoutId) {    clearTimeout(this._timeoutId);    this._timeoutId = null;  }  if (!success) {    if (this.attempts < this.retries) {      this.restart();      return;    }    logInline();    console.error('Failed to open Sauce Connect tunnel');    process.exit(2);  }  logInline();  console.log('Sauce Connect tunnel opened');
  var jobs = this.jobs;  push.apply(jobs.queue, jobs.all);
  this.running = true;  this.emit('start');
  console.log('Starting jobs...');  this.dequeue();}
/*----------------------------------------------------------------------------*/
/** * The Job constructor. * * @private * @param {Object} [properties] The properties to initialize a job with. */function Job(properties) {  EventEmitter.call(this);
  this.options = {};  _.merge(this, properties);  _.defaults(this.options, _.cloneDeep(jobOptions));
  this.attempts = 0;  this.checking = this.failed = this.removing = this.resetting = this.restarting = this.running = this.starting = this.stopping = false;  this._pollerId = this.id = this.result = this.taskId = this.url = null;}
util.inherits(Job, EventEmitter);
/** * Removes the job. * * @memberOf Job * @param {Function} callback The function called once the job is removed. * @param {Object} Returns the job instance. */Job.prototype.remove = function(callback) {  this.once('remove', _.iteratee(callback));  if (this.removing) {    return this;  }  this.removing = true;  return this.stop(function() {    var onRemove = _.bind(onJobRemove, this);    if (!this.id) {      _.defer(onRemove);      return;    }    request.del(_.template('https://saucelabs.com/rest/v1/${user}/jobs/${id}')(this), {      'auth': { 'user': this.user, 'pass': this.pass }    }, onRemove);  });};
/** * Resets the job. * * @memberOf Job * @param {Function} callback The function called once the job is reset. * @param {Object} Returns the job instance. */Job.prototype.reset = function(callback) {  this.once('reset', _.iteratee(callback));  if (this.resetting) {    return this;  }  this.resetting = true;  return this.remove(onJobReset);};
/** * Restarts the job. * * @memberOf Job * @param {Function} callback The function called once the job is restarted. * @param {Object} Returns the job instance. */Job.prototype.restart = function(callback) {  this.once('restart', _.iteratee(callback));  if (this.restarting) {    return this;  }  this.restarting = true;
  var options = this.options,      platform = options.platforms[0],      description = browserName(platform[1]) + ' ' + platform[2] + ' on ' + _.startCase(platform[0]),      label = options.name + ':';
  logInline();  console.log('%s %s restart %d of %d', label, description, ++this.attempts, this.retries);
  return this.remove(onGenericRestart);};
/** * Starts the job. * * @memberOf Job * @param {Function} callback The function called once the job is started. * @param {Object} Returns the job instance. */Job.prototype.start = function(callback) {  this.once('start', _.iteratee(callback));  if (this.starting || this.running) {    return this;  }  this.starting = true;  request.post(_.template('https://saucelabs.com/rest/v1/${user}/js-tests')(this), {    'auth': { 'user': this.user, 'pass': this.pass },    'json': this.options  }, _.bind(onJobStart, this));
  return this;};
/** * Checks the status of a job. * * @memberOf Job * @param {Function} callback The function called once the status is resolved. * @param {Object} Returns the job instance. */Job.prototype.status = function(callback) {  this.once('status', _.iteratee(callback));  if (this.checking || this.removing || this.resetting || this.restarting || this.starting || this.stopping) {    return this;  }  this._pollerId = null;  this.checking = true;  request.post(_.template('https://saucelabs.com/rest/v1/${user}/js-tests/status')(this), {    'auth': { 'user': this.user, 'pass': this.pass },    'json': { 'js tests': [this.taskId] }  }, _.bind(onJobStatus, this));
  return this;};
/** * Stops the job. * * @memberOf Job * @param {Function} callback The function called once the job is stopped. * @param {Object} Returns the job instance. */Job.prototype.stop = function(callback) {  this.once('stop', _.iteratee(callback));  if (this.stopping) {    return this;  }  this.stopping = true;  if (this._pollerId) {    clearTimeout(this._pollerId);    this._pollerId = null;    this.checking = false;  }  var onStop = _.bind(onGenericStop, this);  if (!this.running || !this.id) {    _.defer(onStop);    return this;  }  request.put(_.template('https://saucelabs.com/rest/v1/${user}/jobs/${id}/stop')(this), {    'auth': { 'user': this.user, 'pass': this.pass }  }, onStop);
  return this;};
/*----------------------------------------------------------------------------*/
/** * The Tunnel constructor. * * @private * @param {Object} [properties] The properties to initialize the tunnel with. */function Tunnel(properties) {  EventEmitter.call(this);
  _.merge(this, properties);
  var active = [],      queue = [];
  var all = _.map(this.platforms, _.bind(function(platform) {    return new Job(_.merge({      'user': this.user,      'pass': this.pass,      'tunnel': this,      'options': { 'platforms': [platform] }    }, this.job));  }, this));
  var completed = 0,      restarted = [],      success = true,      total = all.length,      tunnel = this;
  _.invokeMap(all, 'on', 'complete', function() {    _.pull(active, this);    if (success) {      success = !this.failed;    }    if (++completed == total) {      tunnel.stop(_.partial(tunnel.emit, 'complete', success));      return;    }    tunnel.dequeue();  });
  _.invokeMap(all, 'on', 'restart', function() {    if (!_.includes(restarted, this)) {      restarted.push(this);    }    // Restart tunnel if all active jobs have restarted.    var threshold = Math.min(all.length, _.isFinite(throttled) ? throttled : 3);    if (tunnel.attempts < tunnel.retries &&        active.length >= threshold && _.isEmpty(_.difference(active, restarted))) {      tunnel.restart();    }  });
  this.on('restart', function() {    completed = 0;    success = true;    restarted.length = 0;  });
  this._timeoutId = null;  this.attempts = 0;  this.restarting = this.running = this.starting = this.stopping = false;  this.jobs = { 'active': active, 'all': all, 'queue': queue };  this.connection = new SauceTunnel(this.user, this.pass, this.id, this.tunneled, ['-P', '0']);}
util.inherits(Tunnel, EventEmitter);
/** * Restarts the tunnel. * * @memberOf Tunnel * @param {Function} callback The function called once the tunnel is restarted. */Tunnel.prototype.restart = function(callback) {  this.once('restart', _.iteratee(callback));  if (this.restarting) {    return this;  }  this.restarting = true;
  logInline();  console.log('Tunnel %s: restart %d of %d', this.id, ++this.attempts, this.retries);
  var jobs = this.jobs,      active = jobs.active,      all = jobs.all;
  var reset = _.after(all.length, _.bind(this.stop, this, onGenericRestart)),      stop = _.after(active.length, _.partial(_.invokeMap, all, 'reset', reset));
  if (_.isEmpty(active)) {    _.defer(stop);  }  if (_.isEmpty(all)) {    _.defer(reset);  }  _.invokeMap(active, 'stop', function() {    _.pull(active, this);    stop();  });
  if (this._timeoutId) {    clearTimeout(this._timeoutId);    this._timeoutId = null;  }  return this;};
/** * Starts the tunnel. * * @memberOf Tunnel * @param {Function} callback The function called once the tunnel is started. * @param {Object} Returns the tunnel instance. */Tunnel.prototype.start = function(callback) {  this.once('start', _.iteratee(callback));  if (this.starting || this.running) {    return this;  }  this.starting = true;
  logInline();  console.log('Opening Sauce Connect tunnel...');
  var onStart = _.bind(onTunnelStart, this);  if (this.timeout) {    this._timeoutId = _.delay(onStart, this.timeout * 1000, false);  }  this.connection.start(onStart);  return this;};
/** * Removes jobs from the queue and starts them. * * @memberOf Tunnel * @param {Object} Returns the tunnel instance. */Tunnel.prototype.dequeue = function() {  var count = 0,      jobs = this.jobs,      active = jobs.active,      queue = jobs.queue,      throttled = this.throttled;
  while (queue.length && (active.length < throttled)) {    var job = queue.shift();    active.push(job);    _.delay(_.bind(job.start, job), ++count * 1000);  }  return this;};
/** * Stops the tunnel. * * @memberOf Tunnel * @param {Function} callback The function called once the tunnel is stopped. * @param {Object} Returns the tunnel instance. */Tunnel.prototype.stop = function(callback) {  this.once('stop', _.iteratee(callback));  if (this.stopping) {    return this;  }  this.stopping = true;
  logInline();  console.log('Shutting down Sauce Connect tunnel...');
  var jobs = this.jobs,      active = jobs.active;
  var stop = _.after(active.length, _.bind(function() {    var onStop = _.bind(onGenericStop, this);    if (this.running) {      this.connection.stop(onStop);    } else {      onStop();    }  }, this));
  jobs.queue.length = 0;  if (_.isEmpty(active)) {    _.defer(stop);  }  _.invokeMap(active, 'stop', function() {    _.pull(active, this);    stop();  });
  if (this._timeoutId) {    clearTimeout(this._timeoutId);    this._timeoutId = null;  }  return this;};
/*----------------------------------------------------------------------------*/
// Cleanup any inline logs when exited via `ctrl+c`.process.on('SIGINT', function() {  logInline();  process.exit();});
// Create a web server for the current working directory.http.createServer(function(req, res) {  // See http://msdn.microsoft.com/en-us/library/ff955275(v=vs.85).aspx.  if (compatMode && path.extname(url.parse(req.url).pathname) == '.html') {    res.setHeader('X-UA-Compatible', 'IE=' + compatMode);  }  mount(req, res);}).listen(port);
// Setup Sauce Connect so we can use this server from Sauce Labs.var tunnel = new Tunnel({  'user': username,  'pass': accessKey,  'id': tunnelId,  'job': { 'retries': maxJobRetries, 'statusInterval': statusInterval },  'platforms': platforms,  'retries': maxTunnelRetries,  'throttled': throttled,  'tunneled': tunneled,  'timeout': tunnelTimeout});
tunnel.on('complete', function(success) {  process.exit(success ? 0 : 1);});
tunnel.start();
setInterval(logThrobber, throbberDelay);