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
|
// 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 CHROME_BROWSER_CHROMEOS_DRIVE_DRIVE_FEED_PROCESSOR_H_
#define CHROME_BROWSER_CHROMEOS_DRIVE_DRIVE_FEED_PROCESSOR_H_
#include <map>
#include <set>
#include <string>
#include <vector>
#include "base/callback.h"
#include "base/file_path.h"
#include "base/memory/weak_ptr.h"
#include "chrome/browser/chromeos/drive/drive_file_error.h"
#include "chrome/browser/google_apis/gdata_errorcode.h"
#include "chrome/browser/google_apis/gdata_wapi_parser.h"
namespace drive {
class DriveDirectory;
class DriveEntry;
class DriveResourceMetadata;
// DriveFeedProcessor is used to process feeds from WAPI (codename for
// Documents List API).
class DriveFeedProcessor {
public:
typedef std::map<std::string /* resource_id */, DriveEntryProto>
DriveEntryProtoMap;
// Class used to record UMA stats with FeedToEntryProtoMap().
class FeedToEntryProtoMapUMAStats;
explicit DriveFeedProcessor(DriveResourceMetadata* resource_metadata);
~DriveFeedProcessor();
// Applies the documents feeds to the file system using |resource_metadata_|.
//
// |is_delta_feed| determines the type of feed to process, whether it is a
// root feed (false) or a delta feed (true).
//
// In the case of processing the root feeds |root_feed_changestamp| is used
// as its initial changestamp value. The value comes from
// google_apis::AccountMetadataFeed.
// |on_complete_callback| is run after the feed is applied.
// |on_complete_callback| must not be null.
// TODO(achuith): Change the type of on_complete_callback to
// FileOperationCallback instead.
void ApplyFeeds(
const ScopedVector<google_apis::DocumentFeed>& feed_list,
bool is_delta_feed,
int64 root_feed_changestamp,
const base::Closure& on_complete_callback);
// Converts list of document feeds from collected feeds into a
// DriveEntryProtoMap. |feed_changestamp| and/or |uma_stats| may be NULL.
// entry_proto_map_ and root_upload_url_ are updated as side effects.
void FeedToEntryProtoMap(
const ScopedVector<google_apis::DocumentFeed>& feed_list,
int64* feed_changestamp,
FeedToEntryProtoMapUMAStats* uma_stats);
// A map of DriveEntryProto's representing a feed.
const DriveEntryProtoMap& entry_proto_map() const { return entry_proto_map_; }
// The set of changed directories as a result of feed processing.
const std::set<FilePath>& changed_dirs() const { return changed_dirs_; }
private:
// Applies the pre-processed feed from entry_proto_map_ onto the filesystem.
void ApplyEntryProtoMap(bool is_delta_feed);
// Apply the next item from entry_proto_map_ to the file system. The async
// version posts to the message loop to avoid recursive stack-overflow.
void ApplyNextEntryProto();
void ApplyNextEntryProtoAsync();
// Apply |entry_proto| to resource_metadata_.
void ApplyEntryProto(const DriveEntryProto& entry_proto);
// Continue ApplyEntryProto. This is a callback for
// DriveResourceMetadata::GetEntryInfoByResourceId.
void ContinueApplyEntryProto(
const DriveEntryProto& entry_proto,
DriveFileError error,
const FilePath& file_path,
scoped_ptr<DriveEntryProto> old_entry_proto);
// Apply the DriveEntryProto pointed to by |it| to resource_metadata_.
void ApplyNextByIterator(DriveEntryProtoMap::iterator it);
// Helper function to add |entry_proto| to its parent. Updates changed_dirs_
// as a side effect.
void AddEntryToParent(const DriveEntryProto& entry_proto);
// Callback for DriveResourceMetadata::AddEntryToParent.
void NotifyForAddEntryToParent(bool is_directory,
DriveFileError error,
const FilePath& file_path);
// Removes entry pointed to by |resource_id| from its parent. Updates
// changed_dirs_ as a side effect.
void RemoveEntryFromParent(
const DriveEntryProto& entry_proto,
const FilePath& file_path);
// Continues RemoveEntryFromParent after
// DriveResourceMetadata::GetChildDirectories.
void OnGetChildrenForRemove(
const DriveEntryProto& entry_proto,
const FilePath& file_path,
const std::set<FilePath>& child_directories);
// Callback for DriveResourceMetadata::RemoveEntryFromParent.
void NotifyForRemoveEntryFromParent(
bool is_directory,
const FilePath& file_path,
const std::set<FilePath>& child_directories,
DriveFileError error,
const FilePath& parent_path);
// Refreshes DriveResourceMetadata entry that has the same resource_id as
// |entry_proto| with |entry_proto|. Updates changed_dirs_ as a side effect.
void RefreshEntryProto(const DriveEntryProto& entry_proto,
const FilePath& file_path);
// Callback for DriveResourceMetadata::RefreshEntryProto.
void NotifyForRefreshEntryProto(
const FilePath& old_file_path,
DriveFileError error,
const FilePath& file_path,
scoped_ptr<DriveEntryProto> entry_proto);
// Updates the upload url of the root directory with root_upload_url_.
void UpdateRootUploadUrl();
// Callback for DriveResourceMetadata::GetEntryInfoByPath for the root proto.
// Updates root upload url in the root proto, and refreshes the proto.
void OnGetRootEntryProto(DriveFileError error,
scoped_ptr<DriveEntryProto> root_proto);
// Callback for DriveResourceMetadata::RefreshEntryProto after the root upload
// url is set.
void OnUpdateRootUploadUrl(DriveFileError error,
const FilePath& root_path,
scoped_ptr<DriveEntryProto> root_proto);
// Runs after all entries have been processed.
void OnComplete();
// Reset the state of this object.
void Clear();
DriveResourceMetadata* resource_metadata_; // Not owned.
DriveEntryProtoMap entry_proto_map_;
std::set<FilePath> changed_dirs_;
GURL root_upload_url_;
int64 largest_changestamp_;
base::Closure on_complete_callback_;
// Note: This should remain the last member so it'll be destroyed and
// invalidate its weak pointers before any other members are destroyed.
base::WeakPtrFactory<DriveFeedProcessor> weak_ptr_factory_;
DISALLOW_COPY_AND_ASSIGN(DriveFeedProcessor);
};
} // namespace drive
#endif // CHROME_BROWSER_CHROMEOS_DRIVE_DRIVE_FEED_PROCESSOR_H_
|
