Fix flow reloading on inotify events

The flow actor was trying to be smart, but actually too smart.
It was reloading a flow on an modified event only if the file was
actually loading. However, inotify might wrongly notify an update for a
new file.

Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>

Author: didier-wenzek

crates/extensions/tedge_flows/src/actor.rs

@@ -73,7 +73,7 @@ impl Actor for FlowsMapper {
                     if matches!(path.extension(), Some("js" | "ts" | "mjs")) {
                         self.processor.reload_script(path).await;
                     } else if path.extension() == Some("toml") {
-                        self.processor.reload_flow(path).await;
+                        self.processor.add_flow(path).await;
                         self.send_updated_subscriptions().await?;
                     }
                 }

crates/extensions/tedge_flows/src/runtime.rs

@@ -249,22 +249,15 @@ impl MessageProcessor {
 
     pub async fn add_flow(&mut self, path: Utf8PathBuf) {
         let flow_id = Self::flow_id(&path);
-        if !self.flows.contains_key(&flow_id) && self.load_flow(flow_id, path.clone()).await {
-            info!(target: "flows", "Loaded new flow {path}");
-        }
-    }
-
-    pub async fn reload_flow(&mut self, path: Utf8PathBuf) {
-        let flow_id = Self::flow_id(&path);
-        if self.flows.contains_key(&flow_id) && self.load_flow(flow_id, path.clone()).await {
-            info!(target: "flows", "Reloaded updated flow {path}");
+        if self.load_flow(flow_id, path.clone()).await {
+            info!(target: "flows", "Loading flow {path}");
         }
     }
 
     pub async fn remove_flow(&mut self, path: Utf8PathBuf) {
         let flow_id = Self::flow_id(&path);
         self.flows.remove(&flow_id);
-        info!(target: "flows", "Removed deleted flow {path}");
+        info!(target: "flows", "Removing flow {path}");
     }
 }