Trình Kết Nối Stripe

// Xác minh Stripe webhook signature
const event = stripe.webhooks.constructEvent(
  req.body,
  req.headers['stripe-signature'],
  process.env.STRIPE_WEBHOOK_SECRET
);

connectors:
  stripe:
    enabled: true
    secret_key: "${STRIPE_SECRET_KEY}"
    webhook_secret: "${STRIPE_WEBHOOK_SECRET}"

    sync:
      customers: true
      subscriptions: true
      invoices: true
      payment_intents: false

    # Ánh xạ plan sang danh sách Brevo
    plan_list_mapping:
      "price_starter": 30
      "price_pro": 31
      "price_enterprise": 32

import { TajoClient } from '@tajo/sdk';

const tajo = new TajoClient({
  apiKey: process.env.TAJO_API_KEY,
  brevoApiKey: process.env.BREVO_API_KEY
});

await tajo.connectors.connect('stripe', {
  secretKey: process.env.STRIPE_SECRET_KEY,
  webhookSecret: process.env.STRIPE_WEBHOOK_SECRET
});

// Đồng bộ Stripe subscriptions sang liên hệ Brevo
await tajo.connectors.sync('stripe', {
  type: 'full',
  resources: ['customers', 'subscriptions'],
  options: {
    includeTrialing: true,
    includeCanceled: false,
    expandMetadata: true
  }
});

// Xử lý Stripe webhook
app.post('/webhooks/stripe', async (req, res) => {
  const sig = req.headers['stripe-signature'];

  try {
    const event = stripe.webhooks.constructEvent(
      req.rawBody,
      sig,
      process.env.STRIPE_WEBHOOK_SECRET
    );

    await tajo.connectors.handleWebhook('stripe', {
      type: event.type,
      payload: event.data.object
    });

    res.json({ received: true });
  } catch (err) {
    res.status(400).send(`Webhook Error: ${err.message}`);
  }
});