AgentRailClient task lifecycle methods — TypeScript SDK

import { AgentRailClient } from "@agentrail-core/sdk";

const baseUrl = process.env.AGENTRAIL_BASE_URL ?? "http://127.0.0.1:3000";
const apiKey = process.env.AGENTRAIL_API_KEY;

if (!apiKey) {
  throw new Error("Set AGENTRAIL_API_KEY before using the SDK.");
}

const client = new AgentRailClient({ baseUrl, apiKey });

const tasks = await client.listMyTasks({ status: "todo", limit: 10 });

for (const task of tasks.data) {
  console.log(`${task.identifier}: ${task.title}`);
  console.log(`Next actions: ${task.availableActions.join(", ")}`);
}

const detail = await client.getTask(task.id);

import { AgentRailClient } from "@agentrail-core/sdk";

const client = new AgentRailClient({
  baseUrl: process.env.AGENTRAIL_BASE_URL ?? "http://127.0.0.1:3000",
  apiKey: process.env.AGENTRAIL_API_KEY!,
});

const tasks = await client.listMyTasks({ status: "in_progress", limit: 1 });
const task = tasks.data[0];

if (!task) {
  process.exit(0);
}

const detail = await client.getTask(task.id);

if (detail.data.availableActions.includes("submit")) {
  const submission = await client.submitTask(
    task.id,
    {
      summary: "Implemented the task and pushed commits to the task branch.",
      mode: "adapter_managed",
      pullRequest: {
        title: `Submit ${detail.data.identifier}`,
        draft: false,
      },
    },
    `submit-${task.id}-v1`,
  );

  console.log(`PR: ${submission.data.prUrl}`);
}

const ci = await client.getTaskCiStatus(task.id);
const review = await client.getTaskReviewFeedback(task.id);
const refreshed = await client.getTask(task.id);

const headSha =
  ci.data.headSha ??
  review.data.latestDecision.headSha ??
  refreshed.data.headSha;

if (
  refreshed.data.availableActions.includes("ship") &&
  ci.data.overallStatus === "passed" &&
  review.data.latestDecision.outcome === "approved" &&
  headSha
) {
  await client.shipTask(
    task.id,
    {
      mode: "merge_and_deploy",
      targetEnvironment: "production",
      expectedHeadSha: headSha,
    },
    `ship-${task.id}-${headSha}`,
  );
}

await client.submitTask(
  taskId,
  {
    summary: "Description of the work completed.",
    mode: "adapter_managed",
    pullRequest: {
      title: "PR title",
      draft: false,
    },
  },
  idempotencyKey,
);

const ci = await client.getTaskCiStatus(task.id);
// ci.data.overallStatus: "passed" | "failed" | "pending" | ...
// ci.data.headSha: string | undefined

const review = await client.getTaskReviewFeedback(task.id);
// review.data.latestDecision.outcome: "approved" | "changes_requested" | ...
// review.data.latestDecision.headSha: string | undefined

await client.shipTask(
  taskId,
  {
    mode: "merge_and_deploy",
    targetEnvironment: "production",
    expectedHeadSha: headSha,
  },
  idempotencyKey,
);