Alerts when tunnel/worker takes too long to respond

Author: Rohan Jain

bin/runner.js

@@ -83,13 +83,22 @@ function launchBrowser(browser) {
           runningChecked = true;
           clearInterval(statusPoller);
           console.log('[%s] Launched', worker.string);
+
+          setTimeout(function () {
+            if (!worker.acknowledged) {
+              utils.alertBrowserStack('Worker inactive for too long',
+                                      JSON.stringify(worker), function () {
+                                        process.exit(-2);
+                                      })
+            }
+          }, 120 * 1000);
         }
       });
     }, 2000);
   });
 }
 
-if (config.browsers) {
+if (config.browsers && config.browsers.length > 0) {
   tunnel = new Tunnel(config.key, serverPort, function () {
     config.browsers.forEach(function(browser) {
       if (browser.browser_version === "latest") {

lib/server.js

@@ -21,6 +21,13 @@ exports.Server = function Server(bsClient, workers) {
   var status = 0;
 
   function handleFile (filename, request, response) {
+    var url_parts = url.parse(request.url, true);
+    var query = url_parts.query;
+
+    if (query._worker_key) {
+      workers[query._worker_key].acknowledged = true;
+    }
+
     fs.exists(filename, function(exists) {
       if(!exists) {
         response.writeHead(404, {"Content-Type": "text/plain"});

lib/tunnel.js

@@ -1,7 +1,8 @@
 var exec = require('child_process').exec,
     fs = require('fs'),
     http = require('http'),
-    tunnelJar = '/tmp/BrowserStackTunnel.jar';
+    tunnelJar = '/tmp/BrowserStackTunnel.jar',
+    utils = require('./utils');
 
 var Tunnel = function Tunnel (key, port, callback, err) {
   var that = {};
@@ -29,6 +30,15 @@ var Tunnel = function Tunnel (key, port, callback, err) {
     var running = false;
     var runMatcher = "You can now access your local server(s)";
 
+    setTimeout(function () {
+      if (!running) {
+        utils.alertBrowserStack('Tunnel launch timeout',
+                                'Stdout:\n' + data, function () {
+                                  process.exit(-2);
+                                });
+      }
+    }, 60 * 100);
+
     subProcess.stdout.on('data', function (_data) {
       if (running) {
         return;
@@ -41,8 +51,6 @@ var Tunnel = function Tunnel (key, port, callback, err) {
         console.log("..Done");
         callback();
       }
-
-      running = true;
     });
 
     that.process = subProcess;