Implementation of DevToolsBridgeServer.

components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/LocalBindingTestService.java

Index: components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/LocalBindingTestService.java
diff --git a/components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/LocalBindingTestService.java b/components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/LocalBindingTestService.java
new file mode 100644
index 0000000000000000000000000000000000000000..6202fba5a566d6a76a62d8548d7c887e51d62c68
--- /dev/null
+++ b/components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/LocalBindingTestService.java
@@ -0,0 +1,121 @@
+// Copyright 2014 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+package org.chromium.components.devtools_bridge;
+
+import android.app.Service;
+import android.content.Intent;
+import android.os.Binder;
+import android.os.Handler;
+import android.os.IBinder;
+
+import org.chromium.components.devtools_bridge.ui.ServiceUIFactory;
+import org.chromium.components.devtools_bridge.util.LooperExecutor;
+
+import java.util.concurrent.Callable;
+
+/**
+ * Service to host DevToolsBridgeServer in tests.
+ */
+public class LocalBindingTestService extends Service {
+    private DevToolsBridgeServer mServer;
+    private final IBinder mBinder = new LocalBinder();
+    private final String mSocketName;
+    private boolean mForeground = false;
+
+    private void checkCalledOnServiceThread() {
+        assert getMainLooper().getThread() == Thread.currentThread();
+    }
+
+    public void invokeOnServiceThread(Runnable runnable) {
+        try {
+            invokeOnServiceThread(new TestUtils.RunnableAdapter(runnable));
+        } catch (Exception e) {
+            throw new RuntimeException("Unexpected exception", e);
+        }
+    }
+
+    public <T> T invokeOnServiceThread(final Callable<T> callable) throws Exception {
+        final TestUtils.InvokeHelper<T> helper = new TestUtils.InvokeHelper<T>();
+        new Handler(getMainLooper()).post(new Runnable() {
+            @Override
+            public void run() {
+                helper.runOnTargetThread(callable);
+            }
+        });
+        return helper.takeResult();
+    }
+
+    protected LocalBindingTestService(String socketName) {
+        mSocketName = socketName;
+    }
+
+    public LocalBindingTestService() {
+        this(LocalBindingTestService.class.getName() + ".SERVER_SOCKET");
+    }
+
+    /**
+     * Binder that provides direct access to the server for tests.
+     */
+    public class LocalBinder extends Binder {
+        public SignalingReceiver getReceiver() {
+            return mServer;
+        }
+
+        public SessionBase.Executor createExecutor() {
+            return LooperExecutor.newInstanceForMainLooper(LocalBindingTestService.this);
+        }
+
+        public String socketName() {
+            return mSocketName;
+        }
+    }
+
+    @Override
+    public void onCreate() {
+        checkCalledOnServiceThread();
+
+        mServer = new DevToolsBridgeServer(this, mSocketName, new TestServiceUIFactory()) {
+            @Override
+            protected void startForeground() {
+                assert !mForeground;
+                mForeground = true;
+                // TODO: Investigate java.lang.NullPointerException at
+                // android.app.Service.startForeground(Service.java:643).
+                // super.startForeground() should be called.
+            }
+
+            @Override
+            protected void stopForeground() {
+                assert mForeground;
+                mForeground = false;
+            }
+        };
+    }
+
+    @Override
+    public void onDestroy() {
+        checkCalledOnServiceThread();
+
+        mServer.dispose();
+        mServer = null;
+    }
+
+    @Override
+    public IBinder onBind(Intent intent) {
+        checkCalledOnServiceThread();
+
+        return mBinder;
+    }
+
+    private static class TestServiceUIFactory extends ServiceUIFactory {
+        protected String productName() {
+            return "LocalBindingTestService";
+        }
+
+        protected int notificationSmallIcon() {
+            return android.R.drawable.alert_dark_frame;
+        }
+    }
+}