feat: removes orphaned containers. fixes #3077 (#3098)

Author: amir20

assets/stores/container.ts

@@ -59,11 +59,18 @@ export const useContainerStore = defineStore("container", () => {
         container.updateStat(rest);
       }
     });
-    es.addEventListener("container-die", (e) => {
-      const event = JSON.parse((e as MessageEvent).data) as { actorId: string };
-      const container = allContainersById.value[event.actorId];
-      if (container) {
-        container.state = "exited";
+    es.addEventListener("container-event", (e) => {
+      const event = JSON.parse((e as MessageEvent).data) as { actorId: string; name: string };
+      switch (event.name) {
+        case "die":
+          const container = allContainersById.value[event.actorId];
+          if (container) {
+            container.state = "exited";
+          }
+          break;
+        case "destroy":
+          containers.value = containers.value.filter((c) => c.id !== event.actorId);
+          break;
       }
     });
 

internal/web/__snapshots__/web.snapshot

@@ -135,7 +135,7 @@ event: containers-changed
 data: [{"id":"1234","names":null,"name":"test","image":"test","imageId":"","command":"","created":"0001-01-01T00:00:00Z","state":"","status":"","stats":[]}]
 
 
-event: container-start
+event: container-event
 data: {"actorId":"1234","name":"start","host":"localhost"}
 
 /* snapshot: Test_handler_streamLogs_error_finding_container */

internal/web/events.go

@@ -65,7 +65,7 @@ func (h *handler) streamEvents(w http.ResponseWriter, r *http.Request) {
 				return
 			}
 			switch event.Name {
-			case "start", "die":
+			case "start", "die", "destroy":
 				if event.Name == "start" {
 					log.Debugf("found new container with id: %v", event.ActorID)
 					if containers, err := h.multiHostService.ListContainersForHost(event.Host); err == nil {
@@ -77,7 +77,7 @@ func (h *handler) streamEvents(w http.ResponseWriter, r *http.Request) {
 				}
 
 				bytes, _ := json.Marshal(event)
-				if _, err := fmt.Fprintf(w, "event: container-%s\ndata: %s\n\n", event.Name, string(bytes)); err != nil {
+				if _, err := fmt.Fprintf(w, "event: container-event\ndata: %s\n\n", string(bytes)); err != nil {
 					log.Errorf("error writing event to event stream: %v", err)
 					return
 				}