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
|
// Copyright (c) 2012 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.
#include "chrome/browser/sync/glue/theme_model_associator.h"
#include "base/basictypes.h"
#include "base/location.h"
#include "base/logging.h"
#include "base/utf_string_conversions.h"
#include "chrome/browser/sync/glue/sync_backend_host.h"
#include "chrome/browser/sync/glue/theme_util.h"
#include "chrome/browser/sync/profile_sync_service.h"
#include "sync/api/sync_error.h"
#include "sync/internal_api/read_node.h"
#include "sync/internal_api/read_transaction.h"
#include "sync/internal_api/write_node.h"
#include "sync/internal_api/write_transaction.h"
#include "sync/protocol/theme_specifics.pb.h"
namespace browser_sync {
namespace {
static const char kThemesTag[] = "google_chrome_themes";
static const char kCurrentThemeNodeTitle[] = "Current Theme";
static const char kNoThemesFolderError[] =
"Server did not create the top-level themes node. We "
"might be running against an out-of-date server.";
} // namespace
ThemeModelAssociator::ThemeModelAssociator(
ProfileSyncService* sync_service,
DataTypeErrorHandler* error_handler)
: sync_service_(sync_service),
error_handler_(error_handler) {
DCHECK(sync_service_);
}
ThemeModelAssociator::~ThemeModelAssociator() {}
SyncError ThemeModelAssociator::AssociateModels() {
sync_api::WriteTransaction trans(FROM_HERE, sync_service_->GetUserShare());
sync_api::ReadNode root(&trans);
if (root.InitByTagLookup(kThemesTag) != sync_api::BaseNode::INIT_OK) {
return error_handler_->CreateAndUploadError(FROM_HERE,
kNoThemesFolderError,
model_type());
}
Profile* profile = sync_service_->profile();
sync_api::WriteNode node(&trans);
// TODO(akalin): When we have timestamps, we may want to do
// something more intelligent than preferring the sync data over our
// local data.
if (node.InitByClientTagLookup(syncable::THEMES, kCurrentThemeClientTag) ==
sync_api::BaseNode::INIT_OK) {
// Update the current theme from the sync data.
// TODO(akalin): If the sync data does not have
// use_system_theme_by_default and we do, update that flag on the
// sync data.
sync_pb::ThemeSpecifics theme_specifics = node.GetThemeSpecifics();
if (UpdateThemeSpecificsOrSetCurrentThemeIfNecessary(profile,
&theme_specifics))
node.SetThemeSpecifics(theme_specifics);
} else {
// Set the sync data from the current theme.
sync_api::WriteNode node(&trans);
sync_api::WriteNode::InitUniqueByCreationResult result =
node.InitUniqueByCreation(syncable::THEMES, root,
kCurrentThemeClientTag);
if (result != sync_api::WriteNode::INIT_SUCCESS) {
return error_handler_->CreateAndUploadError(
FROM_HERE,
"Could not create current theme node.",
model_type());
}
node.SetIsFolder(false);
node.SetTitle(UTF8ToWide(kCurrentThemeNodeTitle));
sync_pb::ThemeSpecifics theme_specifics;
GetThemeSpecificsFromCurrentTheme(profile, &theme_specifics);
node.SetThemeSpecifics(theme_specifics);
}
return SyncError();
}
SyncError ThemeModelAssociator::DisassociateModels() {
// We don't maintain any association state, so nothing to do.
return SyncError();
}
bool ThemeModelAssociator::SyncModelHasUserCreatedNodes(bool* has_nodes) {
DCHECK(has_nodes);
*has_nodes = false;
sync_api::ReadTransaction trans(FROM_HERE, sync_service_->GetUserShare());
sync_api::ReadNode root(&trans);
if (root.InitByTagLookup(kThemesTag) != sync_api::BaseNode::INIT_OK) {
LOG(ERROR) << kNoThemesFolderError;
return false;
}
// The sync model has user created nodes iff the themes folder has
// any children.
*has_nodes = root.HasChildren();
return true;
}
bool ThemeModelAssociator::CryptoReadyIfNecessary() {
// We only access the cryptographer while holding a transaction.
sync_api::ReadTransaction trans(FROM_HERE, sync_service_->GetUserShare());
const syncable::ModelTypeSet encrypted_types =
sync_api::GetEncryptedTypes(&trans);
return !encrypted_types.Has(syncable::THEMES) ||
sync_service_->IsCryptographerReady(&trans);
}
} // namespace browser_sync
|
