OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // 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 | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include <string> | 5 #include <string> |
6 #include <vector> | 6 #include <vector> |
7 | 7 |
8 #include "base/bind.h" | 8 #include "base/bind.h" |
9 #include "base/file_path.h" | 9 #include "base/file_path.h" |
10 #include "base/file_util.h" | 10 #include "base/file_util.h" |
11 #include "base/json/json_file_value_serializer.h" | 11 #include "base/json/json_file_value_serializer.h" |
12 #include "base/memory/scoped_ptr.h" | 12 #include "base/memory/scoped_ptr.h" |
13 #include "base/message_loop.h" | 13 #include "base/message_loop.h" |
14 #include "base/path_service.h" | 14 #include "base/path_service.h" |
15 #include "base/scoped_temp_dir.h" | 15 #include "base/scoped_temp_dir.h" |
16 #include "base/stringprintf.h" | 16 #include "base/stringprintf.h" |
17 #include "base/threading/sequenced_worker_pool.h" | 17 #include "base/threading/sequenced_worker_pool.h" |
18 #include "base/values.h" | 18 #include "base/values.h" |
19 #include "chrome/browser/chromeos/cros/cros_library.h" | 19 #include "chrome/browser/chromeos/cros/cros_library.h" |
20 #include "chrome/browser/chromeos/gdata/drive.pb.h" | 20 #include "chrome/browser/chromeos/gdata/drive.pb.h" |
21 #include "chrome/browser/chromeos/gdata/drive_api_parser.h" | 21 #include "chrome/browser/chromeos/gdata/drive_api_parser.h" |
22 #include "chrome/browser/chromeos/gdata/drive_file_system.h" | 22 #include "chrome/browser/chromeos/gdata/drive_file_system.h" |
23 #include "chrome/browser/chromeos/gdata/drive_file_system_util.h" | 23 #include "chrome/browser/chromeos/gdata/drive_file_system_util.h" |
24 #include "chrome/browser/chromeos/gdata/drive_function_remove.h" | 24 #include "chrome/browser/chromeos/gdata/drive_function_remove.h" |
| 25 #include "chrome/browser/chromeos/gdata/drive_uploader.h" |
25 #include "chrome/browser/chromeos/gdata/drive_webapps_registry.h" | 26 #include "chrome/browser/chromeos/gdata/drive_webapps_registry.h" |
26 #include "chrome/browser/chromeos/gdata/gdata_test_util.h" | 27 #include "chrome/browser/chromeos/gdata/gdata_test_util.h" |
27 #include "chrome/browser/chromeos/gdata/gdata_uploader.h" | |
28 #include "chrome/browser/chromeos/gdata/mock_directory_change_observer.h" | 28 #include "chrome/browser/chromeos/gdata/mock_directory_change_observer.h" |
29 #include "chrome/browser/chromeos/gdata/mock_drive_cache_observer.h" | 29 #include "chrome/browser/chromeos/gdata/mock_drive_cache_observer.h" |
30 #include "chrome/browser/chromeos/gdata/mock_drive_service.h" | 30 #include "chrome/browser/chromeos/gdata/mock_drive_service.h" |
31 #include "chrome/browser/chromeos/gdata/mock_drive_web_apps_registry.h" | 31 #include "chrome/browser/chromeos/gdata/mock_drive_web_apps_registry.h" |
32 #include "chrome/browser/chromeos/gdata/mock_free_disk_space_getter.h" | 32 #include "chrome/browser/chromeos/gdata/mock_free_disk_space_getter.h" |
33 #include "chrome/common/chrome_paths.h" | 33 #include "chrome/common/chrome_paths.h" |
34 #include "chrome/test/base/testing_profile.h" | 34 #include "chrome/test/base/testing_profile.h" |
35 #include "content/public/browser/browser_thread.h" | 35 #include "content/public/browser/browser_thread.h" |
36 #include "content/public/test/test_browser_thread.h" | 36 #include "content/public/test/test_browser_thread.h" |
37 #include "testing/gmock/include/gmock/gmock.h" | 37 #include "testing/gmock/include/gmock/gmock.h" |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
80 } | 80 } |
81 | 81 |
82 // Action used to set mock expectations for | 82 // Action used to set mock expectations for |
83 // DriveServiceInterface::GetDocumentEntry(). | 83 // DriveServiceInterface::GetDocumentEntry(). |
84 ACTION_P2(MockGetDocumentEntry, status, value) { | 84 ACTION_P2(MockGetDocumentEntry, status, value) { |
85 base::MessageLoopProxy::current()->PostTask(FROM_HERE, | 85 base::MessageLoopProxy::current()->PostTask(FROM_HERE, |
86 base::Bind(arg1, status, base::Passed(value))); | 86 base::Bind(arg1, status, base::Passed(value))); |
87 } | 87 } |
88 | 88 |
89 // Action used to set mock expectations for | 89 // Action used to set mock expectations for |
90 // GDataUploaderInterface::UploadExistingFile(). | 90 // DriveUploaderInterface::UploadExistingFile(). |
91 ACTION_P4(MockUploadExistingFile, | 91 ACTION_P4(MockUploadExistingFile, |
92 error, gdata_path, local_file_path, document_entry) { | 92 error, drive_path, local_file_path, document_entry) { |
93 scoped_ptr<UploadFileInfo> upload_file_info(new UploadFileInfo); | 93 scoped_ptr<UploadFileInfo> upload_file_info(new UploadFileInfo); |
94 upload_file_info->gdata_path = gdata_path; | 94 upload_file_info->drive_path = drive_path; |
95 upload_file_info->file_path = local_file_path; | 95 upload_file_info->file_path = local_file_path; |
96 upload_file_info->entry.reset(document_entry); | 96 upload_file_info->entry.reset(document_entry); |
97 base::MessageLoopProxy::current()->PostTask(FROM_HERE, | 97 base::MessageLoopProxy::current()->PostTask(FROM_HERE, |
98 base::Bind(arg5, error, base::Passed(&upload_file_info))); | 98 base::Bind(arg5, error, base::Passed(&upload_file_info))); |
99 | 99 |
100 const int kUploadId = 123; | 100 const int kUploadId = 123; |
101 return kUploadId; | 101 return kUploadId; |
102 } | 102 } |
103 | 103 |
104 // Action used to set mock expectations for | 104 // Action used to set mock expectations for |
105 // DriveFileSystem::CopyDocument(). | 105 // DriveFileSystem::CopyDocument(). |
106 ACTION_P2(MockCopyDocument, status, value) { | 106 ACTION_P2(MockCopyDocument, status, value) { |
107 base::MessageLoopProxy::current()->PostTask( | 107 base::MessageLoopProxy::current()->PostTask( |
108 FROM_HERE, | 108 FROM_HERE, |
109 base::Bind(arg2, status, base::Passed(value))); | 109 base::Bind(arg2, status, base::Passed(value))); |
110 } | 110 } |
111 | 111 |
112 // Counts the number of files (not directories) in |entries|. | 112 // Counts the number of files (not directories) in |entries|. |
113 int CountFiles(const DriveEntryProtoVector& entries) { | 113 int CountFiles(const DriveEntryProtoVector& entries) { |
114 int num_files = 0; | 114 int num_files = 0; |
115 for (size_t i = 0; i < entries.size(); ++i) { | 115 for (size_t i = 0; i < entries.size(); ++i) { |
116 if (!entries[i].file_info().is_directory()) | 116 if (!entries[i].file_info().is_directory()) |
117 ++num_files; | 117 ++num_files; |
118 } | 118 } |
119 return num_files; | 119 return num_files; |
120 } | 120 } |
121 | 121 |
122 } // namespace | 122 } // namespace |
123 | 123 |
124 class MockGDataUploader : public GDataUploaderInterface { | 124 class MockDriveUploader : public DriveUploaderInterface { |
125 public: | 125 public: |
126 virtual ~MockGDataUploader() {} | 126 virtual ~MockDriveUploader() {} |
127 // This function is not mockable by gmock. | 127 // This function is not mockable by gmock. |
128 virtual int UploadNewFile( | 128 virtual int UploadNewFile( |
129 scoped_ptr<UploadFileInfo> upload_file_info) OVERRIDE { | 129 scoped_ptr<UploadFileInfo> upload_file_info) OVERRIDE { |
130 // Set a document entry for an uploaded file. | 130 // Set a document entry for an uploaded file. |
131 // Used for TransferFileFromLocalToRemote_RegularFile test. | 131 // Used for TransferFileFromLocalToRemote_RegularFile test. |
132 scoped_ptr<base::Value> value( | 132 scoped_ptr<base::Value> value( |
133 test_util::LoadJSONFile("uploaded_file.json")); | 133 test_util::LoadJSONFile("uploaded_file.json")); |
134 scoped_ptr<DocumentEntry> document_entry( | 134 scoped_ptr<DocumentEntry> document_entry( |
135 DocumentEntry::ExtractAndParse(*value)); | 135 DocumentEntry::ExtractAndParse(*value)); |
136 upload_file_info->entry = document_entry.Pass(); | 136 upload_file_info->entry = document_entry.Pass(); |
(...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
199 SetFreeDiskSpaceGetterForTesting(mock_free_disk_space_checker_); | 199 SetFreeDiskSpaceGetterForTesting(mock_free_disk_space_checker_); |
200 | 200 |
201 scoped_refptr<base::SequencedWorkerPool> pool = | 201 scoped_refptr<base::SequencedWorkerPool> pool = |
202 content::BrowserThread::GetBlockingPool(); | 202 content::BrowserThread::GetBlockingPool(); |
203 blocking_task_runner_ = | 203 blocking_task_runner_ = |
204 pool->GetSequencedTaskRunner(pool->GetSequenceToken()); | 204 pool->GetSequencedTaskRunner(pool->GetSequenceToken()); |
205 | 205 |
206 cache_ = DriveCache::CreateDriveCacheOnUIThread( | 206 cache_ = DriveCache::CreateDriveCacheOnUIThread( |
207 DriveCache::GetCacheRootPath(profile_.get()), blocking_task_runner_); | 207 DriveCache::GetCacheRootPath(profile_.get()), blocking_task_runner_); |
208 | 208 |
209 mock_uploader_.reset(new StrictMock<MockGDataUploader>); | 209 mock_uploader_.reset(new StrictMock<MockDriveUploader>); |
210 mock_webapps_registry_.reset(new StrictMock<MockDriveWebAppsRegistry>); | 210 mock_webapps_registry_.reset(new StrictMock<MockDriveWebAppsRegistry>); |
211 | 211 |
212 ASSERT_FALSE(file_system_); | 212 ASSERT_FALSE(file_system_); |
213 file_system_ = new DriveFileSystem(profile_.get(), | 213 file_system_ = new DriveFileSystem(profile_.get(), |
214 cache_, | 214 cache_, |
215 mock_drive_service_, | 215 mock_drive_service_, |
216 mock_uploader_.get(), | 216 mock_uploader_.get(), |
217 mock_webapps_registry_.get(), | 217 mock_webapps_registry_.get(), |
218 blocking_task_runner_); | 218 blocking_task_runner_); |
219 | 219 |
(...skipping 581 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
801 | 801 |
802 MessageLoopForUI message_loop_; | 802 MessageLoopForUI message_loop_; |
803 // The order of the test threads is important, do not change the order. | 803 // The order of the test threads is important, do not change the order. |
804 // See also content/browser/browser_thread_impl.cc. | 804 // See also content/browser/browser_thread_impl.cc. |
805 content::TestBrowserThread ui_thread_; | 805 content::TestBrowserThread ui_thread_; |
806 content::TestBrowserThread io_thread_; | 806 content::TestBrowserThread io_thread_; |
807 scoped_refptr<base::SequencedTaskRunner> blocking_task_runner_; | 807 scoped_refptr<base::SequencedTaskRunner> blocking_task_runner_; |
808 scoped_ptr<TestingProfile> profile_; | 808 scoped_ptr<TestingProfile> profile_; |
809 scoped_refptr<CallbackHelper> callback_helper_; | 809 scoped_refptr<CallbackHelper> callback_helper_; |
810 DriveCache* cache_; | 810 DriveCache* cache_; |
811 scoped_ptr<StrictMock<MockGDataUploader> > mock_uploader_; | 811 scoped_ptr<StrictMock<MockDriveUploader> > mock_uploader_; |
812 DriveFileSystem* file_system_; | 812 DriveFileSystem* file_system_; |
813 StrictMock<MockDriveService>* mock_drive_service_; | 813 StrictMock<MockDriveService>* mock_drive_service_; |
814 scoped_ptr<StrictMock<MockDriveWebAppsRegistry> > mock_webapps_registry_; | 814 scoped_ptr<StrictMock<MockDriveWebAppsRegistry> > mock_webapps_registry_; |
815 StrictMock<MockFreeDiskSpaceGetter>* mock_free_disk_space_checker_; | 815 StrictMock<MockFreeDiskSpaceGetter>* mock_free_disk_space_checker_; |
816 scoped_ptr<StrictMock<MockDriveCacheObserver> > mock_cache_observer_; | 816 scoped_ptr<StrictMock<MockDriveCacheObserver> > mock_cache_observer_; |
817 scoped_ptr<StrictMock<MockDirectoryChangeObserver> > mock_directory_observer_; | 817 scoped_ptr<StrictMock<MockDirectoryChangeObserver> > mock_directory_observer_; |
818 | 818 |
819 int num_callback_invocations_; | 819 int num_callback_invocations_; |
820 DriveFileError expected_error_; | 820 DriveFileError expected_error_; |
821 int expected_cache_state_; | 821 int expected_cache_state_; |
(...skipping 1516 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2338 test_util::TEST_CACHE_STATE_PERSISTENT, | 2338 test_util::TEST_CACHE_STATE_PERSISTENT, |
2339 DriveCache::CACHE_TYPE_PERSISTENT); | 2339 DriveCache::CACHE_TYPE_PERSISTENT); |
2340 const FilePath outgoing_symlink_path = | 2340 const FilePath outgoing_symlink_path = |
2341 DriveCache::GetCacheRootPath(profile_.get()) | 2341 DriveCache::GetCacheRootPath(profile_.get()) |
2342 .AppendASCII("outgoing") | 2342 .AppendASCII("outgoing") |
2343 .AppendASCII(kResourceId); | 2343 .AppendASCII(kResourceId); |
2344 ASSERT_TRUE(file_util::PathExists(dirty_cache_file_path)); | 2344 ASSERT_TRUE(file_util::PathExists(dirty_cache_file_path)); |
2345 ASSERT_TRUE(file_util::PathExists(outgoing_symlink_path)); | 2345 ASSERT_TRUE(file_util::PathExists(outgoing_symlink_path)); |
2346 | 2346 |
2347 // Create a DocumentEntry, which is needed to mock | 2347 // Create a DocumentEntry, which is needed to mock |
2348 // GDataUploaderInterface::UploadExistingFile(). | 2348 // DriveUploaderInterface::UploadExistingFile(). |
2349 // TODO(satorux): This should be cleaned up. crbug.com/134240. | 2349 // TODO(satorux): This should be cleaned up. crbug.com/134240. |
2350 DocumentEntry* document_entry = NULL; | 2350 DocumentEntry* document_entry = NULL; |
2351 scoped_ptr<base::Value> value(test_util::LoadJSONFile("root_feed.json")); | 2351 scoped_ptr<base::Value> value(test_util::LoadJSONFile("root_feed.json")); |
2352 ASSERT_TRUE(value.get()); | 2352 ASSERT_TRUE(value.get()); |
2353 base::DictionaryValue* as_dict = NULL; | 2353 base::DictionaryValue* as_dict = NULL; |
2354 base::ListValue* entry_list = NULL; | 2354 base::ListValue* entry_list = NULL; |
2355 if (value->GetAsDictionary(&as_dict) && | 2355 if (value->GetAsDictionary(&as_dict) && |
2356 as_dict->GetList("feed.entry", &entry_list)) { | 2356 as_dict->GetList("feed.entry", &entry_list)) { |
2357 for (size_t i = 0; i < entry_list->GetSize(); ++i) { | 2357 for (size_t i = 0; i < entry_list->GetSize(); ++i) { |
2358 base::DictionaryValue* entry = NULL; | 2358 base::DictionaryValue* entry = NULL; |
(...skipping 254 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2613 | 2613 |
2614 // Try to close the same file twice. | 2614 // Try to close the same file twice. |
2615 file_system_->CloseFile(kFileInRoot, close_file_callback); | 2615 file_system_->CloseFile(kFileInRoot, close_file_callback); |
2616 message_loop_.Run(); | 2616 message_loop_.Run(); |
2617 | 2617 |
2618 // It must fail. | 2618 // It must fail. |
2619 EXPECT_EQ(DRIVE_FILE_ERROR_NOT_FOUND, callback_helper_->last_error_); | 2619 EXPECT_EQ(DRIVE_FILE_ERROR_NOT_FOUND, callback_helper_->last_error_); |
2620 } | 2620 } |
2621 | 2621 |
2622 } // namespace gdata | 2622 } // namespace gdata |
OLD | NEW |