| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "config.h" | 5 #include "config.h" |
| 6 #include "modules/cachestorage/Cache.h" | 6 #include "modules/cachestorage/Cache.h" |
| 7 | 7 |
| 8 #include "bindings/core/v8/CallbackPromiseAdapter.h" | 8 #include "bindings/core/v8/CallbackPromiseAdapter.h" |
| 9 #include "bindings/core/v8/ExceptionState.h" | 9 #include "bindings/core/v8/ExceptionState.h" |
| 10 #include "bindings/core/v8/ScriptPromiseResolver.h" | 10 #include "bindings/core/v8/ScriptPromiseResolver.h" |
| (...skipping 18 matching lines...) Expand all Loading... |
| 29 public: | 29 public: |
| 30 CacheMatchCallbacks(PassRefPtrWillBeRawPtr<ScriptPromiseResolver> resolver) | 30 CacheMatchCallbacks(PassRefPtrWillBeRawPtr<ScriptPromiseResolver> resolver) |
| 31 : m_resolver(resolver) { } | 31 : m_resolver(resolver) { } |
| 32 | 32 |
| 33 virtual void onSuccess(WebServiceWorkerResponse* webResponse) override | 33 virtual void onSuccess(WebServiceWorkerResponse* webResponse) override |
| 34 { | 34 { |
| 35 m_resolver->resolve(Response::create(m_resolver->scriptState()->executio
nContext(), *webResponse)); | 35 m_resolver->resolve(Response::create(m_resolver->scriptState()->executio
nContext(), *webResponse)); |
| 36 m_resolver.clear(); | 36 m_resolver.clear(); |
| 37 } | 37 } |
| 38 | 38 |
| 39 virtual void onError(WebServiceWorkerCacheError* reason) override | 39 // Ownership of |rawReason| must be passed. |
| 40 virtual void onError(WebServiceWorkerCacheError* rawReason) override |
| 40 { | 41 { |
| 42 OwnPtr<WebServiceWorkerCacheError> reason = adoptPtr(rawReason); |
| 41 if (*reason == WebServiceWorkerCacheErrorNotFound) | 43 if (*reason == WebServiceWorkerCacheErrorNotFound) |
| 42 m_resolver->resolve(); | 44 m_resolver->resolve(); |
| 43 else | 45 else |
| 44 m_resolver->reject(CacheStorageError::createException(*reason)); | 46 m_resolver->reject(CacheStorageError::createException(*reason)); |
| 45 m_resolver.clear(); | 47 m_resolver.clear(); |
| 46 } | 48 } |
| 47 | 49 |
| 48 private: | 50 private: |
| 49 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; | 51 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; |
| 50 }; | 52 }; |
| 51 | 53 |
| 52 // FIXME: Consider using CallbackPromiseAdapter. | 54 // FIXME: Consider using CallbackPromiseAdapter. |
| 53 class CacheWithResponsesCallbacks : public WebServiceWorkerCache::CacheWithRespo
nsesCallbacks { | 55 class CacheWithResponsesCallbacks : public WebServiceWorkerCache::CacheWithRespo
nsesCallbacks { |
| 54 WTF_MAKE_NONCOPYABLE(CacheWithResponsesCallbacks); | 56 WTF_MAKE_NONCOPYABLE(CacheWithResponsesCallbacks); |
| 55 public: | 57 public: |
| 56 CacheWithResponsesCallbacks(PassRefPtrWillBeRawPtr<ScriptPromiseResolver> re
solver) | 58 CacheWithResponsesCallbacks(PassRefPtrWillBeRawPtr<ScriptPromiseResolver> re
solver) |
| 57 : m_resolver(resolver) { } | 59 : m_resolver(resolver) { } |
| 58 | 60 |
| 59 virtual void onSuccess(WebVector<WebServiceWorkerResponse>* webResponses) ov
erride | 61 virtual void onSuccess(WebVector<WebServiceWorkerResponse>* webResponses) ov
erride |
| 60 { | 62 { |
| 61 HeapVector<Member<Response>> responses; | 63 HeapVector<Member<Response>> responses; |
| 62 for (size_t i = 0; i < webResponses->size(); ++i) | 64 for (size_t i = 0; i < webResponses->size(); ++i) |
| 63 responses.append(Response::create(m_resolver->scriptState()->executi
onContext(), (*webResponses)[i])); | 65 responses.append(Response::create(m_resolver->scriptState()->executi
onContext(), (*webResponses)[i])); |
| 64 m_resolver->resolve(responses); | 66 m_resolver->resolve(responses); |
| 65 m_resolver.clear(); | 67 m_resolver.clear(); |
| 66 } | 68 } |
| 67 | 69 |
| 68 virtual void onError(WebServiceWorkerCacheError* reason) override | 70 // Ownership of |rawReason| must be passed. |
| 71 virtual void onError(WebServiceWorkerCacheError* rawReason) override |
| 69 { | 72 { |
| 73 OwnPtr<WebServiceWorkerCacheError> reason = adoptPtr(rawReason); |
| 70 m_resolver->reject(CacheStorageError::createException(*reason)); | 74 m_resolver->reject(CacheStorageError::createException(*reason)); |
| 71 m_resolver.clear(); | 75 m_resolver.clear(); |
| 72 } | 76 } |
| 73 | 77 |
| 74 protected: | 78 protected: |
| 75 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; | 79 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; |
| 76 }; | 80 }; |
| 77 | 81 |
| 78 // FIXME: Consider using CallbackPromiseAdapter. | 82 // FIXME: Consider using CallbackPromiseAdapter. |
| 79 class CacheDeleteCallback : public WebServiceWorkerCache::CacheBatchCallbacks { | 83 class CacheDeleteCallback : public WebServiceWorkerCache::CacheBatchCallbacks { |
| 80 WTF_MAKE_NONCOPYABLE(CacheDeleteCallback); | 84 WTF_MAKE_NONCOPYABLE(CacheDeleteCallback); |
| 81 public: | 85 public: |
| 82 CacheDeleteCallback(PassRefPtrWillBeRawPtr<ScriptPromiseResolver> resolver) | 86 CacheDeleteCallback(PassRefPtrWillBeRawPtr<ScriptPromiseResolver> resolver) |
| 83 : m_resolver(resolver) { } | 87 : m_resolver(resolver) { } |
| 84 | 88 |
| 85 void onSuccess() override | 89 void onSuccess() override |
| 86 { | 90 { |
| 87 m_resolver->resolve(true); | 91 m_resolver->resolve(true); |
| 88 m_resolver.clear(); | 92 m_resolver.clear(); |
| 89 } | 93 } |
| 90 | 94 |
| 91 void onError(WebServiceWorkerCacheError* reason) override | 95 // Ownership of |rawReason| must be passed. |
| 96 virtual void onError(WebServiceWorkerCacheError* rawReason) override |
| 92 { | 97 { |
| 98 OwnPtr<WebServiceWorkerCacheError> reason = adoptPtr(rawReason); |
| 93 if (*reason == WebServiceWorkerCacheErrorNotFound) | 99 if (*reason == WebServiceWorkerCacheErrorNotFound) |
| 94 m_resolver->resolve(false); | 100 m_resolver->resolve(false); |
| 95 else | 101 else |
| 96 m_resolver->reject(CacheStorageError::createException(*reason)); | 102 m_resolver->reject(CacheStorageError::createException(*reason)); |
| 97 m_resolver.clear(); | 103 m_resolver.clear(); |
| 98 } | 104 } |
| 99 | 105 |
| 100 private: | 106 private: |
| 101 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; | 107 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; |
| 102 }; | 108 }; |
| 103 | 109 |
| 104 // FIXME: Consider using CallbackPromiseAdapter. | 110 // FIXME: Consider using CallbackPromiseAdapter. |
| 105 class CacheWithRequestsCallbacks : public WebServiceWorkerCache::CacheWithReques
tsCallbacks { | 111 class CacheWithRequestsCallbacks : public WebServiceWorkerCache::CacheWithReques
tsCallbacks { |
| 106 WTF_MAKE_NONCOPYABLE(CacheWithRequestsCallbacks); | 112 WTF_MAKE_NONCOPYABLE(CacheWithRequestsCallbacks); |
| 107 public: | 113 public: |
| 108 CacheWithRequestsCallbacks(PassRefPtrWillBeRawPtr<ScriptPromiseResolver> res
olver) | 114 CacheWithRequestsCallbacks(PassRefPtrWillBeRawPtr<ScriptPromiseResolver> res
olver) |
| 109 : m_resolver(resolver) { } | 115 : m_resolver(resolver) { } |
| 110 | 116 |
| 111 virtual void onSuccess(WebVector<WebServiceWorkerRequest>* webRequests) over
ride | 117 virtual void onSuccess(WebVector<WebServiceWorkerRequest>* webRequests) over
ride |
| 112 { | 118 { |
| 113 HeapVector<Member<Request>> requests; | 119 HeapVector<Member<Request>> requests; |
| 114 for (size_t i = 0; i < webRequests->size(); ++i) | 120 for (size_t i = 0; i < webRequests->size(); ++i) |
| 115 requests.append(Request::create(m_resolver->scriptState()->execution
Context(), (*webRequests)[i])); | 121 requests.append(Request::create(m_resolver->scriptState()->execution
Context(), (*webRequests)[i])); |
| 116 m_resolver->resolve(requests); | 122 m_resolver->resolve(requests); |
| 117 m_resolver.clear(); | 123 m_resolver.clear(); |
| 118 } | 124 } |
| 119 | 125 |
| 120 virtual void onError(WebServiceWorkerCacheError* reason) override | 126 // Ownership of |rawReason| must be passed. |
| 127 virtual void onError(WebServiceWorkerCacheError* rawReason) override |
| 121 { | 128 { |
| 129 OwnPtr<WebServiceWorkerCacheError> reason = adoptPtr(rawReason); |
| 122 m_resolver->reject(CacheStorageError::createException(*reason)); | 130 m_resolver->reject(CacheStorageError::createException(*reason)); |
| 123 m_resolver.clear(); | 131 m_resolver.clear(); |
| 124 } | 132 } |
| 125 | 133 |
| 126 private: | 134 private: |
| 127 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; | 135 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; |
| 128 }; | 136 }; |
| 129 | 137 |
| 130 ScriptPromise rejectAsNotImplemented(ScriptState* scriptState) | 138 ScriptPromise rejectAsNotImplemented(ScriptState* scriptState) |
| 131 { | 139 { |
| (...skipping 295 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 427 m_webCache->dispatchKeys(new CacheWithRequestsCallbacks(resolver), 0, toWebQ
ueryParams(options)); | 435 m_webCache->dispatchKeys(new CacheWithRequestsCallbacks(resolver), 0, toWebQ
ueryParams(options)); |
| 428 return promise; | 436 return promise; |
| 429 } | 437 } |
| 430 | 438 |
| 431 WebServiceWorkerCache* Cache::webCache() const | 439 WebServiceWorkerCache* Cache::webCache() const |
| 432 { | 440 { |
| 433 return m_webCache.get(); | 441 return m_webCache.get(); |
| 434 } | 442 } |
| 435 | 443 |
| 436 } // namespace blink | 444 } // namespace blink |
| OLD | NEW |