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 "modules/cachestorage/InspectorCacheStorageAgent.h" | 5 #include "modules/cachestorage/InspectorCacheStorageAgent.h" |
6 | 6 |
7 #include "platform/heap/Handle.h" | 7 #include "platform/heap/Handle.h" |
8 #include "platform/weborigin/KURL.h" | 8 #include "platform/weborigin/KURL.h" |
9 #include "platform/weborigin/SecurityOrigin.h" | 9 #include "platform/weborigin/SecurityOrigin.h" |
10 #include "public/platform/Platform.h" | 10 #include "public/platform/Platform.h" |
11 #include "public/platform/WebSecurityOrigin.h" | 11 #include "public/platform/WebSecurityOrigin.h" |
12 #include "public/platform/WebString.h" | 12 #include "public/platform/WebString.h" |
13 #include "public/platform/WebURL.h" | 13 #include "public/platform/WebURL.h" |
14 #include "public/platform/WebVector.h" | 14 #include "public/platform/WebVector.h" |
15 #include "public/platform/modules/serviceworker/WebServiceWorkerCache.h" | 15 #include "public/platform/modules/serviceworker/WebServiceWorkerCache.h" |
16 #include "public/platform/modules/serviceworker/WebServiceWorkerCacheError.h" | 16 #include "public/platform/modules/serviceworker/WebServiceWorkerCacheError.h" |
17 #include "public/platform/modules/serviceworker/WebServiceWorkerCacheStorage.h" | 17 #include "public/platform/modules/serviceworker/WebServiceWorkerCacheStorage.h" |
18 #include "public/platform/modules/serviceworker/WebServiceWorkerRequest.h" | 18 #include "public/platform/modules/serviceworker/WebServiceWorkerRequest.h" |
19 #include "public/platform/modules/serviceworker/WebServiceWorkerResponse.h" | 19 #include "public/platform/modules/serviceworker/WebServiceWorkerResponse.h" |
20 #include "wtf/Noncopyable.h" | 20 #include "wtf/Noncopyable.h" |
21 #include "wtf/PassRefPtr.h" | 21 #include "wtf/PassRefPtr.h" |
22 #include "wtf/PtrUtil.h" | 22 #include "wtf/PtrUtil.h" |
23 #include "wtf/RefCounted.h" | 23 #include "wtf/RefCounted.h" |
24 #include "wtf/RefPtr.h" | 24 #include "wtf/RefPtr.h" |
25 #include "wtf/Vector.h" | 25 #include "wtf/Vector.h" |
26 #include "wtf/text/StringBuilder.h" | 26 #include "wtf/text/StringBuilder.h" |
27 #include <algorithm> | 27 #include <algorithm> |
28 #include <memory> | 28 #include <memory> |
| 29 #include <utility> |
29 | 30 |
30 using blink::protocol::Array; | 31 using blink::protocol::Array; |
31 using blink::protocol::CacheStorage::Cache; | 32 using blink::protocol::CacheStorage::Cache; |
32 using blink::protocol::CacheStorage::DataEntry; | 33 using blink::protocol::CacheStorage::DataEntry; |
33 | 34 |
34 typedef blink::protocol::CacheStorage::Backend::DeleteCacheCallback | 35 typedef blink::protocol::CacheStorage::Backend::DeleteCacheCallback |
35 DeleteCacheCallback; | 36 DeleteCacheCallback; |
36 typedef blink::protocol::CacheStorage::Backend::DeleteEntryCallback | 37 typedef blink::protocol::CacheStorage::Backend::DeleteEntryCallback |
37 DeleteEntryCallback; | 38 DeleteEntryCallback; |
38 typedef blink::protocol::CacheStorage::Backend::RequestCacheNamesCallback | 39 typedef blink::protocol::CacheStorage::Backend::RequestCacheNamesCallback |
(...skipping 229 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
268 std::unique_ptr<Array<DataEntry>> array = Array<DataEntry>::create(); | 269 std::unique_ptr<Array<DataEntry>> array = Array<DataEntry>::create(); |
269 m_callback->sendSuccess(std::move(array), false); | 270 m_callback->sendSuccess(std::move(array), false); |
270 return; | 271 return; |
271 } | 272 } |
272 RefPtr<ResponsesAccumulator> accumulator = | 273 RefPtr<ResponsesAccumulator> accumulator = |
273 adoptRef(new ResponsesAccumulator(requests.size(), m_params, | 274 adoptRef(new ResponsesAccumulator(requests.size(), m_params, |
274 std::move(m_callback))); | 275 std::move(m_callback))); |
275 | 276 |
276 for (size_t i = 0; i < requests.size(); i++) { | 277 for (size_t i = 0; i < requests.size(); i++) { |
277 const auto& request = requests[i]; | 278 const auto& request = requests[i]; |
278 auto* cacheRequest = | 279 auto cacheRequest = WTF::makeUnique<GetCacheResponsesForRequestData>( |
279 new GetCacheResponsesForRequestData(m_params, request, accumulator); | 280 m_params, request, accumulator); |
280 m_cache->dispatchMatch(cacheRequest, request, | 281 m_cache->dispatchMatch(std::move(cacheRequest), request, |
281 WebServiceWorkerCache::QueryParams()); | 282 WebServiceWorkerCache::QueryParams()); |
282 } | 283 } |
283 } | 284 } |
284 | 285 |
285 void onError(WebServiceWorkerCacheError error) override { | 286 void onError(WebServiceWorkerCacheError error) override { |
286 m_callback->sendFailure(Response::Error( | 287 m_callback->sendFailure(Response::Error( |
287 String::format("Error requesting requests for cache %s: %s", | 288 String::format("Error requesting requests for cache %s: %s", |
288 m_params.cacheName.utf8().data(), | 289 m_params.cacheName.utf8().data(), |
289 serviceWorkerCacheErrorString(error).data()))); | 290 serviceWorkerCacheErrorString(error).data()))); |
290 } | 291 } |
291 | 292 |
292 private: | 293 private: |
293 DataRequestParams m_params; | 294 DataRequestParams m_params; |
294 std::unique_ptr<WebServiceWorkerCache> m_cache; | 295 std::unique_ptr<WebServiceWorkerCache> m_cache; |
295 std::unique_ptr<RequestEntriesCallback> m_callback; | 296 std::unique_ptr<RequestEntriesCallback> m_callback; |
296 }; | 297 }; |
297 | 298 |
298 class GetCacheForRequestData | 299 class GetCacheForRequestData |
299 : public WebServiceWorkerCacheStorage::CacheStorageWithCacheCallbacks { | 300 : public WebServiceWorkerCacheStorage::CacheStorageWithCacheCallbacks { |
300 WTF_MAKE_NONCOPYABLE(GetCacheForRequestData); | 301 WTF_MAKE_NONCOPYABLE(GetCacheForRequestData); |
301 | 302 |
302 public: | 303 public: |
303 GetCacheForRequestData(const DataRequestParams& params, | 304 GetCacheForRequestData(const DataRequestParams& params, |
304 std::unique_ptr<RequestEntriesCallback> callback) | 305 std::unique_ptr<RequestEntriesCallback> callback) |
305 : m_params(params), m_callback(std::move(callback)) {} | 306 : m_params(params), m_callback(std::move(callback)) {} |
306 ~GetCacheForRequestData() override {} | 307 ~GetCacheForRequestData() override {} |
307 | 308 |
308 void onSuccess(std::unique_ptr<WebServiceWorkerCache> cache) override { | 309 void onSuccess(std::unique_ptr<WebServiceWorkerCache> cache) override { |
309 auto* cacheRequest = new GetCacheKeysForRequestData( | 310 auto cacheRequest = WTF::makeUnique<GetCacheKeysForRequestData>( |
310 m_params, wrapUnique(cache.release()), std::move(m_callback)); | 311 m_params, std::move(cache), std::move(m_callback)); |
311 cacheRequest->cache()->dispatchKeys(cacheRequest, WebServiceWorkerRequest(), | 312 cacheRequest->cache()->dispatchKeys(std::move(cacheRequest), |
| 313 WebServiceWorkerRequest(), |
312 WebServiceWorkerCache::QueryParams()); | 314 WebServiceWorkerCache::QueryParams()); |
313 } | 315 } |
314 | 316 |
315 void onError(WebServiceWorkerCacheError error) override { | 317 void onError(WebServiceWorkerCacheError error) override { |
316 m_callback->sendFailure(Response::Error(String::format( | 318 m_callback->sendFailure(Response::Error(String::format( |
317 "Error requesting cache %s: %s", m_params.cacheName.utf8().data(), | 319 "Error requesting cache %s: %s", m_params.cacheName.utf8().data(), |
318 serviceWorkerCacheErrorString(error).data()))); | 320 serviceWorkerCacheErrorString(error).data()))); |
319 } | 321 } |
320 | 322 |
321 private: | 323 private: |
(...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
370 public: | 372 public: |
371 GetCacheForDeleteEntry(const String& requestSpec, | 373 GetCacheForDeleteEntry(const String& requestSpec, |
372 const String& cacheName, | 374 const String& cacheName, |
373 std::unique_ptr<DeleteEntryCallback> callback) | 375 std::unique_ptr<DeleteEntryCallback> callback) |
374 : m_requestSpec(requestSpec), | 376 : m_requestSpec(requestSpec), |
375 m_cacheName(cacheName), | 377 m_cacheName(cacheName), |
376 m_callback(std::move(callback)) {} | 378 m_callback(std::move(callback)) {} |
377 ~GetCacheForDeleteEntry() override {} | 379 ~GetCacheForDeleteEntry() override {} |
378 | 380 |
379 void onSuccess(std::unique_ptr<WebServiceWorkerCache> cache) override { | 381 void onSuccess(std::unique_ptr<WebServiceWorkerCache> cache) override { |
380 auto* deleteRequest = new DeleteCacheEntry(std::move(m_callback)); | 382 auto deleteRequest = |
| 383 WTF::makeUnique<DeleteCacheEntry>(std::move(m_callback)); |
381 BatchOperation deleteOperation; | 384 BatchOperation deleteOperation; |
382 deleteOperation.operationType = WebServiceWorkerCache::OperationTypeDelete; | 385 deleteOperation.operationType = WebServiceWorkerCache::OperationTypeDelete; |
383 deleteOperation.request.setURL(KURL(ParsedURLString, m_requestSpec)); | 386 deleteOperation.request.setURL(KURL(ParsedURLString, m_requestSpec)); |
384 Vector<BatchOperation> operations; | 387 Vector<BatchOperation> operations; |
385 operations.append(deleteOperation); | 388 operations.append(deleteOperation); |
386 cache.release()->dispatchBatch(deleteRequest, | 389 cache.release()->dispatchBatch(std::move(deleteRequest), |
387 WebVector<BatchOperation>(operations)); | 390 WebVector<BatchOperation>(operations)); |
388 } | 391 } |
389 | 392 |
390 void onError(WebServiceWorkerCacheError error) override { | 393 void onError(WebServiceWorkerCacheError error) override { |
391 m_callback->sendFailure(Response::Error(String::format( | 394 m_callback->sendFailure(Response::Error(String::format( |
392 "Error requesting cache %s: %s", m_cacheName.utf8().data(), | 395 "Error requesting cache %s: %s", m_cacheName.utf8().data(), |
393 serviceWorkerCacheErrorString(error).data()))); | 396 serviceWorkerCacheErrorString(error).data()))); |
394 } | 397 } |
395 | 398 |
396 private: | 399 private: |
(...skipping 26 matching lines...) Expand all Loading... |
423 return; | 426 return; |
424 } | 427 } |
425 | 428 |
426 std::unique_ptr<WebServiceWorkerCacheStorage> cache; | 429 std::unique_ptr<WebServiceWorkerCacheStorage> cache; |
427 Response response = assertCacheStorage(securityOrigin, cache); | 430 Response response = assertCacheStorage(securityOrigin, cache); |
428 if (!response.isSuccess()) { | 431 if (!response.isSuccess()) { |
429 callback->sendFailure(response); | 432 callback->sendFailure(response); |
430 return; | 433 return; |
431 } | 434 } |
432 cache->dispatchKeys( | 435 cache->dispatchKeys( |
433 new RequestCacheNames(securityOrigin, std::move(callback))); | 436 WTF::makeUnique<RequestCacheNames>(securityOrigin, std::move(callback))); |
434 } | 437 } |
435 | 438 |
436 void InspectorCacheStorageAgent::requestEntries( | 439 void InspectorCacheStorageAgent::requestEntries( |
437 const String& cacheId, | 440 const String& cacheId, |
438 int skipCount, | 441 int skipCount, |
439 int pageSize, | 442 int pageSize, |
440 std::unique_ptr<RequestEntriesCallback> callback) { | 443 std::unique_ptr<RequestEntriesCallback> callback) { |
441 String cacheName; | 444 String cacheName; |
442 std::unique_ptr<WebServiceWorkerCacheStorage> cache; | 445 std::unique_ptr<WebServiceWorkerCacheStorage> cache; |
443 Response response = | 446 Response response = |
444 assertCacheStorageAndNameForId(cacheId, &cacheName, cache); | 447 assertCacheStorageAndNameForId(cacheId, &cacheName, cache); |
445 if (!response.isSuccess()) { | 448 if (!response.isSuccess()) { |
446 callback->sendFailure(response); | 449 callback->sendFailure(response); |
447 return; | 450 return; |
448 } | 451 } |
449 DataRequestParams params; | 452 DataRequestParams params; |
450 params.cacheName = cacheName; | 453 params.cacheName = cacheName; |
451 params.pageSize = pageSize; | 454 params.pageSize = pageSize; |
452 params.skipCount = skipCount; | 455 params.skipCount = skipCount; |
453 cache->dispatchOpen(new GetCacheForRequestData(params, std::move(callback)), | 456 cache->dispatchOpen( |
454 WebString(cacheName)); | 457 WTF::makeUnique<GetCacheForRequestData>(params, std::move(callback)), |
| 458 WebString(cacheName)); |
455 } | 459 } |
456 | 460 |
457 void InspectorCacheStorageAgent::deleteCache( | 461 void InspectorCacheStorageAgent::deleteCache( |
458 const String& cacheId, | 462 const String& cacheId, |
459 std::unique_ptr<DeleteCacheCallback> callback) { | 463 std::unique_ptr<DeleteCacheCallback> callback) { |
460 String cacheName; | 464 String cacheName; |
461 std::unique_ptr<WebServiceWorkerCacheStorage> cache; | 465 std::unique_ptr<WebServiceWorkerCacheStorage> cache; |
462 Response response = | 466 Response response = |
463 assertCacheStorageAndNameForId(cacheId, &cacheName, cache); | 467 assertCacheStorageAndNameForId(cacheId, &cacheName, cache); |
464 if (!response.isSuccess()) { | 468 if (!response.isSuccess()) { |
465 callback->sendFailure(response); | 469 callback->sendFailure(response); |
466 return; | 470 return; |
467 } | 471 } |
468 cache->dispatchDelete(new DeleteCache(std::move(callback)), | 472 cache->dispatchDelete(WTF::makeUnique<DeleteCache>(std::move(callback)), |
469 WebString(cacheName)); | 473 WebString(cacheName)); |
470 } | 474 } |
471 | 475 |
472 void InspectorCacheStorageAgent::deleteEntry( | 476 void InspectorCacheStorageAgent::deleteEntry( |
473 const String& cacheId, | 477 const String& cacheId, |
474 const String& request, | 478 const String& request, |
475 std::unique_ptr<DeleteEntryCallback> callback) { | 479 std::unique_ptr<DeleteEntryCallback> callback) { |
476 String cacheName; | 480 String cacheName; |
477 std::unique_ptr<WebServiceWorkerCacheStorage> cache; | 481 std::unique_ptr<WebServiceWorkerCacheStorage> cache; |
478 Response response = | 482 Response response = |
479 assertCacheStorageAndNameForId(cacheId, &cacheName, cache); | 483 assertCacheStorageAndNameForId(cacheId, &cacheName, cache); |
480 if (!response.isSuccess()) { | 484 if (!response.isSuccess()) { |
481 callback->sendFailure(response); | 485 callback->sendFailure(response); |
482 return; | 486 return; |
483 } | 487 } |
484 cache->dispatchOpen( | 488 cache->dispatchOpen(WTF::makeUnique<GetCacheForDeleteEntry>( |
485 new GetCacheForDeleteEntry(request, cacheName, std::move(callback)), | 489 request, cacheName, std::move(callback)), |
486 WebString(cacheName)); | 490 WebString(cacheName)); |
487 } | 491 } |
488 | 492 |
489 } // namespace blink | 493 } // namespace blink |
OLD | NEW |