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/serviceworkers/CacheStorage.h" | 6 #include "modules/serviceworkers/CacheStorage.h" |
7 | 7 |
8 #include "bindings/core/v8/ScriptPromiseResolver.h" | 8 #include "bindings/core/v8/ScriptPromiseResolver.h" |
9 #include "bindings/core/v8/ScriptState.h" | 9 #include "bindings/core/v8/ScriptState.h" |
10 #include "core/dom/DOMException.h" | 10 #include "core/dom/DOMException.h" |
(...skipping 11 matching lines...) Expand all Loading... |
22 { | 22 { |
23 return DOMException::create(NotSupportedError, "No CacheStorage implementati
on provided."); | 23 return DOMException::create(NotSupportedError, "No CacheStorage implementati
on provided."); |
24 } | 24 } |
25 | 25 |
26 } | 26 } |
27 | 27 |
28 // FIXME: Consider using CallbackPromiseAdapter. | 28 // FIXME: Consider using CallbackPromiseAdapter. |
29 class CacheStorage::Callbacks final : public WebServiceWorkerCacheStorage::Cache
StorageCallbacks { | 29 class CacheStorage::Callbacks final : public WebServiceWorkerCacheStorage::Cache
StorageCallbacks { |
30 WTF_MAKE_NONCOPYABLE(Callbacks); | 30 WTF_MAKE_NONCOPYABLE(Callbacks); |
31 public: | 31 public: |
32 explicit Callbacks(PassRefPtr<ScriptPromiseResolver> resolver) | 32 explicit Callbacks(PassRefPtrWillBeRawPtr<ScriptPromiseResolver> resolver) |
33 : m_resolver(resolver) { } | 33 : m_resolver(resolver) { } |
34 virtual ~Callbacks() { } | 34 virtual ~Callbacks() { } |
35 | 35 |
36 virtual void onSuccess() override | 36 virtual void onSuccess() override |
37 { | 37 { |
38 m_resolver->resolve(true); | 38 m_resolver->resolve(true); |
39 m_resolver.clear(); | 39 m_resolver.clear(); |
40 } | 40 } |
41 | 41 |
42 virtual void onError(WebServiceWorkerCacheError* reason) override | 42 virtual void onError(WebServiceWorkerCacheError* reason) override |
43 { | 43 { |
44 if (*reason == WebServiceWorkerCacheErrorNotFound) | 44 if (*reason == WebServiceWorkerCacheErrorNotFound) |
45 m_resolver->resolve(false); | 45 m_resolver->resolve(false); |
46 else | 46 else |
47 m_resolver->reject(Cache::domExceptionForCacheError(*reason)); | 47 m_resolver->reject(Cache::domExceptionForCacheError(*reason)); |
48 m_resolver.clear(); | 48 m_resolver.clear(); |
49 } | 49 } |
50 | 50 |
51 private: | 51 private: |
52 RefPtr<ScriptPromiseResolver> m_resolver; | 52 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; |
53 }; | 53 }; |
54 | 54 |
55 // FIXME: Consider using CallbackPromiseAdapter. | 55 // FIXME: Consider using CallbackPromiseAdapter. |
56 class CacheStorage::WithCacheCallbacks final : public WebServiceWorkerCacheStora
ge::CacheStorageWithCacheCallbacks { | 56 class CacheStorage::WithCacheCallbacks final : public WebServiceWorkerCacheStora
ge::CacheStorageWithCacheCallbacks { |
57 WTF_MAKE_NONCOPYABLE(WithCacheCallbacks); | 57 WTF_MAKE_NONCOPYABLE(WithCacheCallbacks); |
58 public: | 58 public: |
59 WithCacheCallbacks(const String& cacheName, CacheStorage* cacheStorage, Pass
RefPtr<ScriptPromiseResolver> resolver) | 59 WithCacheCallbacks(const String& cacheName, CacheStorage* cacheStorage, Pass
RefPtrWillBeRawPtr<ScriptPromiseResolver> resolver) |
60 : m_cacheName(cacheName), m_cacheStorage(cacheStorage), m_resolver(resol
ver) { } | 60 : m_cacheName(cacheName), m_cacheStorage(cacheStorage), m_resolver(resol
ver) { } |
61 virtual ~WithCacheCallbacks() { } | 61 virtual ~WithCacheCallbacks() { } |
62 | 62 |
63 virtual void onSuccess(WebServiceWorkerCache* webCache) override | 63 virtual void onSuccess(WebServiceWorkerCache* webCache) override |
64 { | 64 { |
65 // FIXME: Remove this once content's WebServiceWorkerCache implementatio
n has landed. | 65 // FIXME: Remove this once content's WebServiceWorkerCache implementatio
n has landed. |
66 if (!webCache) { | 66 if (!webCache) { |
67 m_resolver->reject("not implemented"); | 67 m_resolver->reject("not implemented"); |
68 return; | 68 return; |
69 } | 69 } |
70 Cache* cache = Cache::create(webCache); | 70 Cache* cache = Cache::create(webCache); |
71 m_cacheStorage->m_nameToCacheMap.set(m_cacheName, cache); | 71 m_cacheStorage->m_nameToCacheMap.set(m_cacheName, cache); |
72 m_resolver->resolve(cache); | 72 m_resolver->resolve(cache); |
73 m_resolver.clear(); | 73 m_resolver.clear(); |
74 } | 74 } |
75 | 75 |
76 virtual void onError(WebServiceWorkerCacheError* reason) override | 76 virtual void onError(WebServiceWorkerCacheError* reason) override |
77 { | 77 { |
78 if (*reason == WebServiceWorkerCacheErrorNotFound) | 78 if (*reason == WebServiceWorkerCacheErrorNotFound) |
79 m_resolver->resolve(); | 79 m_resolver->resolve(); |
80 else | 80 else |
81 m_resolver->reject(Cache::domExceptionForCacheError(*reason)); | 81 m_resolver->reject(Cache::domExceptionForCacheError(*reason)); |
82 m_resolver.clear(); | 82 m_resolver.clear(); |
83 } | 83 } |
84 | 84 |
85 private: | 85 private: |
86 String m_cacheName; | 86 String m_cacheName; |
87 Persistent<CacheStorage> m_cacheStorage; | 87 Persistent<CacheStorage> m_cacheStorage; |
88 RefPtr<ScriptPromiseResolver> m_resolver; | 88 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; |
89 }; | 89 }; |
90 | 90 |
91 // FIXME: Consider using CallbackPromiseAdapter. | 91 // FIXME: Consider using CallbackPromiseAdapter. |
92 class CacheStorage::MatchCallbacks : public WebServiceWorkerCacheStorage::CacheS
torageMatchCallbacks { | 92 class CacheStorage::MatchCallbacks : public WebServiceWorkerCacheStorage::CacheS
torageMatchCallbacks { |
93 WTF_MAKE_NONCOPYABLE(MatchCallbacks); | 93 WTF_MAKE_NONCOPYABLE(MatchCallbacks); |
94 public: | 94 public: |
95 MatchCallbacks(PassRefPtr<ScriptPromiseResolver> resolver) | 95 MatchCallbacks(PassRefPtrWillBeRawPtr<ScriptPromiseResolver> resolver) |
96 : m_resolver(resolver) { } | 96 : m_resolver(resolver) { } |
97 | 97 |
98 virtual void onSuccess(WebServiceWorkerResponse* webResponse) override | 98 virtual void onSuccess(WebServiceWorkerResponse* webResponse) override |
99 { | 99 { |
100 m_resolver->resolve(Response::create(m_resolver->scriptState()->executio
nContext(), *webResponse)); | 100 m_resolver->resolve(Response::create(m_resolver->scriptState()->executio
nContext(), *webResponse)); |
101 m_resolver.clear(); | 101 m_resolver.clear(); |
102 } | 102 } |
103 | 103 |
104 virtual void onError(WebServiceWorkerCacheError* reason) override | 104 virtual void onError(WebServiceWorkerCacheError* reason) override |
105 { | 105 { |
106 if (*reason == WebServiceWorkerCacheErrorNotFound) | 106 if (*reason == WebServiceWorkerCacheErrorNotFound) |
107 m_resolver->resolve(); | 107 m_resolver->resolve(); |
108 else | 108 else |
109 m_resolver->reject(Cache::domExceptionForCacheError(*reason)); | 109 m_resolver->reject(Cache::domExceptionForCacheError(*reason)); |
110 m_resolver.clear(); | 110 m_resolver.clear(); |
111 } | 111 } |
112 | 112 |
113 private: | 113 private: |
114 RefPtr<ScriptPromiseResolver> m_resolver; | 114 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; |
115 }; | 115 }; |
116 | 116 |
117 | 117 |
118 // FIXME: Consider using CallbackPromiseAdapter. | 118 // FIXME: Consider using CallbackPromiseAdapter. |
119 class CacheStorage::DeleteCallbacks final : public WebServiceWorkerCacheStorage:
:CacheStorageCallbacks { | 119 class CacheStorage::DeleteCallbacks final : public WebServiceWorkerCacheStorage:
:CacheStorageCallbacks { |
120 WTF_MAKE_NONCOPYABLE(DeleteCallbacks); | 120 WTF_MAKE_NONCOPYABLE(DeleteCallbacks); |
121 public: | 121 public: |
122 DeleteCallbacks(const String& cacheName, CacheStorage* cacheStorage, PassRef
Ptr<ScriptPromiseResolver> resolver) | 122 DeleteCallbacks(const String& cacheName, CacheStorage* cacheStorage, PassRef
PtrWillBeRawPtr<ScriptPromiseResolver> resolver) |
123 : m_cacheName(cacheName), m_cacheStorage(cacheStorage), m_resolver(resol
ver) { } | 123 : m_cacheName(cacheName), m_cacheStorage(cacheStorage), m_resolver(resol
ver) { } |
124 virtual ~DeleteCallbacks() { } | 124 virtual ~DeleteCallbacks() { } |
125 | 125 |
126 virtual void onSuccess() override | 126 virtual void onSuccess() override |
127 { | 127 { |
128 m_cacheStorage->m_nameToCacheMap.remove(m_cacheName); | 128 m_cacheStorage->m_nameToCacheMap.remove(m_cacheName); |
129 m_resolver->resolve(true); | 129 m_resolver->resolve(true); |
130 m_resolver.clear(); | 130 m_resolver.clear(); |
131 } | 131 } |
132 | 132 |
133 virtual void onError(WebServiceWorkerCacheError* reason) override | 133 virtual void onError(WebServiceWorkerCacheError* reason) override |
134 { | 134 { |
135 if (*reason == WebServiceWorkerCacheErrorNotFound) | 135 if (*reason == WebServiceWorkerCacheErrorNotFound) |
136 m_resolver->resolve(false); | 136 m_resolver->resolve(false); |
137 else | 137 else |
138 m_resolver->reject(Cache::domExceptionForCacheError(*reason)); | 138 m_resolver->reject(Cache::domExceptionForCacheError(*reason)); |
139 m_resolver.clear(); | 139 m_resolver.clear(); |
140 } | 140 } |
141 | 141 |
142 private: | 142 private: |
143 String m_cacheName; | 143 String m_cacheName; |
144 Persistent<CacheStorage> m_cacheStorage; | 144 Persistent<CacheStorage> m_cacheStorage; |
145 RefPtr<ScriptPromiseResolver> m_resolver; | 145 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; |
146 }; | 146 }; |
147 | 147 |
148 // FIXME: Consider using CallbackPromiseAdapter. | 148 // FIXME: Consider using CallbackPromiseAdapter. |
149 class CacheStorage::KeysCallbacks final : public WebServiceWorkerCacheStorage::C
acheStorageKeysCallbacks { | 149 class CacheStorage::KeysCallbacks final : public WebServiceWorkerCacheStorage::C
acheStorageKeysCallbacks { |
150 WTF_MAKE_NONCOPYABLE(KeysCallbacks); | 150 WTF_MAKE_NONCOPYABLE(KeysCallbacks); |
151 public: | 151 public: |
152 explicit KeysCallbacks(PassRefPtr<ScriptPromiseResolver> resolver) | 152 explicit KeysCallbacks(PassRefPtrWillBeRawPtr<ScriptPromiseResolver> resolve
r) |
153 : m_resolver(resolver) { } | 153 : m_resolver(resolver) { } |
154 virtual ~KeysCallbacks() { } | 154 virtual ~KeysCallbacks() { } |
155 | 155 |
156 virtual void onSuccess(WebVector<WebString>* keys) override | 156 virtual void onSuccess(WebVector<WebString>* keys) override |
157 { | 157 { |
158 Vector<String> wtfKeys; | 158 Vector<String> wtfKeys; |
159 for (size_t i = 0; i < keys->size(); ++i) | 159 for (size_t i = 0; i < keys->size(); ++i) |
160 wtfKeys.append((*keys)[i]); | 160 wtfKeys.append((*keys)[i]); |
161 m_resolver->resolve(wtfKeys); | 161 m_resolver->resolve(wtfKeys); |
162 m_resolver.clear(); | 162 m_resolver.clear(); |
163 } | 163 } |
164 | 164 |
165 virtual void onError(WebServiceWorkerCacheError* reason) override | 165 virtual void onError(WebServiceWorkerCacheError* reason) override |
166 { | 166 { |
167 m_resolver->reject(Cache::domExceptionForCacheError(*reason)); | 167 m_resolver->reject(Cache::domExceptionForCacheError(*reason)); |
168 m_resolver.clear(); | 168 m_resolver.clear(); |
169 } | 169 } |
170 | 170 |
171 private: | 171 private: |
172 RefPtr<ScriptPromiseResolver> m_resolver; | 172 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; |
173 }; | 173 }; |
174 | 174 |
175 CacheStorage* CacheStorage::create(WebServiceWorkerCacheStorage* webCacheStorage
) | 175 CacheStorage* CacheStorage::create(WebServiceWorkerCacheStorage* webCacheStorage
) |
176 { | 176 { |
177 return new CacheStorage(webCacheStorage); | 177 return new CacheStorage(webCacheStorage); |
178 } | 178 } |
179 | 179 |
180 ScriptPromise CacheStorage::open(ScriptState* scriptState, const String& cacheNa
me) | 180 ScriptPromise CacheStorage::open(ScriptState* scriptState, const String& cacheNa
me) |
181 { | 181 { |
182 RefPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::create(scrip
tState); | 182 RefPtrWillBeRawPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::
create(scriptState); |
183 const ScriptPromise promise = resolver->promise(); | 183 const ScriptPromise promise = resolver->promise(); |
184 | 184 |
185 if (m_nameToCacheMap.contains(cacheName)) { | 185 if (m_nameToCacheMap.contains(cacheName)) { |
186 Cache* cache = m_nameToCacheMap.find(cacheName)->value; | 186 Cache* cache = m_nameToCacheMap.find(cacheName)->value; |
187 resolver->resolve(cache); | 187 resolver->resolve(cache); |
188 return promise; | 188 return promise; |
189 } | 189 } |
190 | 190 |
191 if (m_webCacheStorage) | 191 if (m_webCacheStorage) |
192 m_webCacheStorage->dispatchOpen(new WithCacheCallbacks(cacheName, this,
resolver), cacheName); | 192 m_webCacheStorage->dispatchOpen(new WithCacheCallbacks(cacheName, this,
resolver), cacheName); |
193 else | 193 else |
194 resolver->reject(createNoImplementationException()); | 194 resolver->reject(createNoImplementationException()); |
195 | 195 |
196 return promise; | 196 return promise; |
197 } | 197 } |
198 | 198 |
199 ScriptPromise CacheStorage::has(ScriptState* scriptState, const String& cacheNam
e) | 199 ScriptPromise CacheStorage::has(ScriptState* scriptState, const String& cacheNam
e) |
200 { | 200 { |
201 RefPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::create(scrip
tState); | 201 RefPtrWillBeRawPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::
create(scriptState); |
202 const ScriptPromise promise = resolver->promise(); | 202 const ScriptPromise promise = resolver->promise(); |
203 | 203 |
204 if (m_nameToCacheMap.contains(cacheName)) { | 204 if (m_nameToCacheMap.contains(cacheName)) { |
205 resolver->resolve(true); | 205 resolver->resolve(true); |
206 return promise; | 206 return promise; |
207 } | 207 } |
208 | 208 |
209 if (m_webCacheStorage) | 209 if (m_webCacheStorage) |
210 m_webCacheStorage->dispatchHas(new Callbacks(resolver), cacheName); | 210 m_webCacheStorage->dispatchHas(new Callbacks(resolver), cacheName); |
211 else | 211 else |
212 resolver->reject(createNoImplementationException()); | 212 resolver->reject(createNoImplementationException()); |
213 | 213 |
214 return promise; | 214 return promise; |
215 } | 215 } |
216 | 216 |
217 ScriptPromise CacheStorage::deleteFunction(ScriptState* scriptState, const Strin
g& cacheName) | 217 ScriptPromise CacheStorage::deleteFunction(ScriptState* scriptState, const Strin
g& cacheName) |
218 { | 218 { |
219 RefPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::create(scrip
tState); | 219 RefPtrWillBeRawPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::
create(scriptState); |
220 const ScriptPromise promise = resolver->promise(); | 220 const ScriptPromise promise = resolver->promise(); |
221 | 221 |
222 if (m_webCacheStorage) | 222 if (m_webCacheStorage) |
223 m_webCacheStorage->dispatchDelete(new DeleteCallbacks(cacheName, this, r
esolver), cacheName); | 223 m_webCacheStorage->dispatchDelete(new DeleteCallbacks(cacheName, this, r
esolver), cacheName); |
224 else | 224 else |
225 resolver->reject(createNoImplementationException()); | 225 resolver->reject(createNoImplementationException()); |
226 | 226 |
227 return promise; | 227 return promise; |
228 } | 228 } |
229 | 229 |
230 ScriptPromise CacheStorage::keys(ScriptState* scriptState) | 230 ScriptPromise CacheStorage::keys(ScriptState* scriptState) |
231 { | 231 { |
232 RefPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::create(scrip
tState); | 232 RefPtrWillBeRawPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::
create(scriptState); |
233 const ScriptPromise promise = resolver->promise(); | 233 const ScriptPromise promise = resolver->promise(); |
234 | 234 |
235 if (m_webCacheStorage) | 235 if (m_webCacheStorage) |
236 m_webCacheStorage->dispatchKeys(new KeysCallbacks(resolver)); | 236 m_webCacheStorage->dispatchKeys(new KeysCallbacks(resolver)); |
237 else | 237 else |
238 resolver->reject(createNoImplementationException()); | 238 resolver->reject(createNoImplementationException()); |
239 | 239 |
240 return promise; | 240 return promise; |
241 } | 241 } |
242 | 242 |
243 ScriptPromise CacheStorage::match(ScriptState* scriptState, const RequestInfo& r
equest, const CacheQueryOptions& options, ExceptionState& exceptionState) | 243 ScriptPromise CacheStorage::match(ScriptState* scriptState, const RequestInfo& r
equest, const CacheQueryOptions& options, ExceptionState& exceptionState) |
244 { | 244 { |
245 ASSERT(!request.isNull()); | 245 ASSERT(!request.isNull()); |
246 | 246 |
247 if (request.isRequest()) | 247 if (request.isRequest()) |
248 return matchImpl(scriptState, request.getAsRequest(), options); | 248 return matchImpl(scriptState, request.getAsRequest(), options); |
249 Request* newRequest = Request::create(scriptState->executionContext(), reque
st.getAsUSVString(), exceptionState); | 249 Request* newRequest = Request::create(scriptState->executionContext(), reque
st.getAsUSVString(), exceptionState); |
250 if (exceptionState.hadException()) | 250 if (exceptionState.hadException()) |
251 return ScriptPromise(); | 251 return ScriptPromise(); |
252 return matchImpl(scriptState, newRequest, options); | 252 return matchImpl(scriptState, newRequest, options); |
253 } | 253 } |
254 | 254 |
255 ScriptPromise CacheStorage::matchImpl(ScriptState* scriptState, const Request* r
equest, const CacheQueryOptions& options) | 255 ScriptPromise CacheStorage::matchImpl(ScriptState* scriptState, const Request* r
equest, const CacheQueryOptions& options) |
256 { | 256 { |
257 WebServiceWorkerRequest webRequest; | 257 WebServiceWorkerRequest webRequest; |
258 request->populateWebServiceWorkerRequest(webRequest); | 258 request->populateWebServiceWorkerRequest(webRequest); |
259 | 259 |
260 RefPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::create(scrip
tState); | 260 RefPtrWillBeRawPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::
create(scriptState); |
261 const ScriptPromise promise = resolver->promise(); | 261 const ScriptPromise promise = resolver->promise(); |
262 | 262 |
263 if (m_webCacheStorage) | 263 if (m_webCacheStorage) |
264 m_webCacheStorage->dispatchMatch(new MatchCallbacks(resolver), webReques
t, Cache::toWebQueryParams(options)); | 264 m_webCacheStorage->dispatchMatch(new MatchCallbacks(resolver), webReques
t, Cache::toWebQueryParams(options)); |
265 else | 265 else |
266 resolver->reject(createNoImplementationException()); | 266 resolver->reject(createNoImplementationException()); |
267 | 267 |
268 return promise; | 268 return promise; |
269 } | 269 } |
270 | 270 |
271 void CacheStorage::trace(Visitor* visitor) | 271 void CacheStorage::trace(Visitor* visitor) |
272 { | 272 { |
273 visitor->trace(m_nameToCacheMap); | 273 visitor->trace(m_nameToCacheMap); |
274 } | 274 } |
275 | 275 |
276 CacheStorage::CacheStorage(WebServiceWorkerCacheStorage* webCacheStorage) | 276 CacheStorage::CacheStorage(WebServiceWorkerCacheStorage* webCacheStorage) |
277 : m_webCacheStorage(webCacheStorage) | 277 : m_webCacheStorage(webCacheStorage) |
278 { | 278 { |
279 } | 279 } |
280 | 280 |
281 } // namespace blink | 281 } // namespace blink |
OLD | NEW |