gdata: Add requestDirectoryRefresh to file_browser_private.

chrome/browser/chromeos/gdata/gdata_file_system.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/gdata/gdata_file_system.h"
 
 #include <errno.h>
 #include <sys/stat.h>
 
 #include <set>
@@ skipping 2533 matching lines @@
     return;
   }
 
   scoped_ptr<GDataDirectoryProto> directory_proto(new GDataDirectoryProto);
   directory->ToProto(directory_proto.get());
 
   if (!callback.is_null())
     callback.Run(base::PLATFORM_FILE_OK, directory_proto.Pass());
 }
 
+void GDataFileSystem::RequestDirectoryRefresh(
+    const FilePath& file_path) {
+  if (!BrowserThread::CurrentlyOn(BrowserThread::UI)) {
+    DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
+    const bool posted = BrowserThread::PostTask(
+        BrowserThread::UI,
+        FROM_HERE,
+        base::Bind(&GDataFileSystem::RequestDirectoryRefreshOnUIThread,
+                   ui_weak_ptr_,
+                   file_path));
+    DCHECK(posted);
+    return;
+  }
+
+  RequestDirectoryRefreshOnUIThread(file_path);
+}
+
+void GDataFileSystem::RequestDirectoryRefreshOnUIThread(
+    const FilePath& file_path) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+
+  base::AutoLock lock(lock_);  // To use GetGDataEntryByPath() and root_.
+  GDataEntry* entry = GetGDataEntryByPath(file_path);
+  if (!entry || !entry->AsGDataDirectory()) {
+    LOG(ERROR) << "Directory entry not found: " << file_path.value();
+    return;
+  }
+
+  if (entry->resource_id().empty()) {
+    // This can happen if the directory is a virtual directory for search.
+    LOG(ERROR) << "Resource ID not found: " << file_path.value();
+    return;
+  }
+
+  LoadFeedFromServer(root_->origin(),
+                     0,  // Not delta feed.
+                     0,  // Not used.
+                     true, // multiple feeds
+                     file_path,
+                     std::string(),  // No search query
+                     entry->resource_id(),
+                     FindEntryCallback(),  // Not used.
+                     base::Bind(&GDataFileSystem::OnRequestDirectoryRefresh,
+                                ui_weak_ptr_));
+}
+
+void GDataFileSystem::OnRequestDirectoryRefresh(
+    GetDocumentsParams* params,
+    base::PlatformFileError error) {
+  DCHECK(params);
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
+
+  const FilePath& directory_path = params->search_file_path;
+  if (error != base::PLATFORM_FILE_OK) {
+    LOG(ERROR) << "Failed to refresh directory: " << directory_path.value()
+               << ": " << error;
+    return;
+  }
+
+  base::AutoLock lock(lock_);  // To use FeedToFileResourceMap() and root_.
+
+  int unused_delta_feed_changestamp = 0;
+  int unused_num_regular_files = 0;
+  int unused_num_hosted_documents = 0;
+  FileResourceIdMap file_map;
+  error = FeedToFileResourceMap(*params->feed_list,
+                                &file_map,
+                                &unused_delta_feed_changestamp,
+                                &unused_num_regular_files,
+                                &unused_num_hosted_documents);
+  if (error != base::PLATFORM_FILE_OK) {
+    LOG(ERROR) << "Failed to convert feed: " << directory_path.value()
+               << ": " << error;
+    return;
+  }
+
+  GDataEntry* directory_entry = root_->GetEntryByResourceId(
+      params->directory_resource_id);
+  if (!directory_entry || !directory_entry->AsGDataDirectory()) {
+    LOG(ERROR) << "Directory entry is gone: " << directory_path.value()
+               << ": " << params->directory_resource_id;
+    return;
+  }
+  GDataDirectory* directory = directory_entry->AsGDataDirectory();
+
+  // Remove the existing files.
+  directory->RemoveChildFiles();
+  // Go through all entires generated by the feed and add files.
+  for (FileResourceIdMap::const_iterator it = file_map.begin();
+       it != file_map.end(); ++it) {
+    scoped_ptr<GDataEntry> entry(it->second);
+    // Skip if it's not a file (i.e. directory).
+    if (!entry->AsGDataFile())
+      continue;
+    directory->AddEntry(entry.release());
+  }
+
+  // Note that there may be no change in the directory, but it's expensive to
+  // check if the new metadata matches the existing one, so we just always
+  // notify that the directory is changed.
+  NotifyDirectoryChanged(directory_path);
+  DVLOG(1) << "Directory refreshed: " << directory_path.value();
+}
+
 bool GDataFileSystem::GetFileInfoByPath(
     const FilePath& file_path, GDataFileProperties* properties) {
   DCHECK(properties);
   base::AutoLock lock(lock_);
   GDataEntry* entry = GetGDataEntryByPath(file_path);
   if (!entry)
     return false;
 
   properties->file_info = entry->file_info();
   properties->resource_id = entry->resource_id();
@@ skipping 2585 matching lines @@
   pref_registrar_->Init(profile_->GetPrefs());
   pref_registrar_->Add(prefs::kDisableGDataHostedFiles, this);
 }
 
 void SetFreeDiskSpaceGetterForTesting(FreeDiskSpaceGetterInterface* getter) {
   delete global_free_disk_getter_for_testing;  // Safe to delete NULL;
   global_free_disk_getter_for_testing = getter;
 }
 
 }  // namespace gdata