[Presentation API] 1-UA presentation support + presenter APIs.

chrome/browser/media/router/receiver_presentation_service_delegate_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/receiver_presentation_service_delegate_impl.h"
+
+#include "chrome/browser/media/router/offscreen_presentation_manager.h"
+#include "chrome/browser/media/router/offscreen_presentation_manager_factory.h"
+#include "chrome/browser/profiles/profile.h"
+#include "content/public/browser/presentation_session_state_listener.h"
+#include "content/public/browser/render_frame_host.h"
+#include "content/public/browser/render_process_host.h"
+
+DEFINE_WEB_CONTENTS_USER_DATA_KEY(
+    media_router::ReceiverPresentationServiceDelegateImpl);
+
+using content::PresentationServiceDelegate;
+using content::RenderFrameHost;
+
+namespace media_router {
+
+using OffscreenPresentationSession =
+    OffscreenPresentationManager::OffscreenPresentationSession;
+
+// static
+void ReceiverPresentationServiceDelegateImpl::CreateForWebContents(
+    content::WebContents* web_contents,
+    const std::string& presentation_id) {
+  DCHECK(web_contents);
+
+  if (FromWebContents(web_contents))
+    return;
+
+  web_contents->SetUserData(UserDataKey(),
+                            new ReceiverPresentationServiceDelegateImpl(
+                                web_contents, presentation_id));
+}
+
+ReceiverPresentationServiceDelegateImpl::
+    ~ReceiverPresentationServiceDelegateImpl() {
+  for (auto& observer_pair : observers_)
+    observer_pair.second->OnDelegateDestroyed();
+
+  receiver_sessions_.clear();
+  offscreen_presentation_manager_->UnregisterOffscreenPresentationReceiver(
+      presentation_id_);
+}
+
+void ReceiverPresentationServiceDelegateImpl::AddObserver(
+    int render_process_id,
+    int render_frame_id,
+    content::PresentationServiceDelegate::Observer* observer) {
+  DCHECK(observer);
+
+  RenderFrameHostId rfh_id(render_process_id, render_frame_id);
+  DCHECK(!ContainsKey(observers_, rfh_id));
+  observers_[rfh_id] = observer;
+}
+
+void ReceiverPresentationServiceDelegateImpl::RemoveObserver(
+    int render_process_id,
+    int render_frame_id) {
+  observers_.erase(RenderFrameHostId(render_process_id, render_frame_id));
+}
+
+bool ReceiverPresentationServiceDelegateImpl::AddScreenAvailabilityListener(
+    int render_process_id,
+    int render_frame_id,
+    content::PresentationScreenAvailabilityListener* listener) {
+  NOTIMPLEMENTED();
+  return false;
+}
+
+void ReceiverPresentationServiceDelegateImpl::RemoveScreenAvailabilityListener(
+    int render_process_id,
+    int render_frame_id,
+    content::PresentationScreenAvailabilityListener* listener) {
+  NOTIMPLEMENTED();
+}
+
+void ReceiverPresentationServiceDelegateImpl::Reset(int render_process_id,
+                                                    int render_frame_id) {
+  DVLOG(2) << __FUNCTION__ << render_process_id << ", " << render_frame_id;
+
+  receiver_sessions_.clear();
+  receiver_available_callback_.Run(nullptr);
+  receiver_available_callback_.Reset();
+}
+
+void ReceiverPresentationServiceDelegateImpl::SetDefaultPresentationUrl(
+    int render_process_id,
+    int render_frame_id,
+    const std::string& default_presentation_url,
+    const PresentationSessionStartedCallback& callback) {
+  NOTIMPLEMENTED();
+}
+
+void ReceiverPresentationServiceDelegateImpl::StartSession(
+    int render_process_id,
+    int render_frame_id,
+    const std::string& presentation_url,
+    const PresentationSessionStartedCallback& success_cb,
+    const PresentationSessionErrorCallback& error_cb) {
+  NOTIMPLEMENTED();
+  error_cb.Run(content::PresentationError(content::PRESENTATION_ERROR_UNKNOWN,
+                                          "Not implemented"));
+}
+
+void ReceiverPresentationServiceDelegateImpl::JoinSession(
+    int render_process_id,
+    int render_frame_id,
+    const std::string& presentation_url,
+    const std::string& presentation_id,
+    const PresentationSessionStartedCallback& success_cb,
+    const PresentationSessionErrorCallback& error_cb) {
+  NOTIMPLEMENTED();
+  error_cb.Run(content::PresentationError(content::PRESENTATION_ERROR_UNKNOWN,
+                                          "Not implemented"));
+}
+
+void ReceiverPresentationServiceDelegateImpl::CloseSession(
+    int render_process_id,
+    int render_frame_id,
+    const std::string& presentation_id) {
+  NOTIMPLEMENTED();
+}
+
+void ReceiverPresentationServiceDelegateImpl::ListenForSessionMessages(
+    int render_process_id,
+    int render_frame_id,
+    const content::PresentationSessionInfo& session_info,
+    const content::PresentationSessionMessageCallback& message_cb) {
+  DVLOG(2) << __FUNCTION__ << render_process_id << ", " << render_frame_id;
+
+  if (!IsMainFrame(render_process_id, render_frame_id)) {
+    DVLOG(2) << __FUNCTION__ << ": not main frame";
+    return;
+  }
+
+  OffscreenPresentationSession* offscreen_session = FindSession(session_info);
+  if (!offscreen_session)
+    return;
+
+  offscreen_session->ListenForMessages(message_cb);
+}
+
+void ReceiverPresentationServiceDelegateImpl::SendMessage(
+    int render_process_id,
+    int render_frame_id,
+    const content::PresentationSessionInfo& session_info,
+    scoped_ptr<content::PresentationSessionMessage> message,
+    const content::SendMessageCallback& send_message_cb) {
+  DVLOG(2) << __FUNCTION__ << render_process_id << ", " << render_frame_id;
+
+  if (!IsMainFrame(render_process_id, render_frame_id)) {
+    DVLOG(2) << __FUNCTION__ << ": not main frame";
+    send_message_cb.Run(false);
+    return;
+  }
+
+  OffscreenPresentationSession* offscreen_session = FindSession(session_info);
+  if (!offscreen_session) {
+    send_message_cb.Run(false);
+    return;
+  }
+
+  offscreen_session->SendMessage(message.Pass(), send_message_cb);
+}
+
+bool ReceiverPresentationServiceDelegateImpl::ListenForSessionStateChange(
+    int render_process_id,
+    int render_frame_id,
+    content::PresentationSessionStateListener* listener) {
+  DVLOG(2) << __FUNCTION__ << render_process_id << ", " << render_frame_id;
+
+  if (!IsMainFrame(render_process_id, render_frame_id)) {
+    DVLOG(2) << __FUNCTION__ << ": not main frame";
+    return false;
+  }
+
+  OffscreenPresentationSession* offscreen_session =
+      FindSession(listener->GetSessionInfo());
+  if (!offscreen_session)
+    return false;
+
+  offscreen_session->ListenForStateChanges(listener);
+  return true;
+}
+
+void ReceiverPresentationServiceDelegateImpl::
+    NotifyWhenReceiverSessionIsAvailable(
+        int render_process_id,
+        int render_frame_id,
+        const content::PresentationReceiverSessionAvailableCallback& callback) {
+  DVLOG(2) << __FUNCTION__ << render_process_id << ", " << render_frame_id;
+  DCHECK(!receiver_available_callback_.is_null());
+
+  if (!IsMainFrame(render_process_id, render_frame_id)) {
+    DVLOG(2) << __FUNCTION__ << ": not main frame";
+    callback.Run(nullptr);
+    return;
+  }
+
+  if (!receiver_sessions_.empty()) {
+    content::PresentationSessionInfo session_info(std::string(),
+                                                  presentation_id_);
+    callback.Run(&session_info);
+    return;
+  }
+
+  receiver_available_callback_ = callback;
+}
+
+ReceiverPresentationServiceDelegateImpl::
+    ReceiverPresentationServiceDelegateImpl(content::WebContents* web_contents,
+                                            const std::string& presentation_id)
+    : web_contents_(web_contents),
+      presentation_id_(presentation_id),
+      offscreen_presentation_manager_(
+          OffscreenPresentationManagerFactory::GetOrCreateForBrowserContext(
+              Profile::FromBrowserContext(web_contents_->GetBrowserContext())
+                  ->GetOriginalProfile())) {
+  DCHECK(web_contents_);
+  DCHECK(!presentation_id.empty());
+  DCHECK(offscreen_presentation_manager_);
+  DCHECK(web_contents_->GetBrowserContext()->IsOffTheRecord());
+
+  offscreen_presentation_manager_->RegisterOffscreenPresentationReceiver(
+      presentation_id_,
+      base::Bind(
+          &ReceiverPresentationServiceDelegateImpl::OnReceiverSessionAvailable,
+          base::Unretained(this)));
+}
+
+void ReceiverPresentationServiceDelegateImpl::OnReceiverSessionAvailable(
+    scoped_ptr<OffscreenPresentationSession> session) {
+  // TODO(imcheng): This is currently broken for the multiple controllers case.
+  // We need additional ID to distinguish between controllers. crbug.com/529911
+  if (!receiver_available_callback_.is_null()) {
+    content::PresentationSessionInfo session_info(std::string(),
+                                                  presentation_id_);
+    receiver_available_callback_.Run(&session_info);
+    receiver_available_callback_.Reset();
+  }
+
+  receiver_sessions_.push_back(session.Pass());
+}
+
+bool ReceiverPresentationServiceDelegateImpl::IsMainFrame(int render_process_id,
+                                                          int render_frame_id) {
+  content::RenderFrameHost* render_frame_host = web_contents_->GetMainFrame();
+  DCHECK(render_frame_host);
+
+  return render_process_id == render_frame_host->GetProcess()->GetID() &&
+         render_frame_id == render_frame_host->GetRoutingID();
+}
+
+OffscreenPresentationSession*
+ReceiverPresentationServiceDelegateImpl::FindSession(
+    const content::PresentationSessionInfo& session_info) {
+  // TODO(imcheng): Need additional information to locate correct session object
+  // in multiple controllers case. crbug.com/529911
+  if (receiver_sessions_.empty()) {
+    DVLOG(2) << "Session not found: " << session_info.presentation_id;
+    return nullptr;
+  } else {
+    return receiver_sessions_.front();
+  }
+}
+
+}  // namespace media_router