sync: Implement per-type commit interface

sync/engine/commit.h

 // 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 SYNC_ENGINE_COMMIT_H_
 #define SYNC_ENGINE_COMMIT_H_
 
+#include <map>
+
+#include "base/stl_util.h"
+#include "sync/base/sync_export.h"
+#include "sync/engine/sync_directory_commit_contributor.h"
 #include "sync/internal_api/public/base/model_type.h"
+#include "sync/internal_api/public/engine/model_safe_worker.h"
 #include "sync/internal_api/public/util/syncer_error.h"
+#include "sync/protocol/sync.pb.h"
+#include "sync/util/extensions_activity.h"
+
+namespace sync_pb {
+class ClientToServerMessage;
+class ClientToServerResponse;
+}
 
 namespace syncer {
 
 namespace sessions {
+class StatusController;
 class SyncSession;
 }
 
+class SyncDirectoryCommitContribution;
+class SyncDirectoryCommitContributor;
 class Syncer;
 
 // This function will commit batches of unsynced items to the server until the
 // number of unsynced and ready to commit items reaches zero or an error is
 // encountered.  A request to exit early will be treated as an error and will
 // abort any blocking operations.
 //
 // The Syncer parameter is provided only for access to its ExitRequested()
 // method.  This is technically unnecessary since an early exit request should
 // be detected as we attempt to contact the sync server.
 //
 // The SyncSession parameter contains pointers to various bits of state,
 // including the syncable::Directory that contains all sync items and the
 // ServerConnectionManager used to contact the server.
 SyncerError BuildAndPostCommits(
     ModelTypeSet request_types,
     Syncer* syncer,
     sessions::SyncSession* session);
 
+// This class wraps the actions related to building and executing a single
+// commit operation.
+//
+// This class' most important responsibility is to manage the ContributionsMap.
+// This class serves as a container for those objects.  Although it would have
+// been acceptable to let this class be a dumb container object, it turns out
+// that there was no other convenient place to put the Init() and
+// PostAndProcessCommitResponse() functions.  So they ended up here.
+class SYNC_EXPORT_PRIVATE Commit {
+ public:
+  static Commit* Init(
+      ModelTypeSet requested_types,
+      CommitContributorMap* contributor_map,
+      size_t max_entries,
+      const std::string& account_name,
+      const std::string& cache_guid,
+      ExtensionsActivity* extensions_activity);
+
+  explicit Commit(
+      std::map<ModelType, SyncDirectoryCommitContribution*> contributions,
+      sync_pb::ClientToServerMessage message,
+      ExtensionsActivity::Records extensions_activity_buffer);
+  ~Commit();
+
+  SyncerError PostAndProcessResponse(
+      sessions::SyncSession* session,
+      sessions::StatusController* status,
+      ExtensionsActivity* extensions_activity);
+
+ private:
+  typedef std::map<ModelType, SyncDirectoryCommitContribution*> ContributionMap;
+
+  ContributionMap contributions_;
+  STLValueDeleter<ContributionMap> deleter_;
+
+  sync_pb::ClientToServerMessage message_;
+  sync_pb::ClientToServerResponse response_;
+  ExtensionsActivity::Records extensions_activity_buffer_;
+};
+
 }  // namespace syncer
 
 #endif  // SYNC_ENGINE_COMMIT_H_