[Offline Pages] Delete associated page along with bookmark.

components/offline_pages/offline_page_model_impl.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 "components/offline_pages/offline_page_model_impl.h"
 
 #include <algorithm>
 #include <limits>
 
 #include "base/bind.h"
 #include "base/files/file_util.h"
 #include "base/location.h"
 #include "base/logging.h"
 #include "base/metrics/histogram_macros.h"
 #include "base/rand_util.h"
 #include "base/sequenced_task_runner.h"
 #include "base/strings/string_number_conversions.h"
 #include "base/threading/thread_task_runner_handle.h"
 #include "base/time/time.h"
+#include "components/bookmarks/browser/bookmark_node.h"
 #include "components/offline_pages/archive_manager.h"
 #include "components/offline_pages/client_namespace_constants.h"
 #include "components/offline_pages/client_policy_controller.h"
+#include "components/offline_pages/offline_page_bookmark_observer.h"
 #include "components/offline_pages/offline_page_item.h"
 #include "components/offline_pages/offline_page_storage_manager.h"
 #include "url/gurl.h"
 
 using ArchiverResult = offline_pages::OfflinePageArchiver::ArchiverResult;
 using ClearStorageCallback =
     offline_pages::OfflinePageStorageManager::ClearStorageCallback;
 using ClearStorageResult =
     offline_pages::OfflinePageStorageManager::ClearStorageResult;
 
@@ skipping 215 matching lines @@
 
 OfflinePageModelImpl::OfflinePageModelImpl(
     std::unique_ptr<OfflinePageMetadataStore> store,
     const base::FilePath& archives_dir,
     const scoped_refptr<base::SequencedTaskRunner>& task_runner)
     : store_(std::move(store)),
       archives_dir_(archives_dir),
       is_loaded_(false),
       policy_controller_(new ClientPolicyController()),
       archive_manager_(new ArchiveManager(archives_dir, task_runner)),
+      bookmark_observer_(new OfflinePageBookmarkObserver(this)),
       weak_ptr_factory_(this) {
   archive_manager_->EnsureArchivesDirCreated(
       base::Bind(&OfflinePageModelImpl::OnEnsureArchivesDirCreatedDone,
                  weak_ptr_factory_.GetWeakPtr(), base::TimeTicks::Now()));
 }
 
 OfflinePageModelImpl::~OfflinePageModelImpl() {}
 
 void OfflinePageModelImpl::AddObserver(Observer* observer) {
   observers_.AddObserver(observer);
@@ skipping 793 matching lines @@
 }
 
 void OfflinePageModelImpl::PostClearStorageIfNeededTask() {
   base::ThreadTaskRunnerHandle::Get()->PostTask(
       FROM_HERE, base::Bind(&OfflinePageModelImpl::ClearStorageIfNeeded,
                             weak_ptr_factory_.GetWeakPtr(),
                             base::Bind(&OfflinePageModelImpl::OnStorageCleared,
                                        weak_ptr_factory_.GetWeakPtr())));
 }
 
+void OfflinePageModelImpl::ExpireRemovedBookmarkPage(
+    const bookmarks::BookmarkNode* node) {
+  ClientId client_id(kBookmarkNamespace, std::to_string(node->id()));
+  GetOfflineIdsForClientId(
+      client_id, base::Bind(&OfflinePageModelImpl::DoExpireRemovedBookmarkPages,
+                            weak_ptr_factory_.GetWeakPtr()));
+}
+
+void OfflinePageModelImpl::DoExpireRemovedBookmarkPages(
+    const std::vector<int64_t>& offline_ids) {
+  ExpirePages(offline_ids, base::Time::Now(),
+              base::Bind(&OfflinePageModelImpl::OnRemovedBookmarkPagesExpired,
+                         weak_ptr_factory_.GetWeakPtr()));
+}
+
+void OfflinePageModelImpl::OnRemovedBookmarkPagesExpired(bool result) {}
+
+OfflinePageBookmarkObserver* OfflinePageModelImpl::GetBookmarkObserver() {
+  return bookmark_observer_.get();
+}
+
 void OfflinePageModelImpl::RunWhenLoaded(const base::Closure& task) {
   if (!is_loaded_) {
     delayed_tasks_.push_back(task);
     return;
   }
 
   base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE, task);
 }
 
 }  // namespace offline_pages