From 154bce366a6095dd351f349fd8515eb8e7a2e208 Mon Sep 17 00:00:00 2001 From: hsiegeln <37154749+hsiegeln@users.noreply.github.com> Date: Tue, 31 Mar 2026 23:00:11 +0200 Subject: [PATCH] fix: remove references to deleted ProcessorExecution tree fields cameleer3-common removed children, loopIndex, splitIndex, multicastIndex from ProcessorExecution (flat model only now). Iteration context lives on synthetic wrapper nodes via processorType. Co-Authored-By: Claude Opus 4.6 (1M context) --- .../cameleer3/server/core/detail/DetailService.java | 9 ++------- .../server/core/ingestion/IngestionService.java | 10 +--------- 2 files changed, 3 insertions(+), 16 deletions(-) diff --git a/cameleer3-server-core/src/main/java/com/cameleer3/server/core/detail/DetailService.java b/cameleer3-server-core/src/main/java/com/cameleer3/server/core/detail/DetailService.java index ed95514c..a91e0c1b 100644 --- a/cameleer3-server-core/src/main/java/com/cameleer3/server/core/detail/DetailService.java +++ b/cameleer3-server-core/src/main/java/com/cameleer3/server/core/detail/DetailService.java @@ -75,7 +75,7 @@ public class DetailService { } } - /** Convert agent ProcessorExecution tree to detail ProcessorNode tree. */ + /** Convert agent ProcessorExecution list to detail ProcessorNode list. */ private List convertProcessors(List executions) { if (executions == null) return List.of(); List result = new ArrayList<>(); @@ -89,9 +89,7 @@ public class DetailService { p.getDurationMs(), p.getErrorMessage(), p.getErrorStackTrace(), p.getAttributes() != null ? new LinkedHashMap<>(p.getAttributes()) : null, - p.getLoopIndex(), p.getLoopSize(), - p.getSplitIndex(), p.getSplitSize(), - p.getMulticastIndex(), + null, null, null, null, null, p.getResolvedEndpointUri(), p.getErrorType(), p.getErrorCategory(), p.getRootCauseType(), p.getRootCauseMessage(), @@ -100,9 +98,6 @@ public class DetailService { p.getFilterMatched(), p.getDuplicateMessage(), hasTrace ); - for (ProcessorNode child : convertProcessors(p.getChildren())) { - node.addChild(child); - } result.add(node); } return result; diff --git a/cameleer3-server-core/src/main/java/com/cameleer3/server/core/ingestion/IngestionService.java b/cameleer3-server-core/src/main/java/com/cameleer3/server/core/ingestion/IngestionService.java index 9ff02b7e..ed3a7d17 100644 --- a/cameleer3-server-core/src/main/java/com/cameleer3/server/core/ingestion/IngestionService.java +++ b/cameleer3-server-core/src/main/java/com/cameleer3/server/core/ingestion/IngestionService.java @@ -132,7 +132,6 @@ public class IngestionService { if (processors == null) return false; for (ProcessorExecution p : processors) { if (p.getInputBody() != null || p.getOutputBody() != null) return true; - if (hasAnyTraceData(p.getChildren())) return true; } return false; } @@ -155,20 +154,13 @@ public class IngestionService { truncateBody(p.getInputBody()), truncateBody(p.getOutputBody()), toJson(p.getInputHeaders()), toJson(p.getOutputHeaders()), toJson(p.getAttributes()), - p.getLoopIndex(), p.getLoopSize(), - p.getSplitIndex(), p.getSplitSize(), - p.getMulticastIndex(), + null, null, null, null, null, p.getResolvedEndpointUri(), p.getErrorType(), p.getErrorCategory(), p.getRootCauseType(), p.getRootCauseMessage(), p.getErrorHandlerType(), p.getCircuitBreakerState(), p.getFallbackTriggered() )); - if (p.getChildren() != null) { - flat.addAll(flattenProcessors( - p.getChildren(), executionId, execStartTime, - applicationName, routeId, p.getProcessorId(), depth + 1)); - } } return flat; }