Sending the proto files for review to unblcok the server team

chrome/browser/sync/glue/autofill_model_associator2.h

Index: chrome/browser/sync/glue/autofill_model_associator2.h
diff --git a/chrome/browser/sync/glue/autofill_model_associator2.h b/chrome/browser/sync/glue/autofill_model_associator2.h
new file mode 100755
index 0000000000000000000000000000000000000000..88de24def2e8a548202ca854165db349481836fc
--- /dev/null
+++ b/chrome/browser/sync/glue/autofill_model_associator2.h
@@ -0,0 +1,211 @@
+// Copyright (c) 2010 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_SYNC_GLUE_AUTOFILL_MODEL_ASSOCIATOR2_H_
+#define CHROME_BROWSER_SYNC_GLUE_AUTOFILL_MODEL_ASSOCIATOR2_H_
+#pragma once
+
+#include <map>
+#include <set>
+#include <string>
+#include <vector>
+
+#include "base/basictypes.h"
+#include "base/lock.h"
+#include "base/ref_counted.h"
+#include "chrome/browser/autofill/personal_data_manager.h"
+#include "chrome/browser/sync/engine/syncapi.h"
+#include "chrome/browser/sync/glue/model_associator.h"
+#include "chrome/browser/sync/protocol/autofill_specifics.pb.h"
+#include "chrome/browser/webdata/autofill_entry.h"
+
+class AutoFillProfile;
+
+class ProfileSyncService;
+class WebDatabase;
+
+namespace sync_api {
+class WriteTransaction;
+}
+
+namespace browser_sync {
+
+class AutofillChangeProcessor;
+class UnrecoverableErrorHandler;
+
+extern const char kAutofillTag[];
+extern const char kAutofillProfileNamespaceTag[];
+extern const char kAutofillEntryNamespaceTag[];
+
+// Contains all model association related logic:
+// * Algorithm to associate autofill model and sync model.
+// We do not check if we have local data before this run; we always
+// merge and sync.
+class AutofillModelAssociator2
+    : public PerDataTypeAssociatorInterface<std::string, std::string> {
+ public:
+  static syncable::ModelType model_type() { return syncable::AUTOFILL; }
+  AutofillModelAssociator2(ProfileSyncService* sync_service,
+                          WebDatabase* web_database,
+                          PersonalDataManager* data_manager);
+  virtual ~AutofillModelAssociator2();
+
+  // A task used by this class and the change processor to inform the
+  // PersonalDataManager living on the UI thread that it needs to refresh.
+  class DoOptimisticRefreshTask : public Task {
+   public:
+    explicit DoOptimisticRefreshTask(PersonalDataManager* pdm);
+    virtual ~DoOptimisticRefreshTask();
+    virtual void Run();
+   private:
+    scoped_refptr<PersonalDataManager> pdm_;
+  };
+
+  // PerDataTypeAssociatorInterface implementation.
+  //
+  // Iterates through the sync model looking for matched pairs of items.
+  virtual bool AssociateModels();
+
+  // Clears all associations.
+  virtual bool DisassociateModels();
+
+  // The has_nodes out param is true if the sync model has nodes other
+  // than the permanent tagged nodes.
+  virtual bool SyncModelHasUserCreatedNodes(bool* has_nodes);
+
+  // See ModelAssociator interface.
+  virtual void AbortAssociation();
+
+  // Not implemented.
+  virtual const std::string* GetChromeNodeFromSyncId(int64 sync_id);
+
+  // Not implemented.
+  virtual bool InitSyncNodeFromChromeId(std::string node_id,
+                                        sync_api::BaseNode* sync_node);
+
+  // Returns the sync id for the given autofill name, or sync_api::kInvalidId
+  // if the autofill name is not associated to any sync id.
+  virtual int64 GetSyncIdFromChromeId(std::string node_id);
+
+  // Associates the given autofill name with the given sync id.
+  virtual void Associate(const std::string* node, int64 sync_id);
+
+  // Remove the association that corresponds to the given sync id.
+  virtual void Disassociate(int64 sync_id);
+
+  // Returns whether a node with the given permanent tag was found and update
+  // |sync_id| with that node's id.
+  virtual bool GetSyncIdForTaggedNode(const std::string& tag, int64* sync_id);
+
+  static std::string KeyToTag(const string16& name, const string16& value);
+  static std::string ProfileLabelToTag(const string16& label);
+
+  static bool MergeTimestamps(const sync_pb::AutofillSpecifics& autofill,
+                              const std::vector<base::Time>& timestamps,
+                              std::vector<base::Time>* new_timestamps);
+  static bool OverwriteProfileWithServerData(
+      AutoFillProfile* merge_into,
+      const sync_pb::AutofillProfileSpecifics& specifics);
+
+  // TODO(georgey) : add the same processing for CC info (already in protocol
+  // buffers).
+
+  // Returns sync service instance.
+  ProfileSyncService* sync_service() { return sync_service_; }
+
+  // Compute and apply suffix to a label so that the resulting label is
+  // unique in the sync database.
+  // |new_non_unique_label| is the colliding label which is to be uniquified.
+  // |existing_unique_label| is the current label of the object, if any; this
+  // is treated as a unique label even if colliding.  If no such label is
+  // available, |existing_unique_label| may be empty.
+  static string16 MakeUniqueLabel(const string16& new_non_unique_label,
+                                  const string16& existing_unique_label,
+                                  sync_api::BaseTransaction* trans);
+
+ private:
+  typedef std::map<std::string, int64> AutofillToSyncIdMap;
+  typedef std::map<int64, std::string> SyncIdToAutofillMap;
+
+  // A convenience wrapper of a bunch of state we pass around while associating
+  // models, and send to the WebDatabase for persistence.
+  struct DataBundle;
+
+  // Helper to query WebDatabase for the current autofill state.
+  bool LoadAutofillData(std::vector<AutofillEntry>* entries,
+                        std::vector<AutoFillProfile*>* profiles);
+
+  // We split up model association first by autofill sub-type (entries, and
+  // profiles.  There is a Traverse* method for each of these.
+  bool TraverseAndAssociateChromeAutofillEntries(
+      sync_api::WriteTransaction* write_trans,
+      const sync_api::ReadNode& autofill_root,
+      const std::vector<AutofillEntry>& all_entries_from_db,
+      std::set<AutofillKey>* current_entries,
+      std::vector<AutofillEntry>* new_entries);
+  bool TraverseAndAssociateChromeAutoFillProfiles(
+      sync_api::WriteTransaction* write_trans,
+      const sync_api::ReadNode& autofill_root,
+      const std::vector<AutoFillProfile*>& all_profiles_from_db,
+      std::set<string16>* current_profiles,
+      std::vector<AutoFillProfile*>* updated_profiles);
+
+  // Once the above traversals are complete, we traverse the sync model to
+  // associate all remaining nodes.
+  bool TraverseAndAssociateAllSyncNodes(
+      sync_api::WriteTransaction* write_trans,
+      const sync_api::ReadNode& autofill_root,
+      DataBundle* bundle);
+
+  // Helper to persist any changes that occured during model association to
+  // the WebDatabase.
+  bool SaveChangesToWebData(const DataBundle& bundle);
+
+  // Helper to insert an AutofillEntry into the WebDatabase (e.g. in response
+  // to encountering a sync node that doesn't exist yet locally).
+  void AddNativeEntryIfNeeded(const sync_pb::AutofillSpecifics& autofill,
+                              DataBundle* bundle,
+                              const sync_api::ReadNode& node);
+
+  // Helper to insert an AutoFillProfile into the WebDatabase (e.g. in response
+  // to encountering a sync node that doesn't exist yet locally).
+  void AddNativeProfileIfNeeded(
+      const sync_pb::AutofillProfileSpecifics& profile,
+      DataBundle* bundle,
+      const sync_api::ReadNode& node);
+
+  // Helper to insert a sync node for the given AutoFillProfile (e.g. in
+  // response to encountering a native profile that doesn't exist yet in the
+  // cloud).
+  bool MakeNewAutofillProfileSyncNode(
+      sync_api::WriteTransaction* trans,
+      const sync_api::BaseNode& autofill_root,
+      const std::string& tag,
+      const AutoFillProfile& profile,
+      int64* sync_id);
+
+  // Called at various points in model association to determine if the
+  // user requested an abort.
+  bool IsAbortPending();
+
+  ProfileSyncService* sync_service_;
+  WebDatabase* web_database_;
+  PersonalDataManager* personal_data_;
+  int64 autofill_node_id_;
+
+  AutofillToSyncIdMap id_map_;
+  SyncIdToAutofillMap id_map_inverse_;
+
+  // Abort association pending flag and lock.  If this is set to true
+  // (via the AbortAssociation method), return from the
+  // AssociateModels method as soon as possible.
+  Lock abort_association_pending_lock_;
+  bool abort_association_pending_;
+
+  DISALLOW_COPY_AND_ASSIGN(AutofillModelAssociator2);
+};
+
+}  // namespace browser_sync
+
+#endif  // CHROME_BROWSER_SYNC_GLUE_AUTOFILL_MODEL_ASSOCIATOR_H_