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
|
// Copyright (c) 2011 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_WEBDATA_AUTOCOMPLETE_SYNCABLE_SERVICE_H_
#define CHROME_BROWSER_WEBDATA_AUTOCOMPLETE_SYNCABLE_SERVICE_H_
#pragma once
#include <map>
#include <string>
#include <utility>
#include <vector>
#include "base/basictypes.h"
#include "base/memory/scoped_ptr.h"
#include "base/threading/non_thread_safe.h"
#include "chrome/browser/sync/api/sync_change.h"
#include "chrome/browser/sync/api/sync_data.h"
#include "chrome/browser/sync/api/sync_error.h"
#include "chrome/browser/sync/api/syncable_service.h"
#include "chrome/browser/webdata/autofill_change.h"
#include "chrome/browser/webdata/autofill_entry.h"
#include "chrome/browser/webdata/web_data_service.h"
#include "content/public/browser/notification_observer.h"
#include "content/public/browser/notification_registrar.h"
class ProfileSyncServiceAutofillTest;
namespace sync_pb {
class AutofillSpecifics;
}
// The sync implementation for autocomplete.
// MergeDataAndStartSyncing() called first, it does cloud->local and
// local->cloud syncs. Then for each cloud change we receive
// ProcessSyncChanges() and for each local change Observe() is called.
// TODO(georgey) : remove reliance on the notifications and make it to be called
// from web_data_service directly.
class AutocompleteSyncableService
: public SyncableService,
public content::NotificationObserver,
public base::NonThreadSafe {
public:
explicit AutocompleteSyncableService(WebDataService* web_data_service);
virtual ~AutocompleteSyncableService();
static syncable::ModelType model_type() { return syncable::AUTOFILL; }
// SyncableService implementation.
virtual SyncError MergeDataAndStartSyncing(
syncable::ModelType type,
const SyncDataList& initial_sync_data,
SyncChangeProcessor* sync_processor) OVERRIDE;
virtual void StopSyncing(syncable::ModelType type) OVERRIDE;
virtual SyncDataList GetAllSyncData(syncable::ModelType type) const OVERRIDE;
virtual SyncError ProcessSyncChanges(
const tracked_objects::Location& from_here,
const SyncChangeList& change_list) OVERRIDE;
// NotificationObserver implementation.
virtual void Observe(int type,
const content::NotificationSource& source,
const content::NotificationDetails& details) OVERRIDE;
protected:
// Helper to query WebDatabase for the current autocomplete state.
// Made virtual for ease of mocking in the unit-test.
virtual bool LoadAutofillData(std::vector<AutofillEntry>* entries) const;
// Helper to persist any changes that occured during model association to
// the WebDatabase. |entries| will be either added or updated.
// Made virtual for ease of mocking in the unit-test.
virtual bool SaveChangesToWebData(const std::vector<AutofillEntry>& entries);
private:
friend class ProfileSyncServiceAutofillTest;
friend class MockAutocompleteSyncableService;
friend class FakeServerUpdater;
FRIEND_TEST_ALL_PREFIXES(AutocompleteSyncableServiceTest,
MergeDataAndStartSyncing);
FRIEND_TEST_ALL_PREFIXES(AutocompleteSyncableServiceTest, GetAllSyncData);
FRIEND_TEST_ALL_PREFIXES(AutocompleteSyncableServiceTest,
ProcessSyncChanges);
FRIEND_TEST_ALL_PREFIXES(AutocompleteSyncableServiceTest,
ActOnChange);
// This is a helper map used only in Merge/Process* functions. The lifetime
// of the iterator is longer than the map object. The bool in the pair is used
// to indicate if the item needs to be added (true) or updated (false).
typedef std::map<AutofillKey,
std::pair<SyncChange::SyncChangeType,
std::vector<AutofillEntry>::iterator> >
AutocompleteEntryMap;
// Creates or updates an autocomplete entry based on |data|.
void CreateOrUpdateEntry(const SyncData& data,
AutocompleteEntryMap* loaded_data,
std::vector<AutofillEntry>* bundle);
// Writes |entry| data into supplied |autofill_specifics|.
static void WriteAutofillEntry(const AutofillEntry& entry,
sync_pb::EntitySpecifics* autofill_specifics);
// Deletes the database entry corresponding to the |autofill| specifics.
SyncError AutofillEntryDelete(const sync_pb::AutofillSpecifics& autofill);
SyncData CreateSyncData(const AutofillEntry& entry) const;
// Syncs |changes| to the cloud.
void ActOnChanges(const AutofillChangeList& changes);
static std::string KeyToTag(const std::string& name,
const std::string& value);
// For unit-tests.
AutocompleteSyncableService();
void set_sync_processor(SyncChangeProcessor* sync_processor) {
sync_processor_.reset(sync_processor);
}
// Lifetime of AutocompleteSyncableService object is shorter than
// |web_data_service_| passed to it.
WebDataService* web_data_service_;
content::NotificationRegistrar notification_registrar_;
// We receive ownership of |sync_processor_| in MergeDataAndStartSyncing() and
// destroy it in StopSyncing().
scoped_ptr<SyncChangeProcessor> sync_processor_;
DISALLOW_COPY_AND_ASSIGN(AutocompleteSyncableService);
};
#endif // CHROME_BROWSER_WEBDATA_AUTOCOMPLETE_SYNCABLE_SERVICE_H_
|
