Introducing the activityLogPrivate.deleteActivities() API call.

chrome/browser/extensions/activity_log/fullstream_ui_policy.cc

 // Copyright 2013 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 "chrome/browser/extensions/activity_log/fullstream_ui_policy.h"
 
 #include "base/callback.h"
 #include "base/command_line.h"
 #include "base/files/file_path.h"
 #include "base/json/json_reader.h"
@@ skipping 202 matching lines @@
         action->set_other(make_scoped_ptr(
             static_cast<base::DictionaryValue*>(parsed_value.release())));
       }
     }
     actions->push_back(action);
   }
 
   return actions.Pass();
 }
 
+void FullStreamUIPolicy::DoRemoveActions(const std::vector<int64>& action_ids) {
+  if (action_ids.empty())
+    return;
+
+  sql::Connection* db = GetDatabaseConnection();
+  if (!db) {
+    LOG(ERROR) << "Unable to connect to database";
+    return;
+  }
+
+  // Flush data first so the activity removal affects queued-up data as well.
+  activity_database()->AdviseFlush(ActivityDatabase::kFlushImmediately);
+
+  int batch_size = 50;
+  int iter = action_ids.size() / batch_size;
+  for (int i = 0; i < iter; i++) {
+    int start = i * batch_size;
+    int end = start + batch_size;
+    std::string rowid_set;
+    for (int j = start; j < end; j++) {
+      rowid_set += "?,";
+    }
+    // Delete the last comma from the set.
+    rowid_set = rowid_set.substr(0, rowid_set.length() - 1);
+    std::string query_str = base::StringPrintf(
+        "DELETE FROM %s WHERE rowid in (%s)", kTableName, rowid_set.c_str());
+    sql::Statement query(db->GetUniqueStatement(query_str.c_str()));
+    for (int j = start; j < end; j++) {
+      query.BindInt64(j - start, action_ids[j]);
+    }
+    if (!query.Run()) {
+      LOG(ERROR) << "Removing activities from database failed: "
+                 << query.GetSQLStatement();
+      return;
+    }
+  }
+  int start = iter * batch_size;
+  int end = action_ids.size();
+  std::string rowid_set;
+  for (int i = start; i < end; i++) {
+    rowid_set += "?,";
+  }
+  // Delete the last comma from the set.
+  rowid_set = rowid_set.substr(0, rowid_set.length() - 1);
+  std::string query_str = base::StringPrintf(
+      "DELETE FROM %s WHERE rowid in (%s)", kTableName, rowid_set.c_str());
+  sql::Statement query(db->GetUniqueStatement(query_str.c_str()));
+  for (int i = start; i < end; i++) {
+    query.BindInt64(i - start, action_ids[i]);
+  }
+  if (!query.Run()) {
+    LOG(ERROR) << "Removing activities from database failed: "
+               << query.GetSQLStatement();
+    return;
+  }
+}
+
 void FullStreamUIPolicy::DoRemoveURLs(const std::vector<GURL>& restrict_urls) {
   sql::Connection* db = GetDatabaseConnection();
   if (!db) {
     LOG(ERROR) << "Unable to connect to database";
     return;
   }
 
   // Make sure any queued in memory are sent to the database before cleaning.
   activity_database()->AdviseFlush(ActivityDatabase::kFlushImmediately);
 
@@ skipping 134 matching lines @@
                  base::Unretained(this),
                  extension_id,
                  type,
                  api_name,
                  page_url,
                  arg_url,
                  days_ago),
       callback);
 }
 
+void FullStreamUIPolicy::RemoveActions(const std::vector<int64>& action_ids) {
+  ScheduleAndForget(this, &FullStreamUIPolicy::DoRemoveActions, action_ids);
+}
+
 void FullStreamUIPolicy::RemoveURLs(const std::vector<GURL>& restrict_urls) {
   ScheduleAndForget(this, &FullStreamUIPolicy::DoRemoveURLs, restrict_urls);
 }
 
 void FullStreamUIPolicy::RemoveExtensionData(const std::string& extension_id) {
   ScheduleAndForget(
       this, &FullStreamUIPolicy::DoRemoveExtensionData, extension_id);
 }
 
 void FullStreamUIPolicy::DeleteDatabase() {
@@ skipping 15 matching lines @@
 }
 
 void FullStreamUIPolicy::QueueAction(scoped_refptr<Action> action) {
   if (activity_database()->is_db_valid()) {
     queued_actions_.push_back(action);
     activity_database()->AdviseFlush(queued_actions_.size());
   }
 }
 
 }  // namespace extensions