Implement Invalidator::Acknowledge

sync/tools/sync_listen_notifications.cc

 // 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.
 
 #include <cstddef>
 #include <cstdio>
 #include <string>
 
 #include "base/at_exit.h"
 #include "base/base64.h"
+#include "base/bind.h"
+#include "base/callback.h"
 #include "base/command_line.h"
 #include "base/compiler_specific.h"
+#include "base/location.h"
 #include "base/logging.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/memory/weak_ptr.h"
 #include "base/message_loop.h"
 #include "base/threading/thread.h"
 #include "jingle/notifier/base/notification_method.h"
 #include "jingle/notifier/base/notifier_options.h"
 #include "net/base/host_port_pair.h"
 #include "net/base/host_resolver.h"
@@ skipping 18 matching lines @@
 namespace syncer {
 namespace {
 
 const char kEmailSwitch[] = "email";
 const char kTokenSwitch[] = "token";
 const char kHostPortSwitch[] = "host-port";
 const char kTrySslTcpFirstSwitch[] = "try-ssltcp-first";
 const char kAllowInsecureConnectionSwitch[] = "allow-insecure-connection";
 const char kNotificationMethodSwitch[] = "notification-method";
 
+void GenerateAckHandlesReplyHelper(

[akalin, 2012/10/19 13:27:16]

bind callback / ackhandles directly

[dcheng, 2012/10/19 19:38:11]

Done.

+    base::Callback<void(const AckHandleMap&)> callback,
+    const AckHandleMap& ack_handles) {
+  callback.Run(ack_handles);
+}
+
 // Class to print received notifications events.
 class NotificationPrinter : public InvalidationHandler {
  public:
   NotificationPrinter() {}
   virtual ~NotificationPrinter() {}
 
   virtual void OnInvalidatorStateChange(InvalidatorState state) OVERRIDE {
     LOG(INFO) << "Invalidator state changed to "
               << InvalidatorStateToString(state);
   }
@@ skipping 17 matching lines @@
   DISALLOW_COPY_AND_ASSIGN(NotificationPrinter);
 };
 
 class NullInvalidationStateTracker
     : public base::SupportsWeakPtr<NullInvalidationStateTracker>,
       public InvalidationStateTracker {
  public:
   NullInvalidationStateTracker() {}
   virtual ~NullInvalidationStateTracker() {}
 
-  virtual InvalidationVersionMap GetAllMaxVersions() const OVERRIDE {
-    return InvalidationVersionMap();
+  virtual InvalidationStateMap GetStateMap() const OVERRIDE {
+    return InvalidationStateMap();
   }
 
   virtual void SetMaxVersion(
       const invalidation::ObjectId& id,
       int64 max_invalidation_version) OVERRIDE {
     LOG(INFO) << "Setting max invalidation version for "
               << ObjectIdToString(id) << " to " << max_invalidation_version;
   }
 
   virtual void Forget(const ObjectIdSet& ids) OVERRIDE {
     for (ObjectIdSet::const_iterator it = ids.begin(); it != ids.end(); ++it) {
       LOG(INFO) << "Forgetting saved state for " << ObjectIdToString(*it);
     }
   }
 
   virtual std::string GetBootstrapData() const OVERRIDE {
     return std::string();
   }
 
   virtual void SetBootstrapData(const std::string& data) OVERRIDE {
     std::string base64_data;
     CHECK(base::Base64Encode(data, &base64_data));
     LOG(INFO) << "Setting bootstrap data to: " << base64_data;
   }
+
+  virtual void GenerateAckHandles(
+      const ObjectIdSet& ids,
+      const scoped_refptr<base::TaskRunner>& task_runner,
+      base::Callback<void(const AckHandleMap&)> callback) OVERRIDE {
+    AckHandleMap ack_handles;
+    for (ObjectIdSet::const_iterator it = ids.begin(); it != ids.end(); ++it) {
+      ack_handles.insert(std::make_pair(*it, AckHandle::InvalidAckHandle()));
+    }
+    task_runner->PostTask(FROM_HERE,
+                          base::Bind(&GenerateAckHandlesReplyHelper,
+                                     callback, ack_handles));
+  }
+
+  virtual void Acknowledge(const invalidation::ObjectId& id,
+                           const AckHandle& ack_handle) OVERRIDE {
+    LOG(INFO) << "Received ack for " << ObjectIdToString(id);
+  }
 };
 
 // Needed to use a real host resolver.
 class MyTestURLRequestContext : public TestURLRequestContext {
  public:
   MyTestURLRequestContext() : TestURLRequestContext(true) {
     context_storage_.set_host_resolver(
         net::CreateSystemHostResolver(
             net::HostResolver::kDefaultParallelism,
             net::HostResolver::kDefaultRetryAttempts,
@@ skipping 133 matching lines @@
   io_thread.Stop();
   return 0;
 }
 
 }  // namespace
 }  // namespace syncer
 
 int main(int argc, char* argv[]) {
   return syncer::SyncListenNotificationsMain(argc, argv);
 }