Prototype of Files service.

services/file_manager/directory_impl.cc

Index: services/file_manager/directory_impl.cc
diff --git a/services/file_manager/directory_impl.cc b/services/file_manager/directory_impl.cc
new file mode 100644
index 0000000000000000000000000000000000000000..973bba9c13d81cafaa64776afd9921c157bd1e5b
--- /dev/null
+++ b/services/file_manager/directory_impl.cc
@@ -0,0 +1,151 @@
+// Copyright 2015 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 "services/file_manager/directory_impl.h"
+
+#include <errno.h>
+#include <fcntl.h>
+#include <stdio.h>
+#include <sys/stat.h>
+#include <sys/types.h>
+
+#include "base/files/file_util.h"
+#include "base/files/scoped_file.h"
+#include "base/logging.h"
+#include "base/posix/eintr_wrapper.h"
+#include "services/file_manager/file_impl.h"
+#include "services/file_manager/util.h"
+
+namespace mojo {
+namespace files {
+
+DirectoryImpl::DirectoryImpl(InterfaceRequest<Directory> request,
+                             base::ScopedFD dir_fd,
+                             const base::FilePath& owned_dir_name)
+    : binding_(this, request.Pass()),
+      dir_fd_(dir_fd.Pass()),
+      owned_dir_name_(owned_dir_name) {
+  DCHECK(dir_fd_.is_valid());
+}
+
+DirectoryImpl::~DirectoryImpl() {
+  if (!owned_dir_name_.empty()) {
+    DVLOG(1) << "Deleting owned directory: " << owned_dir_name_.value();
+    LOG_IF(ERROR, !base::DeleteFile(owned_dir_name_, true))
+        << "Failed to delete owned directory: " << owned_dir_name_.value();
+  }
+}
+
+void DirectoryImpl::Read(
+    const Callback<void(Error, Array<FileInformationPtr>)>& callback) {
+  // TODO(vtl): FIXME soon
+  NOTIMPLEMENTED();
+  callback.Run(ERROR_UNIMPLEMENTED, Array<FileInformationPtr>());
+}
+
+void DirectoryImpl::Change(const String& path,
+                           const Callback<void(Error)>& callback) {
+  DCHECK(!path.is_null());
+  DCHECK(dir_fd_.is_valid());
+
+  // TODO(vtl): FIXME soon
+  NOTIMPLEMENTED();
+  callback.Run(ERROR_UNIMPLEMENTED);
+}
+
+// TODO(vtl): Move the implementation to a thread pool.
+void DirectoryImpl::OpenFile(const String& path,
+                             InterfaceRequest<File> file,
+                             uint32_t access_flags,
+                             uint32_t open_flags,
+                             const Callback<void(Error)>& callback) {
+  DCHECK(!path.is_null());
+  DCHECK(dir_fd_.is_valid());
+
+  if (Error error = IsPathValid(path)) {
+    callback.Run(error);
+    return;
+  }
+  // TODO(vtl): Make sure the path doesn't exit this directory (if appropriate).
+  // TODO(vtl): Maybe allow absolute paths?
+
+  // Treat unknown flags as "unimplemented".
+  if ((access_flags & ~(kAccessFlagRead | kAccessFlagWrite)) ||
+      (open_flags &
+       ~(kOpenFlagCreate | kOpenFlagExclusive | kOpenFlagAppend |
+         kOpenFlagTruncate))) {
+    callback.Run(ERROR_UNIMPLEMENTED);
+    return;
+  }
+  if (!access_flags) {
+    callback.Run(ERROR_INVALID_ARGUMENT);
+    return;
+  }
+
+  int flags = 0;
+  if ((access_flags & kAccessFlagRead)) {
+    flags = (access_flags & kAccessFlagWrite) ? O_RDWR : O_RDONLY;
+  } else {
+    DCHECK((access_flags & kAccessFlagWrite));
+    flags = O_WRONLY;
+  }
+  if ((open_flags & kOpenFlagCreate))
+    flags |= O_CREAT;
+  if ((open_flags & kOpenFlagExclusive))
+    flags |= O_EXCL;
+  if ((open_flags & kOpenFlagAppend))
+    flags |= O_APPEND;
+  if ((open_flags & kOpenFlagTruncate))
+    flags |= O_TRUNC;
+
+  base::ScopedFD file_fd(
+      HANDLE_EINTR(openat(dir_fd_.get(), path.get().c_str(), flags, 0600)));
+  if (!file_fd.is_valid()) {
+    callback.Run(ErrnoToError(errno));
+    return;
+  }
+
+  new FileImpl(file.Pass(), file_fd.Pass());
+  callback.Run(ERROR_OK);
+}
+
+void DirectoryImpl::OpenDirectory(const String& path,
+                                  InterfaceRequest<Directory> directory,
+                                  const Callback<void(Error)>& callback) {
+  DCHECK(!path.is_null());
+  DCHECK(dir_fd_.is_valid());
+
+  // TODO(vtl): FIXME soon
+  NOTIMPLEMENTED();
+  callback.Run(ERROR_UNIMPLEMENTED);
+}
+
+void DirectoryImpl::Rename(const String& path,
+                           const String& new_path,
+                           const Callback<void(Error)>& callback) {
+  DCHECK(!path.is_null());
+  DCHECK(!new_path.is_null());
+  DCHECK(dir_fd_.is_valid());
+
+  if (Error error = IsPathValid(path)) {
+    callback.Run(error);
+    return;
+  }
+  if (Error error = IsPathValid(new_path)) {
+    callback.Run(error);
+    return;
+  }
+  // TODO(vtl): see TODOs about |path| in OpenFile()
+
+  if (renameat(dir_fd_.get(), path.get().c_str(), dir_fd_.get(),
+               new_path.get().c_str())) {
+    callback.Run(ErrnoToError(errno));
+    return;
+  }
+
+  callback.Run(ERROR_OK);
+}
+
+}  // namespace files
+}  // namespace mojo