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 "components/proximity_auth/connection.h" | 5 #include "components/proximity_auth/connection.h" |
6 | 6 |
7 #include "components/proximity_auth/connection_observer.h" | 7 #include "components/proximity_auth/connection_observer.h" |
8 #include "components/proximity_auth/wire_message.h" | 8 #include "components/proximity_auth/wire_message.h" |
9 #include "testing/gmock/include/gmock/gmock.h" | 9 #include "testing/gmock/include/gmock/gmock.h" |
10 #include "testing/gtest/include/gtest/gtest.h" | 10 #include "testing/gtest/include/gtest/gtest.h" |
11 | 11 |
12 using testing::_; | 12 using testing::_; |
| 13 using testing::DoAll; |
13 using testing::NiceMock; | 14 using testing::NiceMock; |
14 using testing::Return; | 15 using testing::Return; |
| 16 using testing::SetArgPointee; |
15 using testing::StrictMock; | 17 using testing::StrictMock; |
16 | 18 |
17 namespace proximity_auth { | 19 namespace proximity_auth { |
18 namespace { | 20 namespace { |
19 | 21 |
20 class MockConnection : public Connection { | 22 class MockConnection : public Connection { |
21 public: | 23 public: |
22 MockConnection() : Connection(RemoteDevice()) {} | 24 MockConnection() : Connection(RemoteDevice()) {} |
23 ~MockConnection() {} | 25 ~MockConnection() {} |
24 | 26 |
25 MOCK_METHOD1(SetPaused, void(bool paused)); | 27 MOCK_METHOD1(SetPaused, void(bool paused)); |
26 MOCK_METHOD0(Connect, void()); | 28 MOCK_METHOD0(Connect, void()); |
27 MOCK_METHOD0(Disconnect, void()); | 29 MOCK_METHOD0(Disconnect, void()); |
28 MOCK_METHOD0(CancelConnectionAttempt, void()); | 30 MOCK_METHOD0(CancelConnectionAttempt, void()); |
29 MOCK_METHOD1(SendMessageImplProxy, void(WireMessage* message)); | 31 MOCK_METHOD1(SendMessageImplProxy, void(WireMessage* message)); |
30 MOCK_METHOD0(HasReceivedCompleteMessage, bool()); | 32 MOCK_METHOD1(DeserializeWireMessageProxy, |
31 MOCK_METHOD0(DeserializeWireMessageProxy, WireMessage*()); | 33 WireMessage*(bool* is_incomplete_message)); |
32 | 34 |
33 // Gmock only supports copyable types, so create simple wrapper methods for | 35 // Gmock only supports copyable types, so create simple wrapper methods for |
34 // ease of mocking. | 36 // ease of mocking. |
35 virtual void SendMessageImpl(scoped_ptr<WireMessage> message) OVERRIDE { | 37 virtual void SendMessageImpl(scoped_ptr<WireMessage> message) OVERRIDE { |
36 SendMessageImplProxy(message.get()); | 38 SendMessageImplProxy(message.get()); |
37 } | 39 } |
38 | 40 |
39 virtual scoped_ptr<WireMessage> DeserializeWireMessage() OVERRIDE { | 41 virtual scoped_ptr<WireMessage> DeserializeWireMessage( |
40 return make_scoped_ptr(DeserializeWireMessageProxy()); | 42 bool* is_incomplete_message) OVERRIDE { |
| 43 return make_scoped_ptr(DeserializeWireMessageProxy(is_incomplete_message)); |
41 } | 44 } |
42 | 45 |
43 using Connection::status; | 46 using Connection::status; |
44 using Connection::SetStatus; | 47 using Connection::SetStatus; |
45 using Connection::OnDidSendMessage; | 48 using Connection::OnDidSendMessage; |
46 using Connection::OnBytesReceived; | 49 using Connection::OnBytesReceived; |
47 | 50 |
48 private: | 51 private: |
49 DISALLOW_COPY_AND_ASSIGN(MockConnection); | 52 DISALLOW_COPY_AND_ASSIGN(MockConnection); |
50 }; | 53 }; |
(...skipping 14 matching lines...) Expand all Loading... |
65 const WireMessage& message, | 68 const WireMessage& message, |
66 bool success)); | 69 bool success)); |
67 | 70 |
68 private: | 71 private: |
69 DISALLOW_COPY_AND_ASSIGN(MockConnectionObserver); | 72 DISALLOW_COPY_AND_ASSIGN(MockConnectionObserver); |
70 }; | 73 }; |
71 | 74 |
72 // Unlike WireMessage, offers a public constructor. | 75 // Unlike WireMessage, offers a public constructor. |
73 class TestWireMessage : public WireMessage { | 76 class TestWireMessage : public WireMessage { |
74 public: | 77 public: |
75 TestWireMessage() {} | 78 TestWireMessage() : WireMessage(std::string(), std::string()) {} |
76 virtual ~TestWireMessage() {} | 79 virtual ~TestWireMessage() {} |
77 | 80 |
78 private: | 81 private: |
79 DISALLOW_COPY_AND_ASSIGN(TestWireMessage); | 82 DISALLOW_COPY_AND_ASSIGN(TestWireMessage); |
80 }; | 83 }; |
81 | 84 |
82 } // namespace | 85 } // namespace |
83 | 86 |
84 TEST(ProximityAuthConnectionTest, IsConnected) { | 87 TEST(ProximityAuthConnectionTest, IsConnected) { |
85 StrictMock<MockConnection> connection; | 88 StrictMock<MockConnection> connection; |
(...skipping 98 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
184 } | 187 } |
185 | 188 |
186 TEST(ProximityAuthConnectionTest, | 189 TEST(ProximityAuthConnectionTest, |
187 OnBytesReceived_NotifiesObserversOnValidMessage) { | 190 OnBytesReceived_NotifiesObserversOnValidMessage) { |
188 NiceMock<MockConnection> connection; | 191 NiceMock<MockConnection> connection; |
189 connection.SetStatus(Connection::CONNECTED); | 192 connection.SetStatus(Connection::CONNECTED); |
190 | 193 |
191 StrictMock<MockConnectionObserver> observer; | 194 StrictMock<MockConnectionObserver> observer; |
192 connection.AddObserver(&observer); | 195 connection.AddObserver(&observer); |
193 | 196 |
194 ON_CALL(connection, HasReceivedCompleteMessage()).WillByDefault(Return(true)); | 197 ON_CALL(connection, DeserializeWireMessageProxy(_)) |
195 ON_CALL(connection, DeserializeWireMessageProxy()) | 198 .WillByDefault(DoAll(SetArgPointee<0>(false), |
196 .WillByDefault(Return(new TestWireMessage)); | 199 Return(new TestWireMessage))); |
197 EXPECT_CALL(observer, OnMessageReceived(Ref(connection), _)); | 200 EXPECT_CALL(observer, OnMessageReceived(Ref(connection), _)); |
198 connection.OnBytesReceived(std::string()); | 201 connection.OnBytesReceived(std::string()); |
199 } | 202 } |
200 | 203 |
201 TEST(ProximityAuthConnectionTest, | 204 TEST(ProximityAuthConnectionTest, |
202 OnBytesReceived_DoesntNotifyObserversIfNotConnected) { | 205 OnBytesReceived_DoesntNotifyObserversIfNotConnected) { |
203 StrictMock<MockConnection> connection; | 206 StrictMock<MockConnection> connection; |
204 connection.SetStatus(Connection::IN_PROGRESS); | 207 connection.SetStatus(Connection::IN_PROGRESS); |
205 | 208 |
206 StrictMock<MockConnectionObserver> observer; | 209 StrictMock<MockConnectionObserver> observer; |
207 connection.AddObserver(&observer); | 210 connection.AddObserver(&observer); |
208 | 211 |
209 EXPECT_CALL(observer, OnMessageReceived(_, _)).Times(0); | 212 EXPECT_CALL(observer, OnMessageReceived(_, _)).Times(0); |
210 connection.OnBytesReceived(std::string()); | 213 connection.OnBytesReceived(std::string()); |
211 } | 214 } |
212 | 215 |
213 TEST(ProximityAuthConnectionTest, | 216 TEST(ProximityAuthConnectionTest, |
214 OnBytesReceived_DoesntNotifyObserversIfMessageIsIncomplete) { | 217 OnBytesReceived_DoesntNotifyObserversIfMessageIsIncomplete) { |
215 NiceMock<MockConnection> connection; | 218 NiceMock<MockConnection> connection; |
216 connection.SetStatus(Connection::CONNECTED); | 219 connection.SetStatus(Connection::CONNECTED); |
217 | 220 |
218 StrictMock<MockConnectionObserver> observer; | 221 StrictMock<MockConnectionObserver> observer; |
219 connection.AddObserver(&observer); | 222 connection.AddObserver(&observer); |
220 | 223 |
221 ON_CALL(connection, HasReceivedCompleteMessage()) | 224 ON_CALL(connection, DeserializeWireMessageProxy(_)) |
222 .WillByDefault(Return(false)); | 225 .WillByDefault(DoAll(SetArgPointee<0>(true), |
| 226 Return(static_cast<WireMessage*>(NULL)))); |
223 EXPECT_CALL(observer, OnMessageReceived(_, _)).Times(0); | 227 EXPECT_CALL(observer, OnMessageReceived(_, _)).Times(0); |
224 connection.OnBytesReceived(std::string()); | 228 connection.OnBytesReceived(std::string()); |
225 } | 229 } |
226 | 230 |
227 TEST(ProximityAuthConnectionTest, | 231 TEST(ProximityAuthConnectionTest, |
228 OnBytesReceived_DoesntNotifyObserversIfMessageIsInvalid) { | 232 OnBytesReceived_DoesntNotifyObserversIfMessageIsInvalid) { |
229 NiceMock<MockConnection> connection; | 233 NiceMock<MockConnection> connection; |
230 connection.SetStatus(Connection::CONNECTED); | 234 connection.SetStatus(Connection::CONNECTED); |
231 | 235 |
232 StrictMock<MockConnectionObserver> observer; | 236 StrictMock<MockConnectionObserver> observer; |
233 connection.AddObserver(&observer); | 237 connection.AddObserver(&observer); |
234 | 238 |
235 ON_CALL(connection, HasReceivedCompleteMessage()).WillByDefault(Return(true)); | 239 ON_CALL(connection, DeserializeWireMessageProxy(_)) |
236 ON_CALL(connection, DeserializeWireMessageProxy()) | 240 .WillByDefault(DoAll(SetArgPointee<0>(false), |
237 .WillByDefault(Return(static_cast<WireMessage*>(NULL))); | 241 Return(static_cast<WireMessage*>(NULL)))); |
238 EXPECT_CALL(observer, OnMessageReceived(_, _)).Times(0); | 242 EXPECT_CALL(observer, OnMessageReceived(_, _)).Times(0); |
239 connection.OnBytesReceived(std::string()); | 243 connection.OnBytesReceived(std::string()); |
240 } | 244 } |
241 | 245 |
242 } // namespace proximity_auth | 246 } // namespace proximity_auth |
OLD | NEW |