Your previous output failed validation. Return ONLY corrected JSON.
Validation diagnostics: [{"message":"Refund amount must be <= 500","path":["refundUsd"]}]

import { z } from 'zod';
import { flow } from '@siglo/core';
import { aiStep, anthropic, openai, gemini } from '@siglo/ai';

const TriageSchema = z.object({
    severity: z.enum(['low', 'medium', 'high', 'critical']),
    summary: z.string().min(10),
    suggestedRefundUsd: z.number().min(0).max(500),
});

const triageTicket = aiStep('triageTicket', {
    // Primary model with automatic multi-provider failover cascade
    model: anthropic('claude-3-7-sonnet-latest'),
    fallbackModels: [openai('gpt-4o-mini'), gemini('gemini-2.5-flash')],
    schema: TriageSchema,
    maxRepairAttempts: 2,
    prompt: (ctx: { ticketId: string; body: string }) =>
        `Analyze support ticket ${ctx.ticketId} and return triage JSON:\n\n${ctx.body}`,
});

import { z } from 'zod';
import { Step, flow } from '@siglo/core';
import { aiStep, defineAiTool, anthropic, openai } from '@siglo/ai';

// 1. Define a normal Siglo Step with a Saga compensation handler
const issueStoreCredit = Step.create(
    'issueStoreCredit',
    async ({ ticketId, amountUsd }: { ticketId: string; amountUsd: number }) => ({
        creditId: await billingApi.grantCredit(ticketId, amountUsd),
    }),
).compensate(async ctx => {
    // Runs automatically if ANY downstream step in the parent workflow fails!
    await billingApi.revokeCredit(ctx.creditId);
});

// 2. Expose the Step as a schema-validated AI Tool
const creditTool = defineAiTool({
    name: 'issue_store_credit',
    description: 'Grant store credit to a customer for a verified service issue.',
    inputSchema: z.object({ amountUsd: z.number().min(1).max(100) }),
    step: issueStoreCredit,
    mapInput: (args, ctx: { ticketId: string; body: string }) => ({
        ticketId: ctx.ticketId,
        amountUsd: args.amountUsd,
    }),
});

// 3. Use the tool inside an aiStep and compose with downstream steps
const resolveSupportTicket = flow(
    aiStep('agentResolution', {
        model: anthropic('claude-3-7-sonnet-latest'),
        fallbackModels: [openai('gpt-4o-mini')],
        tools: [creditTool],
        maxToolTurns: 3,
        schema: z.object({ resolutionNote: z.string() }),
        prompt: (ctx: { ticketId: string; body: string }) =>
            `Resolve ticket ${ctx.ticketId}. Issue store credit if appropriate:\n${ctx.body}`,
    }),
    Step.create('notifyCustomer', async ctx => {
        // If notifyCustomer throws, issueStoreCredit.compensate() automatically revokes the credit!
        await emailService.send(ctx.ticketId, ctx.resolutionNote);
    }),
);

const result = await resolveSupportTicket.run({
    ticketId: 'tkt_901',
    body: 'My package arrived damaged. Order total was $45.',
});

console.log(result.resolutionNote);
console.log(result.$steps.agentResolution.$ai);
// {
//   promptTokens: 312,
//   completionTokens: 84,
//   totalTokens: 396,
//   latencyMs: 1140,
//   modelUsed: 'claude-3-7-sonnet-latest',
//   providerUsed: 'anthropic',
//   repairAttempts: 0,
//   fallbackCount: 0,
//   estimatedCostUsd: 0.002196
// }

npm install @siglo/core @siglo/ai zod