[Privet FS] Allow files to be able to be copied in to the privet filesystem

chrome/browser/local_discovery/storage/privet_filesystem_operations.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/local_discovery/storage/privet_filesystem_operations.h"
 
 #include <algorithm>
 
 #include "base/numerics/safe_conversions.h"
 #include "chrome/browser/local_discovery/privet_constants.h"
@@ skipping 225 matching lines @@
           url.path(),
           base::Bind(&CreateCreateDirectory, containing_path, name),
           false,
           browser_context_,
           this,
           callback);
   async_operations_.insert(operation);
   operation->Start();
 }
 
+void PrivetFileSystemOperationFactory::CopyInForeignFile(
+    base::FilePath src_file_path,
+    const fileapi::FileSystemURL& dest_url,
+    const fileapi::AsyncFileUtil::StatusCallback& callback) {
+  TemporaryServiceDiscoveryClient();
+
+  PrivetFileSystemAsyncOperation* operation =
+      new PrivetFileSystemUploadOperation(
+          dest_url.path(), src_file_path, browser_context_, this, callback);
+  async_operations_.insert(operation);
+  operation->Start();
+}
+
 void PrivetFileSystemOperationFactory::RemoveOperation(
     PrivetFileSystemAsyncOperation* operation) {
   DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
   async_operations_.erase(operation);
   delete operation;
 }
 
 void PrivetFileSystemOperationFactory::RemoveAllOperations() {
   DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
   STLDeleteElements(&async_operations_);
@@ skipping 548 matching lines @@
 }
 
 void PrivetFileSystemStatusOperation::TriggerCallbackAndDestroy(
     base::File::Error result) {
   DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
   content::BrowserThread::PostTask(
       content::BrowserThread::IO, FROM_HERE, base::Bind(callback_, result));
   container_->RemoveOperation(this);
 }
 
+PrivetFileSystemUploadOperation::PrivetFileSystemUploadOperation(
+    const base::FilePath& full_path,
+    const base::FilePath& upload_path,
+    content::BrowserContext* browser_context,
+    PrivetFileSystemAsyncOperationContainer* container,
+    const fileapi::AsyncFileUtil::StatusCallback& callback)
+    : core_(full_path, browser_context, this),
+      full_path_(full_path),
+      upload_path_(upload_path),
+      container_(container),
+      callback_(callback) {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+}
+
+PrivetFileSystemUploadOperation::~PrivetFileSystemUploadOperation() {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+}
+
+void PrivetFileSystemUploadOperation::Start() {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+  core_.Start();
+}
+
+void PrivetFileSystemUploadOperation::PrivetFileSystemResolved(
+    PrivetHTTPClient* http_client,
+    const std::string& path) {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+  if (!http_client) {
+    SignalError();
+    return;
+  }
+
+  overwrite_operation_ = http_client->CreateStorageOverwriteOperation(
+      path,
+      base::Bind(&PrivetFileSystemUploadOperation::OnStorageOverwriteResult,
+                 base::Unretained(this)));
+  overwrite_operation_->SetUploadFile(upload_path_);
+  overwrite_operation_->Start();
+}
+
+void PrivetFileSystemUploadOperation::OnStorageOverwriteResult(
+    PrivetDataReadOperation::ResponseType result_type,
+    const std::string& data,
+    const base::FilePath& file) {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+
+  if (result_type == PrivetDataReadOperation::RESPONSE_TYPE_ERROR) {
+    SignalError();
+  } else {
+    TriggerCallbackAndDestroy(base::File::FILE_OK);
+  }
+}
+
+void PrivetFileSystemUploadOperation::SignalError() {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+  TriggerCallbackAndDestroy(base::File::FILE_ERROR_FAILED);
+}
+
+void PrivetFileSystemUploadOperation::TriggerCallbackAndDestroy(
+    base::File::Error result) {
+  DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI));
+  content::BrowserThread::PostTask(
+      content::BrowserThread::IO, FROM_HERE, base::Bind(callback_, result));
+  container_->RemoveOperation(this);
+}
+
 }  // namespace local_discovery