shiftlabs

import { workflow } from "shiftlabs";

export default workflow(async ({ payload, step, secrets }) => {
  // secrets.STRIPE_KEY is a stand-in: the gateway swaps in the key.
  const charge = await step.run("fetch charge", () =>
    fetch(`https://api.stripe.com/v1/charges/${payload.id}`, {
      headers: { authorization: `Bearer ${secrets.STRIPE_KEY}` },
    }).then((r) => r.json()),
  );
  await step.sleep("cool-off", "10 minutes");
  await step.run("notify", () =>
    fetch("https://hooks.slack.com/services/T0/B0/x", {
      method: "POST",
      body: JSON.stringify({ text: `Refund check for ${charge.id}` }),
    }),
  );
});

import json

from workers import fetch
from shiftlabs import workflow


@workflow
async def refund_check(ctx):
    # ctx.secrets.STRIPE_KEY is a stand-in: the gateway swaps in the key.
    async def fetch_charge():
        r = await fetch(f"https://api.stripe.com/v1/charges/{ctx.payload['id']}",
                        headers={"authorization": f"Bearer {ctx.secrets.STRIPE_KEY}"})
        return await r.json()

    charge = await ctx.step.run("fetch charge", fetch_charge)
    await ctx.step.sleep("cool-off", "10 minutes")

    async def notify():
        await fetch("https://hooks.slack.com/services/T0/B0/x", method="POST",
                    body=json.dumps({"text": f"Refund check for {charge['id']}"}))

    await ctx.step.run("notify", notify)