#303 dataset dirs seen false

eo-cqrs · Jun 27, 2023 · 9bd7cd3 · 9bd7cd3
1 parent b5de1f6
commit 9bd7cd3
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/src/main/java/io/github/eocqrs/kafka/fake/DatasetDirs.java b/src/main/java/io/github/eocqrs/kafka/fake/DatasetDirs.java
@@ -74,6 +74,9 @@ public Directives value() throws Exception {
       .set(this.key)
       .up()
       .addIf("value")
-      .set(this.data.dataized().dataize());
+      .set(this.data.dataized().dataize())
+      .up()
+      .addIf("seen")
+      .set("false");
   }
 }
diff --git a/src/test/java/io/github/eocqrs/kafka/fake/DatasetDirsTest.java b/src/test/java/io/github/eocqrs/kafka/fake/DatasetDirsTest.java
@@ -17,7 +17,8 @@ final class DatasetDirsTest {
   void dirsInRightFormat() throws Exception {
     final String directives = "XPATH \"broker/topics/topic[name = &apos;&apos;]\";ADDIF "
       + "\"datasets\";ADD \"dataset\";ADD \"partition\";\n"
-      + "4:SET \"0\";UP;ADDIF \"key\";SET \"test\";UP;ADDIF \"value\";SET \"\";";
+      + "4:SET \"0\";UP;ADDIF \"key\";SET \"test\";UP;ADDIF \"value\";SET \"\";"
+      + "UP;ADDIF \"seen\";SET \"false\";";
     MatcherAssert.assertThat(
       "Directives in the right format",
       new DatasetDirs<>(