fix: update ChunkAccumulator tests for DiagramStore constructor param

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

cameleer3-server-app/src/test/java/com/cameleer3/server/app/storage/ClickHouseChunkPipelineIT.java

@@ -3,6 +3,7 @@ package com.cameleer3.server.app.storage;
 import com.cameleer3.server.app.search.ClickHouseSearchIndex;
 import com.cameleer3.server.core.ingestion.ChunkAccumulator;
 import com.cameleer3.server.core.ingestion.MergedExecution;
+import com.cameleer3.server.core.storage.DiagramStore;
 import com.cameleer3.server.core.search.ExecutionSummary;
 import com.cameleer3.server.core.search.SearchRequest;
 import com.cameleer3.server.core.search.SearchResult;
@@ -63,7 +64,8 @@ class ClickHouseChunkPipelineIT {
 
         executionBuffer = new ArrayList<>();
         processorBuffer = new ArrayList<>();
-        accumulator = new ChunkAccumulator(executionBuffer::add, processorBuffer::add, Duration.ofMinutes(5));
+        DiagramStore noOpDiagramStore = org.mockito.Mockito.mock(DiagramStore.class);
+        accumulator = new ChunkAccumulator(executionBuffer::add, processorBuffer::add, noOpDiagramStore, Duration.ofMinutes(5));
     }
 
     @Test

cameleer3-server-core/src/test/java/com/cameleer3/server/core/ingestion/ChunkAccumulatorTest.java

@@ -3,6 +3,7 @@ package com.cameleer3.server.core.ingestion;
 import com.cameleer3.common.model.ExecutionChunk;
 import com.cameleer3.common.model.ExecutionStatus;
 import com.cameleer3.common.model.FlatProcessorRecord;
+import com.cameleer3.server.core.storage.DiagramStore;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 
@@ -10,12 +11,21 @@ import java.time.Duration;
 import java.time.Instant;
 import java.util.List;
 import java.util.Map;
+import java.util.Optional;
 import java.util.concurrent.CopyOnWriteArrayList;
 
 import static org.assertj.core.api.Assertions.assertThat;
 
 class ChunkAccumulatorTest {
 
+    private static final DiagramStore NO_OP_DIAGRAM_STORE = new DiagramStore() {
+        public void store(com.cameleer3.server.core.ingestion.TaggedDiagram d) {}
+        public Optional<com.cameleer3.common.graph.RouteGraph> findByContentHash(String h) { return Optional.empty(); }
+        public Optional<String> findContentHashForRoute(String r, String a) { return Optional.empty(); }
+        public Optional<String> findContentHashForRouteByAgents(String r, List<String> a) { return Optional.empty(); }
+        public Map<String, String> findProcessorRouteMapping(String app) { return Map.of(); }
+    };
+
     private CopyOnWriteArrayList<MergedExecution> executionSink;
     private CopyOnWriteArrayList<ChunkAccumulator.ProcessorBatch> processorSink;
     private ChunkAccumulator accumulator;
@@ -25,7 +35,7 @@ class ChunkAccumulatorTest {
         executionSink = new CopyOnWriteArrayList<>();
         processorSink = new CopyOnWriteArrayList<>();
         accumulator = new ChunkAccumulator(
-                executionSink::add, processorSink::add, Duration.ofMinutes(5));
+                executionSink::add, processorSink::add, NO_OP_DIAGRAM_STORE, Duration.ofMinutes(5));
     }
 
     @Test
@@ -109,7 +119,7 @@ class ChunkAccumulatorTest {
     @Test
     void staleExchange_flushedBySweep() throws Exception {
         ChunkAccumulator staleAccumulator = new ChunkAccumulator(
-                executionSink::add, processorSink::add, Duration.ofMillis(1));
+                executionSink::add, processorSink::add, NO_OP_DIAGRAM_STORE, Duration.ofMillis(1));
 
         ExecutionChunk c = chunk("ex-3", "RUNNING",
                 Instant.parse("2026-03-31T10:00:00Z"),