Function addThreadHandler

mcp/src/server/http.ts:507–525

(req, res, params)

 * POST /annotations/:id/thread - Add a thread message.
 */
const addThreadHandler: RouteHandler = async (req, res, params) => {
  try {
    const body = await parseBody<{ role: "human" | "agent"; content: string }>(req);

    if (!body.role || !body.content) {
      return sendError(res, 400, "role and content are required");
    }

    const annotation = addThreadMessage(params.id, body.role, body.content);

    if (!annotation) {
      return sendError(res, 404, "Annotation not found");
    }

    sendJson(res, 201, annotation);
  } catch (err) {
    sendError(res, 400, (err as Error).message);
  }
};

/**
 * GET /sessions/:id/events - SSE stream of events for a session.