Espresso test for loopback video quality testing

Update the AppRTCMobileTestStubbedVideoIO test to run on
phones without Internet connection. This is done by bringing up
a local instance of AppRTC on the Linux machine connected to
the Android device.

Running this test will need the webrtc.DEPS solution to be configured
for the checkout, since that will pull down the precompiled AppRTC
package that is needed.

Continued from http://crrev.com/2780493002#ps20001 (by kjellander@)
Continued from http://crrev.com/2741743002#ps180001 (by mandermo@)

BUG=webrtc:7185

Review-Url: https://codereview.webrtc.org/2825313002
Cr-Commit-Position: refs/heads/master@{#17838}
diff --git a/webrtc/examples/androidtests/src/org/appspot/apprtc/test/CallActivityStubbedInputOutputTest.java b/webrtc/examples/androidtests/src/org/appspot/apprtc/test/CallActivityStubbedInputOutputTest.java
new file mode 100644
index 0000000..2e3a239
--- /dev/null
+++ b/webrtc/examples/androidtests/src/org/appspot/apprtc/test/CallActivityStubbedInputOutputTest.java
@@ -0,0 +1,88 @@
+/*
+ *  Copyright 2016 The WebRTC Project Authors. All rights reserved.
+ *
+ *  Use of this source code is governed by a BSD-style license
+ *  that can be found in the LICENSE file in the root of the source
+ *  tree. An additional intellectual property rights grant can be found
+ *  in the file PATENTS.  All contributing project authors may
+ *  be found in the AUTHORS file in the root of the source tree.
+ */
+
+package org.appspot.apprtc.test;
+
+import static android.support.test.espresso.action.ViewActions.click;
+import static android.support.test.espresso.matcher.ViewMatchers.withId;
+import static android.support.test.espresso.Espresso.onView;
+
+import android.content.Context;
+import android.content.Intent;
+import android.net.Uri;
+import android.os.Environment;
+import android.support.test.espresso.IdlingPolicies;
+import android.support.test.filters.LargeTest;
+import android.support.test.rule.ActivityTestRule;
+import android.support.test.runner.AndroidJUnit4;
+import android.support.test.InstrumentationRegistry;
+import java.util.UUID;
+import java.util.concurrent.TimeUnit;
+import org.appspot.apprtc.CallActivity;
+import org.appspot.apprtc.ConnectActivity;
+import org.appspot.apprtc.R;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+
+/**
+ * Used to start a loopback call with video input from file and video output also to file.
+ * The test case is a building block in other testing for video quality.
+ */
+@RunWith(AndroidJUnit4.class)
+@LargeTest
+public class CallActivityStubbedInputOutputTest {
+  private static final String TAG = "CallActivityStubbedInputOutputTest";
+
+  @Rule
+  public ActivityTestRule<CallActivity> rule = new ActivityTestRule<CallActivity>(
+      CallActivity.class) {
+    @Override
+    protected Intent getActivityIntent() {
+      Context context = InstrumentationRegistry.getContext();
+      Intent intent = new Intent("android.intent.action.VIEW", Uri.parse("http://localhost:9999"));
+
+      intent.putExtra(CallActivity.EXTRA_USE_VALUES_FROM_INTENT, true);
+
+      intent.putExtra(CallActivity.EXTRA_LOOPBACK, true);
+      intent.putExtra(CallActivity.EXTRA_AUDIOCODEC, "OPUS");
+      intent.putExtra(CallActivity.EXTRA_VIDEOCODEC, "VP8");
+      intent.putExtra(CallActivity.EXTRA_CAPTURETOTEXTURE_ENABLED, false);
+      intent.putExtra(CallActivity.EXTRA_CAMERA2, false);
+      intent.putExtra(CallActivity.EXTRA_ROOMID, UUID.randomUUID().toString().substring(0, 8));
+      // TODO false for wstls to disable https, should be option later or if URL is http
+      intent.putExtra(CallActivity.EXTRA_URLPARAMETERS,
+          "wstls=false?debug=loopback?ts=?wshpp=http://localhost:8089");
+
+      intent.putExtra(CallActivity.EXTRA_VIDEO_FILE_AS_CAMERA,
+          Environment.getExternalStorageDirectory().getAbsolutePath()
+              + "/chromium_tests_root/resources/reference_video_640x360_30fps.y4m");
+
+      intent.putExtra(CallActivity.EXTRA_SAVE_REMOTE_VIDEO_TO_FILE,
+          Environment.getExternalStorageDirectory().getAbsolutePath() + "/output.y4m");
+      intent.putExtra(CallActivity.EXTRA_SAVE_REMOTE_VIDEO_TO_FILE_WIDTH, 640);
+      intent.putExtra(CallActivity.EXTRA_SAVE_REMOTE_VIDEO_TO_FILE_HEIGHT, 360);
+
+      return intent;
+    }
+  };
+
+  @Test
+  public void testLoopback() throws InterruptedException {
+    // The time to write down the data during closing of the program can take a while.
+    IdlingPolicies.setMasterPolicyTimeout(240000, TimeUnit.MILLISECONDS);
+
+    // During the time we sleep it will record video.
+    Thread.sleep(8000);
+
+    // Click on hang-up button.
+    onView(withId(R.id.button_call_disconnect)).perform(click());
+  }
+}
diff --git a/webrtc/examples/androidtests/src/org/appspot/apprtc/test/ConnectActivityStubbedInputOutputTest.java b/webrtc/examples/androidtests/src/org/appspot/apprtc/test/ConnectActivityStubbedInputOutputTest.java
deleted file mode 100644
index ebb445bc..0000000
--- a/webrtc/examples/androidtests/src/org/appspot/apprtc/test/ConnectActivityStubbedInputOutputTest.java
+++ /dev/null
@@ -1,86 +0,0 @@
-/*
- *  Copyright 2016 The WebRTC Project Authors. All rights reserved.
- *
- *  Use of this source code is governed by a BSD-style license
- *  that can be found in the LICENSE file in the root of the source
- *  tree. An additional intellectual property rights grant can be found
- *  in the file PATENTS.  All contributing project authors may
- *  be found in the AUTHORS file in the root of the source tree.
- */
-
-package org.appspot.apprtc.test;
-
-import static android.support.test.espresso.action.ViewActions.click;
-import static android.support.test.espresso.matcher.ViewMatchers.withId;
-import static android.support.test.espresso.Espresso.onView;
-
-import android.content.Context;
-import android.content.Intent;
-import android.net.Uri;
-import android.os.Environment;
-import android.support.test.espresso.IdlingPolicies;
-import android.support.test.filters.LargeTest;
-import android.support.test.rule.ActivityTestRule;
-import android.support.test.runner.AndroidJUnit4;
-import android.support.test.InstrumentationRegistry;
-import java.util.UUID;
-import java.util.concurrent.TimeUnit;
-import org.appspot.apprtc.CallActivity;
-import org.appspot.apprtc.ConnectActivity;
-import org.appspot.apprtc.R;
-import org.junit.Rule;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-
-/**
- * Used to start a loopback call with video input from file and video output also to file.
- * The test case is a building block in other testing for video quality.
- */
-@RunWith(AndroidJUnit4.class)
-@LargeTest
-public class ConnectActivityStubbedInputOutputTest {
-  private static final String TAG = "ConnectActivityStubbedInputOutputTest";
-
-  @Rule
-  public ActivityTestRule<ConnectActivity> rule =
-      new ActivityTestRule<ConnectActivity>(ConnectActivity.class) {
-        @Override
-        protected Intent getActivityIntent() {
-          Context context = InstrumentationRegistry.getInstrumentation().getTargetContext();
-          Intent intent = new Intent("android.intent.action.VIEW", Uri.parse("https://appr.tc"),
-              context, ConnectActivity.class);
-
-          intent.putExtra(CallActivity.EXTRA_USE_VALUES_FROM_INTENT, true);
-
-          intent.putExtra(CallActivity.EXTRA_LOOPBACK, true);
-          intent.putExtra(CallActivity.EXTRA_AUDIOCODEC, "OPUS");
-          intent.putExtra(CallActivity.EXTRA_VIDEOCODEC, "VP8");
-          intent.putExtra(CallActivity.EXTRA_CAPTURETOTEXTURE_ENABLED, false);
-          intent.putExtra(CallActivity.EXTRA_CAMERA2, false);
-          intent.putExtra(CallActivity.EXTRA_ROOMID, UUID.randomUUID().toString().substring(0, 8));
-
-          intent.putExtra(CallActivity.EXTRA_VIDEO_FILE_AS_CAMERA,
-              Environment.getExternalStorageDirectory().getAbsolutePath()
-                  + "/chromium_tests_root/resources/reference_video_640x360_30fps.y4m");
-
-          intent.putExtra(CallActivity.EXTRA_SAVE_REMOTE_VIDEO_TO_FILE,
-              Environment.getExternalStorageDirectory().getAbsolutePath() + "/output.y4m");
-          intent.putExtra(CallActivity.EXTRA_SAVE_REMOTE_VIDEO_TO_FILE_WIDTH, 640);
-          intent.putExtra(CallActivity.EXTRA_SAVE_REMOTE_VIDEO_TO_FILE_HEIGHT, 360);
-
-          return intent;
-        }
-      };
-
-  @Test
-  public void testLoopback() throws InterruptedException {
-    // The time to write down the data during closing of the program can take a while.
-    IdlingPolicies.setMasterPolicyTimeout(240000, TimeUnit.MILLISECONDS);
-
-    // During the time we sleep it will record video.
-    Thread.sleep(10000);
-
-    // Click on hang-up button.
-    onView(withId(R.id.button_call_disconnect)).perform(click());
-  }
-}
diff --git a/webrtc/examples/androidtests/video_quality_loopback_test.py b/webrtc/examples/androidtests/video_quality_loopback_test.py
index 7c7ef31..a62d31c 100755
--- a/webrtc/examples/androidtests/video_quality_loopback_test.py
+++ b/webrtc/examples/androidtests/video_quality_loopback_test.py
@@ -19,17 +19,34 @@
 """
 
 import argparse
+import atexit
 import logging
 import os
 import shutil
 import subprocess
 import sys
 import tempfile
+import time
 
 
 SCRIPT_DIR = os.path.dirname(os.path.abspath(__file__))
 SRC_DIR = os.path.normpath(os.path.join(SCRIPT_DIR, os.pardir, os.pardir,
                                         os.pardir))
+WEBRTC_DEPS_INSTRUCTIONS = """Please add a solution to your .gclient file like
+this and run gclient sync:
+{
+  "name": "webrtc.DEPS",
+  "url": "https://chromium.googlesource.com/chromium/deps/webrtc/webrtc.DEPS",
+},
+"""
+
+
+class Error(Exception):
+  pass
+
+
+class VideoQualityTestError(Error):
+  pass
 
 
 def _RunCommand(argv, cwd=SRC_DIR, **kwargs):
@@ -37,6 +54,22 @@
   subprocess.check_call(argv, cwd=cwd, **kwargs)
 
 
+def _RunCommandWithOutput(argv, cwd=SRC_DIR, **kwargs):
+  logging.info('Running %r', argv)
+  return subprocess.check_output(argv, cwd=cwd, **kwargs)
+
+
+def _RunBackgroundCommand(argv, cwd=SRC_DIR):
+  logging.info('Running %r', argv)
+  process = subprocess.Popen(argv, cwd=cwd)
+  atexit.register(process.terminate)
+  time.sleep(0.5)
+  status = process.poll()
+  if status:  # is not None or 0
+    raise subprocess.CalledProcessError(status, argv)
+  return process
+
+
 def _ParseArgs():
   parser = argparse.ArgumentParser(description='Start loopback video analysis.')
   parser.add_argument('build_dir_android',
@@ -45,6 +78,7 @@
       help='The path to the build directory for building locally.')
   parser.add_argument('--temp_dir',
       help='A temporary directory to put the output.')
+  parser.add_argument('--adb-path', help='Path to adb binary.', default='adb')
 
   args = parser.parse_args()
   return args
@@ -58,6 +92,7 @@
   build_dir_android = args.build_dir_android
   build_dir_x86 = args.build_dir_x86
   temp_dir = args.temp_dir
+  adb_path = args.adb_path
   if not temp_dir:
     temp_dir = tempfile.mkdtemp()
   else:
@@ -76,14 +111,49 @@
   download_script = os.path.join(tools_dir, 'download_tools.py')
   _RunCommand([sys.executable, download_script, toolchain_dir])
 
+  # Select an Android device in case multiple are connected
+  for line in _RunCommandWithOutput([adb_path, 'devices']).splitlines():
+    if line.endswith('\tdevice'):
+      android_device = line.split('\t')[0]
+      break
+  else:
+    raise VideoQualityTestError('Cannot find any connected Android device.')
+
+  # Start AppRTC Server
+  dev_appserver = os.path.join(SRC_DIR, 'out', 'apprtc', 'google_appengine',
+                               'dev_appserver.py')
+  if not os.path.isfile(dev_appserver):
+    raise VideoQualityTestError('Cannot find %s.\n%s' %
+                                (dev_appserver, WEBRTC_DEPS_INSTRUCTIONS))
+  appengine_dir = os.path.join(SRC_DIR, 'out', 'apprtc', 'out', 'app_engine')
+  _RunBackgroundCommand(['python', dev_appserver, appengine_dir,
+                         '--port=9999', '--admin_port=9998',
+                         '--skip_sdk_update_check', '--clear_datastore=yes'])
+
+  # Start Collider
+  collider_path = os.path.join(SRC_DIR, 'out', 'go-workspace', 'bin',
+      'collidermain')
+  if not os.path.isfile(collider_path):
+    raise VideoQualityTestError('Cannot find %s.\n%s' %
+                                (collider_path, WEBRTC_DEPS_INSTRUCTIONS))
+  _RunBackgroundCommand([collider_path, '-tls=false',
+                         '-port=8089', '-room-server=http://localhost:9999'])
+
+  # Start adb reverse forwarder
+  reverseforwarder_path = os.path.join(
+      SRC_DIR, 'build', 'android', 'adb_reverse_forwarder.py')
+  _RunBackgroundCommand([reverseforwarder_path, '--device', android_device,
+                         '9999', '9999', '8089', '8089'])
+
   # Run the Espresso code.
   test_script = os.path.join(build_dir_android,
       'bin', 'run_AppRTCMobileTestStubbedVideoIO')
-  _RunCommand([sys.executable, test_script])
+  _RunCommand([test_script, '--device', android_device])
 
   # Pull the output video.
   test_video = os.path.join(temp_dir, 'test_video.y4m')
-  _RunCommand(['adb', 'pull', '/sdcard/output.y4m', test_video])
+  _RunCommand([adb_path, '-s', android_device,
+               'pull', '/sdcard/output.y4m', test_video])
 
   test_video_yuv = os.path.join(temp_dir, 'test_video.yuv')
 
@@ -103,8 +173,7 @@
   ConvertVideo(reference_video, reference_video_yuv)
 
   # Run compare script.
-  compare_script = os.path.join(SRC_DIR, 'webrtc', 'tools',
-      'compare_videos.py')
+  compare_script = os.path.join(SRC_DIR, 'webrtc', 'tools', 'compare_videos.py')
   zxing_path = os.path.join(toolchain_dir, 'linux', 'zxing')
 
   # The frame_analyzer binary should be built for local computer and not for