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 "chrome/browser/chromeos/gdata/gdata_download_observer.h" | 5 #include "chrome/browser/chromeos/gdata/gdata_download_observer.h" |
6 | 6 |
7 #include <string> | 7 #include <string> |
8 | 8 |
9 #include "base/callback.h" | 9 #include "base/callback.h" |
10 #include "base/file_util.h" | 10 #include "base/file_util.h" |
11 #include "base/supports_user_data.h" | 11 #include "base/supports_user_data.h" |
12 #include "chrome/browser/chromeos/gdata/drive.pb.h" | 12 #include "chrome/browser/chromeos/gdata/drive.pb.h" |
| 13 #include "chrome/browser/chromeos/gdata/drive_file_system_interface.h" |
13 #include "chrome/browser/chromeos/gdata/drive_service_interface.h" | 14 #include "chrome/browser/chromeos/gdata/drive_service_interface.h" |
14 #include "chrome/browser/chromeos/gdata/gdata_file_system_interface.h" | |
15 #include "chrome/browser/chromeos/gdata/gdata_system_service.h" | 15 #include "chrome/browser/chromeos/gdata/gdata_system_service.h" |
16 #include "chrome/browser/chromeos/gdata/gdata_upload_file_info.h" | 16 #include "chrome/browser/chromeos/gdata/gdata_upload_file_info.h" |
17 #include "chrome/browser/chromeos/gdata/gdata_uploader.h" | 17 #include "chrome/browser/chromeos/gdata/gdata_uploader.h" |
18 #include "chrome/browser/chromeos/gdata/gdata_util.h" | 18 #include "chrome/browser/chromeos/gdata/gdata_util.h" |
19 #include "chrome/browser/chromeos/gdata/gdata_wapi_parser.h" | 19 #include "chrome/browser/chromeos/gdata/gdata_wapi_parser.h" |
20 #include "chrome/browser/download/download_completion_blocker.h" | 20 #include "chrome/browser/download/download_completion_blocker.h" |
21 #include "chrome/browser/profiles/profile_manager.h" | 21 #include "chrome/browser/profiles/profile_manager.h" |
22 #include "net/base/net_util.h" | 22 #include "net/base/net_util.h" |
23 | 23 |
24 using content::BrowserThread; | 24 using content::BrowserThread; |
(...skipping 101 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
126 BrowserThread::GetBlockingPool()->PostTaskAndReply( | 126 BrowserThread::GetBlockingPool()->PostTaskAndReply( |
127 FROM_HERE, | 127 FROM_HERE, |
128 base::Bind(&GDataDownloadObserver::GetGDataTempDownloadPath, | 128 base::Bind(&GDataDownloadObserver::GetGDataTempDownloadPath, |
129 gdata_tmp_download_dir, | 129 gdata_tmp_download_dir, |
130 gdata_tmp_download_path), | 130 gdata_tmp_download_path), |
131 base::Bind(&RunSubstituteGDataDownloadCallback, | 131 base::Bind(&RunSubstituteGDataDownloadCallback, |
132 callback, | 132 callback, |
133 base::Owned(gdata_tmp_download_path))); | 133 base::Owned(gdata_tmp_download_path))); |
134 } | 134 } |
135 | 135 |
136 // Callback for GDataFileSystem::CreateDirectory. | 136 // Callback for DriveFileSystem::CreateDirectory. |
137 void OnCreateDirectory(const base::Closure& substitute_callback, | 137 void OnCreateDirectory(const base::Closure& substitute_callback, |
138 DriveFileError error) { | 138 DriveFileError error) { |
139 DVLOG(1) << "OnCreateDirectory " << error; | 139 DVLOG(1) << "OnCreateDirectory " << error; |
140 if (error == DRIVE_FILE_OK) { | 140 if (error == DRIVE_FILE_OK) { |
141 substitute_callback.Run(); | 141 substitute_callback.Run(); |
142 } else { | 142 } else { |
143 // TODO(achuith): Handle this. | 143 // TODO(achuith): Handle this. |
144 NOTREACHED(); | 144 NOTREACHED(); |
145 } | 145 } |
146 } | 146 } |
147 | 147 |
148 // Callback for GDataFileSystem::GetEntryInfoByPath. | 148 // Callback for DriveFileSystem::GetEntryInfoByPath. |
149 void OnEntryFound(Profile* profile, | 149 void OnEntryFound(Profile* profile, |
150 const FilePath& gdata_dir_path, | 150 const FilePath& gdata_dir_path, |
151 const base::Closure& substitute_callback, | 151 const base::Closure& substitute_callback, |
152 DriveFileError error, | 152 DriveFileError error, |
153 scoped_ptr<DriveEntryProto> entry_proto) { | 153 scoped_ptr<DriveEntryProto> entry_proto) { |
154 if (error == DRIVE_FILE_ERROR_NOT_FOUND) { | 154 if (error == DRIVE_FILE_ERROR_NOT_FOUND) { |
155 // Destination gdata directory doesn't exist, so create it. | 155 // Destination gdata directory doesn't exist, so create it. |
156 const bool is_exclusive = false, is_recursive = true; | 156 const bool is_exclusive = false, is_recursive = true; |
157 GetSystemService(profile)->file_system()->CreateDirectory( | 157 GetSystemService(profile)->file_system()->CreateDirectory( |
158 gdata_dir_path, is_exclusive, is_recursive, | 158 gdata_dir_path, is_exclusive, is_recursive, |
(...skipping 10 matching lines...) Expand all Loading... |
169 void OnAuthenticate(Profile* profile, | 169 void OnAuthenticate(Profile* profile, |
170 const FilePath& gdata_path, | 170 const FilePath& gdata_path, |
171 const base::Closure& substitute_callback, | 171 const base::Closure& substitute_callback, |
172 GDataErrorCode error, | 172 GDataErrorCode error, |
173 const std::string& token) { | 173 const std::string& token) { |
174 DVLOG(1) << "OnAuthenticate"; | 174 DVLOG(1) << "OnAuthenticate"; |
175 | 175 |
176 if (error == HTTP_SUCCESS) { | 176 if (error == HTTP_SUCCESS) { |
177 const FilePath gdata_dir_path = | 177 const FilePath gdata_dir_path = |
178 util::ExtractGDataPath(gdata_path.DirName()); | 178 util::ExtractGDataPath(gdata_path.DirName()); |
179 // Ensure the directory exists. This also forces GDataFileSystem to | 179 // Ensure the directory exists. This also forces DriveFileSystem to |
180 // initialize GDataRootDirectory. | 180 // initialize GDataRootDirectory. |
181 GetSystemService(profile)->file_system()->GetEntryInfoByPath( | 181 GetSystemService(profile)->file_system()->GetEntryInfoByPath( |
182 gdata_dir_path, | 182 gdata_dir_path, |
183 base::Bind(&OnEntryFound, profile, gdata_dir_path, | 183 base::Bind(&OnEntryFound, profile, gdata_dir_path, |
184 substitute_callback)); | 184 substitute_callback)); |
185 } else { | 185 } else { |
186 // TODO(achuith): Handle this. | 186 // TODO(achuith): Handle this. |
187 NOTREACHED(); | 187 NOTREACHED(); |
188 } | 188 } |
189 } | 189 } |
190 | 190 |
191 } // namespace | 191 } // namespace |
192 | 192 |
193 GDataDownloadObserver::GDataDownloadObserver( | 193 GDataDownloadObserver::GDataDownloadObserver( |
194 GDataUploader* uploader, | 194 GDataUploader* uploader, |
195 GDataFileSystemInterface* file_system) | 195 DriveFileSystemInterface* file_system) |
196 : gdata_uploader_(uploader), | 196 : gdata_uploader_(uploader), |
197 file_system_(file_system), | 197 file_system_(file_system), |
198 download_manager_(NULL), | 198 download_manager_(NULL), |
199 ALLOW_THIS_IN_INITIALIZER_LIST(weak_ptr_factory_(this)) { | 199 ALLOW_THIS_IN_INITIALIZER_LIST(weak_ptr_factory_(this)) { |
200 } | 200 } |
201 | 201 |
202 GDataDownloadObserver::~GDataDownloadObserver() { | 202 GDataDownloadObserver::~GDataDownloadObserver() { |
203 if (download_manager_) | 203 if (download_manager_) |
204 download_manager_->RemoveObserver(this); | 204 download_manager_->RemoveObserver(this); |
205 | 205 |
(...skipping 18 matching lines...) Expand all Loading... |
224 const FilePath& gdata_path, content::DownloadItem* download, | 224 const FilePath& gdata_path, content::DownloadItem* download, |
225 const SubstituteGDataDownloadPathCallback& callback) { | 225 const SubstituteGDataDownloadPathCallback& callback) { |
226 DVLOG(1) << "SubstituteGDataDownloadPath " << gdata_path.value(); | 226 DVLOG(1) << "SubstituteGDataDownloadPath " << gdata_path.value(); |
227 | 227 |
228 SetDownloadParams(gdata_path, download); | 228 SetDownloadParams(gdata_path, download); |
229 | 229 |
230 if (util::IsUnderGDataMountPoint(gdata_path)) { | 230 if (util::IsUnderGDataMountPoint(gdata_path)) { |
231 // Can't access drive if we're not authenticated. | 231 // Can't access drive if we're not authenticated. |
232 // We set off a chain of callbacks as follows: | 232 // We set off a chain of callbacks as follows: |
233 // DriveServiceInterface::Authenticate | 233 // DriveServiceInterface::Authenticate |
234 // OnAuthenticate calls GDataFileSystem::GetEntryInfoByPath | 234 // OnAuthenticate calls DriveFileSystem::GetEntryInfoByPath |
235 // OnEntryFound calls GDataFileSystem::CreateDirectory (if necessary) | 235 // OnEntryFound calls DriveFileSystem::CreateDirectory (if necessary) |
236 // OnCreateDirectory calls SubstituteGDataDownloadPathInternal | 236 // OnCreateDirectory calls SubstituteGDataDownloadPathInternal |
237 GetSystemService(profile)->drive_service()->Authenticate( | 237 GetSystemService(profile)->drive_service()->Authenticate( |
238 base::Bind(&OnAuthenticate, profile, gdata_path, | 238 base::Bind(&OnAuthenticate, profile, gdata_path, |
239 base::Bind(&SubstituteGDataDownloadPathInternal, | 239 base::Bind(&SubstituteGDataDownloadPathInternal, |
240 profile, callback))); | 240 profile, callback))); |
241 } else { | 241 } else { |
242 callback.Run(gdata_path); | 242 callback.Run(gdata_path); |
243 } | 243 } |
244 } | 244 } |
245 | 245 |
(...skipping 375 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
621 DVLOG(1) << "Pending download not found" << download_id; | 621 DVLOG(1) << "Pending download not found" << download_id; |
622 return; | 622 return; |
623 } | 623 } |
624 DVLOG(1) << "Completing upload for download ID " << download_id; | 624 DVLOG(1) << "Completing upload for download ID " << download_id; |
625 DownloadItem* download_item = iter->second; | 625 DownloadItem* download_item = iter->second; |
626 | 626 |
627 UploadingUserData* upload_data = GetUploadingUserData(download_item); | 627 UploadingUserData* upload_data = GetUploadingUserData(download_item); |
628 DCHECK(upload_data); | 628 DCHECK(upload_data); |
629 | 629 |
630 // Take ownership of the DocumentEntry from UploadFileInfo. This is used by | 630 // Take ownership of the DocumentEntry from UploadFileInfo. This is used by |
631 // GDataFileSystem::AddUploadedFile() to add the entry to DriveCache after the | 631 // DriveFileSystem::AddUploadedFile() to add the entry to DriveCache after the |
632 // upload completes. | 632 // upload completes. |
633 upload_data->set_entry(upload_file_info->entry.Pass()); | 633 upload_data->set_entry(upload_file_info->entry.Pass()); |
634 | 634 |
635 // Allow the download item to complete. | 635 // Allow the download item to complete. |
636 upload_data->CompleteDownload(); | 636 upload_data->CompleteDownload(); |
637 } | 637 } |
638 | 638 |
639 void GDataDownloadObserver::MoveFileToDriveCache(DownloadItem* download) { | 639 void GDataDownloadObserver::MoveFileToDriveCache(DownloadItem* download) { |
640 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | 640 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); |
641 | 641 |
(...skipping 23 matching lines...) Expand all Loading... |
665 file_system_->AddUploadedFile(UPLOAD_NEW_FILE, | 665 file_system_->AddUploadedFile(UPLOAD_NEW_FILE, |
666 upload_data->virtual_dir_path(), | 666 upload_data->virtual_dir_path(), |
667 entry.Pass(), | 667 entry.Pass(), |
668 download->GetTargetFilePath(), | 668 download->GetTargetFilePath(), |
669 DriveCache::FILE_OPERATION_MOVE, | 669 DriveCache::FILE_OPERATION_MOVE, |
670 base::Bind(&base::DoNothing)); | 670 base::Bind(&base::DoNothing)); |
671 } | 671 } |
672 } | 672 } |
673 | 673 |
674 } // namespace gdata | 674 } // namespace gdata |
OLD | NEW |