WIP

scalecube · Jul 17, 2024 · 9aa01d2 · 9aa01d2
1 parent 60ce93a
commit 9aa01d2
Showing 1 changed file with 19 additions and 2 deletions.
diff --git a/cluster2/src/test/java/io/scalecube/cluster2/membership/MembershipProtocolTest.java b/cluster2/src/test/java/io/scalecube/cluster2/membership/MembershipProtocolTest.java
@@ -150,12 +150,29 @@ void testOnSyncAck() {
 
   @Test
   void testOnSyncAckPeriodMismatch() {
-    fail("Implemnent");
+    final int period = 10;
+    setMembershipProtocolPeriod(period);
+    emitSyncAck(syncCodec -> syncCodec.encodeSyncAck(20, localRecord));
+    verify(membershipTable, never()).put(any(MembershipRecord.class));
   }
 
   @Test
   void testOnGossipMessage() {
-    fail("Implemnent");
+    emitGossipInputMessage(
+        gossipMessageCodec -> {
+          final MembershipRecordCodec membershipRecordCodec = new MembershipRecordCodec();
+          final MutableDirectBuffer buffer = membershipRecordCodec.encode(localRecord);
+          return gossipMessageCodec.encodeInputMessage(
+              buffer, 0, membershipRecordCodec.encodedLength());
+        });
+
+    verify(membershipTable)
+        .put(
+            argThat(
+                arg -> {
+                  assertMembershipRecordEquals(localRecord, arg);
+                  return true;
+                }));
   }
 
   @Test