Helium: Initial proto and Syncable interface definition

blimp/net/helium/syncable_unittest.cc

+// Copyright 2016 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 "blimp/net/helium/syncable.h"
+
+#include "base/bind.h"
+#include "base/macros.h"
+#include "base/memory/ptr_util.h"
+#include "testing/gmock/include/gmock/gmock.h"
+#include "testing/gtest/include/gtest/gtest.h"
+
+namespace blimp {
+namespace {
+
+// This is a sample implementation that demostrates the implementation
+// of the SyncableMember and SyncableObject
+
+// For simplicity of this example, the ChangeSet will be an integer.
+class FakeIntSyncable : public SyncableMember<int> {
+ public:
+  explicit FakeIntSyncable(SyncableObject* parent)
+      : SyncableMember(parent), value_(0) {
+    last_modified_ = parent_clock();
+  }
+
+  bool ModifiedSince(const VectorClock& from) override {
+    return from.local_revision() < last_modified_.local_revision();
+  }
+
+  std::unique_ptr<int> CreateChangesetToCurrent(
+      const VectorClock& from) override {
+    return base::MakeUnique<int>(value_);
+  }
+
+  void ApplyChangeset(const VectorClock& from,
+                      const VectorClock& to,
+                      std::unique_ptr<int> changeset) override {
+    // Restore the value
+    value_ = *changeset;
+
+    // Update our clock to the latest clock
+    last_modified_ = to;
+  }
+
+  void ReleaseCheckpointsBefore(const VectorClock& checkpoint) override {
+    last_modified_ = checkpoint;
+  }
+
+  void SetValue(int value) {
+    value_ = value;
+
+    // Increment the parent clock and update our last_modified_ value
+    last_modified_ = IncrementParentClock();
+  }
+
+  int value() { return value_; }
+
+ private:
+  // The last time this object was changed
+  VectorClock last_modified_;

[steimel, 2016/10/05 00:57:38]

Should we make this a protected member at the SyncableMember level and then have
a default implementation of ModifiedSince? That way we don't have to
implement/test the same ModifiedSince logic in each subclass

[scf, 2016/10/05 16:45:10]

each class might implement this differently. hard to say until we implement a
few crdts, i can see this being useful for lww register, but not sure for
everything (i.e. UnionSet)

[steimel, 2016/10/05 16:57:58]

Gotcha. Makes sense. I guess in my head I figured UniqueSet would still have
this last_modified_ attribute and essentially treat it as a cached max of its
elements timestamps, but if we're not doing that then having having this
implemented at the SyncableMember level doesn't make sense.

+  int32_t value_;
+
+  DISALLOW_COPY_AND_ASSIGN(FakeIntSyncable);
+};
+
+class ParentObjectSyncable : public SyncableObject {
+ public:
+  explicit ParentObjectSyncable(VectorClock clock)
+      : SyncableObject(clock), child1_(this), child2_(this) {}
+
+  std::unique_ptr<proto::ChangesetMessage> CreateChangesetToCurrent(
+      const VectorClock& from) override {
+    std::unique_ptr<proto::ChangesetMessage> changeset =
+        base::MakeUnique<proto::ChangesetMessage>();
+
+    proto::TestChangesetMessage* bm = changeset->mutable_test();
+
+    if (child1_.ModifiedSince(from)) {
+      std::unique_ptr<int> value1 = child1_.CreateChangesetToCurrent(from);
+      bm->set_value1(*value1);
+    }
+
+    if (child2_.ModifiedSince(from)) {
+      std::unique_ptr<int> value2 = child2_.CreateChangesetToCurrent(from);
+      bm->set_value2(*value2);
+    }
+
+    return changeset;
+  }
+
+  void ApplyChangeset(
+      const VectorClock& from,
+      const VectorClock& to,
+      std::unique_ptr<proto::ChangesetMessage> changeset) override {
+    proto::TestChangesetMessage bm = changeset->test();
+
+    int child1_value = bm.value1();
+    if (child1_value != 0) {
+      child1_.ApplyChangeset(from, to, base::MakeUnique<int>(child1_value));
+    }
+
+    int child2_value = bm.value2();
+    if (child2_value != 0) {
+      child2_.ApplyChangeset(from, to, base::MakeUnique<int>(child2_value));
+    }
+  }
+
+  void ReleaseCheckpointsBefore(const VectorClock& checkpoint) override {
+    child1_.ReleaseCheckpointsBefore(checkpoint);
+    child2_.ReleaseCheckpointsBefore(checkpoint);
+  }
+
+  FakeIntSyncable& get_child1() { return child1_; }
+  FakeIntSyncable& get_child2() { return child2_; }
+
+ private:
+  FakeIntSyncable child1_;
+  FakeIntSyncable child2_;
+
+  DISALLOW_COPY_AND_ASSIGN(ParentObjectSyncable);
+};
+
+class SyncableTest : public testing::Test {
+ public:
+  SyncableTest()
+      : last_sync_local_(),
+        last_sync_remote_(),
+        parent_local_(VectorClock()),
+        parent_remote_(VectorClock()) {}
+
+  ~SyncableTest() override {}
+
+  void OnChangesetCreated(std::unique_ptr<proto::ChangesetMessage> changeset) {
+    VectorClock local_clock = parent_local_.clock();
+    VectorClock remote_clock = local_clock.Invert();
+
+    base::Closure done_cb =
+        base::Bind(&SyncableTest::OnChangesetApplied, base::Unretained(this));
+
+    parent_remote_.ApplyChangesetAsync(last_sync_remote_, remote_clock,
+                                       std::move(changeset), done_cb);
+  }
+
+  void OnChangesetApplied() {
+    EXPECT_EQ(123, parent_remote_.get_child1().value());
+    EXPECT_EQ(0, parent_remote_.get_child2().value());
+  }
+
+ protected:
+  VectorClock last_sync_local_;
+  VectorClock last_sync_remote_;
+  ParentObjectSyncable parent_local_;
+  ParentObjectSyncable parent_remote_;
+
+ private:
+  DISALLOW_COPY_AND_ASSIGN(SyncableTest);
+};
+
+TEST_F(SyncableTest, CreateAndApplyChangesetTestSync) {
+  // Lets modify a children object
+  parent_local_.get_child1().SetValue(123);
+
+  // At this point |child1| and |parentObject| should have its clock incremented
+  // whereas |child2| should still be the same.
+  EXPECT_TRUE(parent_local_.get_child1().ModifiedSince(last_sync_local_));
+  EXPECT_FALSE(parent_local_.get_child2().ModifiedSince(last_sync_local_));
+
+  std::unique_ptr<proto::ChangesetMessage> changeset =
+      parent_local_.CreateChangesetToCurrent(last_sync_local_);
+
+  VectorClock local_clock = parent_local_.clock();
+  VectorClock remote_clock = local_clock.Invert();
+
+  parent_remote_.ApplyChangeset(last_sync_remote_, remote_clock,
+                                std::move(changeset));
+  last_sync_local_ = local_clock;
+  parent_local_.ReleaseCheckpointsBefore(local_clock);
+  EXPECT_FALSE(parent_local_.get_child1().ModifiedSince(last_sync_local_));
+  EXPECT_FALSE(parent_local_.get_child2().ModifiedSince(last_sync_local_));
+
+  EXPECT_EQ(123, parent_remote_.get_child1().value());
+  EXPECT_EQ(0, parent_remote_.get_child2().value());
+}
+
+TEST_F(SyncableTest, CreateAndApplyChangesetTestAsync) {
+  // Lets modify a children object
+  parent_local_.get_child1().SetValue(123);
+
+  ParentObjectSyncable::CreateChangesetCallback changeset_created_cb =
+      base::Bind(&SyncableTest::OnChangesetCreated, base::Unretained(this));
+
+  parent_local_.CreateChangesetToCurrentAsync(last_sync_local_,
+                                              changeset_created_cb);
+}
+
+}  // namespace
+}  // namespace blimp