OLD | NEW |
| (Empty) |
1 // Copyright 2012 The Chromium Authors. All rights reserved. | |
2 // Use of this source code is governed by a BSD-style license that can be | |
3 // found in the LICENSE file. | |
4 | |
5 #include <deque> | |
6 #include <string> | |
7 #include <vector> | |
8 | |
9 #include "base/memory/scoped_ptr.h" | |
10 #include "chrome/browser/extensions/api/serial/serial_api.h" | |
11 #include "chrome/browser/extensions/api/serial/serial_connection.h" | |
12 #include "chrome/browser/extensions/extension_apitest.h" | |
13 #include "chrome/browser/extensions/extension_function_test_utils.h" | |
14 #include "chrome/browser/extensions/extension_test_message_listener.h" | |
15 #include "chrome/browser/ui/browser.h" | |
16 #include "chrome/common/extensions/api/serial.h" | |
17 #include "content/public/browser/browser_thread.h" | |
18 #include "extensions/browser/extension_function.h" | |
19 #include "testing/gmock/include/gmock/gmock.h" | |
20 | |
21 using testing::_; | |
22 using testing::Return; | |
23 | |
24 using content::BrowserThread; | |
25 | |
26 namespace { | |
27 | |
28 class SerialApiTest : public ExtensionApiTest { | |
29 public: | |
30 SerialApiTest() {} | |
31 }; | |
32 | |
33 } // namespace | |
34 | |
35 namespace extensions { | |
36 | |
37 class FakeSerialGetDevicesFunction : public AsyncExtensionFunction { | |
38 public: | |
39 virtual bool RunAsync() OVERRIDE { | |
40 base::ListValue* devices = new base::ListValue(); | |
41 base::DictionaryValue* device0 = new base::DictionaryValue(); | |
42 device0->SetString("path", "/dev/fakeserial"); | |
43 base::DictionaryValue* device1 = new base::DictionaryValue(); | |
44 device1->SetString("path", "\\\\COM800\\"); | |
45 devices->Append(device0); | |
46 devices->Append(device1); | |
47 SetResult(devices); | |
48 SendResponse(true); | |
49 return true; | |
50 } | |
51 protected: | |
52 virtual ~FakeSerialGetDevicesFunction() {} | |
53 }; | |
54 | |
55 class FakeEchoSerialIoHandler : public device::SerialIoHandler { | |
56 public: | |
57 explicit FakeEchoSerialIoHandler() : opened_(false) {} | |
58 | |
59 virtual void Open(const std::string& port, | |
60 const OpenCompleteCallback& callback) OVERRIDE { | |
61 DCHECK(!opened_); | |
62 opened_ = true; | |
63 callback.Run(true); | |
64 } | |
65 | |
66 virtual bool ConfigurePort( | |
67 const device::serial::ConnectionOptions& options) OVERRIDE { | |
68 return true; | |
69 } | |
70 | |
71 virtual void ReadImpl() OVERRIDE {} | |
72 | |
73 virtual void CancelReadImpl() OVERRIDE { | |
74 QueueReadCompleted(0, read_cancel_reason()); | |
75 } | |
76 | |
77 virtual void WriteImpl() OVERRIDE { | |
78 DCHECK(pending_read_buffer()); | |
79 DCHECK_LE(pending_write_buffer_len(), pending_read_buffer_len()); | |
80 memcpy(pending_read_buffer()->data(), | |
81 pending_write_buffer()->data(), | |
82 pending_write_buffer_len()); | |
83 QueueReadCompleted(pending_write_buffer_len(), | |
84 device::serial::RECEIVE_ERROR_NONE); | |
85 QueueWriteCompleted(pending_write_buffer_len(), | |
86 device::serial::SEND_ERROR_NONE); | |
87 } | |
88 | |
89 virtual void CancelWriteImpl() OVERRIDE { | |
90 QueueWriteCompleted(0, write_cancel_reason()); | |
91 } | |
92 | |
93 virtual device::serial::DeviceControlSignalsPtr GetControlSignals() | |
94 const OVERRIDE { | |
95 device::serial::DeviceControlSignalsPtr signals( | |
96 device::serial::DeviceControlSignals::New()); | |
97 signals->dcd = true; | |
98 signals->cts = true; | |
99 signals->ri = true; | |
100 signals->dsr = true; | |
101 return signals.Pass(); | |
102 } | |
103 | |
104 virtual device::serial::ConnectionInfoPtr GetPortInfo() const OVERRIDE { | |
105 device::serial::ConnectionInfoPtr info( | |
106 device::serial::ConnectionInfo::New()); | |
107 info->bitrate = 9600; | |
108 info->data_bits = device::serial::DATA_BITS_EIGHT; | |
109 info->parity_bit = device::serial::PARITY_BIT_NO; | |
110 info->stop_bits = device::serial::STOP_BITS_ONE; | |
111 info->cts_flow_control = false; | |
112 return info.Pass(); | |
113 } | |
114 | |
115 virtual bool Flush() const OVERRIDE { return true; } | |
116 | |
117 MOCK_METHOD1(SetControlSignals, | |
118 bool(const device::serial::HostControlSignals&)); | |
119 | |
120 protected: | |
121 virtual ~FakeEchoSerialIoHandler() {} | |
122 | |
123 private: | |
124 bool opened_; | |
125 | |
126 DISALLOW_COPY_AND_ASSIGN(FakeEchoSerialIoHandler); | |
127 }; | |
128 | |
129 class FakeSerialConnectFunction : public api::SerialConnectFunction { | |
130 protected: | |
131 virtual SerialConnection* CreateSerialConnection( | |
132 const std::string& port, | |
133 const std::string& owner_extension_id) const OVERRIDE { | |
134 scoped_refptr<FakeEchoSerialIoHandler> io_handler = | |
135 new FakeEchoSerialIoHandler; | |
136 EXPECT_CALL(*io_handler, SetControlSignals(_)).Times(1).WillOnce( | |
137 Return(true)); | |
138 SerialConnection* serial_connection = | |
139 new SerialConnection(port, owner_extension_id); | |
140 serial_connection->SetIoHandlerForTest(io_handler); | |
141 return serial_connection; | |
142 } | |
143 | |
144 protected: | |
145 virtual ~FakeSerialConnectFunction() {} | |
146 }; | |
147 | |
148 } // namespace extensions | |
149 | |
150 ExtensionFunction* FakeSerialGetDevicesFunctionFactory() { | |
151 return new extensions::FakeSerialGetDevicesFunction(); | |
152 } | |
153 | |
154 ExtensionFunction* FakeSerialConnectFunctionFactory() { | |
155 return new extensions::FakeSerialConnectFunction(); | |
156 } | |
157 | |
158 // Disable SIMULATE_SERIAL_PORTS only if all the following are true: | |
159 // | |
160 // 1. You have an Arduino or compatible board attached to your machine and | |
161 // properly appearing as the first virtual serial port ("first" is very loosely | |
162 // defined as whichever port shows up in serial.getPorts). We've tested only | |
163 // the Atmega32u4 Breakout Board and Arduino Leonardo; note that both these | |
164 // boards are based on the Atmel ATmega32u4, rather than the more common | |
165 // Arduino '328p with either FTDI or '8/16u2 USB interfaces. TODO: test more | |
166 // widely. | |
167 // | |
168 // 2. Your user has permission to read/write the port. For example, this might | |
169 // mean that your user is in the "tty" or "uucp" group on Ubuntu flavors of | |
170 // Linux, or else that the port's path (e.g., /dev/ttyACM0) has global | |
171 // read/write permissions. | |
172 // | |
173 // 3. You have uploaded a program to the board that does a byte-for-byte echo | |
174 // on the virtual serial port at 57600 bps. An example is at | |
175 // chrome/test/data/extensions/api_test/serial/api/serial_arduino_test.ino. | |
176 // | |
177 #define SIMULATE_SERIAL_PORTS (1) | |
178 IN_PROC_BROWSER_TEST_F(SerialApiTest, SerialFakeHardware) { | |
179 ResultCatcher catcher; | |
180 catcher.RestrictToProfile(browser()->profile()); | |
181 | |
182 #if SIMULATE_SERIAL_PORTS | |
183 ASSERT_TRUE(extensions::ExtensionFunctionDispatcher::OverrideFunction( | |
184 "serial.getDevices", FakeSerialGetDevicesFunctionFactory)); | |
185 ASSERT_TRUE(extensions::ExtensionFunctionDispatcher::OverrideFunction( | |
186 "serial.connect", FakeSerialConnectFunctionFactory)); | |
187 #endif | |
188 | |
189 ASSERT_TRUE(RunExtensionTest("serial/api")) << message_; | |
190 } | |
191 | |
192 IN_PROC_BROWSER_TEST_F(SerialApiTest, SerialRealHardware) { | |
193 ResultCatcher catcher; | |
194 catcher.RestrictToProfile(browser()->profile()); | |
195 | |
196 ASSERT_TRUE(RunExtensionTest("serial/real_hardware")) << message_; | |
197 } | |
OLD | NEW |