Browser testing: Run android content shell tests on hosts with multiple devices connected.

tools/testing/dart/browser_controller.dart

 // Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 library browser;
 
 import "dart:async";
 import "dart:convert" show LineSplitter, UTF8;
 import "dart:core";
 import "dart:io";
 
@@ skipping 20 matching lines @@
 
   /** The version of the browser - normally set when starting a browser */
   String version = "";
 
   // The path to the browser executable.
   String _binary;
 
   /**
    * The underlying process - don't mess directly with this if you don't
    * know what you are doing (this is an interactive process that needs
-   * special threatment to not leak).
+   * special treatment to not leak).
    */
   Process process;
 
   Function logger;
 
   /**
    * Id of the browser
    */
   String id;
 
@@ skipping 522 matching lines @@
     'com.google.android.apps.chrome',
     '.Main',
     'android.intent.action.VIEW');
 
 
 class AndroidBrowser extends Browser {
   final bool checkedMode;
   AdbDevice _adbDevice;
   AndroidBrowserConfig _config;
 
-  AndroidBrowser(this._adbDevice, this._config, this.checkedMode);
+  AndroidBrowser(this._adbDevice, this._config, this.checkedMode, apkPath) {
+    _binary = apkPath;
+  }
 
   Future<bool> start(String url) {
     var intent = new Intent(
         _config.action, _config.package, _config.activity, url);
     return _adbDevice.waitForBootCompleted().then((_) {
       return _adbDevice.forceStop(_config.package);
     }).then((_) {
       return _adbDevice.killAll();
     }).then((_) {
       return _adbDevice.adbRoot();
     }).then((_) {
       return _adbDevice.setProp("DART_FORWARDING_PRINT", "1");
     }).then((_) {
       if (checkedMode) {
         return _adbDevice.setProp("DART_FLAGS", "--checked");
       } else {
         return _adbDevice.setProp("DART_FLAGS", "");
       }
     }).then((_) {
+      return _adbDevice.installApk(new Path(_binary));
+    }).then((_) {
       return _adbDevice.startActivity(intent).then((_) => true);
     });
   }
 
   Future<bool> close() {
     if (_adbDevice != null) {
       return _adbDevice.forceStop(_config.package).then((_) {
         return _adbDevice.killAll().then((_) => true);
       });
     }
@@ skipping 264 matching lines @@
       });
     });
   }
 
   Future<List<Browser>> getBrowsers() {
     // TODO(kustermann): This is a hackisch way to accomplish it and should
     // be encapsulated
     var browsersCompleter = new Completer();
     var androidBrowserCreationMapping = {
       'chromeOnAndroid' : (AdbDevice device) => new AndroidChrome(device),
-      'ContentShellOnAndroid' : (AdbDevice device) =>
-          new AndroidBrowser(device, contentShellOnAndroidConfig, checkedMode),
-      'DartiumOnAndroid' : (AdbDevice device) =>
-          new AndroidBrowser(device, dartiumOnAndroidConfig, checkedMode),
+      'ContentShellOnAndroid' : (AdbDevice device) => new AndroidBrowser(
+          device,
+          contentShellOnAndroidConfig,
+          checkedMode,
+          globalConfiguration['drt']),
+      'DartiumOnAndroid' : (AdbDevice device) => new AndroidBrowser(
+          device,
+          dartiumOnAndroidConfig,
+          checkedMode,
+          globalConfiguration['dartium']),
     };
     if (androidBrowserCreationMapping.containsKey(browserName)) {
       AdbHelper.listDevices().then((deviceIds) {
         if (deviceIds.length > 0) {
           var browsers = [];
           for (int i = 0; i < deviceIds.length; i++) {
             var id = "BROWSER$i";
             var device = new AdbDevice(deviceIds[i]);
             adbDeviceMapping[id] = device;
             var browser = androidBrowserCreationMapping[browserName](device);
@@ skipping 132 matching lines @@
   }
 
   void restartBrowser(String id) {
     var browser;
     var new_id = id;
     if (browserName == 'chromeOnAndroid') {
       browser = new AndroidChrome(adbDeviceMapping[id]);
     } else if (browserName == 'ContentShellOnAndroid') {
       browser = new AndroidBrowser(adbDeviceMapping[id],
                                    contentShellOnAndroidConfig,
-                                   checkedMode);
+                                   checkedMode,
+                                   globalConfiguration['drt']);
     } else if (browserName == 'DartiumOnAndroid') {
       browser = new AndroidBrowser(adbDeviceMapping[id],
                                    dartiumOnAndroidConfig,
-                                   checkedMode);
+                                   checkedMode,
+                                   globalConfiguration['dartium']);
     } else {
       browserStatus.remove(id);
       browser = getInstance();
       new_id = "BROWSER$browserIdCount";
       browserIdCount++;
     }
     browser.id = new_id;
     var status = new BrowserTestingStatus(browser);
     browserStatus[new_id] = status;
     status.nextTestTimeout = createNextTestTimer(status);
@@ skipping 186 matching lines @@
   bool useIframe = false;
 
   Function testDoneCallBack;
   Function testStatusUpdateCallBack;
   Function testStartedCallBack;
   Function nextTestCallBack;
 
   BrowserTestingServer(this.globalConfiguration, this.localIp, this.useIframe);
 
   Future start() {
-    int port = globalConfiguration['test_driver_port'];
-    return HttpServer.bind(localIp, port).then((createdServer) {
-      httpServer = createdServer;
-      void handler(HttpRequest request) {
-        // Don't allow caching of resources from the browser controller, i.e.,
-        // we don't want the browser to cache the result of getNextTest.
-        request.response.headers.set("Cache-Control",
-                                     "no-cache, no-store, must-revalidate");
-        bool isReport = request.uri.path.startsWith(reportPath);
-        bool isStatusUpdate = request.uri.path.startsWith(statusUpdatePath);
-        if (isReport || isStatusUpdate) {
-          var browserId;
-          if (isStatusUpdate) {
-            browserId = request.uri.path.substring(statusUpdatePath.length + 1);
-          } else {
-            browserId = request.uri.path.substring(reportPath.length + 1);
-          }
-          var testId =
-              int.parse(request.uri.queryParameters["id"].split("=")[1]);
-          handleReport(
-              request, browserId, testId, isStatusUpdate: isStatusUpdate);
-          // handleReport will asynchroniously fetch the data and will handle
-          // the closing of the streams.
-          return;
+    var test_driver_port = globalConfiguration['test_driver_port'];

[ricow1, 2014/08/12 13:29:23]

I think it sucks that we are sending in our globalConfiguration to the browser
controller. This basically means that we are making a strong binding between the
browser controller and the rest of the testing infrastructure. This did not
happen in this cl though

+    var test_driver_error_port = globalConfiguration['test_driver_error_port'];
+    return HttpServer.bind(localIp, test_driver_port)
+      .then(setupDriverServer)
+      .then((_) => HttpServer.bind(localIp, test_driver_error_port))
+      .then(setupErrorServer);
+  }
+
+  void setupDriverServer(HttpServer server) {
+    httpServer = server;
+    void handler(HttpRequest request) {
+      print('Driver server received request ${request.uri}');

[ricow1, 2014/08/12 13:29:23]

leftover print?

+      // Don't allow caching of resources from the browser controller, i.e.,
+      // we don't want the browser to cache the result of getNextTest.
+      request.response.headers.set("Cache-Control",
+                                   "no-cache, no-store, must-revalidate");
+      bool isReport = request.uri.path.startsWith(reportPath);
+      bool isStatusUpdate = request.uri.path.startsWith(statusUpdatePath);
+      if (isReport || isStatusUpdate) {
+        var browserId;
+        if (isStatusUpdate) {
+          browserId = request.uri.path.substring(statusUpdatePath.length + 1);
+        } else {
+          browserId = request.uri.path.substring(reportPath.length + 1);
         }
-        if (request.uri.path.startsWith(startedPath)) {
-          var browserId = request.uri.path.substring(startedPath.length + 1);
-          var testId =
-              int.parse(request.uri.queryParameters["id"].split("=")[1]);
-          handleStarted(request, browserId, testId);
-          return;
-        }
-        var textResponse = "";
-        if (request.uri.path.startsWith(driverPath)) {
-          var browserId = request.uri.path.substring(driverPath.length + 1);
-          textResponse = getDriverPage(browserId);
-        } else if (request.uri.path.startsWith(nextTestPath)) {
-          var browserId = request.uri.path.substring(nextTestPath.length + 1);
-          textResponse = getNextTest(browserId);
-        } else {
-          // /favicon.ico requests
-        }
-        request.response.write(textResponse);
-        request.listen((_) {}, onDone: request.response.close);
-        request.response.done.catchError((error) {
+        var testId =
+            int.parse(request.uri.queryParameters["id"].split("=")[1]);
+        handleReport(
+            request, browserId, testId, isStatusUpdate: isStatusUpdate);
+        // handleReport will asynchroniously fetch the data and will handle
+        // the closing of the streams.
+        return;
+      }
+      if (request.uri.path.startsWith(startedPath)) {
+        var browserId = request.uri.path.substring(startedPath.length + 1);
+        var testId =
+            int.parse(request.uri.queryParameters["id"].split("=")[1]);
+        handleStarted(request, browserId, testId);
+        return;
+      }
+      var textResponse = "";
+      if (request.uri.path.startsWith(driverPath)) {
+        var browserId = request.uri.path.substring(driverPath.length + 1);
+        textResponse = getDriverPage(browserId);
+      } else if (request.uri.path.startsWith(nextTestPath)) {
+        var browserId = request.uri.path.substring(nextTestPath.length + 1);
+        textResponse = getNextTest(browserId);
+      } else {
+        // /favicon.ico requests
+      }
+      request.response.write(textResponse);
+      request.listen((_) {}, onDone: request.response.close);
+      request.response.done.catchError((error) {
           if (!underTermination) {
             print("URI ${request.uri}");
             print("Textresponse $textResponse");
             throw "Error returning content to browser: $error";
           }
         });
-      }
-      void errorHandler(e) {
-        if (!underTermination) print("Error occured in httpserver: $e");
-      };
+    }
+    void errorHandler(e) {
+      if (!underTermination) print("Error occured in httpserver: $e");
+    }
+    httpServer.listen(handler, onError: errorHandler);
+  }
 
-      httpServer.listen(handler, onError: errorHandler);
-
-      // Set up the error reporting server that enables us to send back
-      // errors from the browser.
-      port = globalConfiguration['test_driver_error_port'];
-      return HttpServer.bind(localIp, port).then((createdReportServer) {
-        errorReportingServer = createdReportServer;
-        void errorReportingHandler(HttpRequest request) {
-          StringBuffer buffer = new StringBuffer();
-          request.transform(UTF8.decoder).listen((data) {
-            buffer.write(data);
-          }, onDone: () {
-              String back = buffer.toString();
-              request.response.headers.set("Access-Control-Allow-Origin", "*");
-              request.response.done.catchError((error) {
-                DebugLogger.error("Error getting error from browser"
-                                  "on uri ${request.uri.path}: $error");
-              });
-              request.response.close();
-              DebugLogger.error("Error from browser on : "
-                               "${request.uri.path}, data:  $back");
-          }, onError: (error) { print(error); });
-        }
-        errorReportingServer.listen(errorReportingHandler,
-                                    onError: errorHandler);
-        return true;
-      });
-    });
+  void setupErrorServer(HttpServer server) {
+    errorReportingServer = server;
+    void errorReportingHandler(HttpRequest request) {
+      StringBuffer buffer = new StringBuffer();
+      request.transform(UTF8.decoder).listen((data) {
+          buffer.write(data);
+        }, onDone: () {
+          String back = buffer.toString();
+          request.response.headers.set("Access-Control-Allow-Origin", "*");
+          request.response.done.catchError((error) {
+              DebugLogger.error("Error getting error from browser"
+                                "on uri ${request.uri.path}: $error");
+            });
+          request.response.close();
+          DebugLogger.error("Error from browser on : "
+                            "${request.uri.path}, data:  $back");
+        }, onError: (error) { print(error); });
+    }
+    void errorHandler(e) {
+      if (!underTermination) print("Error occured in httpserver: $e");
+    }
+    errorReportingServer.listen(errorReportingHandler, onError: errorHandler);
   }
 
   void handleReport(HttpRequest request, String browserId, var testId,
                     {bool isStatusUpdate}) {
     StringBuffer buffer = new StringBuffer();
     request.transform(UTF8.decoder).listen((data) {
       buffer.write(data);
     }, onDone: () {
       String back = buffer.toString();
       request.response.close();
@@ skipping 237 matching lines @@
     Dart test driver, number of tests: <div id="number"></div><br>
     Currently executing: <div id="currently_executing"></div><br>
     Unhandled error: <div id="unhandled_error"></div>
     <iframe id="embedded_iframe"></iframe>
   </body>
 </html>
 """;
     return driverContent;
   }
 }