[CacheStorage] Entry deletion and cache refresh in Inspector.

Source/modules/cachestorage/InspectorCacheStorageAgent.cpp

 // 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 "modules/cachestorage/InspectorCacheStorageAgent.h"
 
 #include "core/InspectorBackendDispatcher.h"
 #include "core/InspectorTypeBuilder.h"
 #include "platform/JSONValues.h"
 #include "platform/heap/Handle.h"
 #include "platform/weborigin/DatabaseIdentifier.h"
+#include "platform/weborigin/KURL.h"
 #include "platform/weborigin/SecurityOrigin.h"
 #include "public/platform/Platform.h"
 #include "public/platform/WebServiceWorkerCache.h"
 #include "public/platform/WebServiceWorkerCacheError.h"
 #include "public/platform/WebServiceWorkerCacheStorage.h"
 #include "public/platform/WebServiceWorkerRequest.h"
 #include "public/platform/WebServiceWorkerResponse.h"
 #include "public/platform/WebString.h"
 #include "public/platform/WebURL.h"
 #include "public/platform/WebVector.h"
 #include "wtf/Noncopyable.h"
 #include "wtf/OwnPtr.h"
 #include "wtf/PassRefPtr.h"
 #include "wtf/RefCounted.h"
 #include "wtf/RefPtr.h"
 #include "wtf/Vector.h"
 #include "wtf/text/StringBuilder.h"
 
 #include <algorithm>
 
 using blink::TypeBuilder::Array;
 using blink::TypeBuilder::CacheStorage::Cache;
 using blink::TypeBuilder::CacheStorage::DataEntry;
 
 typedef blink::InspectorBackendDispatcher::CacheStorageCommandHandler::DeleteCacheCallback DeleteCacheCallback;
+typedef blink::InspectorBackendDispatcher::CacheStorageCommandHandler::DeleteEntryCallback DeleteEntryCallback;
 typedef blink::InspectorBackendDispatcher::CacheStorageCommandHandler::RequestCacheNamesCallback RequestCacheNamesCallback;
 typedef blink::InspectorBackendDispatcher::CacheStorageCommandHandler::RequestEntriesCallback RequestEntriesCallback;
 typedef blink::InspectorBackendDispatcher::CallbackBase RequestCallback;
+typedef blink::WebServiceWorkerCache::BatchOperation BatchOperation;
 
 namespace blink {
 
 namespace {
 
 String buildCacheId(const String& securityOrigin, const String& cacheName)
 {
     String id(securityOrigin);
     id.append("|");
     id.append(cacheName);
@@ skipping 133 matching lines @@
         if (m_params.skipCount > 0)
             m_responses.remove(0, m_params.skipCount);
         bool hasMore = false;
         if (static_cast<size_t>(m_params.pageSize) < m_responses.size()) {
             m_responses.remove(m_params.pageSize, m_responses.size() - m_params.pageSize);
             hasMore = true;
         }
         RefPtr<Array<DataEntry>> array = Array<DataEntry>::create();
         for (const auto& requestResponse : m_responses) {
             RefPtr<DataEntry> entry = DataEntry::create()
-                .setRequest(JSONString::create(requestResponse.request)->toJSONString())
-                .setResponse(JSONString::create(requestResponse.response)->toJSONString());
+                .setRequest(requestResponse.request)
+                .setResponse(requestResponse.response);
             array->addItem(entry);
         }
         m_callback->sendSuccess(array, hasMore);
     }
 
 private:
     DataRequestParams m_params;
     int m_numResponsesLeft;
     Vector<RequestResponse> m_responses;
     RefPtrWillBePersistent<RequestEntriesCallback> m_callback;
@@ skipping 115 matching lines @@
 
     void onError(WebServiceWorkerCacheError* error)
     {
         m_callback->sendFailure(String::format("Error requesting cache names: %s", serviceWorkerCacheErrorString(error).data()));
     }
 
 private:
     RefPtrWillBePersistent<DeleteCacheCallback> m_callback;
 };
 
+class DeleteCacheEntry
+    : public WebServiceWorkerCache::CacheWithResponsesCallbacks {
+    WTF_MAKE_NONCOPYABLE(DeleteCacheEntry);
+public:
+
+    DeleteCacheEntry(PassRefPtrWillBeRawPtr<DeleteEntryCallback> callback)
+        : m_callback(callback)
+    {
+    }
+    virtual ~DeleteCacheEntry() { }
+
+    void onSuccess(WebVector<WebServiceWorkerResponse>* requests)
+    {
+        m_callback->sendSuccess();
+    }
+
+    void onError(WebServiceWorkerCacheError* error)
+    {
+        m_callback->sendFailure(String::format("Error requesting cache names: %s", serviceWorkerCacheErrorString(error).data()));
+    }
+
+private:
+    RefPtrWillBePersistent<DeleteEntryCallback> m_callback;
+};
+
+class GetCacheForDeleteEntry
+    : public WebServiceWorkerCacheStorage::CacheStorageWithCacheCallbacks {
+    WTF_MAKE_NONCOPYABLE(GetCacheForDeleteEntry);
+
+public:
+    GetCacheForDeleteEntry(const String& requestSpec, const String& cacheName, PassRefPtrWillBeRawPtr<DeleteEntryCallback> callback)
+        : m_requestSpec(requestSpec)
+        , m_cacheName(cacheName)
+        , m_callback(callback)
+    {
+    }
+    virtual ~GetCacheForDeleteEntry() { }
+
+    void onSuccess(WebServiceWorkerCache* cache)
+    {
+        auto* deleteRequest = new DeleteCacheEntry( m_callback);
+        BatchOperation deleteOperation;
+        deleteOperation.operationType = WebServiceWorkerCache::OperationTypeDelete;
+        deleteOperation.request.setURL(KURL(ParsedURLString, m_requestSpec));
+        Vector<BatchOperation> operations;
+        operations.append(deleteOperation);
+        cache->dispatchBatch(deleteRequest, WebVector<BatchOperation>(operations));
+    }
+
+    void onError(WebServiceWorkerCacheError* error)
+    {
+        m_callback->sendFailure(String::format("Error requesting cache %s: %s", m_cacheName.utf8().data(), serviceWorkerCacheErrorString(error).data()));
+    }
+
+private:
+    String m_requestSpec;
+    String m_cacheName;
+    RefPtrWillBePersistent<DeleteEntryCallback> m_callback;
+};
+
 } // namespace
 
 InspectorCacheStorageAgent::InspectorCacheStorageAgent()
     : InspectorBaseAgent<InspectorCacheStorageAgent, InspectorFrontend::CacheStorage>("CacheStorage")
 {
 }
 
 InspectorCacheStorageAgent::~InspectorCacheStorageAgent() { }
 
 DEFINE_TRACE(InspectorCacheStorageAgent)
@@ skipping 30 matching lines @@
 {
     String cacheName;
     OwnPtr<WebServiceWorkerCacheStorage> cache = assertCacheStorageAndNameForId(errorString, cacheId, &cacheName);
     if (!cache) {
         callback->sendFailure(*errorString);
         return;
     }
     cache->dispatchDelete(new DeleteCache(callback), WebString(cacheName));
 }
 
+void InspectorCacheStorageAgent::deleteEntry(ErrorString* errorString, const String& cacheId, const String& request, PassRefPtrWillBeRawPtr<DeleteEntryCallback> callback)
+{
+    String cacheName;
+    OwnPtr<WebServiceWorkerCacheStorage> cache = assertCacheStorageAndNameForId(errorString, cacheId, &cacheName);
+    if (!cache) {
+        callback->sendFailure(*errorString);
+        return;
+    }
+    cache->dispatchOpen(new GetCacheForDeleteEntry(request, cacheName, callback), WebString(cacheName));
+}
+
+
 } // namespace blink