Enable the mojo-based serial API in the renderer behind a flag.

extensions/browser/api/serial/serial_apitest.cc

 // 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.
 
 #include <string>
 
 #include "chrome/browser/extensions/extension_apitest.h"
+#include "content/public/browser/browser_thread.h"
+#include "device/serial/serial_device_enumerator.h"
+#include "device/serial/serial_service_impl.h"
 #include "device/serial/test_serial_io_handler.h"
 #include "extensions/browser/api/serial/serial_api.h"
 #include "extensions/browser/api/serial/serial_connection.h"
 #include "extensions/browser/extension_function.h"
+#include "extensions/browser/service_registration_manager.h"
 #include "extensions/common/api/serial.h"
+#include "extensions/common/switches.h"
 #include "extensions/test/result_catcher.h"
 #include "testing/gmock/include/gmock/gmock.h"
 
 using testing::_;
 using testing::Return;
 
+namespace extensions {
 namespace {
 
-class SerialApiTest : public ExtensionApiTest {
- public:
-  SerialApiTest() {}
-};
-
-}  // namespace
-
-namespace extensions {
-
 class FakeSerialGetDevicesFunction : public AsyncExtensionFunction {
  public:
   virtual bool RunAsync() override {
     base::ListValue* devices = new base::ListValue();
     base::DictionaryValue* device0 = new base::DictionaryValue();
     device0->SetString("path", "/dev/fakeserial");
     base::DictionaryValue* device1 = new base::DictionaryValue();
     device1->SetString("path", "\\\\COM800\\");
     devices->Append(device0);
     devices->Append(device1);
     SetResult(devices);
     SendResponse(true);
     return true;
   }
 
  protected:
   virtual ~FakeSerialGetDevicesFunction() {}
 };
 
+class FakeSerialDeviceEnumerator : public device::SerialDeviceEnumerator {
+ public:
+  virtual ~FakeSerialDeviceEnumerator() {}
+
+  virtual mojo::Array<device::serial::DeviceInfoPtr> GetDevices() override {
+    mojo::Array<device::serial::DeviceInfoPtr> devices;
+    device::serial::DeviceInfoPtr device0(device::serial::DeviceInfo::New());
+    device0->path = "/dev/fakeserialmojo";
+    device::serial::DeviceInfoPtr device1(device::serial::DeviceInfo::New());
+    device1->path = "\\\\COM800\\";
+    devices.push_back(device0.Pass());
+    devices.push_back(device1.Pass());
+    return devices.Pass();
+  }
+};
+
 class FakeEchoSerialIoHandler : public device::TestSerialIoHandler {
  public:
-  explicit FakeEchoSerialIoHandler() {
+  FakeEchoSerialIoHandler() {
     device_control_signals()->dcd = true;
     device_control_signals()->cts = true;
     device_control_signals()->ri = true;
     device_control_signals()->dsr = true;
+    EXPECT_CALL(*this, SetControlSignals(_)).Times(1).WillOnce(Return(true));
+  }
+
+  static scoped_refptr<device::SerialIoHandler> Create() {

[raymes, 2014/10/15 21:07:09]

Where is this called from?

[Sam McNally, 2014/10/20 07:21:07]

CreateTestSerialServiceOnFileThread.

+    return new FakeEchoSerialIoHandler();
   }
 
   MOCK_METHOD1(SetControlSignals,
                bool(const device::serial::HostControlSignals&));
 
  protected:
   virtual ~FakeEchoSerialIoHandler() {}
 
  private:
   DISALLOW_COPY_AND_ASSIGN(FakeEchoSerialIoHandler);
 };
 
 class FakeSerialConnectFunction : public core_api::SerialConnectFunction {
  protected:
   virtual SerialConnection* CreateSerialConnection(
       const std::string& port,
       const std::string& owner_extension_id) const override {
     scoped_refptr<FakeEchoSerialIoHandler> io_handler =
         new FakeEchoSerialIoHandler;
-    EXPECT_CALL(*io_handler.get(), SetControlSignals(_)).Times(1).WillOnce(
-        Return(true));

[raymes, 2014/10/15 21:07:09]

Why did this line get moved?

[Sam McNally, 2014/10/20 07:21:06]

So FakeEchoSerialIoHandlers created elsewhere have the same mock expectation.

     SerialConnection* serial_connection =
         new SerialConnection(port, owner_extension_id);
     serial_connection->SetIoHandlerForTest(io_handler);
     return serial_connection;
   }
 
  protected:
   virtual ~FakeSerialConnectFunction() {}
 };
 
-}  // namespace extensions
+class SerialApiTest : public ExtensionApiTest,
+                      public testing::WithParamInterface<bool> {
+ public:
+  SerialApiTest() {}
+  virtual void SetUpCommandLine(base::CommandLine* command_line) override {
+    ExtensionApiTest::SetUpCommandLine(command_line);
+    if (GetParam())

[raymes, 2014/10/15 21:07:09]

I don't really understand these GetParam related changes. I guess this is for
the mojo implementation, but where is the flag set? Does the test get run twice,
once with the flag and once without?

[Sam McNally, 2014/10/20 07:21:07]

Yes. INSTANTIATE_TEST_CASE_P(SerialApiTest, SerialApiTest, testing::Bool()) does
it.

[raymes, 2014/10/24 00:09:30]

nit: Cool. It's probably worth making a comment about that here.

+      command_line->AppendSwitch(switches::kEnableMojoSerialService);
+  }
+
+  virtual void TearDown() override {
+    ServiceRegistrationManager::GetSharedInstance()->ClearOverridesForTest();
+    ExtensionApiTest::TearDown();
+  }
+};
 
 ExtensionFunction* FakeSerialGetDevicesFunctionFactory() {
   return new extensions::FakeSerialGetDevicesFunction();
 }
 
 ExtensionFunction* FakeSerialConnectFunctionFactory() {
   return new extensions::FakeSerialConnectFunction();
 }
 
+void CreateTestSerialServiceOnFileThread(
+    mojo::InterfaceRequest<device::serial::SerialService> request) {
+  mojo::BindToRequest(
+      new device::SerialServiceImpl(
+          new device::SerialConnectionFactory(
+              base::Bind(&FakeEchoSerialIoHandler::Create),
+              content::BrowserThread::GetMessageLoopProxyForThread(
+                  content::BrowserThread::IO)),
+          scoped_ptr<device::SerialDeviceEnumerator>(
+              new FakeSerialDeviceEnumerator)),
+      &request);

[raymes, 2014/10/15 21:07:09]

Could you split this up into a few statements? :)

[Sam McNally, 2014/10/20 07:21:07]

Done.

+}
+
+void CreateTestSerialService(
+    mojo::InterfaceRequest<device::serial::SerialService> request) {
+  content::BrowserThread::PostTask(
+      content::BrowserThread::FILE,
+      FROM_HERE,
+      base::Bind(&CreateTestSerialServiceOnFileThread, base::Passed(&request)));
+}
+
+}  // namespace
+
 // Disable SIMULATE_SERIAL_PORTS only if all the following are true:
 //
 // 1. You have an Arduino or compatible board attached to your machine and
 // properly appearing as the first virtual serial port ("first" is very loosely
 // defined as whichever port shows up in serial.getPorts). We've tested only
 // the Atmega32u4 Breakout Board and Arduino Leonardo; note that both these
 // boards are based on the Atmel ATmega32u4, rather than the more common
 // Arduino '328p with either FTDI or '8/16u2 USB interfaces. TODO: test more
 // widely.
 //
 // 2. Your user has permission to read/write the port. For example, this might
 // mean that your user is in the "tty" or "uucp" group on Ubuntu flavors of
 // Linux, or else that the port's path (e.g., /dev/ttyACM0) has global
 // read/write permissions.
 //
 // 3. You have uploaded a program to the board that does a byte-for-byte echo
 // on the virtual serial port at 57600 bps. An example is at
 // chrome/test/data/extensions/api_test/serial/api/serial_arduino_test.ino.
 //
 #define SIMULATE_SERIAL_PORTS (1)
-IN_PROC_BROWSER_TEST_F(SerialApiTest, SerialFakeHardware) {
-  extensions::ResultCatcher catcher;
+IN_PROC_BROWSER_TEST_P(SerialApiTest, SerialFakeHardware) {
+  ResultCatcher catcher;
   catcher.RestrictToBrowserContext(browser()->profile());
 
 #if SIMULATE_SERIAL_PORTS
-  ASSERT_TRUE(extensions::ExtensionFunctionDispatcher::OverrideFunction(
-      "serial.getDevices", FakeSerialGetDevicesFunctionFactory));
-  ASSERT_TRUE(extensions::ExtensionFunctionDispatcher::OverrideFunction(
-      "serial.connect", FakeSerialConnectFunctionFactory));
+  if (GetParam()) {
+    ServiceRegistrationManager::GetSharedInstance()
+        ->OverrideServiceFactoryForTest(base::Bind(&CreateTestSerialService));
+  } else {
+    ASSERT_TRUE(extensions::ExtensionFunctionDispatcher::OverrideFunction(
+        "serial.getDevices", FakeSerialGetDevicesFunctionFactory));
+    ASSERT_TRUE(extensions::ExtensionFunctionDispatcher::OverrideFunction(
+        "serial.connect", FakeSerialConnectFunctionFactory));
+  }
 #endif
 
   ASSERT_TRUE(RunExtensionTest("serial/api")) << message_;
 }
 
-IN_PROC_BROWSER_TEST_F(SerialApiTest, SerialRealHardware) {
-  extensions::ResultCatcher catcher;
+IN_PROC_BROWSER_TEST_P(SerialApiTest, SerialRealHardware) {
+  ResultCatcher catcher;
   catcher.RestrictToBrowserContext(browser()->profile());
 
   ASSERT_TRUE(RunExtensionTest("serial/real_hardware")) << message_;
 }
+
+INSTANTIATE_TEST_CASE_P(SerialApiTest, SerialApiTest, testing::Bool());
+
+}  // namespace extensions