Add xadd IT tests

Signed-off-by: Andrew Carbonetto <[email protected]>
valkey-io · Apr 3, 2024 · 292a4a9 · 292a4a9
1 parent 38f5a74
commit 292a4a9
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/java/integTest/src/test/java/glide/TransactionTestUtilities.java b/java/integTest/src/test/java/glide/TransactionTestUtilities.java
@@ -5,6 +5,7 @@
 
 import glide.api.models.BaseTransaction;
 import glide.api.models.commands.SetOptions;
+import glide.api.models.commands.StreamAddOptions;
 import java.util.Map;
 import java.util.Set;
 import java.util.UUID;
@@ -18,6 +19,7 @@ public class TransactionTestUtilities {
     private static final String key6 = "{key}" + UUID.randomUUID();
     private static final String key7 = "{key}" + UUID.randomUUID();
     private static final String key8 = "{key}" + UUID.randomUUID();
+    private static final String key9 = "{key}" + UUID.randomUUID();
     private static final String value1 = UUID.randomUUID().toString();
     private static final String value2 = UUID.randomUUID().toString();
     private static final String value3 = UUID.randomUUID().toString();
@@ -91,6 +93,10 @@ public static BaseTransaction<?> transactionTest(BaseTransaction<?> baseTransact
         baseTransaction.zscore(key8, "two");
         baseTransaction.zpopmax(key8);
 
+        baseTransaction.xadd(key9, Map.of("field1", "value1"), StreamAddOptions.builder().id("0-1").build());
+        baseTransaction.xadd(key9, Map.of("field2", "value2"), StreamAddOptions.builder().id("0-2").build());
+        baseTransaction.xadd(key9, Map.of("field3", "value3"), StreamAddOptions.builder().id("0-3").build());
+
         baseTransaction.configSet(Map.of("timeout", "1000"));
         baseTransaction.configGet(new String[] {"timeout"});
 
@@ -151,6 +157,9 @@ public static Object[] transactionTestResult() {
             2L,
             2.0, // zscore(key8, "two")
             Map.of("three", 3.0), // zpopmax(key8)
+            "0-1", // xadd(key9, Map.of("field1", "value1"), StreamAddOptions.builder().id("0-1").build());
+            "0-2", // xadd(key9, Map.of("field2", "value2"), StreamAddOptions.builder().id("0-2").build());
+            "0-3", // xadd(key9, Map.of("field3", "value3"), StreamAddOptions.builder().id("0-3").build());
             OK,
             Map.of("timeout", "1000"),
             OK,