blob: 58ad6d37a9e861b0d6530c14af11ebbe038357ee [file] [log] [blame]
// Copyright (c) 2012 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.
#include <memory>
#include <set>
#include <string>
#include <vector>
#include "base/compiler_specific.h"
#include "base/files/file_path.h"
#include "base/gtest_prod_util.h"
#include "base/location.h"
#include "base/macros.h"
#include "base/memory/memory_pressure_listener.h"
#include "base/memory/weak_ptr.h"
#include "base/message_loop/message_loop.h"
#include "base/observer_list.h"
#include "base/strings/string16.h"
#include "base/threading/sequenced_worker_pool.h"
#include "base/threading/thread.h"
#include "base/time/time.h"
#include "base/timer/timer.h"
#include "build/build_config.h"
#include "components/signin/core/browser/gaia_cookie_manager_service.h"
#include "components/signin/core/browser/signin_manager_base.h"
#include "components/sync/base/experiments.h"
#include "components/sync/base/model_type.h"
#include "components/sync/base/sync_prefs.h"
#include "components/sync/base/unrecoverable_error_handler.h"
#include "components/sync/device_info/local_device_info_provider.h"
#include "components/sync/driver/data_type_controller.h"
#include "components/sync/driver/data_type_manager.h"
#include "components/sync/driver/data_type_manager_observer.h"
#include "components/sync/driver/data_type_status_table.h"
#include "components/sync/driver/startup_controller.h"
#include "components/sync/driver/sync_client.h"
#include "components/sync/driver/sync_service_base.h"
#include "components/sync/driver/sync_stopped_reporter.h"
#include "components/sync/engine/events/protocol_event_observer.h"
#include "components/sync/engine/model_safe_worker.h"
#include "components/sync/engine/net/network_time_update_callback.h"
#include "components/sync/engine/shutdown_reason.h"
#include "components/sync/engine/sync_engine.h"
#include "components/sync/engine/sync_engine_host.h"
#include "components/sync/engine/sync_manager_factory.h"
#include "components/sync/js/sync_js_controller.h"
#include "components/sync/model/model_type_store.h"
#include "components/sync/syncable/user_share.h"
#include "components/version_info/version_info.h"
#include "google_apis/gaia/google_service_auth_error.h"
#include "google_apis/gaia/oauth2_token_service.h"
#include "net/base/backoff_entry.h"
#include "url/gurl.h"
class ProfileOAuth2TokenService;
class SigninManagerWrapper;
namespace sync_sessions {
class FaviconCache;
class OpenTabsUIDelegate;
class SessionsSyncManager;
} // namespace sync_sessions
namespace syncer {
class BackendMigrator;
class BaseTransaction;
class DataTypeManager;
class DeviceInfoSyncBridge;
class DeviceInfoSyncService;
class DeviceInfoTracker;
class LocalDeviceInfoProvider;
class NetworkResources;
class SyncClient;
class SyncErrorController;
class SyncTypePreferenceProvider;
class TypeDebugInfoObserver;
struct CommitCounters;
struct StatusCounters;
struct SyncCredentials;
struct UpdateCounters;
struct UserShare;
} // namespace syncer
namespace browser_sync {
// ProfileSyncService is the layer between browser subsystems like bookmarks,
// and the sync engine. Each subsystem is logically thought of as being a sync
// datatype. Individual datatypes can, at any point, be in a variety of stages
// of being "enabled". Here are some specific terms for concepts used in this
// class:
// 'Registered' (feature suppression for a datatype)
// When a datatype is registered, the user has the option of syncing it.
// The sync opt-in UI will show only registered types; a checkbox should
// never be shown for an unregistered type, and nor should it ever be
// synced.
// A datatype is considered registered once RegisterDataTypeController
// has been called with that datatype's DataTypeController.
// 'Preferred' (user preferences and opt-out for a datatype)
// This means the user's opt-in or opt-out preference on a per-datatype
// basis. The sync service will try to make active exactly these types.
// If a user has opted out of syncing a particular datatype, it will
// be registered, but not preferred.
// This state is controlled by the ConfigurePreferredDataTypes and
// GetPreferredDataTypes. They are stored in the preferences system,
// and persist; though if a datatype is not registered, it cannot
// be a preferred datatype.
// 'Active' (run-time initialization of sync system for a datatype)
// An active datatype is a preferred datatype that is actively being
// synchronized: the syncer has been instructed to querying the server
// for this datatype, first-time merges have finished, and there is an
// actively installed ChangeProcessor that listens for changes to this
// datatype, propagating such changes into and out of the sync engine
// as necessary.
// When a datatype is in the process of becoming active, it may be
// in some intermediate state. Those finer-grained intermediate states
// are differentiated by the DataTypeController state.
// Sync Configuration:
// Sync configuration is accomplished via the following APIs:
// * OnUserChoseDatatypes(): Set the data types the user wants to sync.
// * SetDecryptionPassphrase(): Attempt to decrypt the user's encrypted data
// using the passed passphrase.
// * SetEncryptionPassphrase(): Re-encrypt the user's data using the passed
// passphrase.
// Additionally, the current sync configuration can be fetched by calling
// * GetRegisteredDataTypes()
// * GetPreferredDataTypes()
// * GetActiveDataTypes()
// * IsUsingSecondaryPassphrase()
// * IsEncryptEverythingEnabled()
// * IsPassphraseRequired()/IsPassphraseRequiredForDecryption()
// The "sync everything" state cannot be read from ProfileSyncService, but
// is instead pulled from SyncPrefs.HasKeepEverythingSynced().
// Initial sync setup:
// For privacy reasons, it is usually desirable to avoid syncing any data
// types until the user has finished setting up sync. There are two APIs
// that control the initial sync download:
// * SetFirstSetupComplete()
// * GetSetupInProgressHandle()
// SetFirstSetupComplete() should be called once the user has finished setting
// up sync at least once on their account. GetSetupInProgressHandle() should
// be called while the user is actively configuring their account. The handle
// should be deleted once configuration is complete.
// Once first setup has completed and there are no outstanding
// setup-in-progress handles, CanConfigureDataTypes() will return true and
// datatype configuration can begin.
class ProfileSyncService : public syncer::SyncServiceBase,
public syncer::SyncPrefObserver,
public syncer::DataTypeManagerObserver,
public syncer::UnrecoverableErrorHandler,
public OAuth2TokenService::Consumer,
public OAuth2TokenService::Observer,
public SigninManagerBase::Observer,
public GaiaCookieManagerService::Observer {
using Status = syncer::SyncEngine::Status;
using PlatformSyncAllowedProvider = base::Callback<bool(void)>;
enum SyncEventCodes {
// Events starting the sync service.
START_FROM_NTP = 1, // Sync was started from the ad in NTP
START_FROM_WRENCH = 2, // Sync was started from the Wrench menu.
START_FROM_OPTIONS = 3, // Sync was started from Wrench->Options.
START_FROM_BOOKMARK_MANAGER = 4, // Sync was started from Bookmark manager.
START_FROM_PROFILE_MENU = 5, // Sync was started from multiprofile menu.
START_FROM_URL = 6, // Sync was started from a typed URL.
// Events regarding cancellation of the signon process of sync.
CANCEL_FROM_SIGNON_WITHOUT_AUTH = 10, // Cancelled before submitting
// username and password.
CANCEL_DURING_SIGNON = 11, // Cancelled after auth.
CANCEL_DURING_CONFIGURE = 12, // Cancelled before choosing data
// types and clicking OK.
// Events resulting in the stoppage of sync service.
STOP_FROM_OPTIONS = 20, // Sync was stopped from Wrench->Options.
STOP_FROM_ADVANCED_DIALOG = 21, // Sync was stopped via advanced settings.
// Miscellaneous events caused by sync service.
enum SyncStatusSummary {
// If AUTO_START, sync will set IsFirstSetupComplete() automatically and sync
// will begin syncing without the user needing to confirm sync settings.
enum StartBehavior {
// Bundles the arguments for ProfileSyncService construction. This is a
// movable struct. Because of the non-POD data members, it needs out-of-line
// constructors, so in particular the move constructor needs to be
// explicitly defined.
struct InitParams {
InitParams(InitParams&& other);
std::unique_ptr<syncer::SyncClient> sync_client;
std::unique_ptr<SigninManagerWrapper> signin_wrapper;
ProfileOAuth2TokenService* oauth2_token_service = nullptr;
GaiaCookieManagerService* gaia_cookie_manager_service = nullptr;
StartBehavior start_behavior = MANUAL_START;
syncer::NetworkTimeUpdateCallback network_time_update_callback;
base::FilePath base_directory;
scoped_refptr<net::URLRequestContextGetter> url_request_context;
std::string debug_identifier;
version_info::Channel channel = version_info::Channel::UNKNOWN;
explicit ProfileSyncService(InitParams init_params);
~ProfileSyncService() override;
// Initializes the object. This must be called at most once, and
// immediately after an object of this class is constructed.
void Initialize();
// syncer::SyncService implementation
bool IsFirstSetupComplete() const override;
bool IsSyncAllowed() const override;
bool IsSyncActive() const override;
bool IsLocalSyncEnabled() const override;
void TriggerRefresh(const syncer::ModelTypeSet& types) override;
void OnDataTypeRequestsSyncStartup(syncer::ModelType type) override;
bool CanSyncStart() const override;
void RequestStop(SyncStopDataFate data_fate) override;
void RequestStart() override;
syncer::ModelTypeSet GetActiveDataTypes() const override;
syncer::SyncClient* GetSyncClient() const override;
syncer::ModelTypeSet GetPreferredDataTypes() const override;
void OnUserChoseDatatypes(bool sync_everything,
syncer::ModelTypeSet chosen_types) override;
void SetFirstSetupComplete() override;
bool IsFirstSetupInProgress() const override;
std::unique_ptr<syncer::SyncSetupInProgressHandle> GetSetupInProgressHandle()
bool IsSetupInProgress() const override;
bool ConfigurationDone() const override;
const GoogleServiceAuthError& GetAuthError() const override;
bool HasUnrecoverableError() const override;
bool IsEngineInitialized() const override;
sync_sessions::OpenTabsUIDelegate* GetOpenTabsUIDelegate() override;
bool IsPassphraseRequiredForDecryption() const override;
base::Time GetExplicitPassphraseTime() const override;
bool IsUsingSecondaryPassphrase() const override;
void EnableEncryptEverything() override;
bool IsEncryptEverythingEnabled() const override;
void SetEncryptionPassphrase(const std::string& passphrase,
PassphraseType type) override;
bool SetDecryptionPassphrase(const std::string& passphrase) override
bool IsCryptographerReady(
const syncer::BaseTransaction* trans) const override;
syncer::UserShare* GetUserShare() const override;
syncer::LocalDeviceInfoProvider* GetLocalDeviceInfoProvider() const override;
void RegisterDataTypeController(std::unique_ptr<syncer::DataTypeController>
data_type_controller) override;
void ReenableDatatype(syncer::ModelType type) override;
SyncTokenStatus GetSyncTokenStatus() const override;
std::string QuerySyncStatusSummaryString() override;
bool QueryDetailedSyncStatus(syncer::SyncStatus* result) override;
base::string16 GetLastSyncedTimeString() const override;
std::string GetEngineInitializationStateString() const override;
syncer::SyncCycleSnapshot GetLastCycleSnapshot() const override;
std::unique_ptr<base::Value> GetTypeStatusMap() override;
const GURL& sync_service_url() const override;
std::string unrecoverable_error_message() const override;
tracked_objects::Location unrecoverable_error_location() const override;
void AddProtocolEventObserver(
syncer::ProtocolEventObserver* observer) override;
void RemoveProtocolEventObserver(
syncer::ProtocolEventObserver* observer) override;
void AddTypeDebugInfoObserver(
syncer::TypeDebugInfoObserver* observer) override;
void RemoveTypeDebugInfoObserver(
syncer::TypeDebugInfoObserver* observer) override;
base::WeakPtr<syncer::JsController> GetJsController() override;
void GetAllNodes(const base::Callback<void(std::unique_ptr<base::ListValue>)>&
callback) override;
syncer::GlobalIdMapper* GetGlobalIdMapper() const override;
// Add a sync type preference provider. Each provider may only be added once.
void AddPreferenceProvider(syncer::SyncTypePreferenceProvider* provider);
// Remove a sync type preference provider. May only be called for providers
// that have been added. Providers must not remove themselves while being
// called back.
void RemovePreferenceProvider(syncer::SyncTypePreferenceProvider* provider);
// Check whether a given sync type preference provider has been added.
bool HasPreferenceProvider(
syncer::SyncTypePreferenceProvider* provider) const;
void RegisterAuthNotifications();
void UnregisterAuthNotifications();
// Returns the SyncableService for syncer::SESSIONS.
virtual syncer::SyncableService* GetSessionsSyncableService();
// Returns the SyncableService for syncer::DEVICE_INFO.
virtual syncer::SyncableService* GetDeviceInfoSyncableService();
// Returns the ModelTypeSyncBridge for syncer::DEVICE_INFO.
virtual syncer::ModelTypeSyncBridge* GetDeviceInfoSyncBridge();
// Returns synced devices tracker.
virtual syncer::DeviceInfoTracker* GetDeviceInfoTracker() const;
// Fills state_map with a map of current data types that are possible to
// sync, as well as their states.
void GetDataTypeControllerStates(
syncer::DataTypeController::StateMap* state_map) const;
// Called when asynchronous session restore has completed.
void OnSessionRestoreComplete();
// SyncEngineHost implementation.
void OnEngineInitialized(
syncer::ModelTypeSet initial_types,
const syncer::WeakHandle<syncer::JsBackend>& js_backend,
const syncer::WeakHandle<syncer::DataTypeDebugInfoListener>&
const std::string& cache_guid,
bool success) override;
void OnSyncCycleCompleted(const syncer::SyncCycleSnapshot& snapshot) override;
void OnProtocolEvent(const syncer::ProtocolEvent& event) override;
void OnDirectoryTypeCommitCounterUpdated(
syncer::ModelType type,
const syncer::CommitCounters& counters) override;
void OnDirectoryTypeUpdateCounterUpdated(
syncer::ModelType type,
const syncer::UpdateCounters& counters) override;
void OnDatatypeStatusCounterUpdated(
syncer::ModelType type,
const syncer::StatusCounters& counters) override;
void OnConnectionStatusChange(syncer::ConnectionStatus status) override;
void OnMigrationNeededForTypes(syncer::ModelTypeSet types) override;
void OnExperimentsChanged(const syncer::Experiments& experiments) override;
void OnActionableError(const syncer::SyncProtocolError& error) override;
// DataTypeManagerObserver implementation.
void OnConfigureDone(
const syncer::DataTypeManager::ConfigureResult& result) override;
void OnConfigureStart() override;
// DataTypeEncryptionHandler implementation.
bool IsPassphraseRequired() const override;
syncer::ModelTypeSet GetEncryptedDataTypes() const override;
// SigninManagerBase::Observer implementation.
void GoogleSigninSucceeded(const std::string& account_id,
const std::string& username) override;
void GoogleSignedOut(const std::string& account_id,
const std::string& username) override;
// GaiaCookieManagerService::Observer implementation.
void OnGaiaAccountsInCookieUpdated(
const std::vector<gaia::ListedAccount>& accounts,
const std::vector<gaia::ListedAccount>& signed_out_accounts,
const GoogleServiceAuthError& error) override;
// Similar to above but with a callback that will be invoked on completion.
void OnGaiaAccountsInCookieUpdatedWithCallback(
const std::vector<gaia::ListedAccount>& accounts,
const std::vector<gaia::ListedAccount>& signed_out_accounts,
const GoogleServiceAuthError& error,
const base::Closure& callback);
// Get the sync status code.
SyncStatusSummary QuerySyncStatusSummary();
// Reconfigures the data type manager with the latest enabled types.
// Note: Does not initialize the engine if it is not already initialized.
// This function needs to be called only after sync has been initialized
// (i.e.,only for reconfigurations). The reason we don't initialize the
// engine is because if we had encountered an unrecoverable error we don't
// want to startup once more.
// This function is called by |SetSetupInProgress|.
virtual void ReconfigureDatatypeManager();
syncer::PassphraseRequiredReason passphrase_required_reason() const {
return crypto_->passphrase_required_reason();
// Returns true if sync is requested to be running by the user.
// Note that this does not mean that sync WILL be running; e.g. if
// IsSyncAllowed() is false then sync won't start, and if the user
// doesn't confirm their settings (IsFirstSetupComplete), sync will
// never become active. Use IsSyncActive to see if sync is running.
virtual bool IsSyncRequested() const;
// Record stats on various events.
static void SyncEvent(SyncEventCodes code);
// Returns whether sync is allowed to run based on command-line switches.
// Profile::IsSyncAllowed() is probably a better signal than this function.
// This function can be called from any thread, and the implementation doesn't
// assume it's running on the UI thread.
static bool IsSyncAllowedByFlag();
// Returns whether sync is currently allowed on this platform.
bool IsSyncAllowedByPlatform() const;
// Whether sync is currently blocked from starting because the sync
// confirmation dialog hasn't been confirmed.
virtual bool IsSyncConfirmationNeeded() const;
// Returns whether sync is managed, i.e. controlled by configuration
// management. If so, the user is not allowed to configure sync.
virtual bool IsManaged() const;
// syncer::UnrecoverableErrorHandler implementation.
void OnUnrecoverableError(const tracked_objects::Location& from_here,
const std::string& message) override;
// The functions below (until ActivateDataType()) should only be
// called if IsEngineInitialized() is true.
// TODO(akalin): These two functions are used only by
// ProfileSyncServiceHarness. Figure out a different way to expose
// this info to that class, and remove these functions.
// Returns whether or not the underlying sync engine has made any
// local changes to items that have not yet been synced with the
// server.
bool HasUnsyncedItems() const;
// Used by ProfileSyncServiceHarness. May return null.
syncer::BackendMigrator* GetBackendMigratorForTest();
// Used by tests to inspect interaction with OAuth2TokenService.
bool IsRetryingAccessTokenFetchForTest() const;
// Used by tests to inspect the OAuth2 access tokens used by PSS.
std::string GetAccessTokenForTest() const;
// TODO(sync): This is only used in tests. Can we remove it?
void GetModelSafeRoutingInfo(syncer::ModelSafeRoutingInfo* out) const;
// SyncPrefObserver implementation.
void OnSyncManagedPrefChange(bool is_sync_managed) override;
// Changes which data types we're going to be syncing to |preferred_types|.
// If it is running, the DataTypeManager will be instructed to reconfigure
// the sync engine so that exactly these datatypes are actively synced. See
// class comment for more on what it means for a datatype to be Preferred.
virtual void ChangePreferredDataTypes(syncer::ModelTypeSet preferred_types);
// Returns the set of types which are enforced programmatically and can not
// be disabled by the user.
virtual syncer::ModelTypeSet GetForcedDataTypes() const;
// Gets the set of all data types that could be allowed (the set that
// should be advertised to the user). These will typically only change
// via a command-line option. See class comment for more on what it means
// for a datatype to be Registered.
virtual syncer::ModelTypeSet GetRegisteredDataTypes() const;
// See the SyncServiceCrypto header.
virtual syncer::PassphraseType GetPassphraseType() const;
virtual bool IsEncryptEverythingAllowed() const;
virtual void SetEncryptEverythingAllowed(bool allowed);
// Returns true if the syncer is waiting for new datatypes to be encrypted.
virtual bool encryption_pending() const;
syncer::SyncErrorController* sync_error_controller() {
return sync_error_controller_.get();
// TODO(sync): This is only used in tests. Can we remove it?
const syncer::DataTypeStatusTable& data_type_status_table() const;
syncer::DataTypeManager::ConfigureStatus configure_status() {
return configure_status_;
// If true, the ProfileSyncService has detected that a new GAIA signin has
// succeeded, and is waiting for initialization to complete. This is used by
// the UI to differentiate between a new auth error (encountered as part of
// the initialization process) and a pre-existing auth error that just hasn't
// been cleared yet. Virtual for testing purposes.
virtual bool waiting_for_auth() const;
// The set of currently enabled sync experiments.
const syncer::Experiments& current_experiments() const;
// OAuth2TokenService::Consumer implementation.
void OnGetTokenSuccess(const OAuth2TokenService::Request* request,
const std::string& access_token,
const base::Time& expiration_time) override;
void OnGetTokenFailure(const OAuth2TokenService::Request* request,
const GoogleServiceAuthError& error) override;
// OAuth2TokenService::Observer implementation.
void OnRefreshTokenAvailable(const std::string& account_id) override;
void OnRefreshTokenRevoked(const std::string& account_id) override;
void OnRefreshTokensLoaded() override;
// KeyedService implementation. This must be called exactly
// once (before this object is destroyed).
void Shutdown() override;
sync_sessions::FaviconCache* GetFaviconCache();
// Overrides the NetworkResources used for Sync connections.
// This function takes ownership of |network_resources|.
void OverrideNetworkResourcesForTest(
std::unique_ptr<syncer::NetworkResources> network_resources);
virtual bool IsDataTypeControllerRunning(syncer::ModelType type) const;
// This triggers a Directory::SaveChanges() call on the sync thread.
// It should be used to persist data to disk when the process might be
// killed in the near future.
void FlushDirectory() const;
// Returns a serialized NigoriKey proto generated from the bootstrap token in
// SyncPrefs. Will return the empty string if no bootstrap token exists.
std::string GetCustomPassphraseKey() const;
// Set the provider for whether sync is currently allowed by the platform.
void SetPlatformSyncAllowedProvider(
const PlatformSyncAllowedProvider& platform_sync_allowed_provider);
// Returns a function for |type| that will create a ModelTypeStore that shares
// the sync LevelDB backend. |base_path| should be set to profile path.
static syncer::ModelTypeStoreFactory GetModelTypeStoreFactory(
syncer::ModelType type,
const base::FilePath& base_path);
// Needed to test whether the directory is deleted properly.
base::FilePath GetDirectoryPathForTest() const;
// Sometimes we need to wait for tasks on the sync thread in tests.
base::MessageLoop* GetSyncLoopForTest() const;
// Some tests rely on injecting calls to the encryption observer.
syncer::SyncEncryptionHandler::Observer* GetEncryptionObserverForTest() const;
// Triggers sync cycle with request to update specified |types|.
void RefreshTypesForTest(syncer::ModelTypeSet types);
// Calls sync engine to send ClearServerDataMessage to server. This is used
// to start accounts with a clean slate when performing end to end testing.
void ClearServerDataForTest(const base::Closure& callback);
// SyncServiceBase implementation.
syncer::SyncCredentials GetCredentials() override;
syncer::WeakHandle<syncer::JsEventHandler> GetJsEventHandler() override;
MakeHttpPostProviderFactoryGetter() override;
GetUnrecoverableErrorHandler() override;
enum UnrecoverableErrorReason {
enum AuthErrorMetric {
// The initial state of sync, for the Sync.InitialState histogram. Even if
// this value is CAN_START, sync startup might fail for reasons that we may
// want to consider logging in the future, such as a passphrase needed for
// decryption, or the version of Chrome being too old. This enum is used to
// back a UMA histogram, and should therefore be treated as append-only.
enum SyncInitialState {
CAN_START, // Sync can attempt to start up.
NOT_SIGNED_IN, // There is no signed in user.
NOT_REQUESTED, // The user turned off sync.
NOT_REQUESTED_NOT_SETUP, // The user turned off sync and setup completed
// is false. Might indicate a stop-and-clear.
NEEDS_CONFIRMATION, // The user must confirm sync settings.
IS_MANAGED, // Sync is disallowed by enterprise policy.
NOT_ALLOWED_BY_PLATFORM, // Sync is disallowed by the platform.
friend class TestProfileSyncService;
// Helper to install and configure a data type manager.
void ConfigureDataTypeManager();
// Shuts down the engine sync components.
// |reason| dictates if syncing is being disabled or not, and whether
// to claim ownership of sync thread from engine.
void ShutdownImpl(syncer::ShutdownReason reason);
// Helper method for managing encryption UI.
bool IsEncryptedDatatypeEnabled() const;
// Helper for OnUnrecoverableError.
// TODO(tim): Use an enum for |delete_sync_database| here, in ShutdownImpl,
// and in SyncEngine::Shutdown.
void OnUnrecoverableErrorImpl(const tracked_objects::Location& from_here,
const std::string& message,
bool delete_sync_database);
// Stops the sync engine. Does NOT set IsSyncRequested to false. Use
// RequestStop for that. |data_fate| controls whether the local sync data is
// deleted or kept when the engine shuts down.
void StopImpl(SyncStopDataFate data_fate);
// Update the last auth error and notify observers of error state.
void UpdateAuthErrorState(const GoogleServiceAuthError& error);
// Puts the engine's sync scheduler into NORMAL mode.
// Called when configuration is complete.
void StartSyncingWithServer();
// RequestAccessToken initiates RPC to request downscoped access token from
// refresh token. This happens when a new OAuth2 login token is loaded and
// when sync server returns AUTH_ERROR which indicates it is time to refresh
// token.
void RequestAccessToken();
// Sets the last synced time to the current time.
void UpdateLastSyncedTime();
void NotifySyncCycleCompleted();
void NotifyForeignSessionUpdated();
void NotifyShutdown();
void ClearStaleErrors();
void ClearUnrecoverableError();
// Starts up the engine sync components.
virtual void StartUpSlowEngineComponents();
// Collects preferred sync data types from |preference_providers_|.
syncer::ModelTypeSet GetDataTypesFromPreferenceProviders() const;
// Called when the user changes the sync configuration, to update the UMA
// stats.
void UpdateSelectedTypesHistogram(
bool sync_everything,
const syncer::ModelTypeSet chosen_types) const;
// Internal unrecoverable error handler. Used to track error reason via
// Sync.UnrecoverableErrors histogram.
void OnInternalUnrecoverableError(const tracked_objects::Location& from_here,
const std::string& message,
bool delete_sync_database,
UnrecoverableErrorReason reason);
// Update UMA for syncing engine.
void UpdateEngineInitUMA(bool success);
// Whether sync has been authenticated with an account ID.
bool IsSignedIn() const;
// The engine can only start if sync can start and has an auth token. This is
// different fron CanSyncStart because it represents whether the engine can
// be started at this moment, whereas CanSyncStart represents whether sync can
// conceptually start without further user action (acquiring a token is an
// automatic process).
bool CanEngineStart() const;
// True if a syncing engine exists.
bool HasSyncingEngine() const;
// Update first sync time stored in preferences
void UpdateFirstSyncTimePref();
// Tell the sync server that this client has disabled sync.
void RemoveClientFromServer() const;
// Called when the system is under memory pressure.
void OnMemoryPressure(
base::MemoryPressureListener::MemoryPressureLevel memory_pressure_level);
// Check if previous shutdown is shutdown cleanly.
void ReportPreviousSessionMemoryWarningCount();
// Estimates and records memory usage histograms per type.
void RecordMemoryUsageHistograms();
// After user switches to custom passphrase encryption a set of steps needs to
// be performed:
// - Download all latest updates from server (catch up configure).
// - Clear user data on server.
// - Clear directory so that data is merged from model types and encrypted.
// SyncServiceCrypto::BeginConfigureCatchUpBeforeClear() and the following two
// functions perform these steps.
// Calls sync engine to send ClearServerDataMessage to server.
void ClearAndRestartSyncForPassphraseEncryption();
// Restarts sync clearing directory in the process.
void OnClearServerDataDone();
// True if setup has been completed at least once and is not in progress.
bool CanConfigureDataTypes() const;
// Called when a SetupInProgressHandle issued by this instance is destroyed.
virtual void OnSetupInProgressHandleDestroyed();
// This is a cache of the last authentication response we received from the
// sync server. The UI queries this to display appropriate messaging to the
// user.
GoogleServiceAuthError last_auth_error_;
// Cache of the last SyncCycleSnapshot received from the sync engine.
syncer::SyncCycleSnapshot last_snapshot_;
// TODO(ncarter): Put this in a profile, once there is UI for it.
// This specifies where to find the sync server.
const GURL sync_service_url_;
// The time that OnConfigureStart is called. This member is zero if
// OnConfigureStart has not yet been called, and is reset to zero once
// OnConfigureDone is called.
base::Time sync_configure_start_time_;
// Callback to update the network time; used for initializing the engine.
syncer::NetworkTimeUpdateCallback network_time_update_callback_;
// The request context in which sync should operate.
scoped_refptr<net::URLRequestContextGetter> url_request_context_;
// Indicates if this is the first time sync is being configured. This value
// is equal to !IsFirstSetupComplete() at the time of OnEngineInitialized().
bool is_first_time_sync_configure_;
// Number of UIs currently configuring the Sync service. When this number
// is decremented back to zero, Sync setup is marked no longer in progress.
int outstanding_setup_in_progress_handles_ = 0;
// List of available data type controllers.
syncer::DataTypeController::TypeMap data_type_controllers_;
// Whether the SyncEngine has been initialized.
bool engine_initialized_;
// Set when sync receives DISABLED_BY_ADMIN error from server. Prevents
// ProfileSyncService from starting engine till browser restarted or user
// signed out.
bool sync_disabled_by_admin_;
// Set to true if a signin has completed but we're still waiting for the
// engine to refresh its credentials.
bool is_auth_in_progress_;
// Information describing an unrecoverable error.
UnrecoverableErrorReason unrecoverable_error_reason_;
std::string unrecoverable_error_message_;
tracked_objects::Location unrecoverable_error_location_;
// Manages the start and stop of the data types.
std::unique_ptr<syncer::DataTypeManager> data_type_manager_;
base::ObserverList<syncer::ProtocolEventObserver> protocol_event_observers_;
base::ObserverList<syncer::TypeDebugInfoObserver> type_debug_info_observers_;
std::set<syncer::SyncTypePreferenceProvider*> preference_providers_;
syncer::SyncJsController sync_js_controller_;
// This allows us to gracefully handle an ABORTED return code from the
// DataTypeManager in the event that the server informed us to cease and
// desist syncing immediately.
bool expect_sync_configuration_aborted_;
std::unique_ptr<syncer::BackendMigrator> migrator_;
// This is the last |SyncProtocolError| we received from the server that had
// an action set on it.
syncer::SyncProtocolError last_actionable_error_;
// Exposes sync errors to the UI.
std::unique_ptr<syncer::SyncErrorController> sync_error_controller_;
// Tracks the set of failed data types (those that encounter an error
// or must delay loading for some reason).
syncer::DataTypeStatusTable data_type_status_table_;
syncer::DataTypeManager::ConfigureStatus configure_status_;
// The set of currently enabled sync experiments.
syncer::Experiments current_experiments_;
// Sync's internal debug info listener. Used to record datatype configuration
// and association information.
syncer::WeakHandle<syncer::DataTypeDebugInfoListener> debug_info_listener_;
// ProfileSyncService uses this service to get access tokens.
ProfileOAuth2TokenService* const oauth2_token_service_;
// ProfileSyncService needs to remember access token in order to invalidate it
// with OAuth2TokenService.
std::string access_token_;
// ProfileSyncService needs to hold reference to access_token_request_ for
// the duration of request in order to receive callbacks.
std::unique_ptr<OAuth2TokenService::Request> access_token_request_;
// If RequestAccessToken fails with transient error then retry requesting
// access token with exponential backoff.
base::OneShotTimer request_access_token_retry_timer_;
net::BackoffEntry request_access_token_backoff_;
// States related to sync token and connection.
base::Time connection_status_update_time_;
syncer::ConnectionStatus connection_status_;
base::Time token_request_time_;
base::Time token_receive_time_;
GoogleServiceAuthError last_get_token_error_;
base::Time next_token_request_time_;
// The gaia cookie manager. Used for monitoring cookie jar changes to detect
// when the user signs out of the content area.
GaiaCookieManagerService* const gaia_cookie_manager_service_;
std::unique_ptr<syncer::LocalDeviceInfoProvider> local_device_;
// Locally owned SyncableService and ModelTypeSyncBridge implementations.
std::unique_ptr<sync_sessions::SessionsSyncManager> sessions_sync_manager_;
std::unique_ptr<syncer::DeviceInfoSyncService> device_info_sync_service_;
std::unique_ptr<syncer::DeviceInfoSyncBridge> device_info_sync_bridge_;
std::unique_ptr<syncer::NetworkResources> network_resources_;
StartBehavior start_behavior_;
std::unique_ptr<syncer::StartupController> startup_controller_;
std::unique_ptr<syncer::SyncStoppedReporter> sync_stopped_reporter_;
// Listens for the system being under memory pressure.
std::unique_ptr<base::MemoryPressureListener> memory_pressure_listener_;
// Whether the major version has changed since the last time Chrome ran,
// and therefore a passphrase required state should result in prompting
// the user. This logic is only enabled on platforms that consume the
// IsPassphrasePrompted sync preference.
bool passphrase_prompt_triggered_by_version_;
// An object that lets us check whether sync is currently allowed on this
// platform.
PlatformSyncAllowedProvider platform_sync_allowed_provider_;
// This weak factory invalidates its issued pointers when Sync is disabled.
base::WeakPtrFactory<ProfileSyncService> sync_enabled_weak_factory_;
base::WeakPtrFactory<ProfileSyncService> weak_factory_;
bool ShouldShowActionOnUI(const syncer::SyncProtocolError& error);
} // namespace browser_sync