Publish as a Quixos Workspace Template

.quixos-template-source.json

@@ -1,4 +1,4 @@
 {
-  "monorepoCommit": "be30143a326d5d7d7b0cbabea5bc5ac0301ef5b9",
+  "monorepoCommit": "d3eb4e936ac578b8c99e9716b2756c0f118f842e",
   "sourcePath": "quixos-instance/packages/agent-presentation"
 }

flake.lock

@@ -21,17 +21,17 @@
     "helpers": {
       "flake": false,
       "locked": {
-        "lastModified": 1790852599,
-        "narHash": "sha256-MdNtZpcsoguLPSCpAy9Naz6fkVPrftbZQbz1Aj7Zm9A=",
-        "ref": "refs/tags/quixos-reachability/91679e8cc82133093cb0b4f9e519cbb39a5bba4f",
-        "rev": "91679e8cc82133093cb0b4f9e519cbb39a5bba4f",
-        "revCount": 54,
+        "lastModified": 1791886789,
+        "narHash": "sha256-7YF98v0AcxD1qkAdS+nL/aDtmTvcRzld9CB9AxY0qaA=",
+        "ref": "refs/tags/quixos-reachability/5657043450c46fc84e1a6d38c2f8919ba1e9d10c",
+        "rev": "5657043450c46fc84e1a6d38c2f8919ba1e9d10c",
+        "revCount": 78,
         "type": "git",
         "url": "https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos-nix-helpers.git"
       },
       "original": {
-        "ref": "refs/tags/quixos-reachability/91679e8cc82133093cb0b4f9e519cbb39a5bba4f",
-        "rev": "91679e8cc82133093cb0b4f9e519cbb39a5bba4f",
+        "ref": "refs/tags/quixos-reachability/5657043450c46fc84e1a6d38c2f8919ba1e9d10c",
+        "rev": "5657043450c46fc84e1a6d38c2f8919ba1e9d10c",
         "type": "git",
         "url": "https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos-nix-helpers.git"
       }
@@ -58,17 +58,17 @@
         "nixpkgs": "nixpkgs"
       },
       "locked": {
-        "lastModified": 1791261504,
-        "narHash": "sha256-QSk9DWR7n5KL6cMHzmSKKXNIyaFA0s8Nu+wXjhhlENI=",
-        "ref": "refs/tags/quixos-reachability/5b44c8154dc038efd87cf1cbdd2c00b66bfd4f87",
-        "rev": "5b44c8154dc038efd87cf1cbdd2c00b66bfd4f87",
-        "revCount": 184,
+        "lastModified": 1792381599,
+        "narHash": "sha256-ojsUJmm+cDuIbxskC2RDOy5HiyIg+R48yRs3dqaccgo=",
+        "ref": "refs/tags/quixos-reachability/5520c2b0116696152ce64d797153133475c4b259",
+        "rev": "5520c2b0116696152ce64d797153133475c4b259",
+        "revCount": 234,
         "type": "git",
         "url": "https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos-protocol.git"
       },
       "original": {
-        "ref": "refs/tags/quixos-reachability/5b44c8154dc038efd87cf1cbdd2c00b66bfd4f87",
-        "rev": "5b44c8154dc038efd87cf1cbdd2c00b66bfd4f87",
+        "ref": "refs/tags/quixos-reachability/5520c2b0116696152ce64d797153133475c4b259",
+        "rev": "5520c2b0116696152ce64d797153133475c4b259",
         "type": "git",
         "url": "https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos-protocol.git"
       }

flake.nix

@@ -1,9 +1,9 @@
 {
-  inputs.protocol.url = "git+https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos-protocol.git?ref=refs/tags/quixos-reachability/5b44c8154dc038efd87cf1cbdd2c00b66bfd4f87&rev=5b44c8154dc038efd87cf1cbdd2c00b66bfd4f87";
+  inputs.protocol.url = "git+https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos-protocol.git?ref=refs/tags/quixos-reachability/5520c2b0116696152ce64d797153133475c4b259&rev=5520c2b0116696152ce64d797153133475c4b259";
   inputs.nixpkgs.follows = "protocol/nixpkgs";
   inputs.flake-utils.follows = "protocol/flake-utils";
   inputs.helpers = {
-    url = "git+https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos-nix-helpers.git?ref=refs/tags/quixos-reachability/91679e8cc82133093cb0b4f9e519cbb39a5bba4f&rev=91679e8cc82133093cb0b4f9e519cbb39a5bba4f";
+    url = "git+https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos-nix-helpers.git?ref=refs/tags/quixos-reachability/5657043450c46fc84e1a6d38c2f8919ba1e9d10c&rev=5657043450c46fc84e1a6d38c2f8919ba1e9d10c";
     flake = false;
   };
   outputs =

quixos.lock

@@ -1,9 +1,9 @@
 quixos-lock version 1 {
-  quixos source { repository "https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos.git"; commit "be30143a326d5d7d7b0cbabea5bc5ac0301ef5b9"; }
-  interface StandaloneView source { repository "https://repos.quixos.org/quixos-templates/interface-react-standalone-view.git"; commit "29a974e9db15387c9efc0f0fe64fec348db10344"; }
-  interface AgentThread source { repository "https://repos.quixos.org/quixos-templates/interface-agent-thread.git"; commit "6ace62f773c230c468efeabe9b5aac35115b7900"; }
-  interface Agent source { repository "https://repos.quixos.org/quixos-templates/interface-agent.git"; commit "dcd3f271b42649b4ce15a890f9b41e19a7271563"; }
-  interface AgentRequest source { repository "https://repos.quixos.org/quixos-templates/interface-agent-request.git"; commit "7f1e9d6278366329fd76f2698cd5a53c136f9914"; }
-  interface AgentItem source { repository "https://repos.quixos.org/quixos-templates/interface-agent-item.git"; commit "6e702e5cab24634d306c8f657f3a0b4873469060"; }
-  interface AgentQuestion source { repository "https://repos.quixos.org/quixos-templates/interface-agent-question.git"; commit "7d69058c2c12b4ca1800d8ff8218caffa45e5d13"; }
+  quixos source { repository "https://gitea.internal.quixos.org/quixos/quixos.git"; commit "d3eb4e936ac578b8c99e9716b2756c0f118f842e"; }
+  interface StandaloneView source { repository "https://repos.quixos.org/quixos-templates/interface-react-standalone-view.git"; commit "95b942b678a939b7f2ac03def18707c6dbe440f2"; }
+  interface AgentThread source { repository "https://repos.quixos.org/quixos-templates/interface-agent-thread.git"; commit "eeb335d552600b90610fd45c78bbe8af2f6a7dfb"; }
+  interface Agent source { repository "https://repos.quixos.org/quixos-templates/interface-agent.git"; commit "6bb1848e13b33af865cf5cdd4caf8814747f89cd"; }
+  interface AgentRequest source { repository "https://repos.quixos.org/quixos-templates/interface-agent-request.git"; commit "398851768d0391e5202c1d4c766aad6c9bb53f47"; }
+  interface AgentItem source { repository "https://repos.quixos.org/quixos-templates/interface-agent-item.git"; commit "0445ca6b80358f306e45a759be8db7bcbdf3e961"; }
+  interface AgentQuestion source { repository "https://repos.quixos.org/quixos-templates/interface-agent-question.git"; commit "a4a6ba43e6ccec4402dadc8ddb07d8a8b8f951f6"; }
 }

src/http.ts

@@ -50,6 +50,64 @@ export const control = async (input: Record<string, unknown>) => {
 };
 export const draftKey = (thread: string) => `quixos.agent.draft:${location.origin}:${thread}`;
 
+/** Status and directory invalidation shared by shells, without a recurring
+ * snapshot timer. Reconnecting rechecks state to cover disconnected changes. */
+export function subscribeAgentUpdates(listener: () => void, onError: (error: unknown) => void) {
+  const abort = new AbortController();
+  let timer: ReturnType<typeof setTimeout> | undefined;
+  const changed = () => {
+    timer ??= setTimeout(() => {
+      timer = undefined;
+      listener();
+    }, 100);
+  };
+  void (async () => {
+    while (!abort.signal.aborted) {
+      try {
+        const response = await fetch("/api/agent/updates", { credentials: "same-origin", signal: abort.signal });
+        if (!response.ok || !response.body) throw Error("Agent updates unavailable");
+        const reader = response.body.getReader(),
+          decoder = new TextDecoder();
+        let buffer = "";
+        try {
+          while (!abort.signal.aborted) {
+            const chunk = await reader.read();
+            if (chunk.done) break;
+            buffer += decoder.decode(chunk.value, { stream: true });
+            if (buffer.length > 65536) throw Error("Agent update frame exceeds limit");
+            let end: number;
+            while ((end = buffer.indexOf("\n")) !== -1) {
+              const line = buffer.slice(0, end);
+              buffer = buffer.slice(end + 1);
+              if (line && JSON.parse(line).type === "changed") changed();
+            }
+          }
+        } finally {
+          await reader.cancel().catch(() => {});
+          reader.releaseLock();
+        }
+      } catch (error) {
+        if (!abort.signal.aborted) onError(error);
+      }
+      if (!abort.signal.aborted)
+        await new Promise<void>((resolve) => {
+          const finish = () => {
+            clearTimeout(retry);
+            abort.signal.removeEventListener("abort", finish);
+            resolve();
+          };
+          const retry = setTimeout(finish, 1000);
+          abort.signal.addEventListener("abort", finish, { once: true });
+          if (abort.signal.aborted) finish();
+        });
+    }
+  })();
+  return () => {
+    abort.abort();
+    clearTimeout(timer);
+  };
+}
+
 /** A browser observer owns no executor. Closing it only stops reads. */
 export class HttpThreadController implements ThreadController {
   private state: ThreadState = {
@@ -65,7 +123,8 @@ export class HttpThreadController implements ThreadController {
   private requests = new Map<string, Request>();
   private aliases = new Map<string, Ref>();
   private abort = new AbortController();
-  private timer?: ReturnType<typeof setInterval>;
+  private timer?: ReturnType<typeof setTimeout>;
+  private refreshNeeded = false;
   private refreshing?: Promise<void>;
   private closed = false;
   constructor(
@@ -76,9 +135,6 @@ export class HttpThreadController implements ThreadController {
     void this.refresh()
       .catch((error) => this.patch({ error: String(error), loading: false }))
       .finally(() => this.stream());
-    this.timer = setInterval(() => {
-      void this.refresh().catch(() => {});
-    }, 2000);
   }
   getSnapshot = () => this.state;
   subscribe = (callback: () => void) => {
@@ -290,6 +346,21 @@ export class HttpThreadController implements ThreadController {
     if (!older) this.refreshing = task;
     return task;
   };
+  private scheduleRefresh() {
+    this.refreshNeeded = true;
+    if (this.closed || this.timer) return;
+    this.timer = setTimeout(() => {
+      this.timer = undefined;
+      this.refreshNeeded = false;
+      void (async () => {
+        // A notification arriving during a previous snapshot needs a subsequent
+        // read, not merely the same in-flight promise.
+        await this.refreshing?.catch(() => {});
+        await this.refresh().catch(() => {});
+        if (this.refreshNeeded) this.scheduleRefresh();
+      })();
+    }, 100);
+  }
   private async stream() {
     while (!this.closed) {
       try {
@@ -300,6 +371,7 @@ export class HttpThreadController implements ThreadController {
         );
         if (!response.ok || !response.body) throw Error("Live Agent stream unavailable");
         this.patch({ connected: true });
+        this.scheduleRefresh();
         const reader = response.body.getReader(),
           decoder = new TextDecoder();
         let buffer = "";
@@ -315,6 +387,10 @@ export class HttpThreadController implements ThreadController {
               buffer = buffer.slice(end + 1);
               if (!line) continue;
               const event = JSON.parse(line);
+              if (event.type === "graph") {
+                this.scheduleRefresh();
+                continue;
+              }
               if (event.type === "reset") {
                 await this.refresh();
                 break;
@@ -425,7 +501,7 @@ export class HttpThreadController implements ThreadController {
   close = () => {
     this.closed = true;
     this.abort.abort();
-    clearInterval(this.timer);
+    clearTimeout(this.timer);
     this.listeners.clear();
   };
 }