[fsp] Introduce file_system_provider::Service class for the FileSystemProvider API.

chrome/browser/chromeos/file_system_provider/service.cc

+// Copyright 2014 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 "chrome/browser/chromeos/file_system_provider/service.h"
+
+#include "base/files/file_path.h"
+#include "base/strings/string_number_conversions.h"
+#include "chrome/browser/chromeos/file_system_provider/observer.h"
+#include "chrome/browser/chromeos/file_system_provider/provided_file_system.h"
+#include "chrome/browser/chromeos/file_system_provider/service_factory.h"
+#include "chrome/browser/chromeos/login/user.h"
+#include "chrome/browser/chromeos/login/user_manager.h"
+#include "content/public/browser/browser_thread.h"
+#include "webkit/browser/fileapi/external_mount_points.h"
+
+namespace chromeos {
+namespace file_system_provider {
+namespace {
+
+// Root mount path for all of the provided file systems.
+static const base::FilePath::CharType kProvidedMountPointRoot[] =
+    FILE_PATH_LITERAL("/provided");
+
+// Maximum number of file systems to be mounted in the same time, per profile.
+static const size_t kMaxFileSystems = 16;
+
+base::FilePath GetMountPointPath(Profile* profile,
+                                 std::string extension_id,
+                                 int file_system_handle) {
+  chromeos::User* const user =
+      chromeos::UserManager::IsInitialized()
+          ? chromeos::UserManager::Get()->GetUserByProfile(
+                profile->GetOriginalProfile())
+          : NULL;
+  const std::string user_suffix = user ? "-" + user->username_hash() : "";
+  return base::FilePath(kProvidedMountPointRoot).AppendASCII(
+      extension_id + "-" + base::IntToString(file_system_handle) + user_suffix);
+}
+
+ProvidedFileSystem CreateProvidedFileSystem(const std::string& extension_id,
+                                            const std::string& file_system_id,
+                                            const std::string& file_system_name,
+                                            const base::FilePath& mount_path) {
+  ProvidedFileSystem result;
+  result.extension_id = extension_id;
+  result.file_system_id = file_system_id;
+  result.file_system_name = file_system_name;
+  result.mount_path = mount_path;
+  return result;
+}
+
+}  // namespace
+
+Service::Service(Profile* profile) : profile_(profile), next_handle_(1) {}
+
+Service::~Service() {}
+
+// static
+Service* Service::Get(content::BrowserContext* context) {
+  return ServiceFactory::Get(context);
+}
+
+void Service::AddObserver(Observer* observer) {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+  DCHECK(observer);
+  observers_.AddObserver(observer);
+}
+
+void Service::RemoveObserver(Observer* observer) {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+  DCHECK(observer);
+  observers_.RemoveObserver(observer);
+}
+
+std::string Service::RegisterFileSystem(const std::string& extension_id,
+                                        const std::string& file_system_name) {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+
+  // Restrict number of file systems to prevent system abusing.
+  if (file_systems_.size() + 1 > kMaxFileSystems)
+    return std::string();
+
+  // The file system handle is unique per service, so per profile.
+  int file_system_handle = next_handle_;
+
+  fileapi::ExternalMountPoints* const mount_points =
+      fileapi::ExternalMountPoints::GetSystemInstance();
+  DCHECK(mount_points);
+
+  // The mount point path and name are unique per system, since they are system
+  // wide. This is necessary for copying between profiles.
+  const base::FilePath& mount_point_path =
+      GetMountPointPath(profile_, extension_id, file_system_handle);
+  const std::string mount_point_name =
+      mount_point_path.BaseName().AsUTF8Unsafe();
+
+  if (!mount_points->RegisterFileSystem(mount_point_name,
+                                        fileapi::kFileSystemTypeProvided,
+                                        fileapi::FileSystemMountOption(),
+                                        mount_point_path)) {
+    return std::string();
+  }
+
+  // Store the file system descriptor. Use the mount point name as the file
+  // system provider file system id.
+  // Examples:
+  //   file_system_handle = 41
+  //   mount_point_name = file_system_id = b33f1337-41-5aa5
+  //   mount_point_path = /provided/b33f1337-41-5aa5
+  const std::string file_system_id = mount_point_name;
+  ProvidedFileSystem file_system = CreateProvidedFileSystem(
+      extension_id, file_system_id, file_system_name, mount_point_path);
+  file_systems_[file_system_id] = file_system;
+
+  FOR_EACH_OBSERVER(
+      Observer, observers_, OnProvidedFileSystemRegistered(file_system));
+
+  next_handle_++;
+  return file_system_id;
+}
+
+bool Service::UnregisterFileSystem(const std::string& extension_id,
+                                   const std::string& file_system_id) {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+
+  FileSystemMap::iterator file_system_it = file_systems_.find(file_system_id);
+  if (file_system_it == file_systems_.end() ||
+      file_system_it->second.extension_id != extension_id) {
+    return false;
+  }
+
+  fileapi::ExternalMountPoints* const mount_points =
+      fileapi::ExternalMountPoints::GetSystemInstance();
+  DCHECK(mount_points);
+
+  if (!mount_points->RevokeFileSystem(file_system_it->second.file_system_id))
+    return false;
+
+  FOR_EACH_OBSERVER(Observer,
+                    observers_,
+                    OnProvidedFileSystemUnregistered(file_system_it->second));
+
+  file_systems_.erase(file_system_it);
+  return true;
+}
+
+std::vector<ProvidedFileSystem> Service::GetRegisteredFileSystems() {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+
+  std::vector<ProvidedFileSystem> result;
+  for (FileSystemMap::const_iterator it = file_systems_.begin();
+       it != file_systems_.end();
+       ++it) {
+    result.push_back(it->second);
+  }
+  return result;
+}
+
+}  // namespace file_system_provider
+}  // namespace chromeos