multipleof4/devsune
1
0
Fork 0
mirror of https://github.com/multipleof4/devsune.git synced 2026-01-14 00:17:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update index.html

Browse Source
This commit is contained in:
multipleof4
2025-08-23 23:54:37 -07:00
committed by GitHub
parent f5f847d8c7
commit 7d09becaf2
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
index.html
View File

@@ -211,7 +211,7 @@ window.addEventListener('resize',()=>{hideHistoryMenu();hideSuneMenu()})
init() init()
</script> </script>
<script> <script>
const WS_URL = "wss://orp.awww.workers.dev/ws"; // fixed for your Worker domain const WS_URL = "wss://orp.awww.workers.dev/ws";
class SingleRunWS { class SingleRunWS {
constructor({ payload, onDelta }) { constructor({ payload, onDelta }) {
@@ -223,15 +223,18 @@ class SingleRunWS {
this._vis = this._onVisibility.bind(this); this._vis = this._onVisibility.bind(this);
} }
start() { start() {
window.SUNE.log("WS start");
this._connect("begin"); this._connect("begin");
document.addEventListener("visibilitychange", this._vis, { passive: true }); document.addEventListener("visibilitychange", this._vis, { passive: true });
} }
abort() { abort() {
window.SUNE.log("WS abort");
this.done = true; this.done = true;
try { this.ws?.close(); } catch {} try { this.ws?.close(); } catch {}
document.removeEventListener("visibilitychange", this._vis); document.removeEventListener("visibilitychange", this._vis);
} }
_onVisibility() { _onVisibility() {
window.SUNE.log(`WS visibility: ${document.visibilityState}`);
if (this.done) return; if (this.done) return;
if (document.visibilityState === "hidden") { if (document.visibilityState === "hidden") {
try { this.ws?.close(); } catch {} try { this.ws?.close(); } catch {}
@@ -241,8 +244,10 @@ class SingleRunWS {
} }
_connect(mode) { _connect(mode) {
if (this.done) return; if (this.done) return;
window.SUNE.log(`WS connect [${mode}]`);
this.ws = new WebSocket(WS_URL); this.ws = new WebSocket(WS_URL);
this.ws.onopen = () => { this.ws.onopen = () => {
window.SUNE.log("WS open");
if (mode === "begin") { if (mode === "begin") {
this.ws.send(JSON.stringify({ type: "begin", ...this.payload, after: this.lastSeq })); this.ws.send(JSON.stringify({ type: "begin", ...this.payload, after: this.lastSeq }));
} else { } else {
@@ -250,6 +255,7 @@ class SingleRunWS {
} }
}; };
this.ws.onmessage = (e) => { this.ws.onmessage = (e) => {
window.SUNE.log(`WS msg: ${e.data.slice(0,80)}`);
let m; try { m = JSON.parse(e.data); } catch { return; } let m; try { m = JSON.parse(e.data); } catch { return; }
if (m.type === "delta" && typeof m.seq === "number" && m.seq > this.lastSeq) { if (m.type === "delta" && typeof m.seq === "number" && m.seq > this.lastSeq) {
this.lastSeq = m.seq; this.lastSeq = m.seq;
@@ -264,6 +270,8 @@ class SingleRunWS {
this.abort(); this.abort();
} }
}; };
this.ws.onerror = (e) => window.SUNE.log("WS error" + (e?.message?": "+e.message:""));
this.ws.onclose = () => window.SUNE.log("WS close");
} }
} }
@@ -283,7 +291,7 @@ async function askViaDOStreaming(onDelta) {
runner.start(); runner.start();
return { ok: true }; return { ok: true };
} }
// keep your existing call site unchanged
askOpenRouterStreaming = askViaDOStreaming; askOpenRouterStreaming = askViaDOStreaming;
</script> </script>
</body> </body>