Cloudflare Workers recipe

npm install @atmosphere-money/app-node@beta

import { createAtmAppClient } from "@atmosphere-money/app-node";

export default {
  async fetch(request: Request, env: Env): Promise<Response> {
    const atm = createAtmAppClient({
      getServiceAuthToken: ({ lxm, aud }) => mintAppServiceAuthJwt(env, { lxm, aud })
    });

    if (request.method === "POST" && new URL(request.url).pathname === "/checkout") {
      const { recipientDid, amountCents } = await request.json();
      const payout = await atm.getPayoutStatus(recipientDid);
      if (!payout.payable) return Response.json({ error: "RecipientNotPayable" }, { status: 409 });

      const approval = await atm.requestRecipientApproval({
        recipientDid,
        environment: "test",
        paymentTypes: ["shop"],
        feeShareBps: 300,
        requestReason: "Enable Workers checkout"
      });
      if (approval.status !== "approved") {
        return Response.json({
          error: "RecipientAppApprovalRequired",
          approvalUrl: approval.dashboardUrl
        }, { status: 409 });
      }

      const order = await createAppOrder(env, { recipientDid, amountCents });
      const checkout = await atm.initiatePayment({
        environment: "test",
        recipient: order.recipientDid,
        amount: order.amountCents,
        currency: "usd",
        paymentType: "shop",
        returnUrl: `https://app.example/orders/${order.id}/return`,
        cancelUrl: `https://app.example/orders/${order.id}`,
        metadata: { appOrderId: order.id }
      });
      return Response.json({ url: checkout.url, token: checkout.token });
    }

    return new Response("Not found", { status: 404 });
  }
};

import { createCloudflareWorkerWebhookHandler } from "@atmosphere-money/app-node";

export async function handleWebhook(request: Request, env: Env) {
  const handler = createCloudflareWorkerWebhookHandler({
    secret: env.ATM_WEBHOOK_SECRET,
    expectedType: "payment.completed",
    insertDeliveryIdOnce: async (deliveryId) => {
      return insertDeliveryIdOnce(env, deliveryId);
    },
    onEvent: async (event) => {
      const metadata = event.data.payment.metadata as
        | { appOrderId?: string }
        | undefined;
      const appOrderId = String(metadata?.appOrderId ?? "");
      if (!appOrderId) return { status: 422, body: { error: "MissingAppOrderId" } };

      await fulfillOrder(env, appOrderId, event.data.payment.id);
      return { body: { ok: true } };
    }
  });

  return handler.fetch(request);
}

cd examples/atm-hono-worker-starter
npm install
npm run smoke
# Then add a Workers-specific integration test around your chosen storage layer