| // 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/drive/file_task_executor.h" |
| |
| #include <string> |
| #include <vector> |
| |
| #include "chrome/browser/chromeos/drive/drive.pb.h" |
| #include "chrome/browser/chromeos/drive/drive_integration_service.h" |
| #include "chrome/browser/chromeos/drive/file_system_interface.h" |
| #include "chrome/browser/drive/drive_service_interface.h" |
| #include "chrome/browser/profiles/profile_manager.h" |
| #include "chrome/browser/ui/ash/multi_user/multi_user_util.h" |
| #include "chrome/browser/ui/browser.h" |
| #include "chrome/browser/ui/browser_tabstrip.h" |
| #include "chrome/browser/ui/browser_window.h" |
| #include "chrome/browser/ui/scoped_tabbed_browser_displayer.h" |
| #include "chrome/common/extensions/api/file_browser_private.h" |
| #include "content/public/browser/browser_thread.h" |
| #include "webkit/browser/fileapi/file_system_url.h" |
| |
| using fileapi::FileSystemURL; |
| |
| namespace drive { |
| |
| namespace { |
| |
| class FileTaskExecutorDelegateImpl : public FileTaskExecutorDelegate { |
| public: |
| explicit FileTaskExecutorDelegateImpl(Profile* profile) : profile_(profile) { |
| } |
| |
| virtual FileSystemInterface* GetFileSystem() OVERRIDE { |
| return util::GetFileSystemByProfile(profile_); |
| } |
| |
| virtual DriveServiceInterface* GetDriveService() OVERRIDE { |
| return util::GetDriveServiceByProfile(profile_); |
| } |
| |
| virtual void OpenBrowserWindow(const GURL& open_link) OVERRIDE { |
| chrome::ScopedTabbedBrowserDisplayer displayer( |
| profile_, chrome::HOST_DESKTOP_TYPE_ASH); |
| chrome::AddSelectedTabWithURL(displayer.browser(), open_link, |
| content::PAGE_TRANSITION_LINK); |
| // Since the ScopedTabbedBrowserDisplayer does not guarantee that the |
| // browser will be shown on the active desktop, we ensure the visibility. |
| multi_user_util::MoveWindowToCurrentDesktop( |
| displayer.browser()->window()->GetNativeWindow()); |
| } |
| |
| private: |
| Profile* const profile_; |
| }; |
| |
| } // namespace |
| |
| FileTaskExecutor::FileTaskExecutor(Profile* profile, const std::string& app_id) |
| : delegate_(new FileTaskExecutorDelegateImpl(profile)), |
| app_id_(app_id), |
| current_index_(0), |
| weak_ptr_factory_(this) { |
| } |
| |
| FileTaskExecutor::FileTaskExecutor( |
| scoped_ptr<FileTaskExecutorDelegate> delegate, |
| const std::string& app_id) |
| : delegate_(delegate.Pass()), |
| app_id_(app_id), |
| current_index_(0), |
| weak_ptr_factory_(this) { |
| } |
| |
| FileTaskExecutor::~FileTaskExecutor() { |
| } |
| |
| void FileTaskExecutor::Execute( |
| const std::vector<FileSystemURL>& file_urls, |
| const file_manager::file_tasks::FileTaskFinishedCallback& done) { |
| DCHECK(!file_urls.empty()); |
| |
| done_ = done; |
| |
| std::vector<base::FilePath> paths; |
| for (size_t i = 0; i < file_urls.size(); ++i) { |
| base::FilePath path = util::ExtractDrivePathFromFileSystemUrl(file_urls[i]); |
| if (path.empty()) { |
| Done(false); |
| return; |
| } |
| paths.push_back(path); |
| } |
| |
| FileSystemInterface* const file_system = delegate_->GetFileSystem(); |
| if (!file_system) { |
| Done(false); |
| return; |
| } |
| |
| // Reset the index, so we know when we're done. |
| DCHECK_EQ(current_index_, 0); |
| current_index_ = paths.size(); |
| |
| for (size_t i = 0; i < paths.size(); ++i) { |
| file_system->GetResourceEntry( |
| paths[i], |
| base::Bind(&FileTaskExecutor::OnFileEntryFetched, |
| weak_ptr_factory_.GetWeakPtr())); |
| } |
| } |
| |
| void FileTaskExecutor::OnFileEntryFetched(FileError error, |
| scoped_ptr<ResourceEntry> entry) { |
| // Here, we are only interested in files. |
| if (entry.get() && !entry->has_file_specific_info()) |
| error = FILE_ERROR_NOT_FOUND; |
| |
| DriveServiceInterface* const drive_service = delegate_->GetDriveService(); |
| if (!drive_service || error != FILE_ERROR_OK) { |
| Done(false); |
| return; |
| } |
| |
| // Send off a request for the drive service to authorize the apps for the |
| // current document entry for this document so we can get the |
| // open-with-<app_id> urls from the document entry. |
| drive_service->AuthorizeApp(entry->resource_id(), |
| app_id_, |
| base::Bind(&FileTaskExecutor::OnAppAuthorized, |
| weak_ptr_factory_.GetWeakPtr(), |
| entry->resource_id())); |
| } |
| |
| void FileTaskExecutor::OnAppAuthorized(const std::string& resource_id, |
| google_apis::GDataErrorCode error, |
| const GURL& open_link) { |
| DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); |
| |
| if (error != google_apis::HTTP_SUCCESS || open_link.is_empty()) { |
| Done(false); |
| return; |
| } |
| |
| delegate_->OpenBrowserWindow(open_link); |
| |
| // We're done with this file. If this is the last one, then we're done. |
| current_index_--; |
| DCHECK_GE(current_index_, 0); |
| if (current_index_ == 0) |
| Done(true); |
| } |
| |
| void FileTaskExecutor::Done(bool success) { |
| DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); |
| if (!done_.is_null()) |
| done_.Run(success |
| ? extensions::api::file_browser_private::TASK_RESULT_OPENED |
| : extensions::api::file_browser_private::TASK_RESULT_FAILED); |
| delete this; |
| } |
| |
| } // namespace drive |