chrome/browser/chromeos/extensions/file_system_provider/file_system_provider_api.cc

   1 // Copyright 2013 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #include "chrome/browser/chromeos/extensions/file_system_provider/file_system_provider_api.h"
   6
   7 #include <string>
   8 #include <vector>
   9
  10 #include "base/debug/trace_event.h"
  11 #include "base/memory/linked_ptr.h"
  12 #include "base/memory/scoped_ptr.h"
  13 #include "base/values.h"
  14 #include "chrome/browser/chromeos/file_system_provider/provided_file_system_interface.h"
  15 #include "chrome/browser/chromeos/file_system_provider/request_manager.h"
  16 #include "chrome/browser/chromeos/file_system_provider/request_value.h"
  17 #include "chrome/browser/chromeos/file_system_provider/service.h"
  18 #include "chrome/common/extensions/api/file_system_provider.h"
  19 #include "chrome/common/extensions/api/file_system_provider_internal.h"
  20
  21 using chromeos::file_system_provider::MountOptions;
  22 using chromeos::file_system_provider::ProvidedFileSystemInfo;
  23 using chromeos::file_system_provider::ProvidedFileSystemInterface;
  24 using chromeos::file_system_provider::ProvidedFileSystemObserver;
  25 using chromeos::file_system_provider::RequestValue;
  26 using chromeos::file_system_provider::Service;
  27
  28 namespace extensions {
  29 namespace {
  30
  31 typedef std::vector<linked_ptr<api::file_system_provider::ChildChange>>
  32     IDLChildChanges;
  33
  34 const char kNotifyFailedErrorMessage[] =
  35     "Sending a response for the request failed.";
  36 const char kInvalidNotificationErrorMessage[] = "The notification is invalid.";
  37
  38 // Converts the change type from the IDL type to a native type. |changed_type|
  39 // must be specified (not CHANGE_TYPE_NONE).
  40 ProvidedFileSystemObserver::ChangeType ParseChangeType(
  41     const api::file_system_provider::ChangeType& change_type) {
  42   switch (change_type) {
  43     case api::file_system_provider::CHANGE_TYPE_CHANGED:
  44       return ProvidedFileSystemObserver::CHANGED;
  45     case api::file_system_provider::CHANGE_TYPE_DELETED:
  46       return ProvidedFileSystemObserver::DELETED;
  47     default:
  48       break;
  49   }
  50   NOTREACHED();
  51   return ProvidedFileSystemObserver::CHANGED;
  52 }
  53
  54 // Convert the child change from the IDL type to a native type. The reason IDL
  55 // types are not used is since they are imperfect, eg. paths are stored as
  56 // strings.
  57 ProvidedFileSystemObserver::ChildChange ParseChildChange(
  58     const api::file_system_provider::ChildChange& child_change) {
  59   ProvidedFileSystemObserver::ChildChange result;
  60   result.entry_path = base::FilePath::FromUTF8Unsafe(child_change.entry_path);
  61   result.change_type = ParseChangeType(child_change.change_type);
  62   return result;
  63 }
  64
  65 // Converts a list of child changes from the IDL type to a native type.
  66 scoped_ptr<ProvidedFileSystemObserver::ChildChanges> ParseChildChanges(
  67     const IDLChildChanges& child_changes) {
  68   scoped_ptr<ProvidedFileSystemObserver::ChildChanges> results(
  69       new ProvidedFileSystemObserver::ChildChanges);
  70   for (IDLChildChanges::const_iterator it = child_changes.begin();
  71        it != child_changes.end();
  72        ++it) {
  73     results->push_back(ParseChildChange(*it->get()));
  74   }
  75   return results;
  76 }
  77
  78 }  // namespace
  79
  80 bool FileSystemProviderMountFunction::RunSync() {
  81   using api::file_system_provider::Mount::Params;
  82   const scoped_ptr<Params> params(Params::Create(*args_));
  83   EXTENSION_FUNCTION_VALIDATE(params);
  84
  85   // It's an error if the file system Id is empty.
  86   if (params->options.file_system_id.empty()) {
  87     base::ListValue* const result = new base::ListValue();
  88     result->Append(CreateError(kSecurityErrorName, kEmptyIdErrorMessage));
  89     SetResult(result);
  90     return true;
  91   }
  92
  93   // It's an error if the display name is empty.
  94   if (params->options.display_name.empty()) {
  95     base::ListValue* const result = new base::ListValue();
  96     result->Append(CreateError(kSecurityErrorName,
  97                                kEmptyNameErrorMessage));
  98     SetResult(result);
  99     return true;
 100   }
 101
 102   Service* const service = Service::Get(GetProfile());
 103   DCHECK(service);
 104   if (!service)
 105     return false;
 106
 107   MountOptions options;
 108   options.file_system_id = params->options.file_system_id;
 109   options.display_name = params->options.display_name;
 110   options.writable = params->options.writable;
 111   options.supports_notify_tag = params->options.supports_notify_tag;
 112
 113   // TODO(mtomasz): Pass more detailed errors, rather than just a bool.
 114   if (!service->MountFileSystem(extension_id(), options)) {
 115     base::ListValue* const result = new base::ListValue();
 116     result->Append(CreateError(kSecurityErrorName, kMountFailedErrorMessage));
 117     SetResult(result);
 118     return true;
 119   }
 120
 121   base::ListValue* result = new base::ListValue();
 122   SetResult(result);
 123   return true;
 124 }
 125
 126 bool FileSystemProviderUnmountFunction::RunSync() {
 127   using api::file_system_provider::Unmount::Params;
 128   scoped_ptr<Params> params(Params::Create(*args_));
 129   EXTENSION_FUNCTION_VALIDATE(params);
 130
 131   Service* const service = Service::Get(GetProfile());
 132   DCHECK(service);
 133   if (!service)
 134     return false;
 135
 136   if (!service->UnmountFileSystem(extension_id(),
 137                                   params->options.file_system_id,
 138                                   Service::UNMOUNT_REASON_USER)) {
 139     // TODO(mtomasz): Pass more detailed errors, rather than just a bool.
 140     base::ListValue* result = new base::ListValue();
 141     result->Append(CreateError(kSecurityErrorName, kUnmountFailedErrorMessage));
 142     SetResult(result);
 143     return true;
 144   }
 145
 146   base::ListValue* const result = new base::ListValue();
 147   SetResult(result);
 148   return true;
 149 }
 150
 151 bool FileSystemProviderGetAllFunction::RunSync() {
 152   using api::file_system_provider::FileSystemInfo;
 153   Service* const service = Service::Get(GetProfile());
 154   DCHECK(service);
 155   if (!service)
 156     return false;
 157
 158   const std::vector<ProvidedFileSystemInfo> file_systems =
 159       service->GetProvidedFileSystemInfoList();
 160   std::vector<linked_ptr<FileSystemInfo> > items;
 161
 162   for (size_t i = 0; i < file_systems.size(); ++i) {
 163     if (file_systems[i].extension_id() == extension_id()) {
 164       linked_ptr<FileSystemInfo> item(new FileSystemInfo);
 165       item->file_system_id = file_systems[i].file_system_id();
 166       item->display_name = file_systems[i].display_name();
 167       item->writable = file_systems[i].writable();
 168       items.push_back(item);
 169     }
 170   }
 171
 172   SetResultList(api::file_system_provider::GetAll::Results::Create(items));
 173   return true;
 174 }
 175
 176 bool FileSystemProviderNotifyFunction::RunSync() {
 177   using api::file_system_provider::Notify::Params;
 178   scoped_ptr<Params> params(Params::Create(*args_));
 179   EXTENSION_FUNCTION_VALIDATE(params);
 180
 181   Service* const service = Service::Get(GetProfile());
 182   DCHECK(service);
 183   if (!service)
 184     return false;
 185
 186   ProvidedFileSystemInterface* const file_system =
 187       service->GetProvidedFileSystem(extension_id(),
 188                                      params->options.file_system_id);
 189   if (!file_system) {
 190     base::ListValue* const result = new base::ListValue();
 191     result->Append(CreateError(kNotFoundErrorName, kNotifyFailedErrorMessage));
 192     SetResult(result);
 193     return true;
 194   }
 195
 196   if (!file_system->Notify(
 197           base::FilePath::FromUTF8Unsafe(params->options.observed_path),
 198           ParseChangeType(params->options.change_type),
 199           params->options.child_changes.get()
 200               ? ParseChildChanges(*params->options.child_changes.get())
 201               : make_scoped_ptr(new ProvidedFileSystemObserver::ChildChanges),
 202           params->options.tag.get() ? *params->options.tag.get() : "")) {
 203     base::ListValue* const result = new base::ListValue();
 204     result->Append(
 205         CreateError(kSecurityErrorName, kInvalidNotificationErrorMessage));
 206     SetResult(result);
 207     return true;
 208   }
 209
 210   base::ListValue* const result = new base::ListValue();
 211   SetResult(result);
 212   return true;
 213 }
 214
 215 bool FileSystemProviderInternalUnmountRequestedSuccessFunction::RunWhenValid() {
 216   using api::file_system_provider_internal::UnmountRequestedSuccess::Params;
 217   scoped_ptr<Params> params(Params::Create(*args_));
 218   EXTENSION_FUNCTION_VALIDATE(params);
 219
 220   FulfillRequest(RequestValue::CreateForUnmountSuccess(params.Pass()),
 221                  false /* has_more */);
 222   return true;
 223 }
 224
 225 bool
 226 FileSystemProviderInternalGetMetadataRequestedSuccessFunction::RunWhenValid() {
 227   using api::file_system_provider_internal::GetMetadataRequestedSuccess::Params;
 228   scoped_ptr<Params> params(Params::Create(*args_));
 229   EXTENSION_FUNCTION_VALIDATE(params);
 230
 231   FulfillRequest(RequestValue::CreateForGetMetadataSuccess(params.Pass()),
 232                  false /* has_more */);
 233   return true;
 234 }
 235
 236 bool FileSystemProviderInternalReadDirectoryRequestedSuccessFunction::
 237     RunWhenValid() {
 238   using api::file_system_provider_internal::ReadDirectoryRequestedSuccess::
 239       Params;
 240   scoped_ptr<Params> params(Params::Create(*args_));
 241   EXTENSION_FUNCTION_VALIDATE(params);
 242
 243   const bool has_more = params->has_more;
 244   FulfillRequest(RequestValue::CreateForReadDirectorySuccess(params.Pass()),
 245                  has_more);
 246   return true;
 247 }
 248
 249 bool
 250 FileSystemProviderInternalReadFileRequestedSuccessFunction::RunWhenValid() {
 251   TRACE_EVENT0("file_system_provider", "ReadFileRequestedSuccess");
 252   using api::file_system_provider_internal::ReadFileRequestedSuccess::Params;
 253
 254   scoped_ptr<Params> params(Params::Create(*args_));
 255   EXTENSION_FUNCTION_VALIDATE(params);
 256
 257   const bool has_more = params->has_more;
 258   FulfillRequest(RequestValue::CreateForReadFileSuccess(params.Pass()),
 259                  has_more);
 260   return true;
 261 }
 262
 263 bool
 264 FileSystemProviderInternalOperationRequestedSuccessFunction::RunWhenValid() {
 265   using api::file_system_provider_internal::OperationRequestedSuccess::Params;
 266   scoped_ptr<Params> params(Params::Create(*args_));
 267   EXTENSION_FUNCTION_VALIDATE(params);
 268
 269   FulfillRequest(scoped_ptr<RequestValue>(
 270                      RequestValue::CreateForOperationSuccess(params.Pass())),
 271                  false /* has_more */);
 272   return true;
 273 }
 274
 275 bool FileSystemProviderInternalOperationRequestedErrorFunction::RunWhenValid() {
 276   using api::file_system_provider_internal::OperationRequestedError::Params;
 277   scoped_ptr<Params> params(Params::Create(*args_));
 278   EXTENSION_FUNCTION_VALIDATE(params);
 279
 280   const base::File::Error error = ProviderErrorToFileError(params->error);
 281   RejectRequest(RequestValue::CreateForOperationError(params.Pass()), error);
 282   return true;
 283 }
 284
 285 }  // namespace extensions