Add Store+Sync to reading list.

ios/chrome/browser/reading_list/reading_list_entry_unittest.cc

Index: ios/chrome/browser/reading_list/reading_list_entry_unittest.cc
diff --git a/ios/chrome/browser/reading_list/reading_list_entry_unittest.cc b/ios/chrome/browser/reading_list/reading_list_entry_unittest.cc
index 73b48bcdda2b1cf03558aa81f614d54ea12da6b3..ee450b8aa8caa094645bdb5fed2b89b8e1b46124 100644
--- a/ios/chrome/browser/reading_list/reading_list_entry_unittest.cc
+++ b/ios/chrome/browser/reading_list/reading_list_entry_unittest.cc
@@ -6,6 +6,8 @@
 
 #include "base/memory/ptr_util.h"
 #include "base/test/simple_test_tick_clock.h"
+#include "components/sync/protocol/reading_list_specifics.pb.h"
+#include "ios/chrome/browser/reading_list/proto/reading_list.pb.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 namespace {
@@ -182,3 +184,144 @@ TEST(ReadingListEntry, FailedDownloadCounter) {
   e.SetDistilledState(ReadingListEntry::ERROR);
   EXPECT_EQ(2, e.FailedDownloadCounter());
 }
+
+// Tests that the reading list entry is correctly encoded to
+// sync_pb::ReadingListSpecifics.
+TEST(ReadingListEntry, AsReadingListSpecifics) {
+  ReadingListEntry entry(GURL("http://example.com/"), "bar");
+  int64_t creation_time_us = entry.UpdateTime();
+
+  std::unique_ptr<sync_pb::ReadingListSpecifics> pb_entry(
+      entry.AsReadingListSpecifics(false));
+  EXPECT_EQ(pb_entry->entry_id(), "http://example.com/");
+  EXPECT_EQ(pb_entry->url(), "http://example.com/");
+  EXPECT_EQ(pb_entry->title(), "bar");
+  EXPECT_EQ(pb_entry->creation_time_us(), creation_time_us);
+  EXPECT_EQ(pb_entry->update_time_us(), entry.UpdateTime());
+  EXPECT_EQ(pb_entry->status(), sync_pb::ReadingListSpecifics::UNREAD);
+
+  entry.MarkEntryUpdated();
+  EXPECT_NE(entry.UpdateTime(), creation_time_us);
+  std::unique_ptr<sync_pb::ReadingListSpecifics> updated_pb_entry(
+      entry.AsReadingListSpecifics(true));
+  EXPECT_EQ(updated_pb_entry->creation_time_us(), creation_time_us);
+  EXPECT_EQ(updated_pb_entry->update_time_us(), entry.UpdateTime());
+  EXPECT_EQ(updated_pb_entry->status(), sync_pb::ReadingListSpecifics::READ);
+}
+
+// Tests that the reading list entry is correctly parsed from
+// sync_pb::ReadingListSpecifics.
+TEST(ReadingListEntry, FromReadingListSpecifics) {
+  std::unique_ptr<sync_pb::ReadingListSpecifics> pb_entry =
+      base::MakeUnique<sync_pb::ReadingListSpecifics>();
+  pb_entry->set_entry_id("http://example.com/");
+  pb_entry->set_url("http://example.com/");
+  pb_entry->set_title("title");
+  pb_entry->set_creation_time_us(1);
+  pb_entry->set_update_time_us(2);
+  pb_entry->set_status(sync_pb::ReadingListSpecifics::UNREAD);
+
+  std::unique_ptr<ReadingListEntry> entry(
+      ReadingListEntry::FromReadingListSpecifics(*pb_entry));
+  EXPECT_EQ(entry->URL().spec(), "http://example.com/");
+  EXPECT_EQ(entry->Title(), "title");
+  EXPECT_EQ(entry->UpdateTime(), 2);
+  EXPECT_EQ(entry->FailedDownloadCounter(), 0);
+}
+
+// Tests that the reading list entry is correctly encoded to
+// reading_list::ReadingListLocal.
+TEST(ReadingListEntry, AsReadingListLocal) {
+  ReadingListEntry entry(GURL("http://example.com/"), "bar");
+  int64_t creation_time_us = entry.UpdateTime();
+
+  std::unique_ptr<reading_list::ReadingListLocal> pb_entry(
+      entry.AsReadingListLocal(false));
+  EXPECT_EQ(pb_entry->entry_id(), "http://example.com/");
+  EXPECT_EQ(pb_entry->url(), "http://example.com/");
+  EXPECT_EQ(pb_entry->title(), "bar");
+  EXPECT_EQ(pb_entry->creation_time_us(), creation_time_us);
+  EXPECT_EQ(pb_entry->update_time_us(), entry.UpdateTime());
+  EXPECT_EQ(pb_entry->status(), reading_list::ReadingListLocal::UNREAD);
+  EXPECT_EQ(pb_entry->distillation_state(),
+            reading_list::ReadingListLocal::WAITING);
+  EXPECT_EQ(pb_entry->distilled_url(), "");
+  EXPECT_EQ(pb_entry->failed_download_counter(), 0);
+  EXPECT_NE(pb_entry->backoff(), "");
+
+  entry.SetDistilledState(ReadingListEntry::WILL_RETRY);
+  std::unique_ptr<reading_list::ReadingListLocal> will_retry_pb_entry(
+      entry.AsReadingListLocal(true));
+  EXPECT_EQ(will_retry_pb_entry->distillation_state(),
+            reading_list::ReadingListLocal::WILL_RETRY);
+  EXPECT_EQ(will_retry_pb_entry->failed_download_counter(), 1);
+
+  entry.SetDistilledURL(GURL("http://distilled.foo/"));
+  entry.MarkEntryUpdated();
+  EXPECT_NE(entry.UpdateTime(), creation_time_us);
+  std::unique_ptr<reading_list::ReadingListLocal> distilled_pb_entry(
+      entry.AsReadingListLocal(true));
+  EXPECT_EQ(distilled_pb_entry->creation_time_us(), creation_time_us);
+  EXPECT_EQ(distilled_pb_entry->update_time_us(), entry.UpdateTime());
+  EXPECT_NE(distilled_pb_entry->backoff(), "");
+  EXPECT_EQ(distilled_pb_entry->status(), reading_list::ReadingListLocal::READ);
+  EXPECT_EQ(distilled_pb_entry->distillation_state(),
+            reading_list::ReadingListLocal::PROCESSED);
+  EXPECT_EQ(distilled_pb_entry->distilled_url(), "http://distilled.foo/");
+  EXPECT_EQ(distilled_pb_entry->failed_download_counter(), 0);
+}
+
+// Tests that the reading list entry is correctly parsed from
+// sync_pb::ReadingListLocal.
+TEST(ReadingListEntry, FromReadingListLocal) {
+  ReadingListEntry entry(GURL("http://example.com/"), "title");
+  base::Time next_call = base::Time::Now() + entry.TimeUntilNextTry();
+
+  std::unique_ptr<reading_list::ReadingListLocal> pb_entry(
+      entry.AsReadingListLocal(false));
+
+  pb_entry->set_entry_id("http://example.com/");
+  pb_entry->set_url("http://example.com/");
+  pb_entry->set_title("title");
+  pb_entry->set_creation_time_us(1);
+  pb_entry->set_update_time_us(2);
+  pb_entry->set_status(reading_list::ReadingListLocal::UNREAD);
+  pb_entry->set_distillation_state(reading_list::ReadingListLocal::WAITING);
+  pb_entry->set_failed_download_counter(2);
+
+  std::unique_ptr<ReadingListEntry> waiting_entry(
+      ReadingListEntry::FromReadingListLocal(*pb_entry));
+  EXPECT_EQ(waiting_entry->URL().spec(), "http://example.com/");
+  EXPECT_EQ(waiting_entry->Title(), "title");
+  EXPECT_EQ(waiting_entry->UpdateTime(), 2);
+  EXPECT_EQ(waiting_entry->FailedDownloadCounter(), 2);
+  EXPECT_EQ(waiting_entry->DistilledState(), ReadingListEntry::WAITING);
+  EXPECT_EQ(waiting_entry->DistilledURL(), GURL());
+  base::Time waiting_next_call =
+      base::Time::Now() + waiting_entry->TimeUntilNextTry();
+  base::TimeDelta delta = next_call - waiting_next_call;
+  EXPECT_NEAR(delta.InMillisecondsRoundedUp(), 0, 10);
+}
+
+// Tests that the merging of two ReadingListEntry.
+TEST(ReadingListEntry, MergeLocalStateFrom) {
+  ReadingListEntry local_entry(GURL("http://example.com/"), "title");
+  base::Time next_call = base::Time::Now() + local_entry.TimeUntilNextTry();
+  int64_t local_update_time_us = local_entry.UpdateTime();
+  local_entry.SetDistilledURL(GURL("http://distilled.com/"));
+
+  ReadingListEntry sync_entry(GURL("http://example2.com/"), "title2");
+  sync_entry.SetDistilledState(ReadingListEntry::ERROR);
+  int64_t sync_update_time_us = sync_entry.UpdateTime();
+  EXPECT_NE(local_update_time_us, sync_update_time_us);
+  sync_entry.MergeLocalStateFrom(local_entry);
+  EXPECT_EQ(sync_entry.URL().spec(), "http://example2.com/");
+  EXPECT_EQ(sync_entry.Title(), "title2");
+  EXPECT_EQ(sync_entry.UpdateTime(), sync_update_time_us);
+  EXPECT_EQ(sync_entry.FailedDownloadCounter(), 0);
+  EXPECT_EQ(sync_entry.DistilledState(), ReadingListEntry::PROCESSED);
+  EXPECT_EQ(sync_entry.DistilledURL().spec(), "http://distilled.com/");
+  base::Time sync_next_call = base::Time::Now() + sync_entry.TimeUntilNextTry();
+  base::TimeDelta delta = next_call - sync_next_call;
+  EXPECT_NEAR(delta.InMillisecondsRoundedUp(), 0, 10);
+}