Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(2145)

Issues Search
    My Issues | Starred     Open | Closed | All

Unified Diff: Source/modules/serviceworkers/CacheTest.cpp

Issue 433793002: Introducing the WebServiceWorkerCache. (Closed) Base URL: svn://svn.chromium.org/blink/trunk
Patch Set: fix build Created 6 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« Source/modules/serviceworkers/CacheStorage.cpp ('K') | « Source/modules/serviceworkers/CacheStorage.cpp ('k') | public/platform/WebServiceWorkerCache.h » ('j') | public/platform/WebServiceWorkerCache.h » ('J')
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: Source/modules/serviceworkers/CacheTest.cpp
diff --git a/Source/modules/serviceworkers/CacheTest.cpp b/Source/modules/serviceworkers/CacheTest.cpp
new file mode 100644
index 0000000000000000000000000000000000000000..831e4ee0249a1b662ff54a79c9631d667552014e
--- /dev/null
+++ b/Source/modules/serviceworkers/CacheTest.cpp
@@ -0,0 +1,525 @@
+// 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 "bindings/core/v8/ExceptionState.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/modules/v8/V8Request.h"
+#include "bindings/modules/v8/V8Response.h"
+#include "core/dom/Document.h"
+#include "core/frame/Frame.h"
+#include "core/testing/DummyPageHolder.h"
+#include "modules/serviceworkers/Cache.h"
+#include "modules/serviceworkers/Request.h"
+#include "modules/serviceworkers/Response.h"
+#include "public/platform/WebServiceWorkerCache.h"
+#include "wtf/OwnPtr.h"
+
+#include <algorithm>
+#include <gtest/gtest.h>
+
+namespace blink {
+namespace {
+
+// A test implementation of the WebServiceWorkerCache interface which returns a (provided) error for every operation, and optionally checks arguments
+// to methods against provided arguments. Also used as a base class for test specific caches.
+class ErrorWebCacheForTests : public WebServiceWorkerCache {
+public:
+ ErrorWebCacheForTests(const WebServiceWorkerCacheError error) : m_error(error), m_expectedUrl(0), m_expectedQueryParams(0), m_expectedBatchOperations(0) { }
jsbell 2014/09/03 19:15:01 style: each initializer on separate line
gavinp 2014/09/04 19:47:33 Done.
+
+ String getAndClearLastErrorWebCacheMethodCalled()
+ {
+ String old = m_lastErrorWebCacheMethodCalled;
+ m_lastErrorWebCacheMethodCalled = "";
+ return old;
+ }
+
+ // These methods do not take ownership of their parameter. They provide an optional sample object to check parameters against. We purposefully avoid
+ // deep inspecting WebFoo objects for strict equality and test only for sanity, trusting the WebFoo test to catch lurking problems earlier.
+ void setExpectedUrl(const String* expectedUrl) { m_expectedUrl = expectedUrl; }
+ void setExpectedQueryParams(const QueryParams* expectedQueryParams) { m_expectedQueryParams = expectedQueryParams; }
+ void setExpectedBatchOperations(const WebVector<BatchOperation>* expectedBatchOperations) { m_expectedBatchOperations = expectedBatchOperations; }
+
+ // From WebServiceWorkerCache:
+ virtual void dispatchMatch(CacheMatchCallbacks* callbacks, const WebServiceWorkerRequest& webRequest, const QueryParams& queryParams) OVERRIDE
+ {
+ m_lastErrorWebCacheMethodCalled = "dispatchMatch";
+ CheckUrlIfProvided(webRequest.url());
+ CheckQueryParamsIfProvided(queryParams);
+
+ OwnPtr<CacheMatchCallbacks> ownedCallbacks(adoptPtr(callbacks));
+ WebServiceWorkerCacheError error = m_error;
+ return callbacks->onError(&error);
+ }
+
+ virtual void dispatchMatchAll(CacheWithResponsesCallbacks* callbacks, const WebServiceWorkerRequest& webRequest, const QueryParams& queryParams) OVERRIDE
+ {
+ m_lastErrorWebCacheMethodCalled = "dispatchMatchAll";
+ CheckUrlIfProvided(webRequest.url());
+ CheckQueryParamsIfProvided(queryParams);
+
+ OwnPtr<CacheWithResponsesCallbacks> ownedCallbacks(adoptPtr(callbacks));
+ WebServiceWorkerCacheError error = m_error;
+ return callbacks->onError(&error);
+ }
+
+ virtual void dispatchKeys(CacheWithRequestsCallbacks* callbacks, const WebServiceWorkerRequest* webRequest, const QueryParams& queryParams) OVERRIDE
+ {
+ m_lastErrorWebCacheMethodCalled = "dispatchKeys";
+ if (webRequest) {
+ CheckUrlIfProvided(webRequest->url());
+ CheckQueryParamsIfProvided(queryParams);
+ }
+
+ OwnPtr<CacheWithRequestsCallbacks> ownedCallbacks(adoptPtr(callbacks));
+ WebServiceWorkerCacheError error = m_error;
+ return callbacks->onError(&error);
+ }
+
+ virtual void dispatchBatch(CacheWithResponsesCallbacks* callbacks, const WebVector<BatchOperation>& batchOperations) OVERRIDE
+ {
+ m_lastErrorWebCacheMethodCalled = "dispatchBatch";
+ CheckBatchOperationsIfProvided(batchOperations);
+
+ OwnPtr<CacheWithResponsesCallbacks> ownedCallbacks(adoptPtr(callbacks));
+ WebServiceWorkerCacheError error = m_error;
+ return callbacks->onError(&error);
+ }
+
+protected:
+ void CheckUrlIfProvided(const KURL& url)
+ {
+ if (!m_expectedUrl)
+ return;
+ EXPECT_EQ(*m_expectedUrl, url);
+ }
+
+ void CheckQueryParamsIfProvided(const QueryParams& queryParams)
+ {
+ if (!m_expectedQueryParams)
+ return;
+ CompareQueryParamsForTest(*m_expectedQueryParams, queryParams);
+ }
+
+ void CheckBatchOperationsIfProvided(const WebVector<BatchOperation>& batchOperations)
+ {
+ if (!m_expectedBatchOperations)
+ return;
+ const WebVector<BatchOperation> expectedBatchOperations = *m_expectedBatchOperations;
+ EXPECT_EQ(expectedBatchOperations.size(), batchOperations.size());
+ for (int i = 0, minsize = std::min(expectedBatchOperations.size(), batchOperations.size()); i < minsize; ++i) {
+ EXPECT_EQ(expectedBatchOperations[i].operationType, batchOperations[i].operationType);
+ const String expectedRequestUrl = KURL(expectedBatchOperations[i].request.url());
+ EXPECT_EQ(expectedRequestUrl, KURL(batchOperations[i].request.url()));
+ const String expectedResponseUrl = KURL(expectedBatchOperations[i].response.url());
+ EXPECT_EQ(expectedResponseUrl, KURL(batchOperations[i].response.url()));
+ CompareQueryParamsForTest(expectedBatchOperations[i].matchParams, batchOperations[i].matchParams);
+ }
+ }
+
+private:
+ static void CompareQueryParamsForTest(const QueryParams& expectedQueryParams, const QueryParams& queryParams)
+ {
+ EXPECT_EQ(expectedQueryParams.ignoreSearch, queryParams.ignoreSearch);
+ EXPECT_EQ(expectedQueryParams.ignoreMethod, queryParams.ignoreMethod);
+ EXPECT_EQ(expectedQueryParams.ignoreVary, queryParams.ignoreVary);
+ EXPECT_EQ(expectedQueryParams.prefixMatch, queryParams.prefixMatch);
+ EXPECT_EQ(expectedQueryParams.cacheName, queryParams.cacheName);
+ }
+
+ const WebServiceWorkerCacheError m_error;
+
+ const String* m_expectedUrl;
+ const QueryParams* m_expectedQueryParams;
+ const WebVector<BatchOperation>* m_expectedBatchOperations;
+
+ String m_lastErrorWebCacheMethodCalled;
+};
+
+class NotImplementedErrorCache : public ErrorWebCacheForTests {
+public:
+ NotImplementedErrorCache() : ErrorWebCacheForTests(WebServiceWorkerCacheErrorNotImplemented) { }
jsbell 2014/09/03 19:15:01 style: wrap initializer
gavinp 2014/09/04 19:47:33 Done.
+};
+
+class ServiceWorkerCacheTest : public ::testing::Test {
+public:
+ ServiceWorkerCacheTest() : m_page(DummyPageHolder::create(IntSize(1, 1))) { }
jsbell 2014/09/03 19:15:01 style: wrap initializer
gavinp 2014/09/04 19:47:33 Done.
+
+ ScriptState* scriptState() { return ScriptState::forMainWorld(m_page->document().frame()); }
+ ExecutionContext* executionContext() { return scriptState()->executionContext(); }
+ v8::Isolate* isolate() { return scriptState()->isolate(); }
+
+ // Convenience methods for testing the returned promises.
+ ScriptValue getRejectValue(ScriptPromise& promise)
+ {
+ ScriptValue onReject;
+ promise.then(NullFunction::create(scriptState()), Function::create(scriptState(), &onReject));
+ isolate()->RunMicrotasks();
+ return onReject;
+ }
+
+ String getRejectString(ScriptPromise& promise)
+ {
+ ScriptValue onReject = getRejectValue(promise);
+ return toCoreString(onReject.v8Value()->ToString());
+ }
+
+ ScriptValue getResolveValue(ScriptPromise& promise)
+ {
+ ScriptValue onResolve;
+ promise.then(Function::create(scriptState(), &onResolve), NullFunction::create(scriptState()));
+ isolate()->RunMicrotasks();
+ return onResolve;
+ }
+
+ String getResolveString(ScriptPromise& promise)
+ {
+ ScriptValue onResolve = getResolveValue(promise);
+ return toCoreString(onResolve.v8Value()->ToString());
+ }
+
+ void expectNotImplemented(ScriptPromise& promise)
+ {
+ EXPECT_EQ("NotSupportedError: Method is not implemented.", getRejectString(promise));
+ }
+
+private:
+ // A ScriptFunction that creates a test failure if it is ever called.
+ class NullFunction : public ScriptFunction {
+ public:
+ static v8::Handle<v8::Function> create(ScriptState* scriptState)
+ {
+ NullFunction* self = new NullFunction(scriptState);
+ return self->bindToV8Function();
+ }
+
+ virtual ScriptValue call(ScriptValue value) OVERRIDE
+ {
+ ADD_FAILURE() << "Unexpected call to a null ScriptFunction.";
+ return value;
+ }
+ private:
+ NullFunction(ScriptState* scriptState) : ScriptFunction(scriptState) { }
+ };
+
+ class Function : public ScriptFunction {
+ public:
+ static v8::Handle<v8::Function> create(ScriptState* scriptState, ScriptValue* outValue)
+ {
+ Function* self = new Function(scriptState, outValue);
+ return self->bindToV8Function();
+ }
+
+ virtual ScriptValue call(ScriptValue value) OVERRIDE
+ {
+ ASSERT(!value.isEmpty());
+ *m_value = value;
+ return value;
+ }
+
+ const ScriptValue& scriptValue() { return *m_value; }
+
+ private:
+ Function(ScriptState* scriptState, ScriptValue* outValue) : ScriptFunction(scriptState), m_value(outValue) { }
+
+ ScriptValue* m_value;
+ };
+
+ // From ::testing::Test:
+ virtual void SetUp() OVERRIDE
+ {
+ EXPECT_FALSE(m_scriptScope);
+ m_scriptScope = adoptPtr(new ScriptState::Scope(scriptState()));
+ }
+
+ virtual void TearDown() OVERRIDE
+ {
+ m_scriptScope = 0;
+ }
+
+ // Lifetime is that of the text fixture.
+ OwnPtr<DummyPageHolder> m_page;
+
+ // Lifetime is per test instance.
+ OwnPtr<ScriptState::Scope> m_scriptScope;
+};
+
+TEST_F(ServiceWorkerCacheTest, Basics)
+{
+ ErrorWebCacheForTests* testCache;
+ RefPtrWillBeRawPtr<Cache> cache = Cache::fromWebServiceWorkerCache(testCache = new NotImplementedErrorCache());
+ ASSERT(cache);
+
+ const String url = "http://www.cachetest.org/";
+
+ ScriptPromise matchPromise = cache->match(scriptState(), url, Dictionary());
+ expectNotImplemented(matchPromise);
+
+ cache = Cache::fromWebServiceWorkerCache(testCache = new ErrorWebCacheForTests(WebServiceWorkerCacheErrorNotFound));
+ matchPromise = cache->match(scriptState(), url, Dictionary());
+ EXPECT_EQ("NotFoundError: Entry was not found.", getRejectString(matchPromise));
+
+ cache = Cache::fromWebServiceWorkerCache(testCache = new ErrorWebCacheForTests(WebServiceWorkerCacheErrorExists));
+ matchPromise = cache->match(scriptState(), url, Dictionary());
+ EXPECT_EQ("InvalidAccessError: Entry already exists.", getRejectString(matchPromise));
+}
+
+// Tests that arguments are faithfully passed on calls to Cache methods, except for methods which use batch operations,
+// which are tested later.
+TEST_F(ServiceWorkerCacheTest, BasicArguments)
+{
+ ErrorWebCacheForTests* testCache;
+ RefPtrWillBeRawPtr<Cache> cache = Cache::fromWebServiceWorkerCache(testCache = new NotImplementedErrorCache());
+ ASSERT(cache);
+
+ const String url = "http://www.cache.arguments.test/";
+ testCache->setExpectedUrl(&url);
+
+ WebServiceWorkerCache::QueryParams expectedQueryParams;
+ expectedQueryParams.ignoreVary = true;
+ expectedQueryParams.cacheName = "this is a cache name";
+ testCache->setExpectedQueryParams(&expectedQueryParams);
+
+ Dictionary queryParamsDict = Dictionary::createEmpty(isolate());
+ queryParamsDict.set("ignoreVary", 1);
+ queryParamsDict.set("cacheName", expectedQueryParams.cacheName);
+
+ TrackExceptionState exceptionState;
+ const RefPtrWillBeRawPtr<Request> request = Request::create(executionContext(), url, exceptionState);
+ ASSERT(request);
+ ASSERT_FALSE(exceptionState.hadException());
+
+ ScriptPromise matchResult = cache->match(scriptState(), request.get(), queryParamsDict);
+ EXPECT_EQ("dispatchMatch", testCache->getAndClearLastErrorWebCacheMethodCalled());
+ expectNotImplemented(matchResult);
+
+ ScriptPromise stringMatchResult = cache->match(scriptState(), url, queryParamsDict);
+ EXPECT_EQ("dispatchMatch", testCache->getAndClearLastErrorWebCacheMethodCalled());
+ expectNotImplemented(stringMatchResult);
+
+ ScriptPromise matchAllResult = cache->matchAll(scriptState(), request.get(), queryParamsDict);
+ EXPECT_EQ("dispatchMatchAll", testCache->getAndClearLastErrorWebCacheMethodCalled());
+ expectNotImplemented(matchAllResult);
+
+ ScriptPromise stringMatchAllResult = cache->matchAll(scriptState(), url, queryParamsDict);
+ EXPECT_EQ("dispatchMatchAll", testCache->getAndClearLastErrorWebCacheMethodCalled());
+ expectNotImplemented(stringMatchAllResult);
+
+ ScriptPromise keysResult1 = cache->keys(scriptState());
+ EXPECT_EQ("dispatchKeys", testCache->getAndClearLastErrorWebCacheMethodCalled());
+ expectNotImplemented(keysResult1);
+
+ ScriptPromise keysResult2 = cache->keys(scriptState(), request.get(), queryParamsDict);
+ EXPECT_EQ("dispatchKeys", testCache->getAndClearLastErrorWebCacheMethodCalled());
+ expectNotImplemented(keysResult2);
+
+ ScriptPromise stringKeysResult2 = cache->keys(scriptState(), url, queryParamsDict);
+ EXPECT_EQ("dispatchKeys", testCache->getAndClearLastErrorWebCacheMethodCalled());
+ expectNotImplemented(stringKeysResult2);
+}
+
+// Tests that arguments are faithfully passed to API calls that degrade to batch operations.
+TEST_F(ServiceWorkerCacheTest, BatchOperationArguments)
+{
+ ErrorWebCacheForTests* testCache;
+ RefPtrWillBeRawPtr<Cache> cache = Cache::fromWebServiceWorkerCache(testCache = new NotImplementedErrorCache());
+ ASSERT(cache);
+
+ WebServiceWorkerCache::QueryParams expectedQueryParams;
+ expectedQueryParams.prefixMatch = true;
+ expectedQueryParams.cacheName = "this is another cache name";
+ testCache->setExpectedQueryParams(&expectedQueryParams);
+
+ Dictionary queryParamsDict = Dictionary::createEmpty(isolate());
+ queryParamsDict.set("prefixMatch", 1);
+ queryParamsDict.set("cacheName", expectedQueryParams.cacheName);
+
+ const String url = "http://batch.operations.test/";
+ TrackExceptionState exceptionState;
+ const RefPtrWillBeRawPtr<Request> request = Request::create(executionContext(), url, exceptionState);
+ ASSERT(request);
+ ASSERT_FALSE(exceptionState.hadException());
+
+ WebServiceWorkerResponse webResponse;
+ webResponse.setURL(KURL(ParsedURLString, url));
+ const RefPtrWillBeRawPtr<Response> response = Response::create(webResponse);
+
+ WebVector<WebServiceWorkerCache::BatchOperation> expectedDeleteOperations(size_t(1));
+ {
+ WebServiceWorkerCache::BatchOperation deleteOperation;
+ deleteOperation.operationType = WebServiceWorkerCache::WebServiceWorkerCacheOperationTypeDelete;
+ request->populateWebServiceWorkerRequest(deleteOperation.request);
+ deleteOperation.matchParams = expectedQueryParams;
+ expectedDeleteOperations[0] = deleteOperation;
+ }
+ testCache->setExpectedBatchOperations(&expectedDeleteOperations);
+
+ ScriptPromise deleteResult = cache->deleteFunction(scriptState(), request.get(), queryParamsDict);
+ EXPECT_EQ("dispatchBatch", testCache->getAndClearLastErrorWebCacheMethodCalled());
+ expectNotImplemented(deleteResult);
+
+ ScriptPromise stringDeleteResult = cache->deleteFunction(scriptState(), url, queryParamsDict);
+ EXPECT_EQ("dispatchBatch", testCache->getAndClearLastErrorWebCacheMethodCalled());
+ expectNotImplemented(stringDeleteResult);
+
+ WebVector<WebServiceWorkerCache::BatchOperation> expectedPutOperations(size_t(1));
+ {
+ WebServiceWorkerCache::BatchOperation putOperation;
+ putOperation.operationType = WebServiceWorkerCache::WebServiceWorkerCacheOperationTypePut;
+ request->populateWebServiceWorkerRequest(putOperation.request);
+ response->populateWebServiceWorkerResponse(putOperation.response);
+ expectedPutOperations[0] = putOperation;
+ }
+ testCache->setExpectedBatchOperations(&expectedPutOperations);
+
+ ScriptPromise putResult = cache->put(scriptState(), request.get(), response.get());
+ EXPECT_EQ("dispatchBatch", testCache->getAndClearLastErrorWebCacheMethodCalled());
+ expectNotImplemented(putResult);
+
+ ScriptPromise stringPutResult = cache->put(scriptState(), url, response.get());
+ EXPECT_EQ("dispatchBatch", testCache->getAndClearLastErrorWebCacheMethodCalled());
+ expectNotImplemented(stringPutResult);
+
+ // FIXME: test add & addAll.
+}
+
+class MatchTestCache : public NotImplementedErrorCache {
+public:
+ MatchTestCache(WebServiceWorkerResponse& response) : m_response(response) { }
+
+ // From WebServiceWorkerCache:
+ virtual void dispatchMatch(CacheMatchCallbacks* callbacks, const WebServiceWorkerRequest& webRequest, const QueryParams& queryParams) OVERRIDE
+ {
+ OwnPtr<CacheMatchCallbacks> ownedCallbacks(adoptPtr(callbacks));
+ return callbacks->onSuccess(&m_response);
+ }
+
+private:
+ WebServiceWorkerResponse& m_response;
+};
+
+TEST_F(ServiceWorkerCacheTest, MatchResponseTest)
+{
+ const String requestUrl = "http://request.url/";
+ const String responseUrl = "http://match.response.test/";
+
+ WebServiceWorkerResponse webResponse;
+ webResponse.setURL(KURL(ParsedURLString, responseUrl));
+
+ RefPtrWillBeRawPtr<Cache> cache = Cache::fromWebServiceWorkerCache(new MatchTestCache(webResponse));
+
+ ScriptPromise result = cache->match(scriptState(), requestUrl, Dictionary());
+ ScriptValue scriptValue = getResolveValue(result);
+ Response* response = V8Response::toNativeWithTypeCheck(isolate(), scriptValue.v8Value());
+ ASSERT_TRUE(response);
+ EXPECT_EQ(responseUrl, response->url());
+}
+
+class KeysTestCache : public NotImplementedErrorCache {
+public:
+ KeysTestCache(WebVector<WebServiceWorkerRequest>& requests) : m_requests(requests) { }
+
+ virtual void dispatchKeys(CacheWithRequestsCallbacks* callbacks, const WebServiceWorkerRequest* webRequest, const QueryParams& queryParams) OVERRIDE
+ {
+ OwnPtr<CacheWithRequestsCallbacks> ownedCallbacks(adoptPtr(callbacks));
+ return callbacks->onSuccess(&m_requests);
+ }
+
+private:
+ WebVector<WebServiceWorkerRequest>& m_requests;
+};
+
+TEST_F(ServiceWorkerCacheTest, KeysResponseTest)
+{
+ const String url1 = "http://first.request/";
+ const String url2 = "http://second.request/";
+
+ Vector<String> expectedUrls(size_t(2));
+ expectedUrls[0] = url1;
+ expectedUrls[1] = url2;
+
+ WebVector<WebServiceWorkerRequest> webRequests(size_t(2));
+ webRequests[0].setURL(KURL(ParsedURLString, url1));
+ webRequests[1].setURL(KURL(ParsedURLString, url2));
+
+ RefPtrWillBeRawPtr<Cache> cache = Cache::fromWebServiceWorkerCache(new KeysTestCache(webRequests));
+
+ ScriptPromise result = cache->keys(scriptState());
+ ScriptValue scriptValue = getResolveValue(result);
+
+ Vector<v8::Handle<v8::Value> > requests = toNativeArray<v8::Handle<v8::Value> >(scriptValue.v8Value(), 0, isolate());
+ EXPECT_EQ(expectedUrls.size(), requests.size());
+ for (int i = 0, minsize = std::min(expectedUrls.size(), requests.size()); i < minsize; ++i) {
+ Request* request = V8Request::toNativeWithTypeCheck(isolate(), requests[i]);
+ EXPECT_TRUE(request);
+ if (request)
+ EXPECT_EQ(expectedUrls[i], request->url());
+ }
+}
+
+class MatchAllAndBatchTestCache : public NotImplementedErrorCache {
+public:
+ MatchAllAndBatchTestCache(WebVector<WebServiceWorkerResponse>& responses) : m_responses(responses) { }
+
+ virtual void dispatchMatchAll(CacheWithResponsesCallbacks* callbacks, const WebServiceWorkerRequest& webRequest, const QueryParams& queryParams) OVERRIDE
+ {
+ OwnPtr<CacheWithResponsesCallbacks> ownedCallbacks(adoptPtr(callbacks));
+ return callbacks->onSuccess(&m_responses);
+ }
+
+ virtual void dispatchBatch(CacheWithResponsesCallbacks* callbacks, const WebVector<BatchOperation>& batchOperations) OVERRIDE
+ {
+ OwnPtr<CacheWithResponsesCallbacks> ownedCallbacks(adoptPtr(callbacks));
+ return callbacks->onSuccess(&m_responses);
+ }
+
+private:
+ WebVector<WebServiceWorkerResponse>& m_responses;
+};
+
+TEST_F(ServiceWorkerCacheTest, MatchAllAndBatchResponseTest)
+{
+ const String url1 = "http://first.response/";
+ const String url2 = "http://second.response/";
+
+ Vector<String> expectedUrls(size_t(2));
+ expectedUrls[0] = url1;
+ expectedUrls[1] = url2;
+
+ WebVector<WebServiceWorkerResponse> webResponses(size_t(2));
+ webResponses[0].setURL(KURL(ParsedURLString, url1));
+ webResponses[1].setURL(KURL(ParsedURLString, url2));
+
+ RefPtrWillBeRawPtr<Cache> cache = Cache::fromWebServiceWorkerCache(new MatchAllAndBatchTestCache(webResponses));
+
+ ScriptPromise result = cache->matchAll(scriptState(), "http://some.url/", Dictionary());
+ ScriptValue scriptValue = getResolveValue(result);
+
+ Vector<v8::Handle<v8::Value> > responses = toNativeArray<v8::Handle<v8::Value> >(scriptValue.v8Value(), 0, isolate());
+ EXPECT_EQ(expectedUrls.size(), responses.size());
+ for (int i = 0, minsize = std::min(expectedUrls.size(), responses.size()); i < minsize; ++i) {
+ Response* response = V8Response::toNativeWithTypeCheck(isolate(), responses[i]);
+ EXPECT_TRUE(response);
+ if (response)
+ EXPECT_EQ(expectedUrls[i], response->url());
+ }
+
+ result = cache->deleteFunction(scriptState(), "http://some.url/", Dictionary());
+ scriptValue = getResolveValue(result);
+ responses = toNativeArray<v8::Handle<v8::Value> >(scriptValue.v8Value(), 0, isolate());
+ EXPECT_EQ(expectedUrls.size(), responses.size());
+ for (int i = 0, minsize = std::min(expectedUrls.size(), responses.size()); i < minsize; ++i) {
+ Response* response = V8Response::toNativeWithTypeCheck(isolate(), responses[i]);
+ EXPECT_TRUE(response);
+ if (response)
+ EXPECT_EQ(expectedUrls[i], response->url());
+ }
+}
+
+} // namespace
+} // namespace blink
« Source/modules/serviceworkers/CacheStorage.cpp ('K') | « Source/modules/serviceworkers/CacheStorage.cpp ('k') | public/platform/WebServiceWorkerCache.h » ('j') | public/platform/WebServiceWorkerCache.h » ('J')

Powered by Google App Engine
This is Rietveld 408576698