| 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 |