chrome/browser/android/history_report/data_observer.cc

   1 // Copyright 2015 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "chrome/browser/android/history_report/data_observer.h"
   6
   7 #include "base/time/time.h"
   8 #include "chrome/browser/android/history_report/delta_file_commons.h"
   9 #include "chrome/browser/android/history_report/delta_file_service.h"
  10 #include "chrome/browser/android/history_report/usage_report_util.h"
  11 #include "chrome/browser/android/history_report/usage_reports_buffer_service.h"
  12 #include "components/bookmarks/browser/bookmark_model.h"
  13 #include "components/history/core/browser/history_service.h"
  14
  15 using bookmarks::BookmarkModel;
  16 using bookmarks::BookmarkNode;
  17
  18 namespace history_report {
  19
  20 DataObserver::DataObserver(
  21     base::Callback<void(void)> data_changed_callback,
  22     base::Callback<void(void)> data_cleared_callback,
  23     base::Callback<void(void)> stop_reporting_callback,
  24     DeltaFileService* delta_file_service,
  25     UsageReportsBufferService* usage_reports_buffer_service,
  26     BookmarkModel* bookmark_model,
  27     history::HistoryService* history_service)
  28     : data_changed_callback_(data_changed_callback),
  29       data_cleared_callback_(data_cleared_callback),
  30       stop_reporting_callback_(stop_reporting_callback),
  31       delta_file_service_(delta_file_service),
  32       usage_reports_buffer_service_(usage_reports_buffer_service) {
  33   bookmark_model->AddObserver(this);
  34   history_service->AddObserver(this);
  35 }
  36
  37 DataObserver::~DataObserver() {}
  38
  39 void DataObserver::BookmarkModelLoaded(BookmarkModel* model,
  40                                        bool ids_reassigned) {}
  41
  42 void DataObserver::BookmarkModelBeingDeleted(BookmarkModel* model) {}
  43
  44 void DataObserver::BookmarkNodeMoved(BookmarkModel* model,
  45                                      const BookmarkNode* old_parent,
  46                                      int old_index,
  47                                      const BookmarkNode* new_parent,
  48                                      int new_index) {}
  49
  50 void DataObserver::BookmarkNodeAdded(BookmarkModel* model,
  51                                      const BookmarkNode* parent,
  52                                      int index) {
  53   delta_file_service_->PageAdded(parent->GetChild(index)->url());
  54   data_changed_callback_.Run();
  55 }
  56
  57 void DataObserver::BookmarkNodeRemoved(BookmarkModel* model,
  58                                        const BookmarkNode* parent,
  59                                        int old_index,
  60                                        const BookmarkNode* node,
  61                                        const std::set<GURL>& removed_urls) {
  62   DeleteBookmarks(removed_urls);
  63 }
  64
  65 void DataObserver::BookmarkAllUserNodesRemoved(
  66     BookmarkModel* model,
  67     const std::set<GURL>& removed_urls) {
  68   DeleteBookmarks(removed_urls);
  69 }
  70
  71 void DataObserver::BookmarkNodeChanged(BookmarkModel* model,
  72                                        const BookmarkNode* node) {
  73   delta_file_service_->PageAdded(node->url());
  74   data_changed_callback_.Run();
  75 }
  76
  77 void DataObserver::BookmarkNodeFaviconChanged(BookmarkModel* model,
  78                                               const BookmarkNode* node) {}
  79
  80 void DataObserver::BookmarkNodeChildrenReordered(BookmarkModel* model,
  81                                                  const BookmarkNode* node) {}
  82
  83 void DataObserver::DeleteBookmarks(const std::set<GURL>& removed_urls) {
  84   for (std::set<GURL>::const_iterator it = removed_urls.begin();
  85        it != removed_urls.end();
  86        ++it) {
  87     delta_file_service_->PageDeleted(*it);
  88   }
  89   if (!removed_urls.empty())
  90     data_changed_callback_.Run();
  91 }
  92
  93 void DataObserver::OnURLVisited(history::HistoryService* history_service,
  94                                 ui::PageTransition transition,
  95                                 const history::URLRow& row,
  96                                 const history::RedirectList& redirects,
  97                                 base::Time visit_time) {
  98   if (row.hidden())
  99     return;
 100
 101   delta_file_service_->PageAdded(row.url());
 102   // TODO(haaawk): check if this is really a data change not just a
 103   //               visit of already seen page.
 104   data_changed_callback_.Run();
 105   std::string id = DeltaFileEntryWithData::UrlToId(row.url().spec());
 106   usage_reports_buffer_service_->AddVisit(
 107       id,
 108       visit_time.ToJavaTime(),
 109       usage_report_util::IsTypedVisit(transition));
 110   // We stop any usage reporting to wait for gmscore to query the provider
 111   // for this url. We do not want to report usage for a URL which might
 112   // not be known to gmscore.
 113   stop_reporting_callback_.Run();
 114 }
 115
 116 void DataObserver::OnURLsModified(history::HistoryService* history_service,
 117                                   const history::URLRows& changed_urls) {
 118   for (const auto& row : changed_urls) {
 119     if (!row.hidden())
 120       delta_file_service_->PageAdded(row.url());
 121   }
 122
 123   data_changed_callback_.Run();
 124 }
 125
 126 void DataObserver::OnURLsDeleted(history::HistoryService* history_service,
 127                                  bool all_history,
 128                                  bool expired,
 129                                  const history::URLRows& deleted_rows,
 130                                  const std::set<GURL>& favicon_urls) {
 131   if (all_history) {
 132     delta_file_service_->Clear();
 133     data_cleared_callback_.Run();
 134   } else {
 135     for (const auto& row : deleted_rows) {
 136       if (!row.hidden())
 137         delta_file_service_->PageDeleted(row.url());
 138     }
 139
 140     data_changed_callback_.Run();
 141   }
 142 }
 143
 144 }  // namespace history_report