update the request url

app/deployer.py

@@ -0,0 +1,45 @@
+import httpx
+import os
+import logging
+from dotenv import load_dotenv
+
+load_dotenv()
+
+GITHUB_TOKEN = os.getenv("GITHUB_TOKEN")
+GITHUB_API_URL = "https://api.github.com/"
+logger = logging.getLogger(__name__)
+
+async def create_github_repo(repo_name: str) -> dict:
+    headers = {"Authorization":f"Bearer {GITHUB_TOKEN}",
+               'Accept': 'application/vnd.github+json'
+               }
+    payload = {"name": repo_name}
+
+    async with httpx.AsyncClient() as client:
+        try:
+            response = await client.post(f"{GITHUB_API_URL}user/repos", headers=headers, json=payload)
+            response.raise_for_status()
+            logger.info(f"GitHub repo '{repo_name}' created successfully.")
+            return response.json()
+        except httpx.HTTPError as e:
+            logger.error(f"Failed to create GitHub repo: {e}")
+            raise RuntimeError(f"GitHub repo creation failed: {e}") from e
+
+def push_to_repo():
+    return
+
+def get_latest_sha():
+    return
+
+def enable_github_pages():
+    pass
+
+
+async def notify_evaluation_url(evaluation_url: str, payload: dict):
+    async with httpx.AsyncClient() as client:
+        try:
+            response = await client.post(evaluation_url, json=payload, timeout=10.0)
+            response.raise_for_status()
+        except httpx.HTTPError as e:
+            # Log error or handle failure as needed
+            print(f"Failed to notify evaluation URL: {e}")

app/llm.py

@@ -0,0 +1,5 @@
+def genereate_code_with_llm():
+    pass
+
+#might have to use pydantic ai 
+#we might need to fetch data from specific attachments

app/main.py

@@ -1,19 +1,37 @@
-from fastapi import FastAPI, HTTPException, status, Request
+from fastapi import FastAPI, HTTPException, status, Request,BackgroundTasks
+from fastapi.responses import JSONResponse
 from .models import TaskRequest
 from .utils import validate_secret
+from .rounds import round1,round2
 app = FastAPI()
 
-@app.post("/handle-task")
-async def handle_task(request: TaskRequest):
+
+@app.post("/handle-task",status_code=status.HTTP_200_OK)
+async def handle_task(request: TaskRequest, background_tasks: BackgroundTasks):
+    # Validate secret
     if not validate_secret(request.secret):
         raise HTTPException(
             status_code=status.HTTP_401_UNAUTHORIZED,
             detail="Invalid secret",
             headers={"WWW-Authenticate": "Bearer"},
         )
-    # Proceed with further task processing here
-    return {"status": "success"}
 
+    # Respond immediately
+    response = JSONResponse(
+        status_code=status.HTTP_200_OK,
+        content={
+            "status": "success",
+            "message": "Secret validated, task accepted for processing."
+        }
+    )
+    if request.round == 1 or request.round =="1":
+        print("in round 1")
+        background_tasks.add_task(round1, request)
+    elif request.round ==2 or request.round =="2":
+        background_tasks.add_task(round2)
+
+
+    return response
 
 
 

app/models.py

@@ -1,4 +1,16 @@
+from typing import List, Optional
 from pydantic import BaseModel
+class Attachment(BaseModel):
+    name: str
+    url: str
 
 class TaskRequest(BaseModel):
+    email: str
     secret: str
+    task: str
+    round: int
+    nonce: str
+    brief: str
+    checks: List[str]
+    evaluation_url: str
+    attachments: Optional[List[Attachment]] = None

app/rounds.py

@@ -0,0 +1,29 @@
+from .models import TaskRequest
+from .deployer import create_github_repo,notify_evaluation_url
+
+
+def round2():
+    print("inside round 2")
+
+
+async def  round1(request: TaskRequest):
+    try:
+        repo_response = await create_github_repo(repo_name=request.task)
+        repo_url = repo_response.get("html_url", "")
+        # Temporary placeholders for commit_sha and pages_url
+        commit_sha = ""
+        pages_url = ""
+
+        # Prepare payload
+        payload = {
+            "email": request.email,
+            "task": request.task,
+            "round": request.round,
+            "nonce": request.nonce,
+            "repo_url": repo_url,
+            "commit_sha": commit_sha,
+            "pages_url": pages_url,
+        }
+        await notify_evaluation_url(request.evaluation_url, payload)
+    except Exception as e:
+        print(f"Error in background task: {e}")

evaluation/server.py

@@ -0,0 +1,14 @@
+from fastapi import FastAPI, Request
+import uvicorn
+
+app = FastAPI()
+
+@app.post("/notify")
+async def receive_evaluation(request: Request):
+    data = await request.json()
+    print("Received evaluation data:")
+    print(data)
+    return {"status": "received"}
+
+if __name__ == "__main__":
+    uvicorn.run(app, host="0.0.0.0", port=8001)

requirements.txt

@@ -2,6 +2,6 @@ fastapi==0.104.1
 uvicorn[standard]==0.24.0
 python-multipart==0.0.6
 pydantic
-
+httpx
 
 python-dotenv==1.0.0