| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "chrome/browser/sync_file_system/drive_metadata_store.h" | 5 #include "chrome/browser/sync_file_system/drive_metadata_store.h" |
| 6 | 6 |
| 7 #include <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/files/file_path.h" | 9 #include "base/files/file_path.h" |
| 10 #include "base/files/scoped_temp_dir.h" | 10 #include "base/files/scoped_temp_dir.h" |
| 11 #include "base/message_loop.h" | 11 #include "base/message_loop.h" |
| 12 #include "base/single_thread_task_runner.h" | 12 #include "base/single_thread_task_runner.h" |
| 13 #include "base/stl_util.h" | 13 #include "base/stl_util.h" |
| 14 #include "base/string_util.h" | 14 #include "base/string_util.h" |
| 15 #include "base/strings/string_number_conversions.h" |
| 15 #include "base/threading/thread.h" | 16 #include "base/threading/thread.h" |
| 17 #include "chrome/browser/sync_file_system/drive/metadata_db_migration_util.h" |
| 16 #include "chrome/browser/sync_file_system/drive_file_sync_service.h" | 18 #include "chrome/browser/sync_file_system/drive_file_sync_service.h" |
| 17 #include "chrome/browser/sync_file_system/sync_file_system.pb.h" | 19 #include "chrome/browser/sync_file_system/sync_file_system.pb.h" |
| 18 #include "content/public/browser/browser_thread.h" | 20 #include "content/public/browser/browser_thread.h" |
| 19 #include "testing/gtest/include/gtest/gtest.h" | 21 #include "testing/gtest/include/gtest/gtest.h" |
| 20 #include "third_party/leveldatabase/src/include/leveldb/db.h" | 22 #include "third_party/leveldatabase/src/include/leveldb/db.h" |
| 23 #include "third_party/leveldatabase/src/include/leveldb/write_batch.h" |
| 21 #include "webkit/browser/fileapi/isolated_context.h" | 24 #include "webkit/browser/fileapi/isolated_context.h" |
| 22 #include "webkit/fileapi/syncable/syncable_file_system_util.h" | 25 #include "webkit/fileapi/syncable/syncable_file_system_util.h" |
| 23 | 26 |
| 24 #define FPL FILE_PATH_LITERAL | 27 #define FPL FILE_PATH_LITERAL |
| 25 | 28 |
| 26 using content::BrowserThread; | 29 using content::BrowserThread; |
| 27 | 30 |
| 28 namespace sync_file_system { | 31 namespace sync_file_system { |
| 29 | 32 |
| 30 namespace { | 33 namespace { |
| (...skipping 292 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 323 } | 326 } |
| 324 | 327 |
| 325 TEST_F(DriveMetadataStoreTest, ReadWriteTest) { | 328 TEST_F(DriveMetadataStoreTest, ReadWriteTest) { |
| 326 InitializeDatabase(); | 329 InitializeDatabase(); |
| 327 | 330 |
| 328 const fileapi::FileSystemURL url = URL(base::FilePath()); | 331 const fileapi::FileSystemURL url = URL(base::FilePath()); |
| 329 DriveMetadata metadata; | 332 DriveMetadata metadata; |
| 330 EXPECT_EQ(SYNC_DATABASE_ERROR_NOT_FOUND, | 333 EXPECT_EQ(SYNC_DATABASE_ERROR_NOT_FOUND, |
| 331 metadata_store()->ReadEntry(url, &metadata)); | 334 metadata_store()->ReadEntry(url, &metadata)); |
| 332 | 335 |
| 333 metadata = CreateMetadata("1234567890", "09876543210", true, false); | 336 metadata = CreateMetadata("file:1234567890", "09876543210", true, false); |
| 334 EXPECT_EQ(SYNC_STATUS_OK, UpdateEntry(url, metadata)); | 337 EXPECT_EQ(SYNC_STATUS_OK, UpdateEntry(url, metadata)); |
| 335 EXPECT_EQ(SYNC_STATUS_OK, SetLargestChangeStamp(1)); | 338 EXPECT_EQ(SYNC_STATUS_OK, SetLargestChangeStamp(1)); |
| 336 | 339 |
| 337 DropDatabase(); | 340 DropDatabase(); |
| 338 InitializeDatabase(); | 341 InitializeDatabase(); |
| 339 | 342 |
| 340 EXPECT_EQ(1, metadata_store()->GetLargestChangeStamp()); | 343 EXPECT_EQ(1, metadata_store()->GetLargestChangeStamp()); |
| 341 | 344 |
| 342 DriveMetadata metadata2; | 345 DriveMetadata metadata2; |
| 343 EXPECT_EQ(SYNC_STATUS_OK, | 346 EXPECT_EQ(SYNC_STATUS_OK, |
| (...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 406 EXPECT_EQ(SYNC_STATUS_OK, | 409 EXPECT_EQ(SYNC_STATUS_OK, |
| 407 metadata_store()->GetToBeFetchedFiles(&list)); | 410 metadata_store()->GetToBeFetchedFiles(&list)); |
| 408 EXPECT_EQ(2U, list.size()); | 411 EXPECT_EQ(2U, list.size()); |
| 409 EXPECT_EQ(list[0].first, URL(path2)); | 412 EXPECT_EQ(list[0].first, URL(path2)); |
| 410 EXPECT_EQ(list[1].first, URL(path3)); | 413 EXPECT_EQ(list[1].first, URL(path3)); |
| 411 | 414 |
| 412 VerifyReverseMap(); | 415 VerifyReverseMap(); |
| 413 } | 416 } |
| 414 | 417 |
| 415 TEST_F(DriveMetadataStoreTest, StoreSyncRootDirectory) { | 418 TEST_F(DriveMetadataStoreTest, StoreSyncRootDirectory) { |
| 416 const std::string kResourceId("hoge"); | 419 const std::string kResourceId("folder:hoge"); |
| 417 | 420 |
| 418 InitializeDatabase(); | 421 InitializeDatabase(); |
| 419 | 422 |
| 420 EXPECT_TRUE(metadata_store()->sync_root_directory().empty()); | 423 EXPECT_TRUE(metadata_store()->sync_root_directory().empty()); |
| 421 | 424 |
| 422 metadata_store()->SetSyncRootDirectory(kResourceId); | 425 metadata_store()->SetSyncRootDirectory(kResourceId); |
| 423 EXPECT_EQ(kResourceId, metadata_store()->sync_root_directory()); | 426 EXPECT_EQ(kResourceId, metadata_store()->sync_root_directory()); |
| 424 | 427 |
| 425 DropSyncRootDirectoryInStore(); | 428 DropSyncRootDirectoryInStore(); |
| 426 EXPECT_TRUE(metadata_store()->sync_root_directory().empty()); | 429 EXPECT_TRUE(metadata_store()->sync_root_directory().empty()); |
| 427 | 430 |
| 428 RestoreSyncRootDirectoryFromDB(); | 431 RestoreSyncRootDirectoryFromDB(); |
| 429 EXPECT_EQ(kResourceId, metadata_store()->sync_root_directory()); | 432 EXPECT_EQ(kResourceId, metadata_store()->sync_root_directory()); |
| 430 | 433 |
| 431 VerifyReverseMap(); | 434 VerifyReverseMap(); |
| 432 } | 435 } |
| 433 | 436 |
| 434 TEST_F(DriveMetadataStoreTest, StoreSyncOrigin) { | 437 TEST_F(DriveMetadataStoreTest, StoreSyncOrigin) { |
| 435 const GURL kOrigin1("chrome-extension://example1"); | 438 const GURL kOrigin1("chrome-extension://example1"); |
| 436 const GURL kOrigin2("chrome-extension://example2"); | 439 const GURL kOrigin2("chrome-extension://example2"); |
| 437 const std::string kResourceId1("hoge"); | 440 const std::string kResourceId1("folder:hoge"); |
| 438 const std::string kResourceId2("fuga"); | 441 const std::string kResourceId2("folder:fuga"); |
| 439 | 442 |
| 440 InitializeDatabase(); | 443 InitializeDatabase(); |
| 441 | 444 |
| 442 // Make sure origins have not been marked yet. | 445 // Make sure origins have not been marked yet. |
| 443 VerifyUntrackedOrigin(kOrigin1); | 446 VerifyUntrackedOrigin(kOrigin1); |
| 444 VerifyUntrackedOrigin(kOrigin2); | 447 VerifyUntrackedOrigin(kOrigin2); |
| 445 | 448 |
| 446 // Mark origins as incremental sync origins. | 449 // Mark origins as incremental sync origins. |
| 447 metadata_store()->AddIncrementalSyncOrigin(kOrigin1, kResourceId1); | 450 metadata_store()->AddIncrementalSyncOrigin(kOrigin1, kResourceId1); |
| 448 metadata_store()->AddIncrementalSyncOrigin(kOrigin2, kResourceId2); | 451 metadata_store()->AddIncrementalSyncOrigin(kOrigin2, kResourceId2); |
| (...skipping 89 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 538 metadata_map().find(kOrigin1); | 541 metadata_map().find(kOrigin1); |
| 539 EXPECT_TRUE(found != metadata_map().end() && found->second.size() == 1u); | 542 EXPECT_TRUE(found != metadata_map().end() && found->second.size() == 1u); |
| 540 | 543 |
| 541 VerifyReverseMap(); | 544 VerifyReverseMap(); |
| 542 } | 545 } |
| 543 | 546 |
| 544 TEST_F(DriveMetadataStoreTest, GetResourceIdForOrigin) { | 547 TEST_F(DriveMetadataStoreTest, GetResourceIdForOrigin) { |
| 545 const GURL kOrigin1("chrome-extension://example1"); | 548 const GURL kOrigin1("chrome-extension://example1"); |
| 546 const GURL kOrigin2("chrome-extension://example2"); | 549 const GURL kOrigin2("chrome-extension://example2"); |
| 547 const GURL kOrigin3("chrome-extension://example3"); | 550 const GURL kOrigin3("chrome-extension://example3"); |
| 548 const std::string kResourceId1("hogera"); | 551 const std::string kResourceId1("folder:hogera"); |
| 549 const std::string kResourceId2("fugaga"); | 552 const std::string kResourceId2("folder:fugaga"); |
| 550 const std::string kResourceId3("piyopiyo"); | 553 const std::string kResourceId3("folder:piyopiyo"); |
| 551 | 554 |
| 552 InitializeDatabase(); | 555 InitializeDatabase(); |
| 553 EXPECT_EQ(SYNC_STATUS_OK, SetLargestChangeStamp(1)); | 556 EXPECT_EQ(SYNC_STATUS_OK, SetLargestChangeStamp(1)); |
| 554 metadata_store()->SetSyncRootDirectory("root"); | 557 metadata_store()->SetSyncRootDirectory("root"); |
| 555 | 558 |
| 556 metadata_store()->AddIncrementalSyncOrigin(kOrigin1, kResourceId1); | 559 metadata_store()->AddIncrementalSyncOrigin(kOrigin1, kResourceId1); |
| 557 metadata_store()->AddIncrementalSyncOrigin(kOrigin2, kResourceId2); | 560 metadata_store()->AddIncrementalSyncOrigin(kOrigin2, kResourceId2); |
| 558 metadata_store()->AddIncrementalSyncOrigin(kOrigin3, kResourceId3); | 561 metadata_store()->AddIncrementalSyncOrigin(kOrigin3, kResourceId3); |
| 559 DisableOrigin(kOrigin3); | 562 DisableOrigin(kOrigin3); |
| 560 | 563 |
| (...skipping 20 matching lines...) Expand all Loading... |
| 581 EXPECT_TRUE(metadata_store()->IsKnownOrigin(kOrigin1)); | 584 EXPECT_TRUE(metadata_store()->IsKnownOrigin(kOrigin1)); |
| 582 EXPECT_TRUE(metadata_store()->IsKnownOrigin(kOrigin2)); | 585 EXPECT_TRUE(metadata_store()->IsKnownOrigin(kOrigin2)); |
| 583 EXPECT_TRUE(metadata_store()->IsKnownOrigin(kOrigin3)); | 586 EXPECT_TRUE(metadata_store()->IsKnownOrigin(kOrigin3)); |
| 584 | 587 |
| 585 VerifyReverseMap(); | 588 VerifyReverseMap(); |
| 586 } | 589 } |
| 587 | 590 |
| 588 TEST_F(DriveMetadataStoreTest, MigrationFromV0) { | 591 TEST_F(DriveMetadataStoreTest, MigrationFromV0) { |
| 589 const GURL kOrigin1("chrome-extension://example1"); | 592 const GURL kOrigin1("chrome-extension://example1"); |
| 590 const GURL kOrigin2("chrome-extension://example2"); | 593 const GURL kOrigin2("chrome-extension://example2"); |
| 591 const std::string kSyncRootResourceId("sync_root_resource_id"); | 594 const std::string kSyncRootResourceId("folder:sync_root_resource_id"); |
| 592 const std::string kResourceId1("hoge"); | 595 const std::string kResourceId1("folder:hoge"); |
| 593 const std::string kResourceId2("fuga"); | 596 const std::string kResourceId2("folder:fuga"); |
| 594 const std::string kFileResourceId("piyo"); | 597 const std::string kFileResourceId("file:piyo"); |
| 595 const base::FilePath kFile(FPL("foo bar")); | 598 const base::FilePath kFile(FPL("foo bar")); |
| 596 const std::string kFileMD5("file_md5"); | 599 const std::string kFileMD5("file_md5"); |
| 597 | 600 |
| 598 { | 601 { |
| 599 const char kChangeStampKey[] = "CHANGE_STAMP"; | 602 const char kChangeStampKey[] = "CHANGE_STAMP"; |
| 600 const char kSyncRootDirectoryKey[] = "SYNC_ROOT_DIR"; | 603 const char kSyncRootDirectoryKey[] = "SYNC_ROOT_DIR"; |
| 601 const char kDriveMetadataKeyPrefix[] = "METADATA: "; | 604 const char kDriveMetadataKeyPrefix[] = "METADATA: "; |
| 602 const char kDriveBatchSyncOriginKeyPrefix[] = "BSYNC_ORIGIN: "; | 605 const char kDriveBatchSyncOriginKeyPrefix[] = "BSYNC_ORIGIN: "; |
| 603 const char kDriveIncrementalSyncOriginKeyPrefix[] = "ISYNC_ORIGIN: "; | 606 const char kDriveIncrementalSyncOriginKeyPrefix[] = "ISYNC_ORIGIN: "; |
| 604 | 607 |
| (...skipping 103 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 708 metadata_store()->AddIncrementalSyncOrigin(kOrigin1, kResourceId1); | 711 metadata_store()->AddIncrementalSyncOrigin(kOrigin1, kResourceId1); |
| 709 VerifyIncrementalSyncOrigin(kOrigin1, kResourceId1); | 712 VerifyIncrementalSyncOrigin(kOrigin1, kResourceId1); |
| 710 VerifyReverseMap(); | 713 VerifyReverseMap(); |
| 711 | 714 |
| 712 metadata_store()->SetOriginRootDirectory(kOrigin1, kResourceId2); | 715 metadata_store()->SetOriginRootDirectory(kOrigin1, kResourceId2); |
| 713 VerifyIncrementalSyncOrigin(kOrigin1, kResourceId2); | 716 VerifyIncrementalSyncOrigin(kOrigin1, kResourceId2); |
| 714 VerifyReverseMap(); | 717 VerifyReverseMap(); |
| 715 } | 718 } |
| 716 | 719 |
| 717 } // namespace sync_file_system | 720 } // namespace sync_file_system |
| OLD | NEW |