n8n vs Temporal : choisir l'orchestrateur de vos flux critiques

// Workflow d'onboarding résilient avec compensation automatique (Saga)
import { proxyActivities, defineSignal, setHandler } from "@temporalio/workflow";
import type * as activities from "./activities";

const { verifyKyc, reserveEscrowAccount, cancelEscrowAccount, notifyMerchant } =
  proxyActivities<typeof activities>({
    startToCloseTimeout: "45s",
    retry: { maximumAttempts: 5, backoffCoefficient: 2 },
  });

export async function merchantOnboardingWorkflow(merchantId: string) {
  const compensations: Array<() => Promise<void>> = [];

  try {
    // Étape 1 : Création compte séquestre
    const escrow = await reserveEscrowAccount(merchantId);
    compensations.push(() => cancelEscrowAccount(escrow.id));

    // Étape 2 : Vérification KYC stricte
    const kycStatus = await verifyKyc(merchantId);
    if (!kycStatus.approved) {
      throw new Error("KYC_REJECTED");
    }

    await notifyMerchant(merchantId, "ACCOUNT_ACTIVE");
  } catch (err) {
    // Exécution déterministe des compensations en ordre inverse
    for (const compensate of compensations.reverse()) {
      await compensate();
    }
    throw err;
  }
}

Ce workflow garantit l'annulation propre des comptes créés en cas de refus KYC ultérieur, sans perte d'état possible.