| // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| #include "components/drive/file_system/move_operation.h" |
| |
| #include "base/sequenced_task_runner.h" |
| #include "components/drive/drive.pb.h" |
| #include "components/drive/file_change.h" |
| #include "components/drive/file_system/operation_delegate.h" |
| #include "components/drive/job_scheduler.h" |
| #include "components/drive/resource_metadata.h" |
| |
| namespace drive { |
| namespace file_system { |
| namespace { |
| |
| // Looks up ResourceEntry for source entry and the destination directory. |
| FileError UpdateLocalState(internal::ResourceMetadata* metadata, |
| const base::FilePath& src_path, |
| const base::FilePath& dest_path, |
| FileChange* changed_files, |
| std::string* local_id) { |
| ResourceEntry entry; |
| FileError error = metadata->GetResourceEntryByPath(src_path, &entry); |
| if (error != FILE_ERROR_OK) |
| return error; |
| *local_id = entry.local_id(); |
| |
| ResourceEntry parent_entry; |
| error = metadata->GetResourceEntryByPath(dest_path.DirName(), &parent_entry); |
| if (error != FILE_ERROR_OK) |
| return error; |
| |
| // The parent must be a directory. |
| if (!parent_entry.file_info().is_directory()) |
| return FILE_ERROR_NOT_A_DIRECTORY; |
| |
| changed_files->Update(src_path, entry, FileChange::CHANGE_TYPE_DELETE); |
| |
| // Strip the extension for a hosted document if necessary. |
| const std::string new_extension = |
| base::FilePath(dest_path.Extension()).AsUTF8Unsafe(); |
| const bool has_hosted_document_extension = |
| entry.has_file_specific_info() && |
| entry.file_specific_info().is_hosted_document() && |
| new_extension == entry.file_specific_info().document_extension(); |
| const std::string new_title = |
| has_hosted_document_extension ? |
| dest_path.BaseName().RemoveExtension().AsUTF8Unsafe() : |
| dest_path.BaseName().AsUTF8Unsafe(); |
| |
| entry.set_title(new_title); |
| entry.set_parent_local_id(parent_entry.local_id()); |
| entry.set_metadata_edit_state(ResourceEntry::DIRTY); |
| entry.set_modification_date(base::Time::Now().ToInternalValue()); |
| error = metadata->RefreshEntry(entry); |
| if (error != FILE_ERROR_OK) |
| return error; |
| |
| changed_files->Update(dest_path, entry, |
| FileChange::CHANGE_TYPE_ADD_OR_UPDATE); |
| return FILE_ERROR_OK; |
| } |
| |
| } // namespace |
| |
| MoveOperation::MoveOperation(base::SequencedTaskRunner* blocking_task_runner, |
| OperationDelegate* delegate, |
| internal::ResourceMetadata* metadata) |
| : blocking_task_runner_(blocking_task_runner), |
| delegate_(delegate), |
| metadata_(metadata), |
| weak_ptr_factory_(this) { |
| } |
| |
| MoveOperation::~MoveOperation() { |
| DCHECK(thread_checker_.CalledOnValidThread()); |
| } |
| |
| void MoveOperation::Move(const base::FilePath& src_file_path, |
| const base::FilePath& dest_file_path, |
| const FileOperationCallback& callback) { |
| DCHECK(thread_checker_.CalledOnValidThread()); |
| DCHECK(!callback.is_null()); |
| |
| FileChange* changed_files = new FileChange; |
| std::string* local_id = new std::string; |
| base::PostTaskAndReplyWithResult( |
| blocking_task_runner_.get(), |
| FROM_HERE, |
| base::Bind(&UpdateLocalState, |
| metadata_, |
| src_file_path, |
| dest_file_path, |
| changed_files, |
| local_id), |
| base::Bind(&MoveOperation::MoveAfterUpdateLocalState, |
| weak_ptr_factory_.GetWeakPtr(), |
| callback, |
| base::Owned(changed_files), |
| base::Owned(local_id))); |
| } |
| |
| void MoveOperation::MoveAfterUpdateLocalState( |
| const FileOperationCallback& callback, |
| const FileChange* changed_files, |
| const std::string* local_id, |
| FileError error) { |
| DCHECK(thread_checker_.CalledOnValidThread()); |
| if (error == FILE_ERROR_OK) { |
| // Notify the change of directory. |
| delegate_->OnFileChangedByOperation(*changed_files); |
| delegate_->OnEntryUpdatedByOperation(ClientContext(USER_INITIATED), |
| *local_id); |
| } |
| callback.Run(error); |
| } |
| |
| } // namespace file_system |
| } // namespace drive |