用 Issue Tracker 当控制面：OpenAI 开源 Symphony，让多编码 Agent 自主协作

name: Agent Task
description: 一个可由编码 Agent 自主完成的任务
labels: ["agent-task"]
body:
  - type: textarea
    id: description
    attributes:
      label: 任务描述
      description: 请写清楚要做什么、改哪个文件、期望的行为是什么。Agent 不会回问。
      placeholder: "例如：在 src/api/users.py 中添加 DELETE /users/{id} 端点，返回 204，需覆盖测试"
    validations:
      required: true
  - type: textarea
    id: constraints
    attributes:
      label: 约束与边界
      description: Agent 必须遵守的规则
      placeholder: "例如：不要改动数据库 schema；只修改 users.py 和 tests/test_users.py"

"""
symphony_minimal.py — 最小 Symphony 编排原型
依赖: pip install openai PyGithub
环境变量: GITHUB_TOKEN, OPENAI_API_KEY, REPO_NAME (格式: owner/repo)
"""

import os
import json
import subprocess
from github import Github
from openai import OpenAI

REPO_NAME = os.environ["REPO_NAME"]          # e.g. "myorg/myrepo"
GITHUB_TOKEN = os.environ["GITHUB_TOKEN"]
OPENAI_API_KEY = os.environ["OPENAI_API_KEY"]

gh = Github(GITHUB_TOKEN)
repo = gh.get_repo(REPO_NAME)
client = OpenAI(api_key=OPENAI_API_KEY)

AGENT_LABEL = "agent-task"
STATUS_LABELS = {"in-progress": "agent-in-progress", "done": "agent-done"}

def fetch_open_tasks():
    """获取所有标记为 agent-task 且未关闭的 Issue"""
    issues = repo.get_issues(state="open", labels=[AGENT_LABEL])
    return [i for i in issues if not any(
        l.name == STATUS_LABELS["in-progress"] or l.name == STATUS_LABELS["done"]
        for l in i.labels
    )]

def mark_status(issue, status):
    """给 Issue 打上状态标签"""
    label = repo.get_label(STATUS_LABELS[status])
    issue.add_to_labels(label)

def agent_run(issue):
    """让 Agent 自主完成一个 Issue"""
    prompt = f"""你是一个自主编码 Agent。以下是你的任务 Issue：

标题: {issue.title}
描述: {issue.body}

规则:
1. 只修改与任务直接相关的文件。
2. 写完代码后生成对应的测试。
3. 输出格式为 JSON，包含两个字段:
   - "files": 一个 dict，key 是文件路径，value 是文件完整内容
   - "summary": 一段简短的变更说明

请直接输出 JSON，不要解释过程。"""

    response = client.chat.completions.create(
        model="gpt-4.1",
        messages=[{"role": "user", "content": prompt}],
        response_format={"type": "json_object"},
    )

    result = json.loads(response.choices[0].message.content)
    return result

def apply_changes(result, issue):
    """把 Agent 产出的文件写入本地，提交并推 PR"""
    branch_name = f"agent-task-{issue.number}"
    base_branch = repo.default_branch

    # 从 base branch 创建新分支
    ref = repo.get_git_ref(f"heads/{base_branch}")
    repo.create_git_ref(f"refs/heads/{branch_name}", ref.object.sha)

    for path, content in result["files"].items():
        # 尝试获取已有文件（如果存在则更新，否则创建）
        try:
            existing = repo.get_contents(path, ref=branch_name)
            repo.update_file(
                path=path,
                message=f"agent update: {path}",
                content=content,
                sha=existing.sha,
                branch=branch_name,
            )
        except Exception:
            repo.create_file(
                path=path,
                message=f"agent create: {path}",
                content=content,
                branch=branch_name,
            )

    # 创建 Pull Request
    pr = repo.create_pull(
        title=f"[Agent] {issue.title}",
        body=result["summary"] + f"\n\nCloses #{issue.number}",
        head=branch_name,
        base=base_branch,
    )

    # 在 Issue 上评论 PR 链接
    issue.create_comment(f"Agent 已完成，PR: #{pr.number}")
    return pr

def main():
    tasks = fetch_open_tasks()
    print(f"发现 {len(tasks)} 个待处理 Agent Task")

    for issue in tasks:
        print(f"→ 处理 Issue #{issue.number}: {issue.title}")
        mark_status(issue, "in-progress")

        result = agent_run(issue)
        pr = apply_changes(result, issue)

        mark_status(issue, "done")
        print(f"  ✓ PR #{pr.number} 已创建，等待人类 Review")

if __name__ == "__main__":
    main()

# 安装依赖
pip install openai PyGithub

# 设置环境变量
export GITHUB_TOKEN="ghp_xxxx"
export OPENAI_API_KEY="sk-xxxx"
export REPO_NAME="myorg/myrepo"

# 执行编排
python symphony_minimal.py