content/browser/renderer_host/media/webrtc_identity_service_host.cc

   1 // Copyright 2013 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "content/browser/renderer_host/media/webrtc_identity_service_host.h"
   6
   7 #include "base/bind.h"
   8 #include "base/callback_helpers.h"
   9 #include "content/browser/child_process_security_policy_impl.h"
  10 #include "content/browser/media/webrtc_identity_store.h"
  11 #include "content/common/media/webrtc_identity_messages.h"
  12 #include "content/public/browser/content_browser_client.h"
  13 #include "net/base/net_errors.h"
  14
  15 namespace content {
  16
  17 WebRTCIdentityServiceHost::WebRTCIdentityServiceHost(
  18     int renderer_process_id,
  19     scoped_refptr<WebRTCIdentityStore> identity_store,
  20     ResourceContext* resource_context)
  21     : BrowserMessageFilter(WebRTCIdentityMsgStart),
  22       renderer_process_id_(renderer_process_id),
  23       identity_store_(identity_store),
  24       resource_context_(resource_context),
  25       weak_factory_(this) {}
  26
  27 WebRTCIdentityServiceHost::~WebRTCIdentityServiceHost() {
  28   if (!cancel_callback_.is_null())
  29     cancel_callback_.Run();
  30 }
  31
  32 bool WebRTCIdentityServiceHost::OnMessageReceived(const IPC::Message& message) {
  33   bool handled = true;
  34   IPC_BEGIN_MESSAGE_MAP(WebRTCIdentityServiceHost, message)
  35     IPC_MESSAGE_HANDLER(WebRTCIdentityMsg_RequestIdentity, OnRequestIdentity)
  36     IPC_MESSAGE_HANDLER(WebRTCIdentityMsg_CancelRequest, OnCancelRequest)
  37     IPC_MESSAGE_UNHANDLED(handled = false)
  38   IPC_END_MESSAGE_MAP()
  39   return handled;
  40 }
  41
  42 void WebRTCIdentityServiceHost::OnRequestIdentity(
  43     const WebRTCIdentityMsg_RequestIdentity_Params& params) {
  44   if (!cancel_callback_.is_null()) {
  45     DLOG(WARNING)
  46         << "Request rejected because the previous request has not finished.";
  47     SendErrorMessage(params.request_id, net::ERR_INSUFFICIENT_RESOURCES);
  48     return;
  49   }
  50
  51   // TODO(mkwst): Convert this to use 'url::Origin'.
  52   GURL origin = params.url.GetOrigin();
  53
  54   ChildProcessSecurityPolicyImpl* policy =
  55       ChildProcessSecurityPolicyImpl::GetInstance();
  56   if (!policy->CanAccessDataForOrigin(renderer_process_id_, origin)) {
  57     DLOG(WARNING) << "Request rejected because origin access is denied.";
  58     SendErrorMessage(params.request_id, net::ERR_ACCESS_DENIED);
  59     return;
  60   }
  61
  62   bool cache_enabled =
  63       GetContentClient()->browser()->AllowWebRTCIdentityCache(
  64           params.url, params.first_party_for_cookies, resource_context_);
  65
  66   cancel_callback_ = identity_store_->RequestIdentity(
  67       origin, params.identity_name, params.common_name,
  68       base::Bind(&WebRTCIdentityServiceHost::OnComplete,
  69                  weak_factory_.GetWeakPtr(), params.request_id),
  70       cache_enabled);
  71   if (cancel_callback_.is_null()) {
  72     SendErrorMessage(params.request_id, net::ERR_UNEXPECTED);
  73   }
  74 }
  75
  76 void WebRTCIdentityServiceHost::OnCancelRequest() {
  77   // cancel_callback_ may be null if we have sent the reponse to the renderer
  78   // but the renderer has not received it.
  79   if (!cancel_callback_.is_null())
  80     base::ResetAndReturn(&cancel_callback_).Run();
  81 }
  82
  83 void WebRTCIdentityServiceHost::OnComplete(int request_id,
  84                                            int status,
  85                                            const std::string& certificate,
  86                                            const std::string& private_key) {
  87   cancel_callback_.Reset();
  88   if (status == net::OK) {
  89     Send(new WebRTCIdentityHostMsg_IdentityReady(
  90         request_id, certificate, private_key));
  91   } else {
  92     SendErrorMessage(request_id, status);
  93   }
  94 }
  95
  96 void WebRTCIdentityServiceHost::SendErrorMessage(int request_id,
  97                                                  int error) {
  98   Send(new WebRTCIdentityHostMsg_RequestFailed(request_id, error));
  99 }
 100
 101 }  // namespace content