Propagate error/exception information for rejected Promises in Service workers.

Source/modules/serviceworkers/RespondWithObserver.cpp

 // Copyright 2014 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 "config.h"
 #include "modules/serviceworkers/RespondWithObserver.h"
 
 #include "bindings/core/v8/ScriptFunction.h"
 #include "bindings/core/v8/ScriptPromise.h"
 #include "bindings/core/v8/ScriptValue.h"
 #include "bindings/core/v8/V8Binding.h"
+#include "bindings/core/v8/V8ErrorEvent.h"
 #include "bindings/modules/v8/V8Response.h"
 #include "core/dom/ExecutionContext.h"
+#include "core/events/ErrorEvent.h"
 #include "modules/serviceworkers/ServiceWorkerGlobalScopeClient.h"
 #include "platform/RuntimeEnabledFeatures.h"
 #include "public/platform/WebServiceWorkerResponse.h"
 #include "wtf/Assertions.h"
 #include "wtf/RefPtr.h"
+#include "core/workers/WorkerGlobalScope.h"
+#include "core/workers/WorkerThread.h"
+#include "core/workers/WorkerReportingProxy.h"
+#include "core/dom/ExecutionContext.h"
 #include <v8.h>
 
+#include "base/logging.h"
+
 namespace blink {
 
 class RespondWithObserver::ThenFunction FINAL : public ScriptFunction {
 public:
     enum ResolveType {
         Fulfilled,
         Rejected,
     };
 
     static v8::Handle<v8::Function> createFunction(ScriptState* scriptState, RespondWithObserver* observer, ResolveType type)
@@ skipping 14 matching lines @@
         , m_observer(observer)
         , m_resolveType(type)
     {
     }
 
     virtual ScriptValue call(ScriptValue value) OVERRIDE
     {
         ASSERT(m_observer);
         ASSERT(m_resolveType == Fulfilled || m_resolveType == Rejected);
         if (m_resolveType == Rejected)
-            m_observer->responseWasRejected();
+            m_observer->responseWasRejected(value);
         else
             m_observer->responseWasFulfilled(value);
         m_observer = nullptr;
         return value;
     }
 
     Member<RespondWithObserver> m_observer;
     ResolveType m_resolveType;
 };
 
@@ skipping 24 matching lines @@
         exceptionState.throwDOMException(InvalidStateError, "respondWith is already called.");
         return;
     }
 
     m_state = Pending;
     ScriptPromise::cast(scriptState, value).then(
         ThenFunction::createFunction(scriptState, this, ThenFunction::Fulfilled),
         ThenFunction::createFunction(scriptState, this, ThenFunction::Rejected));
 }
 
-void RespondWithObserver::responseWasRejected()
+void RespondWithObserver::responseWasRejected(const ScriptValue& value)
 {
+    VLOG(1) <<__FUNCTION__;
     ASSERT(executionContext());
+    if(V8ErrorEvent::hasInstance(value.v8Value(), toIsolate(executionContext()))) {
+        ErrorEvent* errEvent = V8ErrorEvent::toImplWithTypeCheck(toIsolate(executionContext()), value.v8Value());
+        toWorkerGlobalScope(executionContext())->thread()->workerReportingProxy()
+        .reportException(errEvent->message(),
+                        errEvent->lineno(),
+                        errEvent->colno(),
+                        errEvent->filename());
+
+        VLOG(1) << errEvent->message().ascii().data();
+        VLOG(1) << errEvent->filename().ascii().data()<< " : "<< errEvent->lineno() << " : " << errEvent->colno();
+    }
+    
     // The default value of WebServiceWorkerResponse's status is 0, which maps
     // to a network error.
     WebServiceWorkerResponse webResponse;
     ServiceWorkerGlobalScopeClient::from(executionContext())->didHandleFetchEvent(m_eventID, webResponse);
     m_state = Done;
 }
 
 void RespondWithObserver::responseWasFulfilled(const ScriptValue& value)
 {
     ASSERT(executionContext());
     if (!V8Response::hasInstance(value.v8Value(), toIsolate(executionContext()))) {
-        responseWasRejected();
+        responseWasRejected(value);
         return;
     }
     Response* response = V8Response::toImplWithTypeCheck(toIsolate(executionContext()), value.v8Value());
     // "If either |response|'s type is |opaque| and |request|'s mode is not
     // |no CORS| or |response|'s type is |error|, return a network error."
     const FetchResponseData::Type responseType = response->response()->type();
     if ((responseType == FetchResponseData::OpaqueType && m_requestMode != WebURLRequest::FetchRequestModeNoCORS) || responseType == FetchResponseData::ErrorType) {
-        responseWasRejected();
+        responseWasRejected(value);
         return;
     }
     // Treat the opaque response as a network error for frame loading.
     if (responseType == FetchResponseData::OpaqueType && m_frameType != WebURLRequest::FrameTypeNone) {
-        responseWasRejected();
+        responseWasRejected(value);
         return;
     }
     WebServiceWorkerResponse webResponse;
     response->populateWebServiceWorkerResponse(webResponse);
     ServiceWorkerGlobalScopeClient::from(executionContext())->didHandleFetchEvent(m_eventID, webResponse);
     m_state = Done;
 }
 
 RespondWithObserver::RespondWithObserver(ExecutionContext* context, int eventID, WebURLRequest::FetchRequestMode requestMode, WebURLRequest::FrameType frameType)
     : ContextLifecycleObserver(context)
     , m_eventID(eventID)
     , m_requestMode(requestMode)
     , m_frameType(frameType)
     , m_state(Initial)
 {
 }
 
 } // namespace blink