Test reading unrecognised log

gchq · Aug 13, 2024 · 6206a31 · 6206a31
1 parent 72b487e
commit 6206a31
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 0 deletions.
diff --git a/.../src/test/java/sleeper/systemtest/drivers/statestore/StateStoreCommitterLogEntryTest.java b/.../src/test/java/sleeper/systemtest/drivers/statestore/StateStoreCommitterLogEntryTest.java
@@ -56,4 +56,13 @@ void shouldReadCommitApplied() {
         assertThat(StateStoreCommitterLogEntry.readEvent(message)).isEqualTo(
                 new StateStoreCommitSummary("test-table", "TestRequest", Instant.parse("2024-08-13T12:12:30Z")));
     }
+
+    @Test
+    void shouldReadUnrecognisedLog() {
+        // Given
+        String message = "some other log";
+
+        // When / Then
+        assertThat(StateStoreCommitterLogEntry.readEvent(message)).isNull();
+    }
 }
diff --git a/...c/test/java/sleeper/systemtest/drivers/statestore/StateStoreCommitterRunsBuilderTest.java b/...c/test/java/sleeper/systemtest/drivers/statestore/StateStoreCommitterRunsBuilderTest.java
@@ -67,6 +67,15 @@ void shouldBuildSingleRunWithOneCommit() {
                         List.of(new StateStoreCommitSummary("test-table", "TestRequest", Instant.parse("2024-08-13T12:12:30Z")))));
     }
 
+    @Test
+    void shouldIgnoreUnrecognisedLog() {
+        // Given
+        add("test-logstream", "Some unknown message");
+
+        // When / Then
+        assertThat(builder.buildRuns()).isEmpty();
+    }
+
     void add(String logStream, String message) {
         builder.add(List.of(
                 ResultField.builder().field("@logStream").value(logStream).build(),