Create skeleton for the Prefetching store and initial pipeline step.

components/offline_pages/content/suggested_articles_observer.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/content/suggested_articles_observer.h"
 
 #include <unordered_set>
 
 #include "base/memory/ptr_util.h"
 #include "components/ntp_snippets/category.h"
 #include "components/ntp_snippets/category_status.h"
 #include "components/offline_pages/content/prefetch_service_factory.h"
 #include "components/offline_pages/core/client_namespace_constants.h"
 #include "components/offline_pages/core/offline_page_feature.h"
 #include "components/offline_pages/core/prefetch/prefetch_dispatcher.h"
 #include "components/offline_pages/core/prefetch/prefetch_service.h"
+#include "components/offline_pages/core/prefetch/prefetch_types.h"
 
 using ntp_snippets::Category;
 using ntp_snippets::ContentSuggestion;
 
 namespace offline_pages {
 
 namespace {
 
 int kOfflinePageSuggestedArticlesObserverUserDataKey;
 
 const ntp_snippets::Category& ArticlesCategory() {
   static ntp_snippets::Category articles =
       Category::FromKnownCategory(ntp_snippets::KnownCategories::ARTICLES);
   return articles;
 }
 
-ClientId CreateClientIDFromSuggestionId(const ContentSuggestion::ID& id) {
-  return ClientId(kSuggestedArticlesNamespace, id.id_within_category());
-}
-
 // The default delegate that contains external dependencies for the Offline Page
 // Suggestions Observer.  This is unused in tests, which implement their own
 // Delegate.
 class DefaultDelegate : public SuggestedArticlesObserver::Delegate {
  public:
   explicit DefaultDelegate(ntp_snippets::ContentSuggestionsService* service);
   ~DefaultDelegate() override = default;
 
   const std::vector<ContentSuggestion>& GetSuggestions(
       const Category& category) override;
@@ skipping 47 matching lines @@
   if (category != ArticlesCategory() ||
       category_status_ != ntp_snippets::CategoryStatus::AVAILABLE) {
     return;
   }
 
   const std::vector<ContentSuggestion>& suggestions =
       delegate_->GetSuggestions(ArticlesCategory());
   if (suggestions.empty())
     return;
 
-  std::vector<PrefetchDispatcher::PrefetchURL> prefetch_urls;
+  std::vector<PrefetchURL> prefetch_urls;
   for (const ContentSuggestion& suggestion : suggestions) {
     prefetch_urls.push_back(
-        {CreateClientIDFromSuggestionId(suggestion.id()), suggestion.url()});
+        {suggestion.id().id_within_category(), suggestion.url()});
   }
 
   PrefetchService* service = delegate_->GetPrefetchService(browser_context_);
   if (service == nullptr) {
     DVLOG(1) << "PrefetchService unavailable to the "
                 "SuggestedArticlesObserver.";
     return;
   }
-  service->GetDispatcher()->AddCandidatePrefetchURLs(prefetch_urls);
+  service->GetDispatcher()->AddCandidatePrefetchURLs(
+      kSuggestedArticlesNamespace, prefetch_urls);
 }
 
 void SuggestedArticlesObserver::OnCategoryStatusChanged(
     Category category,
     ntp_snippets::CategoryStatus new_status) {
   if (category != ArticlesCategory() || category_status_ == new_status)
     return;
 
   category_status_ = new_status;
 
@@ skipping 14 matching lines @@
 
 void SuggestedArticlesObserver::OnSuggestionInvalidated(
     const ContentSuggestion::ID& suggestion_id) {
   PrefetchService* service = delegate_->GetPrefetchService(browser_context_);
   if (service == nullptr) {
     DVLOG(1) << "PrefetchService unavailable to the "
                 "SuggestedArticlesObserver.";
     return;
   }
   service->GetDispatcher()->RemovePrefetchURLsByClientId(
-      CreateClientIDFromSuggestionId(suggestion_id));
+      kSuggestedArticlesNamespace, suggestion_id.id_within_category());
 }
 
 void SuggestedArticlesObserver::OnFullRefreshRequired() {
   PrefetchService* service = delegate_->GetPrefetchService(browser_context_);
   if (service == nullptr) {
     DVLOG(1) << "PrefetchService unavailable to the "
                 "SuggestedArticlesObserver.";
     return;
   }
   service->GetDispatcher()->RemoveAllUnprocessedPrefetchURLs(
       kSuggestedArticlesNamespace);
   OnNewSuggestions(ArticlesCategory());
 }
 
 void SuggestedArticlesObserver::ContentSuggestionsServiceShutdown() {
   // No need to do anything here, we will just stop getting events.
 }
 
 }  // namespace offline_pages