Publish as a Quixos Workspace Template

.quixos-template-source.json

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

flake.lock

@@ -21,19 +21,19 @@
     "helpers": {
       "flake": false,
       "locked": {
-        "lastModified": 1793277056,
-        "narHash": "sha256-w7TrYSjU8hbVrqbLdHgxDJAzMdN2NoWe+HkInJLWRlI=",
-        "ref": "refs/tags/quixos-reachability/c2454054dac36fb7a6ff12004003170a65e4f288",
-        "rev": "c2454054dac36fb7a6ff12004003170a65e4f288",
-        "revCount": 85,
+        "lastModified": 1790852599,
+        "narHash": "sha256-MdNtZpcsoguLPSCpAy9Naz6fkVPrftbZQbz1Aj7Zm9A=",
+        "ref": "refs/tags/quixos-reachability/91679e8cc82133093cb0b4f9e519cbb39a5bba4f",
+        "rev": "91679e8cc82133093cb0b4f9e519cbb39a5bba4f",
+        "revCount": 54,
         "type": "git",
-        "url": "https://repos.quixos.org/quixos-toolchain/quixos-nix-helpers.git"
+        "url": "https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos-nix-helpers.git"
       },
       "original": {
-        "ref": "refs/tags/quixos-reachability/c2454054dac36fb7a6ff12004003170a65e4f288",
-        "rev": "c2454054dac36fb7a6ff12004003170a65e4f288",
+        "ref": "refs/tags/quixos-reachability/91679e8cc82133093cb0b4f9e519cbb39a5bba4f",
+        "rev": "91679e8cc82133093cb0b4f9e519cbb39a5bba4f",
         "type": "git",
-        "url": "https://repos.quixos.org/quixos-toolchain/quixos-nix-helpers.git"
+        "url": "https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos-nix-helpers.git"
       }
     },
     "nixpkgs": {
@@ -58,19 +58,19 @@
         "nixpkgs": "nixpkgs"
       },
       "locked": {
-        "lastModified": 1793284605,
-        "narHash": "sha256-FgV0Qhy9vxhjZhJs3lWu4NtYZ9FvvkUmM32bP2V73yA=",
-        "ref": "refs/tags/quixos-reachability/a025525f47cdff71f2496bb4e72cb9fc06b046ed",
-        "rev": "a025525f47cdff71f2496bb4e72cb9fc06b046ed",
-        "revCount": 235,
+        "lastModified": 1791261504,
+        "narHash": "sha256-QSk9DWR7n5KL6cMHzmSKKXNIyaFA0s8Nu+wXjhhlENI=",
+        "ref": "refs/tags/quixos-reachability/5b44c8154dc038efd87cf1cbdd2c00b66bfd4f87",
+        "rev": "5b44c8154dc038efd87cf1cbdd2c00b66bfd4f87",
+        "revCount": 184,
         "type": "git",
-        "url": "https://repos.quixos.org/quixos-toolchain/quixos-protocol.git"
+        "url": "https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos-protocol.git"
       },
       "original": {
-        "ref": "refs/tags/quixos-reachability/a025525f47cdff71f2496bb4e72cb9fc06b046ed",
-        "rev": "a025525f47cdff71f2496bb4e72cb9fc06b046ed",
+        "ref": "refs/tags/quixos-reachability/5b44c8154dc038efd87cf1cbdd2c00b66bfd4f87",
+        "rev": "5b44c8154dc038efd87cf1cbdd2c00b66bfd4f87",
         "type": "git",
-        "url": "https://repos.quixos.org/quixos-toolchain/quixos-protocol.git"
+        "url": "https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos-protocol.git"
       }
     },
     "root": {

flake.nix

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

quixos.lock

@@ -1,9 +1,9 @@
 quixos-lock version 1 {
-  quixos source { repository "https://gitea.internal.quixos.org/quixos/quixos.git"; commit "8df8e463945ac3b8de8d893009c30f81ca85e968"; }
-  interface StandaloneView source { repository "https://repos.quixos.org/quixos-templates/interface-react-standalone-view.git"; commit "d015c9445a63c5b86ba648f89bcbf08999fe4c9f"; }
-  interface AgentThread source { repository "https://repos.quixos.org/quixos-templates/interface-agent-thread.git"; commit "91469fda1ba67abd797f8a8fc0321640fe4bc175"; }
-  interface Agent source { repository "https://repos.quixos.org/quixos-templates/interface-agent.git"; commit "15ec3569c6fbc511f923264c7a4b6ee3f751c84b"; }
-  interface AgentRequest source { repository "https://repos.quixos.org/quixos-templates/interface-agent-request.git"; commit "b2c5850562d9ea4524bca71eaabb2dcd749c227b"; }
-  interface AgentItem source { repository "https://repos.quixos.org/quixos-templates/interface-agent-item.git"; commit "7a2e3da4389cbabd74475d42108fa34b30506089"; }
-  interface AgentQuestion source { repository "https://repos.quixos.org/quixos-templates/interface-agent-question.git"; commit "d00844697f4260b3dc6c1735b40dc4e70b0b24c3"; }
+  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"; }
 }

src/http.ts

@@ -50,64 +50,6 @@ 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 = {
@@ -123,8 +65,7 @@ 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 setTimeout>;
-  private refreshNeeded = false;
+  private timer?: ReturnType<typeof setInterval>;
   private refreshing?: Promise<void>;
   private closed = false;
   constructor(
@@ -135,6 +76,9 @@ 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) => {
@@ -346,21 +290,6 @@ 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 {
@@ -371,7 +300,6 @@ 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 = "";
@@ -387,10 +315,6 @@ 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;
@@ -501,7 +425,7 @@ export class HttpThreadController implements ThreadController {
   close = () => {
     this.closed = true;
     this.abort.abort();
-    clearTimeout(this.timer);
+    clearInterval(this.timer);
     this.listeners.clear();
   };
 }