⚡ Workflows Distribuidos con Temporal

import { proxyActivities, defineWorkflow, sleep } from '@temporalio/workflow';
import type { OrderData, OrderResult, PaymentInfo } from './types';

// Definir activities como proxy
const {
  validateOrder,
  reserveInventory,
  processPayment,
  createShipment,
  sendConfirmationEmail,
  releaseInventory
} = proxyActivities<typeof activities>({
  startToCloseTimeout: '10 minutes',
  retry: {
    maximumAttempts: 3,
    backoffCoefficient: 2
  }
});

// Workflow de procesamiento de pedido
export const orderProcessingWorkflow = defineWorkflow(
  async function orderProcessing(orderData: OrderData): Promise<OrderResult> {
    // 1. Validar pedido
    await validateOrder(orderData);
    
    // 2. Reservar inventario
    const reservation = await reserveInventory(orderData.items);
    
    try {
      // 3. Procesar pago con retry personalizado
      const payment = await processPayment(orderData.paymentInfo, {
        startToCloseTimeout: '5 minutes',
        retry: {
          maximumAttempts: 5,
          backoffCoefficient: 2.0
        }
      });
      
      // 4. Crear envío (operación larga)
      await createShipment(orderData, payment, {
        startToCloseTimeout: '1 hour'
      });
      
      // 5. Enviar confirmación por email
      await sendConfirmationEmail(
        orderData.customerEmail,
        payment.orderId
      );
      
      return {
        status: 'completed' as const,
        orderId: payment.orderId,
        totalAmount: payment.amount
      };
      
    } catch (error: any) {
      // Auto-rollback en caso de error
      await releaseInventory(reservation);
      
      throw new Error('Order processing failed');
    }
  }
);