Supervisor MCP Reference

const { workspaces } = await listWorkspaces();
// -> [ { id: "0eCTDeDXETx", name: "billing-service", agentConnected: true, ... }, ... ]

const { workspace } = await createWorkspace({
  name: "billing-service",
  description: "Stripe webhook handling and invoice reconciliation.",
});

console.log(workspace.id, workspace.mcpUrl);
// "0eCTDeDXETx" "https://mcp.agentrq.com/mcp/0eCTDeDXETx"

const { workspace } = await getWorkspace({ id: "0eCTDeDXETx" });
console.log(workspace.name, workspace.agentConnected);

await updateWorkspace({
  id: "0eCTDeDXETx",
  selfLearningLoopNote: "Prefer Stripe test-mode keys unless told otherwise.",
});

const stats = await getWorkspaceStats({ id: "0eCTDeDXETx", range: "7d" });
console.log(stats.summary.tasksCompleted, stats.summary.autoApprovals);

const { tasks } = await listAllTasks({ status: "blocked", limit: 20 });
// every blocked task across every workspace you own

const { tasks } = await listTasks({ workspaceId: "0eCTDeDXETx", status: "ongoing" });

const { task } = await getTask({ workspaceId: "0eCTDeDXETx", taskId: "0ZRgCquBZ7R" });
console.log(task.status, task.messages.length);

const { task } = await createTask({
  workspaceId: "0eCTDeDXETx",
  title: "Review: Stripe webhook signature check",
  body: "Verify the new endpoint rejects unsigned payloads.",
  assignee: "agent",
});
console.log(task.id); // "0ZRgCquBZ7R"

await updateTaskStatus({ workspaceId: "0eCTDeDXETx", taskId: "0ZRgCquBZ7R", status: "completed" });

await updateTaskAssignee({ workspaceId: "0eCTDeDXETx", taskId: "0ZRgCquBZ7R", assignee: "human" });

await updateTaskOrder({ workspaceId: "0eCTDeDXETx", taskId: "0ZRgCquBZ7R", sortOrder: 1.5 });

await updateTaskAllowAll({ workspaceId: "0eCTDeDXETx", taskId: "0ZRgCquBZ7R", allowAll: true });

await updateScheduledTask({
  workspaceId: "0eCTDeDXETx",
  taskId:      "0ZRgCquBZ7R",
  cronSchedule: "0 9 * * *",  // every day at 09:00
});

await deleteTask({ workspaceId: "0eCTDeDXETx", taskId: "0ZRgCquBZ7R" });

await respondToTask({ workspaceId: "0eCTDeDXETx", taskId: "0ZRgCquBZ7R", action: "allow" });

await replyToTask({ workspaceId: "0eCTDeDXETx", taskId: "0ZRgCquBZ7R", text: "Checked the logs — looks clean." });

const att = await getAttachment({ workspaceId: "0eCTDeDXETx", attachmentId: "att_abc123" });
const content = Buffer.from(att.Data, "base64");

const { memories } = await listMemories({ workspaceId: "0eCTDeDXETx" });
// [ { name: "MEMORY.md", sizeBytes: 1204, ... }, { name: "feedback-testing.md", ... } ]

const { memory } = await getMemory({ workspaceId: "0eCTDeDXETx", name: "MEMORY.md" });
console.log(memory.content);

const { events } = await listEvents();

const { event } = await createEvent({
  name: "qa_passed",
  payloadGuidelines: "Include the build number and the pass/fail counts.",
});
console.log(event.id); // "0hNRmEWoU5Z"

const { event } = await getEvent({ eventId: "0hNRmEWoU5Z" });

await updateEvent({ eventId: "0hNRmEWoU5Z", payloadGuidelines: "Also include the git SHA." });

await deleteEvent({ eventId: "0hNRmEWoU5Z" });

const { tasks } = await listEventTasks({ eventId: "0hNRmEWoU5Z" });

const { eventTrigger } = await createEventTrigger({
  eventId:     "0hNRmEWoU5Z",
  workspaceId: "0eCTDeDXETx",
  title:       "Ship the release",
  body:        "QA signed off:\n{{EVENT_PAYLOAD}}",
  emitEventId: "0hDXw48jLfd",
});

const { eventTriggers } = await listEventTriggers({ eventId: "0hNRmEWoU5Z" });

const { eventTrigger } = await getEventTrigger({ triggerId: "0hTr16erABC" });

await updateEventTrigger({
  triggerId:   "0hTr16erABC",
  workspaceId: "0eCTDeDXETx",
  title:       "Ship the release",     // unchanged fields must still be sent
  body:        "QA signed off:\n{{EVENT_PAYLOAD}}",
  emitEventId: "0hDXw48jLfd",
});

await deleteEventTrigger({ triggerId: "0hTr16erABC" });

const { workflows } = await listWorkflows();

const { workflow } = await createWorkflow({
  name:         "release-pipeline",
  startEventId: "0hNRmEWoU5Z",
});
console.log(workflow.id); // "0hWfK92pXqL"

const { workflow } = await getWorkflow({ workflowId: "0hWfK92pXqL" });

await updateWorkflow({ workflowId: "0hWfK92pXqL", description: "QA sign-off through to deploy." });

await deleteWorkflow({ workflowId: "0hWfK92pXqL" });

await createWorkflowStep({
  workflowId:  "0hWfK92pXqL",
  eventId:     "0hNRmEWoU5Z",
  workspaceId: "0eCTDeDXETx",
  title:       "Ship the release",
  body:        "QA signed off:\n{{EVENT_PAYLOAD}}",
  emitEventId: "0hDXw48jLfd",
});

const { workflowSteps } = await listWorkflowSteps({ workflowId: "0hWfK92pXqL" });

await deleteWorkflowStep({ workflowId: "0hWfK92pXqL", stepId: "0hStPq9zXYZ" });

const { tasks } = await listWorkflowTasks({ workflowId: "0hWfK92pXqL" });

const text = await getWorkflowText({ workflowId: "0hWfK92pXqL" });
console.log(text);
// - event:qa_passed
//   - agent:billing-service
//     - event:deploy_finished

await replaceWorkflowFromText({
  workflowId: "0hWfK92pXqL",
  text: `- event:qa_passed
  - agent:billing-service
    - event:deploy_finished`,
});

const { code, enrolCommand } = await createEnrolmentCode();
// enrolCommand: "agentrqd enroll --server https://agentrq.example --code AB12CD34"