[sync] Verify existence of the root when loading DirectoryBackingStore

components/sync/syncable/directory_backing_store_unittest.cc

 // Copyright 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 "components/sync/syncable/directory_backing_store.h"
 
 #include <stddef.h>
 #include <stdint.h>
 
 #include <map>
@@ skipping 60 matching lines @@
 
   static bool LoadAndIgnoreReturnedData(DirectoryBackingStore *dbs) {
     Directory::MetahandlesMap tmp_handles_map;
     JournalIndex delete_journals;
     MetahandleSet metahandles_to_purge;
     Directory::KernelLoadInfo kernel_load_info;
     return dbs->Load(&tmp_handles_map, &delete_journals, &metahandles_to_purge,
                      &kernel_load_info) == OPENED;
   }
 
+  void SetUpCorruptedRootDatabase(sql::Connection* connection);
   void SetUpVersion67Database(sql::Connection* connection);
   void SetUpVersion68Database(sql::Connection* connection);
   void SetUpVersion69Database(sql::Connection* connection);
   void SetUpVersion70Database(sql::Connection* connection);
   void SetUpVersion71Database(sql::Connection* connection);
   void SetUpVersion72Database(sql::Connection* connection);
   void SetUpVersion73Database(sql::Connection* connection);
   void SetUpVersion74Database(sql::Connection* connection);
   void SetUpVersion75Database(sql::Connection* connection);
   void SetUpVersion76Database(sql::Connection* connection);
@@ skipping 312 matching lines @@
     if (it2 == expected_times.end()) {
       ADD_FAILURE() << "Could not find expected time for " << meta_handle;
       continue;
     }
     ExpectTime(*it->second, it2->second);
   }
 }
 
 }  // namespace
 
+void MigrationTest::SetUpCorruptedRootDatabase(sql::Connection* connection) {
+  ASSERT_TRUE(connection->is_open());
+  ASSERT_TRUE(connection->BeginTransaction());
+  ASSERT_TRUE(connection->Execute(
+      "CREATE TABLE extended_attributes(metahandle bigint, key varchar(127), "
+      "value blob, PRIMARY KEY(metahandle, key) ON CONFLICT REPLACE);"
+      "CREATE TABLE metas (metahandle bigint primary key ON CONFLICT FAIL,"
+      "base_version bigint default -1,server_version bigint default 0,"
+      "mtime bigint default 0,server_mtime bigint default 0,"
+      "ctime bigint default 0,server_ctime bigint default 0,"
+      "server_position_in_parent bigint default 0,"
+      "local_external_id bigint default 0,id varchar(255) default 'r',"
+      "parent_id varchar(255) default 'r',"
+      "server_parent_id varchar(255) default 'r',"
+      "prev_id varchar(255) default 'r',next_id varchar(255) default 'r',"
+      "is_unsynced bit default 0,is_unapplied_update bit default 0,"
+      "is_del bit default 0,is_dir bit default 0,"
+      "is_bookmark_object bit default 0,server_is_dir bit default 0,"
+      "server_is_del bit default 0,server_is_bookmark_object bit default 0,"
+      "name varchar(255), "            /* COLLATE PATHNAME, */
+      "unsanitized_name varchar(255)," /* COLLATE PATHNAME, */
+      "non_unique_name varchar,"
+      "server_name varchar(255)," /* COLLATE PATHNAME */
+      "server_non_unique_name varchar,"
+      "bookmark_url varchar,server_bookmark_url varchar,"
+      "singleton_tag varchar,bookmark_favicon blob,"
+      "server_bookmark_favicon blob);"
+      "INSERT INTO metas VALUES(1,-1,0," LEGACY_PROTO_TIME_VALS(
+          1) ",0,0,'r2','r2','r','r','r',0,0,0,1,0,0,0,0,NULL,"
+             "NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL);"
+             "CREATE TABLE share_info (id VARCHAR(128) primary key, "
+             "last_sync_timestamp INT, name VARCHAR(128), "
+             "initial_sync_ended BIT default 0, store_birthday VARCHAR(256), "
+             "db_create_version VARCHAR(128), db_create_time int, "
+             "next_id bigint default -2, cache_guid VARCHAR(32));"
+             "INSERT INTO share_info VALUES('nick@chromium.org',694,"
+             "'nick@chromium.org',1,'c27e9f59-08ca-46f8-b0cc-f16a2ed778bb',"
+             "'Unknown',1263522064,-65542,"
+             "'9010788312004066376x-6609234393368420856x');"
+             "CREATE TABLE share_version (id VARCHAR(128) primary key, data "
+             "INT);"
+             "INSERT INTO share_version VALUES('nick@chromium.org',68);"));
+  ASSERT_TRUE(connection->CommitTransaction());
+}
+
 void MigrationTest::SetUpVersion67Database(sql::Connection* connection) {
   // This is a version 67 database dump whose contents were backformed from
   // the contents of the version 68 database dump (the v68 migration was
   // actually written first).
   ASSERT_TRUE(connection->is_open());
   ASSERT_TRUE(connection->BeginTransaction());
   ASSERT_TRUE(connection->Execute(
       "CREATE TABLE extended_attributes(metahandle bigint, key varchar(127), "
           "value blob, PRIMARY KEY(metahandle, key) ON CONFLICT REPLACE);"
       "CREATE TABLE metas (metahandle bigint primary key ON CONFLICT FAIL,"
@@ skipping 3140 matching lines @@
   // Trying to unpack this entry should signal that the DB is corrupted.
   Directory::MetahandlesMap handles_map;
   JournalIndex delete_journals;
   MetahandleSet metahandles_to_purge;
   Directory::KernelLoadInfo kernel_load_info;
   ASSERT_EQ(FAILED_DATABASE_CORRUPT,
             dbs->Load(&handles_map, &delete_journals, &metahandles_to_purge,
                       &kernel_load_info));
 }
 
+TEST_F(DirectoryBackingStoreTest, DetectCorruptedRoot) {
+  sql::Connection connection;
+  ASSERT_TRUE(connection.OpenInMemory());
+  SetUpCorruptedRootDatabase(&connection);
+
+  std::unique_ptr<TestDirectoryBackingStore> dbs(
+      new TestDirectoryBackingStore(GetUsername(), &connection));
+
+  Directory::MetahandlesMap handles_map;
+  JournalIndex delete_journals;
+  MetahandleSet metahandles_to_purge;
+  Directory::KernelLoadInfo kernel_load_info;
+  ASSERT_EQ(FAILED_DATABASE_CORRUPT,
+            dbs->Load(&handles_map, &delete_journals, &metahandles_to_purge,
+                      &kernel_load_info));
+}
+
 TEST_P(MigrationTest, ToCurrentVersion) {
   sql::Connection connection;
   ASSERT_TRUE(connection.Open(GetDatabasePath()));
   // Assume all old versions have an old page size.
   connection.set_page_size(4096);
   switch (GetParam()) {
     case 67:
       SetUpVersion67Database(&connection);
       break;
     case 68:
@@ skipping 671 matching lines @@
   ASSERT_FALSE(dbs->SaveChanges(snapshot));
   // At this point the handler has been posted but not executed.
   ASSERT_FALSE(was_called);
   // Pump the message loop and see that it is executed.
   base::RunLoop().RunUntilIdle();
   ASSERT_TRUE(was_called);
 }
 
 }  // namespace syncable
 }  // namespace syncer