autofill_webdata_service.cc revision 4e180b6a0b4720a9b8e9e959a882386f690f08ff 
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
3// found in the LICENSE file.
4
5#include "components/autofill/core/browser/webdata/autofill_webdata_service.h"
6
7#include "base/bind.h"
8#include "base/logging.h"
9#include "base/message_loop/message_loop_proxy.h"
10#include "base/stl_util.h"
11#include "components/autofill/core/browser/autofill_country.h"
12#include "components/autofill/core/browser/autofill_profile.h"
13#include "components/autofill/core/browser/credit_card.h"
14#include "components/autofill/core/browser/webdata/autofill_change.h"
15#include "components/autofill/core/browser/webdata/autofill_entry.h"
16#include "components/autofill/core/browser/webdata/autofill_table.h"
17#include "components/autofill/core/browser/webdata/autofill_webdata_backend_impl.h"
18#include "components/autofill/core/browser/webdata/autofill_webdata_service_observer.h"
19#include "components/autofill/core/common/form_field_data.h"
20#include "components/webdata/common/web_data_service_backend.h"
21#include "components/webdata/common/web_database_service.h"
22
23using base::Bind;
24using base::Time;
25
26namespace autofill {
27
28AutofillWebDataService::AutofillWebDataService(
29    scoped_refptr<WebDatabaseService> wdbs,
30    scoped_refptr<base::MessageLoopProxy> ui_thread,
31    scoped_refptr<base::MessageLoopProxy> db_thread,
32    const ProfileErrorCallback& callback)
33    : WebDataServiceBase(wdbs, callback, ui_thread),
34      ui_thread_(ui_thread),
35      db_thread_(db_thread),
36      weak_ptr_factory_(this),
37      autofill_backend_(NULL) {
38
39  base::Closure on_changed_callback = Bind(
40      &AutofillWebDataService::NotifyAutofillMultipleChangedOnUIThread,
41      weak_ptr_factory_.GetWeakPtr());
42
43  autofill_backend_ = new AutofillWebDataBackendImpl(
44      wdbs_->GetBackend(), ui_thread_, db_thread_, on_changed_callback);
45}
46
47AutofillWebDataService::AutofillWebDataService(
48    scoped_refptr<base::MessageLoopProxy> ui_thread,
49    scoped_refptr<base::MessageLoopProxy> db_thread)
50    : WebDataServiceBase(NULL, WebDataServiceBase::ProfileErrorCallback(),
51          ui_thread),
52      ui_thread_(ui_thread),
53      db_thread_(db_thread),
54      weak_ptr_factory_(this),
55      autofill_backend_(new AutofillWebDataBackendImpl(NULL,
56          ui_thread_,
57          db_thread_,
58          base::Closure())) {
59}
60
61void AutofillWebDataService::ShutdownOnUIThread() {
62  weak_ptr_factory_.InvalidateWeakPtrs();
63  db_thread_->PostTask(FROM_HERE,
64      Bind(&AutofillWebDataBackendImpl::ResetUserData, autofill_backend_));
65  WebDataServiceBase::ShutdownOnUIThread();
66}
67
68void AutofillWebDataService::AddFormFields(
69    const std::vector<FormFieldData>& fields) {
70  wdbs_->ScheduleDBTask(FROM_HERE,
71      Bind(&AutofillWebDataBackendImpl::AddFormElements,
72           autofill_backend_, fields));
73}
74
75WebDataServiceBase::Handle AutofillWebDataService::GetFormValuesForElementName(
76    const base::string16& name, const base::string16& prefix, int limit,
77    WebDataServiceConsumer* consumer) {
78  return wdbs_->ScheduleDBTaskWithResult(FROM_HERE,
79      Bind(&AutofillWebDataBackendImpl::GetFormValuesForElementName,
80           autofill_backend_, name, prefix, limit), consumer);
81}
82
83WebDataServiceBase::Handle AutofillWebDataService::HasFormElements(
84    WebDataServiceConsumer* consumer) {
85  return wdbs_->ScheduleDBTaskWithResult(FROM_HERE,
86      Bind(&AutofillWebDataBackendImpl::HasFormElements, autofill_backend_),
87      consumer);
88}
89
90void AutofillWebDataService::RemoveFormElementsAddedBetween(
91    const Time& delete_begin, const Time& delete_end) {
92  wdbs_->ScheduleDBTask(FROM_HERE,
93      Bind(&AutofillWebDataBackendImpl::RemoveFormElementsAddedBetween,
94           autofill_backend_, delete_begin, delete_end));
95}
96
97void AutofillWebDataService::RemoveFormValueForElementName(
98    const base::string16& name, const base::string16& value) {
99  wdbs_->ScheduleDBTask(FROM_HERE,
100      Bind(&AutofillWebDataBackendImpl::RemoveFormValueForElementName,
101           autofill_backend_, name, value));
102}
103
104void AutofillWebDataService::AddAutofillProfile(
105    const AutofillProfile& profile) {
106  wdbs_->ScheduleDBTask(FROM_HERE,
107      Bind(&AutofillWebDataBackendImpl::AddAutofillProfile,
108           autofill_backend_, profile));
109}
110
111void AutofillWebDataService::UpdateAutofillProfile(
112    const AutofillProfile& profile) {
113  wdbs_->ScheduleDBTask(FROM_HERE,
114      Bind(&AutofillWebDataBackendImpl::UpdateAutofillProfile,
115           autofill_backend_, profile));
116}
117
118void AutofillWebDataService::RemoveAutofillProfile(
119    const std::string& guid) {
120  wdbs_->ScheduleDBTask(FROM_HERE,
121      Bind(&AutofillWebDataBackendImpl::RemoveAutofillProfile,
122           autofill_backend_, guid));
123}
124
125WebDataServiceBase::Handle AutofillWebDataService::GetAutofillProfiles(
126    WebDataServiceConsumer* consumer) {
127  return wdbs_->ScheduleDBTaskWithResult(FROM_HERE,
128      Bind(&AutofillWebDataBackendImpl::GetAutofillProfiles, autofill_backend_),
129      consumer);
130}
131
132void AutofillWebDataService::AddCreditCard(const CreditCard& credit_card) {
133  wdbs_->ScheduleDBTask(
134      FROM_HERE,
135      Bind(&AutofillWebDataBackendImpl::AddCreditCard,
136           autofill_backend_, credit_card));
137}
138
139void AutofillWebDataService::UpdateCreditCard(
140    const CreditCard& credit_card) {
141  wdbs_->ScheduleDBTask(
142      FROM_HERE,
143      Bind(&AutofillWebDataBackendImpl::UpdateCreditCard,
144           autofill_backend_, credit_card));
145}
146
147void AutofillWebDataService::RemoveCreditCard(const std::string& guid) {
148  wdbs_->ScheduleDBTask(
149      FROM_HERE,
150      Bind(&AutofillWebDataBackendImpl::RemoveCreditCard,
151           autofill_backend_, guid));
152}
153
154WebDataServiceBase::Handle AutofillWebDataService::GetCreditCards(
155    WebDataServiceConsumer* consumer) {
156  return wdbs_->ScheduleDBTaskWithResult(FROM_HERE,
157      Bind(&AutofillWebDataBackendImpl::GetCreditCards, autofill_backend_),
158      consumer);
159}
160
161void AutofillWebDataService::RemoveAutofillDataModifiedBetween(
162    const Time& delete_begin,
163    const Time& delete_end) {
164  wdbs_->ScheduleDBTask(
165      FROM_HERE,
166      Bind(&AutofillWebDataBackendImpl::RemoveAutofillDataModifiedBetween,
167           autofill_backend_, delete_begin, delete_end));
168}
169
170void AutofillWebDataService::RemoveOriginURLsModifiedBetween(
171    const Time& delete_begin, const Time& delete_end) {
172  wdbs_->ScheduleDBTask(
173      FROM_HERE,
174      Bind(&AutofillWebDataBackendImpl::RemoveOriginURLsModifiedBetween,
175           autofill_backend_, delete_begin, delete_end));
176}
177
178void AutofillWebDataService::AddObserver(
179    AutofillWebDataServiceObserverOnDBThread* observer) {
180  DCHECK(db_thread_->BelongsToCurrentThread());
181  if (autofill_backend_.get())
182    autofill_backend_->AddObserver(observer);
183}
184
185void AutofillWebDataService::RemoveObserver(
186    AutofillWebDataServiceObserverOnDBThread* observer) {
187  DCHECK(db_thread_->BelongsToCurrentThread());
188  if (autofill_backend_.get())
189    autofill_backend_->RemoveObserver(observer);
190}
191
192void AutofillWebDataService::AddObserver(
193    AutofillWebDataServiceObserverOnUIThread* observer) {
194  DCHECK(ui_thread_->BelongsToCurrentThread());
195  ui_observer_list_.AddObserver(observer);
196}
197
198void AutofillWebDataService::RemoveObserver(
199    AutofillWebDataServiceObserverOnUIThread* observer) {
200  DCHECK(ui_thread_->BelongsToCurrentThread());
201  ui_observer_list_.RemoveObserver(observer);
202}
203
204base::SupportsUserData* AutofillWebDataService::GetDBUserData() {
205  DCHECK(db_thread_->BelongsToCurrentThread());
206  return autofill_backend_->GetDBUserData();
207}
208
209void AutofillWebDataService::GetAutofillBackend(
210    const base::Callback<void(AutofillWebDataBackend*)>& callback) {
211  db_thread_->PostTask(FROM_HERE, base::Bind(callback, autofill_backend_));
212}
213
214AutofillWebDataService::~AutofillWebDataService() {
215}
216
217void AutofillWebDataService::NotifyAutofillMultipleChangedOnUIThread() {
218  DCHECK(ui_thread_->BelongsToCurrentThread());
219  FOR_EACH_OBSERVER(AutofillWebDataServiceObserverOnUIThread,
220                    ui_observer_list_,
221                    AutofillMultipleChanged());
222}
223
224}  // namespace autofill
225