Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(211)

Side by Side Diff: extensions/renderer/api/serial/data_receiver_unittest.cc

Issue 873293006: Revert of Remove Client= from device/serial/data_stream.mojom. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 5 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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
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
OLDNEW
« no previous file with comments | « device/serial/serial_service_unittest.cc ('k') | extensions/renderer/api/serial/data_sender_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698