[Media Router] Implement JoinRoute + update CreateRoute API.

chrome/browser/media/router/media_router_mojo_impl.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 "chrome/browser/media/router/media_router_mojo_impl.h"
 
 #include "base/bind.h"
 #include "base/guid.h"
 #include "base/logging.h"
 #include "base/observer_list.h"
 #include "chrome/browser/media/router/media_router_mojo_impl_factory.h"
 #include "chrome/browser/media/router/media_router_type_converters.h"
 #include "chrome/browser/media/router/media_routes_observer.h"
 #include "chrome/browser/media/router/media_sinks_observer.h"
 #include "extensions/browser/process_manager.h"
 
 #define DVLOG_WITH_INSTANCE(level) \
   DVLOG(level) << "MR #" << instance_id_ << ": "
 
 #define DLOG_WITH_INSTANCE(level) DLOG(level) << "MR #" << instance_id_ << ": "
 
 namespace media_router {
 namespace {
 
-// Converts the callback result of calling Mojo CreateRoute() into a local
-// callback.
-void CreateRouteFinished(const MediaSink::Id& sink_id,
-                         const MediaRouteResponseCallback& callback,
-                         interfaces::MediaRoutePtr media_route,
-                         const mojo::String& error_text) {
+// Converts the callback result of calling Mojo CreateRoute()/JoinRoute()
+// into a local callback.
+void RouteResponseReceived(const MediaRouteResponseCallback& callback,
+                           interfaces::MediaRoutePtr media_route,
+                           const mojo::String& error_text) {
   if (media_route.is_null()) {
     // An error occurred.
     DCHECK(!error_text.is_null());
     callback.Run(nullptr, !error_text.get().empty() ? error_text.get()
                                                     : "Unknown error.");
     return;
   }
   callback.Run(media_route.To<scoped_ptr<MediaRoute>>(), "");
 }
 
@@ skipping 112 matching lines @@
     routes_converted.push_back(routes[i].To<MediaRoute>());
   }
 
   FOR_EACH_OBSERVER(MediaRoutesObserver, routes_observers_,
                     OnRoutesUpdated(routes_converted));
 }
 
 void MediaRouterMojoImpl::CreateRoute(
     const MediaSource::Id& source_id,
     const MediaSink::Id& sink_id,
+    const GURL& origin,
+    int tab_id,
     const MediaRouteResponseCallback& callback) {
   DCHECK(thread_checker_.CalledOnValidThread());
 
-  RunOrDefer(base::Bind(&MediaRouterMojoImpl::DoCreateRoute,
-                        base::Unretained(this), source_id, sink_id, callback));
+  if (!origin.is_empty() && !origin.is_valid()) {
+    DVLOG_WITH_INSTANCE(1) << "Invalid origin: " << origin;
+    callback.Run(nullptr, "Invalid origin");
+    return;
+  }
+  RunOrDefer(base::Bind(
+      &MediaRouterMojoImpl::DoCreateRoute, base::Unretained(this), source_id,
+      sink_id, origin.is_empty() ? "" : origin.spec(), tab_id, callback));
+}
+
+void MediaRouterMojoImpl::JoinRoute(
+    const MediaSource::Id& source_id,
+    const std::string& presentation_id,
+    const GURL& origin,
+    int tab_id,
+    const MediaRouteResponseCallback& callback) {
+  DCHECK(thread_checker_.CalledOnValidThread());
+
+  if (!origin.is_empty() && !origin.is_valid()) {
+    DVLOG_WITH_INSTANCE(1) << "Invalid origin: " << origin;
+    callback.Run(nullptr, "Invalid origin");
+    return;
+  }
+  RunOrDefer(base::Bind(&MediaRouterMojoImpl::DoJoinRoute,
+                        base::Unretained(this), source_id, presentation_id,
+                        origin.is_empty() ? "" : origin.spec(), tab_id,
+                        callback));
 }
 
 void MediaRouterMojoImpl::CloseRoute(const MediaRoute::Id& route_id) {
   DCHECK(thread_checker_.CalledOnValidThread());
 
   RunOrDefer(base::Bind(&MediaRouterMojoImpl::DoCloseRoute,
                         base::Unretained(this), route_id));
 }
 
 void MediaRouterMojoImpl::PostMessage(const MediaRoute::Id& route_id,
@@ skipping 85 matching lines @@
 }
 
 void MediaRouterMojoImpl::RemoveIssuesObserver(IssuesObserver* observer) {
   // TODO(imcheng): Implement. (crbug.com/461815)
   NOTIMPLEMENTED();
 }
 
 void MediaRouterMojoImpl::DoCreateRoute(
     const MediaSource::Id& source_id,
     const MediaSink::Id& sink_id,
+    const std::string& origin,
+    int tab_id,
     const MediaRouteResponseCallback& callback) {
-  DVLOG_WITH_INSTANCE(1) << "CreateRoute " << source_id << "=>" << sink_id;
-  mojo_media_router_->CreateRoute(
-      source_id, sink_id, base::Bind(&CreateRouteFinished, sink_id, callback));
+  std::string presentation_id(base::GenerateGUID());

[mark a. foltz, 2015/06/10 23:18:51]

I feel like this should have a prefix like "mr-" to distinguish it from other
GUIDs passed around.

[imcheng (use chromium acct), 2015/06/11 22:49:12]

Yes we should have mr_ per the Start + Join doc.

+  DVLOG_WITH_INSTANCE(1) << "DoCreateRoute " << source_id << "=>" << sink_id
+                         << ", presentation ID: " << presentation_id;
+  mojo_media_router_->CreateRoute(source_id, sink_id, presentation_id, origin,
+                                  tab_id,
+                                  base::Bind(&RouteResponseReceived, callback));
+}
+
+void MediaRouterMojoImpl::DoJoinRoute(
+    const MediaSource::Id& source_id,
+    const std::string& presentation_id,
+    const std::string& origin,
+    int tab_id,
+    const MediaRouteResponseCallback& callback) {
+  DVLOG_WITH_INSTANCE(1) << "DoJoinRoute " << source_id
+                         << ", presentation ID: " << presentation_id;
+  mojo_media_router_->JoinRoute(source_id, presentation_id, origin, tab_id,
+                                base::Bind(&RouteResponseReceived, callback));
 }
 
 void MediaRouterMojoImpl::DoCloseRoute(const MediaRoute::Id& route_id) {
-  DVLOG_WITH_INSTANCE(1) << "CloseRoute " << route_id;
+  DVLOG_WITH_INSTANCE(1) << "DoCloseRoute " << route_id;
   mojo_media_router_->CloseRoute(route_id);
 }
 
 void MediaRouterMojoImpl::DoPostMessage(const MediaRoute::Id& route_id,
                                         const std::string& message) {
-  DVLOG_WITH_INSTANCE(1) << "PostMessage " << route_id;
+  DVLOG_WITH_INSTANCE(1) << "DoPostMessage " << route_id;
   mojo_media_router_->PostMessage(route_id, message);
 }
 
 void MediaRouterMojoImpl::DoClearIssue(const Issue::Id& issue_id) {
-  DVLOG_WITH_INSTANCE(1) << "ClearIssue " << issue_id;
+  DVLOG_WITH_INSTANCE(1) << "DoClearIssue " << issue_id;
   mojo_media_router_->ClearIssue(issue_id);
 }
 
 void MediaRouterMojoImpl::DoStartObservingMediaSinks(
-    const std::string& source_id) {
-  DVLOG_WITH_INSTANCE(1) << "StartObservingMediaSinks: " << source_id;
+    const MediaSource::Id& source_id) {
+  DVLOG_WITH_INSTANCE(1) << "DoStartObservingMediaSinks: " << source_id;
   mojo_media_router_->StartObservingMediaSinks(source_id);
 }
 
 void MediaRouterMojoImpl::DoStopObservingMediaSinks(
-    const std::string& source_id) {
-  DVLOG_WITH_INSTANCE(1) << "StopObservingMediaSinks: " << source_id;
+    const MediaSource::Id& source_id) {
+  DVLOG_WITH_INSTANCE(1) << "DoStopObservingMediaSinks: " << source_id;
   mojo_media_router_->StopObservingMediaSinks(source_id);
 }
 
 void MediaRouterMojoImpl::DoStartObservingMediaRoutes() {
-  DVLOG_WITH_INSTANCE(1) << "StartObservingMediaRoutes";
+  DVLOG_WITH_INSTANCE(1) << "DoStartObservingMediaRoutes";
   mojo_media_router_->StartObservingMediaRoutes();
 }
 
 void MediaRouterMojoImpl::DoStopObservingMediaRoutes() {
-  DVLOG_WITH_INSTANCE(1) << "StopObservingMediaRoutes";
+  DVLOG_WITH_INSTANCE(1) << "DoStopObservingMediaRoutes";
   mojo_media_router_->StopObservingMediaRoutes();
 }
 
 void MediaRouterMojoImpl::EnqueueTask(const base::Closure& closure) {
   pending_requests_.push_back(closure);
   DVLOG_WITH_INSTANCE(2) << "EnqueueTask (queue-length="
                          << pending_requests_.size() << ")";
 }
 
 void MediaRouterMojoImpl::RunOrDefer(const base::Closure& request) {
@@ skipping 34 matching lines @@
     return;
   }
 
   for (const auto& next_request : pending_requests_)
     next_request.Run();
 
   pending_requests_.clear();
 }
 
 }  // namespace media_router