OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include <queue> | 5 #include <queue> |
6 | 6 |
7 #include "device/serial/data_source_sender.h" | 7 #include "device/serial/data_source_sender.h" |
8 #include "device/serial/data_stream.mojom.h" | 8 #include "device/serial/data_stream.mojom.h" |
9 #include "extensions/renderer/api_test_base.h" | 9 #include "extensions/renderer/api_test_base.h" |
10 #include "gin/dictionary.h" | |
11 #include "gin/wrappable.h" | |
12 #include "grit/extensions_renderer_resources.h" | 10 #include "grit/extensions_renderer_resources.h" |
13 | 11 |
14 namespace extensions { | 12 namespace extensions { |
15 | 13 |
16 class DataReceiverFactory : public gin::Wrappable<DataReceiverFactory> { | |
17 public: | |
18 using Callback = base::Callback<void( | |
19 mojo::InterfaceRequest<device::serial::DataSource>, | |
20 mojo::InterfacePtr<device::serial::DataSourceClient>)>; | |
21 static gin::Handle<DataReceiverFactory> Create(v8::Isolate* isolate, | |
22 const Callback& callback) { | |
23 return gin::CreateHandle(isolate, | |
24 new DataReceiverFactory(callback, isolate)); | |
25 } | |
26 | |
27 gin::ObjectTemplateBuilder GetObjectTemplateBuilder( | |
28 v8::Isolate* isolate) override { | |
29 return Wrappable<DataReceiverFactory>::GetObjectTemplateBuilder(isolate) | |
30 .SetMethod("create", &DataReceiverFactory::CreateReceiver); | |
31 } | |
32 | |
33 gin::Dictionary CreateReceiver() { | |
34 mojo::InterfacePtr<device::serial::DataSource> sink; | |
35 mojo::InterfacePtr<device::serial::DataSourceClient> client; | |
36 mojo::InterfaceRequest<device::serial::DataSourceClient> client_request = | |
37 mojo::GetProxy(&client); | |
38 callback_.Run(mojo::GetProxy(&sink), client.Pass()); | |
39 | |
40 gin::Dictionary result = gin::Dictionary::CreateEmpty(isolate_); | |
41 result.Set("source", sink.PassMessagePipe().release()); | |
42 result.Set("client", client_request.PassMessagePipe().release()); | |
43 return result; | |
44 } | |
45 | |
46 static gin::WrapperInfo kWrapperInfo; | |
47 | |
48 private: | |
49 DataReceiverFactory(const Callback& callback, v8::Isolate* isolate) | |
50 : callback_(callback), isolate_(isolate) {} | |
51 | |
52 base::Callback<void(mojo::InterfaceRequest<device::serial::DataSource>, | |
53 mojo::InterfacePtr<device::serial::DataSourceClient>)> | |
54 callback_; | |
55 v8::Isolate* isolate_; | |
56 }; | |
57 | |
58 gin::WrapperInfo DataReceiverFactory::kWrapperInfo = {gin::kEmbedderNativeGin}; | |
59 | |
60 // Runs tests defined in extensions/test/data/data_receiver_unittest.js | 14 // Runs tests defined in extensions/test/data/data_receiver_unittest.js |
61 class DataReceiverTest : public ApiTestBase { | 15 class DataReceiverTest : public ApiTestBase { |
62 public: | 16 public: |
63 DataReceiverTest() {} | 17 DataReceiverTest() {} |
64 | 18 |
65 void SetUp() override { | 19 void SetUp() override { |
66 ApiTestBase::SetUp(); | 20 ApiTestBase::SetUp(); |
67 gin::ModuleRegistry::From(env()->context()->v8_context()) | 21 service_provider()->AddService(base::Bind( |
68 ->AddBuiltinModule(env()->isolate(), | 22 &DataReceiverTest::CreateDataSource, base::Unretained(this))); |
69 "device/serial/data_receiver_test_factory", | |
70 DataReceiverFactory::Create( | |
71 env()->isolate(), | |
72 base::Bind(&DataReceiverTest::CreateDataSource, | |
73 base::Unretained(this))).ToV8()); | |
74 } | 23 } |
75 | 24 |
76 void TearDown() override { | 25 void TearDown() override { |
77 if (sender_.get()) { | 26 if (sender_.get()) { |
78 sender_->ShutDown(); | 27 sender_->ShutDown(); |
79 sender_ = NULL; | 28 sender_ = NULL; |
80 } | 29 } |
81 ApiTestBase::TearDown(); | 30 ApiTestBase::TearDown(); |
82 } | 31 } |
83 | 32 |
84 std::queue<int32_t> error_to_send_; | 33 std::queue<int32_t> error_to_send_; |
85 std::queue<std::string> data_to_send_; | 34 std::queue<std::string> data_to_send_; |
86 | 35 |
87 private: | 36 private: |
88 void CreateDataSource( | 37 void CreateDataSource( |
89 mojo::InterfaceRequest<device::serial::DataSource> request, | 38 mojo::InterfaceRequest<device::serial::DataSource> request) { |
90 mojo::InterfacePtr<device::serial::DataSourceClient> client) { | 39 sender_ = mojo::WeakBindToRequest( |
91 sender_ = new device::DataSourceSender( | 40 new device::DataSourceSender( |
92 request.Pass(), client.Pass(), | 41 base::Bind(&DataReceiverTest::ReadyToSend, base::Unretained(this)), |
93 base::Bind(&DataReceiverTest::ReadyToSend, base::Unretained(this)), | 42 base::Bind(base::DoNothing)), |
94 base::Bind(base::DoNothing)); | 43 &request); |
95 } | 44 } |
96 | 45 |
97 void ReadyToSend(scoped_ptr<device::WritableBuffer> buffer) { | 46 void ReadyToSend(scoped_ptr<device::WritableBuffer> buffer) { |
98 if (data_to_send_.empty() && error_to_send_.empty()) | 47 if (data_to_send_.empty() && error_to_send_.empty()) |
99 return; | 48 return; |
100 | 49 |
101 std::string data; | 50 std::string data; |
102 int32_t error = 0; | 51 int32_t error = 0; |
103 if (!data_to_send_.empty()) { | 52 if (!data_to_send_.empty()) { |
104 data = data_to_send_.front(); | 53 data = data_to_send_.front(); |
(...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
170 data_to_send_.push("a"); | 119 data_to_send_.push("a"); |
171 RunTest("data_receiver_unittest.js", "testSerializeDuringReceive"); | 120 RunTest("data_receiver_unittest.js", "testSerializeDuringReceive"); |
172 } | 121 } |
173 | 122 |
174 TEST_F(DataReceiverTest, SerializeAfterClose) { | 123 TEST_F(DataReceiverTest, SerializeAfterClose) { |
175 data_to_send_.push("a"); | 124 data_to_send_.push("a"); |
176 RunTest("data_receiver_unittest.js", "testSerializeAfterClose"); | 125 RunTest("data_receiver_unittest.js", "testSerializeAfterClose"); |
177 } | 126 } |
178 | 127 |
179 } // namespace extensions | 128 } // namespace extensions |
OLD | NEW |