build codex viewer direct proxy ui

Author: joyang1

.gitignore

@@ -0,0 +1,7 @@
+node_modules
+.npm-cache
+.DS_Store
+npm-debug.log*
+coverage
+*.tgz
+.codex-viewer/mitm-ca/

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2026
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

bin/codex-viewer.js

@@ -0,0 +1,98 @@
+#!/usr/bin/env node
+
+import process from 'node:process';
+import path from 'node:path';
+import { Command } from 'commander';
+import { startServer } from '../src/live-server.js';
+
+const program = new Command();
+
+program
+  .name('codex-viewer')
+  .description('Direct-proxy web viewer for Codex CLI')
+  .version('0.4.0');
+
+program
+  .option('-p, --port <port>', 'server port', '3789')
+  .option('-H, --host <host>', 'server host', '127.0.0.1')
+  .option('--codex-bin <path>', 'codex executable path', 'codex')
+  .option('--max-events <n>', 'max buffered structured events', '3000')
+  .option('--proxy-port <port>', 'direct proxy listen port (0 = random free port)', '0')
+  .option('--proxy-max-body <bytes>', 'max captured body bytes per request/response', String(512 * 1024))
+  .option('--proxy-max-ws <bytes>', 'max captured websocket frame bytes', String(128 * 1024))
+  .option('--proxy-max-json <bytes>', 'max parsed json bytes per payload', String(256 * 1024))
+  .option('-C, --cd <dir>', 'default working directory')
+  .action(async (options) => {
+    const port = Number.parseInt(options.port, 10);
+    if (!Number.isFinite(port) || port <= 0) {
+      throw new Error(`Invalid port: ${options.port}`);
+    }
+
+    const host = String(options.host || '127.0.0.1');
+    const workdir = options.cd ? path.resolve(String(options.cd)) : process.cwd();
+    const maxEvents = Number.parseInt(String(options.maxEvents || '3000'), 10);
+    if (!Number.isFinite(maxEvents) || maxEvents < 100) {
+      throw new Error(`Invalid max-events: ${options.maxEvents}`);
+    }
+
+    const proxyPort = Number.parseInt(String(options.proxyPort || '0'), 10);
+    if (!Number.isFinite(proxyPort) || proxyPort < 0) {
+      throw new Error(`Invalid proxy-port: ${options.proxyPort}`);
+    }
+
+    const proxyMaxBodyBytes = Number.parseInt(String(options.proxyMaxBody || 512 * 1024), 10);
+    if (!Number.isFinite(proxyMaxBodyBytes) || proxyMaxBodyBytes < 4096) {
+      throw new Error(`Invalid proxy-max-body: ${options.proxyMaxBody}`);
+    }
+
+    const proxyMaxWsBytes = Number.parseInt(String(options.proxyMaxWs || 128 * 1024), 10);
+    if (!Number.isFinite(proxyMaxWsBytes) || proxyMaxWsBytes < 1024) {
+      throw new Error(`Invalid proxy-max-ws: ${options.proxyMaxWs}`);
+    }
+
+    const proxyMaxJsonBytes = Number.parseInt(String(options.proxyMaxJson || 256 * 1024), 10);
+    if (!Number.isFinite(proxyMaxJsonBytes) || proxyMaxJsonBytes < 1024) {
+      throw new Error(`Invalid proxy-max-json: ${options.proxyMaxJson}`);
+    }
+
+    const service = await startServer({
+      host,
+      port,
+      options: {
+        codexBin: options.codexBin,
+        workdir,
+        maxEvents,
+        proxy: true,
+        proxyPort,
+        proxyMaxBodyBytes,
+        proxyMaxWsBytes,
+        proxyMaxJsonBytes
+      }
+    });
+
+    console.log(`codex-viewer: http://${host}:${port}`);
+
+    await new Promise((resolve) => {
+      let closed = false;
+
+      async function shutdown() {
+        if (closed) {
+          return;
+        }
+
+        closed = true;
+        service.stopRunner();
+        service.closeSockets();
+        await service.stopProxy?.();
+        service.server.close(() => resolve());
+      }
+
+      process.on('SIGINT', shutdown);
+      process.on('SIGTERM', shutdown);
+    });
+  });
+
+program.parseAsync(process.argv).catch((error) => {
+  console.error(`codex-viewer error: ${error.message}`);
+  process.exitCode = 1;
+});