| Index: Source/modules/navigatorconnect/AcceptConnectionObserver.cpp
|
| diff --git a/Source/modules/navigatorconnect/AcceptConnectionObserver.cpp b/Source/modules/navigatorconnect/AcceptConnectionObserver.cpp
|
| index e3b01a64c74c122365f21403d4ec8b63ac252c50..a1c2aa791ae7b731c3b8624ca716e931e98c197c 100644
|
| --- a/Source/modules/navigatorconnect/AcceptConnectionObserver.cpp
|
| +++ b/Source/modules/navigatorconnect/AcceptConnectionObserver.cpp
|
| @@ -64,11 +64,6 @@ private:
|
| ResolveType m_resolveType;
|
| };
|
|
|
| -AcceptConnectionObserver* AcceptConnectionObserver::create(ExecutionContext* context, int eventID)
|
| -{
|
| - return new AcceptConnectionObserver(context, eventID);
|
| -}
|
| -
|
| AcceptConnectionObserver* AcceptConnectionObserver::create(ServicePortCollection* collection, PassOwnPtr<WebServicePortConnectEventCallbacks> callbacks, WebServicePortID portID, const KURL& targetURL)
|
| {
|
| return new AcceptConnectionObserver(collection, callbacks, portID, targetURL);
|
| @@ -88,19 +83,6 @@ void AcceptConnectionObserver::didDispatchEvent()
|
| responseWasRejected();
|
| }
|
|
|
| -void AcceptConnectionObserver::acceptConnection(ScriptState* scriptState, ScriptPromise value, ExceptionState& exceptionState)
|
| -{
|
| - if (m_state != Initial) {
|
| - exceptionState.throwDOMException(InvalidStateError, "acceptConnection was already called.");
|
| - return;
|
| - }
|
| -
|
| - m_state = Pending;
|
| - value.then(
|
| - ThenFunction::createFunction(scriptState, this, ThenFunction::Fulfilled),
|
| - ThenFunction::createFunction(scriptState, this, ThenFunction::Rejected));
|
| -}
|
| -
|
| ScriptPromise AcceptConnectionObserver::respondWith(ScriptState* scriptState, ScriptPromise value, ExceptionState& exceptionState)
|
| {
|
| if (m_state != Initial) {
|
| @@ -121,28 +103,13 @@ void AcceptConnectionObserver::responseWasRejected()
|
| ASSERT(executionContext());
|
| if (m_resolver)
|
| m_resolver->reject(DOMException::create(AbortError));
|
| - if (m_callbacks) {
|
| - m_callbacks->onError();
|
| - } else {
|
| - ServiceWorkerGlobalScopeClient::from(executionContext())->didHandleCrossOriginConnectEvent(m_eventID, false);
|
| - }
|
| + m_callbacks->onError();
|
| m_state = Done;
|
| }
|
|
|
| void AcceptConnectionObserver::responseWasResolved(const ScriptValue& value)
|
| {
|
| ASSERT(executionContext());
|
| - if (!m_resolver) {
|
| - // TODO(mek): Get rid of this block when observer is only used for
|
| - // service port connect events.
|
| - if (!value.v8Value()->IsTrue()) {
|
| - responseWasRejected();
|
| - return;
|
| - }
|
| - ServiceWorkerGlobalScopeClient::from(executionContext())->didHandleCrossOriginConnectEvent(m_eventID, true);
|
| - m_state = Done;
|
| - return;
|
| - }
|
|
|
| ScriptState* scriptState = m_resolver->scriptState();
|
| ExceptionState exceptionState(ExceptionState::UnknownContext, nullptr, nullptr, scriptState->context()->Global(), scriptState->isolate());
|
| @@ -178,17 +145,8 @@ void AcceptConnectionObserver::responseWasResolved(const ScriptValue& value)
|
| m_state = Done;
|
| }
|
|
|
| -AcceptConnectionObserver::AcceptConnectionObserver(ExecutionContext* context, int eventID)
|
| - : ContextLifecycleObserver(context)
|
| - , m_eventID(eventID)
|
| - , m_portID(-1)
|
| - , m_state(Initial)
|
| -{
|
| -}
|
| -
|
| AcceptConnectionObserver::AcceptConnectionObserver(ServicePortCollection* collection, PassOwnPtr<WebServicePortConnectEventCallbacks> callbacks, WebServicePortID portID, const KURL& targetURL)
|
| : ContextLifecycleObserver(collection->executionContext())
|
| - , m_eventID(-1)
|
| , m_callbacks(callbacks)
|
| , m_collection(collection)
|
| , m_portID(portID)
|
|
|