| Index: chrome/browser/media_galleries/fileapi/picasa/picasa_data_provider.cc
|
| diff --git a/chrome/browser/media_galleries/fileapi/picasa/picasa_data_provider.cc b/chrome/browser/media_galleries/fileapi/picasa/picasa_data_provider.cc
|
| deleted file mode 100644
|
| index 9df5ecc8ee5836736471a3841b6401308fe3f447..0000000000000000000000000000000000000000
|
| --- a/chrome/browser/media_galleries/fileapi/picasa/picasa_data_provider.cc
|
| +++ /dev/null
|
| @@ -1,266 +0,0 @@
|
| -// Copyright 2013 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/media_galleries/fileapi/picasa/picasa_data_provider.h"
|
| -
|
| -#include <utility>
|
| -
|
| -#include "base/basictypes.h"
|
| -#include "base/bind_helpers.h"
|
| -#include "base/callback.h"
|
| -#include "base/file_util.h"
|
| -#include "base/strings/stringprintf.h"
|
| -#include "chrome/browser/media_galleries/fileapi/file_path_watcher_util.h"
|
| -#include "chrome/browser/media_galleries/fileapi/media_file_system_backend.h"
|
| -#include "chrome/browser/media_galleries/fileapi/safe_picasa_album_table_reader.h"
|
| -#include "chrome/browser/media_galleries/fileapi/safe_picasa_albums_indexer.h"
|
| -#include "chrome/browser/media_galleries/imported_media_gallery_registry.h"
|
| -#include "webkit/browser/fileapi/file_system_operation_context.h"
|
| -#include "webkit/browser/fileapi/file_system_url.h"
|
| -
|
| -using chrome::MediaFileSystemBackend;
|
| -
|
| -namespace picasa {
|
| -
|
| -namespace {
|
| -
|
| -void RunAllCallbacks(
|
| - std::queue<PicasaDataProvider::ReadyCallback>* ready_callbacks_queue,
|
| - bool success) {
|
| - while (!ready_callbacks_queue->empty()) {
|
| - ready_callbacks_queue->front().Run(success);
|
| - ready_callbacks_queue->pop();
|
| - }
|
| -}
|
| -
|
| -} // namespace
|
| -
|
| -PicasaDataProvider::PicasaDataProvider(const base::FilePath& database_path)
|
| - : database_path_(database_path),
|
| - state_(STALE_DATA_STATE),
|
| - weak_factory_(this) {
|
| - DCHECK(MediaFileSystemBackend::CurrentlyOnMediaTaskRunnerThread());
|
| -
|
| - chrome::StartFilePathWatchOnMediaTaskRunner(
|
| - database_path_.DirName().AppendASCII(kPicasaTempDirName),
|
| - base::Bind(&PicasaDataProvider::OnTempDirWatchStarted,
|
| - weak_factory_.GetWeakPtr()),
|
| - base::Bind(&PicasaDataProvider::OnTempDirChanged,
|
| - weak_factory_.GetWeakPtr()));
|
| -}
|
| -
|
| -PicasaDataProvider::~PicasaDataProvider() {}
|
| -
|
| -void PicasaDataProvider::RefreshData(DataType needed_data,
|
| - const ReadyCallback& ready_callback) {
|
| - DCHECK(MediaFileSystemBackend::CurrentlyOnMediaTaskRunnerThread());
|
| - // TODO(tommycli): Need to watch the database_path_ folder and handle
|
| - // rereading the data when it changes.
|
| -
|
| - if (state_ == INVALID_DATA_STATE) {
|
| - ready_callback.Run(false /* success */);
|
| - return;
|
| - }
|
| -
|
| - if (needed_data == LIST_OF_ALBUMS_AND_FOLDERS_DATA) {
|
| - if (state_ == LIST_OF_ALBUMS_AND_FOLDERS_FRESH_STATE ||
|
| - state_ == ALBUMS_IMAGES_FRESH_STATE) {
|
| - ready_callback.Run(true /* success */);
|
| - return;
|
| - }
|
| - album_list_ready_callbacks_.push(ready_callback);
|
| - } else {
|
| - if (state_ == ALBUMS_IMAGES_FRESH_STATE) {
|
| - ready_callback.Run(true /* success */);
|
| - return;
|
| - }
|
| - albums_index_ready_callbacks_.push(ready_callback);
|
| - }
|
| - DoRefreshIfNecessary();
|
| -}
|
| -
|
| -scoped_ptr<AlbumMap> PicasaDataProvider::GetFolders() {
|
| - DCHECK(MediaFileSystemBackend::CurrentlyOnMediaTaskRunnerThread());
|
| - DCHECK(state_ == LIST_OF_ALBUMS_AND_FOLDERS_FRESH_STATE ||
|
| - state_ == ALBUMS_IMAGES_FRESH_STATE);
|
| - return make_scoped_ptr(new AlbumMap(folder_map_));
|
| -}
|
| -
|
| -scoped_ptr<AlbumMap> PicasaDataProvider::GetAlbums() {
|
| - DCHECK(MediaFileSystemBackend::CurrentlyOnMediaTaskRunnerThread());
|
| - DCHECK(state_ == LIST_OF_ALBUMS_AND_FOLDERS_FRESH_STATE ||
|
| - state_ == ALBUMS_IMAGES_FRESH_STATE);
|
| - return make_scoped_ptr(new AlbumMap(album_map_));
|
| -}
|
| -
|
| -scoped_ptr<AlbumImages> PicasaDataProvider::FindAlbumImages(
|
| - const std::string& key,
|
| - base::PlatformFileError* error) {
|
| - DCHECK(MediaFileSystemBackend::CurrentlyOnMediaTaskRunnerThread());
|
| - DCHECK(state_ == ALBUMS_IMAGES_FRESH_STATE);
|
| - DCHECK(error);
|
| -
|
| - AlbumImagesMap::const_iterator it = albums_images_.find(key);
|
| -
|
| - if (it == albums_images_.end()) {
|
| - *error = base::PLATFORM_FILE_ERROR_NOT_FOUND;
|
| - return scoped_ptr<AlbumImages>();
|
| - }
|
| -
|
| - *error = base::PLATFORM_FILE_OK;
|
| - return make_scoped_ptr(new AlbumImages(it->second));
|
| -}
|
| -
|
| -void PicasaDataProvider::InvalidateData() {
|
| - DCHECK(MediaFileSystemBackend::CurrentlyOnMediaTaskRunnerThread());
|
| -
|
| - // Set data state to stale and ignore responses from any in-flight processes.
|
| - // TODO(tommycli): Implement and call Cancel function for these
|
| - // UtilityProcessHostClients to actually kill the in-flight processes.
|
| - state_ = STALE_DATA_STATE;
|
| - album_table_reader_ = NULL;
|
| - albums_indexer_ = NULL;
|
| -
|
| - DoRefreshIfNecessary();
|
| -}
|
| -
|
| -void PicasaDataProvider::OnTempDirWatchStarted(
|
| - scoped_ptr<base::FilePathWatcher> temp_dir_watcher) {
|
| - DCHECK(MediaFileSystemBackend::CurrentlyOnMediaTaskRunnerThread());
|
| - temp_dir_watcher_.reset(temp_dir_watcher.release());
|
| -}
|
| -
|
| -void PicasaDataProvider::OnTempDirChanged(const base::FilePath& temp_dir_path,
|
| - bool error) {
|
| - DCHECK(MediaFileSystemBackend::CurrentlyOnMediaTaskRunnerThread());
|
| - if (file_util::IsDirectoryEmpty(temp_dir_path))
|
| - InvalidateData();
|
| -}
|
| -
|
| -void PicasaDataProvider::DoRefreshIfNecessary() {
|
| - DCHECK(state_ != INVALID_DATA_STATE);
|
| - DCHECK(state_ != ALBUMS_IMAGES_FRESH_STATE);
|
| - DCHECK(!(album_table_reader_ && albums_indexer_));
|
| -
|
| - if (album_list_ready_callbacks_.empty() &&
|
| - albums_index_ready_callbacks_.empty()) {
|
| - return;
|
| - }
|
| -
|
| - if (state_ == STALE_DATA_STATE) {
|
| - if (album_table_reader_)
|
| - return;
|
| - album_table_reader_ =
|
| - new SafePicasaAlbumTableReader(AlbumTableFiles(database_path_));
|
| - album_table_reader_->Start(
|
| - base::Bind(&PicasaDataProvider::OnAlbumTableReaderDone,
|
| - weak_factory_.GetWeakPtr(),
|
| - album_table_reader_));
|
| - } else {
|
| - DCHECK(state_ == LIST_OF_ALBUMS_AND_FOLDERS_FRESH_STATE);
|
| - if (albums_indexer_)
|
| - return;
|
| - albums_indexer_ = new SafePicasaAlbumsIndexer(album_map_, folder_map_);
|
| - albums_indexer_->Start(base::Bind(&PicasaDataProvider::OnAlbumsIndexerDone,
|
| - weak_factory_.GetWeakPtr(),
|
| - albums_indexer_));
|
| - }
|
| -}
|
| -
|
| -void PicasaDataProvider::OnAlbumTableReaderDone(
|
| - scoped_refptr<SafePicasaAlbumTableReader> reader,
|
| - bool parse_success,
|
| - const std::vector<AlbumInfo>& albums,
|
| - const std::vector<AlbumInfo>& folders) {
|
| - DCHECK(MediaFileSystemBackend::CurrentlyOnMediaTaskRunnerThread());
|
| - // If the reader has already been deemed stale, ignore the result.
|
| - if (reader != album_table_reader_)
|
| - return;
|
| - album_table_reader_ = NULL;
|
| -
|
| - DCHECK(state_ == STALE_DATA_STATE);
|
| -
|
| - if (!parse_success) {
|
| - // If we didn't get the list successfully, fail all those waiting for
|
| - // the albums indexer also.
|
| - state_ = INVALID_DATA_STATE;
|
| - RunAllCallbacks(&album_list_ready_callbacks_, false /* success */);
|
| - RunAllCallbacks(&albums_index_ready_callbacks_, false /* success */);
|
| - return;
|
| - }
|
| -
|
| - album_map_.clear();
|
| - folder_map_.clear();
|
| - UniquifyNames(albums, &album_map_);
|
| - UniquifyNames(folders, &folder_map_);
|
| -
|
| - state_ = LIST_OF_ALBUMS_AND_FOLDERS_FRESH_STATE;
|
| - RunAllCallbacks(&album_list_ready_callbacks_, parse_success);
|
| -
|
| - // Chain from this process onto refreshing the albums images if necessary.
|
| - DoRefreshIfNecessary();
|
| -}
|
| -
|
| -void PicasaDataProvider::OnAlbumsIndexerDone(
|
| - scoped_refptr<SafePicasaAlbumsIndexer> indexer,
|
| - bool success,
|
| - const picasa::AlbumImagesMap& albums_images) {
|
| - DCHECK(MediaFileSystemBackend::CurrentlyOnMediaTaskRunnerThread());
|
| - // If the indexer has already been deemed stale, ignore the result.
|
| - if (indexer != albums_indexer_)
|
| - return;
|
| - albums_indexer_ = NULL;
|
| -
|
| - DCHECK(state_ == LIST_OF_ALBUMS_AND_FOLDERS_FRESH_STATE);
|
| -
|
| - if (success) {
|
| - state_ = ALBUMS_IMAGES_FRESH_STATE;
|
| -
|
| - albums_images_ = albums_images;
|
| - }
|
| -
|
| - RunAllCallbacks(&albums_index_ready_callbacks_, success);
|
| -}
|
| -
|
| -// static
|
| -std::string PicasaDataProvider::DateToPathString(const base::Time& time) {
|
| - base::Time::Exploded exploded_time;
|
| - time.LocalExplode(&exploded_time);
|
| -
|
| - // TODO(tommycli): Investigate better localization and persisting which locale
|
| - // we use to generate these unique names.
|
| - return base::StringPrintf("%04d-%02d-%02d", exploded_time.year,
|
| - exploded_time.month, exploded_time.day_of_month);
|
| -}
|
| -
|
| -// static
|
| -void PicasaDataProvider::UniquifyNames(const std::vector<AlbumInfo>& info_list,
|
| - AlbumMap* result_map) {
|
| - // TODO(tommycli): We should persist the uniquified names.
|
| - std::vector<std::string> desired_names;
|
| -
|
| - std::map<std::string, int> total_counts;
|
| - std::map<std::string, int> current_counts;
|
| -
|
| - for (std::vector<AlbumInfo>::const_iterator it = info_list.begin();
|
| - it != info_list.end(); ++it) {
|
| - std::string desired_name =
|
| - it->name + " " + DateToPathString(it->timestamp);
|
| - desired_names.push_back(desired_name);
|
| - ++total_counts[desired_name];
|
| - }
|
| -
|
| - for (unsigned int i = 0; i < info_list.size(); i++) {
|
| - std::string name = desired_names[i];
|
| -
|
| - if (total_counts[name] != 1) {
|
| - name = base::StringPrintf("%s (%d)", name.c_str(),
|
| - ++current_counts[name]);
|
| - }
|
| -
|
| - result_map->insert(std::pair<std::string, AlbumInfo>(name, info_list[i]));
|
| - }
|
| -}
|
| -
|
| -} // namespace picasa
|
|
|