drive: Support offline delete

chrome/browser/chromeos/drive/sync_client_unittest.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/drive/sync_client.h"
 
 #include "base/file_util.h"
 #include "base/files/file_path.h"
 #include "base/files/scoped_temp_dir.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/prefs/testing_pref_service.h"
 #include "base/run_loop.h"
 #include "base/test/test_timeouts.h"
 #include "chrome/browser/chromeos/drive/change_list_loader.h"
 #include "chrome/browser/chromeos/drive/change_list_processor.h"
 #include "chrome/browser/chromeos/drive/drive.pb.h"
 #include "chrome/browser/chromeos/drive/fake_free_disk_space_getter.h"
 #include "chrome/browser/chromeos/drive/file_cache.h"
 #include "chrome/browser/chromeos/drive/file_system/operation_observer.h"
+#include "chrome/browser/chromeos/drive/file_system/remove_operation.h"
 #include "chrome/browser/chromeos/drive/job_scheduler.h"
 #include "chrome/browser/chromeos/drive/resource_entry_conversion.h"
 #include "chrome/browser/chromeos/drive/resource_metadata.h"
 #include "chrome/browser/chromeos/drive/test_util.h"
 #include "chrome/browser/drive/fake_drive_service.h"
 #include "chrome/browser/google_apis/test_util.h"
 #include "content/public/test/test_browser_thread_bundle.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 namespace drive {
@@ skipping 123 matching lines @@
                                                     &temp_file));
     ASSERT_TRUE(google_apis::test_util::WriteStringToFile(temp_file,
                                                           kLocalContent));
 
     // Add file entries to the service.
     ASSERT_NO_FATAL_FAILURE(AddFileEntry("foo"));
     ASSERT_NO_FATAL_FAILURE(AddFileEntry("bar"));
     ASSERT_NO_FATAL_FAILURE(AddFileEntry("baz"));
     ASSERT_NO_FATAL_FAILURE(AddFileEntry("fetched"));
     ASSERT_NO_FATAL_FAILURE(AddFileEntry("dirty"));
+    ASSERT_NO_FATAL_FAILURE(AddFileEntry("removed"));
 
     // Load data from the service to the metadata.
     FileError error = FILE_ERROR_FAILED;
     internal::ChangeListLoader change_list_loader(
         base::MessageLoopProxy::current().get(),
         metadata_.get(),
         scheduler_.get(),
         drive_service_.get());
     change_list_loader.LoadIfNeeded(
         DirectoryFetchInfo(),
@@ skipping 14 matching lines @@
     EXPECT_EQ(FILE_ERROR_OK, cache_->Pin(GetLocalId("fetched")));
 
     // Prepare a pinned-and-fetched-and-dirty file.
     const std::string md5_dirty = "";  // Don't care.
     EXPECT_EQ(FILE_ERROR_OK,
               cache_->Store(GetLocalId("dirty"), md5_dirty,
                             temp_file, FileCache::FILE_OPERATION_COPY));
     EXPECT_EQ(FILE_ERROR_OK, cache_->Pin(GetLocalId("dirty")));
     EXPECT_EQ(FILE_ERROR_OK, cache_->MarkDirty(GetLocalId("dirty")));
 
+    // Prepare a removed file.
+    file_system::RemoveOperation remove_operation(
+        base::MessageLoopProxy::current().get(), &observer_, metadata_.get(),
+        cache_.get());
+    remove_operation.Remove(
+        metadata_->GetFilePath(GetLocalId("removed")),
+        false,  // is_recursive
+        google_apis::test_util::CreateCopyResultCallback(&error));
+    base::RunLoop().RunUntilIdle();
+    EXPECT_EQ(FILE_ERROR_OK, error);
   }
 
  protected:
   std::string GetLocalId(const std::string& title) {
     EXPECT_EQ(1U, resource_ids_.count(title));
     std::string local_id;
     EXPECT_EQ(FILE_ERROR_OK,
               metadata_->GetIdByResourceId(resource_ids_[title], &local_id));
     return local_id;
   }
@@ skipping 26 matching lines @@
 
   EXPECT_TRUE(cache_->GetCacheEntry(GetLocalId("bar"), &cache_entry));
   EXPECT_TRUE(cache_entry.is_present());
 
   EXPECT_TRUE(cache_->GetCacheEntry(GetLocalId("baz"), &cache_entry));
   EXPECT_TRUE(cache_entry.is_present());
 
   // Dirty file gets uploaded.
   EXPECT_TRUE(cache_->GetCacheEntry(GetLocalId("dirty"), &cache_entry));
   EXPECT_FALSE(cache_entry.is_dirty());
+
+  // Removed entry is not found.
+  google_apis::GDataErrorCode status = google_apis::GDATA_OTHER_ERROR;
+  scoped_ptr<google_apis::ResourceEntry> resource_entry;
+  drive_service_->GetResourceEntry(
+      resource_ids_["removed"],
+      google_apis::test_util::CreateCopyResultCallback(&status,
+                                                       &resource_entry));
+  base::RunLoop().RunUntilIdle();
+  EXPECT_EQ(google_apis::HTTP_SUCCESS, status);
+  ASSERT_TRUE(resource_entry);
+  EXPECT_TRUE(resource_entry->deleted());
 }
 
 TEST_F(SyncClientTest, AddFetchTask) {
   sync_client_->AddFetchTask(GetLocalId("foo"));
   base::RunLoop().RunUntilIdle();
 
   FileCacheEntry cache_entry;
   EXPECT_TRUE(cache_->GetCacheEntry(GetLocalId("foo"), &cache_entry));
   EXPECT_TRUE(cache_entry.is_present());
 }
@@ skipping 85 matching lines @@
 
   // Fetched and uploaded.
   EXPECT_TRUE(cache_->GetCacheEntry(GetLocalId("foo"), &cache_entry));
   EXPECT_TRUE(cache_entry.is_present());
   EXPECT_TRUE(cache_->GetCacheEntry(GetLocalId("dirty"), &cache_entry));
   EXPECT_FALSE(cache_entry.is_dirty());
 }
 
 }  // namespace internal
 }  // namespace drive