Node.js mein aik enterprise-grade Stripe webhook handler banane ke liye jismein duplicate billing events ka koi khatra na ho, aapko unparsed HTTP request body ko express.raw({ type: 'application/json' }) ka use karke raw Buffer ke taur par capture karna hoga, stripe.webhooks.constructEvent() ke zariye cryptographic authenticity verify karni hogi, aur Redis ke SET key value NX EX 86400 se distributed idempotency enforce karni hogi. Kyunki payment processors unacknowledged webhook deliveries ko 72 ghante tak exponential backoff ke sath retry karte hain, isliye asynchronous message queues ko delegate karne se pehle foran res.status(200).json({ received: true }) ke sath acknowledge karna gateway timeout retries aur race conditions ko khatam kar deta hai.
Naive Webhook Handlers Mein Buniyadi Khamiyan
Zyadatar webhook implementations production mein do wajah se fail hoti hain: (1) body-parsing middleware incoming JSON ko mutate ya stringify kar deta hai, jisse cryptographic HMAC-SHA256 signature verification invalid ho jati hai; aur (2) payment networks at-least-once delivery ki guarantee dete hain, jiska natija yeh hota hai ke network jitter ki wajah se acknowledgement receipts mein dairi hone par duplicate charges ya provisioning ho jati hai.
Step 1: Express Mein Raw Body Middleware Configure Karein
Webhook signature checking ke liye wire par milne wali exact byte sequence ki zaroorat hoti hai. Global body parsers apply karne se pehle raw buffer middleware ko khas taur par apne webhook route par mount karein:
import express from 'express';
import Stripe from 'stripe';
import { Redis } from 'ioredis';
const app = express();
const stripe = new Stripe(process.env.STRIPE_SECRET_KEY, { apiVersion: '2025-01-27.acacia' });
const redis = new Redis(process.env.REDIS_URL);
const endpointSecret = process.env.STRIPE_WEBHOOK_SECRET;
// Webhook endpoint ko LAZMI raw buffer milna chahiye
app.post('/api/webhooks/stripe', express.raw({ type: 'application/json' }), async (req, res) => {
const sig = req.headers['stripe-signature'];
let event;
try {
event = stripe.webhooks.constructEvent(req.body, sig, endpointSecret);
} catch (err) {
console.error(`⚠️ Webhook signature verification fail ho gayi: ${err.message}`);
return res.status(400).send(`Webhook Error: ${err.message}`);
}
// Step 2 & 3: Idempotency check aur processing
const isProcessed = await acquireIdempotencyLock(event.id);
if (!isProcessed) {
// Business logic ko dobara execute kiye bagair duplicate event ko acknowledge karein
return res.status(200).json({ received: true, note: 'Duplicate event skip kar diya gaya hai' });
}
// Stripe ko foran receipt acknowledge karein
res.status(200).json({ received: true });
// Step 4: Event ko asynchronous queue mein dispatch karein
await dispatchToQueue(event);
});Step 2: Redis Ke Zariye Atomic Distributed Idempotency Enforce Karein
Microservice instances ke darmiyan atomic lock qaim karne ke liye Redis ke atomic SET NX EX (Set if Not Exists with Expiration) ka use karein:
async function acquireIdempotencyLock(eventId: string): Promise<boolean> {
const lockKey = `webhook:lock:${eventId}`;
// Lock 24 ghante (86400 seconds) mein expire ho jata hai
const result = await redis.set(lockKey, '1', 'EX', 86400, 'NX');
return result === 'OK';
}Step 3: High-Throughput Queue Workers Mein Container OOM Ko Rokein
Jab aap aise webhook consumers chalate hain jo heavy LLM pipelines ya database migrations invoke karte hain, toh traffic achanak barh jane par worker pods aksar memory limits cross kar jate hain. Cgroup allocations aur worker concurrency ko tune karne ke liye hamari Docker Exit Code 137 in Kubernetes and Deep Learning wali guide check karein.
Step 4: Downstream AI Agents Ko Orchestrate Karna
Agar aapka webhook pipeline customer events ko autonomous conversational agents mein feed kar raha hai, toh aik deterministic orchestrator chunne se runaway API loops ruk jate hain. LangGraph vs AutoGen vs CrewAI ke benchmark mein architecture patterns ka mawazna karein, aur hamare LangGraph Recursion Limit Reached wale playbook ka use karke cyclic state transitions ko mehfooz banayein.
