1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
|
// 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.
#ifndef COMPONENTS_DRIVE_CHANGE_LIST_PROCESSOR_H_
#define COMPONENTS_DRIVE_CHANGE_LIST_PROCESSOR_H_
#include <stdint.h>
#include <map>
#include <set>
#include <string>
#include "base/files/file_path.h"
#include "base/macros.h"
#include "base/memory/scoped_ptr.h"
#include "base/memory/scoped_vector.h"
#include "components/drive/file_errors.h"
#include "components/drive/file_errors.h"
#include "url/gurl.h"
namespace base {
class CancellationFlag;
} // namespace base
namespace google_apis {
class AboutResource;
class ChangeList;
class FileList;
} // namespace google_apis
namespace drive {
class FileChange;
class ResourceEntry;
namespace internal {
class ResourceMetadata;
// Holds information needed to fetch contents of a directory.
// This object is copyable.
class DirectoryFetchInfo {
public:
DirectoryFetchInfo() : changestamp_(0) {}
DirectoryFetchInfo(const std::string& local_id,
const std::string& resource_id,
int64_t changestamp)
: local_id_(local_id),
resource_id_(resource_id),
changestamp_(changestamp) {}
// Returns true if the object is empty.
bool empty() const { return local_id_.empty(); }
// Local ID of the directory.
const std::string& local_id() const { return local_id_; }
// Resource ID of the directory.
const std::string& resource_id() const { return resource_id_; }
// Changestamp of the directory. The changestamp is used to determine if
// the directory contents should be fetched.
int64_t changestamp() const { return changestamp_; }
// Returns a string representation of this object.
std::string ToString() const;
private:
const std::string local_id_;
const std::string resource_id_;
const int64_t changestamp_;
};
// Class to represent a change list.
class ChangeList {
public:
ChangeList(); // For tests.
explicit ChangeList(const google_apis::ChangeList& change_list);
explicit ChangeList(const google_apis::FileList& file_list);
~ChangeList();
const std::vector<ResourceEntry>& entries() const { return entries_; }
std::vector<ResourceEntry>* mutable_entries() { return &entries_; }
const std::vector<std::string>& parent_resource_ids() const {
return parent_resource_ids_;
}
std::vector<std::string>* mutable_parent_resource_ids() {
return &parent_resource_ids_;
}
const GURL& next_url() const { return next_url_; }
int64_t largest_changestamp() const { return largest_changestamp_; }
void set_largest_changestamp(int64_t largest_changestamp) {
largest_changestamp_ = largest_changestamp;
}
private:
std::vector<ResourceEntry> entries_;
std::vector<std::string> parent_resource_ids_;
GURL next_url_;
int64_t largest_changestamp_;
DISALLOW_COPY_AND_ASSIGN(ChangeList);
};
// ChangeListProcessor is used to process change lists, or full resource
// lists from WAPI (codename for Documents List API) or Google Drive API, and
// updates the resource metadata stored locally.
class ChangeListProcessor {
public:
ChangeListProcessor(ResourceMetadata* resource_metadata,
base::CancellationFlag* in_shutdown);
~ChangeListProcessor();
// Applies change lists or full resource lists to |resource_metadata_|.
//
// |is_delta_update| determines the type of input data to process, whether
// it is full resource lists (false) or change lists (true).
//
// Must be run on the same task runner as |resource_metadata_| uses.
FileError Apply(scoped_ptr<google_apis::AboutResource> about_resource,
ScopedVector<ChangeList> change_lists,
bool is_delta_update);
// The set of changed files as a result of change list processing.
const FileChange& changed_files() const { return *changed_files_; }
// Adds or refreshes the child entries from |change_list| to the directory.
static FileError RefreshDirectory(
ResourceMetadata* resource_metadata,
const DirectoryFetchInfo& directory_fetch_info,
scoped_ptr<ChangeList> change_list,
std::vector<ResourceEntry>* out_refreshed_entries);
// Sets |entry|'s parent_local_id.
static FileError SetParentLocalIdOfEntry(
ResourceMetadata* resource_metadata,
ResourceEntry* entry,
const std::string& parent_resource_id);
private:
typedef std::map<std::string /* resource_id */, ResourceEntry>
ResourceEntryMap;
typedef std::map<std::string /* resource_id */,
std::string /* parent_resource_id*/> ParentResourceIdMap;
// Applies the pre-processed metadata from entry_map_ onto the resource
// metadata. |about_resource| must not be null.
FileError ApplyEntryMap(
int64_t changestamp,
scoped_ptr<google_apis::AboutResource> about_resource);
// Apply |entry| to resource_metadata_.
FileError ApplyEntry(const ResourceEntry& entry);
// Adds the directories changed by the update on |entry| to |changed_dirs_|.
void UpdateChangedDirs(const ResourceEntry& entry);
ResourceMetadata* resource_metadata_; // Not owned.
base::CancellationFlag* in_shutdown_; // Not owned.
ResourceEntryMap entry_map_;
ParentResourceIdMap parent_resource_id_map_;
scoped_ptr<FileChange> changed_files_;
DISALLOW_COPY_AND_ASSIGN(ChangeListProcessor);
};
} // namespace internal
} // namespace drive
#endif // COMPONENTS_DRIVE_CHANGE_LIST_PROCESSOR_H_
|
