Invoke AttachmentUploader and update AttachmentIds.

components/sync_driver/generic_change_processor_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 "components/sync_driver/generic_change_processor.h"
 
 #include "base/memory/scoped_ptr.h"
 #include "base/memory/weak_ptr.h"
 #include "base/message_loop/message_loop.h"
 #include "base/strings/stringprintf.h"
@@ skipping 12 matching lines @@
 #include "sync/internal_api/public/user_share.h"
 #include "sync/internal_api/public/write_node.h"
 #include "sync/internal_api/public/write_transaction.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 namespace browser_sync {
 
 namespace {
 
 const char kTestData[] = "some data";
+const char kUrl[] = "http://attachment.server/url";
 
 // A mock that keeps track of attachments passed to StoreAttachments.
 class MockAttachmentService : public syncer::FakeAttachmentService {
  public:
   MockAttachmentService();
   virtual ~MockAttachmentService();
   virtual void StoreAttachments(const syncer::AttachmentList& attachments,
                                 const StoreCallback& callback) OVERRIDE;
   std::vector<syncer::AttachmentList>* attachment_lists();
 
@@ skipping 296 matching lines @@
       change_processor()->ProcessSyncChanges(FROM_HERE, change_list).IsSet());
 
   // Check that the AttachmentService received it.
   ASSERT_EQ(mock_attachment_service()->attachment_lists()->size(), 1U);
   const syncer::AttachmentList& new_attachments_added =
       mock_attachment_service()->attachment_lists()->front();
   ASSERT_EQ(new_attachments_added.size(), 1U);
   ASSERT_EQ(new_attachments_added[0].GetId(), new_attachments[0].GetId());
 }
 
+// Verify that after attachment is uploaded GenericChangeProcessor updates
+// corresponding entries
+TEST_F(SyncGenericChangeProcessorTest, AttachmentUploaded) {
+  std::string tag = "client_tag";
+  std::string title = "client_title";
+  sync_pb::EntitySpecifics specifics;
+  sync_pb::PreferenceSpecifics* pref_specifics = specifics.mutable_preference();
+  pref_specifics->set_name("test");
+  syncer::AttachmentList attachments;
+  scoped_refptr<base::RefCountedString> attachment_data =
+      new base::RefCountedString;
+  attachment_data->data() = kTestData;
+  attachments.push_back(syncer::Attachment::Create(attachment_data));
+
+  // Add a SyncData with two attachments.
+  syncer::SyncChangeList change_list;
+  change_list.push_back(
+      syncer::SyncChange(FROM_HERE,
+                         syncer::SyncChange::ACTION_ADD,
+                         syncer::SyncData::CreateLocalDataWithAttachments(
+                             tag, title, specifics, attachments)));
+  ASSERT_FALSE(
+      change_processor()->ProcessSyncChanges(FROM_HERE, change_list).IsSet());
+
+  sync_pb::AttachmentIdProto attachment_id_proto =
+      attachments[0].GetId().GetProto();
+  attachment_id_proto.set_url(kUrl);
+  syncer::AttachmentId attachment_id =
+      syncer::AttachmentId::CreateFromProto(attachment_id_proto);
+
+  change_processor()->OnAttachmentUploaded(attachment_id);
+  syncer::ReadTransaction read_transaction(FROM_HERE, user_share());
+  syncer::ReadNode node(&read_transaction);
+  ASSERT_EQ(node.InitByClientTagLookup(syncer::PREFERENCES, tag),
+            syncer::BaseNode::INIT_OK);
+  syncer::AttachmentIdList attachment_ids = node.GetAttachmentIds();
+  EXPECT_EQ(1U, attachment_ids.size());
+  EXPECT_EQ(kUrl, attachment_ids[0].GetProto().url());
+}
+
 }  // namespace
 
 }  // namespace browser_sync