Add ability to retrieve capabilities for audio input devices to MediaDevicesDispatcherHost.

content/browser/renderer_host/media/media_devices_dispatcher_host.cc

 // Copyright 2016 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/browser/renderer_host/media/media_devices_dispatcher_host.h"
 
 #include <stddef.h>
 
 #include <utility>
 #include <vector>
 
 #include "base/bind_helpers.h"
 #include "base/memory/ptr_util.h"
 #include "content/browser/bad_message.h"
 #include "content/browser/media/media_devices_util.h"
 #include "content/browser/renderer_host/media/media_stream_manager.h"
 #include "content/browser/renderer_host/media/video_capture_manager.h"
 #include "content/common/media/media_devices.h"
 #include "content/public/browser/browser_context.h"
 #include "content/public/browser/browser_thread.h"
 #include "content/public/browser/media_device_id.h"
 #include "content/public/browser/render_frame_host.h"
 #include "content/public/common/media_stream_request.h"
+#include "media/audio/audio_system.h"
 #include "media/base/video_facing.h"
 #include "mojo/public/cpp/bindings/strong_binding.h"
 #include "services/service_manager/public/cpp/interface_provider.h"
 #include "url/origin.h"
 
 namespace content {
 
 namespace {
 
 // Resolutions used if the source doesn't support capability enumeration.
@@ skipping 44 matching lines @@
     case media::MEDIA_VIDEO_FACING_USER:
       return ::mojom::FacingMode::USER;
     case media::MEDIA_VIDEO_FACING_ENVIRONMENT:
       return ::mojom::FacingMode::ENVIRONMENT;
     default:
       NOTREACHED();
       return ::mojom::FacingMode::NONE;
   }
 }
 
+std::vector<::mojom::AudioInputDeviceCapabilitiesPtr>
+ToVectorAudioInputDeviceCapabilitiesPtr(
+    const std::vector<::mojom::AudioInputDeviceCapabilities>&
+        capabilities_vector) {
+  std::vector<::mojom::AudioInputDeviceCapabilitiesPtr> result;
+  result.reserve(capabilities_vector.size());
+  for (auto& capabilities : capabilities_vector) {
+    ::mojom::AudioInputDeviceCapabilitiesPtr capabilities_ptr =
+        ::mojom::AudioInputDeviceCapabilities::New();
+    *capabilities_ptr = capabilities;
+    result.push_back(std::move(capabilities_ptr));
+  }
+  return result;
+}
+
 }  // namespace
 
 struct MediaDevicesDispatcherHost::SubscriptionInfo {
   uint32_t subscription_id;
   url::Origin security_origin;
 };
 
 // static
 void MediaDevicesDispatcherHost::Create(
     int render_process_id,
@@ skipping 13 matching lines @@
     int render_process_id,
     int render_frame_id,
     const std::string& device_id_salt,
     MediaStreamManager* media_stream_manager)
     : render_process_id_(render_process_id),
       render_frame_id_(render_frame_id),
       device_id_salt_(device_id_salt),
       group_id_salt_(BrowserContext::CreateRandomMediaDeviceIDSalt()),
       media_stream_manager_(media_stream_manager),
       permission_checker_(base::MakeUnique<MediaDevicesPermissionChecker>()),
+      num_pending_audio_input_parameters_(0),
       weak_factory_(this) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
 }
 
 MediaDevicesDispatcherHost::~MediaDevicesDispatcherHost() {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
   // It may happen that media_devices_manager() is destroyed before MDDH on some
   // shutdown scenarios.
   if (!media_stream_manager_->media_devices_manager())
     return;
@@ skipping 63 matching lines @@
     return;
   }
 
   GetDefaultMediaDeviceID(
       MEDIA_DEVICE_TYPE_VIDEO_INPUT, render_process_id_, render_frame_id_,
       base::Bind(&MediaDevicesDispatcherHost::GotDefaultVideoInputDeviceID,
                  weak_factory_.GetWeakPtr(), security_origin,
                  base::Passed(&client_callback)));
 }
 
+void MediaDevicesDispatcherHost::GetAudioInputCapabilities(
+    const url::Origin& security_origin,
+    GetAudioInputCapabilitiesCallback client_callback) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+  if (!MediaStreamManager::IsOriginAllowed(render_process_id_,
+                                           security_origin)) {
+    bad_message::ReceivedBadMessage(render_process_id_,
+                                    bad_message::MDDH_UNAUTHORIZED_ORIGIN);
+    return;
+  }
+
+  pending_audio_input_capabilities_callbacks_.push_back(
+      std::move(client_callback));
+  if (pending_audio_input_capabilities_callbacks_.size() > 1U)
+    return;
+
+  DCHECK(current_audio_input_capabilities_.empty());
+  GetDefaultMediaDeviceID(
+      MEDIA_DEVICE_TYPE_AUDIO_INPUT, render_process_id_, render_frame_id_,
+      base::Bind(&MediaDevicesDispatcherHost::GotDefaultAudioInputDeviceID,
+                 weak_factory_.GetWeakPtr(), security_origin));
+}
+
 void MediaDevicesDispatcherHost::SubscribeDeviceChangeNotifications(
     MediaDeviceType type,
     uint32_t subscription_id,
     const url::Origin& security_origin) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
   DCHECK(IsValidMediaDeviceType(type));
   // Ignore requests from unique origins, but do not crash the renderer.
   if (security_origin.unique())
     return;
 
@@ skipping 137 matching lines @@
                                               security_origin, device_info));
     }
   }
   std::move(client_callback).Run(result);
 }
 
 void MediaDevicesDispatcherHost::GotDefaultVideoInputDeviceID(
     const url::Origin& security_origin,
     GetVideoInputCapabilitiesCallback client_callback,
     const std::string& default_device_id) {
-  MediaDevicesManager::BoolDeviceTypes devices_to_enumerate;
-  devices_to_enumerate[MEDIA_DEVICE_TYPE_VIDEO_INPUT] = true;
   media_stream_manager_->video_capture_manager()->EnumerateDevices(
       base::Bind(&MediaDevicesDispatcherHost::FinalizeGetVideoInputCapabilities,
                  weak_factory_.GetWeakPtr(), security_origin,
                  base::Passed(&client_callback), default_device_id));
 }
 
 void MediaDevicesDispatcherHost::FinalizeGetVideoInputCapabilities(
     const url::Origin& security_origin,
     GetVideoInputCapabilitiesCallback client_callback,
     const std::string& default_device_id,
@@ skipping 51 matching lines @@
   if (format.has_value()) {
     formats.push_back(format.value());
     return formats;
   }
 
   media_stream_manager_->video_capture_manager()->GetDeviceSupportedFormats(
       device_id, &formats);
   return formats;
 }
 
+void MediaDevicesDispatcherHost::GotDefaultAudioInputDeviceID(
+    const url::Origin& security_origin,
+    const std::string& default_device_id) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+  DCHECK_GT(pending_audio_input_capabilities_callbacks_.size(), 0U);
+  DCHECK(current_audio_input_capabilities_.empty());
+  MediaDevicesManager::BoolDeviceTypes devices_to_enumerate;
+  devices_to_enumerate[MEDIA_DEVICE_TYPE_AUDIO_INPUT] = true;
+  media_stream_manager_->media_devices_manager()->EnumerateDevices(
+      devices_to_enumerate,
+      base::Bind(&MediaDevicesDispatcherHost::GotAudioInputEnumeration,
+                 weak_factory_.GetWeakPtr(), security_origin,
+                 default_device_id));
+}
+
+void MediaDevicesDispatcherHost::GotAudioInputEnumeration(
+    const url::Origin& security_origin,
+    const std::string& default_device_id,
+    const MediaDeviceEnumeration& enumeration) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+  DCHECK_GT(pending_audio_input_capabilities_callbacks_.size(), 0U);
+  DCHECK(current_audio_input_capabilities_.empty());
+  for (const auto& device_info : enumeration[MEDIA_DEVICE_TYPE_AUDIO_INPUT]) {
+    ::mojom::AudioInputDeviceCapabilities capabilities(
+        device_info.device_id, media::AudioParameters());
+    if (device_info.device_id == default_device_id)

[tommi (sloooow) - chröme, 2017/05/08 17:52:54]

nit: {}

+      current_audio_input_capabilities_.insert(
+          current_audio_input_capabilities_.begin(), std::move(capabilities));
+    else
+      current_audio_input_capabilities_.push_back(std::move(capabilities));
+  }
+  if (current_audio_input_capabilities_.empty()) {
+    FinalizeGetAudioInputCapabilities();
+    return;
+  }
+
+  num_pending_audio_input_parameters_ =
+      current_audio_input_capabilities_.size();
+  for (size_t i = 0; i < num_pending_audio_input_parameters_; ++i) {
+    std::string raw_device_id =
+        std::move(current_audio_input_capabilities_[i].device_id);
+    current_audio_input_capabilities_[i].device_id = GetHMACForMediaDeviceID(
+        device_id_salt_, security_origin, raw_device_id);
+    media_stream_manager_->audio_system()->GetInputStreamParameters(
+        raw_device_id,
+        base::Bind(&MediaDevicesDispatcherHost::GotAudioInputParameters,
+                   weak_factory_.GetWeakPtr(), i));
+  }
+}
+
+void MediaDevicesDispatcherHost::GotAudioInputParameters(
+    size_t index,
+    const media::AudioParameters& parameters) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+  DCHECK_GT(pending_audio_input_capabilities_callbacks_.size(), 0U);
+  DCHECK_GT(current_audio_input_capabilities_.size(), index);
+  DCHECK_GT(num_pending_audio_input_parameters_, 0U);
+
+  current_audio_input_capabilities_[index].parameters =
+      parameters.IsValid() ? parameters
+                           : media::AudioParameters::UnavailableDeviceParams();
+  if (--num_pending_audio_input_parameters_ == 0U)
+    FinalizeGetAudioInputCapabilities();
+}
+
+void MediaDevicesDispatcherHost::FinalizeGetAudioInputCapabilities() {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+  DCHECK_GT(pending_audio_input_capabilities_callbacks_.size(), 0U);
+  DCHECK_EQ(0U, num_pending_audio_input_parameters_);
+
+  for (auto& callback : pending_audio_input_capabilities_callbacks_) {
+    std::move(callback).Run(ToVectorAudioInputDeviceCapabilitiesPtr(
+        current_audio_input_capabilities_));
+  }
+
+  current_audio_input_capabilities_.clear();
+  pending_audio_input_capabilities_callbacks_.clear();
+}
+
 }  // namespace content