export ANTHROPIC_API_KEY=sk-ant-...
claude --version   # 确认版本

~/.claude/projects/<工作目录路径-非字母数字替换为->/<session-id>.jsonl

# 启动时命名
claude -n auth-refactor

# 会话内改名
/rename auth-refactor

# 选择器里高亮后按 Ctrl+R

claude -p "审查这个代码库的性能问题" --output-format json > run.json
jq '{session_id, cost: .total_cost_usd, result: .result[0:80]}' run.json

{
  "session_id": "a1b2c3d4-...",
  "cost": 0.0123,
  "result": "发现 3 个 N+1 查询，集中在 user_service.py..."
}

session_id=$(claude -p "开始一次审查" --output-format json | jq -r '.session_id')
echo "拿到会话: $session_id"

# 第一条
session_id=$(claude -p "审查这个代码库的性能问题" --output-format json | jq -r '.session_id')

# 续问 1
claude -p "现在重点看数据库查询"           --resume "$session_id"
# 续问 2
claude -p "汇总所有发现的问题"            --resume "$session_id"

claude -p "解释递归" \
  --output-format stream-json \
  --verbose \
  --include-partial-messages

claude -p "写一首关于调试的诗" \
  --output-format stream-json --verbose --include-partial-messages | \
  jq -rj 'select(.type=="stream_event" and .event.delta.type?=="text_delta") | .event.delta.text'

claude -p "提取 auth.py 里的主函数名" \
  --output-format json \
  --json-schema '{"type":"object","properties":{"functions":{"type":"array","items":{"type":"string"}}},"required":["functions"]}' \
  | jq '.structured_output'

{"functions": ["login", "verify_token", "refresh_session"]}

# 命令行：续跑 + 分支
claude --resume "$session_id" --fork-session

# 会话内
/branch try-streaming-approach

my-project/
├─ run.sh            # 运行器
├─ stream_parse.py   # 流式解析器
└─ .agent_state.json # 上次会话状态（自动生成）

#!/usr/bin/env python3
# 读 claude 的 stream-json，打印实时进度，并把最终状态写盘
import sys, json

state_path = sys.argv[1] if len(sys.argv) > 1 else None
session_id, cost, is_error = None, None, False

for line in sys.stdin:
    line = line.strip()
    if not line:
        continue
    try:
        evt = json.loads(line)
    except json.JSONDecodeError:
        continue

    t = evt.get("type")

    # 1) 开场即拿到 session_id、模型、加载的工具/MCP/插件
    if t == "system" and evt.get("subtype") == "init":
        session_id = evt.get("session_id")
        print(f"[init] session={session_id} model={evt.get('model')} "
              f"tools={len(evt.get('tools', []))}", flush=True)

    # 2) 限流/过载重试：可据此发告警或自定义退避
    elif t == "system" and evt.get("subtype") == "api_retry":
        print(f"[retry] 第{evt.get('attempt')}/{evt.get('max_retries')}次 "
              f"{evt.get('error')} (http {evt.get('error_status')}) "
              f"等待 {evt.get('retry_delay_ms')}ms", flush=True)

    # 3) 助手消息：只打印工具调用（文本已由下面的 delta 实时打印）
    elif t == "assistant":
        for c in evt.get("message", {}).get("content", []):
            if c.get("type") == "tool_use":
                print(f"\n[tool] {c.get('name')} -> " +
                      json.dumps(c.get("input", {}), ensure_ascii=False)[:120],
                      flush=True)

    # 4) 逐 token 文本流（需 --include-partial-messages）
    elif t == "stream_event":
        d = evt.get("event", {}).get("delta", {})
        if d.get("type") == "text_delta":
            sys.stdout.write(d.get("text", ""))
            sys.stdout.flush()

    # 5) 权威收尾：最终 session_id / 成本 / 是否出错
    elif t == "result":
        session_id = evt.get("session_id")
        cost = evt.get("total_cost_usd")
        is_error = evt.get("is_error", False)

print(f"\n[done] session={session_id} cost=${cost} error={is_error}", flush=True)

if state_path:
    with open(state_path, "w") as f:
        json.dump({"session_id": session_id, "cost": cost,
                   "is_error": is_error}, f)

sys.exit(1 if is_error else 0)   # 退出码驱动运行器

#!/usr/bin/env bash
set -uo pipefail

PROMPT="${1:?用法: ./run.sh \"<任务>\" [额外 claude 参数]}"
STATE=".agent_state.json"
RESUME=""

# 有上次会话就续跑，没有就新开
if [[ -f "$STATE" ]] && SID=$(jq -r '.session_id // empty' "$STATE") && [[ -n "$SID" ]]; then
  echo "↩  续跑会话 $SID"
  RESUME="--resume $SID"
else
  echo "✦  新建会话"
fi

# --bare：跳过 hooks/skills/plugins/MCP/CLAUDE.md，保证多机一致（官方推荐脚本默认）
# 注意 bare 跳过 OAuth，鉴权须来自 ANTHROPIC_API_KEY
# shellcheck disable=SC2086
claude --bare -p "$PROMPT" $RESUME \
  --output-format stream-json \
  --verbose \
  --include-partial-messages \
  --permission-mode acceptEdits \
  ${2:-} \
  | python3 stream_parse.py "$STATE"

code=$?
if (( code != 0 )); then
  echo "✗ 失败(退出码 $code)。状态已存于 $STATE，重跑本命令即可从断点续上。"
  exit 1
fi
echo "✓ 完成。会话 $(jq -r '.session_id' "$STATE") 已记录，累计成本 \$$(jq -r '.cost' "$STATE")。"

chmod +x run.sh stream_parse.py

# 第一次：新开会话
./run.sh "把 src/ 下所有 console.log 换成项目统一的 logger，并跑一遍测试"

# 中途被限流/超时/你按了 Ctrl+C —— 状态已落盘，直接重跑：
./run.sh "继续刚才的任务"

flowchart TD
    A["运行 ./run.sh '任务'"] --> B{".agent_state.json 存在?"}
    B -- 是 --> C["读取上次 session_id"]
    C --> D["claude --resume SID 续跑"]
    B -- 否 --> E["claude 新开会话"]
    D --> F["stream-json 实时事件流"]
    E --> F
    F --> G["stream_parse.py 解析"]
    G --> H["打印 init/tool/retry/文本"]
    H --> I["捕获 result 事件"]
    I --> J["写 session_id 到状态文件"]
    J --> K{"is_error?"}
    K -- 是 --> L["退出非 0，等待重跑"]
    K -- 否 --> M["✓ 完成"]
    L --> B