Index: chrome/browser/sync/profile_sync_service.cc |
=================================================================== |
--- chrome/browser/sync/profile_sync_service.cc (revision 22320) |
+++ chrome/browser/sync/profile_sync_service.cc (working copy) |
@@ -1,886 +0,0 @@ |
-// Copyright (c) 2006-2008 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. |
- |
-#ifdef CHROME_PERSONALIZATION |
-#include "chrome/browser/sync/profile_sync_service.h" |
- |
-#include <stack> |
-#include <vector> |
- |
-#include "base/basictypes.h" |
-#include "base/command_line.h" |
-#include "base/file_path.h" |
-#include "base/file_util.h" |
-#include "base/gfx/png_encoder.h" |
-#include "base/stl_util-inl.h" |
-#include "base/string_util.h" |
-#include "base/time.h" |
-#include "chrome/browser/bookmarks/bookmark_utils.h" |
-#include "chrome/browser/history/history_notifications.h" |
-#include "chrome/browser/history/history_types.h" |
-#include "chrome/browser/profile.h" |
-#include "chrome/common/chrome_switches.h" |
-#include "chrome/common/pref_service.h" |
-#include "chrome/common/time_format.h" |
-#include "chrome/browser/sync/personalization.h" |
-#include "chrome/browser/sync/personalization_strings.h" |
-#include "chrome/browser/sync/engine/syncapi.h" |
-#include "views/window/window.h" |
- |
-using browser_sync::ModelAssociator; |
-using browser_sync::SyncBackendHost; |
- |
-ProfileSyncService::ProfileSyncService(Profile* profile) |
- : last_auth_error_(AUTH_ERROR_NONE), |
- profile_(profile), |
- backend_initialized_(false), |
- expecting_first_run_auth_needed_event_(false), |
- is_auth_in_progress_(false), |
- ready_to_process_changes_(false), |
- unrecoverable_error_detected_(false), |
- ALLOW_THIS_IN_INITIALIZER_LIST(wizard_(this)) { |
-} |
- |
-ProfileSyncService::~ProfileSyncService() { |
- Shutdown(false); |
-} |
- |
-void ProfileSyncService::Initialize() { |
- InitSettings(); |
- RegisterPreferences(); |
- if (!profile()->GetPrefs()->GetBoolean(prefs::kSyncHasSetupCompleted)) |
- DisableForUser(); // Clean up in case of previous crash / setup abort. |
- else |
- StartUp(); |
-} |
- |
-void ProfileSyncService::InitSettings() { |
- const CommandLine& command_line = *CommandLine::ForCurrentProcess(); |
- |
- // Override the sync server URL from the command-line, if sync server and sync |
- // port command-line arguments exist. |
- if (command_line.HasSwitch(switches::kSyncServiceURL)) { |
- std::wstring value(command_line.GetSwitchValue(switches::kSyncServiceURL)); |
- if (!value.empty()) { |
- GURL custom_sync_url(WideToUTF8(value)); |
- if (custom_sync_url.is_valid()) { |
- sync_service_url_ = custom_sync_url; |
- } else { |
- LOG(WARNING) << "The following sync URL specified at the command-line " |
- << "is invalid: " << value; |
- } |
- } |
- } else { |
- NOTREACHED() << "--sync-url is required when sync is enabled."; |
- } |
- |
- if (command_line.HasSwitch(switches::kSyncServicePort)) { |
- std::string port_str = WideToUTF8(command_line.GetSwitchValue( |
- switches::kSyncServicePort)); |
- if (!port_str.empty()) { |
- GURL::Replacements replacements; |
- replacements.SetPortStr(port_str); |
- sync_service_url_ = sync_service_url_.ReplaceComponents(replacements); |
- } |
- } |
-} |
- |
-void ProfileSyncService::RegisterPreferences() { |
- PrefService* pref_service = profile_->GetPrefs(); |
- if (pref_service->IsPrefRegistered(prefs::kSyncUserName)) |
- return; |
- pref_service->RegisterStringPref(prefs::kSyncUserName, std::wstring()); |
- pref_service->RegisterStringPref(prefs::kSyncLastSyncedTime, std::wstring()); |
- pref_service->RegisterBooleanPref(prefs::kSyncHasSetupCompleted, false); |
-} |
- |
-void ProfileSyncService::LoadPreferences() { |
- PrefService* pref_service = profile_->GetPrefs(); |
- std::wstring last_synced_time_string = |
- pref_service->GetString(prefs::kSyncLastSyncedTime); |
- if (!last_synced_time_string.empty()) { |
- int64 last_synced_time; |
- bool success = StringToInt64(WideToUTF16(last_synced_time_string), |
- &last_synced_time); |
- if (success) { |
- last_synced_time_ = base::Time::FromInternalValue(last_synced_time); |
- } else { |
- NOTREACHED(); |
- } |
- } |
-} |
- |
-void ProfileSyncService::ClearPreferences() { |
- PrefService* pref_service = profile_->GetPrefs(); |
- pref_service->ClearPref(prefs::kSyncUserName); |
- pref_service->ClearPref(prefs::kSyncLastSyncedTime); |
- pref_service->ClearPref(prefs::kSyncHasSetupCompleted); |
- |
- pref_service->ScheduleSavePersistentPrefs(); |
-} |
- |
-void ProfileSyncService::InitializeBackend() { |
- backend_->Initialize(sync_service_url_); |
-} |
- |
-void ProfileSyncService::StartUp() { |
- // Don't start up multiple times. |
- if (backend_.get()) |
- return; |
- |
- LoadPreferences(); |
- |
- backend_.reset(new SyncBackendHost(this, profile_->GetPath())); |
- |
- // We add ourselves as an observer, and we remain one forever. Note we don't |
- // keep any pointer to the model, we just receive notifications from it. |
- BookmarkModel* model = profile_->GetBookmarkModel(); |
- model->AddObserver(this); |
- |
- // Create new model assocation manager. |
- model_associator_ = new ModelAssociator(this); |
- |
- // TODO(timsteele): HttpBridgeFactory should take a const* to the profile's |
- // URLRequestContext, because it needs it to create HttpBridge objects, and |
- // it may need to do that before the default request context has been set |
- // up. For now, call GetRequestContext lazy-init to force creation. |
- profile_->GetRequestContext(); |
- InitializeBackend(); |
-} |
- |
-void ProfileSyncService::Shutdown(bool sync_disabled) { |
- if (backend_.get()) { |
- backend_->Shutdown(sync_disabled); |
- backend_.reset(); |
- } |
- |
- BookmarkModel* model = profile_->GetBookmarkModel(); |
- if (model) |
- model->RemoveObserver(this); |
- |
- // Clear all assocations and throw away the assocation manager instance. |
- if (model_associator_.get()) { |
- model_associator_->ClearAll(); |
- model_associator_ = NULL; |
- } |
- |
- // Clear various flags. |
- is_auth_in_progress_ = false; |
- backend_initialized_ = false; |
- expecting_first_run_auth_needed_event_ = false; |
- ready_to_process_changes_ = false; |
- last_attempted_user_email_.clear(); |
-} |
- |
-void ProfileSyncService::EnableForUser() { |
- if (wizard_.IsVisible()) { |
- // TODO(timsteele): Focus wizard. |
- return; |
- } |
- expecting_first_run_auth_needed_event_ = true; |
- |
- StartUp(); |
- FOR_EACH_OBSERVER(Observer, observers_, OnStateChanged()); |
-} |
- |
-void ProfileSyncService::DisableForUser() { |
- if (wizard_.IsVisible()) { |
- // TODO(timsteele): Focus wizard. |
- return; |
- } |
- Shutdown(true); |
- ClearPreferences(); |
- |
- FOR_EACH_OBSERVER(Observer, observers_, OnStateChanged()); |
-} |
- |
-void ProfileSyncService::Loaded(BookmarkModel* model) { |
- StartProcessingChangesIfReady(); |
-} |
- |
-void ProfileSyncService::UpdateSyncNodeProperties(const BookmarkNode* src, |
- sync_api::WriteNode* dst) { |
- // Set the properties of the item. |
- dst->SetIsFolder(src->is_folder()); |
- dst->SetTitle(WideToUTF16(src->GetTitle()).c_str()); |
- // URL is passed as a C string here because this interface avoids |
- // string16. SetURL copies the data into its own memory. |
- string16 url = UTF8ToUTF16(src->GetURL().spec()); |
- dst->SetURL(url.c_str()); |
- SetSyncNodeFavicon(src, dst); |
-} |
- |
-void ProfileSyncService::EncodeFavicon(const BookmarkNode* src, |
- std::vector<unsigned char>* dst) const { |
- const SkBitmap& favicon = profile_->GetBookmarkModel()->GetFavIcon(src); |
- |
- dst->clear(); |
- |
- // Check for zero-dimension images. This can happen if the favicon is |
- // still being loaded. |
- if (favicon.empty()) |
- return; |
- |
- // Re-encode the BookmarkNode's favicon as a PNG, and pass the data to the |
- // sync subsystem. |
- if (!PNGEncoder::EncodeBGRASkBitmap(favicon, false, dst)) |
- return; |
-} |
- |
-void ProfileSyncService::RemoveOneSyncNode(sync_api::WriteTransaction* trans, |
- const BookmarkNode* node) { |
- sync_api::WriteNode sync_node(trans); |
- if (!model_associator_->InitSyncNodeFromBookmarkId(node->id(), &sync_node)) { |
- SetUnrecoverableError(); |
- return; |
- } |
- // This node should have no children. |
- DCHECK(sync_node.GetFirstChildId() == sync_api::kInvalidId); |
- // Remove association and delete the sync node. |
- model_associator_->DisassociateIds(sync_node.GetId()); |
- sync_node.Remove(); |
-} |
- |
-void ProfileSyncService::RemoveSyncNodeHierarchy(const BookmarkNode* topmost) { |
- sync_api::WriteTransaction trans(backend_->GetUserShareHandle()); |
- |
- // Later logic assumes that |topmost| has been unlinked. |
- DCHECK(!topmost->GetParent()); |
- |
- // A BookmarkModel deletion event means that |node| and all its children were |
- // deleted. Sync backend expects children to be deleted individually, so we do |
- // a depth-first-search here. At each step, we consider the |index|-th child |
- // of |node|. |index_stack| stores index values for the parent levels. |
- std::stack<int> index_stack; |
- index_stack.push(0); // For the final pop. It's never used. |
- const BookmarkNode* node = topmost; |
- int index = 0; |
- while (node) { |
- // The top of |index_stack| should always be |node|'s index. |
- DCHECK(!node->GetParent() || (node->GetParent()->IndexOfChild(node) == |
- index_stack.top())); |
- if (index == node->GetChildCount()) { |
- // If we've processed all of |node|'s children, delete |node| and move |
- // on to its successor. |
- RemoveOneSyncNode(&trans, node); |
- node = node->GetParent(); |
- index = index_stack.top() + 1; // (top() + 0) was what we removed. |
- index_stack.pop(); |
- } else { |
- // If |node| has an unprocessed child, process it next after pushing the |
- // current state onto the stack. |
- DCHECK_LT(index, node->GetChildCount()); |
- index_stack.push(index); |
- node = node->GetChild(index); |
- index = 0; |
- } |
- } |
- DCHECK(index_stack.empty()); // Nothing should be left on the stack. |
-} |
- |
-bool ProfileSyncService::MergeAndSyncAcceptanceNeeded() const { |
- // If we've shown the dialog before, don't show it again. |
- if (profile_->GetPrefs()->GetBoolean(prefs::kSyncHasSetupCompleted)) |
- return false; |
- |
- return model_associator_->BookmarkModelHasUserCreatedNodes() && |
- model_associator_->SyncModelHasUserCreatedNodes(); |
-} |
- |
-bool ProfileSyncService::IsSyncEnabledByUser() const { |
- return profile_->GetPrefs()->GetBoolean(prefs::kSyncHasSetupCompleted); |
-} |
- |
-void ProfileSyncService::UpdateLastSyncedTime() { |
- last_synced_time_ = base::Time::Now(); |
- profile_->GetPrefs()->SetString(prefs::kSyncLastSyncedTime, |
- Int64ToWString(last_synced_time_.ToInternalValue())); |
-} |
- |
-void ProfileSyncService::BookmarkNodeAdded(BookmarkModel* model, |
- const BookmarkNode* parent, |
- int index) { |
- if (!ShouldPushChanges()) |
- return; |
- |
- DCHECK(backend_->GetUserShareHandle()); |
- |
- // Acquire a scoped write lock via a transaction. |
- sync_api::WriteTransaction trans(backend_->GetUserShareHandle()); |
- |
- CreateSyncNode(parent, index, &trans); |
-} |
- |
-int64 ProfileSyncService::CreateSyncNode(const BookmarkNode* parent, |
- int index, |
- sync_api::WriteTransaction* trans) { |
- const BookmarkNode* child = parent->GetChild(index); |
- DCHECK(child); |
- |
- // Create a WriteNode container to hold the new node. |
- sync_api::WriteNode sync_child(trans); |
- |
- // Actually create the node with the appropriate initial position. |
- if (!PlaceSyncNode(CREATE, parent, index, trans, &sync_child)) { |
- LOG(WARNING) << "Sync node creation failed; recovery unlikely"; |
- SetUnrecoverableError(); |
- return sync_api::kInvalidId; |
- } |
- |
- UpdateSyncNodeProperties(child, &sync_child); |
- |
- // Associate the ID from the sync domain with the bookmark node, so that we |
- // can refer back to this item later. |
- model_associator_->AssociateIds(child->id(), sync_child.GetId()); |
- |
- return sync_child.GetId(); |
-} |
- |
-void ProfileSyncService::BookmarkNodeRemoved(BookmarkModel* model, |
- const BookmarkNode* parent, |
- int index, |
- const BookmarkNode* node) { |
- if (!ShouldPushChanges()) |
- return; |
- |
- RemoveSyncNodeHierarchy(node); |
-} |
- |
-void ProfileSyncService::BookmarkNodeChanged(BookmarkModel* model, |
- const BookmarkNode* node) { |
- if (!ShouldPushChanges()) |
- return; |
- |
- // We shouldn't see changes to the top-level nodes. |
- DCHECK_NE(node, model->GetBookmarkBarNode()); |
- DCHECK_NE(node, model->other_node()); |
- |
- // Acquire a scoped write lock via a transaction. |
- sync_api::WriteTransaction trans(backend_->GetUserShareHandle()); |
- |
- // Lookup the sync node that's associated with |node|. |
- sync_api::WriteNode sync_node(&trans); |
- if (!model_associator_->InitSyncNodeFromBookmarkId(node->id(), &sync_node)) { |
- SetUnrecoverableError(); |
- return; |
- } |
- |
- UpdateSyncNodeProperties(node, &sync_node); |
- |
- DCHECK_EQ(sync_node.GetIsFolder(), node->is_folder()); |
- DCHECK_EQ(model_associator_->GetBookmarkNodeFromSyncId( |
- sync_node.GetParentId()), |
- node->GetParent()); |
- // This node's index should be one more than the predecessor's index. |
- DCHECK_EQ(node->GetParent()->IndexOfChild(node), |
- CalculateBookmarkModelInsertionIndex(node->GetParent(), |
- &sync_node)); |
-} |
- |
-void ProfileSyncService::BookmarkNodeMoved(BookmarkModel* model, |
- const BookmarkNode* old_parent, |
- int old_index, |
- const BookmarkNode* new_parent, |
- int new_index) { |
- if (!ShouldPushChanges()) |
- return; |
- |
- const BookmarkNode* child = new_parent->GetChild(new_index); |
- // We shouldn't see changes to the top-level nodes. |
- DCHECK_NE(child, model->GetBookmarkBarNode()); |
- DCHECK_NE(child, model->other_node()); |
- |
- // Acquire a scoped write lock via a transaction. |
- sync_api::WriteTransaction trans(backend_->GetUserShareHandle()); |
- |
- // Lookup the sync node that's associated with |child|. |
- sync_api::WriteNode sync_node(&trans); |
- if (!model_associator_->InitSyncNodeFromBookmarkId(child->id(), |
- &sync_node)) { |
- SetUnrecoverableError(); |
- return; |
- } |
- |
- if (!PlaceSyncNode(MOVE, new_parent, new_index, &trans, &sync_node)) { |
- SetUnrecoverableError(); |
- return; |
- } |
-} |
- |
-void ProfileSyncService::BookmarkNodeFavIconLoaded(BookmarkModel* model, |
- const BookmarkNode* node) { |
- BookmarkNodeChanged(model, node); |
-} |
- |
-void ProfileSyncService::BookmarkNodeChildrenReordered( |
- BookmarkModel* model, const BookmarkNode* node) { |
- if (!ShouldPushChanges()) |
- return; |
- |
- // Acquire a scoped write lock via a transaction. |
- sync_api::WriteTransaction trans(backend_->GetUserShareHandle()); |
- |
- // The given node's children got reordered. We need to reorder all the |
- // children of the corresponding sync node. |
- for (int i = 0; i < node->GetChildCount(); ++i) { |
- sync_api::WriteNode sync_child(&trans); |
- if (!model_associator_->InitSyncNodeFromBookmarkId(node->GetChild(i)->id(), |
- &sync_child)) { |
- SetUnrecoverableError(); |
- return; |
- } |
- DCHECK_EQ(sync_child.GetParentId(), |
- model_associator_->GetSyncIdFromBookmarkId(node->id())); |
- |
- if (!PlaceSyncNode(MOVE, node, i, &trans, &sync_child)) { |
- SetUnrecoverableError(); |
- return; |
- } |
- } |
-} |
- |
-bool ProfileSyncService::PlaceSyncNode(MoveOrCreate operation, |
- const BookmarkNode* parent, |
- int index, |
- sync_api::WriteTransaction* trans, |
- sync_api::WriteNode* dst) { |
- sync_api::ReadNode sync_parent(trans); |
- if (!model_associator_->InitSyncNodeFromBookmarkId(parent->id(), |
- &sync_parent)) { |
- LOG(WARNING) << "Parent lookup failed"; |
- SetUnrecoverableError(); |
- return false; |
- } |
- |
- bool success = false; |
- if (index == 0) { |
- // Insert into first position. |
- success = (operation == CREATE) ? dst->InitByCreation(sync_parent, NULL) : |
- dst->SetPosition(sync_parent, NULL); |
- if (success) { |
- DCHECK_EQ(dst->GetParentId(), sync_parent.GetId()); |
- DCHECK_EQ(dst->GetId(), sync_parent.GetFirstChildId()); |
- DCHECK_EQ(dst->GetPredecessorId(), sync_api::kInvalidId); |
- } |
- } else { |
- // Find the bookmark model predecessor, and insert after it. |
- const BookmarkNode* prev = parent->GetChild(index - 1); |
- sync_api::ReadNode sync_prev(trans); |
- if (!model_associator_->InitSyncNodeFromBookmarkId(prev->id(), |
- &sync_prev)) { |
- LOG(WARNING) << "Predecessor lookup failed"; |
- return false; |
- } |
- success = (operation == CREATE) ? |
- dst->InitByCreation(sync_parent, &sync_prev) : |
- dst->SetPosition(sync_parent, &sync_prev); |
- if (success) { |
- DCHECK_EQ(dst->GetParentId(), sync_parent.GetId()); |
- DCHECK_EQ(dst->GetPredecessorId(), sync_prev.GetId()); |
- DCHECK_EQ(dst->GetId(), sync_prev.GetSuccessorId()); |
- } |
- } |
- return success; |
-} |
- |
-// An invariant has been violated. Transition to an error state where we try |
-// to do as little work as possible, to avoid further corruption or crashes. |
-void ProfileSyncService::SetUnrecoverableError() { |
- unrecoverable_error_detected_ = true; |
- LOG(ERROR) << "Unrecoverable error detected -- ProfileSyncService unusable."; |
-} |
- |
-// Determine the bookmark model index to which a node must be moved so that |
-// predecessor of the node (in the bookmark model) matches the predecessor of |
-// |source| (in the sync model). |
-// As a precondition, this assumes that the predecessor of |source| has been |
-// updated and is already in the correct position in the bookmark model. |
-int ProfileSyncService::CalculateBookmarkModelInsertionIndex( |
- const BookmarkNode* parent, |
- const sync_api::BaseNode* child_info) const { |
- DCHECK(parent); |
- DCHECK(child_info); |
- int64 predecessor_id = child_info->GetPredecessorId(); |
- // A return ID of kInvalidId indicates no predecessor. |
- if (predecessor_id == sync_api::kInvalidId) |
- return 0; |
- |
- // Otherwise, insert after the predecessor bookmark node. |
- const BookmarkNode* predecessor = |
- model_associator_->GetBookmarkNodeFromSyncId(predecessor_id); |
- DCHECK(predecessor); |
- DCHECK_EQ(predecessor->GetParent(), parent); |
- return parent->IndexOfChild(predecessor) + 1; |
-} |
- |
-void ProfileSyncService::OnBackendInitialized() { |
- backend_initialized_ = true; |
- |
- PrefService* pref_service = profile_->GetPrefs(); |
- DCHECK(pref_service->IsPrefRegistered(prefs::kSyncUserName)); |
- pref_service->SetString(prefs::kSyncUserName, |
- UTF16ToWide(backend_->GetAuthenticatedUsername())); |
- StartProcessingChangesIfReady(); |
- |
- // The very first time the backend initializes is effectively the first time |
- // we can say we successfully "synced". last_synced_time_ will only be null |
- // in this case, because the pref wasn't restored on StartUp. |
- if (last_synced_time_.is_null()) |
- UpdateLastSyncedTime(); |
- FOR_EACH_OBSERVER(Observer, observers_, OnStateChanged()); |
-} |
- |
-void ProfileSyncService::OnSyncCycleCompleted() { |
- UpdateLastSyncedTime(); |
- FOR_EACH_OBSERVER(Observer, observers_, OnStateChanged()); |
-} |
- |
-void ProfileSyncService::OnAuthError() { |
- last_auth_error_ = backend_->GetAuthErrorState(); |
- // Protect against the in-your-face dialogs that pop out of nowhere. |
- // Require the user to click somewhere to run the setup wizard in the case |
- // of a steady-state auth failure. |
- if (wizard_.IsVisible() || expecting_first_run_auth_needed_event_) { |
- wizard_.Step(AUTH_ERROR_NONE == backend_->GetAuthErrorState() ? |
- SyncSetupWizard::GAIA_SUCCESS : SyncSetupWizard::GAIA_LOGIN); |
- } |
- |
- if (expecting_first_run_auth_needed_event_) { |
- last_auth_error_ = AUTH_ERROR_NONE; |
- expecting_first_run_auth_needed_event_ = false; |
- } |
- |
- is_auth_in_progress_ = false; |
- // Fan the notification out to interested UI-thread components. |
- FOR_EACH_OBSERVER(Observer, observers_, OnStateChanged()); |
-} |
- |
-void ProfileSyncService::ShowLoginDialog() { |
- if (wizard_.IsVisible()) |
- return; |
- if (last_auth_error_ != AUTH_ERROR_NONE) |
- wizard_.Step(SyncSetupWizard::GAIA_LOGIN); |
-} |
- |
-// ApplyModelChanges is called by the sync backend after changes have been made |
-// to the sync engine's model. Apply these changes to the browser bookmark |
-// model. |
-void ProfileSyncService::ApplyModelChanges( |
- const sync_api::BaseTransaction* trans, |
- const sync_api::SyncManager::ChangeRecord* changes, |
- int change_count) { |
- if (!ShouldPushChanges()) |
- return; |
- |
- // A note about ordering. Sync backend is responsible for ordering the change |
- // records in the following order: |
- // |
- // 1. Deletions, from leaves up to parents. |
- // 2. Existing items with synced parents & predecessors. |
- // 3. New items with synced parents & predecessors. |
- // 4. Items with parents & predecessors in the list. |
- // 5. Repeat #4 until all items are in the list. |
- // |
- // "Predecessor" here means the previous item within a given folder; an item |
- // in the first position is always said to have a synced predecessor. |
- // For the most part, applying these changes in the order given will yield |
- // the correct result. There is one exception, however: for items that are |
- // moved away from a folder that is being deleted, we will process the delete |
- // before the move. Since deletions in the bookmark model propagate from |
- // parent to child, we must move them to a temporary location. |
- BookmarkModel* model = profile_->GetBookmarkModel(); |
- |
- // We are going to make changes to the bookmarks model, but don't want to end |
- // up in a feedback loop, so remove ourselves as an observer while applying |
- // changes. |
- model->RemoveObserver(this); |
- |
- // A parent to hold nodes temporarily orphaned by parent deletion. It is |
- // lazily created inside the loop. |
- const BookmarkNode* foster_parent = NULL; |
- for (int i = 0; i < change_count; ++i) { |
- const BookmarkNode* dst = |
- model_associator_->GetBookmarkNodeFromSyncId(changes[i].id); |
- // Ignore changes to the permanent top-level nodes. We only care about |
- // their children. |
- if ((dst == model->GetBookmarkBarNode()) || (dst == model->other_node())) |
- continue; |
- if (changes[i].action == |
- sync_api::SyncManager::ChangeRecord::ACTION_DELETE) { |
- // Deletions should always be at the front of the list. |
- DCHECK(i == 0 || changes[i-1].action == changes[i].action); |
- // Children of a deleted node should not be deleted; they may be |
- // reparented by a later change record. Move them to a temporary place. |
- DCHECK(dst) << "Could not find node to be deleted"; |
- const BookmarkNode* parent = dst->GetParent(); |
- if (dst->GetChildCount()) { |
- if (!foster_parent) { |
- foster_parent = model->AddGroup(model->other_node(), |
- model->other_node()->GetChildCount(), |
- std::wstring()); |
- } |
- for (int i = dst->GetChildCount() - 1; i >= 0; --i) { |
- model->Move(dst->GetChild(i), foster_parent, |
- foster_parent->GetChildCount()); |
- } |
- } |
- DCHECK_EQ(dst->GetChildCount(), 0) << "Node being deleted has children"; |
- model->Remove(parent, parent->IndexOfChild(dst)); |
- dst = NULL; |
- model_associator_->DisassociateIds(changes[i].id); |
- } else { |
- DCHECK_EQ((changes[i].action == |
- sync_api::SyncManager::ChangeRecord::ACTION_ADD), (dst == NULL)) |
- << "ACTION_ADD should be seen if and only if the node is unknown."; |
- |
- sync_api::ReadNode src(trans); |
- if (!src.InitByIdLookup(changes[i].id)) { |
- LOG(ERROR) << "ApplyModelChanges was passed a bad ID"; |
- SetUnrecoverableError(); |
- return; |
- } |
- |
- CreateOrUpdateBookmarkNode(&src, model); |
- } |
- } |
- // Clean up the temporary node. |
- if (foster_parent) { |
- // There should be no nodes left under the foster parent. |
- DCHECK_EQ(foster_parent->GetChildCount(), 0); |
- model->Remove(foster_parent->GetParent(), |
- foster_parent->GetParent()->IndexOfChild(foster_parent)); |
- foster_parent = NULL; |
- } |
- |
- // We are now ready to hear about bookmarks changes again. |
- model->AddObserver(this); |
-} |
- |
-// Create a bookmark node corresponding to |src| if one is not already |
-// associated with |src|. |
-const BookmarkNode* ProfileSyncService::CreateOrUpdateBookmarkNode( |
- sync_api::BaseNode* src, |
- BookmarkModel* model) { |
- const BookmarkNode* parent = |
- model_associator_->GetBookmarkNodeFromSyncId(src->GetParentId()); |
- if (!parent) { |
- DLOG(WARNING) << "Could not find parent of node being added/updated." |
- << " Node title: " << src->GetTitle() |
- << ", parent id = " << src->GetParentId(); |
- return NULL; |
- } |
- int index = CalculateBookmarkModelInsertionIndex(parent, src); |
- const BookmarkNode* dst = model_associator_->GetBookmarkNodeFromSyncId( |
- src->GetId()); |
- if (!dst) { |
- dst = CreateBookmarkNode(src, parent, index); |
- model_associator_->AssociateIds(dst->id(), src->GetId()); |
- } else { |
- // URL and is_folder are not expected to change. |
- // TODO(ncarter): Determine if such changes should be legal or not. |
- DCHECK_EQ(src->GetIsFolder(), dst->is_folder()); |
- |
- // Handle reparenting and/or repositioning. |
- model->Move(dst, parent, index); |
- |
- // Handle title update and URL changes due to possible conflict resolution |
- // that can happen if both a local user change and server change occur |
- // within a sufficiently small time interval. |
- const BookmarkNode* old_dst = dst; |
- dst = bookmark_utils::ApplyEditsWithNoGroupChange(model, parent, dst, |
- UTF16ToWide(src->GetTitle()), |
- src->GetIsFolder() ? GURL() : GURL(src->GetURL()), |
- NULL); // NULL because we don't need a BookmarkEditor::Handler. |
- if (dst != old_dst) { // dst was replaced with a new node with new URL. |
- model_associator_->DisassociateIds(src->GetId()); |
- model_associator_->AssociateIds(dst->id(), src->GetId()); |
- } |
- SetBookmarkFavicon(src, dst); |
- } |
- |
- return dst; |
-} |
- |
-// Creates a bookmark node under the given parent node from the given sync |
-// node. Returns the newly created node. |
-const BookmarkNode* ProfileSyncService::CreateBookmarkNode( |
- sync_api::BaseNode* sync_node, |
- const BookmarkNode* parent, |
- int index) const { |
- DCHECK(parent); |
- DCHECK(index >= 0 && index <= parent->GetChildCount()); |
- BookmarkModel* model = profile_->GetBookmarkModel(); |
- |
- const BookmarkNode* node; |
- if (sync_node->GetIsFolder()) { |
- node = model->AddGroup(parent, index, UTF16ToWide(sync_node->GetTitle())); |
- } else { |
- GURL url(sync_node->GetURL()); |
- node = model->AddURL(parent, index, UTF16ToWide(sync_node->GetTitle()), url); |
- SetBookmarkFavicon(sync_node, node); |
- } |
- return node; |
-} |
- |
-// Sets the favicon of the given bookmark node from the given sync node. |
-bool ProfileSyncService::SetBookmarkFavicon( |
- sync_api::BaseNode* sync_node, |
- const BookmarkNode* bookmark_node) const { |
- size_t icon_size = 0; |
- const unsigned char* icon_bytes = sync_node->GetFaviconBytes(&icon_size); |
- if (!icon_size || !icon_bytes) |
- return false; |
- |
- // Registering a favicon requires that we provide a source URL, but we |
- // don't know where these came from. Currently we just use the |
- // destination URL, which is not correct, but since the favicon URL |
- // is used as a key in the history's thumbnail DB, this gives us a value |
- // which does not collide with others. |
- GURL fake_icon_url = bookmark_node->GetURL(); |
- |
- std::vector<unsigned char> icon_bytes_vector(icon_bytes, |
- icon_bytes + icon_size); |
- |
- HistoryService* history = |
- profile_->GetHistoryService(Profile::EXPLICIT_ACCESS); |
- |
- history->AddPage(bookmark_node->GetURL()); |
- history->SetFavIcon(bookmark_node->GetURL(), |
- fake_icon_url, |
- icon_bytes_vector); |
- |
- return true; |
-} |
- |
-void ProfileSyncService::SetSyncNodeFavicon( |
- const BookmarkNode* bookmark_node, |
- sync_api::WriteNode* sync_node) const { |
- std::vector<unsigned char> favicon_bytes; |
- EncodeFavicon(bookmark_node, &favicon_bytes); |
- if (!favicon_bytes.empty()) |
- sync_node->SetFaviconBytes(&favicon_bytes[0], favicon_bytes.size()); |
-} |
- |
-SyncBackendHost::StatusSummary ProfileSyncService::QuerySyncStatusSummary() { |
- return backend_->GetStatusSummary(); |
-} |
- |
-SyncBackendHost::Status ProfileSyncService::QueryDetailedSyncStatus() { |
- return backend_->GetDetailedStatus(); |
-} |
- |
-std::wstring ProfileSyncService::BuildSyncStatusSummaryText( |
- const sync_api::SyncManager::Status::Summary& summary) { |
- switch (summary) { |
- case sync_api::SyncManager::Status::OFFLINE: |
- return L"OFFLINE"; |
- case sync_api::SyncManager::Status::OFFLINE_UNSYNCED: |
- return L"OFFLINE_UNSYNCED"; |
- case sync_api::SyncManager::Status::SYNCING: |
- return L"SYNCING"; |
- case sync_api::SyncManager::Status::READY: |
- return L"READY"; |
- case sync_api::SyncManager::Status::PAUSED: |
- return L"PAUSED"; |
- case sync_api::SyncManager::Status::CONFLICT: |
- return L"CONFLICT"; |
- case sync_api::SyncManager::Status::OFFLINE_UNUSABLE: |
- return L"OFFLINE_UNUSABLE"; |
- case sync_api::SyncManager::Status::INVALID: // fall through |
- default: |
- return L"UNKNOWN"; |
- } |
-} |
- |
-std::wstring ProfileSyncService::GetLastSyncedTimeString() const { |
- if (last_synced_time_.is_null()) |
- return kLastSyncedTimeNever; |
- |
- base::TimeDelta last_synced = base::Time::Now() - last_synced_time_; |
- |
- if (last_synced < base::TimeDelta::FromMinutes(1)) |
- return kLastSyncedTimeWithinLastMinute; |
- |
- return TimeFormat::TimeElapsed(last_synced); |
-} |
- |
-string16 ProfileSyncService::GetAuthenticatedUsername() const { |
- return backend_->GetAuthenticatedUsername(); |
-} |
- |
-void ProfileSyncService::OnUserSubmittedAuth( |
- const std::string& username, const std::string& password) { |
- last_attempted_user_email_ = username; |
- is_auth_in_progress_ = true; |
- FOR_EACH_OBSERVER(Observer, observers_, OnStateChanged()); |
- backend_->Authenticate(username, password); |
-} |
- |
-void ProfileSyncService::OnUserAcceptedMergeAndSync() { |
- bool merge_success = model_associator_->AssociateModels(); |
- wizard_.Step(SyncSetupWizard::DONE); // TODO(timsteele): error state? |
- if (!merge_success) { |
- LOG(ERROR) << "Model assocation failed."; |
- SetUnrecoverableError(); |
- return; |
- } |
- |
- ready_to_process_changes_ = true; |
- FOR_EACH_OBSERVER(Observer, observers_, OnStateChanged()); |
-} |
- |
-void ProfileSyncService::OnUserCancelledDialog() { |
- if (!profile_->GetPrefs()->GetBoolean(prefs::kSyncHasSetupCompleted)) { |
- // A sync dialog was aborted before authentication or merge acceptance. |
- // Rollback. |
- DisableForUser(); |
- } |
- FOR_EACH_OBSERVER(Observer, observers_, OnStateChanged()); |
-} |
- |
-void ProfileSyncService::StartProcessingChangesIfReady() { |
- BookmarkModel* model = profile_->GetBookmarkModel(); |
- |
- DCHECK(!ready_to_process_changes_); |
- |
- // First check if the subsystems are ready. We can't proceed until they |
- // both have finished loading. |
- if (!model->IsLoaded()) |
- return; |
- if (!backend_initialized_) |
- return; |
- |
- // Show the sync merge warning dialog if needed. |
- if (MergeAndSyncAcceptanceNeeded()) { |
- wizard_.Step(SyncSetupWizard::MERGE_AND_SYNC); |
- return; |
- } |
- |
- // We're ready to merge the models. |
- bool merge_success = model_associator_->AssociateModels(); |
- wizard_.Step(SyncSetupWizard::DONE); // TODO(timsteele): error state? |
- if (!merge_success) { |
- LOG(ERROR) << "Model assocation failed."; |
- SetUnrecoverableError(); |
- return; |
- } |
- |
- ready_to_process_changes_ = true; |
- FOR_EACH_OBSERVER(Observer, observers_, OnStateChanged()); |
-} |
- |
-void ProfileSyncService::AddObserver(Observer* observer) { |
- observers_.AddObserver(observer); |
-} |
- |
-void ProfileSyncService::RemoveObserver(Observer* observer) { |
- observers_.RemoveObserver(observer); |
-} |
- |
-bool ProfileSyncService::ShouldPushChanges() { |
- return ready_to_process_changes_ && // Wait for model load and merge. |
- !unrecoverable_error_detected_; // Halt after any terrible events. |
-} |
- |
-#endif // CHROME_PERSONALIZATION |