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 10 matching lines...) Expand all Loading... |
21 { | 21 { |
22 return DOMException::create(NotSupportedError, "No CacheStorage implementati
on provided."); | 22 return DOMException::create(NotSupportedError, "No CacheStorage implementati
on provided."); |
23 } | 23 } |
24 | 24 |
25 } | 25 } |
26 | 26 |
27 // FIXME: Consider using CallbackPromiseAdapter. | 27 // FIXME: Consider using CallbackPromiseAdapter. |
28 class CacheStorage::Callbacks final : public WebServiceWorkerCacheStorage::Cache
StorageCallbacks { | 28 class CacheStorage::Callbacks final : public WebServiceWorkerCacheStorage::Cache
StorageCallbacks { |
29 WTF_MAKE_NONCOPYABLE(Callbacks); | 29 WTF_MAKE_NONCOPYABLE(Callbacks); |
30 public: | 30 public: |
31 explicit Callbacks(PassRefPtr<ScriptPromiseResolver> resolver) | 31 explicit Callbacks(PassRefPtrWillBeRawPtr<ScriptPromiseResolver> resolver) |
32 : m_resolver(resolver) { } | 32 : m_resolver(resolver) { } |
33 virtual ~Callbacks() { } | 33 virtual ~Callbacks() { } |
34 | 34 |
35 virtual void onSuccess() override | 35 virtual void onSuccess() override |
36 { | 36 { |
37 m_resolver->resolve(true); | 37 m_resolver->resolve(true); |
38 m_resolver.clear(); | 38 m_resolver.clear(); |
39 } | 39 } |
40 | 40 |
41 virtual void onError(WebServiceWorkerCacheError* reason) override | 41 virtual void onError(WebServiceWorkerCacheError* reason) override |
42 { | 42 { |
43 if (*reason == WebServiceWorkerCacheErrorNotFound) | 43 if (*reason == WebServiceWorkerCacheErrorNotFound) |
44 m_resolver->resolve(false); | 44 m_resolver->resolve(false); |
45 else | 45 else |
46 m_resolver->reject(Cache::domExceptionForCacheError(*reason)); | 46 m_resolver->reject(Cache::domExceptionForCacheError(*reason)); |
47 m_resolver.clear(); | 47 m_resolver.clear(); |
48 } | 48 } |
49 | 49 |
50 private: | 50 private: |
51 RefPtr<ScriptPromiseResolver> m_resolver; | 51 RefPtrWillBeCrossThreadPersistent<ScriptPromiseResolver> m_resolver; |
52 }; | 52 }; |
53 | 53 |
54 // FIXME: Consider using CallbackPromiseAdapter. | 54 // FIXME: Consider using CallbackPromiseAdapter. |
55 class CacheStorage::WithCacheCallbacks final : public WebServiceWorkerCacheStora
ge::CacheStorageWithCacheCallbacks { | 55 class CacheStorage::WithCacheCallbacks final : public WebServiceWorkerCacheStora
ge::CacheStorageWithCacheCallbacks { |
56 WTF_MAKE_NONCOPYABLE(WithCacheCallbacks); | 56 WTF_MAKE_NONCOPYABLE(WithCacheCallbacks); |
57 public: | 57 public: |
58 WithCacheCallbacks(const String& cacheName, CacheStorage* cacheStorage, Pass
RefPtr<ScriptPromiseResolver> resolver) | 58 WithCacheCallbacks(const String& cacheName, CacheStorage* cacheStorage, Pass
RefPtrWillBeRawPtr<ScriptPromiseResolver> resolver) |
59 : m_cacheName(cacheName), m_cacheStorage(cacheStorage), m_resolver(resol
ver) { } | 59 : m_cacheName(cacheName), m_cacheStorage(cacheStorage), m_resolver(resol
ver) { } |
60 virtual ~WithCacheCallbacks() { } | 60 virtual ~WithCacheCallbacks() { } |
61 | 61 |
62 virtual void onSuccess(WebServiceWorkerCache* webCache) override | 62 virtual void onSuccess(WebServiceWorkerCache* webCache) override |
63 { | 63 { |
64 // FIXME: Remove this once content's WebServiceWorkerCache implementatio
n has landed. | 64 // FIXME: Remove this once content's WebServiceWorkerCache implementatio
n has landed. |
65 if (!webCache) { | 65 if (!webCache) { |
66 m_resolver->reject("not implemented"); | 66 m_resolver->reject("not implemented"); |
67 return; | 67 return; |
68 } | 68 } |
69 Cache* cache = Cache::create(webCache); | 69 Cache* cache = Cache::create(webCache); |
70 m_cacheStorage->m_nameToCacheMap.set(m_cacheName, cache); | 70 m_cacheStorage->m_nameToCacheMap.set(m_cacheName, cache); |
71 m_resolver->resolve(cache); | 71 m_resolver->resolve(cache); |
72 m_resolver.clear(); | 72 m_resolver.clear(); |
73 } | 73 } |
74 | 74 |
75 virtual void onError(WebServiceWorkerCacheError* reason) override | 75 virtual void onError(WebServiceWorkerCacheError* reason) override |
76 { | 76 { |
77 if (*reason == WebServiceWorkerCacheErrorNotFound) | 77 if (*reason == WebServiceWorkerCacheErrorNotFound) |
78 m_resolver->resolve(); | 78 m_resolver->resolve(); |
79 else | 79 else |
80 m_resolver->reject(Cache::domExceptionForCacheError(*reason)); | 80 m_resolver->reject(Cache::domExceptionForCacheError(*reason)); |
81 m_resolver.clear(); | 81 m_resolver.clear(); |
82 } | 82 } |
83 | 83 |
84 private: | 84 private: |
85 String m_cacheName; | 85 String m_cacheName; |
86 Persistent<CacheStorage> m_cacheStorage; | 86 Persistent<CacheStorage> m_cacheStorage; |
87 RefPtr<ScriptPromiseResolver> m_resolver; | 87 RefPtrWillBeCrossThreadPersistent<ScriptPromiseResolver> m_resolver; |
88 }; | 88 }; |
89 | 89 |
90 // FIXME: Consider using CallbackPromiseAdapter. | 90 // FIXME: Consider using CallbackPromiseAdapter. |
91 class CacheStorage::DeleteCallbacks final : public WebServiceWorkerCacheStorage:
:CacheStorageCallbacks { | 91 class CacheStorage::DeleteCallbacks final : public WebServiceWorkerCacheStorage:
:CacheStorageCallbacks { |
92 WTF_MAKE_NONCOPYABLE(DeleteCallbacks); | 92 WTF_MAKE_NONCOPYABLE(DeleteCallbacks); |
93 public: | 93 public: |
94 DeleteCallbacks(const String& cacheName, CacheStorage* cacheStorage, PassRef
Ptr<ScriptPromiseResolver> resolver) | 94 DeleteCallbacks(const String& cacheName, CacheStorage* cacheStorage, PassRef
PtrWillBeRawPtr<ScriptPromiseResolver> resolver) |
95 : m_cacheName(cacheName), m_cacheStorage(cacheStorage), m_resolver(resol
ver) { } | 95 : m_cacheName(cacheName), m_cacheStorage(cacheStorage), m_resolver(resol
ver) { } |
96 virtual ~DeleteCallbacks() { } | 96 virtual ~DeleteCallbacks() { } |
97 | 97 |
98 virtual void onSuccess() override | 98 virtual void onSuccess() override |
99 { | 99 { |
100 m_cacheStorage->m_nameToCacheMap.remove(m_cacheName); | 100 m_cacheStorage->m_nameToCacheMap.remove(m_cacheName); |
101 m_resolver->resolve(true); | 101 m_resolver->resolve(true); |
102 m_resolver.clear(); | 102 m_resolver.clear(); |
103 } | 103 } |
104 | 104 |
105 virtual void onError(WebServiceWorkerCacheError* reason) override | 105 virtual void onError(WebServiceWorkerCacheError* reason) override |
106 { | 106 { |
107 if (*reason == WebServiceWorkerCacheErrorNotFound) | 107 if (*reason == WebServiceWorkerCacheErrorNotFound) |
108 m_resolver->resolve(false); | 108 m_resolver->resolve(false); |
109 else | 109 else |
110 m_resolver->reject(Cache::domExceptionForCacheError(*reason)); | 110 m_resolver->reject(Cache::domExceptionForCacheError(*reason)); |
111 m_resolver.clear(); | 111 m_resolver.clear(); |
112 } | 112 } |
113 | 113 |
114 private: | 114 private: |
115 String m_cacheName; | 115 String m_cacheName; |
116 Persistent<CacheStorage> m_cacheStorage; | 116 Persistent<CacheStorage> m_cacheStorage; |
117 RefPtr<ScriptPromiseResolver> m_resolver; | 117 RefPtrWillBeCrossThreadPersistent<ScriptPromiseResolver> m_resolver; |
118 }; | 118 }; |
119 | 119 |
120 // FIXME: Consider using CallbackPromiseAdapter. | 120 // FIXME: Consider using CallbackPromiseAdapter. |
121 class CacheStorage::KeysCallbacks final : public WebServiceWorkerCacheStorage::C
acheStorageKeysCallbacks { | 121 class CacheStorage::KeysCallbacks final : public WebServiceWorkerCacheStorage::C
acheStorageKeysCallbacks { |
122 WTF_MAKE_NONCOPYABLE(KeysCallbacks); | 122 WTF_MAKE_NONCOPYABLE(KeysCallbacks); |
123 public: | 123 public: |
124 explicit KeysCallbacks(PassRefPtr<ScriptPromiseResolver> resolver) | 124 explicit KeysCallbacks(PassRefPtrWillBeRawPtr<ScriptPromiseResolver> resolve
r) |
125 : m_resolver(resolver) { } | 125 : m_resolver(resolver) { } |
126 virtual ~KeysCallbacks() { } | 126 virtual ~KeysCallbacks() { } |
127 | 127 |
128 virtual void onSuccess(WebVector<WebString>* keys) override | 128 virtual void onSuccess(WebVector<WebString>* keys) override |
129 { | 129 { |
130 Vector<String> wtfKeys; | 130 Vector<String> wtfKeys; |
131 for (size_t i = 0; i < keys->size(); ++i) | 131 for (size_t i = 0; i < keys->size(); ++i) |
132 wtfKeys.append((*keys)[i]); | 132 wtfKeys.append((*keys)[i]); |
133 m_resolver->resolve(wtfKeys); | 133 m_resolver->resolve(wtfKeys); |
134 m_resolver.clear(); | 134 m_resolver.clear(); |
135 } | 135 } |
136 | 136 |
137 virtual void onError(WebServiceWorkerCacheError* reason) override | 137 virtual void onError(WebServiceWorkerCacheError* reason) override |
138 { | 138 { |
139 m_resolver->reject(Cache::domExceptionForCacheError(*reason)); | 139 m_resolver->reject(Cache::domExceptionForCacheError(*reason)); |
140 m_resolver.clear(); | 140 m_resolver.clear(); |
141 } | 141 } |
142 | 142 |
143 private: | 143 private: |
144 RefPtr<ScriptPromiseResolver> m_resolver; | 144 RefPtrWillBeCrossThreadPersistent<ScriptPromiseResolver> m_resolver; |
145 }; | 145 }; |
146 | 146 |
147 CacheStorage* CacheStorage::create(WebServiceWorkerCacheStorage* webCacheStorage
) | 147 CacheStorage* CacheStorage::create(WebServiceWorkerCacheStorage* webCacheStorage
) |
148 { | 148 { |
149 return new CacheStorage(webCacheStorage); | 149 return new CacheStorage(webCacheStorage); |
150 } | 150 } |
151 | 151 |
152 ScriptPromise CacheStorage::open(ScriptState* scriptState, const String& cacheNa
me) | 152 ScriptPromise CacheStorage::open(ScriptState* scriptState, const String& cacheNa
me) |
153 { | 153 { |
154 RefPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::create(scrip
tState); | 154 RefPtrWillBeRawPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::
create(scriptState); |
155 const ScriptPromise promise = resolver->promise(); | 155 const ScriptPromise promise = resolver->promise(); |
156 | 156 |
157 if (m_nameToCacheMap.contains(cacheName)) { | 157 if (m_nameToCacheMap.contains(cacheName)) { |
158 Cache* cache = m_nameToCacheMap.find(cacheName)->value; | 158 Cache* cache = m_nameToCacheMap.find(cacheName)->value; |
159 resolver->resolve(cache); | 159 resolver->resolve(cache); |
160 return promise; | 160 return promise; |
161 } | 161 } |
162 | 162 |
163 if (m_webCacheStorage) | 163 if (m_webCacheStorage) |
164 m_webCacheStorage->dispatchOpen(new WithCacheCallbacks(cacheName, this,
resolver), cacheName); | 164 m_webCacheStorage->dispatchOpen(new WithCacheCallbacks(cacheName, this,
resolver), cacheName); |
165 else | 165 else |
166 resolver->reject(createNoImplementationException()); | 166 resolver->reject(createNoImplementationException()); |
167 | 167 |
168 return promise; | 168 return promise; |
169 } | 169 } |
170 | 170 |
171 ScriptPromise CacheStorage::has(ScriptState* scriptState, const String& cacheNam
e) | 171 ScriptPromise CacheStorage::has(ScriptState* scriptState, const String& cacheNam
e) |
172 { | 172 { |
173 RefPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::create(scrip
tState); | 173 RefPtrWillBeRawPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::
create(scriptState); |
174 const ScriptPromise promise = resolver->promise(); | 174 const ScriptPromise promise = resolver->promise(); |
175 | 175 |
176 if (m_nameToCacheMap.contains(cacheName)) { | 176 if (m_nameToCacheMap.contains(cacheName)) { |
177 resolver->resolve(true); | 177 resolver->resolve(true); |
178 return promise; | 178 return promise; |
179 } | 179 } |
180 | 180 |
181 if (m_webCacheStorage) | 181 if (m_webCacheStorage) |
182 m_webCacheStorage->dispatchHas(new Callbacks(resolver), cacheName); | 182 m_webCacheStorage->dispatchHas(new Callbacks(resolver), cacheName); |
183 else | 183 else |
184 resolver->reject(createNoImplementationException()); | 184 resolver->reject(createNoImplementationException()); |
185 | 185 |
186 return promise; | 186 return promise; |
187 } | 187 } |
188 | 188 |
189 ScriptPromise CacheStorage::deleteFunction(ScriptState* scriptState, const Strin
g& cacheName) | 189 ScriptPromise CacheStorage::deleteFunction(ScriptState* scriptState, const Strin
g& cacheName) |
190 { | 190 { |
191 RefPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::create(scrip
tState); | 191 RefPtrWillBeRawPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::
create(scriptState); |
192 const ScriptPromise promise = resolver->promise(); | 192 const ScriptPromise promise = resolver->promise(); |
193 | 193 |
194 if (m_webCacheStorage) | 194 if (m_webCacheStorage) |
195 m_webCacheStorage->dispatchDelete(new DeleteCallbacks(cacheName, this, r
esolver), cacheName); | 195 m_webCacheStorage->dispatchDelete(new DeleteCallbacks(cacheName, this, r
esolver), cacheName); |
196 else | 196 else |
197 resolver->reject(createNoImplementationException()); | 197 resolver->reject(createNoImplementationException()); |
198 | 198 |
199 return promise; | 199 return promise; |
200 } | 200 } |
201 | 201 |
202 ScriptPromise CacheStorage::keys(ScriptState* scriptState) | 202 ScriptPromise CacheStorage::keys(ScriptState* scriptState) |
203 { | 203 { |
204 RefPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::create(scrip
tState); | 204 RefPtrWillBeRawPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::
create(scriptState); |
205 const ScriptPromise promise = resolver->promise(); | 205 const ScriptPromise promise = resolver->promise(); |
206 | 206 |
207 if (m_webCacheStorage) | 207 if (m_webCacheStorage) |
208 m_webCacheStorage->dispatchKeys(new KeysCallbacks(resolver)); | 208 m_webCacheStorage->dispatchKeys(new KeysCallbacks(resolver)); |
209 else | 209 else |
210 resolver->reject(createNoImplementationException()); | 210 resolver->reject(createNoImplementationException()); |
211 | 211 |
212 return promise; | 212 return promise; |
213 } | 213 } |
214 | 214 |
215 void CacheStorage::trace(Visitor* visitor) | 215 void CacheStorage::trace(Visitor* visitor) |
216 { | 216 { |
217 visitor->trace(m_nameToCacheMap); | 217 visitor->trace(m_nameToCacheMap); |
218 } | 218 } |
219 | 219 |
220 CacheStorage::CacheStorage(WebServiceWorkerCacheStorage* webCacheStorage) | 220 CacheStorage::CacheStorage(WebServiceWorkerCacheStorage* webCacheStorage) |
221 : m_webCacheStorage(webCacheStorage) | 221 : m_webCacheStorage(webCacheStorage) |
222 { | 222 { |
223 } | 223 } |
224 | 224 |
225 } // namespace blink | 225 } // namespace blink |
OLD | NEW |