Only distill unread items

ios/chrome/browser/reading_list/reading_list_download_service.cc

 // Copyright 2016 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 "ios/chrome/browser/reading_list/reading_list_download_service.h"
 
 #include <utility>
 
 #include "base/bind.h"
 #include "base/files/file_path.h"
@@ skipping 66 matching lines @@
     const GURL& url) {
   DCHECK_EQ(reading_list_model_, model);
   DCHECK(model->GetEntryByURL(url));
   RemoveDownloadedEntry(url);
 }
 
 void ReadingListDownloadService::ReadingListDidAddEntry(
     const ReadingListModel* model,
     const GURL& url) {
   DCHECK_EQ(reading_list_model_, model);
-  ScheduleDownloadEntry(url);
+  ProcessNewEntry(url);
+}
+
+void ReadingListDownloadService::ReadingListDidMoveEntry(
+    const ReadingListModel* model,
+    const GURL& url) {
+  DCHECK_EQ(reading_list_model_, model);
+  ProcessNewEntry(url);
+}
+
+void ReadingListDownloadService::ProcessNewEntry(const GURL& url) {
+  const ReadingListEntry* entry = reading_list_model_->GetEntryByURL(url);
+  if (!entry || entry->IsRead()) {
+    url_downloader_->CancelDownloadOfflineURL(url);
+  } else {
+    ScheduleDownloadEntry(url);
+  }
 }
 
 void ReadingListDownloadService::DownloadAllEntries() {
   DCHECK(reading_list_model_->loaded());
   for (const auto& url : reading_list_model_->Keys()) {
     this->ScheduleDownloadEntry(url);
   }
 }
 
 void ReadingListDownloadService::ScheduleDownloadEntry(const GURL& url) {
   DCHECK(reading_list_model_->loaded());
   const ReadingListEntry* entry = reading_list_model_->GetEntryByURL(url);
   if (!entry || entry->DistilledState() == ReadingListEntry::ERROR ||
-      entry->DistilledState() == ReadingListEntry::PROCESSED)
+      entry->DistilledState() == ReadingListEntry::PROCESSED || entry->IsRead())
     return;
   GURL local_url(url);
   web::WebThread::PostDelayedTask(
       web::WebThread::UI, FROM_HERE,
       base::Bind(&ReadingListDownloadService::DownloadEntry,
                  weak_ptr_factory_.GetWeakPtr(), local_url),
       entry->TimeUntilNextTry());
 }
 
 void ReadingListDownloadService::DownloadEntry(const GURL& url) {
   DCHECK(reading_list_model_->loaded());
   const ReadingListEntry* entry = reading_list_model_->GetEntryByURL(url);
   if (!entry || entry->DistilledState() == ReadingListEntry::ERROR ||
-      entry->DistilledState() == ReadingListEntry::PROCESSED)
+      entry->DistilledState() == ReadingListEntry::PROCESSED || entry->IsRead())
     return;
 
   if (net::NetworkChangeNotifier::IsOffline()) {
     // There is no connection, save it for download only if we did not exceed
     // the maximaxum number of tries.
     if (entry->FailedDownloadCounter() < kNumberOfFailsBeforeWifiOnly)
       url_to_download_cellular_.push_back(entry->URL());
     if (entry->FailedDownloadCounter() < kNumberOfFailsBeforeStop)
       url_to_download_wifi_.push_back(entry->URL());
     return;
@@ skipping 85 matching lines @@
     for (auto& url : url_to_download_cellular_) {
       ScheduleDownloadEntry(url);
     }
   }
   if (type == net::NetworkChangeNotifier::CONNECTION_WIFI) {
     for (auto& url : url_to_download_wifi_) {
       ScheduleDownloadEntry(url);
     }
   }
 }