Prefetching: Introduce store commands abstractions to be used by tasks.

components/offline_pages/core/prefetch/prefetch_dispatcher_impl.cc

 // Copyright 2017 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 "components/offline_pages/core/prefetch/prefetch_dispatcher_impl.h"
 
 #include <utility>
 
 #include "base/bind.h"
 #include "base/memory/ptr_util.h"
 #include "base/task_runner.h"
 #include "base/threading/thread_task_runner_handle.h"
 #include "components/offline_pages/core/offline_page_feature.h"
 #include "components/offline_pages/core/prefetch/add_unique_urls_task.h"
 #include "components/offline_pages/core/prefetch/prefetch_service.h"
+#include "components/offline_pages/core/prefetch/store/prefetch_store_command_factory.h"
 #include "url/gurl.h"
 
 namespace offline_pages {
 
 namespace {
 void DeleteBackgroundTaskHelper(
     std::unique_ptr<PrefetchDispatcher::ScopedBackgroundTask> task) {
   task.reset();
 }
 }  // namespace
 
 PrefetchDispatcherImpl::PrefetchDispatcherImpl() = default;
 
 PrefetchDispatcherImpl::~PrefetchDispatcherImpl() = default;
 
 void PrefetchDispatcherImpl::SetService(PrefetchService* service) {
   CHECK(service);
   service_ = service;
 }
 
 void PrefetchDispatcherImpl::AddCandidatePrefetchURLs(
+    const std::string& name_space,
     const std::vector<PrefetchURL>& prefetch_urls) {
   if (!IsPrefetchingOfflinePagesEnabled())
     return;
 
+  PrefetchStoreCommandFactory* command_factory =
+      service_->GetPrefetchStoreCommandFactory();
   std::unique_ptr<Task> add_task = base::MakeUnique<AddUniqueUrlsTask>(
-      service_->GetPrefetchStore(), prefetch_urls);
+      command_factory->createAddUrls(), command_factory->createCleanupZombies(),
+      name_space, prefetch_urls);
   task_queue_.AddTask(std::move(add_task));
 }
 
 void PrefetchDispatcherImpl::RemoveAllUnprocessedPrefetchURLs(
     const std::string& name_space) {
   if (!IsPrefetchingOfflinePagesEnabled())
     return;
 
   NOTIMPLEMENTED();
 }
@@ skipping 38 matching lines @@
 
 void PrefetchDispatcherImpl::GCMOperationCompletedMessageReceived(
     const std::string& operation_name) {
   if (!IsPrefetchingOfflinePagesEnabled())
     return;
 
   NOTIMPLEMENTED();
 }
 
 }  // namespace offline_pages