1 // Copyright 2014 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #include "base/files/scoped_temp_dir.h"
6 #include "base/stl_util.h"
7 #include "sync/syncable/deferred_on_disk_directory_backing_store.h"
8 #include "sync/syncable/directory.h"
9 #include "sync/syncable/entry_kernel.h"
10 #include "sync/syncable/on_disk_directory_backing_store.h"
11 #include "sync/syncable/syncable_delete_journal.h"
12 #include "testing/gtest/include/gtest/gtest.h"
13
14 namespace syncer {
15 namespace syncable {
16 namespace {
17
18 static const base::FilePath::CharType kSyncDataFolderName[] =
19 FILE_PATH_LITERAL("Sync Data");
20
21 class DeferredOnDiskDirectoryBackingStoreTest : public testing::Test {
22 protected:
SetUp()23 virtual void SetUp() OVERRIDE {
24 CHECK(temp_dir_.CreateUniqueTempDir());
25 db_path_ = temp_dir_.path().Append(kSyncDataFolderName);
26 }
27
TearDown()28 virtual void TearDown() OVERRIDE {
29 STLDeleteValues(&handles_map_);
30 }
31
32 base::ScopedTempDir temp_dir_;
33 base::FilePath db_path_;
34 Directory::MetahandlesMap handles_map_;
35 JournalIndex delete_journals_;
36 Directory::KernelLoadInfo kernel_load_info_;
37 };
38
39 // Test initialization of root entry when calling Load().
TEST_F(DeferredOnDiskDirectoryBackingStoreTest,Load)40 TEST_F(DeferredOnDiskDirectoryBackingStoreTest, Load) {
41 DeferredOnDiskDirectoryBackingStore store("test", db_path_);
42 EXPECT_EQ(OPENED, store.Load(&handles_map_, &delete_journals_,
43 &kernel_load_info_));
44 EXPECT_TRUE(delete_journals_.empty());
45 ASSERT_EQ(1u, handles_map_.size()); // root node
46 ASSERT_TRUE(handles_map_.count(1));
47 EntryKernel* root = handles_map_[1];
48 EXPECT_TRUE(root->ref(ID).IsRoot());
49 EXPECT_EQ(1, root->ref(META_HANDLE));
50 EXPECT_TRUE(root->ref(IS_DIR));
51 }
52
53 // Test on-disk DB is not created if SaveChanges() is not called.
TEST_F(DeferredOnDiskDirectoryBackingStoreTest,DontPersistIfSavingChangesNotCalled)54 TEST_F(DeferredOnDiskDirectoryBackingStoreTest,
55 DontPersistIfSavingChangesNotCalled) {
56 {
57 // Open and close.
58 DeferredOnDiskDirectoryBackingStore store("test", db_path_);
59 EXPECT_EQ(OPENED, store.Load(&handles_map_, &delete_journals_,
60 &kernel_load_info_));
61 }
62
63 EXPECT_FALSE(base::PathExists(db_path_));
64 }
65
66 // Test on-disk DB is not created when there are no changes.
TEST_F(DeferredOnDiskDirectoryBackingStoreTest,DontPersistWhenSavingNoChanges)67 TEST_F(DeferredOnDiskDirectoryBackingStoreTest,
68 DontPersistWhenSavingNoChanges) {
69 {
70 // Open and close.
71 DeferredOnDiskDirectoryBackingStore store("test", db_path_);
72 EXPECT_EQ(OPENED, store.Load(&handles_map_, &delete_journals_,
73 &kernel_load_info_));
74
75 Directory::SaveChangesSnapshot snapshot;
76 store.SaveChanges(snapshot);
77 }
78
79 EXPECT_FALSE(base::PathExists(db_path_));
80 }
81
82 // Test changes are persisted to disk when SaveChanges() is called.
TEST_F(DeferredOnDiskDirectoryBackingStoreTest,PersistWhenSavingValidChanges)83 TEST_F(DeferredOnDiskDirectoryBackingStoreTest, PersistWhenSavingValidChanges) {
84 {
85 // Open and close.
86 DeferredOnDiskDirectoryBackingStore store("test", db_path_);
87 EXPECT_EQ(OPENED, store.Load(&handles_map_, &delete_journals_,
88 &kernel_load_info_));
89
90 Directory::SaveChangesSnapshot snapshot;
91 EntryKernel* entry = new EntryKernel();
92 entry->put(ID, Id::CreateFromClientString("test_entry"));
93 entry->put(META_HANDLE, 2);
94 entry->mark_dirty(NULL);
95 snapshot.dirty_metas.insert(entry);
96 store.SaveChanges(snapshot);
97 }
98
99 STLDeleteValues(&handles_map_);
100
101 ASSERT_TRUE(base::PathExists(db_path_));
102 OnDiskDirectoryBackingStore read_store("test", db_path_);
103 EXPECT_EQ(OPENED, read_store.Load(&handles_map_, &delete_journals_,
104 &kernel_load_info_));
105 ASSERT_EQ(2u, handles_map_.size());
106 ASSERT_TRUE(handles_map_.count(1)); // root node
107 ASSERT_TRUE(handles_map_.count(2));
108 EntryKernel* entry = handles_map_[2];
109 EXPECT_EQ(Id::CreateFromClientString("test_entry"), entry->ref(ID));
110 }
111
112 } // namespace
113 } // namespace syncable
114 } // namespace syncer
115