Making Paid Requests

async function makeX402Request(endpoint, apiKey, queryParams = {}) {
  const url = new URL(endpoint);
  Object.entries(queryParams).forEach(([key, value]) => {
    url.searchParams.append(key, value);
  });
  
  // Step 1: Initial request
  let response = await fetch(url, {
    headers: {
      'Authorization': `Bearer ${apiKey}`
    }
  });
  
  let data = await response.json();
  
  // Step 2: Handle payment required
  if (response.status === 402 && data.x402) {
    console.log(`💰 Payment required: $${data.x402.amountUsd}`);
    
    // Settle the payment
    const settleResponse = await fetch('http://localhost:3001/v1/x402/settle', {
      method: 'POST',
      headers: {
        'Authorization': `Bearer ${apiKey}`,
        'Content-Type': 'application/json'
      },
      body: JSON.stringify({
        paymentId: data.x402.paymentId
      })
    });
    
    const settlement = await settleResponse.json();
    
    if (settleResponse.status !== 200) {
      throw new Error(`Settlement failed: ${JSON.stringify(settlement)}`);
    }
    
    console.log(`✅ Payment settled: ${settlement.receiptId}`);
    
    // Step 3: Retry with proof
    response = await fetch(url, {
      headers: {
        'Authorization': `Bearer ${apiKey}`,
        'X-Payment-Id': settlement.paymentId,
        'X-Payment-Proof': settlement.receiptId
      }
    });
    
    data = await response.json();
  }
  
  return data;
}

// Usage
const result = await makeX402Request(
  'http://localhost:3001/v1/protected/quote',
  process.env.ACTUMX_API_KEY,
  { topic: 'ai' }
);

console.log(result);

import os
import requests
from typing import Dict, Optional

def make_x402_request(
    endpoint: str,
    api_key: str,
    query_params: Optional[Dict] = None
) -> Dict:
    """Make an x402 request with automatic payment handling."""
    
    headers = {'Authorization': f'Bearer {api_key}'}
    
    # Step 1: Initial request
    response = requests.get(endpoint, headers=headers, params=query_params)
    data = response.json()
    
    # Step 2: Handle payment required
    if response.status_code == 402 and 'x402' in data:
        print(f"💰 Payment required: ${data['x402']['amountUsd']}")
        
        # Settle the payment
        settle_response = requests.post(
            'http://localhost:3001/v1/x402/settle',
            headers=headers,
            json={'paymentId': data['x402']['paymentId']}
        )
        
        settlement = settle_response.json()
        
        if settle_response.status_code != 200:
            raise Exception(f"Settlement failed: {settlement}")
        
        print(f"✅ Payment settled: {settlement['receiptId']}")
        
        # Step 3: Retry with proof
        headers['X-Payment-Id'] = settlement['paymentId']
        headers['X-Payment-Proof'] = settlement['receiptId']
        
        response = requests.get(endpoint, headers=headers, params=query_params)
        data = response.json()
    
    return data

# Usage
result = make_x402_request(
    'http://localhost:3001/v1/protected/quote',
    os.getenv('ACTUMX_API_KEY'),
    {'topic': 'ai'}
)

print(result)