Merge pull request #4198 from systeminit/send-delete-connection-ws-ev…

…ents fix(dal): Send WsEvents to delete connections when upgrading a component
systeminit · Jul 23, 2024 · ad19072 · ad19072
2 parents 68ab17a + 65e3c59
commit ad19072
Showing 1 changed file with 22 additions and 0 deletions.
diff --git a/lib/dal/src/component.rs b/lib/dal/src/component.rs
@@ -3669,6 +3669,17 @@ impl Component {
                 incoming.to_input_socket_id,
             )
             .await?;
+
+            WsEvent::connection_deleted(
+                ctx,
+                incoming.from_component_id,
+                incoming.to_component_id,
+                incoming.from_output_socket_id,
+                incoming.to_input_socket_id,
+            )
+            .await?
+            .publish_on_commit(ctx)
+            .await?;
         }
 
         for outgoing in &original_outgoing_connections {
@@ -3680,6 +3691,17 @@ impl Component {
                 outgoing.to_input_socket_id,
             )
             .await?;
+
+            WsEvent::connection_deleted(
+                ctx,
+                outgoing.from_component_id,
+                outgoing.to_component_id,
+                outgoing.from_output_socket_id,
+                outgoing.to_input_socket_id,
+            )
+            .await?
+            .publish_on_commit(ctx)
+            .await?;
         }
 
         // Let's requeue any Actions for the component