Credit Bundles

list(params?: {
  subscription_config_id?: string;
  cursor?: string;
  limit?: number;
}): Promise<ListResponse<RestCreditBundle>>

{
  data: Array<{
    credit_bundle_id: string;
    subscription_config_id: string;
    name: string;
    cost: string;
    credit_amount: string;
    created_at: string;
  }>;
  has_more: boolean;
  next_cursor: string | null;
}

const { data: bundles } = await lava.creditBundles.list();

for (const bundle of bundles) {
  console.log(`${bundle.name}: $${bundle.cost} for $${bundle.credit_amount} credits`);
}

const { data: proBundles } = await lava.creditBundles.list({
  subscription_config_id: 'subconf_pro123'
});

console.log(`Pro plan has ${proBundles.length} credit bundle options`);

retrieve(id: string): Promise<RestCreditBundle>

const bundle = await lava.creditBundles.retrieve('cb_abc123');

console.log(`Bundle: ${bundle.name}`);
console.log(`Cost: $${bundle.cost}`);
console.log(`Credits: $${bundle.credit_amount}`);
console.log(`Subscription Config: ${bundle.subscription_config_id}`);

type RestCreditBundle = {
  credit_bundle_id: string;
  subscription_config_id: string;
  name: string;
  cost: string;           // Price in dollars (e.g., "10.00")
  credit_amount: string;  // Credits granted (e.g., "15.00")
  created_at: string;     // ISO 8601 timestamp
};

async function getBundleOptions(subscriptionConfigId: string) {
  const { data: bundles } = await lava.creditBundles.list({
    subscription_config_id: subscriptionConfigId
  });

  return bundles.map(bundle => ({
    id: bundle.credit_bundle_id,
    name: bundle.name,
    price: parseFloat(bundle.cost),
    credits: parseFloat(bundle.credit_amount),
    savings: parseFloat(bundle.credit_amount) - parseFloat(bundle.cost)
  }));
}

// Usage
const options = await getBundleOptions('subconf_pro123');
// Returns: [{ id: 'cb_...', name: '$10 Bundle', price: 10, credits: 15, savings: 5 }]

async function purchaseBundle(connectionId: string, bundleId: string) {
  const session = await lava.checkoutSessions.create({
    checkout_mode: 'credit_bundle',
    origin_url: 'https://yourapp.com',
    connection_id: connectionId,
    credit_bundle_id: bundleId
  });

  return session.checkout_session_token;
}

// Listen for bundle purchase completion
app.post('/webhooks/lava', async (req, res) => {
  const { event, data } = req.body;

  if (event === 'credit_bundle.purchased') {
    const { credit_bundle_id, connection_id, credit_amount } = data;

    console.log(`Connection ${connection_id} purchased bundle ${credit_bundle_id}`);
    console.log(`Added $${credit_amount} in credits`);

    // Update your records
    await database.recordBundlePurchase({
      connectionId: connection_id,
      bundleId: credit_bundle_id,
      amount: credit_amount
    });
  }

  res.json({ received: true });
});