118 lines
3.6 KiB
Python
118 lines
3.6 KiB
Python
import logging
|
|
import os
|
|
from contextlib import asynccontextmanager
|
|
|
|
import httpx
|
|
from dotenv import load_dotenv
|
|
from fastapi import FastAPI, HTTPException
|
|
|
|
from agents.coders.BaseCoder import CoderAgent
|
|
from agents.issue_triage.IssueTriageAgent import IssueTriageAgent
|
|
from agents.issue_triage.context_builder import YouTrackContextBuilder
|
|
from agents.registry import AgentRegistry
|
|
from common.gitea_mcp_client import GiteaMCPClient
|
|
from common.llm_client import LLMClient
|
|
from common.youtrack_mcp_client import YouTrackMCPClient, IssueNotFound
|
|
|
|
logging.basicConfig(level=logging.INFO)
|
|
logger = logging.getLogger(__name__)
|
|
|
|
load_dotenv()
|
|
def env(key: str) -> str:
|
|
value = os.environ.get(key)
|
|
if not value:
|
|
raise RuntimeError(f"Missing required env var: {key}")
|
|
return value
|
|
|
|
@asynccontextmanager
|
|
async def lifespan(app: FastAPI):
|
|
app.state.youtrack_mcp = await YouTrackMCPClient(
|
|
str(os.getenv('YOUTRACK_MCP_SERVER')),
|
|
str(os.getenv('YOUTRACK_MCP_TOKEN')),
|
|
).connect()
|
|
#
|
|
#
|
|
# res = await mcp.call_tool(
|
|
# "add_issue_comment",
|
|
# {"issueId": "ARCH-229", "text": "test"}
|
|
# )
|
|
# logger.info(res)
|
|
|
|
http_for_attachments = httpx.AsyncClient(
|
|
headers={"Authorization": f"Bearer {env('YOUTRACK_MCP_TOKEN')}"},
|
|
proxy=env("HTTPS_PROXY"),
|
|
timeout=httpx.Timeout(30.0, connect=10.0, read=60.0),
|
|
follow_redirects=True,
|
|
)
|
|
|
|
app.state.issue_reader_agent = IssueTriageAgent(
|
|
YouTrackContextBuilder(app.state.youtrack_mcp, http_for_attachments),
|
|
LLMClient(
|
|
base_url=env("LLM_ADDRESS"),
|
|
api_key=env("LLM_API_KEY"),
|
|
model=env("LLM_MODEL"),
|
|
),
|
|
AgentRegistry(),
|
|
app.state.youtrack_mcp
|
|
)
|
|
|
|
yield
|
|
|
|
# ---- shutdown ----
|
|
await app.state.youtrack_mcp.close()
|
|
app = FastAPI(lifespan=lifespan)
|
|
|
|
@app.get("/")
|
|
async def root():
|
|
return {"message": "Hello World"}
|
|
|
|
|
|
@app.get("/hello/{name}")
|
|
async def say_hello(name: str):
|
|
return {"message": f"Hello {name}"}
|
|
|
|
|
|
@app.get("/consume_task")
|
|
async def decomposing_issue(issue: str):
|
|
agent: IssueTriageAgent = app.state.issue_reader_agent
|
|
try:
|
|
logger.info(f"Received an issue: {issue}")
|
|
plan = await agent.plan_issue(issue)
|
|
logger.info("Task planning successful.")
|
|
logger.info(plan.render())
|
|
return {"plan": plan}
|
|
except IssueNotFound:
|
|
logger.error(f"Issue {issue} not found.")
|
|
raise HTTPException(status_code=404, detail=f"Issue {issue} not found")
|
|
except Exception as e:
|
|
logger.exception("An unexpected error occurred")
|
|
return {"error": str(e)}
|
|
|
|
@app.get("/code_issue")
|
|
async def code_issue(issue: str):
|
|
issue_agent: IssueTriageAgent = app.state.issue_reader_agent
|
|
gitea_mcp_client = GiteaMCPClient()
|
|
coder_agent: CoderAgent = CoderAgent(
|
|
str(os.getenv("CODER_ID")),
|
|
issue_agent.ctx_builder,
|
|
issue_agent.llm,
|
|
issue_agent.agent_registry,
|
|
issue_agent.youtrack_mcp,
|
|
gitea_mcp_client
|
|
)
|
|
|
|
try:
|
|
logger.info(f"Resolve an issue: {issue}")
|
|
issue_ctx = await issue_agent.ctx_builder.build(issue)
|
|
if issue_ctx:
|
|
response = await coder_agent.fix_an_issue(issue_ctx)
|
|
logger.info("Task planning successful.")
|
|
return {"status": "ok", "response": response}
|
|
except IssueNotFound:
|
|
logger.error(f"Issue {issue} not found.")
|
|
raise HTTPException(status_code=404, detail=f"Issue {issue} not found")
|
|
except Exception as e:
|
|
logger.exception("An unexpected error occurred")
|
|
return {"error": str(e)}
|
|
|
|
return {"error": "No context was created"} |