OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 #include "chrome/browser/webdata/web_data_service.h" | 5 #include "chrome/browser/webdata/web_data_service.h" |
6 | 6 |
7 #include "base/bind.h" | |
8 #include "base/command_line.h" | |
9 #include "base/message_loop.h" | |
10 #include "base/stl_util.h" | |
11 #include "base/threading/thread.h" | |
12 #include "chrome/browser/profiles/profile.h" | |
13 #include "chrome/browser/profiles/profile_manager.h" | |
14 #include "chrome/browser/search_engines/template_url.h" | 7 #include "chrome/browser/search_engines/template_url.h" |
15 #include "chrome/browser/ui/profile_error_dialog.h" | |
16 #include "chrome/browser/webdata/autocomplete_syncable_service.h" | 8 #include "chrome/browser/webdata/autocomplete_syncable_service.h" |
17 #include "chrome/browser/webdata/autofill_change.h" | 9 #include "chrome/browser/webdata/autofill_change.h" |
18 #include "chrome/browser/webdata/autofill_entry.h" | 10 #include "chrome/browser/webdata/autofill_entry.h" |
19 #include "chrome/browser/webdata/autofill_profile_syncable_service.h" | 11 #include "chrome/browser/webdata/autofill_profile_syncable_service.h" |
20 #include "chrome/browser/webdata/autofill_table.h" | 12 #include "chrome/browser/webdata/autofill_table.h" |
21 #include "chrome/browser/webdata/keyword_table.h" | 13 #include "chrome/browser/webdata/keyword_table.h" |
22 #include "chrome/browser/webdata/logins_table.h" | 14 #include "chrome/browser/webdata/logins_table.h" |
23 #include "chrome/browser/webdata/token_service_table.h" | 15 #include "chrome/browser/webdata/token_service_table.h" |
24 #include "chrome/browser/webdata/web_apps_table.h" | 16 #include "chrome/browser/webdata/web_apps_table.h" |
25 #include "chrome/browser/webdata/web_database_service.h" | 17 #include "chrome/browser/webdata/web_database_service.h" |
26 #include "chrome/browser/webdata/web_intents_table.h" | 18 #include "chrome/browser/webdata/web_intents_table.h" |
27 #include "chrome/common/chrome_constants.h" | |
28 #include "chrome/common/chrome_notification_types.h" | 19 #include "chrome/common/chrome_notification_types.h" |
29 #include "components/autofill/browser/autofill_country.h" | 20 #include "components/autofill/browser/autofill_country.h" |
30 #include "components/autofill/browser/autofill_profile.h" | 21 #include "components/autofill/browser/autofill_profile.h" |
31 #include "components/autofill/browser/credit_card.h" | 22 #include "components/autofill/browser/credit_card.h" |
32 #include "components/autofill/common/form_field_data.h" | 23 #include "components/autofill/common/form_field_data.h" |
33 #ifdef DEBUG | |
34 #include "content/public/browser/browser_thread.h" | |
35 #endif | |
36 #include "content/public/browser/notification_details.h" | 24 #include "content/public/browser/notification_details.h" |
37 #include "content/public/browser/notification_service.h" | 25 #include "content/public/browser/notification_service.h" |
38 #include "content/public/browser/notification_source.h" | 26 #include "content/public/browser/notification_source.h" |
39 #include "grit/chromium_strings.h" | |
40 #include "grit/generated_resources.h" | |
41 #include "third_party/skia/include/core/SkBitmap.h" | 27 #include "third_party/skia/include/core/SkBitmap.h" |
42 | 28 |
43 //////////////////////////////////////////////////////////////////////////////// | 29 //////////////////////////////////////////////////////////////////////////////// |
44 // | 30 // |
45 // WebDataService implementation. | 31 // WebDataService implementation. |
46 // | 32 // |
47 //////////////////////////////////////////////////////////////////////////////// | 33 //////////////////////////////////////////////////////////////////////////////// |
48 | 34 |
49 using base::Bind; | 35 using base::Bind; |
50 using base::Time; | 36 using base::Time; |
(...skipping 20 matching lines...) Expand all Loading... |
71 WDAppImagesResult::~WDAppImagesResult() {} | 57 WDAppImagesResult::~WDAppImagesResult() {} |
72 | 58 |
73 WDKeywordsResult::WDKeywordsResult() | 59 WDKeywordsResult::WDKeywordsResult() |
74 : default_search_provider_id(0), | 60 : default_search_provider_id(0), |
75 builtin_keyword_version(0) { | 61 builtin_keyword_version(0) { |
76 } | 62 } |
77 | 63 |
78 WDKeywordsResult::~WDKeywordsResult() {} | 64 WDKeywordsResult::~WDKeywordsResult() {} |
79 | 65 |
80 WebDataService::WebDataService() | 66 WebDataService::WebDataService() |
81 : db_loaded_(false), | 67 : autocomplete_syncable_service_(NULL), |
82 autocomplete_syncable_service_(NULL), | |
83 autofill_profile_syncable_service_(NULL) { | 68 autofill_profile_syncable_service_(NULL) { |
84 // WebDataService requires DB thread if instantiated. | |
85 // Set WebDataServiceFactory::GetInstance()->SetTestingFactory(&profile, NULL) | |
86 // if you do not want to instantiate WebDataService in your test. | |
87 DCHECK(BrowserThread::IsWellKnownThread(BrowserThread::DB)); | |
88 } | 69 } |
89 | 70 |
90 // static | 71 // static |
91 void WebDataService::NotifyOfMultipleAutofillChanges( | 72 void WebDataService::NotifyOfMultipleAutofillChanges( |
92 WebDataService* web_data_service) { | 73 WebDataService* web_data_service) { |
93 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::DB)); | 74 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::DB)); |
94 | 75 |
95 if (!web_data_service) | 76 if (!web_data_service) |
96 return; | 77 return; |
97 | 78 |
98 BrowserThread::PostTask( | 79 BrowserThread::PostTask( |
99 BrowserThread::UI, FROM_HERE, | 80 BrowserThread::UI, FROM_HERE, |
100 Bind(&NotifyOfMultipleAutofillChangesTask, | 81 Bind(&NotifyOfMultipleAutofillChangesTask, |
101 make_scoped_refptr(web_data_service))); | 82 make_scoped_refptr(web_data_service))); |
102 } | 83 } |
103 | 84 |
104 void WebDataService::ShutdownOnUIThread() { | 85 void WebDataService::ShutdownOnUIThread() { |
105 db_loaded_ = false; | |
106 ShutdownDatabase(); | |
107 BrowserThread::PostTask(BrowserThread::DB, FROM_HERE, | 86 BrowserThread::PostTask(BrowserThread::DB, FROM_HERE, |
108 Bind(&WebDataService::ShutdownSyncableServices, this)); | 87 Bind(&WebDataService::ShutdownSyncableServices, this)); |
| 88 WebDataServiceBase::ShutdownOnUIThread(); |
109 } | 89 } |
110 | 90 |
111 void WebDataService::Init(const base::FilePath& path) { | 91 void WebDataService::Init(const base::FilePath& path) { |
112 wdbs_.reset(new WebDatabaseService(path)); | 92 WebDataServiceBase::Init(path); |
113 wdbs_->LoadDatabase(Bind(&WebDataService::DatabaseInitOnDB, this)); | |
114 | |
115 BrowserThread::PostTask(BrowserThread::DB, FROM_HERE, | 93 BrowserThread::PostTask(BrowserThread::DB, FROM_HERE, |
116 Bind(&WebDataService::InitializeSyncableServices, this)); | 94 Bind(&WebDataService::InitializeSyncableServices, this)); |
117 } | 95 } |
118 | 96 |
119 void WebDataService::UnloadDatabase() { | |
120 if (!wdbs_) | |
121 return; | |
122 wdbs_->UnloadDatabase(); | |
123 } | |
124 | |
125 void WebDataService::ShutdownDatabase() { | |
126 if (!wdbs_) | |
127 return; | |
128 wdbs_->ShutdownDatabase(); | |
129 } | |
130 | |
131 void WebDataService::CancelRequest(Handle h) { | |
132 if (!wdbs_) | |
133 return; | |
134 wdbs_->CancelRequest(h); | |
135 } | |
136 | |
137 content::NotificationSource WebDataService::GetNotificationSource() { | |
138 return content::Source<WebDataService>(this); | |
139 } | |
140 | |
141 bool WebDataService::IsDatabaseLoaded() { | |
142 return db_loaded_; | |
143 } | |
144 | |
145 WebDatabase* WebDataService::GetDatabase() { | |
146 if (!wdbs_) | |
147 return NULL; | |
148 return wdbs_->GetDatabaseOnDB(); | |
149 } | |
150 | |
151 ////////////////////////////////////////////////////////////////////////////// | 97 ////////////////////////////////////////////////////////////////////////////// |
152 // | 98 // |
153 // Keywords. | 99 // Keywords. |
154 // | 100 // |
155 ////////////////////////////////////////////////////////////////////////////// | 101 ////////////////////////////////////////////////////////////////////////////// |
156 | 102 |
157 void WebDataService::AddKeyword(const TemplateURLData& data) { | 103 void WebDataService::AddKeyword(const TemplateURLData& data) { |
158 wdbs_->ScheduleDBTask( | 104 wdbs_->ScheduleDBTask( |
159 FROM_HERE, Bind(&WebDataService::AddKeywordImpl, this, data)); | 105 FROM_HERE, Bind(&WebDataService::AddKeywordImpl, this, data)); |
160 } | 106 } |
(...skipping 162 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
323 | 269 |
324 void WebDataService::RemoveAutofillProfilesAndCreditCardsModifiedBetween( | 270 void WebDataService::RemoveAutofillProfilesAndCreditCardsModifiedBetween( |
325 const Time& delete_begin, | 271 const Time& delete_begin, |
326 const Time& delete_end) { | 272 const Time& delete_end) { |
327 wdbs_->ScheduleDBTask(FROM_HERE, Bind( | 273 wdbs_->ScheduleDBTask(FROM_HERE, Bind( |
328 &WebDataService::RemoveAutofillProfilesAndCreditCardsModifiedBetweenImpl, | 274 &WebDataService::RemoveAutofillProfilesAndCreditCardsModifiedBetweenImpl, |
329 this, delete_begin, delete_end)); | 275 this, delete_begin, delete_end)); |
330 } | 276 } |
331 | 277 |
332 WebDataService::~WebDataService() { | 278 WebDataService::~WebDataService() { |
333 wdbs_.reset(); | |
334 DCHECK(!autocomplete_syncable_service_); | 279 DCHECK(!autocomplete_syncable_service_); |
335 DCHECK(!autofill_profile_syncable_service_); | 280 DCHECK(!autofill_profile_syncable_service_); |
336 } | 281 } |
337 | 282 |
338 //////////////////////////////////////////////////////////////////////////////// | 283 //////////////////////////////////////////////////////////////////////////////// |
339 // | 284 // |
340 // The following methods are executed on the DB thread. | 285 // The following methods are executed on the DB thread. |
341 // | 286 // |
342 //////////////////////////////////////////////////////////////////////////////// | 287 //////////////////////////////////////////////////////////////////////////////// |
343 | 288 |
344 void WebDataService::DBInitFailed(sql::InitStatus sql_status) { | |
345 ShowProfileErrorDialog( | |
346 (sql_status == sql::INIT_FAILURE) ? | |
347 IDS_COULDNT_OPEN_PROFILE_ERROR : IDS_PROFILE_TOO_NEW_ERROR); | |
348 } | |
349 | |
350 void WebDataService::NotifyDatabaseLoadedOnUIThread() { | |
351 db_loaded_ = true; | |
352 // Notify that the database has been initialized. | |
353 content::NotificationService::current()->Notify( | |
354 chrome::NOTIFICATION_WEB_DATABASE_LOADED, | |
355 content::Source<WebDataService>(this), | |
356 content::NotificationService::NoDetails()); | |
357 } | |
358 | |
359 void WebDataService::DatabaseInitOnDB(sql::InitStatus status) { | |
360 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::DB)); | |
361 if (status == sql::INIT_OK) { | |
362 BrowserThread::PostTask( | |
363 BrowserThread::UI, FROM_HERE, | |
364 base::Bind(&WebDataService::NotifyDatabaseLoadedOnUIThread, this)); | |
365 } else { | |
366 BrowserThread::PostTask( | |
367 BrowserThread::UI, FROM_HERE, | |
368 base::Bind(&WebDataService::DBInitFailed, this, status)); | |
369 } | |
370 } | |
371 | |
372 void WebDataService::InitializeSyncableServices() { | 289 void WebDataService::InitializeSyncableServices() { |
373 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::DB)); | 290 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::DB)); |
374 DCHECK(!autocomplete_syncable_service_); | 291 DCHECK(!autocomplete_syncable_service_); |
375 DCHECK(!autofill_profile_syncable_service_); | 292 DCHECK(!autofill_profile_syncable_service_); |
376 | 293 |
377 autocomplete_syncable_service_ = new AutocompleteSyncableService(this); | 294 autocomplete_syncable_service_ = new AutocompleteSyncableService(this); |
378 autofill_profile_syncable_service_ = new AutofillProfileSyncableService(this); | 295 autofill_profile_syncable_service_ = new AutofillProfileSyncableService(this); |
379 } | 296 } |
380 | 297 |
381 void WebDataService::ShutdownSyncableServices() { | 298 void WebDataService::ShutdownSyncableServices() { |
(...skipping 401 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
783 | 700 |
784 void WebDataService::DestroyAutofillCreditCardResult( | 701 void WebDataService::DestroyAutofillCreditCardResult( |
785 const WDTypedResult* result) { | 702 const WDTypedResult* result) { |
786 DCHECK(result->GetType() == AUTOFILL_CREDITCARDS_RESULT); | 703 DCHECK(result->GetType() == AUTOFILL_CREDITCARDS_RESULT); |
787 const WDResult<std::vector<CreditCard*> >* r = | 704 const WDResult<std::vector<CreditCard*> >* r = |
788 static_cast<const WDResult<std::vector<CreditCard*> >*>(result); | 705 static_cast<const WDResult<std::vector<CreditCard*> >*>(result); |
789 | 706 |
790 std::vector<CreditCard*> credit_cards = r->GetValue(); | 707 std::vector<CreditCard*> credit_cards = r->GetValue(); |
791 STLDeleteElements(&credit_cards); | 708 STLDeleteElements(&credit_cards); |
792 } | 709 } |
OLD | NEW |