[POC] Listen modifications from loadflow run

src/main/java/org/gridsuite/loadflow/server/service/LoadFlowWorkerService.java

@@ -73,10 +73,13 @@ protected LoadFlowResultContext fromMessage(Message<String> message) {
 
     @Override
     protected LoadFlowResult run(LoadFlowRunContext runContext, UUID resultUuid, AtomicReference<ReportNode> rootReporter) {
+        NetworkStoreListener networkStoreListener = new NetworkStoreListener();
+        runContext.getNetwork().addListener(networkStoreListener);
         LoadFlowResult result = super.run(runContext, resultUuid, rootReporter);
         if (result != null && !result.isFailed()) {
             // flush network in the network store
             observer.observe("network.save", runContext, () -> networkStoreService.flush(runContext.getNetwork()));
+            networkStoreListener.flush();
         }
         return result;
     }

src/main/java/org/gridsuite/loadflow/server/service/NetworkStoreListener.java

@@ -0,0 +1,100 @@
+package org.gridsuite.loadflow.server.service;
+
+import com.powsybl.commons.extensions.Extension;
+import com.powsybl.iidm.network.Identifiable;
+import com.powsybl.iidm.network.NetworkListener;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Set;
+
+public class NetworkStoreListener implements NetworkListener {
+    private static final Logger LOG = LoggerFactory.getLogger(NetworkStoreListener.class);
+
+    private List<Modification> modificationList = new ArrayList<>();
+
+    private record Modification(Identifiable<?> identifiable, String attribute, Object oldValue, Object newValue) { }
+
+    private Set flowAttributes = Set.of("p1", "p2", "q1", "q2");
+
+    @Override
+    public void onCreation(Identifiable<?> identifiable) {
+        modificationList.add(new Modification(identifiable, "CREATE", null, null));
+        LOG.error("NetworkStoreListener onCreation {}", identifiable.getId());
+    }
+
+    @Override
+    public void beforeRemoval(Identifiable<?> identifiable) {
+        modificationList.add(new Modification(identifiable, "DELETE", null, null));
+    }
+
+    @Override
+    public void afterRemoval(String id) {
+
+    }
+
+    @Override
+    public void onUpdate(Identifiable<?> identifiable, String attribute, String variantId, Object oldValue, Object newValue) {
+        modificationList.add(new Modification(identifiable, attribute, oldValue, newValue));
+        if (!flowAttributes.contains(attribute)) {
+            LOG.error("NetworkStoreListener onUpdate {} : {}", identifiable.getType(), attribute);
+        }
+    }
+
+    @Override
+    public void onExtensionCreation(Extension<?> extension) {
+
+    }
+
+    @Override
+    public void onExtensionAfterRemoval(Identifiable<?> identifiable, String extensionName) {
+
+    }
+
+    @Override
+    public void onExtensionBeforeRemoval(Extension<?> extension) {
+
+    }
+
+    @Override
+    public void onExtensionUpdate(Extension<?> extendable, String attribute, String variantId, Object oldValue, Object newValue) {
+
+    }
+
+    @Override
+    public void onPropertyAdded(Identifiable<?> identifiable, String key, Object newValue) {
+        modificationList.add(new Modification(identifiable, key, null, newValue));
+        LOG.error("NetworkStoreListener onPropertyAdded {} : {}", identifiable.getId(), key);
+    }
+
+    @Override
+    public void onPropertyReplaced(Identifiable<?> identifiable, String key, Object oldValue, Object newValue) {
+        LOG.error("NetworkStoreListener onPropertyReplaced {} : {}", identifiable.getId(), key);
+    }
+
+    @Override
+    public void onPropertyRemoved(Identifiable<?> identifiable, String key, Object oldValue) {
+
+    }
+
+    @Override
+    public void onVariantCreated(String sourceVariantId, String targetVariantId) {
+
+    }
+
+    @Override
+    public void onVariantOverwritten(String sourceVariantId, String targetVariantId) {
+
+    }
+
+    @Override
+    public void onVariantRemoved(String variantId) {
+
+    }
+
+    public void flush() {
+        LOG.error("NetworkStoreListener flush");
+    }
+}