[Presentation API] 1-UA: notify receiver page when receiver connection becomes available (blink sid…

content/renderer/presentation/presentation_dispatcher.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 "content/renderer/presentation/presentation_dispatcher.h"
 
 #include <utility>
 #include <vector>
 
 #include "base/bind.h"
 #include "base/logging.h"
 #include "base/memory/ptr_util.h"
 #include "content/public/common/presentation_constants.h"
 #include "content/public/renderer/render_frame.h"
 #include "content/renderer/presentation/presentation_connection_client.h"
 #include "services/shell/public/cpp/interface_provider.h"
 #include "third_party/WebKit/public/platform/WebString.h"
 #include "third_party/WebKit/public/platform/WebURL.h"
 #include "third_party/WebKit/public/platform/WebVector.h"
 #include "third_party/WebKit/public/platform/modules/presentation/WebPresentationAvailabilityObserver.h"
 #include "third_party/WebKit/public/platform/modules/presentation/WebPresentationController.h"
 #include "third_party/WebKit/public/platform/modules/presentation/WebPresentationError.h"
+#include "third_party/WebKit/public/platform/modules/presentation/WebPresentationReceiver.h"
 #include "third_party/WebKit/public/platform/modules/presentation/presentation.mojom.h"
 #include "third_party/WebKit/public/web/WebLocalFrame.h"
 #include "url/gurl.h"
 
 namespace {
 
 blink::WebPresentationError::ErrorType GetWebPresentationErrorTypeFromMojo(
     blink::mojom::PresentationErrorType mojoErrorType) {
   switch (mojoErrorType) {
     case blink::mojom::PresentationErrorType::NO_AVAILABLE_SCREENS:
@@ skipping 258 matching lines @@
     const blink::WebVector<blink::WebURL>& presentationUrls) {
   ConnectToPresentationServiceIfNeeded();
 
   std::vector<GURL> urls;
   for (const auto& url : presentationUrls)
     urls.push_back(url);
 
   presentation_service_->SetDefaultPresentationUrls(urls);
 }
 
+void PresentationDispatcher::setReceiver(
+    blink::WebPresentationReceiver* receiver) {
+  ConnectToPresentationServiceIfNeeded();
+  receiver_ = receiver;
+}
+
 void PresentationDispatcher::DidCommitProvisionalLoad(
     bool is_new_navigation,
     bool is_same_page_navigation) {
   blink::WebFrame* frame = render_frame()->GetWebFrame();
   // If not top-level navigation.
   if (frame->parent() || is_same_page_navigation)
     return;
 
   // Remove all pending send message requests.
   MessageRequestQueue empty;
@@ skipping 73 matching lines @@
         blink::WebString::fromUTF8(error->message)));
     return;
   }
 
   DCHECK(!session_info.is_null());
   presentation_service_->ListenForSessionMessages(session_info.Clone());
   callback->onSuccess(
       base::MakeUnique<PresentationConnectionClient>(std::move(session_info)));
 }
 
+void PresentationDispatcher::OnReceiverConnectionAvailable(
+    blink::mojom::PresentationSessionInfoPtr session_info) {
+  if (receiver_) {
+    receiver_->onReceiverConnectionAvailable(
+        new PresentationConnectionClient(std::move(session_info)));
+  }
+}
+
 void PresentationDispatcher::OnConnectionStateChanged(
     blink::mojom::PresentationSessionInfoPtr connection,
     blink::mojom::PresentationConnectionState state) {
   if (!controller_)
     return;
 
   DCHECK(!connection.is_null());
   controller_->didChangeSessionState(
       new PresentationConnectionClient(std::move(connection)),
       GetWebPresentationConnectionStateFromMojo(state));
@@ skipping 124 matching lines @@
 PresentationDispatcher::AvailabilityStatus::AvailabilityStatus(
     const GURL& availability_url)
     : url(availability_url),
       last_known_availability(false),
       listening_state(ListeningState::INACTIVE) {}
 
 PresentationDispatcher::AvailabilityStatus::~AvailabilityStatus() {
 }
 
 }  // namespace content