TypeScript SDK

import { S6SClient, WorkflowBuilder, ref } from "@s6s/sdk";

const client = new S6SClient({
  baseUrl: "https://s6s.ai",
  apiKey: process.env.S6S_API_KEY!,
});

const builder = new WorkflowBuilder("Health Check")
  .schedule("0 * * * *")
  .httpGet("Ping", "https://example.com/health");
const pingId = builder.lastNodeId;

builder.transform("Format", {
  status: ref(pingId, "status"),
  checkedAt: "{{run.startedAt}}",
});

const { workflowId } = await client.deployWorkflow(builder.build());
console.log("Deployed:", workflowId);

// Don't wait for the schedule: start a run now
const { runId } = await client.runWorkflow(workflowId);
const result = await client.waitForRun(runId);
console.log("Status:", result.status);
console.log(result.steps.map((s) => `${s.nodeType}: ${s.status}`));

const builder = new WorkflowBuilder("Order Processor")
  .webhook("/orders/new", "POST")
  .transform("Extract", {
    orderId: "{{trigger.output.body.order_id}}",
    email: "{{trigger.output.body.customer_email}}",
  });
const extractId = builder.lastNodeId;

builder
  .slack("Notify Team", "#orders",
    `New order #${ref(extractId, "orderId")} from ${ref(extractId, "email")}`,
    { id: "default" },
  );

const result = await client.deployWorkflow(builder.build());

if (result.missing_credentials?.length) {
  // Connect Slack, then deploy again to get the webhook details
  console.log(result.missing_credentials.map((c) => c.connect_url));
} else {
  console.log("Webhook URL:", result.webhookTrigger?.invokeUrl);
  console.log("Secret:", result.webhookTrigger?.secret); // first deploy only
}

// List all workflows
const workflows = await client.listWorkflows();
for (const wf of workflows) {
  console.log(wf.id, wf.name, wf.enabled);
}

// List recent failed runs
const failedRuns = await client.listRuns({
  status: "failed",
  limit: 5,
});

// Retry the most recent failed run
const failed = failedRuns[0];
if (failed) {
  const retried = await client.retryFailed(failed.runId);
  console.log("Retried:", retried.runId, retried.status);
}

// Cancel an active run
const activeRuns = await client.listRuns({ status: "running" });
const active = activeRuns[0];
if (active) {
  await client.cancelRun(active.runId);
  console.log("Cancelled:", active.runId);
}