From a637b7db758304c60061935a9ae99ca615bba906 Mon Sep 17 00:00:00 2001
From: Paulus Schoutsen <balloob@gmail.com>
Date: Mon, 26 Jun 2023 09:15:20 -0400
Subject: [PATCH] Automatically refresh when showing debug for a pipeline in
 progress (#17030)

---
 .../debug/assist-pipeline-debug.ts            | 29 +++++++++++++++++++
 1 file changed, 29 insertions(+)

diff --git a/src/panels/config/voice-assistants/debug/assist-pipeline-debug.ts b/src/panels/config/voice-assistants/debug/assist-pipeline-debug.ts
index e75f3a230f..9fb7782474 100644
--- a/src/panels/config/voice-assistants/debug/assist-pipeline-debug.ts
+++ b/src/panels/config/voice-assistants/debug/assist-pipeline-debug.ts
@@ -35,6 +35,8 @@ export class AssistPipelineDebug extends LitElement {
 
   @state() private _events?: PipelineRunEvent[];
 
+  private _unsubRefreshEventsID?: number;
+
   protected render() {
     return html`<hass-subpage
       .narrow=${this.narrow}
@@ -94,11 +96,27 @@ export class AssistPipelineDebug extends LitElement {
   }
 
   protected willUpdate(changedProperties) {
+    let clearRefresh = false;
+
     if (changedProperties.has("pipelineId")) {
       this._fetchRuns();
+      clearRefresh = true;
     }
     if (changedProperties.has("_runId")) {
       this._fetchEvents();
+      clearRefresh = true;
+    }
+    if (clearRefresh && this._unsubRefreshEventsID) {
+      clearTimeout(this._unsubRefreshEventsID);
+      this._unsubRefreshEventsID = undefined;
+    }
+  }
+
+  public disconnectedCallback(): void {
+    super.disconnectedCallback();
+    if (this._unsubRefreshEventsID) {
+      clearTimeout(this._unsubRefreshEventsID);
+      this._unsubRefreshEventsID = undefined;
     }
   }
 
@@ -144,6 +162,17 @@ export class AssistPipelineDebug extends LitElement {
         title: "Failed to fetch events",
         text: e.message,
       });
+      return;
+    }
+    if (
+      this._events?.length &&
+      // If the last event is not a finish run event, the run is still ongoing.
+      // Refresh events automatically.
+      !["run-end", "error"].includes(this._events[this._events.length - 1].type)
+    ) {
+      this._unsubRefreshEventsID = window.setTimeout(() => {
+        this._fetchEvents();
+      }, 2000);
     }
   }