API 网关蓝图

import { Ingestion, trackAPICall } from '@dodopayments/ingestion-blueprints';

const ingestion = new Ingestion({
  apiKey: process.env.DODO_PAYMENTS_API_KEY,
  environment: 'test_mode',
  eventName: 'api_call'
});

// Track a single API call
await trackAPICall(ingestion, {
  customerId: 'cus_123',
  metadata: {
    endpoint: '/api/v1/users',
    method: 'GET',
    status_code: 200,
    response_time_ms: 45
  }
});

import { Ingestion, createBatch } from '@dodopayments/ingestion-blueprints';

const ingestion = new Ingestion({
  apiKey: process.env.DODO_PAYMENTS_API_KEY,
  environment: 'live_mode',
  eventName: 'api_call'
});

// Create batch for high-volume tracking
const batch = createBatch(ingestion, {
  maxSize: 100,      // Flush after 100 events
  flushInterval: 5000 // Or flush 5 seconds after the last add()
});

// Add API calls to batch
batch.add({
  customerId: 'cus_123',
  metadata: {
    endpoint: '/api/v1/products',
    method: 'GET',
    status_code: 200
  }
});

// Clean up when done
await batch.cleanup();

import express from 'express';
import { Ingestion, createBatch } from '@dodopayments/ingestion-blueprints';

const app = express();

const ingestion = new Ingestion({
  apiKey: process.env.DODO_PAYMENTS_API_KEY,
  environment: 'live_mode',
  eventName: 'api_call'
});

const batch = createBatch(ingestion, {
  maxSize: 50,
  flushInterval: 10000
});

// Middleware to track all API calls
app.use((req, res, next) => {
  const startTime = Date.now();
  
  res.on('finish', () => {
    const responseTime = Date.now() - startTime;
    
    batch.add({
      // req.user is set by your auth middleware
      customerId: req.user?.id || 'anonymous',
      metadata: {
        endpoint: req.path,
        method: req.method,
        status_code: res.statusCode,
        response_time_ms: responseTime
      }
    });
  });
  
  next();
});

// Cleanup on shutdown
process.on('SIGTERM', async () => {
  await batch.cleanup();
  process.exit(0);
});