sync: Implement fake server reflection blocking

sync/test/fake_server/fake_server.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 "sync/test/fake_server/fake_server.h"
 
 #include <algorithm>
 #include <limits>
 #include <string>
 #include <vector>
@@ skipping 209 matching lines @@
 
   sync_pb::ClientToServerResponse response_proto;
   bool success;
   switch (message.message_contents()) {
     case sync_pb::ClientToServerMessage::GET_UPDATES:
       success = HandleGetUpdatesRequest(message.get_updates(),
                                         response_proto.mutable_get_updates());
       break;
     case sync_pb::ClientToServerMessage::COMMIT:
       success = HandleCommitRequest(message.commit(),
+                                    message.invalidator_client_id(),
                                     response_proto.mutable_commit());
       break;
     default:
       callback.Run(net::ERR_NOT_IMPLEMENTED, 0, string());;
       return;
   }
 
   if (!success) {
     // TODO(pvalenzuela): Add logging here so that tests have more info about
     // the failure.
@@ skipping 149 matching lines @@
       return false;
     }
     SaveEntity(tombstone);
   }
 
   return true;
 }
 
 bool FakeServer::HandleCommitRequest(
     const sync_pb::CommitMessage& commit,
+    const std::string& invalidator_client_id,
     sync_pb::CommitResponse* response) {
   std::map<string, string> client_to_server_ids;
   string guid = commit.cache_guid();
   ModelTypeSet committed_model_types;
 
   // TODO(pvalenzuela): Add validation of CommitMessage.entries.
   ::google::protobuf::RepeatedPtrField<sync_pb::SyncEntity>::const_iterator it;
   for (it = commit.entries().begin(); it != commit.entries().end(); ++it) {
     sync_pb::CommitResponse_EntryResponse* entry_response =
         response->add_entryresponse();
@@ skipping 14 matching lines @@
     }
 
     // Record the ID if it was renamed.
     if (entity_id != client_entity.id_string()) {
       client_to_server_ids[client_entity.id_string()] = entity_id;
     }
     FakeServerEntity* entity = entities_[entity_id];
     committed_model_types.Put(entity->GetModelType());
   }
 
-  FOR_EACH_OBSERVER(Observer, observers_, OnCommit(committed_model_types));
+  FOR_EACH_OBSERVER(Observer, observers_,
+                    OnCommit(invalidator_client_id, committed_model_types));
   return true;
 }
 
 scoped_ptr<base::DictionaryValue> FakeServer::GetEntitiesAsDictionaryValue() {
   scoped_ptr<base::DictionaryValue> dictionary(new base::DictionaryValue());
 
   // Initialize an empty ListValue for all ModelTypes.
   ModelTypeSet all_types = ModelTypeSet::All();
   for (ModelTypeSet::Iterator it = all_types.First(); it.Good(); it.Inc()) {
     dictionary->Set(ModelTypeToString(it.Get()), new base::ListValue());
@@ skipping 28 matching lines @@
 
 void FakeServer::AddObserver(Observer* observer) {
   observers_.AddObserver(observer);
 }
 
 void FakeServer::RemoveObserver(Observer* observer) {
   observers_.RemoveObserver(observer);
 }
 
 }  // namespace fake_server