Introducing the WebServiceWorkerCacheStorage

Source/modules/serviceworkers/FetchStores.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/FetchStores.h"
+
+#include "bindings/core/v8/ScriptPromiseResolver.h"
+#include "bindings/core/v8/ScriptState.h"
+#include "public/platform/WebServiceWorkerFetchStores.h"
+#include "public/platform/WebServiceWorkerFetchStoresError.h"
+
+namespace blink {
+
+namespace {
+
+const char* FetchStoresErrorToString(WebServiceWorkerFetchStoresError reason)
+{
+    // TODO: Construct correct DOM error objects rather than returning strings.

[falken, 2014/07/30 02:14:09]

blink world says FIXME

[gavinp, 2014/08/05 08:09:11]

Done.

+    switch (reason) {
+    case WebServiceWorkerFetchStoresError::WebServiceWorkerFetchStoresErrorNotImplemented:
+        return "not implemented";
+    case WebServiceWorkerFetchStoresError::WebServiceWorkerFetchStoresErrorNotFound:
+        return "not found";
+    case WebServiceWorkerFetchStoresError::WebServiceWorkerFetchStoresErrorExists:
+        return "entry already exists";
+    default:
+        ASSERT_NOT_REACHED();
+        return "unknown error";
+    }
+}
+
+class FetchStoresCallbacks : public WebServiceWorkerFetchStores::FetchStoresCallbacks {
+public:
+    FetchStoresCallbacks(PassRefPtr<ScriptPromiseResolver> resolver) : m_resolver(resolver) { }
+    virtual ~FetchStoresCallbacks() { }
+
+    virtual void onSuccess() OVERRIDE
+    {
+        m_resolver->resolve(true);
+    }
+
+    virtual void onError(WebServiceWorkerFetchStoresError* reason) OVERRIDE
+    {
+        m_resolver->reject(FetchStoresErrorToString(*reason));
+    }
+
+private:
+    const RefPtr<ScriptPromiseResolver> m_resolver;
+};
+
+class FetchStoresWithFetchStoreCallbacks : public WebServiceWorkerFetchStores::FetchStoresWithFetchStoreCallbacks {
+public:
+    FetchStoresWithFetchStoreCallbacks(PassRefPtr<ScriptPromiseResolver> resolver) : m_resolver(resolver) { }
+    virtual ~FetchStoresWithFetchStoreCallbacks() { }
+
+    virtual void onSuccess(int* fetchStoreID) OVERRIDE
+    {
+        // TODO: There should be a blink side of the Cache object implementation here, rather than

[falken, 2014/07/30 02:14:09]

FIXME

[gavinp, 2014/08/05 08:09:11]

Done.

+        // this nonsensical pass through.
+        m_resolver->resolve(*fetchStoreID);
+    }
+
+    virtual void onError(WebServiceWorkerFetchStoresError* reason) OVERRIDE
+    {
+        m_resolver->reject(FetchStoresErrorToString(*reason));
+    }
+
+private:
+    const RefPtr<ScriptPromiseResolver> m_resolver;
+};
+
+class FetchStoresKeysCallbacks : public WebServiceWorkerFetchStores::FetchStoresKeysCallbacks {
+public:
+    FetchStoresKeysCallbacks(ScriptState* scriptState, PassRefPtr<ScriptPromiseResolver> resolver) : m_resolver(resolver), m_scriptState(scriptState) { }
+    virtual ~FetchStoresKeysCallbacks() { }
+
+    virtual void onSuccess(blink::WebVector<blink::WebString>* keys) OVERRIDE
+    {
+        Vector<String> wtfKeys;
+        for (size_t i = 0; i < keys->size(); ++i)
+            wtfKeys.append((*keys)[i]);
+        m_resolver->resolve(wtfKeys);
+    }
+
+    virtual void onError(WebServiceWorkerFetchStoresError* reason) OVERRIDE
+    {
+        m_resolver->reject(FetchStoresErrorToString(*reason));
+    }
+
+private:
+    const RefPtr<ScriptPromiseResolver> m_resolver;
+    const RefPtr<ScriptState> m_scriptState;
+};
+
+}
+
+PassRefPtr<FetchStores> FetchStores::create(WebServiceWorkerFetchStores* webFetchStores)
+{
+    return adoptRefWillBeNoop(new FetchStores(webFetchStores));
+}
+
+ScriptPromise FetchStores::get(ScriptState* scriptState, const String& fetchStoreName)
+{
+    RefPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::create(scriptState);
+    const ScriptPromise promise = resolver->promise();
+
+    if (m_webFetchStores)
+        m_webFetchStores->dispatchGet(new FetchStoresWithFetchStoreCallbacks(resolver), fetchStoreName);
+    else
+        resolver->reject("no implementation provided");
+
+    return promise;
+}
+
+ScriptPromise FetchStores::has(ScriptState* scriptState, const String& fetchStoreName)
+{
+    RefPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::create(scriptState);
+    const ScriptPromise promise = resolver->promise();
+
+    if (m_webFetchStores)
+        m_webFetchStores->dispatchHas(new FetchStoresCallbacks(resolver), fetchStoreName);
+    else
+        resolver->reject("no implementation provided");
+
+    return promise;
+}
+
+ScriptPromise FetchStores::createFunction(ScriptState* scriptState, const String& fetchStoreName)
+{
+    RefPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::create(scriptState);
+    const ScriptPromise promise = resolver->promise();
+
+    if (m_webFetchStores)
+        m_webFetchStores->dispatchCreate(new FetchStoresWithFetchStoreCallbacks(resolver), fetchStoreName);
+    else
+        resolver->reject("no implementation provided");
+
+    return promise;
+}
+
+ScriptPromise FetchStores::deleteFunction(ScriptState* scriptState, const String& fetchStoreName)
+{
+    RefPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::create(scriptState);
+    const ScriptPromise promise = resolver->promise();
+
+    if (m_webFetchStores)
+        m_webFetchStores->dispatchDelete(new FetchStoresCallbacks(resolver), fetchStoreName);
+    else
+        resolver->reject("no implementation provided");
+
+    return promise;
+}
+
+ScriptPromise FetchStores::keys(ScriptState* scriptState)
+{
+    RefPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::create(scriptState);
+    const ScriptPromise promise = resolver->promise();
+
+    if (m_webFetchStores)
+        m_webFetchStores->dispatchKeys(new FetchStoresKeysCallbacks(scriptState, resolver));
+    else
+        resolver->reject("no implementation provided");
+
+    return promise;
+}
+
+FetchStores::FetchStores(WebServiceWorkerFetchStores* webFetchStores) : m_webFetchStores(webFetchStores)
+{
+    ScriptWrappable::init(this);
+}
+
+} // namespace blink