SyncFS: Convert WAPI ResourceID to DriveAPI FileID

chrome/browser/sync_file_system/drive_metadata_store_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/sync_file_system/drive_metadata_store.h"
 
 #include <utility>
 
 #include "base/files/file_path.h"
 #include "base/files/scoped_temp_dir.h"
@@ skipping 317 matching lines @@
 }
 
 TEST_F(DriveMetadataStoreTest, ReadWriteTest) {
   InitializeDatabase();
 
   const fileapi::FileSystemURL url = URL(base::FilePath());
   DriveMetadata metadata;
   EXPECT_EQ(SYNC_DATABASE_ERROR_NOT_FOUND,
             metadata_store()->ReadEntry(url, &metadata));
 
-  metadata = CreateMetadata("1234567890", "09876543210", true, false);
+  metadata = CreateMetadata("file:1234567890", "09876543210", true, false);
   EXPECT_EQ(SYNC_STATUS_OK, UpdateEntry(url, metadata));
   EXPECT_EQ(SYNC_STATUS_OK, SetLargestChangeStamp(1));
 
   DropDatabase();
   InitializeDatabase();
 
   EXPECT_EQ(1, metadata_store()->GetLargestChangeStamp());
 
   DriveMetadata metadata2;
   EXPECT_EQ(SYNC_STATUS_OK,
@@ skipping 62 matching lines @@
   EXPECT_EQ(SYNC_STATUS_OK,
             metadata_store()->GetToBeFetchedFiles(&list));
   EXPECT_EQ(2U, list.size());
   EXPECT_EQ(list[0].first, URL(path2));
   EXPECT_EQ(list[1].first, URL(path3));
 
   VerifyReverseMap();
 }
 
 TEST_F(DriveMetadataStoreTest, StoreSyncRootDirectory) {
-  const std::string kResourceId("hoge");
+  const std::string kResourceId("folder:hoge");
 
   InitializeDatabase();
 
   EXPECT_TRUE(metadata_store()->sync_root_directory().empty());
 
   metadata_store()->SetSyncRootDirectory(kResourceId);
   EXPECT_EQ(kResourceId, metadata_store()->sync_root_directory());
 
   DropSyncRootDirectoryInStore();
   EXPECT_TRUE(metadata_store()->sync_root_directory().empty());
 
   RestoreSyncRootDirectoryFromDB();
   EXPECT_EQ(kResourceId, metadata_store()->sync_root_directory());
 
   VerifyReverseMap();
 }
 
 TEST_F(DriveMetadataStoreTest, StoreSyncOrigin) {
   const GURL kOrigin1("chrome-extension://example1");
   const GURL kOrigin2("chrome-extension://example2");
-  const std::string kResourceId1("hoge");
-  const std::string kResourceId2("fuga");
+  const std::string kResourceId1("folder:hoge");
+  const std::string kResourceId2("folder:fuga");
 
   InitializeDatabase();
 
   // Make sure origins have not been marked yet.
   VerifyUntrackedOrigin(kOrigin1);
   VerifyUntrackedOrigin(kOrigin2);
 
   // Mark origins as incremental sync origins.
   metadata_store()->AddIncrementalSyncOrigin(kOrigin1, kResourceId1);
   metadata_store()->AddIncrementalSyncOrigin(kOrigin2, kResourceId2);
@@ skipping 90 matching lines @@
       metadata_map().find(kOrigin1);
   EXPECT_TRUE(found != metadata_map().end() && found->second.size() == 1u);
 
   VerifyReverseMap();
 }
 
 TEST_F(DriveMetadataStoreTest, GetResourceIdForOrigin) {
   const GURL kOrigin1("chrome-extension://example1");
   const GURL kOrigin2("chrome-extension://example2");
   const GURL kOrigin3("chrome-extension://example3");
-  const std::string kResourceId1("hogera");
-  const std::string kResourceId2("fugaga");
-  const std::string kResourceId3("piyopiyo");
+  const std::string kResourceId1("folder:hogera");
+  const std::string kResourceId2("folder:fugaga");
+  const std::string kResourceId3("folder:piyopiyo");
 
   InitializeDatabase();
   EXPECT_EQ(SYNC_STATUS_OK, SetLargestChangeStamp(1));
   metadata_store()->SetSyncRootDirectory("root");
 
   metadata_store()->AddIncrementalSyncOrigin(kOrigin1, kResourceId1);
   metadata_store()->AddIncrementalSyncOrigin(kOrigin2, kResourceId2);
   metadata_store()->AddIncrementalSyncOrigin(kOrigin3, kResourceId3);
   DisableOrigin(kOrigin3);
 
@@ skipping 20 matching lines @@
   EXPECT_TRUE(metadata_store()->IsKnownOrigin(kOrigin1));
   EXPECT_TRUE(metadata_store()->IsKnownOrigin(kOrigin2));
   EXPECT_TRUE(metadata_store()->IsKnownOrigin(kOrigin3));
 
   VerifyReverseMap();
 }
 
 TEST_F(DriveMetadataStoreTest, MigrationFromV0) {
   const GURL kOrigin1("chrome-extension://example1");
   const GURL kOrigin2("chrome-extension://example2");
-  const std::string kSyncRootResourceId("sync_root_resource_id");
-  const std::string kResourceId1("hoge");
-  const std::string kResourceId2("fuga");
-  const std::string kFileResourceId("piyo");
+  const std::string kSyncRootResourceId("folder:sync_root_resource_id");
+  const std::string kResourceId1("folder:hoge");
+  const std::string kResourceId2("folder:fuga");
+  const std::string kFileResourceId("file:piyo");
   const base::FilePath kFile(FPL("foo bar"));
   const std::string kFileMD5("file_md5");
 
+  {

[nhiroki, 2013/05/27 09:17:56]

Sorry, I uploaded wrong commit. This migration test has not updated yet (just
copied). Please ignore for now...

+    const char kChangeStampKey[] = "CHANGE_STAMP";
+    const char kSyncRootDirectoryKey[] = "SYNC_ROOT_DIR";
+    const char kDriveMetadataKeyPrefix[] = "METADATA: ";
+    const char kDriveBatchSyncOriginKeyPrefix[] = "BSYNC_ORIGIN: ";
+    const char kDriveIncrementalSyncOriginKeyPrefix[] = "ISYNC_ORIGIN: ";
+
+    const char kV0ServiceName[] = "drive";
+    ASSERT_TRUE(RegisterSyncableFileSystem(kV0ServiceName));
+    leveldb::Options options;
+    options.create_if_missing = true;
+    leveldb::DB* db_ptr = NULL;
+    std::string db_dir = fileapi::FilePathToString(
+        base_dir().Append(DriveMetadataStore::kDatabaseName));
+    leveldb::Status status = leveldb::DB::Open(options, db_dir, &db_ptr);
+
+    scoped_ptr<leveldb::DB> db(db_ptr);
+    ASSERT_TRUE(status.ok());
+
+    leveldb::WriteOptions write_options;
+    db->Put(write_options, kChangeStampKey, "1");
+    db->Put(write_options, kSyncRootDirectoryKey, kSyncRootResourceId);
+
+    DriveMetadata drive_metadata;
+    drive_metadata.set_resource_id(kFileResourceId);
+    drive_metadata.set_md5_checksum(kFileMD5);
+    drive_metadata.set_conflicted(false);
+    drive_metadata.set_to_be_fetched(false);
+
+    fileapi::FileSystemURL url = CreateSyncableFileSystemURL(
+        kOrigin1, kV0ServiceName, kFile);
+    std::string serialized_url;
+    SerializeSyncableFileSystemURL(url, &serialized_url);
+    std::string metadata_string;
+    drive_metadata.SerializeToString(&metadata_string);
+
+    db->Put(write_options,
+            kDriveMetadataKeyPrefix + serialized_url, metadata_string);
+    db->Put(write_options,
+            kDriveBatchSyncOriginKeyPrefix + kOrigin1.spec(), kResourceId1);
+    db->Put(write_options,
+            kDriveIncrementalSyncOriginKeyPrefix + kOrigin2.spec(),
+            kResourceId2);
+    EXPECT_TRUE(RevokeSyncableFileSystem(kV0ServiceName));
+    MarkAsCreated();
+  }
+
+  InitializeDatabase();
+
+  EXPECT_EQ(1, metadata_store()->GetLargestChangeStamp());
+  EXPECT_EQ(kSyncRootResourceId, metadata_store()->sync_root_directory());
+  EXPECT_EQ(kResourceId1, metadata_store()->GetResourceIdForOrigin(kOrigin1));
+  EXPECT_EQ(kResourceId2, metadata_store()->GetResourceIdForOrigin(kOrigin2));
+
+  DriveMetadata metadata;
+  EXPECT_EQ(SYNC_STATUS_OK,
+            metadata_store()->ReadEntry(
+                CreateSyncableFileSystemURL(kOrigin1, kServiceName, kFile),
+                &metadata));
+  EXPECT_EQ(kFileResourceId, metadata.resource_id());
+  EXPECT_EQ(kFileMD5, metadata.md5_checksum());
+  EXPECT_FALSE(metadata.conflicted());
+  EXPECT_FALSE(metadata.to_be_fetched());
+
+  VerifyReverseMap();
+}
+
+TEST_F(DriveMetadataStoreTest, MigrationFromV1) {
+  const GURL kOrigin1("chrome-extension://example1");
+  const GURL kOrigin2("chrome-extension://example2");
+  const std::string kSyncRootResourceId("folder:sync_root_resource_id");
+  const std::string kResourceId1("folder:hoge");
+  const std::string kResourceId2("folder:fuga");
+  const std::string kFileResourceId("file:piyo");
+  const base::FilePath kFile(FPL("foo bar"));
+  const std::string kFileMD5("file_md5");
+
   {
     const char kChangeStampKey[] = "CHANGE_STAMP";
     const char kSyncRootDirectoryKey[] = "SYNC_ROOT_DIR";
     const char kDriveMetadataKeyPrefix[] = "METADATA: ";
     const char kDriveBatchSyncOriginKeyPrefix[] = "BSYNC_ORIGIN: ";
     const char kDriveIncrementalSyncOriginKeyPrefix[] = "ISYNC_ORIGIN: ";
 
     const char kV0ServiceName[] = "drive";
     ASSERT_TRUE(RegisterSyncableFileSystem(kV0ServiceName));
     leveldb::Options options;
@@ skipping 65 matching lines @@
   metadata_store()->AddIncrementalSyncOrigin(kOrigin1, kResourceId1);
   VerifyIncrementalSyncOrigin(kOrigin1, kResourceId1);
   VerifyReverseMap();
 
   metadata_store()->SetOriginRootDirectory(kOrigin1, kResourceId2);
   VerifyIncrementalSyncOrigin(kOrigin1, kResourceId2);
   VerifyReverseMap();
 }
 
 }  // namespace sync_file_system