Resources & Tools

# Install Stripe Agent Toolkit
npm install @stripe/agent-toolkit

# Install Stripe CLI
brew install stripe/stripe-cli/stripe
 
# Listen for webhooks
stripe listen --forward-to localhost:3000/webhooks/stripe
 
# Trigger test events
stripe trigger payment_intent.succeeded

{
  "info": {
    "name": "ACP API Collection",
    "schema": "https://schema.getpostman.com/json/collection/v2.1.0/collection.json"
  },
  "item": [
    {
      "name": "Products",
      "item": [
        {
          "name": "Get All Products",
          "request": {
            "method": "GET",
            "url": "{{base_url}}/acp/v1/products"
          }
        },
        {
          "name": "Search Products",
          "request": {
            "method": "GET",
            "url": "{{base_url}}/acp/v1/products?search=headphones"
          }
        }
      ]
    },
    {
      "name": "Checkout",
      "item": [
        {
          "name": "Create Session",
          "request": {
            "method": "POST",
            "url": "{{base_url}}/acp/v1/checkout_sessions",
            "body": {
              "mode": "raw",
              "raw": "{\"cart\":{\"items\":[{\"product_id\":\"prod_001\",\"quantity\":1}]}}"
            }
          }
        }
      ]
    }
  ]
}

// Product validation schema
const productSchema = {
  type: 'object',
  required: ['id', 'title', 'description', 'price', 'currency', 'availability'],
  properties: {
    id: { type: 'string', minLength: 1 },
    title: { type: 'string', minLength: 1, maxLength: 200 },
    description: { type: 'string', minLength: 1 },
    price: { type: 'integer', minimum: 0 },
    currency: { type: 'string', pattern: '^[A-Z]{3}$' },
    availability: {
      type: 'string',
      enum: ['in_stock', 'out_of_stock', 'preorder', 'discontinued']
    }
  }
};

const Ajv = require('ajv');
const ajv = new Ajv();
 
const validate = ajv.compile(productSchema);
 
function validateProduct(product) {
  const valid = validate(product);
  if (!valid) {
    console.error('Validation errors:', validate.errors);
    return false;
  }
  return true;
}

# Clone the starter template
git clone https://github.com/example/acp-nodejs-starter.git
cd acp-nodejs-starter
npm install
npm run dev

├── src/
│   ├── routes/
│   │   ├── products.js
│   │   └── checkout.js
│   ├── services/
│   │   ├── productService.js
│   │   ├── sessionService.js
│   │   └── paymentService.js
│   ├── models/
│   │   ├── product.js
│   │   └── session.js
│   └── app.js
├── test/
├── .env.example
└── package.json

# requirements.txt
fastapi==0.104.1
uvicorn==0.24.0
stripe==7.0.0
pydantic==2.5.0
sqlalchemy==2.0.23

# main.py
from fastapi import FastAPI, HTTPException
from pydantic import BaseModel
import stripe
 
app = FastAPI(title="ACP Store")
 
class CartItem(BaseModel):
    product_id: str
    quantity: int
 
class CreateSessionRequest(BaseModel):
    cart: dict
    buyer_context: dict = None
 
@app.post("/acp/v1/checkout_sessions")
async def create_session(request: CreateSessionRequest):
    # Implementation
    pass

// Enable Stripe debug logging
const stripe = new Stripe(process.env.STRIPE_SECRET_KEY, {
  apiVersion: '2023-10-16',
  telemetry: false,
  maxNetworkRetries: 3
});
 
// Enable request logging
app.use((req, res, next) => {
  console.log(`${req.method} ${req.path}`, req.body);
  next();
});

app.get('/health', async (req, res) => {
  const checks = {
    api: 'ok',
    database: 'unknown',
    stripe: 'unknown'
  };
 
  try {
    await mongoose.connection.db.admin().ping();
    checks.database = 'ok';
  } catch (e) {
    checks.database = 'error';
  }
 
  try {
    await stripe.balance.retrieve();
    checks.stripe = 'ok';
  } catch (e) {
    checks.stripe = 'error';
  }
 
  const status = Object.values(checks).every(v => v === 'ok') ? 200 : 503;
  res.status(status).json(checks);
});

const rateLimit = require('express-rate-limit');
 
const checkoutLimiter = rateLimit({
  windowMs: 60 * 1000, // 1 minute
  max: 100,
  message: {
    error: 'Too many requests',
    retry_after: 60
  }
});
 
app.use('/acp/v1/checkout_sessions', checkoutLimiter);