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