Workflows

import { workflow } from "shiftlabs";

export default workflow<{ id: string }>(async ({ payload, step, secrets, log }) => {
  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()),
  );
  log.info("charge loaded", { id: charge.id });
  await step.sleep("cool-off", "10 minutes");
  await step.run(
    "notify",
    { retries: { limit: 3, delay: "30 seconds", backoff: "exponential" } },
    () =>
      fetch("https://hooks.slack.com/services/T0/B0/x", {
        method: "POST",
        body: JSON.stringify({ text: charge.id }),
      }),
  );
});

import json

from workers import fetch
from shiftlabs import workflow


@workflow
async def refund_check(ctx):
    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)
    ctx.log.info("charge loaded", {"id": charge["id"]})
    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": charge["id"]}))

    await ctx.step.run("notify", notify, retries={"limit": 3, "delay": "30 seconds", "backoff": "exponential"})

# /// script
# dependencies = ["httpx", "numpy>=2"]
# ///
import httpx
import numpy as np
from shiftlabs import workflow


@workflow
async def refund_check(ctx):
    async def fetch_charge():
        async with httpx.AsyncClient() as http:
            r = await http.get(f"https://api.stripe.com/v1/charges/{ctx.payload['id']}",
                               headers={"authorization": f"Bearer {ctx.secrets.STRIPE_KEY}"})
            return r.json()

    charge = await ctx.step.run("fetch charge", fetch_charge)
    return {"cents": int(np.round(charge["amount"]))}