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
|
// 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_PROFILE_SYNC_TEST_UTIL_H_
#define CHROME_BROWSER_SYNC_PROFILE_SYNC_TEST_UTIL_H_
#include "chrome/browser/sync/glue/bookmark_change_processor.h"
#include "chrome/browser/sync/glue/bookmark_data_type_controller.h"
#include "chrome/browser/sync/glue/bookmark_model_associator.h"
#include "chrome/browser/sync/glue/change_processor.h"
#include "chrome/browser/sync/profile_sync_factory.h"
#include "chrome/browser/sync/profile_sync_service.h"
#include "chrome/test/sync/test_http_bridge_factory.h"
class TestProfileSyncFactory : public ProfileSyncFactory {
public:
TestProfileSyncFactory(ProfileSyncService* profile_sync_service,
browser_sync::AssociatorInterface* model_associator,
browser_sync::ChangeProcessor* change_processor)
: profile_sync_service_(profile_sync_service),
model_associator_(model_associator),
change_processor_(change_processor) {}
virtual ~TestProfileSyncFactory() {}
virtual ProfileSyncService* CreateProfileSyncService() {
return profile_sync_service_.release();
}
virtual SyncComponents CreateBookmarkSyncComponents(
ProfileSyncService* service) {
return SyncComponents(model_associator_.release(),
change_processor_.release());
}
virtual SyncComponents CreatePreferenceSyncComponents(
ProfileSyncService* service) {
return SyncComponents(model_associator_.release(),
change_processor_.release());
}
private:
scoped_ptr<ProfileSyncService> profile_sync_service_;
scoped_ptr<browser_sync::AssociatorInterface> model_associator_;
scoped_ptr<browser_sync::ChangeProcessor> change_processor_;
DISALLOW_COPY_AND_ASSIGN(TestProfileSyncFactory);
};
template <class ModelAssociatorImpl>
class TestModelAssociator : public ModelAssociatorImpl {
public:
explicit TestModelAssociator(ProfileSyncService* service)
: ModelAssociatorImpl(service) {
}
virtual bool GetSyncIdForTaggedNode(const std::string& tag, int64* sync_id) {
std::wstring tag_wide;
if (!UTF8ToWide(tag.c_str(), tag.length(), &tag_wide)) {
NOTREACHED() << "Unable to convert UTF8 to wide for string: " << tag;
return false;
}
sync_api::WriteTransaction trans(
ModelAssociatorImpl::sync_service()->backend()->GetUserShareHandle());
sync_api::ReadNode root(&trans);
root.InitByRootLookup();
// First, try to find a node with the title among the root's children.
// This will be the case if we are testing model persistence, and
// are reloading a sync repository created earlier in the test.
int64 last_child_id = sync_api::kInvalidId;
for (int64 id = root.GetFirstChildId(); id != sync_api::kInvalidId; /***/) {
sync_api::ReadNode child(&trans);
child.InitByIdLookup(id);
last_child_id = id;
if (tag_wide == child.GetTitle()) {
*sync_id = id;
return true;
}
id = child.GetSuccessorId();
}
sync_api::ReadNode predecessor_node(&trans);
sync_api::ReadNode* predecessor = NULL;
if (last_child_id != sync_api::kInvalidId) {
predecessor_node.InitByIdLookup(last_child_id);
predecessor = &predecessor_node;
}
sync_api::WriteNode node(&trans);
// Create new fake tagged nodes at the end of the ordering.
node.InitByCreation(ModelAssociatorImpl::model_type(), root, predecessor);
node.SetIsFolder(true);
node.SetTitle(tag_wide);
node.SetExternalId(0);
*sync_id = node.GetId();
return true;
}
~TestModelAssociator() {}
};
#endif // CHROME_BROWSER_SYNC_PROFILE_SYNC_TEST_UTIL_H_
|
