Preparation for new Promise-based RTCPeerConnection.getStats.

third_party/WebKit/Source/modules/peerconnection/RTCPeerConnection.cpp

 /*
  * Copyright (C) 2012 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  *
  * 1. Redistributions of source code must retain the above copyright
  *    notice, this list of conditions and the following disclaimer.
  * 2. Redistributions in binary form must reproduce the above copyright
@@ skipping 22 matching lines @@
 #include "bindings/core/v8/ArrayValue.h"
 #include "bindings/core/v8/ExceptionMessages.h"
 #include "bindings/core/v8/ExceptionState.h"
 #include "bindings/core/v8/Microtask.h"
 #include "bindings/core/v8/Nullable.h"
 #include "bindings/core/v8/ScriptPromiseResolver.h"
 #include "bindings/core/v8/ScriptState.h"
 #include "bindings/core/v8/ScriptValue.h"
 #include "bindings/core/v8/V8ThrowException.h"
 #include "bindings/modules/v8/RTCIceCandidateInitOrRTCIceCandidate.h"
+#include "bindings/modules/v8/V8MediaStreamTrack.h"
 #include "bindings/modules/v8/V8RTCCertificate.h"
+#include "bindings/modules/v8/V8RTCStatsCallback.h"
 #include "core/dom/DOMException.h"
 #include "core/dom/DOMTimeStamp.h"
 #include "core/dom/Document.h"
 #include "core/dom/ExceptionCode.h"
 #include "core/dom/ExecutionContext.h"
 #include "core/frame/HostsUsingFeatures.h"
 #include "core/frame/LocalFrame.h"
 #include "core/frame/UseCounter.h"
 #include "core/html/VoidCallback.h"
 #include "core/loader/FrameLoader.h"
@@ skipping 10 matching lines @@
 #include "modules/peerconnection/RTCPeerConnectionErrorCallback.h"
 #include "modules/peerconnection/RTCSessionDescription.h"
 #include "modules/peerconnection/RTCSessionDescriptionCallback.h"
 #include "modules/peerconnection/RTCSessionDescriptionInit.h"
 #include "modules/peerconnection/RTCSessionDescriptionRequestImpl.h"
 #include "modules/peerconnection/RTCSessionDescriptionRequestPromiseImpl.h"
 #include "modules/peerconnection/RTCStatsCallback.h"
 #include "modules/peerconnection/RTCStatsRequestImpl.h"
 #include "modules/peerconnection/RTCVoidRequestImpl.h"
 #include "modules/peerconnection/RTCVoidRequestPromiseImpl.h"
+#include "platform/RuntimeEnabledFeatures.h"
 #include "platform/peerconnection/RTCAnswerOptionsPlatform.h"
 #include "platform/peerconnection/RTCConfiguration.h"
 #include "platform/peerconnection/RTCOfferOptionsPlatform.h"
 #include "public/platform/Platform.h"
 #include "public/platform/WebCryptoAlgorithmParams.h"
 #include "public/platform/WebMediaStream.h"
 #include "public/platform/WebRTCAnswerOptions.h"
 #include "public/platform/WebRTCCertificate.h"
 #include "public/platform/WebRTCCertificateGenerator.h"
 #include "public/platform/WebRTCConfiguration.h"
@@ skipping 280 matching lines @@
         offerToReceiveVideo = 0;
     if (DictionaryHelper::get(options, "offerToReceiveAudio", offerToReceiveAudio) && offerToReceiveAudio < 0)
         offerToReceiveAudio = 0;
     DictionaryHelper::get(options, "voiceActivityDetection", voiceActivityDetection);
     DictionaryHelper::get(options, "iceRestart", iceRestart);
 
     RTCOfferOptionsPlatform* rtcOfferOptions = RTCOfferOptionsPlatform::create(offerToReceiveVideo, offerToReceiveAudio, voiceActivityDetection, iceRestart);
     return rtcOfferOptions;
 }
 
+RTCStatsCallback* ValueToRTCStatsCallback(ScriptState* scriptState, const v8::Local<v8::Value>& value)
+{
+    if (!value->IsObject())
+        return nullptr;
+    v8::Local<v8::Object> object = value->ToObject();
+    if (!object->IsCallable())
+        return nullptr;
+    v8::Local<v8::Function> function = v8::Local<v8::Function>::Cast(object);
+    // |function| should have one argument. If called and it doesn't have one it
+    // is still invoked but without the |RTCLegacyStatsReport|. If it has more
+    // than one argument it is invoked with the subsequent arguments undefined.

[hta - Chromium, 2016/07/19 09:56:48]

Is this just a description of how v8::Function works, or is there something
special about this particular usage of v8::Function?

If it's just general, I suggest removing it.

[hbos_chromium, 2016/07/19 13:59:35]

Done.

+    return V8RTCStatsCallback::create(function, scriptState);
+}
+
 } // namespace
 
 RTCPeerConnection::EventWrapper::EventWrapper(
     Event* event,
     std::unique_ptr<BoolFunction> function)
     : m_event(event)
     , m_setupFunction(std::move(function))
 {
 }
 
@@ skipping 557 matching lines @@
     }
 
     for (MediaStreamVector::iterator iter = m_remoteStreams.begin(); iter != m_remoteStreams.end(); ++iter) {
         if ((*iter)->id() == streamId)
             return iter->get();
     }
 
     return 0;
 }
 
-void RTCPeerConnection::getStats(ExecutionContext* context, RTCStatsCallback* successCallback, MediaStreamTrack* selector)
+ScriptPromise RTCPeerConnection::getStats(ScriptState* scriptState, ScriptValue value)
 {
+    v8::Local<v8::Value> v8Value = value.v8Value();
+    if (v8Value->IsUndefined() || v8Value->IsNull()) {
+        // Dispatch to "getStats(optional MediaStreamTrack?)".
+        return getStats(scriptState, static_cast<MediaStreamTrack*>(nullptr));
+    }
+    if (v8Value->IsObject()) {
+        // Is |v8Value| a |MediaStreamTrack|?
+        MediaStreamTrack* selector = V8MediaStreamTrack::toImplWithTypeCheck(scriptState->isolate(), v8Value);
+        if (selector) {
+            // Dispatch to "getStats(optional MediaStreamTrack?)".
+            return getStats(scriptState, selector);
+        }
+
+        // [RTCStatsCallback| is either a function or an object that contains a |handleEvent| function.
+        // Is |v8Value| a valid callback function?
+        RTCStatsCallback* callback = ValueToRTCStatsCallback(scriptState, v8Value);
+        if (!callback) {
+            // Is "value.handleEvent" a valid callback function?
+            v8::Local<v8::Object> object = v8Value->ToObject(scriptState->context()).ToLocalChecked();
+            v8::MaybeLocal<v8::Value> handleEvent = object->Get(
+                scriptState->context(),
+                v8::String::NewFromUtf8(scriptState->isolate(), "handleEvent"));
+            if (!handleEvent.IsEmpty())
+                callback = ValueToRTCStatsCallback(scriptState, handleEvent.ToLocalChecked());
+        }
+        if (callback) {
+            // Dispatch to "getStats(RTCStatsCallback, MediaStreamTrack?)".
+            return getStats(scriptState, callback, nullptr);
+        }
+    }
+
+    // Invalid parameter, |value| is not compatible with |MediaStreamTrack| or |RTCStatsCallback|.
+    ScriptPromiseResolver* resolver = ScriptPromiseResolver::create(scriptState);
+    ScriptPromise promise = resolver->promise();
+    resolver->reject();

[hta - Chromium, 2016/07/19 09:56:48]

Where do we set the error to be returned in this case?

[hbos_chromium, 2016/07/19 13:59:35]

This error was undefined. I added an error and updated other rejection code to
use rejectWithDOMException instead.

+    return promise;
+}
+
+ScriptPromise RTCPeerConnection::getStats(ScriptState* scriptState, RTCStatsCallback* successCallback, MediaStreamTrack* selector)
+{
+    ExecutionContext* context = scriptState->getExecutionContext();
+    ScriptPromiseResolver* resolver = ScriptPromiseResolver::create(scriptState);
+    ScriptPromise promise = resolver->promise();
+
     UseCounter::count(context, UseCounter::RTCPeerConnectionGetStatsLegacyNonCompliant);
     RTCStatsRequest* statsRequest = RTCStatsRequestImpl::create(getExecutionContext(), this, successCallback, selector);
     // FIXME: Add passing selector as part of the statsRequest.
     m_peerHandler->getStats(statsRequest);
+
+    resolver->resolve();
+    return promise;
+}
+
+ScriptPromise RTCPeerConnection::getStats(ScriptState* scriptState, MediaStreamTrack* selector)
+{
+    ScriptPromiseResolver* resolver = ScriptPromiseResolver::create(scriptState);
+    ScriptPromise promise = resolver->promise();
+    if (!RuntimeEnabledFeatures::rTCPeerConnectionNewGetStatsEnabled()) {
+        resolver->reject(ExceptionMessages::argumentNullOrIncorrectType(1, "successCallback"));
+        return promise;
+    }
+
+    // TODO(hbos): Implement new |getStats| function.
+    resolver->reject(DOMException::create(NotSupportedError, "getStats(optional MediaStreamTrack?) has not been implemented yet."));
+    return promise;
 }
 
 RTCDataChannel* RTCPeerConnection::createDataChannel(String label, const Dictionary& options, ExceptionState& exceptionState)
 {
     if (throwExceptionIfSignalingStateClosed(m_signalingState, exceptionState))
         return nullptr;
 
     WebRTCDataChannelInit init;
     DictionaryHelper::get(options, "ordered", init.ordered);
     DictionaryHelper::get(options, "negotiated", init.negotiated);
@@ skipping 291 matching lines @@
 {
     visitor->trace(m_localStreams);
     visitor->trace(m_remoteStreams);
     visitor->trace(m_dispatchScheduledEventRunner);
     visitor->trace(m_scheduledEvents);
     EventTargetWithInlineData::trace(visitor);
     ActiveDOMObject::trace(visitor);
 }
 
 } // namespace blink