Create app.py

app.py

@@ -0,0 +1,48 @@
+from fastapi import FastAPI
+from fastapi.responses import StreamingResponse
+from pydantic import BaseModel
+import subprocess
+import shlex
+
+app = FastAPI()
+
+class AgentRequest(BaseModel):
+    prompt: str
+    # Defaulting to one of the built-in free OpenCode Zen models
+    model: str = "opencode/minimax-m2.5-free" 
+
+def stream_opencode_logs(prompt: str, model: str):
+    """
+    Executes OpenCode in headless mode and streams the live terminal output.
+    """
+    # shlex.quote ensures the prompt doesn't break the shell command
+    cmd = f'opencode run --model {shlex.quote(model)} {shlex.quote(prompt)}'
+    
+    # Run OpenCode as a subprocess and capture stdout live
+    process = subprocess.Popen(
+        cmd,
+        shell=True,
+        stdout=subprocess.PIPE,
+        stderr=subprocess.STDOUT, # Pipe errors to the same log stream
+        text=True,
+        bufsize=1
+    )
+    
+    # Yield logs line-by-line as Server-Sent Events
+    for line in process.stdout:
+        yield f"data: {line}\n\n"
+        
+    process.stdout.close()
+    process.wait()
+    yield f"data: [DONE]\n\n"
+
+@app.post("/run")
+async def execute_task(req: AgentRequest):
+    return StreamingResponse(
+        stream_opencode_logs(req.prompt, req.model), 
+        media_type="text/event-stream"
+    )
+
+@app.get("/")
+def health_check():
+    return {"status": "OpenCode Executor is live and waiting for Super Agent!"}