Your AI agent decides what to do. Actuate makes sure it happens.

import { defineActuator, z } from "@actuate/sdk";

export default defineActuator({
  name: "lead_intake",
  description: "Saves a lead, then follows up until they reply.",
  input: z.object({
    name: z.string(),
    email: z.email(),
  }),
  capabilities: ["messaging"],
  async run(ctx, { name, email }) {
    const id = ctx.runId;
    // An inbound-email webhook posts reply.<id>, ending a wait.
    const wait = (step: string, timeout: "2 days" | "4 days") =>
      ctx.step.waitForEvent(step, { event: `reply.${id}`, timeout });

    await ctx.step.do("save", ({ now }) => ctx.db.sql`
      INSERT INTO leads VALUES (${id}, ${email}, ${now})`);
    await ctx.step.do("day-1", () =>
      ctx.messaging.send(email, `Hi ${name}, thanks!`));
    let reply = await wait("day-3", "2 days");
    if (!reply) {
      await ctx.step.do("follow-up", () =>
        ctx.messaging.send(email, "Any questions?"));
      reply = await wait("day-7", "4 days");
    }
    const status = reply ? "REPLIED" : "COLD";
    await ctx.step.do("close", () => ctx.db.sql`
      UPDATE leads SET status = ${status} WHERE id = ${id}`);
    return { leadId: id, status };
  },
});

import { defineActuator, z } from "@actuate/sdk";

export default defineActuator({
  name: "github_release_telegram",
  description: "Posts each GitHub release to Telegram once.",
  input: z.object({
    action: z.string(),
    release: z.object({
      id: z.number(),
      html_url: z.url(),
    }),
  }),
  capabilities: ["messaging"],
  async run(ctx, { action, release }) {
    if (action !== "published") return { posted: false };
    // GitHub redelivers webhooks; the primary key stops repeats.
    const firstTime = await ctx.step.do("claim", async () => {
      const rows = await ctx.db.sql`INSERT INTO announced
        VALUES (${release.id}) ON CONFLICT DO NOTHING
        RETURNING release_id`;
      return rows.length === 1;
    });
    if (!firstTime) return { posted: false, reason: "repeat" };
    await ctx.step.do("post", { retries: 3 }, () =>
      ctx.messaging.send("@releases", release.html_url));
    return { posted: true };
  },
});

import { defineActuator, z } from "@actuate/sdk";

export default defineActuator({
  name: "daily_report",
  description: "Records events; sends a summary every morning.",
  input: z.object({
    event: z.string().optional(),
  }),
  capabilities: ["messaging"],
  cron: ["0 1 * * *"], // 09:00 in Kuala Lumpur
  async run(ctx, { event }) {
    if (event) {
      await ctx.step.do("record", ({ now }) => ctx.db.sql`
        INSERT INTO events VALUES (${event}, ${now})`);
      return { recorded: event };
    }
    const rows = await ctx.step.do("summarise", ({ now }) =>
      ctx.db.query<{ type: string; n: number }>(
        `SELECT type, COUNT(*) AS n FROM events
         WHERE at >= ? GROUP BY type`,
        [now - 86_400_000],
      ));
    const text = rows.map((r) => `${r.type}: ${r.n}`).join("\n");
    await ctx.step.do("send", () =>
      ctx.messaging.send("@team", text));
    return { types: rows.length };
  },
});