| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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 <string> | 5 #include <string> |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/bind_helpers.h" | 8 #include "base/bind_helpers.h" |
| 9 #include "base/memory/scoped_ptr.h" | 9 #include "base/memory/scoped_ptr.h" |
| 10 #include "base/run_loop.h" | 10 #include "base/run_loop.h" |
| (...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 56 expected->presentation_id != actual->presentation_id || | 56 expected->presentation_id != actual->presentation_id || |
| 57 expected->type != actual->type) { | 57 expected->type != actual->type) { |
| 58 return false; | 58 return false; |
| 59 } | 59 } |
| 60 return expected->is_binary() ? *(expected->data) == *(actual->data) | 60 return expected->is_binary() ? *(expected->data) == *(actual->data) |
| 61 : *(expected->message) == *(actual->message); | 61 : *(expected->message) == *(actual->message); |
| 62 } | 62 } |
| 63 | 63 |
| 64 } // namespace | 64 } // namespace |
| 65 | 65 |
| 66 // Adapts Invoke(), which takes a move-only scoped_ptr parameter (not mockable) | |
| 67 // to a variant that accepts raw pointers instead (mock friendly). | |
| 68 class RouteResponseCallbackHandler { | 66 class RouteResponseCallbackHandler { |
| 69 public: | 67 public: |
| 70 void Invoke(scoped_ptr<MediaRoute> route, const std::string& error_text) { | 68 MOCK_METHOD2(Invoke, |
| 71 InvokeObserver(route.get(), error_text); | 69 void(const MediaRoute* route, const std::string& error_text)); |
| 72 } | |
| 73 | |
| 74 MOCK_METHOD2(InvokeObserver, | |
| 75 void(MediaRoute* route, const std::string& error_text)); | |
| 76 }; | 70 }; |
| 77 | 71 |
| 78 class SendMessageCallbackHandler { | 72 class SendMessageCallbackHandler { |
| 79 public: | 73 public: |
| 80 MOCK_METHOD1(Invoke, void(bool)); | 74 MOCK_METHOD1(Invoke, void(bool)); |
| 81 }; | 75 }; |
| 82 | 76 |
| 83 class ListenForMessagesCallbackHandler { | 77 class ListenForMessagesCallbackHandler { |
| 84 public: | 78 public: |
| 85 ListenForMessagesCallbackHandler(scoped_ptr< | 79 ListenForMessagesCallbackHandler(scoped_ptr< |
| (...skipping 79 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 165 mojo::String(kOrigin), kTabId, _)) | 159 mojo::String(kOrigin), kTabId, _)) |
| 166 .WillOnce(Invoke([&route]( | 160 .WillOnce(Invoke([&route]( |
| 167 const mojo::String& source, const mojo::String& sink, | 161 const mojo::String& source, const mojo::String& sink, |
| 168 const mojo::String& presentation_id, const mojo::String& origin, | 162 const mojo::String& presentation_id, const mojo::String& origin, |
| 169 int tab_id, | 163 int tab_id, |
| 170 const interfaces::MediaRouteProvider::CreateRouteCallback& cb) { | 164 const interfaces::MediaRouteProvider::CreateRouteCallback& cb) { |
| 171 cb.Run(route.Pass(), mojo::String()); | 165 cb.Run(route.Pass(), mojo::String()); |
| 172 })); | 166 })); |
| 173 | 167 |
| 174 RouteResponseCallbackHandler handler; | 168 RouteResponseCallbackHandler handler; |
| 175 EXPECT_CALL(handler, InvokeObserver(Pointee(Equals(expected_route)), "")); | 169 EXPECT_CALL(handler, Invoke(Pointee(Equals(expected_route)), "")); |
| 170 std::vector<MediaRouteResponseCallback> route_response_callbacks; |
| 171 route_response_callbacks.push_back(base::Bind( |
| 172 &RouteResponseCallbackHandler::Invoke, base::Unretained(&handler))); |
| 176 router()->CreateRoute(kSource, kSink, GURL(kOrigin), kTabId, | 173 router()->CreateRoute(kSource, kSink, GURL(kOrigin), kTabId, |
| 177 base::Bind(&RouteResponseCallbackHandler::Invoke, | 174 route_response_callbacks); |
| 178 base::Unretained(&handler))); | |
| 179 ProcessEventLoop(); | 175 ProcessEventLoop(); |
| 180 } | 176 } |
| 181 | 177 |
| 182 TEST_F(MediaRouterMojoImplTest, CreateRouteFails) { | 178 TEST_F(MediaRouterMojoImplTest, CreateRouteFails) { |
| 183 EXPECT_CALL(mock_media_route_provider_, | 179 EXPECT_CALL(mock_media_route_provider_, |
| 184 CreateRoute(mojo::String(kSource), mojo::String(kSink), _, | 180 CreateRoute(mojo::String(kSource), mojo::String(kSink), _, |
| 185 mojo::String(kOrigin), kTabId, _)) | 181 mojo::String(kOrigin), kTabId, _)) |
| 186 .WillOnce(Invoke( | 182 .WillOnce(Invoke( |
| 187 [](const mojo::String& source, const mojo::String& sink, | 183 [](const mojo::String& source, const mojo::String& sink, |
| 188 const mojo::String& presentation_id, const mojo::String& origin, | 184 const mojo::String& presentation_id, const mojo::String& origin, |
| 189 int tab_id, | 185 int tab_id, |
| 190 const interfaces::MediaRouteProvider::CreateRouteCallback& cb) { | 186 const interfaces::MediaRouteProvider::CreateRouteCallback& cb) { |
| 191 cb.Run(interfaces::MediaRoutePtr(), mojo::String(kError)); | 187 cb.Run(interfaces::MediaRoutePtr(), mojo::String(kError)); |
| 192 })); | 188 })); |
| 193 | 189 |
| 194 RouteResponseCallbackHandler handler; | 190 RouteResponseCallbackHandler handler; |
| 195 EXPECT_CALL(handler, InvokeObserver(nullptr, kError)); | 191 EXPECT_CALL(handler, Invoke(nullptr, kError)); |
| 192 std::vector<MediaRouteResponseCallback> route_response_callbacks; |
| 193 route_response_callbacks.push_back(base::Bind( |
| 194 &RouteResponseCallbackHandler::Invoke, base::Unretained(&handler))); |
| 196 router()->CreateRoute(kSource, kSink, GURL(kOrigin), kTabId, | 195 router()->CreateRoute(kSource, kSink, GURL(kOrigin), kTabId, |
| 197 base::Bind(&RouteResponseCallbackHandler::Invoke, | 196 route_response_callbacks); |
| 198 base::Unretained(&handler))); | |
| 199 ProcessEventLoop(); | 197 ProcessEventLoop(); |
| 200 } | 198 } |
| 201 | 199 |
| 202 TEST_F(MediaRouterMojoImplTest, JoinRoute) { | 200 TEST_F(MediaRouterMojoImplTest, JoinRoute) { |
| 203 MediaRoute expected_route(kRouteId, MediaSource(std::string(kSource)), | 201 MediaRoute expected_route(kRouteId, MediaSource(std::string(kSource)), |
| 204 MediaSink(kSink, kSinkName), "", false); | 202 MediaSink(kSink, kSinkName), "", false); |
| 205 interfaces::MediaRoutePtr route = interfaces::MediaRoute::New(); | 203 interfaces::MediaRoutePtr route = interfaces::MediaRoute::New(); |
| 206 route->media_source = kSource; | 204 route->media_source = kSource; |
| 207 route->media_sink = interfaces::MediaSink::New(); | 205 route->media_sink = interfaces::MediaSink::New(); |
| 208 route->media_sink->sink_id = kSink; | 206 route->media_sink->sink_id = kSink; |
| 209 route->media_sink->name = kSinkName; | 207 route->media_sink->name = kSinkName; |
| 210 route->media_route_id = kRouteId; | 208 route->media_route_id = kRouteId; |
| 211 route->description = kDescription; | 209 route->description = kDescription; |
| 212 | 210 |
| 213 // Use a lambda function as an invocation target here to work around | 211 // Use a lambda function as an invocation target here to work around |
| 214 // a limitation with GMock::Invoke that prevents it from using move-only types | 212 // a limitation with GMock::Invoke that prevents it from using move-only types |
| 215 // in runnable parameter lists. | 213 // in runnable parameter lists. |
| 216 EXPECT_CALL(mock_media_route_provider_, | 214 EXPECT_CALL(mock_media_route_provider_, |
| 217 JoinRoute(mojo::String(kSource), mojo::String(kPresentationId), | 215 JoinRoute(mojo::String(kSource), mojo::String(kPresentationId), |
| 218 mojo::String(kOrigin), kTabId, _)) | 216 mojo::String(kOrigin), kTabId, _)) |
| 219 .WillOnce(Invoke([&route]( | 217 .WillOnce(Invoke([&route]( |
| 220 const mojo::String& source, const mojo::String& presentation_id, | 218 const mojo::String& source, const mojo::String& presentation_id, |
| 221 const mojo::String& origin, int tab_id, | 219 const mojo::String& origin, int tab_id, |
| 222 const interfaces::MediaRouteProvider::JoinRouteCallback& cb) { | 220 const interfaces::MediaRouteProvider::JoinRouteCallback& cb) { |
| 223 cb.Run(route.Pass(), mojo::String()); | 221 cb.Run(route.Pass(), mojo::String()); |
| 224 })); | 222 })); |
| 225 | 223 |
| 226 RouteResponseCallbackHandler handler; | 224 RouteResponseCallbackHandler handler; |
| 227 EXPECT_CALL(handler, InvokeObserver(Pointee(Equals(expected_route)), "")); | 225 EXPECT_CALL(handler, Invoke(Pointee(Equals(expected_route)), "")); |
| 226 std::vector<MediaRouteResponseCallback> route_response_callbacks; |
| 227 route_response_callbacks.push_back(base::Bind( |
| 228 &RouteResponseCallbackHandler::Invoke, base::Unretained(&handler))); |
| 228 router()->JoinRoute(kSource, kPresentationId, GURL(kOrigin), kTabId, | 229 router()->JoinRoute(kSource, kPresentationId, GURL(kOrigin), kTabId, |
| 229 base::Bind(&RouteResponseCallbackHandler::Invoke, | 230 route_response_callbacks); |
| 230 base::Unretained(&handler))); | |
| 231 ProcessEventLoop(); | 231 ProcessEventLoop(); |
| 232 } | 232 } |
| 233 | 233 |
| 234 TEST_F(MediaRouterMojoImplTest, JoinRouteFails) { | 234 TEST_F(MediaRouterMojoImplTest, JoinRouteFails) { |
| 235 EXPECT_CALL(mock_media_route_provider_, | 235 EXPECT_CALL(mock_media_route_provider_, |
| 236 JoinRoute(mojo::String(kSource), mojo::String(kPresentationId), | 236 JoinRoute(mojo::String(kSource), mojo::String(kPresentationId), |
| 237 mojo::String(kOrigin), kTabId, _)) | 237 mojo::String(kOrigin), kTabId, _)) |
| 238 .WillOnce(Invoke( | 238 .WillOnce(Invoke( |
| 239 [](const mojo::String& source, const mojo::String& presentation_id, | 239 [](const mojo::String& source, const mojo::String& presentation_id, |
| 240 const mojo::String& origin, int tab_id, | 240 const mojo::String& origin, int tab_id, |
| 241 const interfaces::MediaRouteProvider::JoinRouteCallback& cb) { | 241 const interfaces::MediaRouteProvider::JoinRouteCallback& cb) { |
| 242 cb.Run(interfaces::MediaRoutePtr(), mojo::String(kError)); | 242 cb.Run(interfaces::MediaRoutePtr(), mojo::String(kError)); |
| 243 })); | 243 })); |
| 244 | 244 |
| 245 RouteResponseCallbackHandler handler; | 245 RouteResponseCallbackHandler handler; |
| 246 EXPECT_CALL(handler, InvokeObserver(nullptr, kError)); | 246 EXPECT_CALL(handler, Invoke(nullptr, kError)); |
| 247 std::vector<MediaRouteResponseCallback> route_response_callbacks; |
| 248 route_response_callbacks.push_back(base::Bind( |
| 249 &RouteResponseCallbackHandler::Invoke, base::Unretained(&handler))); |
| 247 router()->JoinRoute(kSource, kPresentationId, GURL(kOrigin), kTabId, | 250 router()->JoinRoute(kSource, kPresentationId, GURL(kOrigin), kTabId, |
| 248 base::Bind(&RouteResponseCallbackHandler::Invoke, | 251 route_response_callbacks); |
| 249 base::Unretained(&handler))); | |
| 250 ProcessEventLoop(); | 252 ProcessEventLoop(); |
| 251 } | 253 } |
| 252 | 254 |
| 253 TEST_F(MediaRouterMojoImplTest, CloseRoute) { | 255 TEST_F(MediaRouterMojoImplTest, CloseRoute) { |
| 254 EXPECT_CALL(mock_media_route_provider_, CloseRoute(mojo::String(kRouteId))); | 256 EXPECT_CALL(mock_media_route_provider_, CloseRoute(mojo::String(kRouteId))); |
| 255 router()->CloseRoute(kRouteId); | 257 router()->CloseRoute(kRouteId); |
| 256 ProcessEventLoop(); | 258 ProcessEventLoop(); |
| 257 } | 259 } |
| 258 | 260 |
| 259 TEST_F(MediaRouterMojoImplTest, RegisterAndUnregisterMediaSinksObserver) { | 261 TEST_F(MediaRouterMojoImplTest, RegisterAndUnregisterMediaSinksObserver) { |
| (...skipping 255 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 515 binding.reset(new mojo::Binding<interfaces::MediaRouteProvider>( | 517 binding.reset(new mojo::Binding<interfaces::MediaRouteProvider>( |
| 516 &mock_media_route_provider, mojo::GetProxy(&media_route_provider_proxy))); | 518 &mock_media_route_provider, mojo::GetProxy(&media_route_provider_proxy))); |
| 517 media_router_proxy->RegisterMediaRouteProvider( | 519 media_router_proxy->RegisterMediaRouteProvider( |
| 518 media_route_provider_proxy.Pass(), | 520 media_route_provider_proxy.Pass(), |
| 519 base::Bind(&RegisterMediaRouteProviderHandler::Invoke, | 521 base::Bind(&RegisterMediaRouteProviderHandler::Invoke, |
| 520 base::Unretained(&provide_handler))); | 522 base::Unretained(&provide_handler))); |
| 521 message_loop.RunUntilIdle(); | 523 message_loop.RunUntilIdle(); |
| 522 } | 524 } |
| 523 | 525 |
| 524 } // namespace media_router | 526 } // namespace media_router |
| OLD | NEW |