UserMediaRequest.cpp [plain text]
#include "config.h"
#include "UserMediaRequest.h"
#if ENABLE(MEDIA_STREAM)
#include "CaptureDeviceManager.h"
#include "DeprecatedGlobalSettings.h"
#include "Document.h"
#include "DocumentLoader.h"
#include "Frame.h"
#include "HTMLIFrameElement.h"
#include "HTMLParserIdioms.h"
#include "JSMediaStream.h"
#include "JSOverconstrainedError.h"
#include "Logging.h"
#include "MediaConstraints.h"
#include "RealtimeMediaSourceCenter.h"
#include "SchemeRegistry.h"
#include "Settings.h"
#include "UserMediaController.h"
namespace WebCore {
RefPtr<UserMediaRequest> UserMediaRequest::create(Document& document, MediaStreamRequest&& request, DOMPromiseDeferred<IDLInterface<MediaStream>>&& promise)
{
auto result = adoptRef(new UserMediaRequest(document, WTFMove(request), WTFMove(promise)));
result->suspendIfNeeded();
return result;
}
UserMediaRequest::UserMediaRequest(Document& document, MediaStreamRequest&& request, DOMPromiseDeferred<IDLInterface<MediaStream>>&& promise)
: ActiveDOMObject(&document)
, m_promise(WTFMove(promise))
, m_request(WTFMove(request))
{
}
UserMediaRequest::~UserMediaRequest() = default;
SecurityOrigin* UserMediaRequest::userMediaDocumentOrigin() const
{
if (!m_scriptExecutionContext)
return nullptr;
return m_scriptExecutionContext->securityOrigin();
}
SecurityOrigin* UserMediaRequest::topLevelDocumentOrigin() const
{
if (!m_scriptExecutionContext)
return nullptr;
return &m_scriptExecutionContext->topOrigin();
}
static bool isSecure(DocumentLoader& documentLoader)
{
auto& response = documentLoader.response();
if (SecurityOrigin::isLocalHostOrLoopbackIPAddress(documentLoader.response().url().host()))
return true;
return SchemeRegistry::shouldTreatURLSchemeAsSecure(response.url().protocol().toStringWithoutCopying())
&& response.certificateInfo()
&& !response.certificateInfo()->containsNonRootSHA1SignedCertificate();
}
static bool isAllowedToUse(Document& document, Document& topDocument, bool requiresAudio, bool requiresVideo)
{
if (&document == &topDocument)
return true;
auto* parentDocument = document.parentDocument();
if (!parentDocument)
return false;
if (document.securityOrigin().isSameSchemeHostPort(parentDocument->securityOrigin()))
return true;
auto* element = document.ownerElement();
ASSERT(element);
if (!element)
return false;
if (!is<HTMLIFrameElement>(*element))
return false;
auto& allow = downcast<HTMLIFrameElement>(*element).allow();
bool allowCameraAccess = false;
bool allowMicrophoneAccess = false;
for (auto allowItem : StringView { allow }.split(';')) {
auto item = allowItem.stripLeadingAndTrailingMatchedCharacters(isHTMLSpace<UChar>);
if (!allowCameraAccess && item == "camera")
allowCameraAccess = true;
else if (!allowMicrophoneAccess && item == "microphone")
allowMicrophoneAccess = true;
}
return (allowCameraAccess || !requiresVideo) && (allowMicrophoneAccess || !requiresAudio);
}
static bool canCallGetUserMedia(Document& document, bool wantsAudio, bool wantsVideo, String& errorMessage)
{
ASSERT(wantsAudio || wantsVideo);
bool requiresSecureConnection = DeprecatedGlobalSettings::mediaCaptureRequiresSecureConnection();
auto& documentLoader = *document.loader();
if (requiresSecureConnection && !isSecure(documentLoader)) {
errorMessage = "Trying to call getUserMedia from an insecure document.";
return false;
}
auto& topDocument = document.topDocument();
if (&document != &topDocument) {
for (auto* ancestorDocument = &document; ancestorDocument != &topDocument; ancestorDocument = ancestorDocument->parentDocument()) {
if (requiresSecureConnection && !isSecure(*ancestorDocument->loader())) {
errorMessage = "Trying to call getUserMedia from a document with an insecure parent frame.";
return false;
}
if (!isAllowedToUse(*ancestorDocument, topDocument, wantsAudio, wantsVideo)) {
errorMessage = "The top-level frame has prevented a document with a different security origin to call getUserMedia.";
return false;
}
}
}
return true;
}
void UserMediaRequest::start()
{
ASSERT(m_scriptExecutionContext);
if (!m_scriptExecutionContext) {
deny(MediaAccessDenialReason::UserMediaDisabled);
return;
}
if (m_request.type == MediaStreamRequest::Type::DisplayMedia) {
if (m_request.videoConstraints.isValid && !(m_request.videoConstraints.mandatoryConstraints.isEmpty() && m_request.videoConstraints.advancedConstraints.isEmpty())) {
deny(MediaAccessDenialReason::InvalidAccess);
return;
}
if (m_request.audioConstraints.isValid && !(m_request.audioConstraints.mandatoryConstraints.isEmpty() && m_request.audioConstraints.advancedConstraints.isEmpty())) {
deny(MediaAccessDenialReason::InvalidAccess);
return;
}
}
if (!m_request.audioConstraints.isValid && !m_request.videoConstraints.isValid) {
deny(MediaAccessDenialReason::NoConstraints);
return;
}
auto& document = downcast<Document>(*m_scriptExecutionContext);
auto* controller = UserMediaController::from(document.page());
if (!controller) {
deny(MediaAccessDenialReason::UserMediaDisabled);
return;
}
String errorMessage;
if (!canCallGetUserMedia(document, m_request.audioConstraints.isValid, m_request.videoConstraints.isValid, errorMessage)) {
deny(MediaAccessDenialReason::PermissionDenied);
document.domWindow()->printErrorMessage(errorMessage);
return;
}
controller->requestUserMediaAccess(*this);
}
void UserMediaRequest::allow(CaptureDevice&& audioDevice, CaptureDevice&& videoDevice, String&& deviceIdentifierHashSalt)
{
RELEASE_LOG(MediaStream, "UserMediaRequest::allow %s %s", audioDevice ? audioDevice.persistentId().utf8().data() : "", videoDevice ? videoDevice.persistentId().utf8().data() : "");
auto callback = [this, protector = makePendingActivity(*this)](RefPtr<MediaStreamPrivate>&& privateStream) mutable {
if (!m_scriptExecutionContext)
return;
if (!privateStream) {
deny(MediaAccessDenialReason::HardwareError);
return;
}
privateStream->monitorOrientation(downcast<Document>(m_scriptExecutionContext)->orientationNotifier());
auto stream = MediaStream::create(*m_scriptExecutionContext, privateStream.releaseNonNull());
if (stream->getTracks().isEmpty()) {
deny(MediaAccessDenialReason::HardwareError);
return;
}
m_pendingActivationMediaStream = PendingActivationMediaStream::create(WTFMove(protector), *this, WTFMove(stream));
};
m_request.audioConstraints.deviceIDHashSalt = deviceIdentifierHashSalt;
m_request.videoConstraints.deviceIDHashSalt = WTFMove(deviceIdentifierHashSalt);
RealtimeMediaSourceCenter::singleton().createMediaStream(WTFMove(callback), WTFMove(audioDevice), WTFMove(videoDevice), m_request);
if (!m_scriptExecutionContext)
return;
#if ENABLE(WEB_RTC)
auto& document = downcast<Document>(*m_scriptExecutionContext);
if (auto* page = document.page())
page->rtcController().disableICECandidateFilteringForDocument(document);
#endif
}
void UserMediaRequest::deny(MediaAccessDenialReason reason, const String& message)
{
if (!m_scriptExecutionContext)
return;
ExceptionCode code;
switch (reason) {
case MediaAccessDenialReason::NoConstraints:
RELEASE_LOG(MediaStream, "UserMediaRequest::deny - no constraints");
code = TypeError;
break;
case MediaAccessDenialReason::UserMediaDisabled:
RELEASE_LOG(MediaStream, "UserMediaRequest::deny - user media disabled");
code = SecurityError;
break;
case MediaAccessDenialReason::NoCaptureDevices:
RELEASE_LOG(MediaStream, "UserMediaRequest::deny - no capture devices");
code = NotFoundError;
break;
case MediaAccessDenialReason::InvalidConstraint:
RELEASE_LOG(MediaStream, "UserMediaRequest::deny - invalid constraint - %s", message.utf8().data());
m_promise.rejectType<IDLInterface<OverconstrainedError>>(OverconstrainedError::create(message, "Invalid constraint"_s).get());
return;
case MediaAccessDenialReason::HardwareError:
RELEASE_LOG(MediaStream, "UserMediaRequest::deny - hardware error");
code = NotReadableError;
break;
case MediaAccessDenialReason::OtherFailure:
RELEASE_LOG(MediaStream, "UserMediaRequest::deny - other failure");
code = AbortError;
break;
case MediaAccessDenialReason::PermissionDenied:
RELEASE_LOG(MediaStream, "UserMediaRequest::deny - permission denied");
code = NotAllowedError;
break;
case MediaAccessDenialReason::InvalidAccess:
RELEASE_LOG(MediaStream, "UserMediaRequest::deny - invalid access");
code = InvalidAccessError;
break;
}
if (!message.isEmpty())
m_promise.reject(code, message);
else
m_promise.reject(code);
}
void UserMediaRequest::stop()
{
Ref<UserMediaRequest> protectedThis(*this);
m_pendingActivationMediaStream = nullptr;
auto& document = downcast<Document>(*m_scriptExecutionContext);
if (auto* controller = UserMediaController::from(document.page()))
controller->cancelUserMediaAccessRequest(*this);
}
const char* UserMediaRequest::activeDOMObjectName() const
{
return "UserMediaRequest";
}
bool UserMediaRequest::canSuspendForDocumentSuspension() const
{
return !hasPendingActivity();
}
Document* UserMediaRequest::document() const
{
return downcast<Document>(m_scriptExecutionContext);
}
UserMediaRequest::PendingActivationMediaStream::PendingActivationMediaStream(Ref<PendingActivity<UserMediaRequest>>&& protectingUserMediaRequest, UserMediaRequest& userMediaRequest, Ref<MediaStream>&& stream)
: m_protectingUserMediaRequest(WTFMove(protectingUserMediaRequest))
, m_userMediaRequest(userMediaRequest)
, m_mediaStream(WTFMove(stream))
{
m_mediaStream->privateStream().addObserver(*this);
m_mediaStream->startProducingData();
}
UserMediaRequest::PendingActivationMediaStream::~PendingActivationMediaStream()
{
m_mediaStream->privateStream().removeObserver(*this);
}
void UserMediaRequest::PendingActivationMediaStream::characteristicsChanged()
{
if (!m_userMediaRequest.m_pendingActivationMediaStream)
return;
for (auto& track : m_mediaStream->privateStream().tracks()) {
if (track->source().captureDidFail()) {
m_userMediaRequest.mediaStreamDidFail(track->source().type());
return;
}
}
if (m_mediaStream->privateStream().hasVideo() || m_mediaStream->privateStream().hasAudio()) {
m_userMediaRequest.mediaStreamIsReady(WTFMove(m_mediaStream));
return;
}
}
void UserMediaRequest::mediaStreamIsReady(Ref<MediaStream>&& stream)
{
RELEASE_LOG(MediaStream, "UserMediaRequest::mediaStreamIsReady");
stream->document()->setHasCaptureMediaStreamTrack();
m_promise.resolve(WTFMove(stream));
callOnMainThread([stream = WTFMove(m_pendingActivationMediaStream)] { });
}
void UserMediaRequest::mediaStreamDidFail(RealtimeMediaSource::Type type)
{
RELEASE_LOG(MediaStream, "UserMediaRequest::mediaStreamDidFail");
const char* typeDescription = "";
switch (type) {
case RealtimeMediaSource::Type::Audio:
typeDescription = "audio";
break;
case RealtimeMediaSource::Type::Video:
typeDescription = "video";
break;
case RealtimeMediaSource::Type::None:
typeDescription = "unknown";
break;
}
m_promise.reject(NotReadableError, makeString("Failed starting capture of a "_s, typeDescription, " track"_s));
callOnMainThread([stream = WTFMove(m_pendingActivationMediaStream)] { });
}
}
#endif // ENABLE(MEDIA_STREAM)