extract step execution to commons

monitor-commons/pom.xml

@@ -23,5 +23,16 @@
             <groupId>com.fasterxml.jackson.core</groupId>
             <artifactId>jackson-annotations</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.powsybl</groupId>
+            <artifactId>powsybl-commons</artifactId>
+        </dependency>
+
+        <!-- Test dependencies -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 </project>

monitor-worker-server/src/main/java/org/gridsuite/monitor/worker/server/dto/ReportInfos.java → monitor-commons/src/main/java/org/gridsuite/monitor/commons/ReportInfos.java

@@ -4,7 +4,7 @@
  * License, v. 2.0. If a copy of the MPL was not distributed with this
  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
  */
-package org.gridsuite.monitor.worker.server.dto;
+package org.gridsuite.monitor.commons;
 
 import com.powsybl.commons.report.ReportNode;
 

monitor-commons/src/main/java/org/gridsuite/monitor/commons/steps/AbstractStepExecutor.java

@@ -0,0 +1,118 @@
+/**
+ * Copyright (c) 2026, RTE (http://www.rte-france.com)
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/.
+ */
+package org.gridsuite.monitor.commons.steps;
+
+import org.gridsuite.monitor.commons.ProcessExecutionStep;
+import org.gridsuite.monitor.commons.ReportInfos;
+import org.gridsuite.monitor.commons.ResultInfos;
+import org.gridsuite.monitor.commons.StepStatus;
+
+import java.time.Instant;
+import java.util.UUID;
+
+/**
+ * @author Mohamed Ben-rejeb <mohamed.ben-rejeb at rte-france.com>
+ */
+public abstract class AbstractStepExecutor {
+
+    protected final StepStatusPublisher stepStatusPublisher;
+    protected final ReportPublisher reportPublisher;
+
+    protected AbstractStepExecutor(StepStatusPublisher stepStatusPublisher, ReportPublisher reportPublisher) {
+        this.stepStatusPublisher = stepStatusPublisher;
+        this.reportPublisher = reportPublisher;
+    }
+
+    public void skipStep(
+            UUID processExecutionId,
+            UUID stepExecutionId,
+            String stepTypeName,
+            int stepOrder,
+            Instant startedAt
+    ) {
+        ProcessExecutionStep executionStep = ProcessExecutionStep.builder()
+                .id(stepExecutionId)
+                .stepType(stepTypeName)
+                .stepOrder(stepOrder)
+                .status(StepStatus.SKIPPED)
+                .startedAt(startedAt)
+                .completedAt(Instant.now())
+                .build();
+        stepStatusPublisher.updateStepStatus(processExecutionId, executionStep);
+    }
+
+    public void executeStep(
+            UUID processExecutionId,
+            UUID stepExecutionId,
+            String stepTypeName,
+            int stepOrder,
+            Instant startedAt,
+            UUID reportUuid,
+            ReportInfos reportInfos,
+            ResultInfos resultInfos,
+            Runnable stepExecution
+    ) {
+        ProcessExecutionStep executionStep = ProcessExecutionStep.builder()
+                .id(stepExecutionId)
+                .stepType(stepTypeName)
+                .stepOrder(stepOrder)
+                .status(StepStatus.RUNNING)
+                .reportId(reportUuid)
+                .startedAt(startedAt)
+                .build();
+        stepStatusPublisher.updateStepStatus(processExecutionId, executionStep);
+
+        try {
+            stepExecution.run();
+            reportPublisher.sendReport(reportInfos);
+            updateStepStatus(
+                    processExecutionId,
+                    stepExecutionId,
+                    stepTypeName,
+                    stepOrder,
+                    startedAt,
+                    reportUuid,
+                    resultInfos,
+                    StepStatus.COMPLETED);
+        } catch (Exception e) {
+            updateStepStatus(
+                    processExecutionId,
+                    stepExecutionId,
+                    stepTypeName,
+                    stepOrder,
+                    startedAt,
+                    reportUuid,
+                    resultInfos,
+                    StepStatus.FAILED);
+            throw e;
+        }
+    }
+
+    private void updateStepStatus(
+            UUID processExecutionId,
+            UUID stepExecutionId,
+            String stepTypeName,
+            int stepOrder,
+            Instant startedAt,
+            UUID reportUuid,
+            ResultInfos resultInfos,
+            StepStatus status
+    ) {
+        ProcessExecutionStep updated = ProcessExecutionStep.builder()
+                .id(stepExecutionId)
+                .stepType(stepTypeName)
+                .stepOrder(stepOrder)
+                .status(status)
+                .resultId(resultInfos != null ? resultInfos.resultUUID() : null)
+                .resultType(resultInfos != null ? resultInfos.resultType() : null)
+                .reportId(reportUuid)
+                .startedAt(startedAt)
+                .completedAt(Instant.now())
+                .build();
+        stepStatusPublisher.updateStepStatus(processExecutionId, updated);
+    }
+}

monitor-commons/src/main/java/org/gridsuite/monitor/commons/steps/ReportPublisher.java

@@ -0,0 +1,19 @@
+/**
+ * Copyright (c) 2026, RTE (http://www.rte-france.com)
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/.
+ */
+package org.gridsuite.monitor.commons.steps;
+
+import org.gridsuite.monitor.commons.ReportInfos;
+
+/**
+ * @author Mohamed Ben-rejeb <mohamed.ben-rejeb at rte-france.com>
+ */
+@FunctionalInterface
+public interface ReportPublisher {
+
+    void sendReport(ReportInfos reportInfos);
+
+}

monitor-commons/src/main/java/org/gridsuite/monitor/commons/steps/StepStatusPublisher.java

@@ -0,0 +1,20 @@
+/**
+ * Copyright (c) 2026, RTE (http://www.rte-france.com)
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/.
+ */
+package org.gridsuite.monitor.commons.steps;
+
+import org.gridsuite.monitor.commons.ProcessExecutionStep;
+
+import java.util.UUID;
+
+/**
+ * @author Mohamed Ben-rejeb <mohamed.ben-rejeb at rte-france.com>
+ */
+@FunctionalInterface
+public interface StepStatusPublisher {
+
+    void updateStepStatus(UUID executionId, ProcessExecutionStep processExecutionStep);
+}

monitor-commons/src/test/java/org/gridsuite/monitor/commons/steps/ReportPublisherTest.java

@@ -0,0 +1,33 @@
+/**
+ * Copyright (c) 2026, RTE (http://www.rte-france.com)
+ * This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/.
+ */
+package org.gridsuite.monitor.commons.steps;
+
+import com.powsybl.commons.report.ReportNode;
+import org.gridsuite.monitor.commons.ReportInfos;
+import org.junit.jupiter.api.Test;
+
+import java.util.UUID;
+import java.util.concurrent.atomic.AtomicReference;
+
+import static org.junit.jupiter.api.Assertions.assertSame;
+
+/**
+ * @author Mohamed Ben-rejeb <mohamed.ben-rejeb at rte-france.com>
+ */
+class ReportPublisherTest {
+
+    @Test
+    void sendReportShouldForwardReportInfosToImplementation() {
+        AtomicReference<ReportInfos> published = new AtomicReference<>();
+        ReportPublisher reportPublisher = published::set;
+        ReportInfos reportInfos = new ReportInfos(UUID.randomUUID(), ReportNode.NO_OP);
+
+        reportPublisher.sendReport(reportInfos);
+
+        assertSame(reportInfos, published.get());
+    }
+}