[invalidations] Added table with registered objectsIds

chrome/browser/invalidation/invalidation_logger.cc

 // Copyright 2014 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 "chrome/browser/invalidation/invalidation_logger.h"
 
 #include "base/memory/scoped_ptr.h"
 #include "base/values.h"
 #include "chrome/browser/invalidation/invalidation_logger_observer.h"
+#include "sync/notifier/invalidation_handler.h"
 
 namespace syncer {
 class ObjectIdInvalidationMap;
 }
 
 namespace invalidation {
 class InvalidationLoggerObserver;
 
 InvalidationLogger::InvalidationLogger()
     : last_invalidator_state_(syncer::TRANSIENT_INVALIDATION_ERROR) {}
@@ skipping 16 matching lines @@
   last_invalidator_state_ = newState;
   EmitState();
 }
 
 void InvalidationLogger::EmitState() {
   FOR_EACH_OBSERVER(InvalidationLoggerObserver,
                     observer_list_,
                     OnStateChange(last_invalidator_state_));
 }
 
-void InvalidationLogger::OnUpdateIds(const base::DictionaryValue& details) {
-  FOR_EACH_OBSERVER(
-      InvalidationLoggerObserver, observer_list_, OnUpdateIds(details));
+void InvalidationLogger::OnUpdateIds(
+    std::map<std::string, syncer::ObjectIdSet> updatedIds) {
+  for (std::map<std::string, syncer::ObjectIdSet>::iterator it =
+           updatedIds.begin();
+       it != updatedIds.end();
+       ++it) {
+    latest_ids_[it->first] = syncer::ObjectIdSet(it->second);
+  }
+  EmitUpdatedIds();
+}
+
+void InvalidationLogger::EmitUpdatedIds() {
+  for (std::map<std::string, syncer::ObjectIdSet>::iterator it =
+           latest_ids_.begin();
+       it != latest_ids_.end();
+       ++it) {
+    FOR_EACH_OBSERVER(InvalidationLoggerObserver,
+                      observer_list_,
+                      OnUpdateIds(it->first, it->second));
+  }
 }
 
 void InvalidationLogger::OnDebugMessage(const base::DictionaryValue& details) {
   FOR_EACH_OBSERVER(
       InvalidationLoggerObserver, observer_list_, OnDebugMessage(details));
 }
 
 void InvalidationLogger::OnInvalidation(
     const syncer::ObjectIdInvalidationMap& details) {
   FOR_EACH_OBSERVER(
       InvalidationLoggerObserver, observer_list_, OnInvalidation(details));
 }
 
 void InvalidationLogger::EmitContent() {
   // Here we add content to send to the observers not via real time push
   // but on explicit request.
   EmitState();
+  EmitUpdatedIds();
 }
 
 // Obtain a target object to call whenever we have
 // debug messages to display
 void InvalidationLogger::RegisterForDebug(
     InvalidationLoggerObserver* debug_observer) {
   observer_list_.AddObserver(debug_observer);
 }
 
 // Removes the target object to call whenever we have
 // debug messages to display
 void InvalidationLogger::UnregisterForDebug(
     InvalidationLoggerObserver* debug_observer) {
   observer_list_.RemoveObserver(debug_observer);
 }
 }  // namespace invalidation