| 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
|
|
|