From 73b04f6117543de6fbc851910a2c42d47993e7e8 Mon Sep 17 00:00:00 2001
From: aitbc <aitbc@keisanki.net>
Date: Fri, 15 May 2026 06:37:01 +0200
Subject: [PATCH] fix: swarm coordinator endpoints

Fixed parameter naming conflict in swarm router where 'request' parameter
was shadowed by FastAPI's HTTP Request object. Renamed body parameters to
'body' and Request parameters to 'http_request'.

Also fixed consensus endpoint which was accessing request.consensus_threshold
instead of request_consensus.consensus_threshold.

All swarm endpoints now work: join, coordinate, status, consensus, leave.
---
 .../src/app/routers/swarm.py                  | 24 +++++++++----------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git a/apps/agent-coordinator/src/app/routers/swarm.py b/apps/agent-coordinator/src/app/routers/swarm.py
index ffae4bf3..c5ee4a1c 100644
--- a/apps/agent-coordinator/src/app/routers/swarm.py
+++ b/apps/agent-coordinator/src/app/routers/swarm.py
@@ -64,16 +64,16 @@ async def list_swarms(
 @router.post("/join", response_model=dict, status_code=201)
 @rate_limit(rate=50, per=60)
 async def join_swarm(
-    request_http: Request, request: JoinRequest
+    http_request: Request, body: JoinRequest
 ):
     """Join agent swarm for collective optimization."""
     import uuid
     return {
         "swarm_id": f"swarm_{uuid.uuid4().hex[:16]}",
-        "role": request.role,
-        "capability": request.capability,
-        "priority": request.priority,
-        "region": request.region,
+        "role": body.role,
+        "capability": body.capability,
+        "priority": body.priority,
+        "region": body.region,
         "status": "joined"
     }
 
@@ -81,16 +81,16 @@ async def join_swarm(
 @router.post("/coordinate", response_model=dict, status_code=202)
 @rate_limit(rate=50, per=60)
 async def coordinate_swarm(
-    request_http: Request, request: CoordinateRequest
+    http_request: Request, body: CoordinateRequest
 ):
     """Coordinate swarm task execution."""
     import uuid
     return {
         "task_id": f"task_{uuid.uuid4().hex[:16]}",
-        "task": request.task,
-        "collaborators": request.collaborators,
-        "strategy": request.strategy,
-        "timeout_seconds": request.timeout_seconds,
+        "task": body.task,
+        "collaborators": body.collaborators,
+        "strategy": body.strategy,
+        "timeout_seconds": body.timeout_seconds,
         "status": "coordinating"
     }
 
@@ -126,12 +126,12 @@ async def leave_swarm(
 @router.post("/tasks/{task_id}/consensus", response_model=dict)
 @rate_limit(rate=50, per=60)
 async def achieve_consensus(
-    request: Request, task_id: str, request_consensus: ConsensusRequest
+    request: Request, task_id: str, body: ConsensusRequest
 ):
     """Achieve swarm consensus on task result."""
     return {
         "task_id": task_id,
-        "consensus_threshold": request.consensus_threshold,
+        "consensus_threshold": body.consensus_threshold,
         "consensus_reached": True,
         "status": "consensus_achieved"
     }