[Offline pages] Adding expiration capability to OfflinePageModel

components/offline_pages/offline_page_model.cc

 // Copyright 2015 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/offline_page_model.h"
 
 #include <algorithm>
 #include <utility>
 
 #include "base/bind.h"
@@ skipping 489 matching lines @@
 }
 
 void OfflinePageModel::CheckForExternalFileDeletion() {
   DCHECK(is_loaded_);
 
   archive_manager_->GetAllArchives(
       base::Bind(&OfflinePageModel::ScanForMissingArchiveFiles,
                  weak_ptr_factory_.GetWeakPtr()));
 }
 
+void OfflinePageModel::ExpirePages(const std::vector<int64_t>& offline_ids,
+                                   const base::Time& expiration_time) {
+  for (int64_t offline_id : offline_ids) {
+    auto iter = offline_pages_.find(offline_id);
+    if (iter == offline_pages_.end())
+      continue;
+
+    OfflinePageItem offline_page = iter->second;
+    offline_page.expiration_time = expiration_time;
+
+    store_->AddOrUpdateOfflinePage(
+        offline_page, base::Bind(&OfflinePageModel::OnExpirePageDone,
+                                 weak_ptr_factory_.GetWeakPtr(), offline_id,
+                                 expiration_time));
+  }
+}
+
+void OfflinePageModel::OnExpirePageDone(int64_t offline_id,
+                                        const base::Time& expiration_time,
+                                        bool success) {
+  // TODO(romax): Report UMA about successful expiration.
+  if (success) {
+    auto iter = offline_pages_.find(offline_id);
+    if (iter != offline_pages_.end())
+      iter->second.expiration_time = expiration_time;
+  }
+}
+
 ClientPolicyController* OfflinePageModel::GetPolicyController() {
   return policy_controller_.get();
 }
 
 OfflinePageMetadataStore* OfflinePageModel::GetStoreForTesting() {
   return store_.get();
 }
 
 OfflinePageStorageManager* OfflinePageModel::GetStorageManager() {
   return storage_manager_.get();
@@ skipping 306 matching lines @@
 void OfflinePageModel::RunWhenLoaded(const base::Closure& task) {
   if (!is_loaded_) {
     delayed_tasks_.push_back(task);
     return;
   }
 
   base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE, task);
 }
 
 }  // namespace offline_pages