SyncFS: Factor out DriveMetadataDB migration functions

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 570 matching lines @@
   EXPECT_TRUE(metadata_store()->GetResourceIdForOrigin(kOrigin3).empty());
 
   // Make sure they're still known origins.
   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("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;
-    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(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, DeprecateBatchSyncOrigins) {
-  // Make sure that previously saved batch sync origins were deleted from the DB
-  // as they are no longer used.
-  const char kDriveBatchSyncOriginKeyPrefix[] = "BSYNC_ORIGIN: ";
-  const GURL kOrigin1("chrome-extension://example1");
-  const std::string kResourceId1("hoge");
-
-  // Purposely add in an old batch sync origin (from previous DB version).
-  {
-    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::DB::Open(options, db_dir, &db_ptr);
-    scoped_ptr<leveldb::DB> db(db_ptr);
-    leveldb::WriteOptions write_options;
-    db->Put(write_options,
-            kDriveBatchSyncOriginKeyPrefix + kOrigin1.spec(), kResourceId1);
-  }
-
-  InitializeDatabase();
-
-  // Confirm no batch sync origins remain after InitializeDatabase.
-  scoped_ptr<leveldb::Iterator> itr(metadata_db()->NewIterator(
-      leveldb::ReadOptions()));
-  int batch_origins_found = 0;
-  for (itr->Seek(kDriveBatchSyncOriginKeyPrefix); itr->Valid(); itr->Next()) {
-    std::string key = itr->key().ToString();
-    if (!StartsWithASCII(key, kDriveBatchSyncOriginKeyPrefix, true))
-      break;
-    batch_origins_found++;
-  }
-  EXPECT_EQ(0, batch_origins_found);
-}
-
 TEST_F(DriveMetadataStoreTest, ResetOriginRootDirectory) {
   const GURL kOrigin1("chrome-extension://example1");
   const std::string kResourceId1("hoge");
   const std::string kResourceId2("fuga");
 
   InitializeDatabase();
   EXPECT_EQ(SYNC_STATUS_OK, SetLargestChangeStamp(1));
 
   metadata_store()->AddIncrementalSyncOrigin(kOrigin1, kResourceId1);
   VerifyIncrementalSyncOrigin(kOrigin1, kResourceId1);
   VerifyReverseMap();
 
   metadata_store()->SetOriginRootDirectory(kOrigin1, kResourceId2);
   VerifyIncrementalSyncOrigin(kOrigin1, kResourceId2);
   VerifyReverseMap();
 }
 
 }  // namespace sync_file_system