even-terminal updates

Even Realities released a patch for even-terminal that adds passive mirroring of external Claude Code sessions. The update allows the terminal to tail session JSONL files and broadcast entries over SSE, enabling users to view Claude Code sessions initiated outside the Even Terminal app directly in their glasses.

| Patch: live-mirror external Claude Code sessions in even-terminal | | | @evenrealities/even-terminal only streams sessions it drives itself via the | | | Agent SDK. This patch adds passive mirroring: when you open a session in the | | | app/glasses, it tails that session's ~/.claude/projects/ /<id .jsonl which | | | the claude process in your own terminal appends to live and broadcasts each | | | new entry over SSE in the same message shapes the UI already renders. | | | Applies to dist/ of a global install $ npm root -g /@evenrealities/even-terminal/dist . | | | Restart even-terminal after applying. Note: dist edits are wiped on reinstall. | | | --- | | | 1. NEW FILE — dist/claude/tail.js | | | js | | | // Live-mirror tailer for external Claude Code sessions. | | | import { existsSync, readdirSync, statSync, openSync, readSync, closeSync, watch } from "node:fs"; | | | import { join } from "node:path"; | | | import { homedir } from "node:os"; | | | import { summarizeClaudeToolCall } from "./summarize.js"; | | | import { claudeSessionStatus } from "./provider.js"; | | | import { pushMessage, broadcast, sessionHasClients } from "../routes/events.js"; | | | // session ids Even Terminal is itself driving — tailer stays quiet for these | | | export const drivenSessions = new Set ; | | | const tails = new Map ; | | | function findSessionFile sessionId { | | | const claudeDir = join homedir , ".claude", "projects" ; | | | if existsSync claudeDir return null; | | | for const dir of readdirSync claudeDir { | | | const p = join claudeDir, dir, ${sessionId}.jsonl ; | | | if existsSync p return p; | | | } | | | return null; | | | } | | | function emit sessionId, msg { | | | const id = pushMessage sessionId, msg ; | | | broadcast sessionId, msg, id ; | | | } | | | / Convert one Claude Code jsonl entry into SSE display messages. / | | | function entryToMessages entry, t { | | | const out = ; | | | if entry || typeof entry == "object" return out; | | | if entry.type === "assistant" { | | | const content = entry.message?.content; | | | if Array.isArray content return out; | | | for const block of content { | | | if block.type === "text" && block.text?.trim { | | | out.push { type: "status", state: "text start", sessionId: t.sessionId } ; | | | out.push { type: "text delta", text: block.text } ; | | | out.push { type: "status", state: "text end", sessionId: t.sessionId } ; | | | } else if block.type === "thinking" && typeof block.thinking === "string" && block.thinking.trim { | | | out.push { type: "status", state: "think start", sessionId: t.sessionId } ; | | | out.push { type: "text delta", text: block.thinking } ; | | | out.push { type: "status", state: "think end", sessionId: t.sessionId } ; | | | } else if block.type === "tool use" { | | | t.pending.set block.id, { name: block.name, input: block.input } ; | | | out.push { type: "tool start", name: block.name, toolId: block.id } ; | | | } | | | } | | | } else if entry.type === "user" { | | | const content = entry.message?.content; | | | if typeof content === "string" { | | | if content.trim && content.includes "Request interrupted by user" | | | out.push { type: "user prompt", text: content } ; | | | } else if Array.isArray content { | | | for const block of content { | | | if block.type === "tool result" { | | | const toolId = block.tool use id; | | | const pending = t.pending.get toolId ; | | | let output; | | | if typeof block.content === "string" output = block.content; | | | else if Array.isArray block.content | | | output = block.content.filter b = b.type === "text" .map b = b.text .join "\n" ; | | | out.push { | | | type: "tool end", | | | name: pending?.name ?? "", | | | toolId, | | | summary: pending ? summarizeClaudeToolCall pending.name, pending.input : "", | | | detail: { input: pending?.input, output }, | | | } ; | | | t.pending.delete toolId ; | | | } else if block.type === "text" && block.text?.trim { | | | out.push { type: "user prompt", text: block.text } ; | | | } | | | } | | | } | | | } else if entry.type === "result" { | | | out.push { | | | type: "result", | | | success: entry.subtype === "success", | | | text: entry.result ?? "", | | | sessionId: entry.session id ?? t.sessionId, | | | costUsd: entry.total cost usd ?? 0, | | | provider: "claude", | | | turns: entry.num turns ?? 0, | | | durationMs: entry.duration ms ?? 0, | | | inputTokens: 0, | | | outputTokens: 0, | | | } ; | | | } | | | return out; | | | } | | | function processFile sessionId { | | | const t = tails.get sessionId ; | | | if t return; | | | let size; | | | try { size = statSync t.file .size; } catch { return; } | | | if size < t.offset { t.offset = 0; t.remainder = ""; } // truncated/rotated | | | if size === t.offset return; | | | let chunk; | | | try { | | | const fd = openSync t.file, "r" ; | | | try { | | | const buf = Buffer.alloc size - t.offset ; | | | readSync fd, buf, 0, buf.length, t.offset ; | | | chunk = buf.toString "utf8" ; | | | } finally { closeSync fd ; } | | | } catch { return; } | | | t.offset = size; | | | const data = t.remainder + chunk; | | | const lines = data.split "\n" ; | | | t.remainder = lines.pop ?? ""; // keep trailing partial line | | | if drivenSessions.has sessionId return; // ET drives it → SDK already emits | | | for const line of lines { | | | const trimmed = line.trim ; | | | if trimmed continue; | | | let entry; | | | try { entry = JSON.parse trimmed ; } catch { continue; } | | | if entry.uuid { | | | if t.seen.has entry.uuid continue; | | | t.seen.add entry.uuid ; | | | } | | | for const m of entryToMessages entry, t emit sessionId, m ; | | | } | | | const status = claudeSessionStatus sessionId ; | | | if status == t.lastStatus { | | | t.lastStatus = status; | | | emit sessionId, { type: "status", state: status, sessionId } ; | | | } | | | } | | | export function startTail sessionId { | | | if sessionId || tails.has sessionId return; | | | const file = findSessionFile sessionId ; | | | if file return; | | | let size = 0; | | | try { size = statSync file .size; } catch {} | | | const t = { | | | sessionId, file, | | | offset: size, // start at EOF: stream only NEW activity | | | remainder: "", pending: new Map , seen: new Set , | | | lastStatus: null, watcher: null, timer: null, | | | }; | | | tails.set sessionId, t ; | | | const status = claudeSessionStatus sessionId ; | | | t.lastStatus = status; | | | emit sessionId, { type: "status", state: status, sessionId } ; | | | try { t.watcher = watch file, { persistent: false }, = processFile sessionId ; } catch {} | | | t.timer = setInterval = processFile sessionId , 1000 ; // poll fallback | | | console.log tail Mirroring external session=${sessionId} from offset=${size} ; | | | } | | | export function stopTail sessionId { | | | const t = tails.get sessionId ; | | | if t return; | | | if t.watcher { try { t.watcher.close ; } catch {} } | | | if t.timer clearInterval t.timer ; | | | tails.delete sessionId ; | | | console.log tail Stopped mirroring session=${sessionId} ; | | | } | | | export function stopTailIfIdle sessionId { | | | if sessionHasClients sessionId stopTail sessionId ; | | | } | | | | | | --- | | | 2. dist/routes/events.js | | | diff | | | import { Router } from "express"; | | | import { writeToLogFile } from "../logger.js"; | | | +import { startTail, stopTailIfIdle } from "../claude/tail.js"; | | | @@ in router.get "/events", ... @@ | | | s.clients.add res ; | | | console.log sse Client connected session=${sessionId} session clients: ${s.clients.size}, total: ${clientCount } ; | | | + // Mirror an externally-running Claude session's live jsonl output over SSE. | | | + startTail sessionId ; | | | @@ req.on "close", ... @@ | | | clearInterval heartbeat ; | | | s.clients.delete res ; | | | + stopTailIfIdle sessionId ; | | | console.log sse Client disconnected total: ${clientCount } ; | | | | | | --- | | | 3. dist/claude/session.js dedup: stay quiet for ET-driven sessions | | | diff | | | import { query } from "@anthropic-ai/claude-agent-sdk"; | | | import { existsSync } from "node:fs"; | | | +import { drivenSessions } from "./tail.js"; | | | @@ async run prompt @@ | | | this. busy = true; | | | this.busyEmitted = false; | | | this.currentBlockType = null; | | | + this.onIdReady sid = drivenSessions.add sid ; | | | this.turnStartMs = Date.now ; | | | @@ query finally block @@ | | | this. busy = false; | | | + if this.sessionId | | | + drivenSessions.delete this.sessionId ; | | | this.queryHandle = null; | | | | | | --- | | | 4. Re-apply script — ~/.even-terminal/apply-tail-patch.mjs | | | Run after upgrading/reinstalling even-terminal npm wipes dist/ edits , then | | | restart even-terminal: | | | | | | node ~/.even-terminal/apply-tail-patch.mjs | | | | | | Idempotent — safe to run repeatedly. | | | js | | | /usr/bin/env node | | | // Re-applies the "live-mirror external Claude sessions" patch to a globally | | | // installed @evenrealities/even-terminal. Safe to run repeatedly. | | | import { execSync } from "node:child process"; | | | import { readFileSync, writeFileSync, existsSync } from "node:fs"; | | | import { join } from "node:path"; | | | const root = execSync "npm root -g" .toString .trim ; | | | const pkg = join root, "@evenrealities", "even-terminal" ; | | | if existsSync pkg { | | | console.error even-terminal not found under ${root} ; | | | process.exit 1 ; | | | } | | | const dist = join pkg, "dist" ; | | | // Full source of dist/claude/tail.js see section 1 of this gist . | | | // Paste the tail.js body between the backticks below. | | | const TAIL JS = <<< PASTE dist/claude/tail.js SOURCE HERE ; | | | function patchFile path, edits, marker { | | | let src = readFileSync path, "utf8" ; | | | if src.includes marker { | | | console.log already patched: ${path} ; | | | return; | | | } | | | for const find, replace of edits { | | | if src.includes find | | | throw new Error anchor not found in ${path}:\n${find} ; | | | src = src.replace find, replace ; | | | } | | | writeFileSync path, src ; | | | console.log patched: ${path} ; | | | } | | | // 1. tail.js | | | writeFileSync join dist, "claude", "tail.js" , TAIL JS ; | | | console.log wrote: ${join dist, "claude", "tail.js" } ; | | | // 2. events.js | | | patchFile join dist, "routes", "events.js" , | | | | | | import { Router } from "express";\nimport { writeToLogFile } from "../logger.js"; , | | | import { Router } from "express";\nimport { writeToLogFile } from "../logger.js";\nimport { startTail, stopTailIfIdle } from "../claude/tail.js"; , | | | , | | | | | | s.clients.add res ;\n console.log \ sse Client connected session=\${sessionId} session clients: \${s.clients.size}, total: \${clientCount } \ ; , | | | s.clients.add res ;\n console.log \ sse Client connected session=\${sessionId} session clients: \${s.clients.size}, total: \${clientCount } \ ;\n // Mirror an externally-running Claude session's live jsonl output over SSE.\n startTail sessionId ; , | | | , | | | | | | clearInterval heartbeat ;\n s.clients.delete res ;\n console.log \ sse Client disconnected total: \${clientCount } \ ; , | | | clearInterval heartbeat ;\n s.clients.delete res ;\n stopTailIfIdle sessionId ;\n console.log \ sse Client disconnected total: \${clientCount } \ ; , | | | , | | | , ../claude/tail.js ; | | | // 3. session.js | | | patchFile join dist, "claude", "session.js" , | | | | | | import { query } from "@anthropic-ai/claude-agent-sdk";\nimport { existsSync } from "node:fs"; , | | | import { query } from "@anthropic-ai/claude-agent-sdk";\nimport { existsSync } from "node:fs";\nimport { drivenSessions } from "./tail.js"; , | | | , | | | | | | this. busy = true;\n this.busyEmitted = false;\n this.currentBlockType = null;\n this.turnStartMs = Date.now ; , | | | this. busy = true;\n this.busyEmitted = false;\n this.currentBlockType = null;\n this.onIdReady sid = drivenSessions.add sid ;\n this.turnStartMs = Date.now ; , | | | , | | | | | | this. busy = false;\n this.queryHandle = null; , | | | this. busy = false;\n if this.sessionId \n drivenSessions.delete this.sessionId ;\n this.queryHandle = null; , | | | , | | | , drivenSessions ; | | | console.log "Done. Restart even-terminal for changes to take effect." ; | | | | | | Note: assign TAIL JS to the section-1 tail.js source e.g. a template | | | literal, or readFileSync it from a saved copy . In the working version on | | | disk it's embedded inline. |