fix: terminals sharing again

Author: Vierre3

app/components/TerminalPanel.vue

@@ -124,7 +124,7 @@ watch(isSharing, (sharing) => {
     }
 });
 
-watch(sharedTerminals, (list) => {
+watch(() => sharedTerminals.value, (list) => {
     if (!isSharing.value) return;
     // Add new terminals we don't have yet
     for (const t of list) {

app/composables/useShare.ts

@@ -28,6 +28,8 @@ const sharedTerminals = ref<{id: string, name: string}[]>([]);
 let controlWs: WebSocket | null = null;
 // Relay WebSocket (desktop host only — forwards guest requests)
 let relayWs: WebSocket | null = null;
+// Buffered messages waiting for relay WS to be ready
+let relayMsgQueue: any[] = [];
 // Remote server URL (desktop host sharing via Railway)
 let remoteServerUrl: string | null = null;
 
@@ -249,6 +251,13 @@ export function useShare() {
         relayWs.onmessage = (ev) => {
             try {
                 const msg = JSON.parse(ev.data);
+                if (msg.type === "auth-ok") {
+                    // Flush any messages that were queued before the relay was ready
+                    const queued = relayMsgQueue.splice(0);
+                    for (const m of queued) {
+                        relayWs?.send(JSON.stringify(m));
+                    }
+                }
                 handleRelayMessage(msg);
             } catch {}
         };
@@ -309,7 +318,12 @@ export function useShare() {
     }
 
     function sendRelayMessage(msg: any) {
-        relayWs?.send(JSON.stringify(msg));
+        if (relayWs?.readyState === WebSocket.OPEN) {
+            relayWs.send(JSON.stringify(msg));
+        } else {
+            // Buffer until relay WS is connected and authenticated
+            relayMsgQueue.push(msg);
+        }
     }
 
     // --- Shared terminal WebSocket URL ---
@@ -332,6 +346,7 @@ export function useShare() {
 
         if (controlWs) { controlWs.close(); controlWs = null; }
         if (relayWs) { relayWs.close(); relayWs = null; }
+        relayMsgQueue = [];
         remoteServerUrl = null;
     }
 

server/utils/share.ts

@@ -255,17 +255,24 @@ export function resolveRelayResponse(reqId: string, status: number, body: any):
 // --- Shared terminal peer registry ---
 // Centralized here to avoid circular imports between _share-terminal.ts and _share-relay.ts
 
+const MAX_TERMINAL_BUFFER = 50 * 1024; // 50KB rolling replay buffer per terminal
+
 interface SharedTerminalEntry {
     peers: Set<Peer>;
+    outputBuffer: string; // rolling buffer for late subscribers
 }
 const sharedTerminals = new Map<string, SharedTerminalEntry>();
 
 export function registerTerminalPeer(terminalId: string, peer: Peer): void {
     let entry = sharedTerminals.get(terminalId);
     if (!entry) {
-        entry = { peers: new Set() };
+        entry = { peers: new Set(), outputBuffer: "" };
         sharedTerminals.set(terminalId, entry);
     }
+    // Replay buffered output to late subscriber
+    if (entry.outputBuffer.length > 0) {
+        try { peer.send(JSON.stringify({ type: "output", terminalId, data: entry.outputBuffer })); } catch {}
+    }
     entry.peers.add(peer);
 }
 
@@ -280,6 +287,13 @@ export function unregisterTerminalPeer(terminalId: string, peer: Peer): void {
 export function broadcastToTerminalPeers(terminalId: string, message: any): void {
     const entry = sharedTerminals.get(terminalId);
     if (!entry) return;
+    // Accumulate output in rolling replay buffer for late subscribers
+    if (message.type === "output" && typeof message.data === "string") {
+        entry.outputBuffer += message.data;
+        if (entry.outputBuffer.length > MAX_TERMINAL_BUFFER) {
+            entry.outputBuffer = entry.outputBuffer.slice(entry.outputBuffer.length - MAX_TERMINAL_BUFFER);
+        }
+    }
     const msg = JSON.stringify(message);
     for (const peer of entry.peers) {
         try { peer.send(msg); } catch {}