Merge pull request #190 from ks6088ts-labs/feature/issue-189_codex-cli

add CLI runner app

Author: ks6088ts

docs/references.md

@@ -114,3 +114,35 @@
 ### [Langfuse](https://langfuse.com/)
 
 - [Cookbook: LangGraph Integration](https://langfuse.com/guides/cookbook/integration_langgraph)
+
+### [Codex CLI](https://github.com/openai/codex)
+
+- Azure OpenAI で Codex CLI を使う: [Codex Azure OpenAI Integration: Fast & Secure Code Development](https://devblogs.microsoft.com/all-things-azure/codex-azure-openai-integration-fast-secure-code-development/)
+- [OpenAI Codex CLI のクイックスタート](https://note.com/npaka/n/n7b6448020250)
+
+```shell
+# Install Codex CLI
+npm install -g @openai/codex
+
+# Generate shell completion scripts
+codex completion zsh
+
+# Dump configurations
+cat ~/.codex/config.toml
+
+# Set up environment variables
+export AZURE_OPENAI_API_KEY="<your-api-key>"
+
+# MCP server management: https://qiita.com/tomada/items/2eb8d5b5173a4d70b287
+## Add a global MCP server entry
+codex mcp add context7   -- npx -y @upstash/context7-mcp
+codex mcp add playwright -- npx -y @playwright/mcp@latest
+codex mcp add mslearn -- npx -y mcp-remote "https://learn.microsoft.com/api/mcp" # ref. https://zenn.dev/yanskun/articles/codex-remote-mcp
+## Remove MCP server
+codex mcp remove context7
+## List MCP servers
+codex mcp list
+
+# Run Codex non-interactively
+codex exec "Playwright MCP を使って Yahoo リアルタイム検索の上位キーワードをまとめて"
+```

template_langgraph/services/streamlits/pages/cli_runner.py

@@ -0,0 +1,214 @@
+"""Simple Streamlit runner for executing shell commands and tailing their output."""
+
+from __future__ import annotations
+
+import html
+import subprocess
+import threading
+import time
+from datetime import datetime
+from queue import Empty, Queue
+
+import streamlit as st
+
+LogEntry = tuple[str, str]
+
+
+LOG_COLORS = {
+    "stdout": "#e8f5e9",
+    "stderr": "#ff7961",
+}
+LOG_FONT_FAMILY = "SFMono-Regular,Consolas,Menlo,monospace"
+MAX_LOG_LINES = 4000
+
+
+def _init_state() -> None:
+    if "cli_runner" not in st.session_state:
+        st.session_state.cli_runner = {
+            "command": "",
+            "process": None,
+            "queue": Queue(),
+            "logs": [],
+            "start_time": None,
+            "returncode": None,
+            "auto_refresh": True,
+        }
+
+
+def _stream_reader(stream, label: str, buffer: Queue) -> None:
+    for raw_line in iter(stream.readline, ""):
+        buffer.put((label, raw_line.rstrip("\n")))
+    stream.close()
+
+
+def _start_process(command: str) -> None:
+    runner = st.session_state.cli_runner
+    if runner.get("process") and runner["process"].poll() is None:
+        st.sidebar.warning("他のプロセスが実行中です。停止してから再度実行してください。")
+        return
+
+    try:
+        process = subprocess.Popen(
+            command,
+            shell=True,
+            stdout=subprocess.PIPE,
+            stderr=subprocess.PIPE,
+            text=True,
+            bufsize=1,
+            universal_newlines=True,
+        )
+    except OSError as exc:
+        st.sidebar.error(f"プロセスを起動できませんでした: {exc}")
+        return
+
+    runner.update(
+        {
+            "command": command,
+            "process": process,
+            "queue": Queue(),
+            "logs": [],
+            "start_time": datetime.now(),
+            "returncode": None,
+        }
+    )
+
+    if process.stdout:
+        stdout_thread = threading.Thread(
+            target=_stream_reader,
+            args=(process.stdout, "stdout", runner["queue"]),
+            daemon=True,
+        )
+        stdout_thread.start()
+
+    if process.stderr:
+        stderr_thread = threading.Thread(
+            target=_stream_reader,
+            args=(process.stderr, "stderr", runner["queue"]),
+            daemon=True,
+        )
+        stderr_thread.start()
+
+
+def _drain_queue() -> None:
+    runner = st.session_state.cli_runner
+    queue: Queue | None = runner.get("queue")
+    if queue is None:
+        return
+    logs: list[LogEntry] = runner.get("logs", [])
+
+    while True:
+        try:
+            entry = queue.get_nowait()
+        except Empty:
+            break
+        logs.append(entry)
+        if len(logs) > MAX_LOG_LINES:
+            logs.pop(0)
+
+    runner["logs"] = logs
+
+
+def _terminate_process() -> None:
+    runner = st.session_state.cli_runner
+    process = runner.get("process")
+    if not process or process.poll() is not None:
+        return
+
+    process.terminate()
+    try:
+        process.wait(timeout=5)
+    except subprocess.TimeoutExpired:
+        process.kill()
+    runner["returncode"] = process.poll()
+
+
+def _render_logs(logs: list[LogEntry]) -> None:
+    if not logs:
+        st.info("まだ出力はありません。コマンドを実行してください。")
+        return
+
+    log_container = st.container()
+    lines = []
+    for stream_label, line in logs:
+        color = LOG_COLORS.get(stream_label, "#e0e0e0")
+        safe_line = html.escape(line)
+        lines.append(
+            f"<div style='color:{color};font-family:{LOG_FONT_FAMILY};white-space:pre-wrap;margin:0;'>{safe_line}</div>"
+        )
+    log_container.markdown("\n".join(lines), unsafe_allow_html=True)
+
+
+_init_state()
+runner = st.session_state.cli_runner
+process = runner.get("process")
+is_running = bool(process) and process.poll() is None
+
+st.title("CLI Runner")
+
+with st.sidebar:
+    st.header("Command Settings")
+    st.text("CLIコマンドを指定して実行します。")
+    st.session_state.cli_runner["command"] = st.text_input(
+        label="Command",
+        key="cli_runner_command_input",
+        value="codex exec --help",
+        placeholder="e.g. ls -la; while true; do date +%s; sleep 1; done",
+    )
+
+    run_clicked = st.button("Run", use_container_width=True)
+    stop_clicked = st.button(
+        "Stop",
+        use_container_width=True,
+        disabled=not is_running,
+    )
+
+    runner["auto_refresh"] = st.checkbox(
+        label="Auto refresh (1s)",
+        value=runner.get("auto_refresh", True),
+    )
+
+    if st.button("Clear Logs", use_container_width=True):
+        runner["logs"] = []
+
+if run_clicked:
+    command = st.session_state.cli_runner.get("command", "").strip()
+    if not command:
+        st.sidebar.error("コマンドを入力してください。")
+    else:
+        _start_process(command)
+
+if stop_clicked:
+    _terminate_process()
+
+_drain_queue()
+
+process = runner.get("process")
+is_running = bool(process) and process.poll() is None
+
+if process and not is_running and runner.get("returncode") is None:
+    runner["returncode"] = process.poll()
+
+status_placeholder = st.empty()
+if is_running:
+    status_placeholder.info("プロセス実行中です…")
+else:
+    return_code = runner.get("returncode")
+    if return_code is None:
+        status_placeholder.info("プロセスを待機しています。")
+    elif return_code == 0:
+        status_placeholder.success("プロセスが正常終了しました。")
+    else:
+        status_placeholder.error(f"プロセスが終了コード {return_code} で終了しました。")
+
+if runner.get("start_time"):
+    if is_running:
+        elapsed = datetime.now() - runner["start_time"]
+        st.caption(f"Started at {runner['start_time'].strftime('%Y-%m-%d %H:%M:%S')} | Elapsed: {elapsed}")
+    else:
+        st.caption(f"Started at {runner['start_time'].strftime('%Y-%m-%d %H:%M:%S')}")
+
+_render_logs(runner.get("logs", []))
+
+if is_running and runner.get("auto_refresh", True):
+    time.sleep(1)
+    st.rerun()