1 // Copyright (c) 2013 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 "chrome/browser/sync_file_system/fake_remote_change_processor.h" 6 7 #include "base/bind.h" 8 #include "base/files/file_path.h" 9 #include "base/location.h" 10 #include "base/message_loop/message_loop_proxy.h" 11 #include "chrome/browser/sync_file_system/file_change.h" 12 #include "chrome/browser/sync_file_system/sync_file_metadata.h" 13 #include "chrome/browser/sync_file_system/syncable_file_system_util.h" 14 #include "testing/gtest/include/gtest/gtest.h" 15 #include "webkit/browser/fileapi/file_system_url.h" 16 #include "webkit/common/fileapi/file_system_util.h" 17 18 namespace sync_file_system { 19 20 FakeRemoteChangeProcessor::FakeRemoteChangeProcessor() { 21 } 22 23 FakeRemoteChangeProcessor::~FakeRemoteChangeProcessor() { 24 } 25 26 void FakeRemoteChangeProcessor::PrepareForProcessRemoteChange( 27 const fileapi::FileSystemURL& url, 28 const PrepareChangeCallback& callback) { 29 SyncFileMetadata local_metadata; 30 31 if (fileapi::VirtualPath::IsRootPath(url.path())) { 32 // Origin root directory case. 33 local_metadata = SyncFileMetadata( 34 SYNC_FILE_TYPE_DIRECTORY, 0, base::Time::Now()); 35 } 36 37 URLToFileMetadata::iterator found_metadata = local_file_metadata_.find(url); 38 if (found_metadata != local_file_metadata_.end()) 39 local_metadata = found_metadata->second; 40 41 // Override |local_metadata| by applied changes. 42 URLToFileChangesMap::iterator found = applied_changes_.find(url); 43 if (found != applied_changes_.end()) { 44 DCHECK(!found->second.empty()); 45 const FileChange& applied_change = found->second.back(); 46 if (applied_change.IsAddOrUpdate()) { 47 local_metadata = SyncFileMetadata( 48 applied_change.file_type(), 49 100 /* size */, 50 base::Time::Now()); 51 } 52 } 53 54 FileChangeList change_list; 55 URLToFileChangeList::iterator found_list = local_changes_.find(url); 56 if (found_list != local_changes_.end()) 57 change_list = found_list->second; 58 59 base::MessageLoopProxy::current()->PostTask( 60 FROM_HERE, 61 base::Bind(callback, SYNC_STATUS_OK, 62 local_metadata, change_list)); 63 } 64 65 void FakeRemoteChangeProcessor::ApplyRemoteChange( 66 const FileChange& change, 67 const base::FilePath& local_path, 68 const fileapi::FileSystemURL& url, 69 const SyncStatusCallback& callback) { 70 SyncStatusCode status = SYNC_STATUS_UNKNOWN; 71 base::FilePath ancestor = fileapi::VirtualPath::DirName(url.path()); 72 while (true) { 73 fileapi::FileSystemURL ancestor_url = 74 CreateSyncableFileSystemURL(url.origin(), ancestor); 75 if (!ancestor_url.is_valid()) 76 break; 77 78 URLToFileChangeList::iterator found_list = 79 local_changes_.find(ancestor_url); 80 if (found_list != local_changes_.end()) { 81 const FileChange& local_change = found_list->second.back(); 82 if (local_change.IsAddOrUpdate() && 83 local_change.file_type() != SYNC_FILE_TYPE_DIRECTORY) { 84 status = SYNC_FILE_ERROR_NOT_A_DIRECTORY; 85 break; 86 } 87 } 88 89 base::FilePath ancestor_parent = fileapi::VirtualPath::DirName(ancestor); 90 if (ancestor == ancestor_parent) 91 break; 92 ancestor = ancestor_parent; 93 } 94 if (status == SYNC_STATUS_UNKNOWN) { 95 applied_changes_[url].push_back(change); 96 status = SYNC_STATUS_OK; 97 } 98 base::MessageLoopProxy::current()->PostTask( 99 FROM_HERE, base::Bind(callback, status)); 100 } 101 102 void FakeRemoteChangeProcessor::FinalizeRemoteSync( 103 const fileapi::FileSystemURL& url, 104 bool clear_local_changes, 105 const base::Closure& completion_callback) { 106 base::MessageLoopProxy::current()->PostTask(FROM_HERE, completion_callback); 107 } 108 109 void FakeRemoteChangeProcessor::RecordFakeLocalChange( 110 const fileapi::FileSystemURL& url, 111 const FileChange& change, 112 const SyncStatusCallback& callback) { 113 local_changes_[url].Update(change); 114 base::MessageLoopProxy::current()->PostTask( 115 FROM_HERE, base::Bind(callback, SYNC_STATUS_OK)); 116 } 117 118 void FakeRemoteChangeProcessor::UpdateLocalFileMetadata( 119 const fileapi::FileSystemURL& url, 120 const FileChange& change) { 121 if (change.IsAddOrUpdate()) { 122 local_file_metadata_[url] = SyncFileMetadata( 123 change.file_type(), 100 /* size */, base::Time::Now()); 124 } else { 125 local_file_metadata_.erase(url); 126 } 127 local_changes_[url].Update(change); 128 } 129 130 void FakeRemoteChangeProcessor::ClearLocalChanges( 131 const fileapi::FileSystemURL& url) { 132 local_changes_.erase(url); 133 } 134 135 const FakeRemoteChangeProcessor::URLToFileChangesMap& 136 FakeRemoteChangeProcessor::GetAppliedRemoteChanges() const { 137 return applied_changes_; 138 } 139 140 void FakeRemoteChangeProcessor::VerifyConsistency( 141 const URLToFileChangesMap& expected_changes) { 142 EXPECT_EQ(expected_changes.size(), applied_changes_.size()); 143 for (URLToFileChangesMap::const_iterator itr = applied_changes_.begin(); 144 itr != applied_changes_.end(); ++itr) { 145 const fileapi::FileSystemURL& url = itr->first; 146 URLToFileChangesMap::const_iterator found = expected_changes.find(url); 147 if (found == expected_changes.end()) { 148 EXPECT_TRUE(found != expected_changes.end()) 149 << "Change not expected for " << url.DebugString(); 150 continue; 151 } 152 153 const std::vector<FileChange>& applied = itr->second; 154 const std::vector<FileChange>& expected = found->second; 155 156 if (applied.empty() || expected.empty()) { 157 EXPECT_TRUE(!applied.empty()); 158 EXPECT_TRUE(!expected.empty()); 159 continue; 160 } 161 162 EXPECT_EQ(expected.size(), applied.size()); 163 164 for (size_t i = 0; i < applied.size() && i < expected.size(); ++i) { 165 EXPECT_EQ(expected[i], applied[i]) 166 << url.DebugString() 167 << " expected:" << expected[i].DebugString() 168 << " applied:" << applied[i].DebugString(); 169 } 170 } 171 } 172 173 } // namespace sync_file_system 174
