const express = require('express');
const crypto = require('crypto');

const app = express();

// CRITICAL: Use express.raw() for webhook endpoint - Clerk needs raw body
app.post('/webhooks/clerk',
  express.raw({ type: 'application/json' }),
  async (req, res) => {
    // Get Svix headers
    const svixId = req.headers['svix-id'];
    const svixTimestamp = req.headers['svix-timestamp'];
    const svixSignature = req.headers['svix-signature'];

    // Verify we have required headers
    if (!svixId || !svixTimestamp || !svixSignature) {
      return res.status(400).json({ error: 'Missing required Svix headers' });
    }

    // Manual signature verification (recommended approach)
    const secret = process.env.CLERK_WEBHOOK_SECRET; // whsec_xxxxx from Clerk dashboard
    const signedContent = `${svixId}.${svixTimestamp}.${req.body}`;

    try {
      // Extract base64 secret after 'whsec_' prefix
      const secretBytes = Buffer.from(secret.split('_')[1], 'base64');
      const expectedSignature = crypto
        .createHmac('sha256', secretBytes)
        .update(signedContent)
        .digest('base64');

      // Svix can send multiple signatures, check each one
      const signatures = svixSignature.split(' ').map(sig => sig.split(',')[1]);
      const isValid = signatures.some(sig => {
        try {
          return crypto.timingSafeEqual(
            Buffer.from(sig),
            Buffer.from(expectedSignature)
          );
        } catch {
          return false; // Different lengths = invalid
        }
      });

      if (!isValid) {
        return res.status(400).json({ error: 'Invalid signature' });
      }

      // Check timestamp to prevent replay attacks (5-minute window)
      const timestamp = parseInt(svixTimestamp, 10);
      const currentTime = Math.floor(Date.now() / 1000);
      if (currentTime - timestamp > 300) {
        return res.status(400).json({ error: 'Timestamp too old' });
      }
    } catch (err) {
      console.error('Signature verification error:', err);
      return res.status(400).json({ error: 'Invalid signature' });
    }

    // Parse the verified webhook body
    const event = JSON.parse(req.body.toString());

    // Handle the event
    switch (event.type) {
      case 'user.created':
        console.log('User created:', event.data.id);
        break;
      case 'user.updated':
        console.log('User updated:', event.data.id);
        break;
      case 'session.created':
        console.log('Session created:', event.data.user_id);
        break;
      case 'organization.created':
        console.log('Organization created:', event.data.id);
        break;
      default:
        console.log('Unhandled event:', event.type);
    }

    res.status(200).json({ success: true });
  }
);

import os
import hmac
import hashlib
import base64
from fastapi import FastAPI, Request, HTTPException
from time import time

webhook_secret = os.environ.get("CLERK_WEBHOOK_SECRET")

@app.post("/webhooks/clerk")
async def clerk_webhook(request: Request):
    # Get Svix headers
    svix_id = request.headers.get("svix-id")
    svix_timestamp = request.headers.get("svix-timestamp")
    svix_signature = request.headers.get("svix-signature")

    if not all([svix_id, svix_timestamp, svix_signature]):
        raise HTTPException(status_code=400, detail="Missing required Svix headers")

    # Get raw body
    body = await request.body()

    # Manual signature verification
    signed_content = f"{svix_id}.{svix_timestamp}.{body.decode()}"

    # Extract base64 secret after 'whsec_' prefix
    secret_bytes = base64.b64decode(webhook_secret.split('_')[1])
    expected_signature = base64.b64encode(
        hmac.new(secret_bytes, signed_content.encode(), hashlib.sha256).digest()
    ).decode()

    # Svix can send multiple signatures, check each one
    signatures = [sig.split(',')[1] for sig in svix_signature.split(' ')]
    if expected_signature not in signatures:
        raise HTTPException(status_code=400, detail="Invalid signature")

    # Check timestamp (5-minute window)
    current_time = int(time())
    if current_time - int(svix_timestamp) > 300:
        raise HTTPException(status_code=400, detail="Timestamp too old")

    # Handle event...
    return {"success": True}

CLERK_WEBHOOK_SECRET=whsec_xxxxx    # From webhook endpoint settings in Clerk Dashboard

# Install Hookdeck CLI for local webhook testing
brew install hookdeck/hookdeck/hookdeck

# Start tunnel (no account needed)
hookdeck listen 3000 --path /webhooks/clerk

// Generated with: clerk-webhooks skill
// https://github.com/hookdeck/webhook-skills