chrome/browser/sync_file_system/drive_backend/conflict_resolver.h

   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_CONFLICT_RESOLVER_H_
   6 #define CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_CONFLICT_RESOLVER_H_
   7
   8 #include <string>
   9 #include <utility>
  10 #include <vector>
  11
  12 #include "base/memory/scoped_ptr.h"
  13 #include "base/memory/weak_ptr.h"
  14 #include "chrome/browser/sync_file_system/drive_backend/sync_task.h"
  15 #include "chrome/browser/sync_file_system/sync_callbacks.h"
  16 #include "google_apis/drive/drive_api_error_codes.h"
  17
  18 namespace drive {
  19 class DriveServiceInterface;
  20 }
  21
  22 namespace google_apis {
  23 class FileResource;
  24 }
  25
  26 namespace sync_file_system {
  27 namespace drive_backend {
  28
  29 class MetadataDatabase;
  30 class SyncEngineContext;
  31 class TrackerIDSet;
  32
  33 // Resolves server side file confliction.
  34 // If a remote file has an active tracker and multiple managed parents,
  35 // ConflictResolver detaches the file from all parents other than the parent
  36 // of the active tracker.
  37 // If multiple trackers have the same local path or the same remote file,
  38 // ConflictResolver picks up one of them and delete others.
  39 class ConflictResolver : public SyncTask {
  40  public:
  41   typedef std::vector<std::string> FileIDList;
  42
  43   explicit ConflictResolver(SyncEngineContext* sync_context);
  44   ~ConflictResolver() override;
  45   void RunPreflight(scoped_ptr<SyncTaskToken> token) override;
  46   void RunExclusive(scoped_ptr<SyncTaskToken> token);
  47
  48  private:
  49   typedef std::pair<std::string, std::string> FileIDAndETag;
  50
  51   void DetachFromNonPrimaryParents(scoped_ptr<SyncTaskToken> token);
  52   void DidDetachFromParent(scoped_ptr<SyncTaskToken> token,
  53                            google_apis::DriveApiErrorCode error);
  54
  55   std::string PickPrimaryFile(const TrackerIDSet& trackers);
  56   void RemoveNonPrimaryFiles(scoped_ptr<SyncTaskToken> token);
  57   void DidRemoveFile(scoped_ptr<SyncTaskToken> token,
  58                      const std::string& file_id,
  59                      google_apis::DriveApiErrorCode error);
  60
  61   void UpdateFileMetadata(const std::string& file_id,
  62                           scoped_ptr<SyncTaskToken> token);
  63   void DidGetRemoteMetadata(const std::string& file_id,
  64                             scoped_ptr<SyncTaskToken> token,
  65                             google_apis::DriveApiErrorCode error,
  66                             scoped_ptr<google_apis::FileResource> entry);
  67
  68   std::string target_file_id_;
  69   std::vector<std::string> parents_to_remove_;
  70
  71   std::vector<FileIDAndETag> non_primary_file_ids_;
  72   FileIDList deleted_file_ids_;
  73
  74   bool IsContextReady();
  75   drive::DriveServiceInterface* drive_service();
  76   MetadataDatabase* metadata_database();
  77
  78   SyncEngineContext* sync_context_;  // Not owned.
  79
  80   base::WeakPtrFactory<ConflictResolver> weak_ptr_factory_;
  81
  82   DISALLOW_COPY_AND_ASSIGN(ConflictResolver);
  83 };
  84
  85 }  // namespace drive_backend
  86 }  // namespace sync_file_system
  87
  88 #endif  // CHROME_BROWSER_SYNC_FILE_SYSTEM_DRIVE_BACKEND_CONFLICT_RESOLVER_H_