[COPY] - Implemented API for tracking ongoing file transfers from file manager.

chrome/browser/chromeos/extensions/file_browser_private_api.cc

 // 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 "chrome/browser/chromeos/extensions/file_browser_private_api.h"
 
 #include "base/base64.h"
 #include "base/bind.h"
 #include "base/command_line.h"
 #include "base/logging.h"
 #include "base/memory/singleton.h"
 #include "base/string_split.h"
 #include "base/stringprintf.h"
 #include "base/time.h"
 #include "base/values.h"
 #include "chrome/browser/chromeos/extensions/file_browser_event_router.h"
 #include "chrome/browser/chromeos/extensions/file_handler_util.h"
 #include "chrome/browser/chromeos/extensions/file_manager_util.h"
 #include "chrome/browser/chromeos/gdata/gdata_file_system_proxy.h"
+#include "chrome/browser/chromeos/gdata/gdata_operation_registry.h"
 #include "chrome/browser/chromeos/gdata/gdata_util.h"
 #include "chrome/browser/extensions/extension_function_dispatcher.h"
 #include "chrome/browser/extensions/extension_process_manager.h"
 #include "chrome/browser/extensions/extension_service.h"
 #include "chrome/browser/extensions/extension_tab_util.h"
 #include "chrome/browser/extensions/process_map.h"
 #include "chrome/browser/prefs/pref_service.h"
 #include "chrome/browser/profiles/profile.h"
 #include "chrome/browser/ui/browser.h"
 #include "chrome/browser/ui/browser_window.h"
@@ skipping 23 matching lines @@
 #include "chrome/browser/chromeos/disks/disk_mount_manager.h"
 #endif
 
 using chromeos::disks::DiskMountManager;
 using content::BrowserContext;
 using content::BrowserThread;
 using content::ChildProcessSecurityPolicy;
 using content::SiteInstance;
 using content::WebContents;
 using file_handler_util::FileTaskExecutor;
+using gdata::GDataOperationRegistry;
 
 namespace {
 
 // Error messages.
 const char kFileError[] = "File error %d";
 const char kInvalidFileUrl[] = "Invalid file URL";
 const char kVolumeDevicePathNotFound[] = "Device path not found";
 
 // Unescape rules used for parsing query parameters.
 const net::UnescapeRule::Type kUnescapeRuleForQueryParameters =
@@ skipping 442 matching lines @@
       base::Bind(
           &FileWatchBrowserFunctionBase::RespondOnUIThread,
           this,
           true));
 }
 
 bool AddFileWatchBrowserFunction::PerformFileWatchOperation(
     const FilePath& local_path, const FilePath& virtual_path,
     const std::string& extension_id) {
 #if defined(OS_CHROMEOS)
-  return profile_->GetExtensionService()->file_browser_event_router()->
+  return FileBrowserEventRouterFactory::GetForProfile(profile_)->
       AddFileWatch(local_path, virtual_path, extension_id);
 #else
   return true;
 #endif  // defined(OS_CHROMEOS)
 }
 
 bool RemoveFileWatchBrowserFunction::PerformFileWatchOperation(
     const FilePath& local_path, const FilePath& unused,
     const std::string& extension_id) {
 #if defined(OS_CHROMEOS)
-  profile_->GetExtensionService()->file_browser_event_router()->
+  FileBrowserEventRouterFactory::GetForProfile(profile_)->
       RemoveFileWatch(local_path, extension_id);
 #endif
   return true;
 }
 
 bool GetFileTasksFileBrowserFunction::RunImpl() {
   ListValue* files_list = NULL;
   if (!args_->GetList(0, &files_list))
     return false;
 
@@ skipping 450 matching lines @@
 
 void AddMountFunction::RaiseGDataMountEvent(gdata::GDataErrorCode error) {
   chromeos::MountError error_code = error == gdata::HTTP_SUCCESS ?
       chromeos::MOUNT_ERROR_NONE : chromeos::MOUNT_ERROR_NOT_AUTHENTICATED;
   DiskMountManager::MountPointInfo mount_info(
       gdata::util::GetGDataMountPointPathAsString(),
       gdata::util::GetGDataMountPointPathAsString(),
       chromeos::MOUNT_TYPE_GDATA,
       chromeos::disks::MOUNT_CONDITION_NONE);
   // Raise mount event
-  profile_->GetExtensionService()->file_browser_event_router()->MountCompleted(
-      DiskMountManager::MOUNTING,
-      error_code,
-      mount_info);
+  FileBrowserEventRouterFactory::GetForProfile(profile_)->
+      MountCompleted(DiskMountManager::MOUNTING, error_code, mount_info);
 }
 
 void AddMountFunction::OnGDataAuthentication(gdata::GDataErrorCode error,
                                              const std::string& token) {
   if (error == gdata::HTTP_SUCCESS)
     AddGDataMountPoint();
 
   RaiseGDataMountEvent(error);
   SendResponse(true);
 }
@@ skipping 686 matching lines @@
     local_paths_->Append(Value::CreateStringValue(""));
     DVLOG(1) << "Failed to get " << gdata_path.value()
              << " with error code: " << error;
   }
 
   remaining_gdata_paths_.pop();
 
   // Start getting the next file.
   GetFileOrSendResponse();
 }
+
+GetFileTransfersFunction::GetFileTransfersFunction() {}
+
+GetFileTransfersFunction::~GetFileTransfersFunction() {}
+
+ListValue* GetFileTransfersFunction::GetFileTransfersList() {
+  gdata::GDataFileSystem* file_system =
+      gdata::GDataFileSystemFactory::GetForProfile(profile_);
+  if (!file_system)
+    return NULL;
+
+  std::vector<gdata::GDataOperationRegistry::ProgressStatus>
+      list = file_system->GetProgressStatusList();
+  return file_manager_util::ProgressStatusVectorToListValue(
+      profile_, source_url_.GetOrigin(), list);
+}
+
+bool GetFileTransfersFunction::RunImpl() {
+  scoped_ptr<ListValue> progress_status_list(GetFileTransfersList());
+  if (!progress_status_list.get()) {
+    SendResponse(false);
+    return false;
+  }
+
+  result_.reset(progress_status_list.release());
+  SendResponse(true);
+  return true;
+}
+