[MediaRouter] Implement send binary message from PSDImpl to MRPManager

chrome/browser/media/router/media_router_mojo_impl_unittest.cc

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include <string>
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/run_loop.h"
@@ skipping 30 matching lines @@
 const char kSource[] = "source1";
 const char kSource2[] = "source2";
 const char kRouteId[] = "routeId";
 const char kRouteId2[] = "routeId2";
 const char kSink[] = "sink";
 const char kSink2[] = "sink2";
 const char kSinkName[] = "sinkName";
 const char kPresentationId[] = "presentationId";
 const char kOrigin[] = "http://origin/";
 const int kTabId = 123;
+const uint8 kBinaryMessage[] = {0x01, 0x02, 0x03, 0x04};
 
 bool ArePresentationSessionMessagesEqual(
     const content::PresentationSessionMessage* expected,
     const content::PresentationSessionMessage* actual) {
   if (expected->presentation_url != actual->presentation_url ||
       expected->presentation_id != actual->presentation_id ||
       expected->type != actual->type) {
     return false;
   }
   return expected->is_binary() ? *(expected->data) == *(actual->data)
@@ skipping 322 matching lines @@
       }));
 
   SendMessageCallbackHandler handler;
   EXPECT_CALL(handler, Invoke(true));
   router()->SendRouteMessage(kRouteId, kMessage,
                              base::Bind(&SendMessageCallbackHandler::Invoke,
                                         base::Unretained(&handler)));
   ProcessEventLoop();
 }
 
+TEST_F(MediaRouterMojoImplTest, SendRouteBinaryMessage) {
+  scoped_ptr<std::vector<uint8>> expected_binary_data(new std::vector<uint8>(
+      kBinaryMessage, kBinaryMessage + arraysize(kBinaryMessage)));
+
+  EXPECT_CALL(mock_media_route_provider_,
+              SendRouteBinaryMessageInternal(mojo::String(kRouteId), _, _))
+      .WillOnce(Invoke([](
+          const MediaRoute::Id& route_id, const std::vector<uint8>& data,
+          const interfaces::MediaRouteProvider::SendRouteMessageCallback& cb) {
+        EXPECT_EQ(
+            0, memcmp(kBinaryMessage, &(data[0]), arraysize(kBinaryMessage)));
+        cb.Run(true);
+      }));
+
+  SendMessageCallbackHandler handler;
+  EXPECT_CALL(handler, Invoke(true));
+  router()->SendRouteBinaryMessage(
+      kRouteId, expected_binary_data.Pass(),
+      base::Bind(&SendMessageCallbackHandler::Invoke,
+                 base::Unretained(&handler)));
+  ProcessEventLoop();
+}
+
 TEST_F(MediaRouterMojoImplTest, ListenForRouteMessages) {
   mojo::Array<interfaces::RouteMessagePtr> mojo_messages(2);
   mojo_messages[0] = interfaces::RouteMessage::New();
   mojo_messages[0]->route_id = "r1";
   mojo_messages[0]->type = interfaces::RouteMessage::Type::TYPE_TEXT;
   mojo_messages[0]->message = "text";
   mojo_messages[1] = interfaces::RouteMessage::New();
   mojo_messages[1]->route_id = "r2";
   mojo_messages[1]->type = interfaces::RouteMessage::Type::TYPE_BINARY;
   mojo_messages[1]->data.push_back(1);
@@ skipping 114 matching lines @@
   binding.reset(new mojo::Binding<interfaces::MediaRouteProvider>(
       &mock_media_route_provider, mojo::GetProxy(&media_route_provider_proxy)));
   media_router_proxy->RegisterMediaRouteProvider(
       media_route_provider_proxy.Pass(),
       base::Bind(&RegisterMediaRouteProviderHandler::Invoke,
                  base::Unretained(&provide_handler)));
   message_loop.RunUntilIdle();
 }
 
 }  // namespace media_router