mirror of
https://github.com/cexll/myclaude.git
synced 2026-02-11 03:23:50 +08:00
Compare commits
10 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
291a4e3d0a | ||
|
|
957b737126 | ||
|
|
3e30f4e207 | ||
|
|
b172343235 | ||
|
|
c8a652ec15 | ||
|
|
12e47affa9 | ||
|
|
612150f72e | ||
|
|
77d9870094 | ||
|
|
c96c07be2a | ||
|
|
cee467fc0e |
@@ -255,9 +255,6 @@
|
|||||||
],
|
],
|
||||||
"agents": [
|
"agents": [
|
||||||
"./agents/dev-plan-generator.md"
|
"./agents/dev-plan-generator.md"
|
||||||
],
|
|
||||||
"skills": [
|
|
||||||
"../skills/codex/SKILL.md"
|
|
||||||
]
|
]
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
|
|||||||
104
.github/workflows/release.yml
vendored
Normal file
104
.github/workflows/release.yml
vendored
Normal file
@@ -0,0 +1,104 @@
|
|||||||
|
name: Release codex-wrapper
|
||||||
|
|
||||||
|
on:
|
||||||
|
push:
|
||||||
|
tags:
|
||||||
|
- 'v*'
|
||||||
|
|
||||||
|
permissions:
|
||||||
|
contents: write
|
||||||
|
|
||||||
|
jobs:
|
||||||
|
test:
|
||||||
|
name: Test
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- name: Checkout code
|
||||||
|
uses: actions/checkout@v4
|
||||||
|
|
||||||
|
- name: Setup Go
|
||||||
|
uses: actions/setup-go@v5
|
||||||
|
with:
|
||||||
|
go-version: '1.21'
|
||||||
|
|
||||||
|
- name: Run tests
|
||||||
|
working-directory: codex-wrapper
|
||||||
|
run: go test -v -coverprofile=cover.out ./...
|
||||||
|
|
||||||
|
- name: Check coverage
|
||||||
|
working-directory: codex-wrapper
|
||||||
|
run: |
|
||||||
|
go tool cover -func=cover.out | grep total
|
||||||
|
COVERAGE=$(go tool cover -func=cover.out | grep total | awk '{print $3}' | sed 's/%//')
|
||||||
|
echo "Coverage: ${COVERAGE}%"
|
||||||
|
|
||||||
|
build:
|
||||||
|
name: Build
|
||||||
|
needs: test
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
strategy:
|
||||||
|
matrix:
|
||||||
|
include:
|
||||||
|
- goos: linux
|
||||||
|
goarch: amd64
|
||||||
|
- goos: linux
|
||||||
|
goarch: arm64
|
||||||
|
- goos: darwin
|
||||||
|
goarch: amd64
|
||||||
|
- goos: darwin
|
||||||
|
goarch: arm64
|
||||||
|
|
||||||
|
steps:
|
||||||
|
- name: Checkout code
|
||||||
|
uses: actions/checkout@v4
|
||||||
|
|
||||||
|
- name: Setup Go
|
||||||
|
uses: actions/setup-go@v5
|
||||||
|
with:
|
||||||
|
go-version: '1.21'
|
||||||
|
|
||||||
|
- name: Build binary
|
||||||
|
working-directory: codex-wrapper
|
||||||
|
env:
|
||||||
|
GOOS: ${{ matrix.goos }}
|
||||||
|
GOARCH: ${{ matrix.goarch }}
|
||||||
|
CGO_ENABLED: 0
|
||||||
|
run: |
|
||||||
|
VERSION=${GITHUB_REF#refs/tags/}
|
||||||
|
OUTPUT_NAME=codex-wrapper-${{ matrix.goos }}-${{ matrix.goarch }}
|
||||||
|
go build -ldflags="-s -w -X main.version=${VERSION}" -o ${OUTPUT_NAME} .
|
||||||
|
chmod +x ${OUTPUT_NAME}
|
||||||
|
|
||||||
|
- name: Upload artifact
|
||||||
|
uses: actions/upload-artifact@v4
|
||||||
|
with:
|
||||||
|
name: codex-wrapper-${{ matrix.goos }}-${{ matrix.goarch }}
|
||||||
|
path: codex-wrapper/codex-wrapper-${{ matrix.goos }}-${{ matrix.goarch }}
|
||||||
|
|
||||||
|
release:
|
||||||
|
name: Create Release
|
||||||
|
needs: build
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- name: Checkout code
|
||||||
|
uses: actions/checkout@v4
|
||||||
|
|
||||||
|
- name: Download all artifacts
|
||||||
|
uses: actions/download-artifact@v4
|
||||||
|
with:
|
||||||
|
path: artifacts
|
||||||
|
|
||||||
|
- name: Prepare release files
|
||||||
|
run: |
|
||||||
|
mkdir -p release
|
||||||
|
find artifacts -type f -name "codex-wrapper-*" -exec mv {} release/ \;
|
||||||
|
cp install.sh release/
|
||||||
|
ls -la release/
|
||||||
|
|
||||||
|
- name: Create Release
|
||||||
|
uses: softprops/action-gh-release@v2
|
||||||
|
with:
|
||||||
|
files: release/*
|
||||||
|
generate_release_notes: true
|
||||||
|
draft: false
|
||||||
|
prerelease: false
|
||||||
@@ -1,95 +0,0 @@
|
|||||||
# Claude Code Plugin System
|
|
||||||
|
|
||||||
本项目已支持Claude Code插件系统,可以将命令和代理打包成可安装的插件包。
|
|
||||||
|
|
||||||
## 插件配置
|
|
||||||
|
|
||||||
插件配置文件位于 `.claude-plugin/marketplace.json`,定义了所有可用的插件包。
|
|
||||||
|
|
||||||
## 可用插件
|
|
||||||
|
|
||||||
### 1. Requirements-Driven Development
|
|
||||||
- **描述**: 需求驱动的开发工作流,包含90%质量门控
|
|
||||||
- **命令**: `/requirements-pilot`
|
|
||||||
- **代理**: requirements-generate, requirements-code, requirements-testing, requirements-review
|
|
||||||
|
|
||||||
### 2. BMAD Agile Workflow
|
|
||||||
- **描述**: 完整的BMAD敏捷工作流(产品负责人→架构师→SM→开发→QA)
|
|
||||||
- **命令**: `/bmad-pilot`
|
|
||||||
- **代理**: bmad-po, bmad-architect, bmad-sm, bmad-dev, bmad-qa, bmad-orchestrator
|
|
||||||
|
|
||||||
### 3. Development Essentials
|
|
||||||
- **描述**: 核心开发命令套件
|
|
||||||
- **命令**: `/code`, `/debug`, `/test`, `/optimize`, `/review`, `/bugfix`, `/refactor`, `/docs`, `/ask`, `/think`
|
|
||||||
- **代理**: code, bugfix, bugfix-verify, code-optimize, debug, develop
|
|
||||||
|
|
||||||
### 4. Advanced AI Agents
|
|
||||||
- **描述**: 高级AI代理,集成GPT-5进行深度分析
|
|
||||||
- **代理**: gpt5
|
|
||||||
|
|
||||||
## 使用插件命令
|
|
||||||
|
|
||||||
### 列出所有可用插件
|
|
||||||
```bash
|
|
||||||
/plugin list
|
|
||||||
```
|
|
||||||
|
|
||||||
### 查看插件详情
|
|
||||||
```bash
|
|
||||||
/plugin info <plugin-name>
|
|
||||||
```
|
|
||||||
例如:`/plugin info requirements-driven-development`
|
|
||||||
|
|
||||||
### 安装插件
|
|
||||||
```bash
|
|
||||||
/plugin install <plugin-name>
|
|
||||||
```
|
|
||||||
例如:`/plugin install bmad-agile-workflow`
|
|
||||||
|
|
||||||
### 移除插件
|
|
||||||
```bash
|
|
||||||
/plugin remove <plugin-name>
|
|
||||||
```
|
|
||||||
|
|
||||||
## 创建自定义插件
|
|
||||||
|
|
||||||
要创建自己的插件:
|
|
||||||
|
|
||||||
1. 在 `.claude-plugin/marketplace.json` 中添加新的插件定义
|
|
||||||
2. 指定插件包含的命令和代理文件路径
|
|
||||||
3. 设置适当的元数据(版本、作者、关键词等)
|
|
||||||
|
|
||||||
示例插件结构:
|
|
||||||
```json
|
|
||||||
{
|
|
||||||
"name": "my-custom-plugin",
|
|
||||||
"source": "./",
|
|
||||||
"description": "自定义插件描述",
|
|
||||||
"version": "1.0.0",
|
|
||||||
"commands": [
|
|
||||||
"./commands/my-command.md"
|
|
||||||
],
|
|
||||||
"agents": [
|
|
||||||
"./agents/my-agent.md"
|
|
||||||
]
|
|
||||||
}
|
|
||||||
```
|
|
||||||
|
|
||||||
## 分享插件
|
|
||||||
|
|
||||||
要分享插件给其他项目:
|
|
||||||
1. 复制整个 `.claude-plugin` 目录到目标项目
|
|
||||||
2. 确保相关的命令和代理文件存在
|
|
||||||
3. 在新项目中使用 `/plugin` 命令管理插件
|
|
||||||
|
|
||||||
## 注意事项
|
|
||||||
|
|
||||||
- 插件系统遵循Claude Code的插件规范
|
|
||||||
- 所有命令和代理文件必须是有效的Markdown格式
|
|
||||||
- 插件配置支持版本管理和依赖关系
|
|
||||||
- 插件可以包含多个命令、代理和输出样式
|
|
||||||
|
|
||||||
## 相关文档
|
|
||||||
|
|
||||||
- [Claude Code插件文档](https://docs.claude.com/en/docs/claude-code/plugins)
|
|
||||||
- [示例插件仓库](https://github.com/wshobson/agents)
|
|
||||||
13
README.md
13
README.md
@@ -15,7 +15,7 @@
|
|||||||
|
|
||||||
**Plugin System (Recommended)**
|
**Plugin System (Recommended)**
|
||||||
```bash
|
```bash
|
||||||
/plugin github.com/cexll/myclaude
|
/plugin marketplace add cexll/myclaude
|
||||||
```
|
```
|
||||||
|
|
||||||
**Traditional Installation**
|
**Traditional Installation**
|
||||||
@@ -44,6 +44,8 @@ make install
|
|||||||
|--------|-------------|--------------|
|
|--------|-------------|--------------|
|
||||||
| **[bmad-agile-workflow](docs/BMAD-WORKFLOW.md)** | Complete BMAD methodology with 6 specialized agents | `/bmad-pilot` |
|
| **[bmad-agile-workflow](docs/BMAD-WORKFLOW.md)** | Complete BMAD methodology with 6 specialized agents | `/bmad-pilot` |
|
||||||
| **[requirements-driven-workflow](docs/REQUIREMENTS-WORKFLOW.md)** | Streamlined requirements-to-code workflow | `/requirements-pilot` |
|
| **[requirements-driven-workflow](docs/REQUIREMENTS-WORKFLOW.md)** | Streamlined requirements-to-code workflow | `/requirements-pilot` |
|
||||||
|
| **[dev-workflow](dev-workflow/README.md)** | Extreme lightweight end-to-end development workflow | `/dev` |
|
||||||
|
| **[codex-wrapper](codex-wrapper/)** | Go binary wrapper for Codex CLI integration | `codex-wrapper` |
|
||||||
| **[development-essentials](docs/DEVELOPMENT-COMMANDS.md)** | Core development slash commands | `/code` `/debug` `/test` `/optimize` |
|
| **[development-essentials](docs/DEVELOPMENT-COMMANDS.md)** | Core development slash commands | `/code` `/debug` `/test` `/optimize` |
|
||||||
| **[advanced-ai-agents](docs/ADVANCED-AGENTS.md)** | GPT-5 deep reasoning integration | Agent: `gpt5` |
|
| **[advanced-ai-agents](docs/ADVANCED-AGENTS.md)** | GPT-5 deep reasoning integration | Agent: `gpt5` |
|
||||||
| **[requirements-clarity](docs/REQUIREMENTS-CLARITY.md)** | Automated requirements clarification with 100-point scoring | Auto-activated skill |
|
| **[requirements-clarity](docs/REQUIREMENTS-CLARITY.md)** | Automated requirements clarification with 100-point scoring | Auto-activated skill |
|
||||||
@@ -88,6 +90,11 @@ make install
|
|||||||
|
|
||||||
## 🛠️ Installation Methods
|
## 🛠️ Installation Methods
|
||||||
|
|
||||||
|
**Codex Wrapper** (Go binary for Codex CLI)
|
||||||
|
```bash
|
||||||
|
curl -fsSL https://raw.githubusercontent.com/cexll/myclaude/refs/heads/master/install.sh | bash
|
||||||
|
```
|
||||||
|
|
||||||
**Method 1: Plugin Install** (One command)
|
**Method 1: Plugin Install** (One command)
|
||||||
```bash
|
```bash
|
||||||
/plugin install bmad-agile-workflow
|
/plugin install bmad-agile-workflow
|
||||||
@@ -101,8 +108,8 @@ make deploy-all # Everything
|
|||||||
```
|
```
|
||||||
|
|
||||||
**Method 3: Manual Setup**
|
**Method 3: Manual Setup**
|
||||||
- Copy `/commands/*.md` to `~/.config/claude/commands/`
|
- Copy `./commands/*.md` to `~/.config/claude/commands/`
|
||||||
- Copy `/agents/*.md` to `~/.config/claude/agents/`
|
- Copy `./agents/*.md` to `~/.config/claude/agents/`
|
||||||
|
|
||||||
Run `make help` for all options.
|
Run `make help` for all options.
|
||||||
|
|
||||||
|
|||||||
@@ -15,7 +15,7 @@
|
|||||||
|
|
||||||
**插件系统(推荐)**
|
**插件系统(推荐)**
|
||||||
```bash
|
```bash
|
||||||
/plugin github.com/cexll/myclaude
|
/plugin marketplace add cexll/myclaude
|
||||||
```
|
```
|
||||||
|
|
||||||
**传统安装**
|
**传统安装**
|
||||||
@@ -44,6 +44,7 @@ make install
|
|||||||
|------|------|---------|
|
|------|------|---------|
|
||||||
| **[bmad-agile-workflow](docs/BMAD-WORKFLOW.md)** | 完整 BMAD 方法论,包含6个专业智能体 | `/bmad-pilot` |
|
| **[bmad-agile-workflow](docs/BMAD-WORKFLOW.md)** | 完整 BMAD 方法论,包含6个专业智能体 | `/bmad-pilot` |
|
||||||
| **[requirements-driven-workflow](docs/REQUIREMENTS-WORKFLOW.md)** | 精简的需求到代码工作流 | `/requirements-pilot` |
|
| **[requirements-driven-workflow](docs/REQUIREMENTS-WORKFLOW.md)** | 精简的需求到代码工作流 | `/requirements-pilot` |
|
||||||
|
| **[dev-workflow](dev-workflow/README.md)** | 极简端到端开发工作流 | `/dev` |
|
||||||
| **[development-essentials](docs/DEVELOPMENT-COMMANDS.md)** | 核心开发斜杠命令 | `/code` `/debug` `/test` `/optimize` |
|
| **[development-essentials](docs/DEVELOPMENT-COMMANDS.md)** | 核心开发斜杠命令 | `/code` `/debug` `/test` `/optimize` |
|
||||||
| **[advanced-ai-agents](docs/ADVANCED-AGENTS.md)** | GPT-5 深度推理集成 | 智能体: `gpt5` |
|
| **[advanced-ai-agents](docs/ADVANCED-AGENTS.md)** | GPT-5 深度推理集成 | 智能体: `gpt5` |
|
||||||
| **[requirements-clarity](docs/REQUIREMENTS-CLARITY.md)** | 自动需求澄清,100分制质量评分 | 自动激活技能 |
|
| **[requirements-clarity](docs/REQUIREMENTS-CLARITY.md)** | 自动需求澄清,100分制质量评分 | 自动激活技能 |
|
||||||
@@ -101,8 +102,8 @@ make deploy-all # 全部安装
|
|||||||
```
|
```
|
||||||
|
|
||||||
**方式3: 手动安装**
|
**方式3: 手动安装**
|
||||||
- 复制 `/commands/*.md` 到 `~/.config/claude/commands/`
|
- 复制 `./commands/*.md` 到 `~/.config/claude/commands/`
|
||||||
- 复制 `/agents/*.md` 到 `~/.config/claude/agents/`
|
- 复制 `./agents/*.md` 到 `~/.config/claude/agents/`
|
||||||
|
|
||||||
运行 `make help` 查看所有选项。
|
运行 `make help` 查看所有选项。
|
||||||
|
|
||||||
|
|||||||
3
codex-wrapper/go.mod
Normal file
3
codex-wrapper/go.mod
Normal file
@@ -0,0 +1,3 @@
|
|||||||
|
module codex-wrapper
|
||||||
|
|
||||||
|
go 1.25.3
|
||||||
492
codex-wrapper/main.go
Normal file
492
codex-wrapper/main.go
Normal file
@@ -0,0 +1,492 @@
|
|||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"bufio"
|
||||||
|
"context"
|
||||||
|
"encoding/json"
|
||||||
|
"fmt"
|
||||||
|
"io"
|
||||||
|
"os"
|
||||||
|
"os/exec"
|
||||||
|
"os/signal"
|
||||||
|
"strconv"
|
||||||
|
"strings"
|
||||||
|
"syscall"
|
||||||
|
"time"
|
||||||
|
)
|
||||||
|
|
||||||
|
const (
|
||||||
|
version = "1.0.0"
|
||||||
|
defaultWorkdir = "."
|
||||||
|
defaultTimeout = 7200 // seconds
|
||||||
|
forceKillDelay = 5 // seconds
|
||||||
|
)
|
||||||
|
|
||||||
|
// Test hooks for dependency injection
|
||||||
|
var (
|
||||||
|
stdinReader io.Reader = os.Stdin
|
||||||
|
isTerminalFn = defaultIsTerminal
|
||||||
|
codexCommand = "codex"
|
||||||
|
)
|
||||||
|
|
||||||
|
// Config holds CLI configuration
|
||||||
|
type Config struct {
|
||||||
|
Mode string // "new" or "resume"
|
||||||
|
Task string
|
||||||
|
SessionID string
|
||||||
|
WorkDir string
|
||||||
|
ExplicitStdin bool
|
||||||
|
Timeout int
|
||||||
|
}
|
||||||
|
|
||||||
|
// JSONEvent represents a Codex JSON output event
|
||||||
|
type JSONEvent struct {
|
||||||
|
Type string `json:"type"`
|
||||||
|
ThreadID string `json:"thread_id,omitempty"`
|
||||||
|
Item *EventItem `json:"item,omitempty"`
|
||||||
|
}
|
||||||
|
|
||||||
|
// EventItem represents the item field in a JSON event
|
||||||
|
type EventItem struct {
|
||||||
|
Type string `json:"type"`
|
||||||
|
Text interface{} `json:"text"`
|
||||||
|
}
|
||||||
|
|
||||||
|
func main() {
|
||||||
|
exitCode := run()
|
||||||
|
os.Exit(exitCode)
|
||||||
|
}
|
||||||
|
|
||||||
|
// run is the main logic, returns exit code for testability
|
||||||
|
func run() int {
|
||||||
|
// Handle --version and --help first
|
||||||
|
if len(os.Args) > 1 {
|
||||||
|
switch os.Args[1] {
|
||||||
|
case "--version", "-v":
|
||||||
|
fmt.Printf("codex-wrapper version %s\n", version)
|
||||||
|
return 0
|
||||||
|
case "--help", "-h":
|
||||||
|
printHelp()
|
||||||
|
return 0
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
logInfo("Script started")
|
||||||
|
|
||||||
|
cfg, err := parseArgs()
|
||||||
|
if err != nil {
|
||||||
|
logError(err.Error())
|
||||||
|
return 1
|
||||||
|
}
|
||||||
|
logInfo(fmt.Sprintf("Parsed args: mode=%s, task_len=%d", cfg.Mode, len(cfg.Task)))
|
||||||
|
|
||||||
|
timeoutSec := resolveTimeout()
|
||||||
|
logInfo(fmt.Sprintf("Timeout: %ds", timeoutSec))
|
||||||
|
cfg.Timeout = timeoutSec
|
||||||
|
|
||||||
|
// Determine task text and stdin mode
|
||||||
|
var taskText string
|
||||||
|
var piped bool
|
||||||
|
|
||||||
|
if cfg.ExplicitStdin {
|
||||||
|
logInfo("Explicit stdin mode: reading task from stdin")
|
||||||
|
data, err := io.ReadAll(stdinReader)
|
||||||
|
if err != nil {
|
||||||
|
logError("Failed to read stdin: " + err.Error())
|
||||||
|
return 1
|
||||||
|
}
|
||||||
|
taskText = string(data)
|
||||||
|
if taskText == "" {
|
||||||
|
logError("Explicit stdin mode requires task input from stdin")
|
||||||
|
return 1
|
||||||
|
}
|
||||||
|
piped = !isTerminal()
|
||||||
|
} else {
|
||||||
|
pipedTask := readPipedTask()
|
||||||
|
piped = pipedTask != ""
|
||||||
|
if piped {
|
||||||
|
taskText = pipedTask
|
||||||
|
} else {
|
||||||
|
taskText = cfg.Task
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
useStdin := cfg.ExplicitStdin || shouldUseStdin(taskText, piped)
|
||||||
|
|
||||||
|
if useStdin {
|
||||||
|
var reasons []string
|
||||||
|
if piped {
|
||||||
|
reasons = append(reasons, "piped input")
|
||||||
|
}
|
||||||
|
if cfg.ExplicitStdin {
|
||||||
|
reasons = append(reasons, "explicit \"-\"")
|
||||||
|
}
|
||||||
|
if strings.Contains(taskText, "\n") {
|
||||||
|
reasons = append(reasons, "newline")
|
||||||
|
}
|
||||||
|
if strings.Contains(taskText, "\\") {
|
||||||
|
reasons = append(reasons, "backslash")
|
||||||
|
}
|
||||||
|
if len(taskText) > 800 {
|
||||||
|
reasons = append(reasons, "length>800")
|
||||||
|
}
|
||||||
|
if len(reasons) > 0 {
|
||||||
|
logWarn(fmt.Sprintf("Using stdin mode for task due to: %s", strings.Join(reasons, ", ")))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
targetArg := taskText
|
||||||
|
if useStdin {
|
||||||
|
targetArg = "-"
|
||||||
|
}
|
||||||
|
|
||||||
|
codexArgs := buildCodexArgs(cfg, targetArg)
|
||||||
|
logInfo("codex running...")
|
||||||
|
|
||||||
|
message, threadID, exitCode := runCodexProcess(codexArgs, taskText, useStdin, cfg.Timeout)
|
||||||
|
|
||||||
|
if exitCode != 0 {
|
||||||
|
return exitCode
|
||||||
|
}
|
||||||
|
|
||||||
|
// Output agent_message
|
||||||
|
fmt.Println(message)
|
||||||
|
|
||||||
|
// Output session_id if present
|
||||||
|
if threadID != "" {
|
||||||
|
fmt.Printf("\n---\nSESSION_ID: %s\n", threadID)
|
||||||
|
}
|
||||||
|
|
||||||
|
return 0
|
||||||
|
}
|
||||||
|
|
||||||
|
func parseArgs() (*Config, error) {
|
||||||
|
args := os.Args[1:]
|
||||||
|
if len(args) == 0 {
|
||||||
|
return nil, fmt.Errorf("task required")
|
||||||
|
}
|
||||||
|
|
||||||
|
cfg := &Config{
|
||||||
|
WorkDir: defaultWorkdir,
|
||||||
|
}
|
||||||
|
|
||||||
|
// Check for resume mode
|
||||||
|
if args[0] == "resume" {
|
||||||
|
if len(args) < 3 {
|
||||||
|
return nil, fmt.Errorf("resume mode requires: resume <session_id> <task>")
|
||||||
|
}
|
||||||
|
cfg.Mode = "resume"
|
||||||
|
cfg.SessionID = args[1]
|
||||||
|
cfg.Task = args[2]
|
||||||
|
cfg.ExplicitStdin = (args[2] == "-")
|
||||||
|
if len(args) > 3 {
|
||||||
|
cfg.WorkDir = args[3]
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
cfg.Mode = "new"
|
||||||
|
cfg.Task = args[0]
|
||||||
|
cfg.ExplicitStdin = (args[0] == "-")
|
||||||
|
if len(args) > 1 {
|
||||||
|
cfg.WorkDir = args[1]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return cfg, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func readPipedTask() string {
|
||||||
|
if isTerminal() {
|
||||||
|
logInfo("Stdin is tty, skipping pipe read")
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
logInfo("Reading from stdin pipe...")
|
||||||
|
data, err := io.ReadAll(stdinReader)
|
||||||
|
if err != nil || len(data) == 0 {
|
||||||
|
logInfo("Stdin pipe returned empty data")
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
logInfo(fmt.Sprintf("Read %d bytes from stdin pipe", len(data)))
|
||||||
|
return string(data)
|
||||||
|
}
|
||||||
|
|
||||||
|
func shouldUseStdin(taskText string, piped bool) bool {
|
||||||
|
if piped {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
if strings.Contains(taskText, "\n") {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
if strings.Contains(taskText, "\\") {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
if len(taskText) > 800 {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
func buildCodexArgs(cfg *Config, targetArg string) []string {
|
||||||
|
if cfg.Mode == "resume" {
|
||||||
|
return []string{
|
||||||
|
"e",
|
||||||
|
"--skip-git-repo-check",
|
||||||
|
"--json",
|
||||||
|
"resume",
|
||||||
|
cfg.SessionID,
|
||||||
|
targetArg,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return []string{
|
||||||
|
"e",
|
||||||
|
"--skip-git-repo-check",
|
||||||
|
"-C", cfg.WorkDir,
|
||||||
|
"--json",
|
||||||
|
targetArg,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func runCodexProcess(codexArgs []string, taskText string, useStdin bool, timeoutSec int) (message, threadID string, exitCode int) {
|
||||||
|
ctx, cancel := context.WithTimeout(context.Background(), time.Duration(timeoutSec)*time.Second)
|
||||||
|
defer cancel()
|
||||||
|
|
||||||
|
cmd := exec.CommandContext(ctx, codexCommand, codexArgs...)
|
||||||
|
cmd.Stderr = os.Stderr
|
||||||
|
|
||||||
|
// Setup stdin if needed
|
||||||
|
var stdinPipe io.WriteCloser
|
||||||
|
var err error
|
||||||
|
if useStdin {
|
||||||
|
stdinPipe, err = cmd.StdinPipe()
|
||||||
|
if err != nil {
|
||||||
|
logError("Failed to create stdin pipe: " + err.Error())
|
||||||
|
return "", "", 1
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Setup stdout
|
||||||
|
stdout, err := cmd.StdoutPipe()
|
||||||
|
if err != nil {
|
||||||
|
logError("Failed to create stdout pipe: " + err.Error())
|
||||||
|
return "", "", 1
|
||||||
|
}
|
||||||
|
|
||||||
|
logInfo(fmt.Sprintf("Starting codex with args: codex %s...", strings.Join(codexArgs[:min(5, len(codexArgs))], " ")))
|
||||||
|
|
||||||
|
// Start process
|
||||||
|
if err := cmd.Start(); err != nil {
|
||||||
|
if strings.Contains(err.Error(), "executable file not found") {
|
||||||
|
logError("codex command not found in PATH")
|
||||||
|
return "", "", 127
|
||||||
|
}
|
||||||
|
logError("Failed to start codex: " + err.Error())
|
||||||
|
return "", "", 1
|
||||||
|
}
|
||||||
|
logInfo(fmt.Sprintf("Process started with PID: %d", cmd.Process.Pid))
|
||||||
|
|
||||||
|
// Write to stdin if needed
|
||||||
|
if useStdin && stdinPipe != nil {
|
||||||
|
logInfo(fmt.Sprintf("Writing %d chars to stdin...", len(taskText)))
|
||||||
|
go func() {
|
||||||
|
defer stdinPipe.Close()
|
||||||
|
io.WriteString(stdinPipe, taskText)
|
||||||
|
}()
|
||||||
|
logInfo("Stdin closed")
|
||||||
|
}
|
||||||
|
|
||||||
|
// Setup signal handling
|
||||||
|
sigCh := make(chan os.Signal, 1)
|
||||||
|
signal.Notify(sigCh, syscall.SIGINT, syscall.SIGTERM)
|
||||||
|
go func() {
|
||||||
|
sig := <-sigCh
|
||||||
|
logError(fmt.Sprintf("Received signal: %v", sig))
|
||||||
|
if cmd.Process != nil {
|
||||||
|
cmd.Process.Signal(syscall.SIGTERM)
|
||||||
|
time.AfterFunc(time.Duration(forceKillDelay)*time.Second, func() {
|
||||||
|
if cmd.Process != nil {
|
||||||
|
cmd.Process.Kill()
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}()
|
||||||
|
|
||||||
|
logInfo("Reading stdout...")
|
||||||
|
|
||||||
|
// Parse JSON stream
|
||||||
|
message, threadID = parseJSONStream(stdout)
|
||||||
|
|
||||||
|
// Wait for process to complete
|
||||||
|
err = cmd.Wait()
|
||||||
|
|
||||||
|
// Check for timeout
|
||||||
|
if ctx.Err() == context.DeadlineExceeded {
|
||||||
|
logError("Codex execution timeout")
|
||||||
|
if cmd.Process != nil {
|
||||||
|
cmd.Process.Kill()
|
||||||
|
}
|
||||||
|
return "", "", 124
|
||||||
|
}
|
||||||
|
|
||||||
|
// Check exit code
|
||||||
|
if err != nil {
|
||||||
|
if exitErr, ok := err.(*exec.ExitError); ok {
|
||||||
|
code := exitErr.ExitCode()
|
||||||
|
logError(fmt.Sprintf("Codex exited with status %d", code))
|
||||||
|
return "", "", code
|
||||||
|
}
|
||||||
|
logError("Codex error: " + err.Error())
|
||||||
|
return "", "", 1
|
||||||
|
}
|
||||||
|
|
||||||
|
if message == "" {
|
||||||
|
logError("Codex completed without agent_message output")
|
||||||
|
return "", "", 1
|
||||||
|
}
|
||||||
|
|
||||||
|
return message, threadID, 0
|
||||||
|
}
|
||||||
|
|
||||||
|
func parseJSONStream(r io.Reader) (message, threadID string) {
|
||||||
|
scanner := bufio.NewScanner(r)
|
||||||
|
// Set larger buffer for long lines
|
||||||
|
buf := make([]byte, 0, 64*1024)
|
||||||
|
scanner.Buffer(buf, 1024*1024)
|
||||||
|
|
||||||
|
for scanner.Scan() {
|
||||||
|
line := strings.TrimSpace(scanner.Text())
|
||||||
|
if line == "" {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
var event JSONEvent
|
||||||
|
if err := json.Unmarshal([]byte(line), &event); err != nil {
|
||||||
|
logWarn(fmt.Sprintf("Failed to parse line: %s", truncate(line, 100)))
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
// Capture thread_id
|
||||||
|
if event.Type == "thread.started" {
|
||||||
|
threadID = event.ThreadID
|
||||||
|
}
|
||||||
|
|
||||||
|
// Capture agent_message
|
||||||
|
if event.Type == "item.completed" && event.Item != nil {
|
||||||
|
if event.Item.Type == "agent_message" {
|
||||||
|
text := normalizeText(event.Item.Text)
|
||||||
|
if text != "" {
|
||||||
|
message = text
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if err := scanner.Err(); err != nil {
|
||||||
|
logWarn("Scanner error: " + err.Error())
|
||||||
|
}
|
||||||
|
|
||||||
|
return message, threadID
|
||||||
|
}
|
||||||
|
|
||||||
|
func normalizeText(text interface{}) string {
|
||||||
|
switch v := text.(type) {
|
||||||
|
case string:
|
||||||
|
return v
|
||||||
|
case []interface{}:
|
||||||
|
var sb strings.Builder
|
||||||
|
for _, item := range v {
|
||||||
|
if s, ok := item.(string); ok {
|
||||||
|
sb.WriteString(s)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return sb.String()
|
||||||
|
default:
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func resolveTimeout() int {
|
||||||
|
raw := os.Getenv("CODEX_TIMEOUT")
|
||||||
|
if raw == "" {
|
||||||
|
return defaultTimeout
|
||||||
|
}
|
||||||
|
|
||||||
|
parsed, err := strconv.Atoi(raw)
|
||||||
|
if err != nil || parsed <= 0 {
|
||||||
|
logWarn(fmt.Sprintf("Invalid CODEX_TIMEOUT '%s', falling back to %ds", raw, defaultTimeout))
|
||||||
|
return defaultTimeout
|
||||||
|
}
|
||||||
|
|
||||||
|
// Environment variable is in milliseconds if > 10000, convert to seconds
|
||||||
|
if parsed > 10000 {
|
||||||
|
return parsed / 1000
|
||||||
|
}
|
||||||
|
return parsed
|
||||||
|
}
|
||||||
|
|
||||||
|
func defaultIsTerminal() bool {
|
||||||
|
fi, err := os.Stdin.Stat()
|
||||||
|
if err != nil {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
return (fi.Mode() & os.ModeCharDevice) != 0
|
||||||
|
}
|
||||||
|
|
||||||
|
func isTerminal() bool {
|
||||||
|
return isTerminalFn()
|
||||||
|
}
|
||||||
|
|
||||||
|
func getEnv(key, defaultValue string) string {
|
||||||
|
if val := os.Getenv(key); val != "" {
|
||||||
|
return val
|
||||||
|
}
|
||||||
|
return defaultValue
|
||||||
|
}
|
||||||
|
|
||||||
|
func truncate(s string, maxLen int) string {
|
||||||
|
if len(s) <= maxLen {
|
||||||
|
return s
|
||||||
|
}
|
||||||
|
return s[:maxLen] + "..."
|
||||||
|
}
|
||||||
|
|
||||||
|
func min(a, b int) int {
|
||||||
|
if a < b {
|
||||||
|
return a
|
||||||
|
}
|
||||||
|
return b
|
||||||
|
}
|
||||||
|
|
||||||
|
func logInfo(msg string) {
|
||||||
|
fmt.Fprintf(os.Stderr, "INFO: %s\n", msg)
|
||||||
|
}
|
||||||
|
|
||||||
|
func logWarn(msg string) {
|
||||||
|
fmt.Fprintf(os.Stderr, "WARN: %s\n", msg)
|
||||||
|
}
|
||||||
|
|
||||||
|
func logError(msg string) {
|
||||||
|
fmt.Fprintf(os.Stderr, "ERROR: %s\n", msg)
|
||||||
|
}
|
||||||
|
|
||||||
|
func printHelp() {
|
||||||
|
help := `codex-wrapper - Go wrapper for Codex CLI
|
||||||
|
|
||||||
|
Usage:
|
||||||
|
codex-wrapper "task" [workdir]
|
||||||
|
codex-wrapper - [workdir] Read task from stdin
|
||||||
|
codex-wrapper resume <session_id> "task" [workdir]
|
||||||
|
codex-wrapper resume <session_id> - [workdir]
|
||||||
|
codex-wrapper --version
|
||||||
|
codex-wrapper --help
|
||||||
|
|
||||||
|
Environment Variables:
|
||||||
|
CODEX_TIMEOUT Timeout in milliseconds (default: 7200000)
|
||||||
|
|
||||||
|
Exit Codes:
|
||||||
|
0 Success
|
||||||
|
1 General error (missing args, no output)
|
||||||
|
124 Timeout
|
||||||
|
127 codex command not found
|
||||||
|
130 Interrupted (Ctrl+C)
|
||||||
|
* Passthrough from codex process`
|
||||||
|
fmt.Println(help)
|
||||||
|
}
|
||||||
748
codex-wrapper/main_test.go
Normal file
748
codex-wrapper/main_test.go
Normal file
@@ -0,0 +1,748 @@
|
|||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"bytes"
|
||||||
|
"io"
|
||||||
|
"os"
|
||||||
|
"strings"
|
||||||
|
"testing"
|
||||||
|
)
|
||||||
|
|
||||||
|
// Helper to reset test hooks
|
||||||
|
func resetTestHooks() {
|
||||||
|
stdinReader = os.Stdin
|
||||||
|
isTerminalFn = defaultIsTerminal
|
||||||
|
codexCommand = "codex"
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestParseArgs_NewMode(t *testing.T) {
|
||||||
|
tests := []struct {
|
||||||
|
name string
|
||||||
|
args []string
|
||||||
|
want *Config
|
||||||
|
wantErr bool
|
||||||
|
}{
|
||||||
|
{
|
||||||
|
name: "simple task",
|
||||||
|
args: []string{"codex-wrapper", "analyze code"},
|
||||||
|
want: &Config{
|
||||||
|
Mode: "new",
|
||||||
|
Task: "analyze code",
|
||||||
|
WorkDir: ".",
|
||||||
|
ExplicitStdin: false,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "task with workdir",
|
||||||
|
args: []string{"codex-wrapper", "analyze code", "/path/to/dir"},
|
||||||
|
want: &Config{
|
||||||
|
Mode: "new",
|
||||||
|
Task: "analyze code",
|
||||||
|
WorkDir: "/path/to/dir",
|
||||||
|
ExplicitStdin: false,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "explicit stdin mode",
|
||||||
|
args: []string{"codex-wrapper", "-"},
|
||||||
|
want: &Config{
|
||||||
|
Mode: "new",
|
||||||
|
Task: "-",
|
||||||
|
WorkDir: ".",
|
||||||
|
ExplicitStdin: true,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "stdin with workdir",
|
||||||
|
args: []string{"codex-wrapper", "-", "/some/dir"},
|
||||||
|
want: &Config{
|
||||||
|
Mode: "new",
|
||||||
|
Task: "-",
|
||||||
|
WorkDir: "/some/dir",
|
||||||
|
ExplicitStdin: true,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "no args",
|
||||||
|
args: []string{"codex-wrapper"},
|
||||||
|
wantErr: true,
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, tt := range tests {
|
||||||
|
t.Run(tt.name, func(t *testing.T) {
|
||||||
|
os.Args = tt.args
|
||||||
|
|
||||||
|
cfg, err := parseArgs()
|
||||||
|
|
||||||
|
if tt.wantErr {
|
||||||
|
if err == nil {
|
||||||
|
t.Errorf("parseArgs() expected error, got nil")
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
t.Errorf("parseArgs() unexpected error: %v", err)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
if cfg.Mode != tt.want.Mode {
|
||||||
|
t.Errorf("Mode = %v, want %v", cfg.Mode, tt.want.Mode)
|
||||||
|
}
|
||||||
|
if cfg.Task != tt.want.Task {
|
||||||
|
t.Errorf("Task = %v, want %v", cfg.Task, tt.want.Task)
|
||||||
|
}
|
||||||
|
if cfg.WorkDir != tt.want.WorkDir {
|
||||||
|
t.Errorf("WorkDir = %v, want %v", cfg.WorkDir, tt.want.WorkDir)
|
||||||
|
}
|
||||||
|
if cfg.ExplicitStdin != tt.want.ExplicitStdin {
|
||||||
|
t.Errorf("ExplicitStdin = %v, want %v", cfg.ExplicitStdin, tt.want.ExplicitStdin)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestParseArgs_ResumeMode(t *testing.T) {
|
||||||
|
tests := []struct {
|
||||||
|
name string
|
||||||
|
args []string
|
||||||
|
want *Config
|
||||||
|
wantErr bool
|
||||||
|
}{
|
||||||
|
{
|
||||||
|
name: "resume with task",
|
||||||
|
args: []string{"codex-wrapper", "resume", "session-123", "continue task"},
|
||||||
|
want: &Config{
|
||||||
|
Mode: "resume",
|
||||||
|
SessionID: "session-123",
|
||||||
|
Task: "continue task",
|
||||||
|
WorkDir: ".",
|
||||||
|
ExplicitStdin: false,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "resume with workdir",
|
||||||
|
args: []string{"codex-wrapper", "resume", "session-456", "task", "/work"},
|
||||||
|
want: &Config{
|
||||||
|
Mode: "resume",
|
||||||
|
SessionID: "session-456",
|
||||||
|
Task: "task",
|
||||||
|
WorkDir: "/work",
|
||||||
|
ExplicitStdin: false,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "resume with stdin",
|
||||||
|
args: []string{"codex-wrapper", "resume", "session-789", "-"},
|
||||||
|
want: &Config{
|
||||||
|
Mode: "resume",
|
||||||
|
SessionID: "session-789",
|
||||||
|
Task: "-",
|
||||||
|
WorkDir: ".",
|
||||||
|
ExplicitStdin: true,
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "resume missing session_id",
|
||||||
|
args: []string{"codex-wrapper", "resume"},
|
||||||
|
wantErr: true,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "resume missing task",
|
||||||
|
args: []string{"codex-wrapper", "resume", "session-123"},
|
||||||
|
wantErr: true,
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, tt := range tests {
|
||||||
|
t.Run(tt.name, func(t *testing.T) {
|
||||||
|
os.Args = tt.args
|
||||||
|
|
||||||
|
cfg, err := parseArgs()
|
||||||
|
|
||||||
|
if tt.wantErr {
|
||||||
|
if err == nil {
|
||||||
|
t.Errorf("parseArgs() expected error, got nil")
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
t.Errorf("parseArgs() unexpected error: %v", err)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
if cfg.Mode != tt.want.Mode {
|
||||||
|
t.Errorf("Mode = %v, want %v", cfg.Mode, tt.want.Mode)
|
||||||
|
}
|
||||||
|
if cfg.SessionID != tt.want.SessionID {
|
||||||
|
t.Errorf("SessionID = %v, want %v", cfg.SessionID, tt.want.SessionID)
|
||||||
|
}
|
||||||
|
if cfg.Task != tt.want.Task {
|
||||||
|
t.Errorf("Task = %v, want %v", cfg.Task, tt.want.Task)
|
||||||
|
}
|
||||||
|
if cfg.WorkDir != tt.want.WorkDir {
|
||||||
|
t.Errorf("WorkDir = %v, want %v", cfg.WorkDir, tt.want.WorkDir)
|
||||||
|
}
|
||||||
|
if cfg.ExplicitStdin != tt.want.ExplicitStdin {
|
||||||
|
t.Errorf("ExplicitStdin = %v, want %v", cfg.ExplicitStdin, tt.want.ExplicitStdin)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestShouldUseStdin(t *testing.T) {
|
||||||
|
tests := []struct {
|
||||||
|
name string
|
||||||
|
task string
|
||||||
|
piped bool
|
||||||
|
want bool
|
||||||
|
}{
|
||||||
|
{"simple task", "analyze code", false, false},
|
||||||
|
{"piped input", "analyze code", true, true},
|
||||||
|
{"contains newline", "line1\nline2", false, true},
|
||||||
|
{"contains backslash", "path\\to\\file", false, true},
|
||||||
|
{"long task", strings.Repeat("a", 801), false, true},
|
||||||
|
{"exactly 800 chars", strings.Repeat("a", 800), false, false},
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, tt := range tests {
|
||||||
|
t.Run(tt.name, func(t *testing.T) {
|
||||||
|
got := shouldUseStdin(tt.task, tt.piped)
|
||||||
|
if got != tt.want {
|
||||||
|
t.Errorf("shouldUseStdin(%q, %v) = %v, want %v", truncate(tt.task, 20), tt.piped, got, tt.want)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestBuildCodexArgs_NewMode(t *testing.T) {
|
||||||
|
cfg := &Config{
|
||||||
|
Mode: "new",
|
||||||
|
WorkDir: "/test/dir",
|
||||||
|
}
|
||||||
|
|
||||||
|
args := buildCodexArgs(cfg, "my task")
|
||||||
|
|
||||||
|
expected := []string{
|
||||||
|
"e",
|
||||||
|
"--skip-git-repo-check",
|
||||||
|
"-C", "/test/dir",
|
||||||
|
"--json",
|
||||||
|
"my task",
|
||||||
|
}
|
||||||
|
|
||||||
|
if len(args) != len(expected) {
|
||||||
|
t.Errorf("buildCodexArgs() returned %d args, want %d", len(args), len(expected))
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
for i, arg := range args {
|
||||||
|
if arg != expected[i] {
|
||||||
|
t.Errorf("buildCodexArgs()[%d] = %v, want %v", i, arg, expected[i])
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestBuildCodexArgs_ResumeMode(t *testing.T) {
|
||||||
|
cfg := &Config{
|
||||||
|
Mode: "resume",
|
||||||
|
SessionID: "session-abc",
|
||||||
|
}
|
||||||
|
|
||||||
|
args := buildCodexArgs(cfg, "-")
|
||||||
|
|
||||||
|
expected := []string{
|
||||||
|
"e",
|
||||||
|
"--skip-git-repo-check",
|
||||||
|
"--json",
|
||||||
|
"resume",
|
||||||
|
"session-abc",
|
||||||
|
"-",
|
||||||
|
}
|
||||||
|
|
||||||
|
if len(args) != len(expected) {
|
||||||
|
t.Errorf("buildCodexArgs() returned %d args, want %d", len(args), len(expected))
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
for i, arg := range args {
|
||||||
|
if arg != expected[i] {
|
||||||
|
t.Errorf("buildCodexArgs()[%d] = %v, want %v", i, arg, expected[i])
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestResolveTimeout(t *testing.T) {
|
||||||
|
tests := []struct {
|
||||||
|
name string
|
||||||
|
envVal string
|
||||||
|
want int
|
||||||
|
}{
|
||||||
|
{"empty env", "", 7200},
|
||||||
|
{"milliseconds", "7200000", 7200},
|
||||||
|
{"seconds", "3600", 3600},
|
||||||
|
{"invalid", "invalid", 7200},
|
||||||
|
{"negative", "-100", 7200},
|
||||||
|
{"zero", "0", 7200},
|
||||||
|
{"small milliseconds", "5000", 5000},
|
||||||
|
{"boundary", "10000", 10000},
|
||||||
|
{"above boundary", "10001", 10},
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, tt := range tests {
|
||||||
|
t.Run(tt.name, func(t *testing.T) {
|
||||||
|
os.Setenv("CODEX_TIMEOUT", tt.envVal)
|
||||||
|
defer os.Unsetenv("CODEX_TIMEOUT")
|
||||||
|
|
||||||
|
got := resolveTimeout()
|
||||||
|
if got != tt.want {
|
||||||
|
t.Errorf("resolveTimeout() with env=%q = %v, want %v", tt.envVal, got, tt.want)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestNormalizeText(t *testing.T) {
|
||||||
|
tests := []struct {
|
||||||
|
name string
|
||||||
|
input interface{}
|
||||||
|
want string
|
||||||
|
}{
|
||||||
|
{"string", "hello world", "hello world"},
|
||||||
|
{"string array", []interface{}{"hello", " ", "world"}, "hello world"},
|
||||||
|
{"empty array", []interface{}{}, ""},
|
||||||
|
{"mixed array", []interface{}{"text", 123, "more"}, "textmore"},
|
||||||
|
{"nil", nil, ""},
|
||||||
|
{"number", 123, ""},
|
||||||
|
{"empty string", "", ""},
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, tt := range tests {
|
||||||
|
t.Run(tt.name, func(t *testing.T) {
|
||||||
|
got := normalizeText(tt.input)
|
||||||
|
if got != tt.want {
|
||||||
|
t.Errorf("normalizeText(%v) = %q, want %q", tt.input, got, tt.want)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestParseJSONStream(t *testing.T) {
|
||||||
|
tests := []struct {
|
||||||
|
name string
|
||||||
|
input string
|
||||||
|
wantMessage string
|
||||||
|
wantThreadID string
|
||||||
|
}{
|
||||||
|
{
|
||||||
|
name: "thread started and agent message",
|
||||||
|
input: `{"type":"thread.started","thread_id":"abc-123"}
|
||||||
|
{"type":"item.completed","item":{"type":"agent_message","text":"Hello world"}}`,
|
||||||
|
wantMessage: "Hello world",
|
||||||
|
wantThreadID: "abc-123",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "multiple agent messages (last wins)",
|
||||||
|
input: `{"type":"item.completed","item":{"type":"agent_message","text":"First"}}
|
||||||
|
{"type":"item.completed","item":{"type":"agent_message","text":"Second"}}`,
|
||||||
|
wantMessage: "Second",
|
||||||
|
wantThreadID: "",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "text as array",
|
||||||
|
input: `{"type":"item.completed","item":{"type":"agent_message","text":["Hello"," ","World"]}}`,
|
||||||
|
wantMessage: "Hello World",
|
||||||
|
wantThreadID: "",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "ignore other event types",
|
||||||
|
input: `{"type":"other.event","data":"ignored"}
|
||||||
|
{"type":"item.completed","item":{"type":"other_type","text":"ignored"}}
|
||||||
|
{"type":"item.completed","item":{"type":"agent_message","text":"Valid"}}`,
|
||||||
|
wantMessage: "Valid",
|
||||||
|
wantThreadID: "",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "empty input",
|
||||||
|
input: "",
|
||||||
|
wantMessage: "",
|
||||||
|
wantThreadID: "",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "invalid JSON (skipped)",
|
||||||
|
input: "not valid json\n{\"type\":\"thread.started\",\"thread_id\":\"xyz\"}",
|
||||||
|
wantMessage: "",
|
||||||
|
wantThreadID: "xyz",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "blank lines ignored",
|
||||||
|
input: "\n\n{\"type\":\"thread.started\",\"thread_id\":\"test\"}\n\n",
|
||||||
|
wantMessage: "",
|
||||||
|
wantThreadID: "test",
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, tt := range tests {
|
||||||
|
t.Run(tt.name, func(t *testing.T) {
|
||||||
|
r := strings.NewReader(tt.input)
|
||||||
|
gotMessage, gotThreadID := parseJSONStream(r)
|
||||||
|
|
||||||
|
if gotMessage != tt.wantMessage {
|
||||||
|
t.Errorf("parseJSONStream() message = %q, want %q", gotMessage, tt.wantMessage)
|
||||||
|
}
|
||||||
|
if gotThreadID != tt.wantThreadID {
|
||||||
|
t.Errorf("parseJSONStream() threadID = %q, want %q", gotThreadID, tt.wantThreadID)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestGetEnv(t *testing.T) {
|
||||||
|
tests := []struct {
|
||||||
|
name string
|
||||||
|
key string
|
||||||
|
defaultVal string
|
||||||
|
envVal string
|
||||||
|
setEnv bool
|
||||||
|
want string
|
||||||
|
}{
|
||||||
|
{"env set", "TEST_KEY", "default", "custom", true, "custom"},
|
||||||
|
{"env not set", "TEST_KEY_MISSING", "default", "", false, "default"},
|
||||||
|
{"env empty", "TEST_KEY_EMPTY", "default", "", true, "default"},
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, tt := range tests {
|
||||||
|
t.Run(tt.name, func(t *testing.T) {
|
||||||
|
os.Unsetenv(tt.key)
|
||||||
|
if tt.setEnv {
|
||||||
|
os.Setenv(tt.key, tt.envVal)
|
||||||
|
defer os.Unsetenv(tt.key)
|
||||||
|
}
|
||||||
|
|
||||||
|
got := getEnv(tt.key, tt.defaultVal)
|
||||||
|
if got != tt.want {
|
||||||
|
t.Errorf("getEnv(%q, %q) = %q, want %q", tt.key, tt.defaultVal, got, tt.want)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestTruncate(t *testing.T) {
|
||||||
|
tests := []struct {
|
||||||
|
name string
|
||||||
|
input string
|
||||||
|
maxLen int
|
||||||
|
want string
|
||||||
|
}{
|
||||||
|
{"short string", "hello", 10, "hello"},
|
||||||
|
{"exact length", "hello", 5, "hello"},
|
||||||
|
{"truncate", "hello world", 5, "hello..."},
|
||||||
|
{"empty", "", 5, ""},
|
||||||
|
{"zero maxLen", "hello", 0, "..."},
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, tt := range tests {
|
||||||
|
t.Run(tt.name, func(t *testing.T) {
|
||||||
|
got := truncate(tt.input, tt.maxLen)
|
||||||
|
if got != tt.want {
|
||||||
|
t.Errorf("truncate(%q, %d) = %q, want %q", tt.input, tt.maxLen, got, tt.want)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestMin(t *testing.T) {
|
||||||
|
tests := []struct {
|
||||||
|
a, b, want int
|
||||||
|
}{
|
||||||
|
{1, 2, 1},
|
||||||
|
{2, 1, 1},
|
||||||
|
{5, 5, 5},
|
||||||
|
{-1, 0, -1},
|
||||||
|
{0, -1, -1},
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, tt := range tests {
|
||||||
|
t.Run("", func(t *testing.T) {
|
||||||
|
got := min(tt.a, tt.b)
|
||||||
|
if got != tt.want {
|
||||||
|
t.Errorf("min(%d, %d) = %d, want %d", tt.a, tt.b, got, tt.want)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestLogFunctions(t *testing.T) {
|
||||||
|
// Capture stderr
|
||||||
|
oldStderr := os.Stderr
|
||||||
|
r, w, _ := os.Pipe()
|
||||||
|
os.Stderr = w
|
||||||
|
|
||||||
|
logInfo("info message")
|
||||||
|
logWarn("warn message")
|
||||||
|
logError("error message")
|
||||||
|
|
||||||
|
w.Close()
|
||||||
|
os.Stderr = oldStderr
|
||||||
|
|
||||||
|
var buf bytes.Buffer
|
||||||
|
io.Copy(&buf, r)
|
||||||
|
output := buf.String()
|
||||||
|
|
||||||
|
if !strings.Contains(output, "INFO: info message") {
|
||||||
|
t.Errorf("logInfo output missing, got: %s", output)
|
||||||
|
}
|
||||||
|
if !strings.Contains(output, "WARN: warn message") {
|
||||||
|
t.Errorf("logWarn output missing, got: %s", output)
|
||||||
|
}
|
||||||
|
if !strings.Contains(output, "ERROR: error message") {
|
||||||
|
t.Errorf("logError output missing, got: %s", output)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestPrintHelp(t *testing.T) {
|
||||||
|
// Capture stdout
|
||||||
|
oldStdout := os.Stdout
|
||||||
|
r, w, _ := os.Pipe()
|
||||||
|
os.Stdout = w
|
||||||
|
|
||||||
|
printHelp()
|
||||||
|
|
||||||
|
w.Close()
|
||||||
|
os.Stdout = oldStdout
|
||||||
|
|
||||||
|
var buf bytes.Buffer
|
||||||
|
io.Copy(&buf, r)
|
||||||
|
output := buf.String()
|
||||||
|
|
||||||
|
expectedPhrases := []string{
|
||||||
|
"codex-wrapper",
|
||||||
|
"Usage:",
|
||||||
|
"resume",
|
||||||
|
"CODEX_TIMEOUT",
|
||||||
|
"Exit Codes:",
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, phrase := range expectedPhrases {
|
||||||
|
if !strings.Contains(output, phrase) {
|
||||||
|
t.Errorf("printHelp() missing phrase %q", phrase)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Tests for isTerminal with mock
|
||||||
|
func TestIsTerminal(t *testing.T) {
|
||||||
|
defer resetTestHooks()
|
||||||
|
|
||||||
|
tests := []struct {
|
||||||
|
name string
|
||||||
|
mockFn func() bool
|
||||||
|
want bool
|
||||||
|
}{
|
||||||
|
{"is terminal", func() bool { return true }, true},
|
||||||
|
{"is not terminal", func() bool { return false }, false},
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, tt := range tests {
|
||||||
|
t.Run(tt.name, func(t *testing.T) {
|
||||||
|
isTerminalFn = tt.mockFn
|
||||||
|
got := isTerminal()
|
||||||
|
if got != tt.want {
|
||||||
|
t.Errorf("isTerminal() = %v, want %v", got, tt.want)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Tests for readPipedTask with mock
|
||||||
|
func TestReadPipedTask(t *testing.T) {
|
||||||
|
defer resetTestHooks()
|
||||||
|
|
||||||
|
tests := []struct {
|
||||||
|
name string
|
||||||
|
isTerminal bool
|
||||||
|
stdinContent string
|
||||||
|
want string
|
||||||
|
}{
|
||||||
|
{"terminal mode", true, "ignored", ""},
|
||||||
|
{"piped with data", false, "task from pipe", "task from pipe"},
|
||||||
|
{"piped empty", false, "", ""},
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, tt := range tests {
|
||||||
|
t.Run(tt.name, func(t *testing.T) {
|
||||||
|
isTerminalFn = func() bool { return tt.isTerminal }
|
||||||
|
stdinReader = strings.NewReader(tt.stdinContent)
|
||||||
|
|
||||||
|
got := readPipedTask()
|
||||||
|
if got != tt.want {
|
||||||
|
t.Errorf("readPipedTask() = %q, want %q", got, tt.want)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Tests for runCodexProcess with mock command
|
||||||
|
func TestRunCodexProcess_CommandNotFound(t *testing.T) {
|
||||||
|
defer resetTestHooks()
|
||||||
|
|
||||||
|
codexCommand = "nonexistent-command-xyz"
|
||||||
|
|
||||||
|
_, _, exitCode := runCodexProcess([]string{"arg1"}, "task", false, 10)
|
||||||
|
|
||||||
|
if exitCode != 127 {
|
||||||
|
t.Errorf("runCodexProcess() exitCode = %d, want 127 for command not found", exitCode)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestRunCodexProcess_WithEcho(t *testing.T) {
|
||||||
|
defer resetTestHooks()
|
||||||
|
|
||||||
|
// Use echo to simulate codex output
|
||||||
|
codexCommand = "echo"
|
||||||
|
|
||||||
|
jsonOutput := `{"type":"thread.started","thread_id":"test-session"}
|
||||||
|
{"type":"item.completed","item":{"type":"agent_message","text":"Test output"}}`
|
||||||
|
|
||||||
|
message, threadID, exitCode := runCodexProcess([]string{jsonOutput}, "", false, 10)
|
||||||
|
|
||||||
|
if exitCode != 0 {
|
||||||
|
t.Errorf("runCodexProcess() exitCode = %d, want 0", exitCode)
|
||||||
|
}
|
||||||
|
if message != "Test output" {
|
||||||
|
t.Errorf("runCodexProcess() message = %q, want %q", message, "Test output")
|
||||||
|
}
|
||||||
|
if threadID != "test-session" {
|
||||||
|
t.Errorf("runCodexProcess() threadID = %q, want %q", threadID, "test-session")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestRunCodexProcess_NoMessage(t *testing.T) {
|
||||||
|
defer resetTestHooks()
|
||||||
|
|
||||||
|
codexCommand = "echo"
|
||||||
|
|
||||||
|
// Output without agent_message
|
||||||
|
jsonOutput := `{"type":"thread.started","thread_id":"test-session"}`
|
||||||
|
|
||||||
|
_, _, exitCode := runCodexProcess([]string{jsonOutput}, "", false, 10)
|
||||||
|
|
||||||
|
if exitCode != 1 {
|
||||||
|
t.Errorf("runCodexProcess() exitCode = %d, want 1 for no message", exitCode)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestRunCodexProcess_WithStdin(t *testing.T) {
|
||||||
|
defer resetTestHooks()
|
||||||
|
|
||||||
|
// Use cat to echo stdin back
|
||||||
|
codexCommand = "cat"
|
||||||
|
|
||||||
|
message, _, exitCode := runCodexProcess([]string{}, `{"type":"item.completed","item":{"type":"agent_message","text":"from stdin"}}`, true, 10)
|
||||||
|
|
||||||
|
if exitCode != 0 {
|
||||||
|
t.Errorf("runCodexProcess() exitCode = %d, want 0", exitCode)
|
||||||
|
}
|
||||||
|
if message != "from stdin" {
|
||||||
|
t.Errorf("runCodexProcess() message = %q, want %q", message, "from stdin")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestRunCodexProcess_ExitError(t *testing.T) {
|
||||||
|
defer resetTestHooks()
|
||||||
|
|
||||||
|
// Use false command which exits with code 1
|
||||||
|
codexCommand = "false"
|
||||||
|
|
||||||
|
_, _, exitCode := runCodexProcess([]string{}, "", false, 10)
|
||||||
|
|
||||||
|
if exitCode == 0 {
|
||||||
|
t.Errorf("runCodexProcess() exitCode = 0, want non-zero for failed command")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestDefaultIsTerminal(t *testing.T) {
|
||||||
|
// This test just ensures defaultIsTerminal doesn't panic
|
||||||
|
// The actual result depends on the test environment
|
||||||
|
_ = defaultIsTerminal()
|
||||||
|
}
|
||||||
|
|
||||||
|
// Tests for run() function
|
||||||
|
func TestRun_Version(t *testing.T) {
|
||||||
|
defer resetTestHooks()
|
||||||
|
|
||||||
|
os.Args = []string{"codex-wrapper", "--version"}
|
||||||
|
exitCode := run()
|
||||||
|
if exitCode != 0 {
|
||||||
|
t.Errorf("run() with --version returned %d, want 0", exitCode)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestRun_VersionShort(t *testing.T) {
|
||||||
|
defer resetTestHooks()
|
||||||
|
|
||||||
|
os.Args = []string{"codex-wrapper", "-v"}
|
||||||
|
exitCode := run()
|
||||||
|
if exitCode != 0 {
|
||||||
|
t.Errorf("run() with -v returned %d, want 0", exitCode)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestRun_Help(t *testing.T) {
|
||||||
|
defer resetTestHooks()
|
||||||
|
|
||||||
|
os.Args = []string{"codex-wrapper", "--help"}
|
||||||
|
exitCode := run()
|
||||||
|
if exitCode != 0 {
|
||||||
|
t.Errorf("run() with --help returned %d, want 0", exitCode)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestRun_HelpShort(t *testing.T) {
|
||||||
|
defer resetTestHooks()
|
||||||
|
|
||||||
|
os.Args = []string{"codex-wrapper", "-h"}
|
||||||
|
exitCode := run()
|
||||||
|
if exitCode != 0 {
|
||||||
|
t.Errorf("run() with -h returned %d, want 0", exitCode)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestRun_NoArgs(t *testing.T) {
|
||||||
|
defer resetTestHooks()
|
||||||
|
|
||||||
|
os.Args = []string{"codex-wrapper"}
|
||||||
|
exitCode := run()
|
||||||
|
if exitCode != 1 {
|
||||||
|
t.Errorf("run() with no args returned %d, want 1", exitCode)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestRun_ExplicitStdinEmpty(t *testing.T) {
|
||||||
|
defer resetTestHooks()
|
||||||
|
|
||||||
|
os.Args = []string{"codex-wrapper", "-"}
|
||||||
|
stdinReader = strings.NewReader("")
|
||||||
|
isTerminalFn = func() bool { return false }
|
||||||
|
|
||||||
|
exitCode := run()
|
||||||
|
if exitCode != 1 {
|
||||||
|
t.Errorf("run() with empty stdin returned %d, want 1", exitCode)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestRun_CommandFails(t *testing.T) {
|
||||||
|
defer resetTestHooks()
|
||||||
|
|
||||||
|
os.Args = []string{"codex-wrapper", "task"}
|
||||||
|
stdinReader = strings.NewReader("")
|
||||||
|
isTerminalFn = func() bool { return true }
|
||||||
|
codexCommand = "false"
|
||||||
|
|
||||||
|
exitCode := run()
|
||||||
|
if exitCode == 0 {
|
||||||
|
t.Errorf("run() with failing command returned 0, want non-zero")
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -20,35 +20,35 @@ Your output is a single file: `./.claude/specs/{feature_name}/dev-plan.md`
|
|||||||
## Document Structure You Must Follow
|
## Document Structure You Must Follow
|
||||||
|
|
||||||
```markdown
|
```markdown
|
||||||
# {Feature Name} - 开发计划
|
# {Feature Name} - Development Plan
|
||||||
|
|
||||||
## 功能概述
|
## Overview
|
||||||
[一句话描述核心功能]
|
[One-sentence description of core functionality]
|
||||||
|
|
||||||
## 任务分解
|
## Task Breakdown
|
||||||
|
|
||||||
### 任务 1: [任务名称]
|
### Task 1: [Task Name]
|
||||||
- **ID**: task-1
|
- **ID**: task-1
|
||||||
- **描述**: [具体要做什么]
|
- **Description**: [What needs to be done]
|
||||||
- **文件范围**: [涉及的目录或文件,如 src/auth/**, tests/auth/]
|
- **File Scope**: [Directories or files involved, e.g., src/auth/**, tests/auth/]
|
||||||
- **依赖**: [无 或 依赖 task-x]
|
- **Dependencies**: [None or depends on task-x]
|
||||||
- **测试命令**: [如 pytest tests/auth --cov=src/auth --cov-report=term]
|
- **Test Command**: [e.g., pytest tests/auth --cov=src/auth --cov-report=term]
|
||||||
- **测试重点**: [需要覆盖的场景]
|
- **Test Focus**: [Scenarios to cover]
|
||||||
|
|
||||||
### 任务 2: [任务名称]
|
### Task 2: [Task Name]
|
||||||
...
|
...
|
||||||
|
|
||||||
(2-5个任务)
|
(2-5 tasks)
|
||||||
|
|
||||||
## 验收标准
|
## Acceptance Criteria
|
||||||
- [ ] 功能点 1
|
- [ ] Feature point 1
|
||||||
- [ ] 功能点 2
|
- [ ] Feature point 2
|
||||||
- [ ] 所有单元测试通过
|
- [ ] All unit tests pass
|
||||||
- [ ] 代码覆盖率 ≥90%
|
- [ ] Code coverage ≥90%
|
||||||
|
|
||||||
## 技术要点
|
## Technical Notes
|
||||||
- [关键技术决策]
|
- [Key technical decisions]
|
||||||
- [需要注意的约束]
|
- [Constraints to be aware of]
|
||||||
```
|
```
|
||||||
|
|
||||||
## Generation Rules You Must Enforce
|
## Generation Rules You Must Enforce
|
||||||
@@ -58,7 +58,7 @@ Your output is a single file: `./.claude/specs/{feature_name}/dev-plan.md`
|
|||||||
- Clear ID (task-1, task-2, etc.)
|
- Clear ID (task-1, task-2, etc.)
|
||||||
- Specific description of what needs to be done
|
- Specific description of what needs to be done
|
||||||
- Explicit file scope (directories or files affected)
|
- Explicit file scope (directories or files affected)
|
||||||
- Dependency declaration ("无" or "依赖 task-x")
|
- Dependency declaration ("None" or "depends on task-x")
|
||||||
- Complete test command with coverage parameters
|
- Complete test command with coverage parameters
|
||||||
- Testing focus points (scenarios to cover)
|
- Testing focus points (scenarios to cover)
|
||||||
3. **Task Independence**: Design tasks to be as independent as possible to enable parallel execution
|
3. **Task Independence**: Design tasks to be as independent as possible to enable parallel execution
|
||||||
@@ -78,7 +78,7 @@ Your output is a single file: `./.claude/specs/{feature_name}/dev-plan.md`
|
|||||||
## Quality Checks Before Writing
|
## Quality Checks Before Writing
|
||||||
|
|
||||||
- [ ] Task count is between 2-5
|
- [ ] Task count is between 2-5
|
||||||
- [ ] Every task has all 6 required fields (ID, 描述, 文件范围, 依赖, 测试命令, 测试重点)
|
- [ ] Every task has all 6 required fields (ID, Description, File Scope, Dependencies, Test Command, Test Focus)
|
||||||
- [ ] Test commands include coverage parameters
|
- [ ] Test commands include coverage parameters
|
||||||
- [ ] Dependencies are explicitly stated
|
- [ ] Dependencies are explicitly stated
|
||||||
- [ ] Acceptance criteria includes 90% coverage requirement
|
- [ ] Acceptance criteria includes 90% coverage requirement
|
||||||
@@ -90,7 +90,7 @@ Your output is a single file: `./.claude/specs/{feature_name}/dev-plan.md`
|
|||||||
- **Document Only**: You generate documentation. You do NOT execute code, run tests, or modify source files.
|
- **Document Only**: You generate documentation. You do NOT execute code, run tests, or modify source files.
|
||||||
- **Single Output**: You produce exactly one file: `dev-plan.md` in the correct location
|
- **Single Output**: You produce exactly one file: `dev-plan.md` in the correct location
|
||||||
- **Path Accuracy**: The path must be `./.claude/specs/{feature_name}/dev-plan.md` where {feature_name} matches the input
|
- **Path Accuracy**: The path must be `./.claude/specs/{feature_name}/dev-plan.md` where {feature_name} matches the input
|
||||||
- **Chinese Language**: The document must be in Chinese (as shown in the structure)
|
- **Language Matching**: Output language matches user input (Chinese input → Chinese doc, English input → English doc)
|
||||||
- **Structured Format**: Follow the exact markdown structure provided
|
- **Structured Format**: Follow the exact markdown structure provided
|
||||||
|
|
||||||
## Example Output Quality
|
## Example Output Quality
|
||||||
|
|||||||
@@ -20,61 +20,66 @@ You are the /dev Workflow Orchestrator, an expert development workflow manager s
|
|||||||
- Focus questions on functional boundaries, inputs/outputs, constraints, testing
|
- Focus questions on functional boundaries, inputs/outputs, constraints, testing
|
||||||
- Iterate 2-3 rounds until clear; rely on judgment; keep questions concise
|
- Iterate 2-3 rounds until clear; rely on judgment; keep questions concise
|
||||||
|
|
||||||
- **Step 2: Codex Analysis**
|
- **Step 2: Codex Deep Analysis (Plan Mode Style)**
|
||||||
- Run:
|
|
||||||
```bash
|
|
||||||
uv run ~/.claude/skills/codex/scripts/codex.py "分析以下需求并提取开发要点:
|
|
||||||
|
|
||||||
需求描述:
|
Use Codex Skill to perform deep analysis. Codex should operate in "plan mode" style:
|
||||||
[用户需求 + 澄清后的细节]
|
|
||||||
|
|
||||||
请输出:
|
**When Deep Analysis is Needed** (any condition triggers):
|
||||||
1. 核心功能(一句话)
|
- Multiple valid approaches exist (e.g., Redis vs in-memory vs file-based caching)
|
||||||
2. 关键技术点
|
- Significant architectural decisions required (e.g., WebSockets vs SSE vs polling)
|
||||||
3. 可并发的任务分解(2-5个):
|
- Large-scale changes touching many files or systems
|
||||||
- 任务ID
|
- Unclear scope requiring exploration first
|
||||||
- 任务描述
|
|
||||||
- 涉及文件/目录
|
**What Codex Does in Analysis Mode**:
|
||||||
- 是否依赖其他任务
|
1. **Explore Codebase**: Use Glob, Grep, Read to understand structure, patterns, architecture
|
||||||
- 测试重点
|
2. **Identify Existing Patterns**: Find how similar features are implemented, reuse conventions
|
||||||
" "gpt-5.1-codex"
|
3. **Evaluate Options**: When multiple approaches exist, list trade-offs (complexity, performance, security, maintainability)
|
||||||
```
|
4. **Make Architectural Decisions**: Choose patterns, APIs, data models with justification
|
||||||
- Extract core functionality, technical key points, and 2-5 parallelizable tasks with full metadata
|
5. **Design Task Breakdown**: Produce 2-5 parallelizable tasks with file scope and dependencies
|
||||||
|
|
||||||
|
**Analysis Output Structure**:
|
||||||
|
```
|
||||||
|
## Context & Constraints
|
||||||
|
[Tech stack, existing patterns, constraints discovered]
|
||||||
|
|
||||||
|
## Codebase Exploration
|
||||||
|
[Key files, modules, patterns found via Glob/Grep/Read]
|
||||||
|
|
||||||
|
## Implementation Options (if multiple approaches)
|
||||||
|
| Option | Pros | Cons | Recommendation |
|
||||||
|
|
||||||
|
## Technical Decisions
|
||||||
|
[API design, data models, architecture choices made]
|
||||||
|
|
||||||
|
## Task Breakdown
|
||||||
|
[2-5 tasks with: ID, description, file scope, dependencies, test command]
|
||||||
|
```
|
||||||
|
|
||||||
|
**Skip Deep Analysis When**:
|
||||||
|
- Simple, straightforward implementation with obvious approach
|
||||||
|
- Small changes confined to 1-2 files
|
||||||
|
- Clear requirements with single implementation path
|
||||||
|
|
||||||
- **Step 3: Generate Development Documentation**
|
- **Step 3: Generate Development Documentation**
|
||||||
- invoke agent dev-plan-generator:
|
- invoke agent dev-plan-generator
|
||||||
```
|
- Output a brief summary of dev-plan.md:
|
||||||
基于以下分析结果生成开发文档:
|
- Number of tasks and their IDs
|
||||||
|
- File scope for each task
|
||||||
[Codex 分析输出]
|
- Dependencies between tasks
|
||||||
|
- Test commands
|
||||||
输出文件:./.claude/specs/{feature_name}/dev-plan.md
|
- Use AskUserQuestion to confirm with user:
|
||||||
|
- Question: "Proceed with this development plan?"
|
||||||
包含:
|
- Options: "Confirm and execute" / "Need adjustments"
|
||||||
1. 功能概述
|
- If user chooses "Need adjustments", return to Step 1 or Step 2 based on feedback
|
||||||
2. 任务列表(2-5个并发任务)
|
|
||||||
- 每个任务:ID、描述、文件范围、依赖、测试命令
|
|
||||||
3. 验收标准
|
|
||||||
4. 覆盖率要求:≥90%
|
|
||||||
```
|
|
||||||
|
|
||||||
- **Step 4: Parallel Development Execution**
|
- **Step 4: Parallel Development Execution**
|
||||||
- For each task in `dev-plan.md` run:
|
- For each task in `dev-plan.md`, invoke Codex with this brief:
|
||||||
```bash
|
```
|
||||||
uv run ~/.claude/skills/codex/scripts/codex.py "实现任务:[任务ID]
|
Task: [task-id]
|
||||||
|
Reference: @.claude/specs/{feature_name}/dev-plan.md
|
||||||
参考文档:@.claude/specs/{feature_name}/dev-plan.md
|
Scope: [task file scope]
|
||||||
|
Test: [test command]
|
||||||
你的职责:
|
Deliverables: code + unit tests + coverage ≥90% + coverage summary
|
||||||
1. 实现功能代码
|
|
||||||
2. 编写单元测试
|
|
||||||
3. 运行测试 + 覆盖率
|
|
||||||
4. 报告覆盖率结果
|
|
||||||
|
|
||||||
文件范围:[任务的文件范围]
|
|
||||||
测试命令:[任务指定的测试命令]
|
|
||||||
覆盖率目标:≥90%
|
|
||||||
" "gpt-5.1-codex"
|
|
||||||
```
|
```
|
||||||
- Execute independent tasks concurrently; serialize conflicting ones; track coverage reports
|
- Execute independent tasks concurrently; serialize conflicting ones; track coverage reports
|
||||||
|
|
||||||
|
|||||||
@@ -104,7 +104,7 @@ This repository provides 4 ready-to-use Claude Code plugins that can be installe
|
|||||||
|
|
||||||
```bash
|
```bash
|
||||||
# Install from GitHub repository
|
# Install from GitHub repository
|
||||||
/plugin github.com/cexll/myclaude
|
/plugin marketplace add cexll/myclaude
|
||||||
```
|
```
|
||||||
|
|
||||||
This will present all available plugins from the repository.
|
This will present all available plugins from the repository.
|
||||||
|
|||||||
@@ -8,7 +8,7 @@
|
|||||||
|
|
||||||
```bash
|
```bash
|
||||||
# Install everything with one command
|
# Install everything with one command
|
||||||
/plugin github.com/cexll/myclaude
|
/plugin marketplace add cexll/myclaude
|
||||||
```
|
```
|
||||||
|
|
||||||
### Option 2: Make Install
|
### Option 2: Make Install
|
||||||
|
|||||||
46
install.sh
Normal file
46
install.sh
Normal file
@@ -0,0 +1,46 @@
|
|||||||
|
#!/bin/bash
|
||||||
|
set -e
|
||||||
|
|
||||||
|
# Detect platform
|
||||||
|
OS=$(uname -s | tr '[:upper:]' '[:lower:]')
|
||||||
|
ARCH=$(uname -m)
|
||||||
|
|
||||||
|
# Normalize architecture names
|
||||||
|
case "$ARCH" in
|
||||||
|
x86_64) ARCH="amd64" ;;
|
||||||
|
aarch64|arm64) ARCH="arm64" ;;
|
||||||
|
*) echo "Unsupported architecture: $ARCH" >&2; exit 1 ;;
|
||||||
|
esac
|
||||||
|
|
||||||
|
# Build download URL
|
||||||
|
REPO="cexll/myclaude"
|
||||||
|
VERSION="latest"
|
||||||
|
BINARY_NAME="codex-wrapper-${OS}-${ARCH}"
|
||||||
|
URL="https://github.com/${REPO}/releases/${VERSION}/download/${BINARY_NAME}"
|
||||||
|
|
||||||
|
echo "Downloading codex-wrapper from ${URL}..."
|
||||||
|
if ! curl -fsSL "$URL" -o /tmp/codex-wrapper; then
|
||||||
|
echo "ERROR: failed to download binary" >&2
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
|
|
||||||
|
mkdir -p "$HOME/bin"
|
||||||
|
|
||||||
|
mv /tmp/codex-wrapper "$HOME/bin/codex-wrapper"
|
||||||
|
chmod +x "$HOME/bin/codex-wrapper"
|
||||||
|
|
||||||
|
if "$HOME/bin/codex-wrapper" --version >/dev/null 2>&1; then
|
||||||
|
echo "codex-wrapper installed successfully to ~/bin/codex-wrapper"
|
||||||
|
else
|
||||||
|
echo "ERROR: installation verification failed" >&2
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
|
|
||||||
|
if [[ ":$PATH:" != *":$HOME/bin:"* ]]; then
|
||||||
|
echo ""
|
||||||
|
echo "WARNING: ~/bin is not in your PATH"
|
||||||
|
echo "Add this line to your ~/.bashrc or ~/.zshrc:"
|
||||||
|
echo ""
|
||||||
|
echo " export PATH=\"\$HOME/bin:\$PATH\""
|
||||||
|
echo ""
|
||||||
|
fi
|
||||||
@@ -20,7 +20,7 @@ Execute Codex CLI commands and parse structured JSON responses. Supports file re
|
|||||||
**Mandatory**: Run every automated invocation through the Bash tool in the foreground with **HEREDOC syntax** to avoid shell quoting issues, keeping the `timeout` parameter fixed at `7200000` milliseconds (do not change it or use any other entry point).
|
**Mandatory**: Run every automated invocation through the Bash tool in the foreground with **HEREDOC syntax** to avoid shell quoting issues, keeping the `timeout` parameter fixed at `7200000` milliseconds (do not change it or use any other entry point).
|
||||||
|
|
||||||
```bash
|
```bash
|
||||||
uv run ~/.claude/skills/codex/scripts/codex.py - [working_dir] <<'EOF'
|
codex-wrapper - [working_dir] <<'EOF'
|
||||||
<task content here>
|
<task content here>
|
||||||
EOF
|
EOF
|
||||||
```
|
```
|
||||||
@@ -32,12 +32,12 @@ EOF
|
|||||||
**Simple tasks** (backward compatibility):
|
**Simple tasks** (backward compatibility):
|
||||||
For simple single-line tasks without special characters, you can still use direct quoting:
|
For simple single-line tasks without special characters, you can still use direct quoting:
|
||||||
```bash
|
```bash
|
||||||
uv run ~/.claude/skills/codex/scripts/codex.py "simple task here" [working_dir]
|
codex-wrapper "simple task here" [working_dir]
|
||||||
```
|
```
|
||||||
|
|
||||||
**Resume a session with HEREDOC:**
|
**Resume a session with HEREDOC:**
|
||||||
```bash
|
```bash
|
||||||
uv run ~/.claude/skills/codex/scripts/codex.py resume <session_id> - [working_dir] <<'EOF'
|
codex-wrapper resume <session_id> - [working_dir] <<'EOF'
|
||||||
<task content>
|
<task content>
|
||||||
EOF
|
EOF
|
||||||
```
|
```
|
||||||
@@ -46,18 +46,19 @@ EOF
|
|||||||
- **Bash/Zsh**: Use `<<'EOF'` (single quotes prevent variable expansion)
|
- **Bash/Zsh**: Use `<<'EOF'` (single quotes prevent variable expansion)
|
||||||
- **PowerShell 5.1+**: Use `@'` and `'@` (here-string syntax)
|
- **PowerShell 5.1+**: Use `@'` and `'@` (here-string syntax)
|
||||||
```powershell
|
```powershell
|
||||||
uv run ~/.claude/skills/codex/scripts/codex.py - @'
|
codex-wrapper - @'
|
||||||
task content
|
task content
|
||||||
'@
|
'@
|
||||||
```
|
```
|
||||||
|
|
||||||
## Environment Variables
|
## Environment Variables
|
||||||
|
|
||||||
- **CODEX_TIMEOUT**: Override timeout in milliseconds (default: 7200000 = 2 hours)
|
- **CODEX_TIMEOUT**: Override timeout in milliseconds (default: 7200000 = 2 hours)
|
||||||
- Example: `export CODEX_TIMEOUT=3600000` for 1 hour
|
- Example: `export CODEX_TIMEOUT=3600000` for 1 hour
|
||||||
|
|
||||||
## Timeout Control
|
## Timeout Control
|
||||||
|
|
||||||
- **Built-in**: Script enforces 2-hour timeout by default
|
- **Built-in**: Binary enforces 2-hour timeout by default
|
||||||
- **Override**: Set `CODEX_TIMEOUT` environment variable (in milliseconds, e.g., `CODEX_TIMEOUT=3600000` for 1 hour)
|
- **Override**: Set `CODEX_TIMEOUT` environment variable (in milliseconds, e.g., `CODEX_TIMEOUT=3600000` for 1 hour)
|
||||||
- **Behavior**: On timeout, sends SIGTERM, then SIGKILL after 5s if process doesn't exit
|
- **Behavior**: On timeout, sends SIGTERM, then SIGKILL after 5s if process doesn't exit
|
||||||
- **Exit code**: Returns 124 on timeout (consistent with GNU timeout)
|
- **Exit code**: Returns 124 on timeout (consistent with GNU timeout)
|
||||||
@@ -91,7 +92,7 @@ All automated executions must use HEREDOC syntax through the Bash tool in the fo
|
|||||||
|
|
||||||
```
|
```
|
||||||
Bash tool parameters:
|
Bash tool parameters:
|
||||||
- command: uv run ~/.claude/skills/codex/scripts/codex.py - [working_dir] <<'EOF'
|
- command: codex-wrapper - [working_dir] <<'EOF'
|
||||||
<task content>
|
<task content>
|
||||||
EOF
|
EOF
|
||||||
- timeout: 7200000
|
- timeout: 7200000
|
||||||
@@ -106,19 +107,19 @@ Run every call in the foreground—never append `&` to background it—so logs a
|
|||||||
|
|
||||||
**Basic code analysis:**
|
**Basic code analysis:**
|
||||||
```bash
|
```bash
|
||||||
# Recommended: via uv run with HEREDOC (handles any special characters)
|
# Recommended: with HEREDOC (handles any special characters)
|
||||||
uv run ~/.claude/skills/codex/scripts/codex.py - <<'EOF'
|
codex-wrapper - <<'EOF'
|
||||||
explain @src/main.ts
|
explain @src/main.ts
|
||||||
EOF
|
EOF
|
||||||
# timeout: 7200000
|
# timeout: 7200000
|
||||||
|
|
||||||
# Alternative: simple direct quoting (if task is simple)
|
# Alternative: simple direct quoting (if task is simple)
|
||||||
uv run ~/.claude/skills/codex/scripts/codex.py "explain @src/main.ts"
|
codex-wrapper "explain @src/main.ts"
|
||||||
```
|
```
|
||||||
|
|
||||||
**Refactoring with multiline instructions:**
|
**Refactoring with multiline instructions:**
|
||||||
```bash
|
```bash
|
||||||
uv run ~/.claude/skills/codex/scripts/codex.py - <<'EOF'
|
codex-wrapper - <<'EOF'
|
||||||
refactor @src/utils for performance:
|
refactor @src/utils for performance:
|
||||||
- Extract duplicate code into helpers
|
- Extract duplicate code into helpers
|
||||||
- Use memoization for expensive calculations
|
- Use memoization for expensive calculations
|
||||||
@@ -129,7 +130,7 @@ EOF
|
|||||||
|
|
||||||
**Multi-file analysis:**
|
**Multi-file analysis:**
|
||||||
```bash
|
```bash
|
||||||
uv run ~/.claude/skills/codex/scripts/codex.py - "/path/to/project" <<'EOF'
|
codex-wrapper - "/path/to/project" <<'EOF'
|
||||||
analyze @. and find security issues:
|
analyze @. and find security issues:
|
||||||
1. Check for SQL injection vulnerabilities
|
1. Check for SQL injection vulnerabilities
|
||||||
2. Identify XSS risks in templates
|
2. Identify XSS risks in templates
|
||||||
@@ -142,13 +143,13 @@ EOF
|
|||||||
**Resume previous session:**
|
**Resume previous session:**
|
||||||
```bash
|
```bash
|
||||||
# First session
|
# First session
|
||||||
uv run ~/.claude/skills/codex/scripts/codex.py - <<'EOF'
|
codex-wrapper - <<'EOF'
|
||||||
add comments to @utils.js explaining the caching logic
|
add comments to @utils.js explaining the caching logic
|
||||||
EOF
|
EOF
|
||||||
# Output includes: SESSION_ID: 019a7247-ac9d-71f3-89e2-a823dbd8fd14
|
# Output includes: SESSION_ID: 019a7247-ac9d-71f3-89e2-a823dbd8fd14
|
||||||
|
|
||||||
# Continue the conversation with more context
|
# Continue the conversation with more context
|
||||||
uv run ~/.claude/skills/codex/scripts/codex.py resume 019a7247-ac9d-71f3-89e2-a823dbd8fd14 - <<'EOF'
|
codex-wrapper resume 019a7247-ac9d-71f3-89e2-a823dbd8fd14 - <<'EOF'
|
||||||
now add TypeScript type hints and handle edge cases where cache is null
|
now add TypeScript type hints and handle edge cases where cache is null
|
||||||
EOF
|
EOF
|
||||||
# timeout: 7200000
|
# timeout: 7200000
|
||||||
@@ -156,7 +157,7 @@ EOF
|
|||||||
|
|
||||||
**Task with code snippets and special characters:**
|
**Task with code snippets and special characters:**
|
||||||
```bash
|
```bash
|
||||||
uv run ~/.claude/skills/codex/scripts/codex.py - <<'EOF'
|
codex-wrapper - <<'EOF'
|
||||||
Fix the bug in @app.js where the regex /\d+/ doesn't match "123"
|
Fix the bug in @app.js where the regex /\d+/ doesn't match "123"
|
||||||
The current code is:
|
The current code is:
|
||||||
const re = /\d+/;
|
const re = /\d+/;
|
||||||
@@ -173,18 +174,16 @@ EOF
|
|||||||
|
|
||||||
| ID | Description | Scope | Dependencies | Tests | Command |
|
| ID | Description | Scope | Dependencies | Tests | Command |
|
||||||
| --- | --- | --- | --- | --- | --- |
|
| --- | --- | --- | --- | --- | --- |
|
||||||
| T1 | Review @spec.md to extract requirements | docs/, @spec.md | None | None | `uv run ~/.claude/skills/codex/scripts/codex.py - <<'EOF'`<br/>`analyze requirements @spec.md`<br/>`EOF` |
|
| T1 | Review @spec.md to extract requirements | docs/, @spec.md | None | None | `codex-wrapper - <<'EOF'`<br/>`analyze requirements @spec.md`<br/>`EOF` |
|
||||||
| T2 | Implement the module and add test cases | src/module | T1 | npm test -- --runInBand | `uv run ~/.claude/skills/codex/scripts/codex.py - <<'EOF'`<br/>`implement and test @src/module`<br/>`EOF` |
|
| T2 | Implement the module and add test cases | src/module | T1 | npm test -- --runInBand | `codex-wrapper - <<'EOF'`<br/>`implement and test @src/module`<br/>`EOF` |
|
||||||
|
|
||||||
## Notes
|
## Notes
|
||||||
|
|
||||||
- **Recommended**: Use `uv run` for automatic Python environment management (requires uv installed)
|
- **Binary distribution**: Single Go binary, zero dependencies
|
||||||
- **Alternative**: Direct execution `./codex.py` (uses system Python via shebang)
|
- **Installation**: Download from GitHub Releases or use install.sh
|
||||||
- Python implementation using standard library (zero dependencies)
|
- **Cross-platform compatible**: Linux (amd64/arm64), macOS (amd64/arm64)
|
||||||
- All automated runs must use the Bash tool with the fixed timeout to provide dual timeout protection and unified logging/exit semantics; any alternative approach is limited to manual foreground execution.
|
- All automated runs must use the Bash tool with the fixed timeout to provide dual timeout protection and unified logging/exit semantics
|
||||||
- Cross-platform compatible (Windows/macOS/Linux)
|
for automation (new sessions only)
|
||||||
- PEP 723 compliant (inline script metadata)
|
|
||||||
- Runs with `--dangerously-bypass-approvals-and-sandbox` for automation (new sessions only)
|
|
||||||
- Uses `--skip-git-repo-check` to work in any directory
|
- Uses `--skip-git-repo-check` to work in any directory
|
||||||
- Streams progress, returns only final agent message
|
- Streams progress, returns only final agent message
|
||||||
- Every execution returns a session ID for resuming conversations
|
- Every execution returns a session ID for resuming conversations
|
||||||
|
|||||||
Reference in New Issue
Block a user