Failed payment follow-up

trigger:
  kind: stripe
  connection: stripe
  events: [invoice.payment_failed]
  livemode: [true]
steps:
  - key: subscriptions
    name: Look up subscriptions
    kind: tool
    tool: stripe.list_subscriptions
    args:
      customer: "{{ trigger.data.object.customer }}"
  - key: assess
    name: Judge the risk
    kind: llm
    model: smart
    system: You help the billing team of a B2B software company decide how to follow up on failed payments. Be brief and concrete.
    prompt: |
      A payment just failed.
      Customer: {{ trigger.data.object.customer_name }} ({{ trigger.data.object.customer_email }})
      Amount due: {{ trigger.data.object.amount_due }} in the smallest unit of {{ trigger.data.object.currency }}
      Attempt: {{ trigger.data.object.attempt_count }}
      Subscriptions: {{ steps.subscriptions.output }}
      High risk means an annual plan, more than $2,000 at stake, or a third failed attempt.
    schema:
      type: object
      properties:
        risk: { type: string, enum: [high, medium, low] }
        summary: { type: string }
        next_step: { type: string }
      required: [risk, summary, next_step]
  - key: notify
    name: "Tell #billing"
    kind: tool
    tool: slack.post_message
    args:
      channel: C04BILLING
      text: ":credit_card: Payment failed ({{ steps.assess.output.data.risk }} risk): {{ steps.assess.output.data.summary }}\nNext: {{ steps.assess.output.data.next_step }}\n{{ trigger.data.object.hosted_invoice_url }}"
  - key: escalate
    name: Email customer success
    kind: tool
    if: steps.assess.output.data.risk == "high"
    tool: email.send_email
    args:
      to: success@northwind.example
      subject: "At risk: {{ trigger.data.object.customer_name }}'s payment failed"
      text: "{{ steps.assess.output.data.summary }}\n\nSuggested next step: {{ steps.assess.output.data.next_step }}\n\nInvoice: {{ trigger.data.object.hosted_invoice_url }}"