sync_file_system_service.cc revision a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7
15821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Copyright (c) 2012 The Chromium Authors. All rights reserved. 25821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 35821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// found in the LICENSE file. 45821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 55821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "chrome/browser/sync_file_system/sync_file_system_service.h" 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 72a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include <string> 82a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 95821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/bind.h" 107d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles)#include "base/format_macros.h" 115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/logging.h" 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/memory/ref_counted.h" 132a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "base/stl_util.h" 147dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch#include "chrome/browser/chrome_notification_types.h" 152a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "chrome/browser/extensions/api/sync_file_system/extension_sync_event_observer.h" 167dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch#include "chrome/browser/extensions/api/sync_file_system/sync_file_system_api_helpers.h" 17d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles)#include "chrome/browser/extensions/extension_prefs.h" 185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "chrome/browser/profiles/profile.h" 192a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "chrome/browser/sync/profile_sync_service.h" 202a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "chrome/browser/sync/profile_sync_service_factory.h" 212385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdoch#include "chrome/browser/sync_file_system/local/local_file_sync_service.h" 2290dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles)#include "chrome/browser/sync_file_system/logger.h" 23eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch#include "chrome/browser/sync_file_system/sync_direction.h" 242a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "chrome/browser/sync_file_system/sync_event_observer.h" 252385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdoch#include "chrome/browser/sync_file_system/sync_file_metadata.h" 26a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)#include "chrome/browser/sync_file_system/sync_process_runner.h" 272385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdoch#include "chrome/browser/sync_file_system/sync_status_code.h" 282385ea399aae016c0806a4f9ef3c9cfe3d2a39dfBen Murdoch#include "chrome/browser/sync_file_system/syncable_file_system_util.h" 2990dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles)#include "components/browser_context_keyed_service/browser_context_dependency_manager.h" 305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "content/public/browser/browser_thread.h" 312a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "content/public/browser/notification_details.h" 322a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "content/public/browser/notification_service.h" 337dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch#include "content/public/browser/storage_partition.h" 34f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles)#include "extensions/common/extension.h" 3568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles)#include "extensions/common/manifest_constants.h" 36eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch#include "url/gurl.h" 3790dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles)#include "webkit/browser/fileapi/file_system_context.h" 385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)using content::BrowserThread; 40d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles)using extensions::Extension; 41d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles)using extensions::ExtensionPrefs; 425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)using fileapi::FileSystemURL; 432a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)using fileapi::FileSystemURLSet; 445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace sync_file_system { 465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 472a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)namespace { 482a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 49a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)const char kLocalSyncName[] = "Local sync"; 50a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)const char kRemoteSyncName[] = "Remote sync"; 51a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)const char kRemoteSyncNameV2[] = "Remote sync (v2)"; 52c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) 53c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles)SyncServiceState RemoteStateToSyncServiceState( 542a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) RemoteServiceState state) { 552a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) switch (state) { 562a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) case REMOTE_SERVICE_OK: 57c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) return SYNC_SERVICE_RUNNING; 582a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) case REMOTE_SERVICE_TEMPORARY_UNAVAILABLE: 59c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) return SYNC_SERVICE_TEMPORARY_UNAVAILABLE; 602a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) case REMOTE_SERVICE_AUTHENTICATION_REQUIRED: 61c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) return SYNC_SERVICE_AUTHENTICATION_REQUIRED; 622a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) case REMOTE_SERVICE_DISABLED: 63c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) return SYNC_SERVICE_DISABLED; 642a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 65c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) NOTREACHED() << "Unknown remote service state: " << state; 66c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) return SYNC_SERVICE_DISABLED; 672a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 682a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 692a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void DidHandleOriginForExtensionUnloadedEvent( 702a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int type, 712a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const GURL& origin, 722a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncStatusCode code) { 73a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) DCHECK(chrome::NOTIFICATION_EXTENSION_UNLOADED == type || 74a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) chrome::NOTIFICATION_EXTENSION_UNINSTALLED == type); 75b2df76ea8fec9e32f6f3718986dba0d95315b29cTorne (Richard Coles) if (code != SYNC_STATUS_OK && 76b2df76ea8fec9e32f6f3718986dba0d95315b29cTorne (Richard Coles) code != SYNC_STATUS_UNKNOWN_ORIGIN) { 77a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) switch (type) { 78a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) case chrome::NOTIFICATION_EXTENSION_UNLOADED: 7990dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) util::Log(logging::LOG_WARNING, 8090dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) FROM_HERE, 81a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) "Disabling origin for UNLOADED(DISABLE) failed: %s", 8290dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) origin.spec().c_str()); 832a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) break; 84a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) case chrome::NOTIFICATION_EXTENSION_UNINSTALLED: 8590dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) util::Log(logging::LOG_WARNING, 8690dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) FROM_HERE, 87a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) "Uninstall origin for UNINSTALLED failed: %s", 8890dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) origin.spec().c_str()); 892a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) break; 902a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) default: 912a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) break; 922a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 932a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 942a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 952a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 962a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void DidHandleOriginForExtensionEnabledEvent( 972a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int type, 982a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const GURL& origin, 992a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncStatusCode code) { 1002a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) DCHECK(chrome::NOTIFICATION_EXTENSION_ENABLED == type); 1012a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (code != SYNC_STATUS_OK) 10290dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) util::Log(logging::LOG_WARNING, 10390dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) FROM_HERE, 10490dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) "Enabling origin for ENABLED failed: %s", 10590dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) origin.spec().c_str()); 1062a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 1072a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 1087dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdochstd::string SyncFileStatusToString(SyncFileStatus sync_file_status) { 1097dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch return extensions::api::sync_file_system::ToString( 1107dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch extensions::SyncFileStatusToExtensionEnum(sync_file_status)); 1117dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch} 1127dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch 1137d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles)// Gets called repeatedly until every SyncFileStatus has been mapped. 1147dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdochvoid DidGetFileSyncStatusForDump( 1157dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch base::ListValue* files, 1167d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) size_t* num_results, 1177dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch const SyncFileSystemService::DumpFilesCallback& callback, 1187dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch base::DictionaryValue* file, 1197d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) SyncStatusCode sync_status_code, 1207d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) SyncFileStatus sync_file_status) { 1217dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch DCHECK(files); 1227d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) DCHECK(num_results); 1237d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) 1247dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch if (file) 1257dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch file->SetString("status", SyncFileStatusToString(sync_file_status)); 1267d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) 1277d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) // Once all results have been received, run the callback to signal end. 1287dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch DCHECK_LE(*num_results, files->GetSize()); 1297dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch if (++*num_results < files->GetSize()) 1307d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) return; 1317d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) 1327dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch callback.Run(files); 1337d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles)} 1347d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) 135a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)// We need this indirection because WeakPtr can only be bound to methods 136a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)// without a return value. 137a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)LocalChangeProcessor* GetLocalChangeProcessorAdapter( 138a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::WeakPtr<SyncFileSystemService> service, 139a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) const GURL& origin) { 140a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (!service) 141a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return NULL; 142a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return service->GetLocalChangeProcessor(origin); 143a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)} 1442a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 145a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)} // namespace 146d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 147a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)//--------------------------------------------------------------------------- 148a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)// SyncProcessRunner's. 149d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 150a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)// SyncProcessRunner implementation for LocalSync. 151a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)class LocalSyncRunner : public SyncProcessRunner, 152a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) public LocalFileSyncService::Observer { 153a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) public: 154a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) LocalSyncRunner(const std::string& name, 155a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) SyncFileSystemService* sync_service) 156a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) : SyncProcessRunner(name, sync_service), 157a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) factory_(this) {} 158a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 159a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) virtual void StartSync(const SyncStatusCallback& callback) OVERRIDE { 160a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) sync_service()->local_service_->ProcessLocalChange( 161a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::Bind(&LocalSyncRunner::DidProcessLocalChange, 162a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) factory_.GetWeakPtr(), callback)); 163d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) } 164d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 165a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // LocalFileSyncService::Observer overrides. 166a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) virtual void OnLocalChangeAvailable(int64 pending_changes) OVERRIDE { 167a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 168d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 169a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) OnChangesUpdated(pending_changes); 170d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 171a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Kick other sync runners just in case they're not running. 172a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) sync_service()->RunForEachSyncRunners( 173a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) &SyncProcessRunner::ScheduleIfNotRunning); 174a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) } 175d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 176d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) private: 177a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) void DidProcessLocalChange( 178a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) const SyncStatusCallback& callback, 179a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) SyncStatusCode status, 180a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) const FileSystemURL& url) { 181d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) util::Log(logging::LOG_VERBOSE, FROM_HERE, 182a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) "ProcessLocalChange finished with status=%d (%s) for url=%s", 183a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) status, SyncStatusCodeToString(status), 184a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) url.DebugString().c_str()); 185a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) callback.Run(status); 186d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) } 187d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 188a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::WeakPtrFactory<LocalSyncRunner> factory_; 189a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DISALLOW_COPY_AND_ASSIGN(LocalSyncRunner); 190a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)}; 191d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 192a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)// SyncProcessRunner implementation for RemoteSync. 193a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)class RemoteSyncRunner : public SyncProcessRunner, 194a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) public RemoteFileSyncService::Observer { 195a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) public: 196a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) RemoteSyncRunner(const std::string& name, 197a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) SyncFileSystemService* sync_service, 198a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) RemoteFileSyncService* remote_service) 199a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) : SyncProcessRunner(name, sync_service), 200a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_(remote_service), 201a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) last_state_(REMOTE_SERVICE_OK), 202a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) factory_(this) {} 203a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 204a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) virtual void StartSync(const SyncStatusCallback& callback) OVERRIDE { 205a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_->ProcessRemoteChange( 206a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::Bind(&RemoteSyncRunner::DidProcessRemoteChange, 207a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) factory_.GetWeakPtr(), callback)); 208a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) } 209d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 210a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) virtual SyncServiceState GetServiceState() OVERRIDE { 211a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return RemoteStateToSyncServiceState(last_state_); 212d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) } 213d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 214a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // RemoteFileSyncService::Observer overrides. 215a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) virtual void OnRemoteChangeQueueUpdated(int64 pending_changes) OVERRIDE { 216a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 217d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 218a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) OnChangesUpdated(pending_changes); 219d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 220a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Kick other sync runners just in case they're not running. 221a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) sync_service()->RunForEachSyncRunners( 222a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) &SyncProcessRunner::ScheduleIfNotRunning); 223a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) } 224d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 225a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) virtual void OnRemoteServiceStateUpdated( 226a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) RemoteServiceState state, 227a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) const std::string& description) OVERRIDE { 228a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Just forward to SyncFileSystemService. 229a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) sync_service()->OnRemoteServiceStateUpdated(state, description); 230a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) last_state_ = state; 231a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) } 232d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 233a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) private: 234a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) void DidProcessRemoteChange( 235a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) const SyncStatusCallback& callback, 236a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) SyncStatusCode status, 237a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) const FileSystemURL& url) { 238a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) util::Log(logging::LOG_VERBOSE, FROM_HERE, 239a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) "ProcessRemoteChange finished with status=%d (%s) for url=%s", 240a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) status, SyncStatusCodeToString(status), 241a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) url.DebugString().c_str()); 242a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 243a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (status == SYNC_STATUS_FILE_BUSY) { 244a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) sync_service()->local_service_->RegisterURLForWaitingSync( 245a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) url, base::Bind(&RemoteSyncRunner::Schedule, 246a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) factory_.GetWeakPtr())); 247a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) } 248a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) callback.Run(status); 249d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) } 250d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 251d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) RemoteFileSyncService* remote_service_; 252a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) RemoteServiceState last_state_; 253a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::WeakPtrFactory<RemoteSyncRunner> factory_; 254a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DISALLOW_COPY_AND_ASSIGN(RemoteSyncRunner); 255d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles)}; 256d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 257d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles)//----------------------------------------------------------------------------- 258a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)// SyncFileSystemService 259d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 2605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void SyncFileSystemService::Shutdown() { 2615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 2625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 263a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->Shutdown(); 264a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_.reset(); 2655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 266a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_.reset(); 267a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) v2_remote_service_.reset(); 2685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2692a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) ProfileSyncServiceBase* profile_sync_service = 2702a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) ProfileSyncServiceFactory::GetForProfile(profile_); 2712a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (profile_sync_service) 2722a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) profile_sync_service->RemoveObserver(this); 2732a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 2745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) profile_ = NULL; 2755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SyncFileSystemService::~SyncFileSystemService() { 2785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 2795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(!profile_); 2805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 2815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void SyncFileSystemService::InitializeForApp( 2835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) fileapi::FileSystemContext* file_system_context, 2845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const GURL& app_origin, 2855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const SyncStatusCallback& callback) { 286a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DCHECK(local_service_); 287a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DCHECK(remote_service_); 2885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(app_origin == app_origin.GetOrigin()); 2895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2907d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) util::Log(logging::LOG_VERBOSE, FROM_HERE, 2917d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) "Initializing for App: %s", app_origin.spec().c_str()); 2925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 293a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->MaybeInitializeFileSystemContext( 294868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) app_origin, file_system_context, 2952a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::Bind(&SyncFileSystemService::DidInitializeFileSystem, 2962a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) AsWeakPtr(), app_origin, callback)); 2972a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 2985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 299c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles)SyncServiceState SyncFileSystemService::GetSyncServiceState() { 300a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // For now we always query the state from the main RemoteFileSyncService. 301a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return RemoteStateToSyncServiceState(remote_service_->GetCurrentState()); 302c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles)} 303c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) 304868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)void SyncFileSystemService::GetExtensionStatusMap( 305868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) std::map<GURL, std::string>* status_map) { 306868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) DCHECK(status_map); 307a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) status_map->clear(); 308a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_->GetOriginStatusMap(status_map); 309a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (v2_remote_service_) 310a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) v2_remote_service_->GetOriginStatusMap(status_map); 311868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)} 312868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 3137dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdochvoid SyncFileSystemService::DumpFiles(const GURL& origin, 3147dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch const DumpFilesCallback& callback) { 315eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch DCHECK(!origin.is_empty()); 3167d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) 3177dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch content::StoragePartition* storage_partition = 3187dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch content::BrowserContext::GetStoragePartitionForSite(profile_, origin); 3197dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch fileapi::FileSystemContext* file_system_context = 3207dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch storage_partition->GetFileSystemContext(); 321a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->MaybeInitializeFileSystemContext( 3227dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch origin, file_system_context, 3237dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch base::Bind(&SyncFileSystemService::DidInitializeFileSystemForDump, 3247dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch AsWeakPtr(), origin, callback)); 3257d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles)} 3267d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) 327a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)scoped_ptr<base::ListValue> SyncFileSystemService::DumpDatabase() { 328a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) scoped_ptr<base::ListValue> list = remote_service_->DumpDatabase(); 329a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (!list) 330a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) list.reset(new base::ListValue); 331a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (v2_remote_service_) { 332a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) scoped_ptr<base::ListValue> v2list = v2_remote_service_->DumpDatabase(); 333a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (!v2list) 334a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return list.Pass(); 335a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) for (base::ListValue::iterator itr = v2list->begin(); 336a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) itr != v2list->end(); ) { 337a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) scoped_ptr<base::Value> item; 338a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) itr = v2list->Erase(itr, &item); 339a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) list->Append(item.release()); 340a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) } 341a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) } 342a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return list.Pass(); 343a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)} 344a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 3452a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::GetFileSyncStatus( 3462a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const FileSystemURL& url, const SyncFileStatusCallback& callback) { 347a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DCHECK(local_service_); 348a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DCHECK(GetRemoteService(url.origin())); 3492a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 3502a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // It's possible to get an invalid FileEntry. 3512a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (!url.is_valid()) { 3522a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::MessageLoopProxy::current()->PostTask( 3532a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) FROM_HERE, 3542a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::Bind(callback, 3552a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SYNC_FILE_ERROR_INVALID_URL, 3562a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SYNC_FILE_STATUS_UNKNOWN)); 3572a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) return; 3585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 3595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 360a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (GetRemoteService(url.origin())->IsConflicting(url)) { 3612a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::MessageLoopProxy::current()->PostTask( 3622a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) FROM_HERE, 3632a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::Bind(callback, 3642a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SYNC_STATUS_OK, 3652a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SYNC_FILE_STATUS_CONFLICTING)); 3662a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) return; 3672a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 3685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 369a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->HasPendingLocalChanges( 3702a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) url, 3712a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::Bind(&SyncFileSystemService::DidGetLocalChangeStatus, 3722a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) AsWeakPtr(), callback)); 3735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3752a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::AddSyncEventObserver(SyncEventObserver* observer) { 3762a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) observers_.AddObserver(observer); 3772a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 3785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3792a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::RemoveSyncEventObserver( 3802a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncEventObserver* observer) { 3812a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) observers_.RemoveObserver(observer); 3825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3842a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)ConflictResolutionPolicy 3852a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)SyncFileSystemService::GetConflictResolutionPolicy() const { 386a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return remote_service_->GetConflictResolutionPolicy(); 3875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3892a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)SyncStatusCode SyncFileSystemService::SetConflictResolutionPolicy( 3902a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) ConflictResolutionPolicy policy) { 391a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return remote_service_->SetConflictResolutionPolicy(policy); 392a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)} 393a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 394a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)LocalChangeProcessor* SyncFileSystemService::GetLocalChangeProcessor( 395a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) const GURL& origin) { 396a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return GetRemoteService(origin)->GetLocalChangeProcessor(); 3975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)SyncFileSystemService::SyncFileSystemService(Profile* profile) 4005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) : profile_(profile), 4012a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) sync_enabled_(true) { 4022a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 4035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void SyncFileSystemService::Initialize( 405a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) scoped_ptr<LocalFileSyncService> local_service, 406a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) scoped_ptr<RemoteFileSyncService> remote_service) { 4075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 408a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DCHECK(local_service); 409a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) DCHECK(remote_service); 4105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(profile_); 4115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 412a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_ = local_service.Pass(); 413a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_ = remote_service.Pass(); 4145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 415a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) scoped_ptr<LocalSyncRunner> local_syncer( 416a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) new LocalSyncRunner(kLocalSyncName, this)); 417a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) scoped_ptr<RemoteSyncRunner> remote_syncer( 418a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) new RemoteSyncRunner(kRemoteSyncName, this, remote_service_.get())); 4192a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 420a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->AddChangeObserver(local_syncer.get()); 421a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->SetLocalChangeProcessorCallback( 422a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::Bind(&GetLocalChangeProcessorAdapter, AsWeakPtr())); 4232a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 424a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_->AddServiceObserver(remote_syncer.get()); 425a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_->AddFileStatusObserver(this); 426a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_->SetRemoteChangeProcessor(local_service_.get()); 427a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 428a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) sync_runners_.push_back(local_syncer.release()); 429a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) sync_runners_.push_back(remote_syncer.release()); 430d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 4312a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) ProfileSyncServiceBase* profile_sync_service = 4322a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) ProfileSyncServiceFactory::GetForProfile(profile_); 4332a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (profile_sync_service) { 4342a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) UpdateSyncEnabledStatus(profile_sync_service); 4352a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) profile_sync_service->AddObserver(this); 4362a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 4372a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 438c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) registrar_.Add(this, chrome::NOTIFICATION_EXTENSION_INSTALLED, 439c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) content::Source<Profile>(profile_)); 4402a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) registrar_.Add(this, chrome::NOTIFICATION_EXTENSION_UNLOADED, 4412a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) content::Source<Profile>(profile_)); 442a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) registrar_.Add(this, chrome::NOTIFICATION_EXTENSION_UNINSTALLED, 443a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) content::Source<Profile>(profile_)); 4442a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) registrar_.Add(this, chrome::NOTIFICATION_EXTENSION_ENABLED, 4452a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) content::Source<Profile>(profile_)); 4465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4482a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::DidInitializeFileSystem( 4492a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const GURL& app_origin, 4502a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const SyncStatusCallback& callback, 4512a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncStatusCode status) { 4522a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) DVLOG(1) << "DidInitializeFileSystem: " 4532a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) << app_origin.spec() << " " << status; 4542a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 4552a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (status != SYNC_STATUS_OK) { 4562a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) callback.Run(status); 4572a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) return; 4582a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 4595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4602a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Local side of initialization for the app is done. 4612a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Continue on initializing the remote side. 462a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) GetRemoteService(app_origin)->RegisterOrigin( 4632a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) app_origin, 4642a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::Bind(&SyncFileSystemService::DidRegisterOrigin, 4652a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) AsWeakPtr(), app_origin, callback)); 4665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4682a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::DidRegisterOrigin( 4692a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const GURL& app_origin, 4702a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const SyncStatusCallback& callback, 4712a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncStatusCode status) { 47258537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) util::Log(logging::LOG_VERBOSE, FROM_HERE, 47358537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) "DidInitializeForApp (registered the origin): %s: %s", 47458537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) app_origin.spec().c_str(), 47558537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) SyncStatusCodeToString(status)); 4762a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 477a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (status == SYNC_STATUS_FAILED) { 478a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // If we got generic error return the service status information. 479a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) switch (GetRemoteService(app_origin)->GetCurrentState()) { 480a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) case REMOTE_SERVICE_AUTHENTICATION_REQUIRED: 481a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) callback.Run(SYNC_STATUS_AUTHENTICATION_FAILED); 482a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return; 483a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) case REMOTE_SERVICE_TEMPORARY_UNAVAILABLE: 484a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) callback.Run(SYNC_STATUS_SERVICE_TEMPORARILY_UNAVAILABLE); 485a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return; 486a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) default: 487a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) break; 488a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) } 489a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) } 490a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 4912a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) callback.Run(status); 4925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 4935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 4947dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdochvoid SyncFileSystemService::DidInitializeFileSystemForDump( 4957dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch const GURL& origin, 4967dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch const DumpFilesCallback& callback, 4977dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch SyncStatusCode status) { 4987dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch DCHECK(!origin.is_empty()); 4997dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch 5007dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch if (status != SYNC_STATUS_OK) { 5017dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch base::ListValue empty_result; 5027dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch callback.Run(&empty_result); 5037dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch return; 5047dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch } 5057dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch 506a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::ListValue* files = 507a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) GetRemoteService(origin)->DumpFiles(origin).release(); 5087dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch if (!files->GetSize()) { 5097dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch callback.Run(files); 5107dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch return; 5117dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch } 5127dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch 5137dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch base::Callback<void(base::DictionaryValue* file, 5147dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch SyncStatusCode sync_status, 5157dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch SyncFileStatus sync_file_status)> completion_callback = 5167dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch base::Bind(&DidGetFileSyncStatusForDump, base::Owned(files), 5177dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch base::Owned(new size_t(0)), callback); 5187dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch 5197dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch // After all metadata loaded, sync status can be added to each entry. 5207dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch for (size_t i = 0; i < files->GetSize(); ++i) { 5217dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch base::DictionaryValue* file = NULL; 5227dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch std::string path_string; 5237dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch if (!files->GetDictionary(i, &file) || 5247dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch !file->GetString("path", &path_string)) { 5257dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch NOTREACHED(); 5267dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch completion_callback.Run( 5277dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch NULL, SYNC_FILE_ERROR_FAILED, SYNC_FILE_STATUS_UNKNOWN); 5287dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch continue; 5297dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch } 5307dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch 5317dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch base::FilePath file_path = base::FilePath::FromUTF8Unsafe(path_string); 5327dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch FileSystemURL url = CreateSyncableFileSystemURL(origin, file_path); 5337dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch GetFileSyncStatus(url, base::Bind(completion_callback, file)); 5347dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch } 5357dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch} 5367dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch 5372a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::SetSyncEnabledForTesting(bool enabled) { 5382a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) sync_enabled_ = enabled; 539a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_->SetSyncEnabled(sync_enabled_); 540a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (v2_remote_service_) 541a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) v2_remote_service_->SetSyncEnabled(sync_enabled_); 5422a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 5432a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 5442a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::DidGetLocalChangeStatus( 5452a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const SyncFileStatusCallback& callback, 5462a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncStatusCode status, 5472a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) bool has_pending_local_changes) { 5482a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) callback.Run( 5492a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) status, 5502a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) has_pending_local_changes ? 5512a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SYNC_FILE_STATUS_HAS_PENDING_CHANGES : SYNC_FILE_STATUS_SYNCED); 5522a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 5532a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 5542a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::OnRemoteServiceStateUpdated( 5552a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) RemoteServiceState state, 5562a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const std::string& description) { 5572a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); 5587d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) util::Log(logging::LOG_INFO, FROM_HERE, 5597d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) "OnRemoteServiceStateChanged: %d %s", state, description.c_str()); 560c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) 5612a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) FOR_EACH_OBSERVER( 5622a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncEventObserver, observers_, 5632a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) OnSyncStateUpdated(GURL(), 5642a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) RemoteStateToSyncServiceState(state), 5652a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) description)); 566a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 567a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) RunForEachSyncRunners(&SyncProcessRunner::Schedule); 5682a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 5692a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 5702a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::Observe( 5712a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int type, 5722a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const content::NotificationSource& source, 5732a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const content::NotificationDetails& details) { 574c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // Event notification sequence. 575c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // 576c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // (User action) (Notification type) 577c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // Install: INSTALLED. 578c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // Update: INSTALLED. 579a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) // Uninstall: UNINSTALLED. 580c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // Launch, Close: No notification. 581868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) // Enable: ENABLED. 582c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // Disable: UNLOADED(DISABLE). 583c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // Reload, Restart: UNLOADED(DISABLE) -> INSTALLED -> ENABLED. 584c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // 5852a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) switch (type) { 586c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) case chrome::NOTIFICATION_EXTENSION_INSTALLED: 587c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) HandleExtensionInstalled(details); 588c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) break; 5892a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) case chrome::NOTIFICATION_EXTENSION_UNLOADED: 5902a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) HandleExtensionUnloaded(type, details); 5912a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) break; 592a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) case chrome::NOTIFICATION_EXTENSION_UNINSTALLED: 593a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) HandleExtensionUninstalled(type, details); 594a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) break; 5952a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) case chrome::NOTIFICATION_EXTENSION_ENABLED: 5962a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) HandleExtensionEnabled(type, details); 5972a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) break; 5982a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) default: 5992a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) NOTREACHED() << "Unknown notification."; 6002a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) break; 6012a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 6022a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 6032a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 604c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles)void SyncFileSystemService::HandleExtensionInstalled( 605c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) const content::NotificationDetails& details) { 606d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) const Extension* extension = 607c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) content::Details<const extensions::InstalledExtensionInfo>(details)-> 608c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) extension; 609d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) GURL app_origin = Extension::GetBaseURLFromExtensionId(extension->id()); 610c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) DVLOG(1) << "Handle extension notification for INSTALLED: " << app_origin; 611c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // NOTE: When an app is uninstalled and re-installed in a sequence, 612a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // |local_service_| may still keeps |app_origin| as disabled origin. 613a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->SetOriginEnabled(app_origin, true); 614c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles)} 615c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) 6162a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::HandleExtensionUnloaded( 6172a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int type, 6182a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const content::NotificationDetails& details) { 619c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) content::Details<const extensions::UnloadedExtensionInfo> info(details); 6201e9bf3e0803691d0a228da41fc608347b6db4340Torne (Richard Coles) if (info->reason != extensions::UnloadedExtensionInfo::REASON_DISABLE) 621a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) return; 622d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 623d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) std::string extension_id = info->extension->id(); 624d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) GURL app_origin = Extension::GetBaseURLFromExtensionId(extension_id); 625d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 626d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) int reasons = ExtensionPrefs::Get(profile_)->GetDisableReasons(extension_id); 627d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) if (reasons & Extension::DISABLE_RELOAD) { 628d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // Bypass disabling the origin since the app will be re-enabled soon. 629d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // NOTE: If re-enabling the app fails, the app is disabled while it is 630d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // handled as enabled origin in the SyncFS. This should be safe and will be 631d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // recovered when the user re-enables the app manually or the sync service 632d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) // restarts. 633d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) DVLOG(1) << "Handle extension notification for UNLOAD(DISABLE_RELOAD): " 634d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) << app_origin; 635d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) return; 636d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) } 637d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) 638a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) DVLOG(1) << "Handle extension notification for UNLOAD(DISABLE): " 639a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) << app_origin; 640a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) GetRemoteService(app_origin)->DisableOrigin( 641a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) app_origin, 642a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) base::Bind(&DidHandleOriginForExtensionUnloadedEvent, 643a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) type, app_origin)); 644a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->SetOriginEnabled(app_origin, false); 645a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles)} 6462a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 647a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles)void SyncFileSystemService::HandleExtensionUninstalled( 648a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) int type, 649a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) const content::NotificationDetails& details) { 65068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) const Extension* extension = content::Details<const Extension>(details).ptr(); 65168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) DCHECK(extension); 65268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 65368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RemoteFileSyncService::UninstallFlag flag = 65468043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) RemoteFileSyncService::UNINSTALL_AND_PURGE_REMOTE; 65568043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // If it's loaded from an unpacked package and with key: field, 65668043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // the uninstall will not be sync'ed and the user might be using the 65768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) // same app key in other installs, so avoid purging the remote folder. 65868043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) if (extensions::Manifest::IsUnpackedLocation(extension->location()) && 65968043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) extension->manifest()->HasKey(extensions::manifest_keys::kKey)) { 66068043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) flag = RemoteFileSyncService::UNINSTALL_AND_KEEP_REMOTE; 66168043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) } 66268043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) 66368043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) GURL app_origin = Extension::GetBaseURLFromExtensionId(extension->id()); 664a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) DVLOG(1) << "Handle extension notification for UNINSTALLED: " 665a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) << app_origin; 666a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) GetRemoteService(app_origin)->UninstallOrigin( 66768043e1e95eeb07d5cae7aca370b26518b0867d6Torne (Richard Coles) app_origin, flag, 668a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) base::Bind(&DidHandleOriginForExtensionUnloadedEvent, 669a36e5920737c6adbddd3e43b760e5de8431db6e0Torne (Richard Coles) type, app_origin)); 670a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->SetOriginEnabled(app_origin, false); 6712a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 6722a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 6732a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::HandleExtensionEnabled( 6742a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) int type, 6752a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const content::NotificationDetails& details) { 676d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) std::string extension_id = content::Details<const Extension>(details)->id(); 677d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) GURL app_origin = Extension::GetBaseURLFromExtensionId(extension_id); 6782a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) DVLOG(1) << "Handle extension notification for ENABLED: " << app_origin; 679a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) GetRemoteService(app_origin)->EnableOrigin( 6802a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) app_origin, 6812a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::Bind(&DidHandleOriginForExtensionEnabledEvent, type, app_origin)); 682a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) local_service_->SetOriginEnabled(app_origin, true); 6832a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 6842a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 6852a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::OnStateChanged() { 6862a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) ProfileSyncServiceBase* profile_sync_service = 6872a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) ProfileSyncServiceFactory::GetForProfile(profile_); 6882a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (profile_sync_service) 6892a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) UpdateSyncEnabledStatus(profile_sync_service); 6902a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 6912a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 6922a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::OnFileStatusChanged( 6932a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const FileSystemURL& url, 6942a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncFileStatus sync_status, 6952a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncAction action_taken, 6962a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncDirection direction) { 6972a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) FOR_EACH_OBSERVER( 6982a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SyncEventObserver, observers_, 6992a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) OnFileSynced(url, sync_status, action_taken, direction)); 7002a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)} 7012a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 7022a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)void SyncFileSystemService::UpdateSyncEnabledStatus( 7032a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) ProfileSyncServiceBase* profile_sync_service) { 7042a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) if (!profile_sync_service->HasSyncSetupCompleted()) 7052a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) return; 706d0247b1b59f9c528cb6df88b4f2b9afaf80d181eTorne (Richard Coles) bool old_sync_enabled = sync_enabled_; 707868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) sync_enabled_ = profile_sync_service->GetActiveDataTypes().Has( 7082a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) syncer::APPS); 709a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) remote_service_->SetSyncEnabled(sync_enabled_); 710a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (v2_remote_service_) 711a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) v2_remote_service_->SetSyncEnabled(sync_enabled_); 712a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (!old_sync_enabled && sync_enabled_) 713a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) RunForEachSyncRunners(&SyncProcessRunner::Schedule); 714a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)} 715a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 716a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)void SyncFileSystemService::RunForEachSyncRunners( 717a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) void(SyncProcessRunner::*method)()) { 718a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) for (ScopedVector<SyncProcessRunner>::iterator iter = sync_runners_.begin(); 719a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) iter != sync_runners_.end(); ++iter) 720a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) ((*iter)->*method)(); 721a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)} 722a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 723a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)RemoteFileSyncService* SyncFileSystemService::GetRemoteService( 724a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) const GURL& origin) { 725a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (IsV2Enabled()) 726a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return remote_service_.get(); 727a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (!IsV2EnabledForOrigin(origin)) 728a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return remote_service_.get(); 729a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 730a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (!v2_remote_service_) { 731a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) v2_remote_service_ = RemoteFileSyncService::CreateForBrowserContext( 732a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) RemoteFileSyncService::V2, profile_); 733a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) scoped_ptr<RemoteSyncRunner> v2_remote_syncer( 734a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) new RemoteSyncRunner(kRemoteSyncNameV2, this, 735a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) v2_remote_service_.get())); 736a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) v2_remote_service_->AddServiceObserver(v2_remote_syncer.get()); 737a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) v2_remote_service_->AddFileStatusObserver(this); 738a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) v2_remote_service_->SetRemoteChangeProcessor(local_service_.get()); 739a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) sync_runners_.push_back(v2_remote_syncer.release()); 7402a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) } 741a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return v2_remote_service_.get(); 7425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 7435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 7445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace sync_file_system 745