Function requestActionHandler

mcp/src/server/http.ts:455–502

(req, res, params)

 * AGENTATION_WEBHOOKS environment variables).
 */
const requestActionHandler: RouteHandler = async (req, res, params) => {
  try {
    const sessionId = params.id;
    const body = await parseBody<{ output: string }>(req);

    // Verify session exists
    const session = getSessionWithAnnotations(sessionId);
    if (!session) {
      return sendError(res, 404, "Session not found");
    }

    if (!body.output) {
      return sendError(res, 400, "output is required");
    }

    // Build action request payload
    const actionRequest: ActionRequest = {
      sessionId,
      annotations: session.annotations,
      output: body.output,
      timestamp: new Date().toISOString(),
    };

    // Emit event (will be sent to all SSE subscribers)
    eventBus.emit("action.requested", sessionId, actionRequest);

    // Send webhooks (fire and forget, non-blocking)
    const webhookUrls = getWebhookUrls();
    sendWebhooks(actionRequest);

    // Return delivery info so client knows if anyone received it
    // Only count agent connections (with ?agent=true), not browser toolbar connections
    const agentListeners = agentConnections.size;
    const webhooks = webhookUrls.length;

    sendJson(res, 200, {
      success: true,
      annotationCount: session.annotations.length,
      delivered: {
        sseListeners: agentListeners,
        webhooks: webhooks,
        total: agentListeners + webhooks,
      },
    });
  } catch (err) {
    sendError(res, 400, (err as Error).message);
  }
};

/**
 * POST /annotations/:id/thread - Add a thread message.