npm install @visulima/notification @visulima/workflow

import { createNotification } from "@visulima/notification";
import { createNotificationWorkflow } from "@visulima/notification/workflow";
import { slackProvider } from "@visulima/notification/providers/slack";
import { fcmProvider } from "@visulima/notification/providers/fcm";
import { createRuntime } from "@visulima/workflow";

const notify = createNotification({
    chat: slackProvider({ token: "xoxb-…", defaultChannel: "C123" }),
    push: fcmProvider({ projectId: "app", getAccessToken: getToken }),
});

const onComment = createNotificationWorkflow<{ subscriberId: string; author: string }>(notify, {
    id: "comment-posted",
    run: async ({ step, payload }) => {
        // Each channel step delivers exactly once and records its receipt.
        await step.push("ping", () => ({ to: [payload.subscriberId], title: "New comment", body: payload.author }));

        // Durably pause — the process can exit and resume later.
        await step.delay("cool-off", { amount: 1, unit: "hours" });

        // Conditionally skip a step.
        await step.chat("recap", () => ({ text: `${payload.author} commented` }), {
            skip: ({ payload }) => payload.author === "bot",
        });
    },
});

const runtime = createRuntime({ workflows: [onComment] });

await runtime.trigger(onComment, { subscriberId: "u1", author: "ada" });

// Resume delayed runs on a timer (cron job, Cloudflare alarm, …):
await runtime.sweep();