sync_client_unittest.cc revision cedac228d2dd51db4b79ea1e72c7f249408ee061
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) 5c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles)#include "chrome/browser/chromeos/drive/sync_client.h" 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 75821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/file_util.h" 82a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "base/files/file_path.h" 92a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "base/files/scoped_temp_dir.h" 105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/memory/scoped_ptr.h" 117dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch#include "base/prefs/testing_pref_service.h" 12868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)#include "base/run_loop.h" 135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/test/test_timeouts.h" 14868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)#include "chrome/browser/chromeos/drive/change_list_loader.h" 155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "chrome/browser/chromeos/drive/drive.pb.h" 16eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch#include "chrome/browser/chromeos/drive/fake_free_disk_space_getter.h" 17c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles)#include "chrome/browser/chromeos/drive/file_cache.h" 18a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)#include "chrome/browser/chromeos/drive/file_system/move_operation.h" 19868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)#include "chrome/browser/chromeos/drive/file_system/operation_observer.h" 20f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles)#include "chrome/browser/chromeos/drive/file_system/remove_operation.h" 21a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)#include "chrome/browser/chromeos/drive/file_system_util.h" 22868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)#include "chrome/browser/chromeos/drive/job_scheduler.h" 23868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)#include "chrome/browser/chromeos/drive/resource_entry_conversion.h" 24868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)#include "chrome/browser/chromeos/drive/resource_metadata.h" 25c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles)#include "chrome/browser/chromeos/drive/test_util.h" 265d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)#include "chrome/browser/drive/event_logger.h" 277d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles)#include "chrome/browser/drive/fake_drive_service.h" 28868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)#include "content/public/test/test_browser_thread_bundle.h" 29a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)#include "google_apis/drive/test_util.h" 305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "testing/gtest/include/gtest/gtest.h" 315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace drive { 3390dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles)namespace internal { 345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace { 365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 37eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch// The content of files initially stored in the cache. 38868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)const char kLocalContent[] = "Hello!"; 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 40868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)// The content of files stored in the service. 41868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)const char kRemoteContent[] = "World!"; 425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 43868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)// SyncClientTestDriveService will return GDATA_CANCELLED when a request is 44868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)// made with the specified resource ID. 45eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdochclass SyncClientTestDriveService : public ::drive::FakeDriveService { 46868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) public: 47a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) SyncClientTestDriveService() : download_file_count_(0) {} 48a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 49868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) // FakeDriveService override: 50eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch virtual google_apis::CancelCallback DownloadFile( 51eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch const base::FilePath& local_cache_path, 52868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) const std::string& resource_id, 53eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch const google_apis::DownloadActionCallback& download_action_callback, 54eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch const google_apis::GetContentCallback& get_content_callback, 55eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch const google_apis::ProgressCallback& progress_callback) OVERRIDE { 56a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) ++download_file_count_; 57868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) if (resource_id == resource_id_to_be_cancelled_) { 58868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) base::MessageLoopProxy::current()->PostTask( 59868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) FROM_HERE, 60eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch base::Bind(download_action_callback, 61868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) google_apis::GDATA_CANCELLED, 62eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch base::FilePath())); 637d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) return google_apis::CancelCallback(); 64868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) } 65a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) if (resource_id == resource_id_to_be_paused_) { 66a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) paused_action_ = base::Bind(download_action_callback, 67a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) google_apis::GDATA_OTHER_ERROR, 68a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::FilePath()); 69a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) return google_apis::CancelCallback(); 70a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) } 71eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch return FakeDriveService::DownloadFile(local_cache_path, 72eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch resource_id, 73eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch download_action_callback, 74eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch get_content_callback, 75eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch progress_callback); 76868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) } 77868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 78a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) int download_file_count() const { return download_file_count_; } 79a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 80868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) void set_resource_id_to_be_cancelled(const std::string& resource_id) { 81868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) resource_id_to_be_cancelled_ = resource_id; 82868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) } 83868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 84a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) void set_resource_id_to_be_paused(const std::string& resource_id) { 85a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) resource_id_to_be_paused_ = resource_id; 86a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) } 87a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 88a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) const base::Closure& paused_action() const { return paused_action_; } 89a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 90868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) private: 91a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) int download_file_count_; 92868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) std::string resource_id_to_be_cancelled_; 93a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) std::string resource_id_to_be_paused_; 94a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::Closure paused_action_; 95868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)}; 96868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 97868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)class DummyOperationObserver : public file_system::OperationObserver { 987d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) // OperationObserver override: 99868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) virtual void OnDirectoryChangedByOperation( 100868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) const base::FilePath& path) OVERRIDE {} 101868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)}; 1025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace 1045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 105c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles)class SyncClientTest : public testing::Test { 1065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) public: 1075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) virtual void SetUp() OVERRIDE { 1085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ASSERT_TRUE(temp_dir_.CreateUniqueTempDir()); 1095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1107dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch pref_service_.reset(new TestingPrefServiceSimple); 1117dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch test_util::RegisterDrivePrefs(pref_service_->registry()); 112868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 113eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch fake_network_change_notifier_.reset( 114eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch new test_util::FakeNetworkChangeNotifier); 115eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 1165d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) logger_.reset(new EventLogger); 1175d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 118868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) drive_service_.reset(new SyncClientTestDriveService); 119868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 1207dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch scheduler_.reset(new JobScheduler(pref_service_.get(), 1215d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) logger_.get(), 1227dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch drive_service_.get(), 1237dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch base::MessageLoopProxy::current().get())); 124eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 125eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch metadata_storage_.reset(new ResourceMetadataStorage( 1267dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch temp_dir_.path(), base::MessageLoopProxy::current().get())); 127eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch ASSERT_TRUE(metadata_storage_->Initialize()); 128eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 129eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch cache_.reset(new FileCache(metadata_storage_.get(), 1307d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) temp_dir_.path(), 1317dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch base::MessageLoopProxy::current().get(), 132868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) NULL /* free_disk_space_getter */)); 1337d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) ASSERT_TRUE(cache_->Initialize()); 1342a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 135cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) metadata_.reset(new internal::ResourceMetadata( 136cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) metadata_storage_.get(), cache_.get(), 137cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) base::MessageLoopProxy::current())); 138cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) ASSERT_EQ(FILE_ERROR_OK, metadata_->Initialize()); 139cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) 1405d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) about_resource_loader_.reset(new AboutResourceLoader(scheduler_.get())); 1415d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) loader_controller_.reset(new LoaderController); 1425d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) change_list_loader_.reset(new ChangeListLoader( 1435d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) logger_.get(), 1445d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) base::MessageLoopProxy::current().get(), 1455d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) metadata_.get(), 1465d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) scheduler_.get(), 1475d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) about_resource_loader_.get(), 1485d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) loader_controller_.get())); 149868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) ASSERT_NO_FATAL_FAILURE(SetUpTestData()); 150868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 1517dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch sync_client_.reset(new SyncClient(base::MessageLoopProxy::current().get(), 152868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) &observer_, 153868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) scheduler_.get(), 154868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) metadata_.get(), 1557d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) cache_.get(), 1565d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) loader_controller_.get(), 1577d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) temp_dir_.path())); 1585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Disable delaying so that DoSyncLoop() starts immediately. 1605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sync_client_->set_delay_for_testing(base::TimeDelta::FromSeconds(0)); 1615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 163868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) // Adds a file to the service root and |resource_ids_|. 164868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) void AddFileEntry(const std::string& title) { 165868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) google_apis::GDataErrorCode error = google_apis::GDATA_FILE_ERROR; 166868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) scoped_ptr<google_apis::ResourceEntry> entry; 167868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) drive_service_->AddNewFile( 168868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) "text/plain", 169868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) kRemoteContent, 170868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) drive_service_->GetRootResourceId(), 171868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) title, 172868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) false, // shared_with_me 173868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) google_apis::test_util::CreateCopyResultCallback(&error, &entry)); 174868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) base::RunLoop().RunUntilIdle(); 175868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) ASSERT_EQ(google_apis::HTTP_CREATED, error); 176868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) ASSERT_TRUE(entry); 177868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) resource_ids_[title] = entry->resource_id(); 1785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 1795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 180868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) // Sets up data for tests. 181868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) void SetUpTestData() { 1822a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Prepare a temp file. 1832a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::FilePath temp_file; 184a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) EXPECT_TRUE(base::CreateTemporaryFileInDir(temp_dir_.path(), &temp_file)); 185868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) ASSERT_TRUE(google_apis::test_util::WriteStringToFile(temp_file, 186868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) kLocalContent)); 1875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1884e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) // Add file entries to the service. 189868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) ASSERT_NO_FATAL_FAILURE(AddFileEntry("foo")); 190868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) ASSERT_NO_FATAL_FAILURE(AddFileEntry("bar")); 191868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) ASSERT_NO_FATAL_FAILURE(AddFileEntry("baz")); 192868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) ASSERT_NO_FATAL_FAILURE(AddFileEntry("fetched")); 193868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) ASSERT_NO_FATAL_FAILURE(AddFileEntry("dirty")); 194f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) ASSERT_NO_FATAL_FAILURE(AddFileEntry("removed")); 195a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) ASSERT_NO_FATAL_FAILURE(AddFileEntry("moved")); 196868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 197868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) // Load data from the service to the metadata. 198868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) FileError error = FILE_ERROR_FAILED; 199a1401311d1ab56c4ed0a474bd38c108f75cb0cd9Torne (Richard Coles) change_list_loader_->LoadIfNeeded( 2002a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) google_apis::test_util::CreateCopyResultCallback(&error)); 201868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) base::RunLoop().RunUntilIdle(); 202c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, error); 2034e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 2044e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) // Prepare 3 pinned-but-not-present files. 2054e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, cache_->Pin(GetLocalId("foo"))); 2064e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, cache_->Pin(GetLocalId("bar"))); 2074e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, cache_->Pin(GetLocalId("baz"))); 2084e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 2094e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) // Prepare a pinned-and-fetched file. 2104e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) const std::string md5_fetched = "md5"; 2114e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, 2124e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) cache_->Store(GetLocalId("fetched"), md5_fetched, 2134e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) temp_file, FileCache::FILE_OPERATION_COPY)); 2144e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, cache_->Pin(GetLocalId("fetched"))); 2154e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 2164e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) // Prepare a pinned-and-fetched-and-dirty file. 2174e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, 2185d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) cache_->Store(GetLocalId("dirty"), std::string(), 2194e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) temp_file, FileCache::FILE_OPERATION_COPY)); 2204e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, cache_->Pin(GetLocalId("dirty"))); 2214e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 222f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // Prepare a removed file. 223f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) file_system::RemoveOperation remove_operation( 224f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) base::MessageLoopProxy::current().get(), &observer_, metadata_.get(), 225f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) cache_.get()); 226f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) remove_operation.Remove( 227cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) util::GetDriveMyDriveRootPath().AppendASCII("removed"), 228f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) false, // is_recursive 229f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) google_apis::test_util::CreateCopyResultCallback(&error)); 230f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) base::RunLoop().RunUntilIdle(); 231f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, error); 232a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 233a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Prepare a moved file. 234a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) file_system::MoveOperation move_operation( 235a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::MessageLoopProxy::current().get(), &observer_, metadata_.get()); 236a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) move_operation.Move( 237cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) util::GetDriveMyDriveRootPath().AppendASCII("moved"), 238a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) util::GetDriveMyDriveRootPath().AppendASCII("moved_new_title"), 239a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) google_apis::test_util::CreateCopyResultCallback(&error)); 240a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::RunLoop().RunUntilIdle(); 241a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, error); 2425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 2435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) protected: 2454e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) std::string GetLocalId(const std::string& title) { 2464e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) EXPECT_EQ(1U, resource_ids_.count(title)); 2474e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) std::string local_id; 2484e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, 2494e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) metadata_->GetIdByResourceId(resource_ids_[title], &local_id)); 2504e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) return local_id; 2514e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) } 2524e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) 253868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) content::TestBrowserThreadBundle thread_bundle_; 2542a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::ScopedTempDir temp_dir_; 2557dbb3d5cf0c15f500944d211057644d6a2f37371Ben Murdoch scoped_ptr<TestingPrefServiceSimple> pref_service_; 256eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch scoped_ptr<test_util::FakeNetworkChangeNotifier> 257eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch fake_network_change_notifier_; 2585d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) scoped_ptr<EventLogger> logger_; 259868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) scoped_ptr<SyncClientTestDriveService> drive_service_; 260868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) DummyOperationObserver observer_; 261868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) scoped_ptr<JobScheduler> scheduler_; 262eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch scoped_ptr<ResourceMetadataStorage, 263eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch test_util::DestroyHelperForTests> metadata_storage_; 26490dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles) scoped_ptr<FileCache, test_util::DestroyHelperForTests> cache_; 265cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) scoped_ptr<ResourceMetadata, test_util::DestroyHelperForTests> metadata_; 2665d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) scoped_ptr<AboutResourceLoader> about_resource_loader_; 2675d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) scoped_ptr<LoaderController> loader_controller_; 2685d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) scoped_ptr<ChangeListLoader> change_list_loader_; 269c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) scoped_ptr<SyncClient> sync_client_; 270868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 271868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) std::map<std::string, std::string> resource_ids_; // Name-to-id map. 2725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)}; 2735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 274868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)TEST_F(SyncClientTest, StartProcessingBacklog) { 2755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sync_client_->StartProcessingBacklog(); 276868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) base::RunLoop().RunUntilIdle(); 277868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 278cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) ResourceEntry entry; 279868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) // Pinned files get downloaded. 280cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, 281cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) metadata_->GetResourceEntryById(GetLocalId("foo"), &entry)); 282cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_TRUE(entry.file_specific_info().cache_state().is_present()); 283868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 284cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, 285cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) metadata_->GetResourceEntryById(GetLocalId("bar"), &entry)); 286cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_TRUE(entry.file_specific_info().cache_state().is_present()); 287868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 288cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, 289cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) metadata_->GetResourceEntryById(GetLocalId("baz"), &entry)); 290cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_TRUE(entry.file_specific_info().cache_state().is_present()); 291868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 292868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) // Dirty file gets uploaded. 293cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, 294cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) metadata_->GetResourceEntryById(GetLocalId("dirty"), &entry)); 295cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_FALSE(entry.file_specific_info().cache_state().is_dirty()); 296f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) 297f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) // Removed entry is not found. 298f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) google_apis::GDataErrorCode status = google_apis::GDATA_OTHER_ERROR; 299f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) scoped_ptr<google_apis::ResourceEntry> resource_entry; 300f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) drive_service_->GetResourceEntry( 301f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) resource_ids_["removed"], 302f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) google_apis::test_util::CreateCopyResultCallback(&status, 303f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) &resource_entry)); 304f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) base::RunLoop().RunUntilIdle(); 305f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) EXPECT_EQ(google_apis::HTTP_SUCCESS, status); 306f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) ASSERT_TRUE(resource_entry); 307f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) EXPECT_TRUE(resource_entry->deleted()); 308a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 309a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Moved entry was moved. 310a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) status = google_apis::GDATA_OTHER_ERROR; 311a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) drive_service_->GetResourceEntry( 312a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) resource_ids_["moved"], 313a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) google_apis::test_util::CreateCopyResultCallback(&status, 314a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) &resource_entry)); 315a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::RunLoop().RunUntilIdle(); 316a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) EXPECT_EQ(google_apis::HTTP_SUCCESS, status); 317a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) ASSERT_TRUE(resource_entry); 318a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) EXPECT_EQ("moved_new_title", resource_entry->title()); 3195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3217d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles)TEST_F(SyncClientTest, AddFetchTask) { 3224e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) sync_client_->AddFetchTask(GetLocalId("foo")); 323868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) base::RunLoop().RunUntilIdle(); 3245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 325cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) ResourceEntry entry; 326cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, 327cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) metadata_->GetResourceEntryById(GetLocalId("foo"), &entry)); 328cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_TRUE(entry.file_specific_info().cache_state().is_present()); 329868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles)} 3302a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 3317d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles)TEST_F(SyncClientTest, AddFetchTaskAndCancelled) { 332868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) // Trigger fetching of a file which results in cancellation. 3337d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) drive_service_->set_resource_id_to_be_cancelled(resource_ids_["foo"]); 3344e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) sync_client_->AddFetchTask(GetLocalId("foo")); 335868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) base::RunLoop().RunUntilIdle(); 336868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 337868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) // The file should be unpinned if the user wants the download to be cancelled. 338cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) ResourceEntry entry; 339cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, 340cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) metadata_->GetResourceEntryById(GetLocalId("foo"), &entry)); 341cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_FALSE(entry.file_specific_info().cache_state().is_pinned()); 3425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3447d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles)TEST_F(SyncClientTest, RemoveFetchTask) { 3454e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) sync_client_->AddFetchTask(GetLocalId("foo")); 3464e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) sync_client_->AddFetchTask(GetLocalId("bar")); 3474e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) sync_client_->AddFetchTask(GetLocalId("baz")); 3487d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) 3494e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) sync_client_->RemoveFetchTask(GetLocalId("foo")); 3504e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) sync_client_->RemoveFetchTask(GetLocalId("baz")); 351868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) base::RunLoop().RunUntilIdle(); 352868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 353868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) // Only "bar" should be fetched. 354cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) ResourceEntry entry; 355cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, 356cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) metadata_->GetResourceEntryById(GetLocalId("foo"), &entry)); 357cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_FALSE(entry.file_specific_info().cache_state().is_present()); 358868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 359cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, 360cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) metadata_->GetResourceEntryById(GetLocalId("bar"), &entry)); 361cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_TRUE(entry.file_specific_info().cache_state().is_present()); 362868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 363cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, 364cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) metadata_->GetResourceEntryById(GetLocalId("baz"), &entry)); 365cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_FALSE(entry.file_specific_info().cache_state().is_present()); 3662a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 3675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 369c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles)TEST_F(SyncClientTest, ExistingPinnedFiles) { 3705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Start checking the existing pinned files. This will collect the resource 3715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // IDs of pinned files, with stale local cache files. 3725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) sync_client_->StartCheckingExistingPinnedFiles(); 373868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) base::RunLoop().RunUntilIdle(); 374868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 375868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) // "fetched" and "dirty" are the existing pinned files. 376868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) // The non-dirty one should be synced, but the dirty one should not. 377868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) base::FilePath cache_file; 378868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) std::string content; 3794e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, cache_->GetFile(GetLocalId("fetched"), &cache_file)); 38058537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) EXPECT_TRUE(base::ReadFileToString(cache_file, &content)); 381868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) EXPECT_EQ(kRemoteContent, content); 382868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) content.clear(); 383868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) 3844e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, cache_->GetFile(GetLocalId("dirty"), &cache_file)); 38558537e28ecd584eab876aee8be7156509866d23aTorne (Richard Coles) EXPECT_TRUE(base::ReadFileToString(cache_file, &content)); 386868fa2fe829687343ffae624259930155e16dbd8Torne (Richard Coles) EXPECT_EQ(kLocalContent, content); 3875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 3885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 389eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen MurdochTEST_F(SyncClientTest, RetryOnDisconnection) { 390eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // Let the service go down. 391eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch drive_service_->set_offline(true); 392eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // Change the network connection state after some delay, to test that 393eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // FILE_ERROR_NO_CONNECTION is handled by SyncClient correctly. 394eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // Without this delay, JobScheduler will keep the jobs unrun and SyncClient 395eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // will receive no error. 396eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch base::MessageLoopProxy::current()->PostDelayedTask( 397eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch FROM_HERE, 398eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch base::Bind(&test_util::FakeNetworkChangeNotifier::SetConnectionType, 399eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch base::Unretained(fake_network_change_notifier_.get()), 400eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch net::NetworkChangeNotifier::CONNECTION_NONE), 401eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch TestTimeouts::tiny_timeout()); 402eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 403eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // Try fetch and upload. 4044e180b6a0b4720a9b8e9e959a882386f690f08ffTorne (Richard Coles) sync_client_->AddFetchTask(GetLocalId("foo")); 4055d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) sync_client_->AddUpdateTask(ClientContext(USER_INITIATED), 406f2477e01787aa58f445919b809d89e252beef54fTorne (Richard Coles) GetLocalId("dirty")); 407eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch base::RunLoop().RunUntilIdle(); 408eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 409eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // Not yet fetched nor uploaded. 410cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) ResourceEntry entry; 411cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, 412cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) metadata_->GetResourceEntryById(GetLocalId("foo"), &entry)); 413cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_FALSE(entry.file_specific_info().cache_state().is_present()); 414cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, 415cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) metadata_->GetResourceEntryById(GetLocalId("dirty"), &entry)); 416cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_TRUE(entry.file_specific_info().cache_state().is_dirty()); 417eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 418eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // Switch to online. 419eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch fake_network_change_notifier_->SetConnectionType( 420eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch net::NetworkChangeNotifier::CONNECTION_WIFI); 421eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch drive_service_->set_offline(false); 422eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch base::RunLoop().RunUntilIdle(); 423eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 424eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch // Fetched and uploaded. 425cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, 426cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) metadata_->GetResourceEntryById(GetLocalId("foo"), &entry)); 427cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_TRUE(entry.file_specific_info().cache_state().is_present()); 428cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, 429cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) metadata_->GetResourceEntryById(GetLocalId("dirty"), &entry)); 430cedac228d2dd51db4b79ea1e72c7f249408ee061Torne (Richard Coles) EXPECT_FALSE(entry.file_specific_info().cache_state().is_dirty()); 431eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch} 432eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 433a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)TEST_F(SyncClientTest, ScheduleRerun) { 434a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Add a fetch task for "foo", this should result in being paused. 435a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) drive_service_->set_resource_id_to_be_paused(resource_ids_["foo"]); 436a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) sync_client_->AddFetchTask(GetLocalId("foo")); 437a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::RunLoop().RunUntilIdle(); 438a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 439a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // While the first task is paused, add a task again. 440a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // This results in scheduling rerun of the task. 441a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) sync_client_->AddFetchTask(GetLocalId("foo")); 442a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::RunLoop().RunUntilIdle(); 443a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 444a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Resume the paused task. 445a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) drive_service_->set_resource_id_to_be_paused(std::string()); 446a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) ASSERT_FALSE(drive_service_->paused_action().is_null()); 447a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) drive_service_->paused_action().Run(); 448a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) base::RunLoop().RunUntilIdle(); 449a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 450a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) // Task should be run twice. 451a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) EXPECT_EQ(2, drive_service_->download_file_count()); 452a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles)} 453a3f6a49ab37290eeeb8db0f41ec0f1cb74a68be7Torne (Richard Coles) 4545d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)TEST_F(SyncClientTest, Dependencies) { 4555d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // Create directories locally. 4565d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) const base::FilePath kPath1(FILE_PATH_LITERAL("drive/root/dir1")); 4575d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) const base::FilePath kPath2 = kPath1.AppendASCII("dir2"); 4585d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 4595d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) ResourceEntry parent; 4605d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, 4615d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) metadata_->GetResourceEntryByPath(kPath1.DirName(), &parent)); 4625d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 4635d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) ResourceEntry entry1; 4645d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) entry1.set_parent_local_id(parent.local_id()); 4655d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) entry1.set_title(kPath1.BaseName().AsUTF8Unsafe()); 4665d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) entry1.mutable_file_info()->set_is_directory(true); 4675d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) entry1.set_metadata_edit_state(ResourceEntry::DIRTY); 4685d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) std::string local_id1; 4695d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, metadata_->AddEntry(entry1, &local_id1)); 4705d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 4715d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) ResourceEntry entry2; 4725d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) entry2.set_parent_local_id(local_id1); 4735d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) entry2.set_title(kPath2.BaseName().AsUTF8Unsafe()); 4745d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) entry2.mutable_file_info()->set_is_directory(true); 4755d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) entry2.set_metadata_edit_state(ResourceEntry::DIRTY); 4765d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) std::string local_id2; 4775d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, metadata_->AddEntry(entry2, &local_id2)); 4785d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 4795d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // Start syncing the child first. 4805d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) sync_client_->AddUpdateTask(ClientContext(USER_INITIATED), local_id2); 4815d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) base::RunLoop().RunUntilIdle(); 4825d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // Start syncing the parent later. 4835d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) sync_client_->AddUpdateTask(ClientContext(USER_INITIATED), local_id1); 4845d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) base::RunLoop().RunUntilIdle(); 4855d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 4865d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) // Both entries are synced. 4875d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, metadata_->GetResourceEntryById(local_id1, &entry1)); 4885d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) EXPECT_EQ(ResourceEntry::CLEAN, entry1.metadata_edit_state()); 4895d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) EXPECT_EQ(FILE_ERROR_OK, metadata_->GetResourceEntryById(local_id2, &entry2)); 4905d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) EXPECT_EQ(ResourceEntry::CLEAN, entry2.metadata_edit_state()); 4915d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles)} 4925d1f7b1de12d16ceb2c938c56701a3e8bfa558f7Torne (Richard Coles) 49390dce4d38c5ff5333bea97d859d4e484e27edf0cTorne (Richard Coles)} // namespace internal 4945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace drive 495