1 files changed, 121 insertions, 0 deletions
diff --git a/components/drive/file_system/move_operation.cc b/components/drive/file_system/move_operation.cc
new file mode 100644
index 0000000..ff1edd6
--- /dev/null
+++ b/components/drive/file_system/move_operation.cc
@@ -0,0 +1,121 @@
+// 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