Webhooks API

{
  "type": "payment.completed",
  "productId": "prod_abc123xyz",
  "productTitle": "Premium Article",
  "walletAddress": "7xK3abcdefghijklmnop",
  "txHash": "5defghijklmnopqrstuvwxyz123456789",
  "amount": "0.50",
  "currency": "USDC",
  "network": "mainnet-beta",
  "timestamp": "2024-01-15T10:30:00.000Z"
}

{
  "type": "feature.unlocked",
  "productId": "prod_feature123",
  "productTitle": "Pro Plan",
  "accessToken": "ft_a1b2c3d4e5f6g7h8i9j0k1l2m3n4o5p6",
  "featureIds": [
    "pro_analytics",
    "pro_export",
    "pro_themes"
  ],
  "walletAddress": "7xK3abcdefghijklmnop",
  "txHash": "5defghijklmnopqrstuvwxyz123456789",
  "timestamp": "2024-01-15T10:30:00.000Z"
}

{
  "type": "product.created",
  "productId": "prod_new123",
  "productTitle": "New Product",
  "productType": "content",
  "price": "1.00",
  "currency": "USDC",
  "status": "active",
  "network": "mainnet-beta",
  "timestamp": "2024-01-15T10:30:00.000Z"
}

{
  "type": "product.updated",
  "productId": "prod_abc123",
  "productTitle": "Updated Product",
  "productType": "content",
  "price": "2.00",
  "currency": "USDC",
  "status": "active",
  "network": "mainnet-beta",
  "changes": ["price", "status"],
  "timestamp": "2024-01-15T10:30:00.000Z"
}

{
  "type": "product.deleted",
  "productId": "prod_abc123",
  "productTitle": "Deleted Product",
  "timestamp": "2024-01-15T10:30:00.000Z"
}

import express from 'express';

const app = express();
app.use(express.json());

app.post('/webhooks/paygate', async (req, res) => {
  const event = req.body;

  // Log for debugging
  console.log('Webhook received:', event.type);

  switch (event.type) {
    case 'payment.completed':
      await handlePaymentCompleted(event);
      break;

    case 'feature.unlocked':
      await handleFeatureUnlocked(event);
      break;

    case 'product.created':
    case 'product.updated':
    case 'product.deleted':
      await handleProductEvent(event);
      break;

    default:
      console.log('Unknown event type:', event.type);
  }

  // Always respond 200 to acknowledge
  res.json({ received: true });
});

async function handlePaymentCompleted(event) {
  // Grant access in your system
  await db.access.create({
    data: {
      productId: event.productId,
      walletAddress: event.walletAddress,
      txHash: event.txHash,
      amount: parseFloat(event.amount),
      createdAt: new Date(event.timestamp)
    }
  });
}

async function handleFeatureUnlocked(event) {
  // Store access token for user
  await db.users.upsert({
    where: { wallet: event.walletAddress },
    update: {
      accessToken: event.accessToken,
      features: event.featureIds
    },
    create: {
      wallet: event.walletAddress,
      accessToken: event.accessToken,
      features: event.featureIds
    }
  });
}

async function handleProductEvent(event) {
  console.log(`Product ${event.productId}: ${event.type}`);
}