Release v0.6.0 startup reliability fixes

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>

Author: HaShiShark

.gitignore

@@ -1,4 +1,5 @@
 node_modules/
+.claude/
 release/
 python_dist/
 .venv/

electron/context-window.cjs

@@ -4,7 +4,8 @@ const fs = require('node:fs');
 const http = require('node:http');
 const path = require('node:path');
 
-const HOST = '127.0.0.1';
+const HOST = process.env.HASH_CONTEXT_HOST || 'localhost';
+const PROBE_HOST = process.env.HASH_CONTEXT_PROBE_HOST || (HOST === 'localhost' ? '127.0.0.1' : HOST);
 const BACKEND_PORT = 8765;
 const FRONTEND_PORT = 5174;
 const PROXY_PORT = 8787;
@@ -36,11 +37,11 @@ function writeLog(message) {
   );
 }
 
-function requestOk(port, pathname = '/') {
+function requestOk(port, pathname = '/', hostname = HOST) {
   return new Promise((resolve) => {
     const req = http.get(
       {
-        hostname: HOST,
+        hostname,
         port,
         path: pathname,
         timeout: 1000,
@@ -140,33 +141,66 @@ function startControlServer() {
   });
 }
 
-async function waitFor(port, pathname, label, timeoutMs = 30000) {
+async function waitFor(port, pathname, label, timeoutMs = 30000, hostname = HOST) {
   const startedAt = Date.now();
 
   while (Date.now() - startedAt < timeoutMs) {
-    if (await requestOk(port, pathname)) {
+    if (await requestOk(port, pathname, hostname)) {
       return;
     }
     await new Promise((resolve) => setTimeout(resolve, 300));
   }
 
-  throw new Error(`${label} did not become ready on ${HOST}:${port}.`);
+  throw new Error(`${label} did not become ready on ${hostname}:${port}.`);
 }
 
-function pythonCommand(root) {
+function pythonCandidateWorks(candidate) {
+  const result = spawnSync(
+    candidate.command,
+    [...candidate.args, '-c', 'import dotenv, zstandard'],
+    { encoding: 'utf8', timeout: 5000, windowsHide: true },
+  );
+  return result.status === 0;
+}
+
+function sourcePythonCandidates(root) {
   const localPython = process.platform === 'win32'
     ? path.join(root, '.venv', 'Scripts', 'python.exe')
     : path.join(root, '.venv', 'bin', 'python');
-  const fallbackPython = process.platform === 'win32' ? 'python' : 'python3';
-  return fs.existsSync(localPython) ? localPython : fallbackPython;
+  const candidates = [];
+
+  if (process.env.HASH_CONTEXT_PYTHON) {
+    candidates.push({ command: process.env.HASH_CONTEXT_PYTHON, args: [] });
+  }
+  if (fs.existsSync(localPython)) {
+    candidates.push({ command: localPython, args: [] });
+  }
+  if (process.platform === 'win32') {
+    candidates.push({ command: 'py', args: ['-3'] });
+    candidates.push({ command: 'python', args: [] });
+  } else {
+    candidates.push({ command: 'python3', args: [] });
+    candidates.push({ command: 'python', args: [] });
+  }
+
+  return candidates;
+}
+
+function pythonScriptCommand(root, scriptName) {
+  for (const candidate of sourcePythonCandidates(root)) {
+    if (pythonCandidateWorks(candidate)) {
+      return { command: candidate.command, args: [...candidate.args, scriptName] };
+    }
+  }
+  throw new Error('No usable Python runtime found. Run npm run setup:python or set HASH_CONTEXT_PYTHON to a Python with the project dependencies installed.');
 }
 
 function pythonServerCommand(root, scriptName, exeName) {
   const preferSource =
     process.env.HASH_CONTEXT_PREFER_SOURCE_SERVERS === '1' ||
     (!app.isPackaged && process.env.HASH_CONTEXT_USE_BUNDLED_PYTHON !== '1');
   if (preferSource) {
-    return { command: pythonCommand(root), args: [scriptName] };
+    return pythonScriptCommand(root, scriptName);
   }
 
   const candidates = process.platform === 'win32'
@@ -185,7 +219,7 @@ function pythonServerCommand(root, scriptName, exeName) {
     }
   }
 
-  return { command: pythonCommand(root), args: [scriptName] };
+  return pythonScriptCommand(root, scriptName);
 }
 
 function cleanEnv(extra = {}) {
@@ -200,7 +234,7 @@ function cleanEnv(extra = {}) {
 
 async function startBackend(root) {
   writeLog('checking backend');
-  if (await requestOk(BACKEND_PORT, '/api/init')) {
+  if (await requestOk(BACKEND_PORT, '/api/health', PROBE_HOST)) {
     writeLog('backend already running');
     return;
   }
@@ -228,13 +262,13 @@ async function startBackend(root) {
     writeLog(`[backend:error] ${chunk.toString().trim()}`);
   });
 
-  await waitFor(BACKEND_PORT, '/api/init', 'Backend');
+  await waitFor(BACKEND_PORT, '/api/health', 'Backend', 30000, PROBE_HOST);
   writeLog('backend ready');
 }
 
 async function startProxy(root) {
   writeLog('checking proxy');
-  if (await requestOk(PROXY_PORT, '/api/proxy/sessions')) {
+  if (await requestOk(PROXY_PORT, '/api/proxy/health', PROBE_HOST)) {
     writeLog('proxy already running');
     return;
   }
@@ -262,7 +296,7 @@ async function startProxy(root) {
     writeLog(`[proxy:error] ${chunk.toString().trim()}`);
   });
 
-  await waitFor(PROXY_PORT, '/api/proxy/sessions', 'Proxy');
+  await waitFor(PROXY_PORT, '/api/proxy/health', 'Proxy', 30000, PROBE_HOST);
   writeLog('proxy ready');
 }
 

package-lock.json

@@ -1,15 +1,15 @@
 {
   "name": "hash-context-codex-lab",
-  "version": "0.4.0",
+  "version": "0.6.0",
   "private": true,
   "description": "Local context proxy and workbench companion for Codex.",
   "author": "",
   "main": "electron/context-window.cjs",
   "scripts": {
     "start": "npm run start:backend",
-    "setup:python": "powershell -NoProfile -ExecutionPolicy Bypass -Command \"if (-not (Test-Path '.venv\\Scripts\\python.exe')) { python -m venv .venv }; .venv\\Scripts\\python.exe -m pip install --upgrade pip; .venv\\Scripts\\python.exe -m pip install -r requirements.txt\"",
-    "start:backend": "if exist .venv\\Scripts\\python.exe (.venv\\Scripts\\python.exe web_server.py) else (python web_server.py)",
-    "proxy": "if exist .venv\\Scripts\\python.exe (.venv\\Scripts\\python.exe proxy_server.py) else (python proxy_server.py)",
+    "setup:python": "powershell -NoProfile -ExecutionPolicy Bypass -Command \"if (-not (Test-Path '.venv\\Scripts\\python.exe')) { py -3 -m venv .venv }; .venv\\Scripts\\python.exe -m pip install --upgrade pip; .venv\\Scripts\\python.exe -m pip install -r requirements.txt\"",
+    "start:backend": "if exist .venv\\Scripts\\python.exe (.venv\\Scripts\\python.exe web_server.py) else (py -3 web_server.py)",
+    "proxy": "if exist .venv\\Scripts\\python.exe (.venv\\Scripts\\python.exe proxy_server.py) else (py -3 proxy_server.py)",
     "codex": "powershell -NoProfile -ExecutionPolicy Bypass -File scripts/codex-with-context.ps1",
     "ctx:install": "powershell -NoProfile -ExecutionPolicy Bypass -File scripts/codex-ctx-proxy.ps1 install",
     "ctx:proxy:on": "powershell -NoProfile -ExecutionPolicy Bypass -File scripts/codex-ctx-proxy.ps1 on",
@@ -28,7 +28,7 @@
     "dev": "vite --config react_app/vite.config.ts",
     "dev:react": "vite --config react_app/vite.config.ts",
     "typecheck": "tsc -p react_app/tsconfig.json --noEmit",
-    "test:compact-proxy": "if exist .venv\\Scripts\\python.exe (.venv\\Scripts\\python.exe scripts/test_compact_proxy.py) else (python scripts/test_compact_proxy.py)",
+    "test:compact-proxy": "if exist .venv\\Scripts\\python.exe (.venv\\Scripts\\python.exe scripts/test_compact_proxy.py) else (py -3 scripts/test_compact_proxy.py)",
     "build": "npm run build:react",
     "build:react": "vite build --config react_app/vite.config.ts",
     "build:python": "node scripts/build-python.mjs",
@@ -69,6 +69,7 @@
     },
     "files": [
       "electron/**/*",
+      "codex_context.py",
       "web_server.py",
       "main.py",
       "hash.html",

package.json

@@ -25,7 +25,8 @@
 )
 
 
-HOST = os.environ.get("HASH_CONTEXT_PROXY_HOST", "127.0.0.1")
+
+HOST = os.environ.get("HASH_CONTEXT_PROXY_HOST", os.environ.get("HASH_CONTEXT_HOST", "localhost"))
 PORT = int(os.environ.get("HASH_CONTEXT_PROXY_PORT", "8787"))
 OPENAI_UPSTREAM_BASE_URL = os.environ.get(
     "HASH_CONTEXT_OPENAI_UPSTREAM_BASE_URL",
@@ -939,7 +940,7 @@ def open_context_workbench(session_id: str) -> tuple[bool, str]:
     path = "/show"
     if session_id:
         path = f"{path}?session_id={urllib.parse.quote(session_id, safe='')}"
-    conn = http.client.HTTPConnection("127.0.0.1", CONTROL_PORT, timeout=2)
+    conn = http.client.HTTPConnection(os.environ.get("HASH_CONTEXT_HOST", "localhost"), CONTROL_PORT, timeout=2)
     try:
         conn.request("POST", path, body=b"", headers={"Content-Length": "0"})
         response = conn.getresponse()
@@ -1317,14 +1318,17 @@ def begin_request(self, session_id: str, body: dict[str, Any], headers: dict[str
                     merged_body_transcript,
                 )
                 if input_items_end_with_tool_output(body.get("input")):
-                    session.pending_transcript = with_running_assistant(source_transcript)
+                    session.edited_transcript = forwarded_transcript
+                    session.pending_transcript = with_running_assistant(forwarded_transcript)
+                    request_body["input"] = drop_unpaired_tool_items(transcript_to_input_items(forwarded_transcript))
+                    request_body.pop("previous_response_id", None)
                     session.status = "running"
                     session.last_error = ""
                     session.updated_at = utc_timestamp()
                     session.request_log.append(
                         {
                             "created_at": session.updated_at,
-                            "kind": "tool_output_passthrough",
+                            "kind": "override_tool_output_rewrite",
                             "headers": {key: value for key, value in headers.items() if key.lower().startswith("x-")},
                             "body": body,
                             "forwarded_body": request_body,
@@ -1728,6 +1732,17 @@ def latest_user_turn_tail(source_transcript: list[dict[str, Any]]) -> list[dict[
     return copy.deepcopy(source[start:])
 
 
+def latest_conversation_turn_tail(source_transcript: list[dict[str, Any]]) -> list[dict[str, Any]]:
+    source = clean_transcript(source_transcript)
+    for index in range(len(source) - 1, -1, -1):
+        if str(source[index].get("role") or "") == "user" and not is_initial_context_prefix_record(source[index]):
+            start = index
+            while start > 0 and is_initial_context_prefix_record(source[start - 1]):
+                start -= 1
+            return copy.deepcopy(source[start:])
+    return []
+
+
 def merge_override_transcript(
     edited_transcript: list[dict[str, Any]],
     mirrored_transcript: list[dict[str, Any]],
@@ -1748,7 +1763,7 @@ def merge_override_transcript(
     if base and base_prefix >= len(base):
         return append_non_duplicate(base, source[base_prefix:])
 
-    latest_tail = latest_user_turn_tail(source)
+    latest_tail = latest_user_turn_tail(source) or latest_conversation_turn_tail(source)
     if latest_tail:
         return append_non_duplicate(base, latest_tail)
     return base
@@ -1785,6 +1800,10 @@ def do_OPTIONS(self) -> None:
 
     def do_GET(self) -> None:
         parsed = urllib.parse.urlparse(self.path)
+        if parsed.path == "/api/proxy/health":
+            self._send_json({"ok": True})
+            return
+
         proxy_log(
             "incoming get "
             f"path={parsed.path} "

proxy_server.py

@@ -26,6 +26,8 @@ import { normalizeConversation, normalizeReasoningOptions } from './utils';
 const DEMO_SESSION_ID = 'hash-context-preview';
 const LIVE_REFRESH_IDLE_MS = 1600;
 const LIVE_REFRESH_RUNNING_MS = 800;
+const PENDING_CONTEXT_REFRESH_MS = 200;
+const PENDING_CONTEXT_REFRESH_MAX_MS = 5000;
 const LOCAL_EDIT_GRACE_MS = 1500;
 const MIN_WORKBENCH_WINDOW_WIDTH = 760;
 const MIN_WORKBENCH_WINDOW_HEIGHT = 520;
@@ -55,6 +57,19 @@ function isProxyBusy(status?: string, isRunning?: boolean): boolean {
   return Boolean(isRunning || status === 'running' || status === 'compacting');
 }
 
+function hasPendingAssistantMessage(messages: MessageRecord[]): boolean {
+  const lastAssistant = [...messages].reverse().find((message) => message.role === 'an');
+  if (!lastAssistant) {
+    return false;
+  }
+
+  return Boolean(
+    lastAssistant.pending
+    || (!lastAssistant.text.trim() && lastAssistant.blocks.some((block) => block.kind === 'thinking'))
+    || lastAssistant.blocks.some((block) => block.kind === 'reasoning' && block.status === 'streaming'),
+  );
+}
+
 type LoadInitOptions = {
   silent?: boolean;
   targetSessionId?: string;
@@ -530,6 +545,28 @@ export default function WorkbenchWindow() {
   );
 
   const currentPendingRestore = sessionId ? pendingRestores[sessionId] || null : null;
+  const hasPendingAssistant = useMemo(() => hasPendingAssistantMessage(messages), [messages]);
+
+  useEffect(() => {
+    if (!hasPendingAssistant) {
+      return undefined;
+    }
+
+    const startedAt = Date.now();
+    const intervalId = window.setInterval(() => {
+      if (Date.now() - startedAt >= PENDING_CONTEXT_REFRESH_MAX_MS) {
+        window.clearInterval(intervalId);
+        return;
+      }
+      if (Date.now() - lastLocalEditAtRef.current < LOCAL_EDIT_GRACE_MS) {
+        return;
+      }
+
+      void loadInit({ silent: true });
+    }, PENDING_CONTEXT_REFRESH_MS);
+
+    return () => window.clearInterval(intervalId);
+  }, [hasPendingAssistant, loadInit]);
 
   const commitContextConversation = useCallback(
     async (

react_app/src/WorkbenchWindow.tsx

@@ -172,11 +172,12 @@ function areScrollMetricsEqual(left: ScrollMetrics, right: ScrollMetrics) {
 function canExpandMessage(record: MessageRecord, previewText: string, isPreviewTruncated: boolean) {
   void previewText;
   const textValue = record.text || '';
+  const trimmedTextValue = textValue.trim();
   const hasStructuredContent = Boolean(
     record.attachments.length
     || record.toolEvents.length
     || record.blocks.length > 1
-    || /\r?\n/.test(textValue),
+    || /\r?\n/.test(trimmedTextValue),
   );
 
   return hasStructuredContent || isPreviewTruncated;

react_app/src/components/ContextMapSidebar.tsx

@@ -22,11 +22,11 @@ export default defineConfig(({ command }) => ({
     },
     proxy: {
       '/api/proxy/sessions': {
-        target: 'http://127.0.0.1:8787',
+        target: 'http://localhost:8787',
         changeOrigin: true,
       },
       '/api': {
-        target: 'http://127.0.0.1:8765',
+        target: 'http://localhost:8765',
         changeOrigin: true,
       },
     },