[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 <algorithm>
 #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/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 262 matching lines @@
 void PresentationDispatcher::setDefaultPresentationUrls(
     const blink::WebVector<blink::WebString>& presentationUrls) {
   ConnectToPresentationServiceIfNeeded();
 
   std::vector<GURL> urls(presentationUrls.size());
   std::transform(presentationUrls.begin(), presentationUrls.end(), urls.begin(),
                  [](const blink::WebString& url) { return GURL(url.utf8()); });
   presentation_service_->SetDefaultPresentationUrls(urls);
 }
 
+void PresentationDispatcher::setReceiver(
+    blink::WebPresentationReceiver* receiver) {
+  ConnectToPresentationServiceIfNeeded();
+  m_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 (m_receiver)

[mark a. foltz, 2016/09/15 16:53:18]

What if this is called before m_receiver is set?  I believe you'll need to queue
up connections in that case.

[zhaobin, 2016/09/15 18:56:03]

Yes. Going to send out another CL with queuing logic.

+    m_receiver->onReceiverConnectionAvailable(
+        new PresentationConnectionClient(std::move(session_info)));

[mlamouri (slow - plz ping), 2016/09/15 10:49:39]

style: add {} when the statement is wrapped in more than one line.

[zhaobin, 2016/09/15 18:56:03]

Done.

+}
+
 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 125 matching lines @@
 PresentationDispatcher::AvailabilityStatus::AvailabilityStatus(
     const std::string& availability_url)
     : url(availability_url),
       last_known_availability(false),
       listening_state(ListeningState::INACTIVE) {}
 
 PresentationDispatcher::AvailabilityStatus::~AvailabilityStatus() {
 }
 
 }  // namespace content