feat: add HTTP message endpoint on WS server, pass managerPort to agents

- WS server: POST /message for agents to send messages (saved to API + broadcast)
- WS server: GET /health endpoint
- Spawner: inject TOBAN_MANAGER_PORT env var
- Types: add managerPort to AgentConfig

Author: recuu-pfeg

src/cli.ts

@@ -570,6 +570,7 @@ async function runLoop(cliArgs: CliArgs, runner: AgentRunner): Promise<void> {
           parentAgent: cliArgs.agentName,
           sprintNumber: sprintData.sprint.number,
           ...(Object.keys(secrets).length > 0 ? { secrets } : {}),
+          ...(actualWsPort ? { managerPort: actualWsPort } : {}),
         };
 
         ui.agentSpawned({

src/spawner.ts

@@ -110,6 +110,7 @@ export function spawnAgent(
       TOBAN_API_URL: config.apiUrl,
       TOBAN_AGENT_NAME: config.name,
       TOBAN_TASK_ID: config.taskId,
+      ...(config.managerPort ? { TOBAN_MANAGER_PORT: String(config.managerPort) } : {}),
       // Inject project secrets directly as env vars (no prefix in non-Docker mode)
       ...(config.secrets ?? {}),
     },

src/types.ts

@@ -29,6 +29,8 @@ export interface AgentConfig {
   commandTemplate?: string;
   /** Project secrets to inject into the agent environment */
   secrets?: Record<string, string>;
+  /** Manager WS server port (for agent HTTP messaging) */
+  managerPort?: number;
 }
 
 export type AgentStatus = "spawning" | "running" | "completed" | "failed" | "stopped";

src/ws-server.ts

@@ -58,7 +58,9 @@ export class WsChatServer {
    */
   async start(): Promise<number> {
     return new Promise((resolve, reject) => {
-      this.httpServer = createServer();
+      this.httpServer = createServer((req, res) => {
+        this.handleHttpRequest(req, res);
+      });
 
       this.wss = new WebSocketServer({
         server: this.httpServer,
@@ -222,6 +224,53 @@ export class WsChatServer {
     return this.port;
   }
 
+  private handleHttpRequest(req: IncomingMessage, res: import("node:http").ServerResponse): void {
+    // Health check
+    if (req.method === "GET" && (req.url === "/" || req.url === "/health")) {
+      res.writeHead(200, { "Content-Type": "application/json" });
+      res.end(JSON.stringify({ ok: true, clients: this.clients.size }));
+      return;
+    }
+
+    // Agent message endpoint
+    if (req.method === "POST" && req.url === "/message") {
+      let body = "";
+      req.on("data", (chunk: Buffer) => { body += chunk.toString(); });
+      req.on("end", () => {
+        try {
+          const { from, to, content } = JSON.parse(body);
+          if (!from || !to || !content) {
+            res.writeHead(400, { "Content-Type": "application/json" });
+            res.end(JSON.stringify({ error: "from, to, content required" }));
+            return;
+          }
+          this.handleAgentMessage(from, to, content);
+          res.writeHead(200, { "Content-Type": "application/json" });
+          res.end(JSON.stringify({ ok: true }));
+        } catch {
+          res.writeHead(400, { "Content-Type": "application/json" });
+          res.end(JSON.stringify({ error: "Invalid JSON" }));
+        }
+      });
+      return;
+    }
+
+    res.writeHead(404);
+    res.end();
+  }
+
+  private handleAgentMessage(from: string, to: string, content: string): void {
+    ui.info(`[ws] Agent message: ${from} → ${to}`);
+    this.saveMessageToApi(from, to, content).catch(() => {});
+    this.broadcast({
+      type: "chat",
+      from,
+      to,
+      content,
+      timestamp: new Date().toISOString(),
+    });
+  }
+
   private async handleMessage(ws: WebSocket, msg: WsMessage): Promise<void> {
     switch (msg.type) {
       case "ping":