[Sync] Add plumbing of context from client to server

sync/engine/directory_update_handler_unittest.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/engine/directory_update_handler.h"
 
 #include "base/compiler_specific.h"
 #include "base/message_loop/message_loop.h"
 #include "base/stl_util.h"
 #include "sync/engine/syncer_proto_util.h"
@@ skipping 233 matching lines @@
 TEST_F(DirectoryUpdateHandlerProcessUpdateTest, GarbageCollectionByVersion) {
   DirectoryUpdateHandler handler(dir(), SYNCED_NOTIFICATIONS, ui_worker());
   sessions::StatusController status;
 
   sync_pb::DataTypeProgressMarker progress;
   progress.set_data_type_id(
       GetSpecificsFieldNumberFromModelType(SYNCED_NOTIFICATIONS));
   progress.set_token("token");
   progress.mutable_gc_directive()->set_version_watermark(kDefaultVersion + 10);
 
+  sync_pb::DataTypeContext context;
+  context.set_data_type_id(
+      GetSpecificsFieldNumberFromModelType(SYNCED_NOTIFICATIONS));
+  context.set_context("context");
+  context.set_version(1);
+
   scoped_ptr<sync_pb::SyncEntity> type_root =
       CreateUpdate(SyncableIdToProto(syncable::Id::CreateFromServerId("root")),
                    syncable::GetNullId().GetServerId(),
                    SYNCED_NOTIFICATIONS);
   type_root->set_server_defined_unique_tag(
       ModelTypeToRootTag(SYNCED_NOTIFICATIONS));
   type_root->set_folder(true);
 
   scoped_ptr<sync_pb::SyncEntity> e1 =
       CreateUpdate(SyncableIdToProto(syncable::Id::CreateFromServerId("e1")),
                    type_root->id_string(),
                    SYNCED_NOTIFICATIONS);
 
   scoped_ptr<sync_pb::SyncEntity> e2 =
       CreateUpdate(SyncableIdToProto(syncable::Id::CreateFromServerId("e2")),
                    type_root->id_string(),
                    SYNCED_NOTIFICATIONS);
   e2->set_version(kDefaultVersion + 100);
 
   // Add to the applicable updates list.
   SyncEntityList updates;
   updates.push_back(type_root.get());
   updates.push_back(e1.get());
   updates.push_back(e2.get());
 
   // Process and apply updates.
-  handler.ProcessGetUpdatesResponse(progress, updates, &status);
+  handler.ProcessGetUpdatesResponse(progress, context, updates, &status);
   handler.ApplyUpdates(&status);
 
   // Verify none is deleted because they are unapplied during GC.
   EXPECT_TRUE(EntryExists(type_root->id_string()));
   EXPECT_TRUE(EntryExists(e1->id_string()));
   EXPECT_TRUE(EntryExists(e2->id_string()));
 
   // Process and apply again. Old entry is deleted but not root.
   progress.mutable_gc_directive()->set_version_watermark(kDefaultVersion + 20);
-  handler.ProcessGetUpdatesResponse(progress, SyncEntityList(), &status);
+  handler.ProcessGetUpdatesResponse(
+      progress, context, SyncEntityList(), &status);
   handler.ApplyUpdates(&status);
   EXPECT_TRUE(EntryExists(type_root->id_string()));
   EXPECT_FALSE(EntryExists(e1->id_string()));
   EXPECT_TRUE(EntryExists(e2->id_string()));
 }
 
 // A test harness for tests that focus on applying updates.
 //
 // Update application is performed when we want to take updates that were
 // previously downloaded, processed, and stored in our syncable::Directory
@@ skipping 580 matching lines @@
     syncable::Entry e1(&trans, syncable::GET_BY_HANDLE, decryptable_handle);
     syncable::Entry e2(&trans, syncable::GET_BY_HANDLE, undecryptable_handle);
     ASSERT_TRUE(e1.good());
     ASSERT_TRUE(e2.good());
     EXPECT_FALSE(e1.GetIsUnappliedUpdate());
     EXPECT_TRUE(e2.GetIsUnappliedUpdate());
   }
 }
 
 }  // namespace syncer