blob: 111378bf165d9938407a1d273b1707d4794ce68c [file] [log] [blame]
[email protected]92b84f332012-03-21 20:45:211// Copyright (c) 2012 The Chromium Authors. All rights reserved.
2// Use of this source code is governed by a BSD-style license that can be
3// found in the LICENSE file.
4
yawano3513e142016-04-20 00:42:425#include "components/drive/chromeos/sync_client.h"
[email protected]92b84f332012-03-21 20:45:216
dchengf42750232016-04-12 04:12:277#include <memory>
8
Sebastien Marchand53801a32019-01-25 16:26:119#include "base/bind.h"
[email protected]57999812013-02-24 05:40:5210#include "base/files/file_path.h"
thestig18dfb7a52014-08-26 10:44:0411#include "base/files/file_util.h"
[email protected]ea1a3f62012-11-16 20:34:2312#include "base/files/scoped_temp_dir.h"
[email protected]b568b882013-06-10 04:38:0713#include "base/run_loop.h"
pranay.kumar229290b52015-05-14 05:21:0414#include "base/single_thread_task_runner.h"
[email protected]b83e5202012-06-27 07:50:2415#include "base/test/test_timeouts.h"
gab7966d312016-05-11 20:35:0116#include "base/threading/thread_task_runner_handle.h"
Stuart Langleyad8728c2018-04-19 04:05:5617#include "components/drive/chromeos/about_resource_loader.h"
Stuart Langley24e4ff52018-05-25 00:29:1918#include "components/drive/chromeos/about_resource_root_folder_id_loader.h"
yawano3513e142016-04-20 00:42:4219#include "components/drive/chromeos/change_list_loader.h"
20#include "components/drive/chromeos/drive_test_util.h"
21#include "components/drive/chromeos/fake_free_disk_space_getter.h"
22#include "components/drive/chromeos/file_cache.h"
23#include "components/drive/chromeos/file_system/move_operation.h"
24#include "components/drive/chromeos/file_system/operation_delegate.h"
25#include "components/drive/chromeos/file_system/remove_operation.h"
Stuart Langleyf51f3412018-05-08 23:43:0426#include "components/drive/chromeos/loader_controller.h"
yawano3513e142016-04-20 00:42:4227#include "components/drive/chromeos/resource_metadata.h"
Stuart Langleyc92ed252018-05-16 08:38:3428#include "components/drive/chromeos/start_page_token_loader.h"
lukasza01b9d55a2015-07-21 15:19:2529#include "components/drive/drive.pb.h"
lukasza8acc4eb2015-07-20 20:57:2030#include "components/drive/event_logger.h"
lukasza76b4a982015-08-08 00:36:3931#include "components/drive/file_change.h"
lukasza6364a022015-08-21 01:13:2432#include "components/drive/file_system_core_util.h"
lukaszab371ff4f2015-08-13 18:23:4733#include "components/drive/job_scheduler.h"
lukasza6364a022015-08-21 01:13:2434#include "components/drive/resource_entry_conversion.h"
lukasza8acc4eb2015-07-20 20:57:2035#include "components/drive/service/fake_drive_service.h"
brettw066508682016-02-03 08:22:0236#include "components/prefs/testing_pref_service.h"
Gabriel Charettec7108742019-08-23 03:31:4037#include "content/public/test/browser_task_environment.h"
[email protected]31258442014-06-05 03:37:4138#include "google_apis/drive/drive_api_parser.h"
[email protected]e196bef32013-12-03 05:33:1339#include "google_apis/drive/test_util.h"
Miyoung Shin9421dea2019-09-05 12:59:4240#include "mojo/public/cpp/bindings/pending_remote.h"
Jun Cai065916a2018-12-18 03:06:4341#include "services/network/test/test_network_connection_tracker.h"
[email protected]92b84f332012-03-21 20:45:2142#include "testing/gtest/include/gtest/gtest.h"
43
[email protected]d9d04df2012-10-12 07:06:3544namespace drive {
[email protected]4e87c4862013-05-20 04:06:3245namespace internal {
[email protected]92b84f332012-03-21 20:45:2146
[email protected]80199362012-09-09 23:24:2947namespace {
48
[email protected]7a6860162013-07-03 12:31:4649// The content of files initially stored in the cache.
[email protected]b568b882013-06-10 04:38:0750const char kLocalContent[] = "Hello!";
[email protected]61a41c12013-06-06 06:23:3651
[email protected]b568b882013-06-10 04:38:0752// The content of files stored in the service.
53const char kRemoteContent[] = "World!";
54
satorux1e04b422015-01-29 07:50:5355// SyncClientTestDriveService will return DRIVE_CANCELLED when a request is
[email protected]b568b882013-06-10 04:38:0756// made with the specified resource ID.
[email protected]e50af7652013-06-20 06:39:3157class SyncClientTestDriveService : public ::drive::FakeDriveService {
[email protected]67e264a2013-06-03 05:39:0158 public:
[email protected]799d4ec2013-12-06 07:39:2359 SyncClientTestDriveService() : download_file_count_(0) {}
60
[email protected]b568b882013-06-10 04:38:0761 // FakeDriveService override:
dchengfe773302015-01-22 19:45:5262 google_apis::CancelCallback DownloadFile(
[email protected]7a6860162013-07-03 12:31:4663 const base::FilePath& local_cache_path,
[email protected]67e264a2013-06-03 05:39:0164 const std::string& resource_id,
[email protected]7a6860162013-07-03 12:31:4665 const google_apis::DownloadActionCallback& download_action_callback,
66 const google_apis::GetContentCallback& get_content_callback,
mostynb9108efb92014-10-03 23:46:1567 const google_apis::ProgressCallback& progress_callback) override {
[email protected]799d4ec2013-12-06 07:39:2368 ++download_file_count_;
[email protected]b568b882013-06-10 04:38:0769 if (resource_id == resource_id_to_be_cancelled_) {
pranay.kumar229290b52015-05-14 05:21:0470 base::ThreadTaskRunnerHandle::Get()->PostTask(
[email protected]b568b882013-06-10 04:38:0771 FROM_HERE,
tzik2bcf8e42018-07-31 11:22:1572 base::BindOnce(download_action_callback, google_apis::DRIVE_CANCELLED,
73 base::FilePath()));
[email protected]cef0f062013-06-14 16:13:0774 return google_apis::CancelCallback();
[email protected]61a41c12013-06-06 06:23:3675 }
[email protected]799d4ec2013-12-06 07:39:2376 if (resource_id == resource_id_to_be_paused_) {
77 paused_action_ = base::Bind(download_action_callback,
satorux1e04b422015-01-29 07:50:5378 google_apis::DRIVE_OTHER_ERROR,
[email protected]799d4ec2013-12-06 07:39:2379 base::FilePath());
80 return google_apis::CancelCallback();
81 }
[email protected]7a6860162013-07-03 12:31:4682 return FakeDriveService::DownloadFile(local_cache_path,
83 resource_id,
84 download_action_callback,
85 get_content_callback,
86 progress_callback);
[email protected]67e264a2013-06-03 05:39:0187 }
[email protected]aaa70a42012-06-05 22:22:5188
[email protected]799d4ec2013-12-06 07:39:2389 int download_file_count() const { return download_file_count_; }
90
[email protected]b568b882013-06-10 04:38:0791 void set_resource_id_to_be_cancelled(const std::string& resource_id) {
92 resource_id_to_be_cancelled_ = resource_id;
[email protected]67e264a2013-06-03 05:39:0193 }
[email protected]b83e5202012-06-27 07:50:2494
[email protected]799d4ec2013-12-06 07:39:2395 void set_resource_id_to_be_paused(const std::string& resource_id) {
96 resource_id_to_be_paused_ = resource_id;
97 }
98
99 const base::Closure& paused_action() const { return paused_action_; }
100
[email protected]67e264a2013-06-03 05:39:01101 private:
[email protected]799d4ec2013-12-06 07:39:23102 int download_file_count_;
[email protected]b568b882013-06-10 04:38:07103 std::string resource_id_to_be_cancelled_;
[email protected]799d4ec2013-12-06 07:39:23104 std::string resource_id_to_be_paused_;
105 base::Closure paused_action_;
[email protected]b568b882013-06-10 04:38:07106};
107
[email protected]80199362012-09-09 23:24:29108} // namespace
109
[email protected]d876d70b2013-04-23 20:06:15110class SyncClientTest : public testing::Test {
[email protected]ffd60e432012-03-24 20:36:00111 public:
dchengfe773302015-01-22 19:45:52112 void SetUp() override {
[email protected]92b84f332012-03-21 20:45:21113 ASSERT_TRUE(temp_dir_.CreateUniqueTempDir());
114
Stuart Langley6b785f82018-06-13 05:32:20115 pref_service_ = std::make_unique<TestingPrefServiceSimple>();
[email protected]db20d212013-07-08 07:18:16116 test_util::RegisterDrivePrefs(pref_service_->registry());
[email protected]b568b882013-06-10 04:38:07117
Stuart Langley6b785f82018-06-13 05:32:20118 logger_ = std::make_unique<EventLogger>();
[email protected]9475cc72014-02-05 01:50:57119
Stuart Langley6b785f82018-06-13 05:32:20120 drive_service_ = std::make_unique<SyncClientTestDriveService>();
[email protected]b568b882013-06-10 04:38:07121
Jun Cai065916a2018-12-18 03:06:43122 network::TestNetworkConnectionTracker::GetInstance()->SetConnectionType(
123 network::mojom::ConnectionType::CONNECTION_WIFI);
Stuart Langley6b785f82018-06-13 05:32:20124 scheduler_ = std::make_unique<JobScheduler>(
Ke He24a04642017-06-26 08:38:36125 pref_service_.get(), logger_.get(), drive_service_.get(),
Jun Cai065916a2018-12-18 03:06:43126 network::TestNetworkConnectionTracker::GetInstance(),
Miyoung Shin9421dea2019-09-05 12:59:42127 base::ThreadTaskRunnerHandle::Get().get(), mojo::NullRemote());
[email protected]be427d72013-06-21 07:09:27128
129 metadata_storage_.reset(new ResourceMetadataStorage(
vabr96fd0c0f2016-09-13 14:21:31130 temp_dir_.GetPath(), base::ThreadTaskRunnerHandle::Get().get()));
[email protected]be427d72013-06-21 07:09:27131 ASSERT_TRUE(metadata_storage_->Initialize());
132
vabr96fd0c0f2016-09-13 14:21:31133 cache_.reset(new FileCache(metadata_storage_.get(), temp_dir_.GetPath(),
pranay.kumar229290b52015-05-14 05:21:04134 base::ThreadTaskRunnerHandle::Get().get(),
Stuart Langleyfda065f2018-05-30 03:01:05135 nullptr /* free_disk_space_getter */));
[email protected]34a1bbf32013-06-17 07:24:02136 ASSERT_TRUE(cache_->Initialize());
[email protected]e63bdc972012-11-22 12:10:48137
[email protected]1c98a9ee2014-05-14 04:01:55138 metadata_.reset(new internal::ResourceMetadata(
139 metadata_storage_.get(), cache_.get(),
pranay.kumar229290b52015-05-14 05:21:04140 base::ThreadTaskRunnerHandle::Get()));
[email protected]1c98a9ee2014-05-14 04:01:55141 ASSERT_EQ(FILE_ERROR_OK, metadata_->Initialize());
142
Stuart Langley6b785f82018-06-13 05:32:20143 about_resource_loader_ =
144 std::make_unique<AboutResourceLoader>(scheduler_.get());
Stuart Langley24e4ff52018-05-25 00:29:19145 root_folder_id_loader_ = std::make_unique<AboutResourceRootFolderIdLoader>(
146 about_resource_loader_.get());
147
Stuart Langley6b785f82018-06-13 05:32:20148 start_page_token_loader_ = std::make_unique<StartPageTokenLoader>(
149 drive::util::kTeamDriveIdDefaultCorpus, scheduler_.get());
150 loader_controller_ = std::make_unique<LoaderController>();
151 change_list_loader_ = std::make_unique<ChangeListLoader>(
Stuart Langleyc92ed252018-05-16 08:38:34152 logger_.get(), base::ThreadTaskRunnerHandle::Get().get(),
Stuart Langley24e4ff52018-05-25 00:29:19153 metadata_.get(), scheduler_.get(), root_folder_id_loader_.get(),
Stuart Langley95c21502018-05-25 04:21:29154 start_page_token_loader_.get(), loader_controller_.get(),
Stuart Langley6b785f82018-06-13 05:32:20155 util::kTeamDriveIdDefaultCorpus, util::GetDriveMyDriveRootPath());
[email protected]b568b882013-06-10 04:38:07156 ASSERT_NO_FATAL_FAILURE(SetUpTestData());
157
Stuart Langley6b785f82018-06-13 05:32:20158 sync_client_ = std::make_unique<SyncClient>(
159 base::ThreadTaskRunnerHandle::Get().get(), &delegate_, scheduler_.get(),
160 metadata_.get(), cache_.get(), loader_controller_.get(),
161 temp_dir_.GetPath());
[email protected]e0529fc2012-06-12 11:07:58162
[email protected]b83e5202012-06-27 07:50:24163 // Disable delaying so that DoSyncLoop() starts immediately.
164 sync_client_->set_delay_for_testing(base::TimeDelta::FromSeconds(0));
[email protected]92b84f332012-03-21 20:45:21165 }
166
[email protected]b568b882013-06-10 04:38:07167 // Adds a file to the service root and |resource_ids_|.
168 void AddFileEntry(const std::string& title) {
satorux1e04b422015-01-29 07:50:53169 google_apis::DriveApiErrorCode error = google_apis::DRIVE_FILE_ERROR;
dchengf42750232016-04-12 04:12:27170 std::unique_ptr<google_apis::FileResource> entry;
[email protected]b568b882013-06-10 04:38:07171 drive_service_->AddNewFile(
172 "text/plain",
173 kRemoteContent,
174 drive_service_->GetRootResourceId(),
175 title,
176 false, // shared_with_me
177 google_apis::test_util::CreateCopyResultCallback(&error, &entry));
178 base::RunLoop().RunUntilIdle();
179 ASSERT_EQ(google_apis::HTTP_CREATED, error);
180 ASSERT_TRUE(entry);
[email protected]31258442014-06-05 03:37:41181 resource_ids_[title] = entry->file_id();
[email protected]b568b882013-06-10 04:38:07182 }
183
184 // Sets up data for tests.
185 void SetUpTestData() {
[email protected]e63bdc972012-11-22 12:10:48186 // Prepare a temp file.
[email protected]650b2d52013-02-10 03:41:45187 base::FilePath temp_file;
vabr96fd0c0f2016-09-13 14:21:31188 EXPECT_TRUE(
189 base::CreateTemporaryFileInDir(temp_dir_.GetPath(), &temp_file));
[email protected]b568b882013-06-10 04:38:07190 ASSERT_TRUE(google_apis::test_util::WriteStringToFile(temp_file,
191 kLocalContent));
[email protected]b83e5202012-06-27 07:50:24192
[email protected]efd37ff2013-10-11 03:27:57193 // Add file entries to the service.
[email protected]b568b882013-06-10 04:38:07194 ASSERT_NO_FATAL_FAILURE(AddFileEntry("foo"));
[email protected]b568b882013-06-10 04:38:07195 ASSERT_NO_FATAL_FAILURE(AddFileEntry("bar"));
[email protected]b568b882013-06-10 04:38:07196 ASSERT_NO_FATAL_FAILURE(AddFileEntry("baz"));
[email protected]b568b882013-06-10 04:38:07197 ASSERT_NO_FATAL_FAILURE(AddFileEntry("fetched"));
[email protected]b568b882013-06-10 04:38:07198 ASSERT_NO_FATAL_FAILURE(AddFileEntry("dirty"));
[email protected]562af1c12013-11-26 10:27:53199 ASSERT_NO_FATAL_FAILURE(AddFileEntry("removed"));
[email protected]5170a132013-12-02 10:35:13200 ASSERT_NO_FATAL_FAILURE(AddFileEntry("moved"));
[email protected]adf84402012-03-25 21:56:38201
[email protected]b568b882013-06-10 04:38:07202 // Load data from the service to the metadata.
203 FileError error = FILE_ERROR_FAILED;
[email protected]53f57102014-02-26 03:39:03204 change_list_loader_->LoadIfNeeded(
[email protected]b568b882013-06-10 04:38:07205 google_apis::test_util::CreateCopyResultCallback(&error));
206 base::RunLoop().RunUntilIdle();
207 EXPECT_EQ(FILE_ERROR_OK, error);
[email protected]efd37ff2013-10-11 03:27:57208
209 // Prepare 3 pinned-but-not-present files.
210 EXPECT_EQ(FILE_ERROR_OK, cache_->Pin(GetLocalId("foo")));
211 EXPECT_EQ(FILE_ERROR_OK, cache_->Pin(GetLocalId("bar")));
212 EXPECT_EQ(FILE_ERROR_OK, cache_->Pin(GetLocalId("baz")));
213
214 // Prepare a pinned-and-fetched file.
215 const std::string md5_fetched = "md5";
216 EXPECT_EQ(FILE_ERROR_OK,
217 cache_->Store(GetLocalId("fetched"), md5_fetched,
218 temp_file, FileCache::FILE_OPERATION_COPY));
219 EXPECT_EQ(FILE_ERROR_OK, cache_->Pin(GetLocalId("fetched")));
220
221 // Prepare a pinned-and-fetched-and-dirty file.
[email protected]efd37ff2013-10-11 03:27:57222 EXPECT_EQ(FILE_ERROR_OK,
[email protected]bae99ae52014-01-29 01:13:14223 cache_->Store(GetLocalId("dirty"), std::string(),
[email protected]efd37ff2013-10-11 03:27:57224 temp_file, FileCache::FILE_OPERATION_COPY));
225 EXPECT_EQ(FILE_ERROR_OK, cache_->Pin(GetLocalId("dirty")));
[email protected]efd37ff2013-10-11 03:27:57226
[email protected]562af1c12013-11-26 10:27:53227 // Prepare a removed file.
228 file_system::RemoveOperation remove_operation(
pranay.kumar229290b52015-05-14 05:21:04229 base::ThreadTaskRunnerHandle::Get().get(), &delegate_, metadata_.get(),
[email protected]562af1c12013-11-26 10:27:53230 cache_.get());
231 remove_operation.Remove(
[email protected]86097a0a2014-05-12 09:25:19232 util::GetDriveMyDriveRootPath().AppendASCII("removed"),
[email protected]562af1c12013-11-26 10:27:53233 false, // is_recursive
234 google_apis::test_util::CreateCopyResultCallback(&error));
235 base::RunLoop().RunUntilIdle();
236 EXPECT_EQ(FILE_ERROR_OK, error);
[email protected]5170a132013-12-02 10:35:13237
238 // Prepare a moved file.
239 file_system::MoveOperation move_operation(
pranay.kumar229290b52015-05-14 05:21:04240 base::ThreadTaskRunnerHandle::Get().get(), &delegate_, metadata_.get());
[email protected]5170a132013-12-02 10:35:13241 move_operation.Move(
[email protected]86097a0a2014-05-12 09:25:19242 util::GetDriveMyDriveRootPath().AppendASCII("moved"),
[email protected]5170a132013-12-02 10:35:13243 util::GetDriveMyDriveRootPath().AppendASCII("moved_new_title"),
[email protected]5170a132013-12-02 10:35:13244 google_apis::test_util::CreateCopyResultCallback(&error));
245 base::RunLoop().RunUntilIdle();
246 EXPECT_EQ(FILE_ERROR_OK, error);
[email protected]b83e5202012-06-27 07:50:24247 }
248
[email protected]ffd60e432012-03-24 20:36:00249 protected:
[email protected]efd37ff2013-10-11 03:27:57250 std::string GetLocalId(const std::string& title) {
251 EXPECT_EQ(1U, resource_ids_.count(title));
252 std::string local_id;
253 EXPECT_EQ(FILE_ERROR_OK,
254 metadata_->GetIdByResourceId(resource_ids_[title], &local_id));
255 return local_id;
256 }
257
Gabriel Charette798fde72019-08-20 22:24:04258 content::BrowserTaskEnvironment task_environment_;
[email protected]ea1a3f62012-11-16 20:34:23259 base::ScopedTempDir temp_dir_;
dchengf42750232016-04-12 04:12:27260 std::unique_ptr<TestingPrefServiceSimple> pref_service_;
dchengf42750232016-04-12 04:12:27261 std::unique_ptr<EventLogger> logger_;
262 std::unique_ptr<SyncClientTestDriveService> drive_service_;
[email protected]4ffef212014-07-24 02:33:18263 file_system::OperationDelegate delegate_;
dchengf42750232016-04-12 04:12:27264 std::unique_ptr<JobScheduler> scheduler_;
265 std::unique_ptr<ResourceMetadataStorage, test_util::DestroyHelperForTests>
266 metadata_storage_;
267 std::unique_ptr<FileCache, test_util::DestroyHelperForTests> cache_;
268 std::unique_ptr<ResourceMetadata, test_util::DestroyHelperForTests> metadata_;
269 std::unique_ptr<AboutResourceLoader> about_resource_loader_;
Stuart Langleyc92ed252018-05-16 08:38:34270 std::unique_ptr<StartPageTokenLoader> start_page_token_loader_;
dchengf42750232016-04-12 04:12:27271 std::unique_ptr<LoaderController> loader_controller_;
272 std::unique_ptr<ChangeListLoader> change_list_loader_;
273 std::unique_ptr<SyncClient> sync_client_;
Stuart Langley24e4ff52018-05-25 00:29:19274 std::unique_ptr<AboutResourceRootFolderIdLoader> root_folder_id_loader_;
[email protected]b568b882013-06-10 04:38:07275
276 std::map<std::string, std::string> resource_ids_; // Name-to-id map.
[email protected]92b84f332012-03-21 20:45:21277};
278
[email protected]b568b882013-06-10 04:38:07279TEST_F(SyncClientTest, StartProcessingBacklog) {
[email protected]b83e5202012-06-27 07:50:24280 sync_client_->StartProcessingBacklog();
[email protected]b568b882013-06-10 04:38:07281 base::RunLoop().RunUntilIdle();
[email protected]92b84f332012-03-21 20:45:21282
[email protected]9971db12014-05-16 06:57:12283 ResourceEntry entry;
[email protected]b568b882013-06-10 04:38:07284 // Pinned files get downloaded.
[email protected]bbd72ec2014-05-12 09:27:04285 EXPECT_EQ(FILE_ERROR_OK,
[email protected]9971db12014-05-16 06:57:12286 metadata_->GetResourceEntryById(GetLocalId("foo"), &entry));
287 EXPECT_TRUE(entry.file_specific_info().cache_state().is_present());
[email protected]b83e5202012-06-27 07:50:24288
[email protected]bbd72ec2014-05-12 09:27:04289 EXPECT_EQ(FILE_ERROR_OK,
[email protected]9971db12014-05-16 06:57:12290 metadata_->GetResourceEntryById(GetLocalId("bar"), &entry));
291 EXPECT_TRUE(entry.file_specific_info().cache_state().is_present());
[email protected]b568b882013-06-10 04:38:07292
[email protected]bbd72ec2014-05-12 09:27:04293 EXPECT_EQ(FILE_ERROR_OK,
[email protected]9971db12014-05-16 06:57:12294 metadata_->GetResourceEntryById(GetLocalId("baz"), &entry));
295 EXPECT_TRUE(entry.file_specific_info().cache_state().is_present());
[email protected]b568b882013-06-10 04:38:07296
297 // Dirty file gets uploaded.
[email protected]bbd72ec2014-05-12 09:27:04298 EXPECT_EQ(FILE_ERROR_OK,
[email protected]9971db12014-05-16 06:57:12299 metadata_->GetResourceEntryById(GetLocalId("dirty"), &entry));
300 EXPECT_FALSE(entry.file_specific_info().cache_state().is_dirty());
[email protected]562af1c12013-11-26 10:27:53301
302 // Removed entry is not found.
satorux1e04b422015-01-29 07:50:53303 google_apis::DriveApiErrorCode status = google_apis::DRIVE_OTHER_ERROR;
dchengf42750232016-04-12 04:12:27304 std::unique_ptr<google_apis::FileResource> server_entry;
[email protected]31258442014-06-05 03:37:41305 drive_service_->GetFileResource(
[email protected]562af1c12013-11-26 10:27:53306 resource_ids_["removed"],
[email protected]31258442014-06-05 03:37:41307 google_apis::test_util::CreateCopyResultCallback(&status, &server_entry));
[email protected]562af1c12013-11-26 10:27:53308 base::RunLoop().RunUntilIdle();
309 EXPECT_EQ(google_apis::HTTP_SUCCESS, status);
[email protected]31258442014-06-05 03:37:41310 ASSERT_TRUE(server_entry);
311 EXPECT_TRUE(server_entry->labels().is_trashed());
[email protected]5170a132013-12-02 10:35:13312
313 // Moved entry was moved.
satorux1e04b422015-01-29 07:50:53314 status = google_apis::DRIVE_OTHER_ERROR;
[email protected]31258442014-06-05 03:37:41315 drive_service_->GetFileResource(
[email protected]5170a132013-12-02 10:35:13316 resource_ids_["moved"],
[email protected]31258442014-06-05 03:37:41317 google_apis::test_util::CreateCopyResultCallback(&status, &server_entry));
[email protected]5170a132013-12-02 10:35:13318 base::RunLoop().RunUntilIdle();
319 EXPECT_EQ(google_apis::HTTP_SUCCESS, status);
[email protected]31258442014-06-05 03:37:41320 ASSERT_TRUE(server_entry);
321 EXPECT_EQ("moved_new_title", server_entry->title());
[email protected]a5381772012-04-05 02:20:04322}
323
[email protected]bd2254d2013-06-12 16:00:47324TEST_F(SyncClientTest, AddFetchTask) {
[email protected]efd37ff2013-10-11 03:27:57325 sync_client_->AddFetchTask(GetLocalId("foo"));
[email protected]b568b882013-06-10 04:38:07326 base::RunLoop().RunUntilIdle();
[email protected]67e264a2013-06-03 05:39:01327
[email protected]9971db12014-05-16 06:57:12328 ResourceEntry entry;
[email protected]bbd72ec2014-05-12 09:27:04329 EXPECT_EQ(FILE_ERROR_OK,
[email protected]9971db12014-05-16 06:57:12330 metadata_->GetResourceEntryById(GetLocalId("foo"), &entry));
331 EXPECT_TRUE(entry.file_specific_info().cache_state().is_present());
[email protected]adf84402012-03-25 21:56:38332}
333
[email protected]bd2254d2013-06-12 16:00:47334TEST_F(SyncClientTest, AddFetchTaskAndCancelled) {
[email protected]61a41c12013-06-06 06:23:36335 // Trigger fetching of a file which results in cancellation.
[email protected]bd2254d2013-06-12 16:00:47336 drive_service_->set_resource_id_to_be_cancelled(resource_ids_["foo"]);
[email protected]efd37ff2013-10-11 03:27:57337 sync_client_->AddFetchTask(GetLocalId("foo"));
[email protected]b568b882013-06-10 04:38:07338 base::RunLoop().RunUntilIdle();
[email protected]61a41c12013-06-06 06:23:36339
340 // The file should be unpinned if the user wants the download to be cancelled.
[email protected]9971db12014-05-16 06:57:12341 ResourceEntry entry;
342 EXPECT_EQ(FILE_ERROR_OK,
343 metadata_->GetResourceEntryById(GetLocalId("foo"), &entry));
344 EXPECT_FALSE(entry.file_specific_info().cache_state().is_pinned());
[email protected]61a41c12013-06-06 06:23:36345}
346
[email protected]bd2254d2013-06-12 16:00:47347TEST_F(SyncClientTest, RemoveFetchTask) {
[email protected]efd37ff2013-10-11 03:27:57348 sync_client_->AddFetchTask(GetLocalId("foo"));
349 sync_client_->AddFetchTask(GetLocalId("bar"));
350 sync_client_->AddFetchTask(GetLocalId("baz"));
[email protected]adf84402012-03-25 21:56:38351
[email protected]efd37ff2013-10-11 03:27:57352 sync_client_->RemoveFetchTask(GetLocalId("foo"));
353 sync_client_->RemoveFetchTask(GetLocalId("baz"));
[email protected]b568b882013-06-10 04:38:07354 base::RunLoop().RunUntilIdle();
[email protected]e07bbd972013-01-23 17:38:42355
[email protected]b568b882013-06-10 04:38:07356 // Only "bar" should be fetched.
[email protected]9971db12014-05-16 06:57:12357 ResourceEntry entry;
[email protected]bbd72ec2014-05-12 09:27:04358 EXPECT_EQ(FILE_ERROR_OK,
[email protected]9971db12014-05-16 06:57:12359 metadata_->GetResourceEntryById(GetLocalId("foo"), &entry));
360 EXPECT_FALSE(entry.file_specific_info().cache_state().is_present());
[email protected]b568b882013-06-10 04:38:07361
[email protected]bbd72ec2014-05-12 09:27:04362 EXPECT_EQ(FILE_ERROR_OK,
[email protected]9971db12014-05-16 06:57:12363 metadata_->GetResourceEntryById(GetLocalId("bar"), &entry));
364 EXPECT_TRUE(entry.file_specific_info().cache_state().is_present());
[email protected]b568b882013-06-10 04:38:07365
[email protected]bbd72ec2014-05-12 09:27:04366 EXPECT_EQ(FILE_ERROR_OK,
[email protected]9971db12014-05-16 06:57:12367 metadata_->GetResourceEntryById(GetLocalId("baz"), &entry));
368 EXPECT_FALSE(entry.file_specific_info().cache_state().is_present());
[email protected]b568b882013-06-10 04:38:07369
[email protected]adf84402012-03-25 21:56:38370}
371
[email protected]d876d70b2013-04-23 20:06:15372TEST_F(SyncClientTest, ExistingPinnedFiles) {
[email protected]85b62192012-06-29 19:56:38373 // Start checking the existing pinned files. This will collect the resource
374 // IDs of pinned files, with stale local cache files.
375 sync_client_->StartCheckingExistingPinnedFiles();
[email protected]b568b882013-06-10 04:38:07376 base::RunLoop().RunUntilIdle();
[email protected]67e264a2013-06-03 05:39:01377
[email protected]b568b882013-06-10 04:38:07378 // "fetched" and "dirty" are the existing pinned files.
379 // The non-dirty one should be synced, but the dirty one should not.
380 base::FilePath cache_file;
381 std::string content;
[email protected]efd37ff2013-10-11 03:27:57382 EXPECT_EQ(FILE_ERROR_OK, cache_->GetFile(GetLocalId("fetched"), &cache_file));
[email protected]82f84b92013-08-30 18:23:50383 EXPECT_TRUE(base::ReadFileToString(cache_file, &content));
[email protected]b568b882013-06-10 04:38:07384 EXPECT_EQ(kRemoteContent, content);
385 content.clear();
386
[email protected]efd37ff2013-10-11 03:27:57387 EXPECT_EQ(FILE_ERROR_OK, cache_->GetFile(GetLocalId("dirty"), &cache_file));
[email protected]82f84b92013-08-30 18:23:50388 EXPECT_TRUE(base::ReadFileToString(cache_file, &content));
[email protected]b568b882013-06-10 04:38:07389 EXPECT_EQ(kLocalContent, content);
[email protected]189541ba2012-10-24 11:18:15390}
391
[email protected]d2c08b72013-07-02 08:23:48392TEST_F(SyncClientTest, RetryOnDisconnection) {
393 // Let the service go down.
394 drive_service_->set_offline(true);
395 // Change the network connection state after some delay, to test that
396 // FILE_ERROR_NO_CONNECTION is handled by SyncClient correctly.
397 // Without this delay, JobScheduler will keep the jobs unrun and SyncClient
398 // will receive no error.
pranay.kumar229290b52015-05-14 05:21:04399 base::ThreadTaskRunnerHandle::Get()->PostDelayedTask(
[email protected]d2c08b72013-07-02 08:23:48400 FROM_HERE,
Jun Cai065916a2018-12-18 03:06:43401 base::BindOnce(&network::TestNetworkConnectionTracker::SetConnectionType,
402 base::Unretained(
403 network::TestNetworkConnectionTracker::GetInstance()),
404 network::mojom::ConnectionType::CONNECTION_NONE),
[email protected]d2c08b72013-07-02 08:23:48405 TestTimeouts::tiny_timeout());
406
407 // Try fetch and upload.
[email protected]efd37ff2013-10-11 03:27:57408 sync_client_->AddFetchTask(GetLocalId("foo"));
[email protected]bfcaaf332014-01-27 06:34:59409 sync_client_->AddUpdateTask(ClientContext(USER_INITIATED),
[email protected]882e3202013-11-25 08:33:50410 GetLocalId("dirty"));
[email protected]d2c08b72013-07-02 08:23:48411 base::RunLoop().RunUntilIdle();
412
413 // Not yet fetched nor uploaded.
[email protected]9971db12014-05-16 06:57:12414 ResourceEntry entry;
[email protected]bbd72ec2014-05-12 09:27:04415 EXPECT_EQ(FILE_ERROR_OK,
[email protected]9971db12014-05-16 06:57:12416 metadata_->GetResourceEntryById(GetLocalId("foo"), &entry));
417 EXPECT_FALSE(entry.file_specific_info().cache_state().is_present());
[email protected]bbd72ec2014-05-12 09:27:04418 EXPECT_EQ(FILE_ERROR_OK,
[email protected]9971db12014-05-16 06:57:12419 metadata_->GetResourceEntryById(GetLocalId("dirty"), &entry));
420 EXPECT_TRUE(entry.file_specific_info().cache_state().is_dirty());
[email protected]d2c08b72013-07-02 08:23:48421
422 // Switch to online.
Jun Cai065916a2018-12-18 03:06:43423 network::TestNetworkConnectionTracker::GetInstance()->SetConnectionType(
424 network::mojom::ConnectionType::CONNECTION_WIFI);
[email protected]d2c08b72013-07-02 08:23:48425 drive_service_->set_offline(false);
426 base::RunLoop().RunUntilIdle();
427
428 // Fetched and uploaded.
[email protected]bbd72ec2014-05-12 09:27:04429 EXPECT_EQ(FILE_ERROR_OK,
[email protected]9971db12014-05-16 06:57:12430 metadata_->GetResourceEntryById(GetLocalId("foo"), &entry));
431 EXPECT_TRUE(entry.file_specific_info().cache_state().is_present());
[email protected]bbd72ec2014-05-12 09:27:04432 EXPECT_EQ(FILE_ERROR_OK,
[email protected]9971db12014-05-16 06:57:12433 metadata_->GetResourceEntryById(GetLocalId("dirty"), &entry));
434 EXPECT_FALSE(entry.file_specific_info().cache_state().is_dirty());
[email protected]d2c08b72013-07-02 08:23:48435}
436
[email protected]799d4ec2013-12-06 07:39:23437TEST_F(SyncClientTest, ScheduleRerun) {
438 // Add a fetch task for "foo", this should result in being paused.
439 drive_service_->set_resource_id_to_be_paused(resource_ids_["foo"]);
440 sync_client_->AddFetchTask(GetLocalId("foo"));
441 base::RunLoop().RunUntilIdle();
442
443 // While the first task is paused, add a task again.
444 // This results in scheduling rerun of the task.
445 sync_client_->AddFetchTask(GetLocalId("foo"));
446 base::RunLoop().RunUntilIdle();
447
448 // Resume the paused task.
449 drive_service_->set_resource_id_to_be_paused(std::string());
450 ASSERT_FALSE(drive_service_->paused_action().is_null());
451 drive_service_->paused_action().Run();
452 base::RunLoop().RunUntilIdle();
453
454 // Task should be run twice.
455 EXPECT_EQ(2, drive_service_->download_file_count());
456}
457
[email protected]99bd5432014-02-03 06:53:38458TEST_F(SyncClientTest, Dependencies) {
459 // Create directories locally.
460 const base::FilePath kPath1(FILE_PATH_LITERAL("drive/root/dir1"));
461 const base::FilePath kPath2 = kPath1.AppendASCII("dir2");
462
463 ResourceEntry parent;
464 EXPECT_EQ(FILE_ERROR_OK,
465 metadata_->GetResourceEntryByPath(kPath1.DirName(), &parent));
466
467 ResourceEntry entry1;
468 entry1.set_parent_local_id(parent.local_id());
469 entry1.set_title(kPath1.BaseName().AsUTF8Unsafe());
470 entry1.mutable_file_info()->set_is_directory(true);
471 entry1.set_metadata_edit_state(ResourceEntry::DIRTY);
472 std::string local_id1;
473 EXPECT_EQ(FILE_ERROR_OK, metadata_->AddEntry(entry1, &local_id1));
474
475 ResourceEntry entry2;
476 entry2.set_parent_local_id(local_id1);
477 entry2.set_title(kPath2.BaseName().AsUTF8Unsafe());
478 entry2.mutable_file_info()->set_is_directory(true);
479 entry2.set_metadata_edit_state(ResourceEntry::DIRTY);
480 std::string local_id2;
481 EXPECT_EQ(FILE_ERROR_OK, metadata_->AddEntry(entry2, &local_id2));
482
483 // Start syncing the child first.
484 sync_client_->AddUpdateTask(ClientContext(USER_INITIATED), local_id2);
[email protected]99bd5432014-02-03 06:53:38485 // Start syncing the parent later.
486 sync_client_->AddUpdateTask(ClientContext(USER_INITIATED), local_id1);
487 base::RunLoop().RunUntilIdle();
488
489 // Both entries are synced.
490 EXPECT_EQ(FILE_ERROR_OK, metadata_->GetResourceEntryById(local_id1, &entry1));
491 EXPECT_EQ(ResourceEntry::CLEAN, entry1.metadata_edit_state());
492 EXPECT_EQ(FILE_ERROR_OK, metadata_->GetResourceEntryById(local_id2, &entry2));
493 EXPECT_EQ(ResourceEntry::CLEAN, entry2.metadata_edit_state());
494}
495
[email protected]e849db52014-07-23 07:02:09496TEST_F(SyncClientTest, WaitForUpdateTaskToComplete) {
497 // Create a directory locally.
498 const base::FilePath kPath(FILE_PATH_LITERAL("drive/root/dir1"));
499
500 ResourceEntry parent;
501 EXPECT_EQ(FILE_ERROR_OK,
502 metadata_->GetResourceEntryByPath(kPath.DirName(), &parent));
503
504 ResourceEntry entry;
505 entry.set_parent_local_id(parent.local_id());
506 entry.set_title(kPath.BaseName().AsUTF8Unsafe());
507 entry.mutable_file_info()->set_is_directory(true);
508 entry.set_metadata_edit_state(ResourceEntry::DIRTY);
509 std::string local_id;
510 EXPECT_EQ(FILE_ERROR_OK, metadata_->AddEntry(entry, &local_id));
511
512 // Sync task is not yet avialable.
513 FileError error = FILE_ERROR_FAILED;
514 EXPECT_FALSE(sync_client_->WaitForUpdateTaskToComplete(
515 local_id, google_apis::test_util::CreateCopyResultCallback(&error)));
516
517 // Start syncing the directory and wait for it to complete.
518 sync_client_->AddUpdateTask(ClientContext(USER_INITIATED), local_id);
519
520 EXPECT_TRUE(sync_client_->WaitForUpdateTaskToComplete(
521 local_id, google_apis::test_util::CreateCopyResultCallback(&error)));
522
523 base::RunLoop().RunUntilIdle();
524
525 // The callback is called.
526 EXPECT_EQ(FILE_ERROR_OK, error);
527}
528
[email protected]4e87c4862013-05-20 04:06:32529} // namespace internal
[email protected]d9d04df2012-10-12 07:06:35530} // namespace drive