OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 // A policy for storing activity log data to a database that performs | 5 // A policy for storing activity log data to a database that performs |
6 // aggregation to reduce the size of the database. The database layout is | 6 // aggregation to reduce the size of the database. The database layout is |
7 // nearly the same as FullStreamUIPolicy, which stores a complete log, with a | 7 // nearly the same as FullStreamUIPolicy, which stores a complete log, with a |
8 // few changes: | 8 // few changes: |
9 // - a "count" column is added to track how many log records were merged | 9 // - a "count" column is added to track how many log records were merged |
10 // together into this row | 10 // together into this row |
(...skipping 23 matching lines...) Expand all Loading... |
34 | 34 |
35 #include <map> | 35 #include <map> |
36 #include <string> | 36 #include <string> |
37 #include <vector> | 37 #include <vector> |
38 | 38 |
39 #include "base/callback.h" | 39 #include "base/callback.h" |
40 #include "base/files/file_path.h" | 40 #include "base/files/file_path.h" |
41 #include "base/json/json_reader.h" | 41 #include "base/json/json_reader.h" |
42 #include "base/json/json_string_value_serializer.h" | 42 #include "base/json/json_string_value_serializer.h" |
43 #include "base/macros.h" | 43 #include "base/macros.h" |
| 44 #include "base/memory/ptr_util.h" |
44 #include "base/strings/string_util.h" | 45 #include "base/strings/string_util.h" |
45 #include "base/strings/stringprintf.h" | 46 #include "base/strings/stringprintf.h" |
46 #include "chrome/common/chrome_constants.h" | 47 #include "chrome/common/chrome_constants.h" |
47 #include "sql/statement.h" | 48 #include "sql/statement.h" |
48 #include "sql/transaction.h" | 49 #include "sql/transaction.h" |
49 | 50 |
50 using content::BrowserThread; | 51 using content::BrowserThread; |
51 | 52 |
52 namespace { | 53 namespace { |
53 | 54 |
(...skipping 360 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
414 return false; | 415 return false; |
415 last_database_cleaning_time_ = Now(); | 416 last_database_cleaning_time_ = Now(); |
416 } | 417 } |
417 | 418 |
418 if (!transaction.Commit()) | 419 if (!transaction.Commit()) |
419 return false; | 420 return false; |
420 | 421 |
421 return true; | 422 return true; |
422 } | 423 } |
423 | 424 |
424 scoped_ptr<Action::ActionVector> CountingPolicy::DoReadFilteredData( | 425 std::unique_ptr<Action::ActionVector> CountingPolicy::DoReadFilteredData( |
425 const std::string& extension_id, | 426 const std::string& extension_id, |
426 const Action::ActionType type, | 427 const Action::ActionType type, |
427 const std::string& api_name, | 428 const std::string& api_name, |
428 const std::string& page_url, | 429 const std::string& page_url, |
429 const std::string& arg_url, | 430 const std::string& arg_url, |
430 const int days_ago) { | 431 const int days_ago) { |
431 // Ensure data is flushed to the database first so that we query over all | 432 // Ensure data is flushed to the database first so that we query over all |
432 // data. | 433 // data. |
433 activity_database()->AdviseFlush(ActivityDatabase::kFlushImmediately); | 434 activity_database()->AdviseFlush(ActivityDatabase::kFlushImmediately); |
434 scoped_ptr<Action::ActionVector> actions(new Action::ActionVector()); | 435 std::unique_ptr<Action::ActionVector> actions(new Action::ActionVector()); |
435 | 436 |
436 sql::Connection* db = GetDatabaseConnection(); | 437 sql::Connection* db = GetDatabaseConnection(); |
437 if (!db) | 438 if (!db) |
438 return actions; | 439 return actions; |
439 | 440 |
440 // Build up the query based on which parameters were specified. | 441 // Build up the query based on which parameters were specified. |
441 std::string where_str = ""; | 442 std::string where_str = ""; |
442 std::string where_next = ""; | 443 std::string where_next = ""; |
443 if (!extension_id.empty()) { | 444 if (!extension_id.empty()) { |
444 where_str += "extension_id=?"; | 445 where_str += "extension_id=?"; |
(...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
492 | 493 |
493 // Execute the query and get results. | 494 // Execute the query and get results. |
494 while (query.is_valid() && query.Step()) { | 495 while (query.is_valid() && query.Step()) { |
495 scoped_refptr<Action> action = | 496 scoped_refptr<Action> action = |
496 new Action(query.ColumnString(0), | 497 new Action(query.ColumnString(0), |
497 base::Time::FromInternalValue(query.ColumnInt64(1)), | 498 base::Time::FromInternalValue(query.ColumnInt64(1)), |
498 static_cast<Action::ActionType>(query.ColumnInt(2)), | 499 static_cast<Action::ActionType>(query.ColumnInt(2)), |
499 query.ColumnString(3), query.ColumnInt64(10)); | 500 query.ColumnString(3), query.ColumnInt64(10)); |
500 | 501 |
501 if (query.ColumnType(4) != sql::COLUMN_TYPE_NULL) { | 502 if (query.ColumnType(4) != sql::COLUMN_TYPE_NULL) { |
502 scoped_ptr<base::Value> parsed_value = | 503 std::unique_ptr<base::Value> parsed_value = |
503 base::JSONReader::Read(query.ColumnString(4)); | 504 base::JSONReader::Read(query.ColumnString(4)); |
504 if (parsed_value && parsed_value->IsType(base::Value::TYPE_LIST)) { | 505 if (parsed_value && parsed_value->IsType(base::Value::TYPE_LIST)) { |
505 action->set_args(make_scoped_ptr( | 506 action->set_args(base::WrapUnique( |
506 static_cast<base::ListValue*>(parsed_value.release()))); | 507 static_cast<base::ListValue*>(parsed_value.release()))); |
507 } | 508 } |
508 } | 509 } |
509 | 510 |
510 action->ParsePageUrl(query.ColumnString(5)); | 511 action->ParsePageUrl(query.ColumnString(5)); |
511 action->set_page_title(query.ColumnString(6)); | 512 action->set_page_title(query.ColumnString(6)); |
512 action->ParseArgUrl(query.ColumnString(7)); | 513 action->ParseArgUrl(query.ColumnString(7)); |
513 | 514 |
514 if (query.ColumnType(8) != sql::COLUMN_TYPE_NULL) { | 515 if (query.ColumnType(8) != sql::COLUMN_TYPE_NULL) { |
515 scoped_ptr<base::Value> parsed_value = | 516 std::unique_ptr<base::Value> parsed_value = |
516 base::JSONReader::Read(query.ColumnString(8)); | 517 base::JSONReader::Read(query.ColumnString(8)); |
517 if (parsed_value && parsed_value->IsType(base::Value::TYPE_DICTIONARY)) { | 518 if (parsed_value && parsed_value->IsType(base::Value::TYPE_DICTIONARY)) { |
518 action->set_other(make_scoped_ptr( | 519 action->set_other(base::WrapUnique( |
519 static_cast<base::DictionaryValue*>(parsed_value.release()))); | 520 static_cast<base::DictionaryValue*>(parsed_value.release()))); |
520 } | 521 } |
521 } | 522 } |
522 action->set_count(query.ColumnInt(9)); | 523 action->set_count(query.ColumnInt(9)); |
523 actions->push_back(action); | 524 actions->push_back(action); |
524 } | 525 } |
525 | 526 |
526 return actions; | 527 return actions; |
527 } | 528 } |
528 | 529 |
(...skipping 188 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
717 } | 718 } |
718 } | 719 } |
719 | 720 |
720 void CountingPolicy::ReadFilteredData( | 721 void CountingPolicy::ReadFilteredData( |
721 const std::string& extension_id, | 722 const std::string& extension_id, |
722 const Action::ActionType type, | 723 const Action::ActionType type, |
723 const std::string& api_name, | 724 const std::string& api_name, |
724 const std::string& page_url, | 725 const std::string& page_url, |
725 const std::string& arg_url, | 726 const std::string& arg_url, |
726 const int days_ago, | 727 const int days_ago, |
727 const base::Callback | 728 const base::Callback<void(std::unique_ptr<Action::ActionVector>)>& |
728 <void(scoped_ptr<Action::ActionVector>)>& callback) { | 729 callback) { |
729 BrowserThread::PostTaskAndReplyWithResult( | 730 BrowserThread::PostTaskAndReplyWithResult( |
730 BrowserThread::DB, | 731 BrowserThread::DB, |
731 FROM_HERE, | 732 FROM_HERE, |
732 base::Bind(&CountingPolicy::DoReadFilteredData, | 733 base::Bind(&CountingPolicy::DoReadFilteredData, |
733 base::Unretained(this), | 734 base::Unretained(this), |
734 extension_id, | 735 extension_id, |
735 type, | 736 type, |
736 api_name, | 737 api_name, |
737 page_url, | 738 page_url, |
738 arg_url, | 739 arg_url, |
(...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
797 return true; | 798 return true; |
798 } | 799 } |
799 | 800 |
800 void CountingPolicy::Close() { | 801 void CountingPolicy::Close() { |
801 // The policy object should have never been created if there's no DB thread. | 802 // The policy object should have never been created if there's no DB thread. |
802 DCHECK(BrowserThread::IsMessageLoopValid(BrowserThread::DB)); | 803 DCHECK(BrowserThread::IsMessageLoopValid(BrowserThread::DB)); |
803 ScheduleAndForget(activity_database(), &ActivityDatabase::Close); | 804 ScheduleAndForget(activity_database(), &ActivityDatabase::Close); |
804 } | 805 } |
805 | 806 |
806 } // namespace extensions | 807 } // namespace extensions |
OLD | NEW |