diff options
Diffstat (limited to 'chrome/browser/sync/profile_sync_service.cc')
| -rw-r--r-- | chrome/browser/sync/profile_sync_service.cc | 886 |
1 files changed, 0 insertions, 886 deletions
diff --git a/chrome/browser/sync/profile_sync_service.cc b/chrome/browser/sync/profile_sync_service.cc deleted file mode 100644 index e596e28..0000000 --- a/chrome/browser/sync/profile_sync_service.cc +++ /dev/null @@ -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 |