Stripe

STRIPE_SECRET_KEY=sk_test_51ABC...
STRIPE_WEBHOOK_SECRET=whsec_abc123...

integrations:
  stripe:
    enabled: true
    credentials:
      secret_key: ${STRIPE_SECRET_KEY}
      webhook_secret: ${STRIPE_WEBHOOK_SECRET}
    settings:
      # Stripe API version to pin (recommended for stability)
      api_version: "2024-12-18.acacia"
      # Webhook endpoint path (Cognest registers this route automatically)
      webhook_path: /webhooks/stripe
      # Events to listen for (empty = all events)
      events:
        - payment_intent.succeeded
        - payment_intent.payment_failed
        - invoice.created
        - invoice.payment_succeeded
        - customer.subscription.created
        - customer.subscription.deleted
        - charge.dispute.created
      # Automatic retry for failed webhook deliveries
      max_retries: 3
      # Currency default for new payment links
      default_currency: usd

stripe.on('payment:succeeded', async (event) => {
  console.log(
    `Payment ${event.paymentIntentId} succeeded: ${event.amount / 100} ${event.currency.toUpperCase()}`
  )

  // Send a thank-you message via another integration
  const customer = await stripe.getCustomer(event.customerId)
  console.log(`Customer: ${customer.email}`)
})

stripe.on('payment:failed', async (event) => {
  console.error(
    `Payment failed for customer ${event.customerId}: ${event.failureReason}`
  )
})

stripe.on('dispute:created', async (event) => {
  console.warn(
    `Dispute ${event.disputeId} opened for ${event.amount / 100} — reason: ${event.reason}`
  )
})

stripe.on('subscription:canceled', async (event) => {
  console.log(
    `Subscription ${event.subscriptionId} canceled: ${event.cancelReason ?? 'no reason provided'}`
  )
})

import { Cognest } from '@cognest/sdk'

const cognest = new Cognest()
const stripe = cognest.integration('stripe')
const slack = cognest.integration('slack')

// Notify Slack on successful payments
stripe.on('payment:succeeded', async (event) => {
  const customer = await stripe.getCustomer(event.customerId)
  const amount = (event.amount / 100).toFixed(2)

  await slack.sendMessage({
    channel: '#payments',
    text: `Payment received: $${amount} ${event.currency.toUpperCase()} from ${customer.email}`,
  })
})

// Alert on failed payments so the team can follow up
stripe.on('payment:failed', async (event) => {
  const customer = await stripe.getCustomer(event.customerId)

  await slack.sendMessage({
    channel: '#payments-alerts',
    text: `:warning: Payment failed for ${customer.email} — ${event.failureReason}. Follow up required.`,
  })
})

// Escalate disputes immediately
stripe.on('dispute:created', async (event) => {
  const amount = (event.amount / 100).toFixed(2)

  await slack.sendMessage({
    channel: '#disputes',
    text: `:rotating_light: New dispute: $${amount} — reason: ${event.reason}. Respond within 7 days.`,
  })
})

// Welcome new subscribers
stripe.on('subscription:created', async (event) => {
  const customer = await stripe.getCustomer(event.customerId)

  await slack.sendMessage({
    channel: '#new-subscribers',
    text: `New subscriber: ${customer.email} on plan ${event.priceId}`,
  })
})

// Weekly revenue report
cognest.skill('revenue-report', {
  schedule: '0 9 * * 1', // 9 AM every Monday
  handler: async () => {
    const balance = await stripe.getBalance()
    const payments = await stripe.listPayments({
      status: 'succeeded',
      limit: 100,
    })

    const weekTotal = payments.data
      .filter((p) => {
        const age = Date.now() - p.created * 1000
        return age < 7 * 24 * 60 * 60 * 1000
      })
      .reduce((sum, p) => sum + p.amount, 0)

    const availableBalance = balance.available
      .map((b) => `${(b.amount / 100).toFixed(2)} ${b.currency.toUpperCase()}`)
      .join(', ')

    await slack.sendMessage({
      channel: '#revenue',
      text: [
        ':chart_with_upwards_trend: *Weekly Revenue Report*',
        `Payments this week: $${(weekTotal / 100).toFixed(2)}`,
        `Available balance: ${availableBalance}`,
        `Total transactions: ${payments.data.length}`,
      ].join('\n'),
    })
  },
})

// Create a checkout skill that can be invoked by other skills
cognest.skill('create-checkout', {
  handler: async ({ params }) => {
    const { priceId, quantity = 1, customerEmail } = params

    const link = await stripe.createPaymentLink({
      lineItems: [{ price: priceId, quantity }],
      metadata: { source: 'cognest-bot', customerEmail },
      afterCompletion: {
        type: 'redirect',
        url: 'https://app.example.com/thank-you',
      },
    })

    return { url: link.url, expiresAt: link.expiresAt }
  },
})

await cognest.start()
console.log('Stripe payment automation is running...')