Agentic Commerce

1import { createProxy } from '@xpaysh/sdk';
2 
3const proxy = createProxy({
4  apiKey: process.env.XPAY_AGENT_KEY,
5  budgetLimit: '100.00', // USD equivalent
6  allowedDomains: ['api.openai.com', 'api.anthropic.com'],
7});
8 
9// Agent makes calls through proxy
10const response = await proxy.fetch(
11  'https://api.openai.com/v1/chat/completions',
12  {
13    method: 'POST',
14    body: JSON.stringify({
15      model: 'gpt-4',
16      messages: [{ role: 'user', content: 'Hello!' }],
17    }),
18  }
19);
20 
21// Response includes cost tracking
22console.log('Request cost:', response.meta.cost);
23console.log('Budget remaining:', response.meta.budgetRemaining);

1import requests
2from xpay import X402Client
3import os
4 
5client = X402Client(wallet_key=os.environ['AGENT_WALLET'])
6 
7# Initial request to x402-enabled API
8response = requests.get('https://api.example.com/premium-data')
9 
10if response.status_code == 402:
11    # Parse payment requirements from headers
12    payment_details = response.headers['X-Payment-Required']
13 
14    # Execute payment via x402 (settles in <3s)
15    receipt = client.pay(payment_details)
16 
17    # Retry with payment receipt
18    response = requests.get(
19        'https://api.example.com/premium-data',
20        headers={'X-Payment-Receipt': receipt}
21    )
22 
23# Access the premium data
24data = response.json()

1# policy.yaml - Smart Proxy Budget Policies
2policies:
3  - name: openai-budget
4    target: api.openai.com/*
5    limits:
6      per_request: 0.50      # Max $0.50 per request
7      per_hour: 10.00        # Max $10/hour
8      per_day: 100.00        # Max $100/day
9    alerts:
10      - threshold: 80%       # Alert at 80% of daily limit
11        channel: slack
12      - threshold: 95%
13        channel: email
14    actions:
15      on_limit_reached: block  # or 'warn', 'queue'
16 
17  - name: anthropic-budget
18    target: api.anthropic.com/*
19    limits:
20      per_request: 1.00
21      per_hour: 25.00
22      per_day: 200.00
23    alerts:
24      - threshold: 90%
25        channel: slack
26 
27  - name: premium-apis
28    target: "*.premium-api.com/*"
29    limits:
30      per_request: 5.00
31      per_day: 500.00
32    x402:
33      enabled: true
34      max_payment: 5.00      # Max x402 payment per request

1import express from 'express';
2import { verifyWebhookSignature, XpayWebhookEvent } from '@xpaysh/sdk';
3 
4const app = express();
5 
6app.post('/webhooks/xpay', express.json(), (req, res) => {
7  // Verify webhook authenticity
8  const isValid = verifyWebhookSignature(
9    req.body,
10    req.headers['x-xpay-signature'] as string,
11    process.env.WEBHOOK_SECRET!
12  );
13 
14  if (!isValid) {
15    return res.status(401).send('Invalid signature');
16  }
17 
18  const event: XpayWebhookEvent = req.body;
19 
20  switch (event.type) {
21    case 'budget.threshold_reached':
22      console.log(`Alert: Agent ${event.agentId} at ${event.threshold}% of budget`);
23      // Send Slack notification, trigger review, etc.
24      break;
25 
26    case 'budget.limit_exceeded':
27      console.log(`Critical: Agent ${event.agentId} exceeded budget`);
28      // Emergency response: disable agent, alert on-call
29      break;
30 
31    case 'transaction.completed':
32      console.log(`Transaction: ${event.amount} to ${event.target}`);
33      // Log for analytics, update dashboards
34      break;
35 
36    case 'anomaly.detected':
37      console.log(`Anomaly: ${event.anomalyType} on agent ${event.agentId}`);
38      // Investigate unusual patterns
39      break;
40  }
41 
42  res.status(200).send('OK');
43});