local_to_remote_syncer.h revision 116680a4aac90f2aa7413d9095a592090648e557 
1// Copyright 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#ifndef CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_LOCAL_TO_REMOTE_SYNCER_H_
6#define CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_LOCAL_TO_REMOTE_SYNCER_H_
7
8#include <string>
9
10#include "base/memory/scoped_ptr.h"
11#include "base/memory/scoped_vector.h"
12#include "base/memory/weak_ptr.h"
13#include "chrome/browser/sync_file_system/drive_backend/sync_task.h"
14#include "chrome/browser/sync_file_system/file_change.h"
15#include "chrome/browser/sync_file_system/sync_action.h"
16#include "chrome/browser/sync_file_system/sync_file_metadata.h"
17#include "google_apis/drive/gdata_errorcode.h"
18
19namespace drive {
20class DriveServiceInterface;
21class DriveUploaderInterface;
22}
23
24namespace google_apis {
25class FileResource;
26class ResourceList;
27}
28
29namespace sync_file_system {
30
31class RemoteChangeProcessor;
32
33namespace drive_backend {
34
35class FileDetails;
36class FileTracker;
37class FolderCreator;
38class MetadataDatabase;
39class SyncEngineContext;
40
41class LocalToRemoteSyncer : public SyncTask {
42 public:
43  typedef base::Callback<void(scoped_ptr<SyncTaskToken>)> Continuation;
44
45  LocalToRemoteSyncer(SyncEngineContext* sync_context,
46                      const SyncFileMetadata& local_metadata,
47                      const FileChange& local_change,
48                      const base::FilePath& local_path,
49                      const fileapi::FileSystemURL& url);
50  virtual ~LocalToRemoteSyncer();
51  virtual void RunPreflight(scoped_ptr<SyncTaskToken> token) OVERRIDE;
52
53  const fileapi::FileSystemURL& url() const { return url_; }
54  const base::FilePath& target_path() const { return target_path_; }
55  SyncAction sync_action() const { return sync_action_; }
56  bool needs_remote_change_listing() const {
57    return needs_remote_change_listing_;
58  }
59
60 private:
61  void MoveToBackground(const Continuation& continuation,
62                        scoped_ptr<SyncTaskToken> token);
63  void ContinueAsBackgroundTask(const Continuation& continuation,
64                                scoped_ptr<SyncTaskToken> token);
65  void SyncCompleted(scoped_ptr<SyncTaskToken> token,
66                     SyncStatusCode status);
67
68  void HandleConflict(scoped_ptr<SyncTaskToken> token);
69  void HandleExistingRemoteFile(scoped_ptr<SyncTaskToken> token);
70
71  void UpdateTrackerForReusedFolder(const FileDetails& details,
72                                    scoped_ptr<SyncTaskToken> token);
73
74  void DeleteRemoteFile(scoped_ptr<SyncTaskToken> token);
75  void DidDeleteRemoteFile(scoped_ptr<SyncTaskToken> token,
76                           google_apis::GDataErrorCode error);
77
78  void UploadExistingFile(scoped_ptr<SyncTaskToken> token);
79  void DidGetMD5ForUpload(scoped_ptr<SyncTaskToken> token,
80                          const std::string& local_file_md5);
81  void DidUploadExistingFile(scoped_ptr<SyncTaskToken> token,
82                             google_apis::GDataErrorCode error,
83                             const GURL&,
84                             scoped_ptr<google_apis::FileResource>);
85  void DidUpdateDatabaseForUploadExistingFile(
86      scoped_ptr<SyncTaskToken> token,
87      SyncStatusCode status);
88  void UpdateRemoteMetadata(const std::string& file_id,
89                            scoped_ptr<SyncTaskToken> token);
90  void DidGetRemoteMetadata(const std::string& file_id,
91                            scoped_ptr<SyncTaskToken> token,
92                            google_apis::GDataErrorCode error,
93                            scoped_ptr<google_apis::FileResource> entry);
94
95  void UploadNewFile(scoped_ptr<SyncTaskToken> token);
96  void DidUploadNewFile(scoped_ptr<SyncTaskToken> token,
97                        google_apis::GDataErrorCode error,
98                        const GURL& upload_location,
99                        scoped_ptr<google_apis::FileResource> entry);
100
101  void CreateRemoteFolder(scoped_ptr<SyncTaskToken> token);
102  void DidCreateRemoteFolder(scoped_ptr<SyncTaskToken> token,
103                             const std::string& file_id,
104                             SyncStatusCode status);
105  void DidDetachResourceForCreationConflict(scoped_ptr<SyncTaskToken> token,
106                                            google_apis::GDataErrorCode error);
107
108  bool IsContextReady();
109  drive::DriveServiceInterface* drive_service();
110  drive::DriveUploaderInterface* drive_uploader();
111  MetadataDatabase* metadata_database();
112
113  SyncEngineContext* sync_context_;  // Not owned.
114
115  FileChange local_change_;
116  bool local_is_missing_;
117  base::FilePath local_path_;
118  fileapi::FileSystemURL url_;
119  SyncAction sync_action_;
120
121  scoped_ptr<FileTracker> remote_file_tracker_;
122  scoped_ptr<FileTracker> remote_parent_folder_tracker_;
123  base::FilePath target_path_;
124  int64 remote_file_change_id_;
125
126  bool retry_on_success_;
127  bool needs_remote_change_listing_;
128
129  scoped_ptr<FolderCreator> folder_creator_;
130
131  base::WeakPtrFactory<LocalToRemoteSyncer> weak_ptr_factory_;
132
133  DISALLOW_COPY_AND_ASSIGN(LocalToRemoteSyncer);
134};
135
136}  // namespace drive_backend
137}  // namespace sync_file_system
138
139#endif  // CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_LOCAL_TO_REMOTE_SYNCER_H_
140