Declare connections in a workflow

import { z } from 'zod';
import { createStep, createWorkflow, fromInit, template, Integrations } from 'lua-cli';

const RefundRequest = z.object({ chargeId: z.string(), amount: z.number() });

const postRefund = createStep({
  id: 'postRefund',
  inputSchema: z.object({ approved: z.boolean(), editedPayload: RefundRequest.optional() }).passthrough(),
  outputSchema: z.object({ refundId: z.string().nullable() }),
  sideEffects: 'external',
  onError: 'park',
  requiredConnections: ['stripe'],
  async execute({ inputData, getStepResult, once }) {
    if (!inputData.approved) return { refundId: null };
    // The approval does not echo its payload back: read the edited copy, else the one it showed.
    const request = inputData.editedPayload ?? getStepResult<z.infer<typeof RefundRequest>>('request');
    const refundId = await once(`refund:${request.chargeId}`, async () => {
      const res = await Integrations.passthrough('stripe', {
        method: 'POST',
        path: '/v1/refunds',
        data: { charge: request.chargeId, amount: request.amount },
      });
      return (res.data as { id: string }).id;
    });
    return { refundId };
  },
});

export const refundApproval = createWorkflow({
  name: 'refund-approval',
  description: 'Ask a support lead to approve a refund, then post it through Stripe.',
  inputSchema: RefundRequest,
  outputSchema: z.object({ refundId: z.string().nullable() }),
  budget: { maxCredits: 5, maxDurationSeconds: 14 * 24 * 3600 },
  connections: [{ key: 'stripe', integrationType: 'stripe', required: true, description: 'Posts refunds' }],
})
  .map({ chargeId: fromInit('chargeId'), amount: fromInit('amount') }, { id: 'request' })
  .approval('approveRefund', {
    title: 'Refund request',
    details: template('Refund ${initData.amount} on charge ${initData.chargeId}'),
    approver: { role: 'support-lead' },
    excludeInitiator: true,
    timeoutHours: 8,
    businessHours: { tz: 'Europe/London', calendar: 'mon-fri' },
    onTimeout: [{ escalateTo: 'org-admins', timeoutHours: 24 }, 'deny'],
    onDeny: 'continue',
    editablePaths: ['amount'],
    editedPayloadSchema: RefundRequest.extend({ amount: z.number().positive().max(500) }),
  })
  .then(postRefund)
  .commit();