Webhooks Advanced

{
  "event": "subscription.created",
  "timestamp": "2024-01-15T10:30:00Z",
  "webhook_id": "wh_abc123",
  "data": {
    // Event-specific data
  }
}

{
  "event": "subscription.created",
  "timestamp": "2024-01-15T10:30:00Z",
  "webhook_id": "wh_abc123",
  "data": {
    "subscription_id": "sub_12345",
    "shopify_subscription_id": "gid://shopify/SubscriptionContract/12345",
    "customer": {
      "id": "cust_67890",
      "shopify_id": "gid://shopify/Customer/67890",
      "email": "customer@example.com",
      "first_name": "John",
      "last_name": "Doe"
    },
    "plan": {
      "id": "plan_111",
      "name": "VIP Membership",
      "price": 29.99,
      "currency": "USD",
      "billing_frequency": "monthly"
    },
    "status": "active",
    "created_at": "2024-01-15T10:30:00Z",
    "next_billing_date": "2024-02-15T10:30:00Z"
  }
}

{
  "event": "billing.success",
  "timestamp": "2024-02-15T10:30:00Z",
  "webhook_id": "wh_def456",
  "data": {
    "billing_attempt_id": "ba_789",
    "subscription_id": "sub_12345",
    "customer": {
      "id": "cust_67890",
      "email": "customer@example.com"
    },
    "order": {
      "id": "order_111",
      "shopify_id": "gid://shopify/Order/111",
      "order_number": "#1001",
      "total": 29.99,
      "currency": "USD"
    },
    "amount": 29.99,
    "currency": "USD",
    "payment_method": {
      "type": "credit_card",
      "last_four": "4242",
      "brand": "visa"
    },
    "next_billing_date": "2024-03-15T10:30:00Z"
  }
}

{
  "event": "billing.failed",
  "timestamp": "2024-02-15T10:30:00Z",
  "webhook_id": "wh_ghi789",
  "data": {
    "billing_attempt_id": "ba_790",
    "subscription_id": "sub_12345",
    "customer": {
      "id": "cust_67890",
      "email": "customer@example.com"
    },
    "amount": 29.99,
    "currency": "USD",
    "error": {
      "code": "card_declined",
      "message": "Your card was declined.",
      "decline_code": "insufficient_funds"
    },
    "retry_scheduled": true,
    "retry_date": "2024-02-18T10:30:00Z",
    "attempts_remaining": 3
  }
}

{
  "event": "member.points_changed",
  "timestamp": "2024-01-20T14:00:00Z",
  "webhook_id": "wh_jkl012",
  "data": {
    "member_id": "mem_12345",
    "customer": {
      "id": "cust_67890",
      "email": "customer@example.com"
    },
    "points": {
      "previous_balance": 500,
      "new_balance": 600,
      "change": 100
    },
    "reason": "order_placed",
    "order_id": "order_222"
  }
}

POST https://your-domain.com/webhooks/subscribfy
Content-Type: application/json
X-Subscribfy-Signature: sha256=...

const crypto = require('crypto');

function verifyWebhook(payload, signature, secret) {
  const expected = crypto
    .createHmac('sha256', secret)
    .update(payload)
    .digest('hex');

  return `sha256=${expected}` === signature;
}

// Express.js example
app.post('/webhooks/subscribfy', (req, res) => {
  const signature = req.headers['x-subscribfy-signature'];
  const isValid = verifyWebhook(
    JSON.stringify(req.body),
    signature,
    process.env.WEBHOOK_SECRET
  );

  if (!isValid) {
    return res.status(401).send('Invalid signature');
  }

  // Process webhook
  processEvent(req.body);
  res.status(200).send('OK');
});

const processedWebhooks = new Set();

function processEvent(webhook) {
  if (processedWebhooks.has(webhook.webhook_id)) {
    console.log('Duplicate webhook, skipping');
    return;
  }

  processedWebhooks.add(webhook.webhook_id);

  // Process the event
  switch (webhook.event) {
    case 'subscription.created':
      handleSubscriptionCreated(webhook.data);
      break;
    case 'billing.failed':
      handleBillingFailed(webhook.data);
      break;
    // ...
  }
}

# Using ngrok
ngrok http 3000

# Your endpoint becomes
# https://abc123.ngrok.io/webhooks/subscribfy

async function syncToWarehouse(webhook) {
  const { event, data } = webhook;

  if (event === 'subscription.created') {
    await warehouse.insert('subscriptions', {
      id: data.subscription_id,
      customer_email: data.customer.email,
      plan: data.plan.name,
      price: data.plan.price,
      created_at: data.created_at
    });
  }
}

async function triggerEmail(webhook) {
  if (webhook.event === 'billing.failed') {
    await emailService.send({
      template: 'payment_failed',
      to: webhook.data.customer.email,
      data: {
        amount: webhook.data.amount,
        retry_date: webhook.data.retry_date
      }
    });
  }
}

async function updateCRM(webhook) {
  if (webhook.event === 'subscription.cancelled') {
    await crm.updateContact(webhook.data.customer.email, {
      subscription_status: 'cancelled',
      cancel_reason: webhook.data.cancel_reason,
      cancelled_at: webhook.timestamp
    });
  }
}