| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "chrome/browser/sync/glue/theme_model_associator.h" | 5 #include "chrome/browser/sync/glue/theme_model_associator.h" |
| 6 | 6 |
| 7 #include "base/basictypes.h" | 7 #include "base/basictypes.h" |
| 8 #include "base/logging.h" | 8 #include "base/logging.h" |
| 9 #include "base/tracked.h" | 9 #include "base/tracked.h" |
| 10 #include "base/utf_string_conversions.h" | 10 #include "base/utf_string_conversions.h" |
| 11 #include "chrome/browser/sync/api/sync_error.h" | |
| 12 #include "chrome/browser/sync/engine/syncapi.h" | 11 #include "chrome/browser/sync/engine/syncapi.h" |
| 13 #include "chrome/browser/sync/glue/sync_backend_host.h" | 12 #include "chrome/browser/sync/glue/sync_backend_host.h" |
| 14 #include "chrome/browser/sync/glue/theme_util.h" | 13 #include "chrome/browser/sync/glue/theme_util.h" |
| 15 #include "chrome/browser/sync/profile_sync_service.h" | 14 #include "chrome/browser/sync/profile_sync_service.h" |
| 16 #include "chrome/browser/sync/protocol/theme_specifics.pb.h" | 15 #include "chrome/browser/sync/protocol/theme_specifics.pb.h" |
| 17 | 16 |
| 18 namespace browser_sync { | 17 namespace browser_sync { |
| 19 | 18 |
| 20 namespace { | 19 namespace { |
| 21 | 20 |
| 22 static const char kThemesTag[] = "google_chrome_themes"; | 21 static const char kThemesTag[] = "google_chrome_themes"; |
| 23 static const char kCurrentThemeNodeTitle[] = "Current Theme"; | 22 static const char kCurrentThemeNodeTitle[] = "Current Theme"; |
| 24 | 23 |
| 25 static const char kNoThemesFolderError[] = | 24 static const char kNoThemesFolderError[] = |
| 26 "Server did not create the top-level themes node. We " | 25 "Server did not create the top-level themes node. We " |
| 27 "might be running against an out-of-date server."; | 26 "might be running against an out-of-date server."; |
| 28 | 27 |
| 29 } // namespace | 28 } // namespace |
| 30 | 29 |
| 31 ThemeModelAssociator::ThemeModelAssociator( | 30 ThemeModelAssociator::ThemeModelAssociator( |
| 32 ProfileSyncService* sync_service) | 31 ProfileSyncService* sync_service) |
| 33 : sync_service_(sync_service) { | 32 : sync_service_(sync_service) { |
| 34 DCHECK(sync_service_); | 33 DCHECK(sync_service_); |
| 35 } | 34 } |
| 36 | 35 |
| 37 ThemeModelAssociator::~ThemeModelAssociator() {} | 36 ThemeModelAssociator::~ThemeModelAssociator() {} |
| 38 | 37 |
| 39 bool ThemeModelAssociator::AssociateModels(SyncError* error) { | 38 bool ThemeModelAssociator::AssociateModels() { |
| 40 sync_api::WriteTransaction trans(FROM_HERE, sync_service_->GetUserShare()); | 39 sync_api::WriteTransaction trans(FROM_HERE, sync_service_->GetUserShare()); |
| 41 sync_api::ReadNode root(&trans); | 40 sync_api::ReadNode root(&trans); |
| 42 if (!root.InitByTagLookup(kThemesTag)) { | 41 if (!root.InitByTagLookup(kThemesTag)) { |
| 43 error->Reset(FROM_HERE, kNoThemesFolderError, model_type()); | 42 LOG(ERROR) << kNoThemesFolderError; |
| 44 return false; | 43 return false; |
| 45 } | 44 } |
| 46 | 45 |
| 47 Profile* profile = sync_service_->profile(); | 46 Profile* profile = sync_service_->profile(); |
| 48 sync_api::WriteNode node(&trans); | 47 sync_api::WriteNode node(&trans); |
| 49 // TODO(akalin): When we have timestamps, we may want to do | 48 // TODO(akalin): When we have timestamps, we may want to do |
| 50 // something more intelligent than preferring the sync data over our | 49 // something more intelligent than preferring the sync data over our |
| 51 // local data. | 50 // local data. |
| 52 if (node.InitByClientTagLookup(syncable::THEMES, kCurrentThemeClientTag)) { | 51 if (node.InitByClientTagLookup(syncable::THEMES, kCurrentThemeClientTag)) { |
| 53 // Update the current theme from the sync data. | 52 // Update the current theme from the sync data. |
| 54 // TODO(akalin): If the sync data does not have | 53 // TODO(akalin): If the sync data does not have |
| 55 // use_system_theme_by_default and we do, update that flag on the | 54 // use_system_theme_by_default and we do, update that flag on the |
| 56 // sync data. | 55 // sync data. |
| 57 sync_pb::ThemeSpecifics theme_specifics = node.GetThemeSpecifics(); | 56 sync_pb::ThemeSpecifics theme_specifics = node.GetThemeSpecifics(); |
| 58 if (UpdateThemeSpecificsOrSetCurrentThemeIfNecessary(profile, | 57 if (UpdateThemeSpecificsOrSetCurrentThemeIfNecessary(profile, |
| 59 &theme_specifics)) | 58 &theme_specifics)) |
| 60 node.SetThemeSpecifics(theme_specifics); | 59 node.SetThemeSpecifics(theme_specifics); |
| 61 } else { | 60 } else { |
| 62 // Set the sync data from the current theme. | 61 // Set the sync data from the current theme. |
| 63 sync_api::WriteNode node(&trans); | 62 sync_api::WriteNode node(&trans); |
| 64 if (!node.InitUniqueByCreation(syncable::THEMES, root, | 63 if (!node.InitUniqueByCreation(syncable::THEMES, root, |
| 65 kCurrentThemeClientTag)) { | 64 kCurrentThemeClientTag)) { |
| 66 error->Reset(FROM_HERE, | 65 LOG(ERROR) << "Could not create current theme node."; |
| 67 "Could not create current theme node.", | |
| 68 model_type()); | |
| 69 return false; | 66 return false; |
| 70 } | 67 } |
| 71 node.SetIsFolder(false); | 68 node.SetIsFolder(false); |
| 72 node.SetTitle(UTF8ToWide(kCurrentThemeNodeTitle)); | 69 node.SetTitle(UTF8ToWide(kCurrentThemeNodeTitle)); |
| 73 sync_pb::ThemeSpecifics theme_specifics; | 70 sync_pb::ThemeSpecifics theme_specifics; |
| 74 GetThemeSpecificsFromCurrentTheme(profile, &theme_specifics); | 71 GetThemeSpecificsFromCurrentTheme(profile, &theme_specifics); |
| 75 node.SetThemeSpecifics(theme_specifics); | 72 node.SetThemeSpecifics(theme_specifics); |
| 76 } | 73 } |
| 77 return true; | 74 return true; |
| 78 } | 75 } |
| 79 | 76 |
| 80 bool ThemeModelAssociator::DisassociateModels(SyncError* error) { | 77 bool ThemeModelAssociator::DisassociateModels() { |
| 81 // We don't maintain any association state, so nothing to do. | 78 // We don't maintain any association state, so nothing to do. |
| 82 return true; | 79 return true; |
| 83 } | 80 } |
| 84 | 81 |
| 85 bool ThemeModelAssociator::SyncModelHasUserCreatedNodes(bool* has_nodes) { | 82 bool ThemeModelAssociator::SyncModelHasUserCreatedNodes(bool* has_nodes) { |
| 86 DCHECK(has_nodes); | 83 DCHECK(has_nodes); |
| 87 *has_nodes = false; | 84 *has_nodes = false; |
| 88 sync_api::ReadTransaction trans(FROM_HERE, sync_service_->GetUserShare()); | 85 sync_api::ReadTransaction trans(FROM_HERE, sync_service_->GetUserShare()); |
| 89 sync_api::ReadNode root(&trans); | 86 sync_api::ReadNode root(&trans); |
| 90 if (!root.InitByTagLookup(kThemesTag)) { | 87 if (!root.InitByTagLookup(kThemesTag)) { |
| 91 LOG(ERROR) << kNoThemesFolderError; | 88 LOG(ERROR) << kNoThemesFolderError; |
| 92 return false; | 89 return false; |
| 93 } | 90 } |
| 94 // The sync model has user created nodes iff the themes folder has | 91 // The sync model has user created nodes iff the themes folder has |
| 95 // any children. | 92 // any children. |
| 96 *has_nodes = root.GetFirstChildId() != sync_api::kInvalidId; | 93 *has_nodes = root.GetFirstChildId() != sync_api::kInvalidId; |
| 97 return true; | 94 return true; |
| 98 } | 95 } |
| 99 | 96 |
| 100 bool ThemeModelAssociator::CryptoReadyIfNecessary() { | 97 bool ThemeModelAssociator::CryptoReadyIfNecessary() { |
| 101 // We only access the cryptographer while holding a transaction. | 98 // We only access the cryptographer while holding a transaction. |
| 102 sync_api::ReadTransaction trans(FROM_HERE, sync_service_->GetUserShare()); | 99 sync_api::ReadTransaction trans(FROM_HERE, sync_service_->GetUserShare()); |
| 103 syncable::ModelTypeSet encrypted_types; | 100 syncable::ModelTypeSet encrypted_types; |
| 104 encrypted_types = sync_api::GetEncryptedTypes(&trans); | 101 encrypted_types = sync_api::GetEncryptedTypes(&trans); |
| 105 return encrypted_types.count(syncable::THEMES) == 0 || | 102 return encrypted_types.count(syncable::THEMES) == 0 || |
| 106 sync_service_->IsCryptographerReady(&trans); | 103 sync_service_->IsCryptographerReady(&trans); |
| 107 } | 104 } |
| 108 | 105 |
| 109 } // namespace browser_sync | 106 } // namespace browser_sync |
| OLD | NEW |