1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
|
// Copyright (c) 2010 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.
#ifndef CHROME_BROWSER_SYNC_GLUE_AUTOFILL_CHANGE_PROCESSOR_H_
#define CHROME_BROWSER_SYNC_GLUE_AUTOFILL_CHANGE_PROCESSOR_H_
#pragma once
#include <vector>
#include "chrome/browser/autofill/autofill_profile.h"
#include "chrome/browser/autofill/credit_card.h"
#include "chrome/browser/autofill/personal_data_manager.h"
#include "chrome/browser/sync/engine/syncapi.h"
#include "chrome/browser/sync/glue/change_processor.h"
#include "chrome/browser/sync/glue/sync_backend_host.h"
#include "chrome/browser/sync/protocol/autofill_specifics.pb.h"
#include "chrome/browser/webdata/web_data_service.h"
#include "chrome/common/notification_observer.h"
#include "chrome/common/notification_registrar.h"
class AutofillCreditCardChange;
class AutofillEntry;
class AutofillProfileChange;
class PersonalDataManager;
class WebDatabase;
namespace browser_sync {
class AutofillModelAssociator;
class UnrecoverableErrorHandler;
// This class is responsible for taking changes from the web data service and
// applying them to the sync_api 'syncable' model, and vice versa. All
// operations and use of this class are from the DB thread.
class AutofillChangeProcessor : public ChangeProcessor,
public NotificationObserver {
public:
AutofillChangeProcessor(AutofillModelAssociator* model_associator,
WebDatabase* web_database,
PersonalDataManager* personal_data,
UnrecoverableErrorHandler* error_handler);
virtual ~AutofillChangeProcessor() {}
// NotificationObserver implementation.
// WebDataService -> sync_api model change application.
virtual void Observe(NotificationType type,
const NotificationSource& source,
const NotificationDetails& details);
// sync_api model -> WebDataService change application.
virtual void ApplyChangesFromSyncModel(
const sync_api::BaseTransaction* trans,
const sync_api::SyncManager::ChangeRecord* changes,
int change_count);
// Commit any changes from ApplyChangesFromSyncModel buffered in
// autofill_changes_.
virtual void CommitChangesFromSyncModel();
// Copy the properties of the given Autofill entry into the sync
// node.
static void WriteAutofillEntry(const AutofillEntry& entry,
sync_api::WriteNode* node);
// As above, for autofill profiles.
static void WriteAutofillProfile(const AutoFillProfile& profile,
sync_api::WriteNode* node);
// TODO(georgey) : add the same processing for CC info (already in protocol
// buffers).
protected:
virtual void StartImpl(Profile* profile);
virtual void StopImpl();
private:
struct AutofillChangeRecord {
sync_api::SyncManager::ChangeRecord::Action action_;
int64 id_;
sync_pb::AutofillSpecifics autofill_;
AutofillChangeRecord(sync_api::SyncManager::ChangeRecord::Action action,
int64 id, const sync_pb::AutofillSpecifics& autofill)
: action_(action),
id_(id),
autofill_(autofill) { }
};
void StartObserving();
void StopObserving();
// A function to remove the sync node for an autofill entry or profile.
void RemoveSyncNode(const std::string& tag,
sync_api::WriteTransaction* trans);
// These two methods are dispatched to by Observe depending on the type.
void ObserveAutofillEntriesChanged(AutofillChangeList* changes,
sync_api::WriteTransaction* trans,
const sync_api::ReadNode& autofill_root);
void ObserveAutofillProfileChanged(AutofillProfileChange* change,
sync_api::WriteTransaction* trans,
const sync_api::ReadNode& autofill_root);
// The following methods are the implementation of ApplyChangeFromSyncModel
// for the respective autofill subtypes.
void ApplySyncAutofillEntryChange(
sync_api::SyncManager::ChangeRecord::Action action,
const sync_pb::AutofillSpecifics& autofill,
std::vector<AutofillEntry>* new_entries,
int64 sync_id);
void ApplySyncAutofillProfileChange(
sync_api::SyncManager::ChangeRecord::Action action,
const sync_pb::AutofillProfileSpecifics& profile,
int64 sync_id);
// Delete is a special case of change application.
void ApplySyncAutofillEntryDelete(
const sync_pb::AutofillSpecifics& autofill);
void ApplySyncAutofillProfileDelete(
const sync_pb::AutofillProfileSpecifics& profile,
int64 sync_id);
// If the chrome model tries to add an AutoFillProfile with a label that
// is already in use, we perform a move-aside by calling-back into the chrome
// model and overwriting the label with a unique value we can apply for sync.
// This method should be called on an ADD notification from the chrome model.
// |tag| contains the unique sync client tag identifier for |profile|, which
// is derived from the profile label using ProfileLabelToTag.
// |existing_unique_label| is the current label of the object, if any; this
// is an allowed value, because it's taken by the item in question.
// For new items, set |existing_unique_label| to the empty string.
void ChangeProfileLabelIfAlreadyTaken(
sync_api::BaseTransaction* trans,
const string16& existing_unique_label,
AutoFillProfile* profile,
std::string* tag);
// Reassign the label of the profile, write this back to the web database,
// and update |tag| with the tag corresponding to the new label.
void OverrideProfileLabel(
const string16& new_label,
AutoFillProfile* profile_to_update,
std::string* tag_to_update);
// Helper to create a sync node with tag |tag|, storing |profile| as
// the node's AutofillSpecifics.
void AddAutofillProfileSyncNode(
sync_api::WriteTransaction* trans,
const sync_api::BaseNode& autofill,
const std::string& tag,
const AutoFillProfile* profile);
// Helper to post a task to the UI loop to inform the PersonalDataManager
// it needs to refresh itself.
void PostOptimisticRefreshTask();
// The two models should be associated according to this ModelAssociator.
AutofillModelAssociator* model_associator_;
// The model we are processing changes from. This is owned by the
// WebDataService which is kept alive by our data type controller
// holding a reference.
WebDatabase* web_database_;
// We periodically tell the PersonalDataManager to refresh as we make
// changes to the autofill data in the WebDatabase.
PersonalDataManager* personal_data_;
NotificationRegistrar notification_registrar_;
bool observing_;
// Record of changes from ApplyChangesFromSyncModel. These are then processed
// in CommitChangesFromSyncModel.
std::vector<AutofillChangeRecord> autofill_changes_;
DISALLOW_COPY_AND_ASSIGN(AutofillChangeProcessor);
};
} // namespace browser_sync
#endif // CHROME_BROWSER_SYNC_GLUE_AUTOFILL_CHANGE_PROCESSOR_H_
|
