content/renderer/media/media_permission_dispatcher.cc

   1 // Copyright 2015 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/renderer/media/media_permission_dispatcher.h"
   6
   7 #include "base/bind.h"
   8 #include "base/logging.h"
   9 #include "content/public/common/service_registry.h"
  10 #include "content/public/renderer/render_frame.h"
  11 #include "third_party/WebKit/public/web/WebUserGestureIndicator.h"
  12 #include "url/gurl.h"
  13
  14 namespace {
  15
  16 using Type = media::MediaPermission::Type;
  17
  18 content::PermissionName MediaPermissionTypeToPermissionName(Type type) {
  19   switch (type) {
  20     case Type::PROTECTED_MEDIA_IDENTIFIER:
  21       return content::PERMISSION_NAME_PROTECTED_MEDIA_IDENTIFIER;
  22     case Type::AUDIO_CAPTURE:
  23       return content::PERMISSION_NAME_AUDIO_CAPTURE;
  24     case Type::VIDEO_CAPTURE:
  25       return content::PERMISSION_NAME_VIDEO_CAPTURE;
  26   }
  27   NOTREACHED();
  28   return content::PERMISSION_NAME_PROTECTED_MEDIA_IDENTIFIER;
  29 }
  30
  31 }  // namespace
  32
  33 namespace content {
  34
  35 MediaPermissionDispatcher::MediaPermissionDispatcher(RenderFrame* render_frame)
  36     : RenderFrameObserver(render_frame), next_request_id_(0) {
  37 }
  38
  39 MediaPermissionDispatcher::~MediaPermissionDispatcher() {
  40   DCHECK(thread_checker_.CalledOnValidThread());
  41
  42   // Fire all pending callbacks with |false|.
  43   for (auto& request : requests_)
  44     request.second.Run(false);
  45
  46   requests_.clear();
  47 }
  48
  49 void MediaPermissionDispatcher::HasPermission(
  50     Type type,
  51     const GURL& security_origin,
  52     const PermissionStatusCB& permission_status_cb) {
  53   DCHECK(thread_checker_.CalledOnValidThread());
  54
  55   if (!permission_service_.get()) {
  56     render_frame()->GetServiceRegistry()->ConnectToRemoteService(
  57         mojo::GetProxy(&permission_service_));
  58   }
  59
  60   uint32_t request_id = next_request_id_++;
  61   DCHECK(!requests_.count(request_id));
  62   requests_[request_id] = permission_status_cb;
  63
  64   DVLOG(2) << __FUNCTION__ << ": request ID " << request_id;
  65
  66   permission_service_->HasPermission(
  67       MediaPermissionTypeToPermissionName(type), security_origin.spec(),
  68       base::Bind(&MediaPermissionDispatcher::OnPermissionStatus,
  69                  base::Unretained(this), request_id));
  70 }
  71
  72 void MediaPermissionDispatcher::RequestPermission(
  73     Type type,
  74     const GURL& security_origin,
  75     const PermissionStatusCB& permission_status_cb) {
  76   DCHECK(thread_checker_.CalledOnValidThread());
  77
  78   if (!permission_service_.get()) {
  79     render_frame()->GetServiceRegistry()->ConnectToRemoteService(
  80         mojo::GetProxy(&permission_service_));
  81   }
  82
  83   uint32_t request_id = next_request_id_++;
  84   DCHECK(!requests_.count(request_id));
  85   requests_[request_id] = permission_status_cb;
  86
  87   DVLOG(2) << __FUNCTION__ << ": request ID " << request_id;
  88
  89   permission_service_->RequestPermission(
  90       MediaPermissionTypeToPermissionName(type), security_origin.spec(),
  91       blink::WebUserGestureIndicator::isProcessingUserGesture(),
  92       base::Bind(&MediaPermissionDispatcher::OnPermissionStatus,
  93                  base::Unretained(this), request_id));
  94 }
  95
  96 void MediaPermissionDispatcher::OnPermissionStatus(uint32_t request_id,
  97                                                    PermissionStatus status) {
  98   DVLOG(2) << __FUNCTION__ << ": (" << request_id << ", " << status << ")";
  99   DCHECK(thread_checker_.CalledOnValidThread());
 100
 101   RequestMap::iterator iter = requests_.find(request_id);
 102   if (iter == requests_.end()) {
 103     DVLOG(2) << "Request not found.";
 104     return;
 105   }
 106
 107   PermissionStatusCB permission_status_cb = iter->second;
 108   requests_.erase(iter);
 109
 110   permission_status_cb.Run(status == PERMISSION_STATUS_GRANTED);
 111 }
 112
 113 }  // namespace content