Webhook Retries နှင့် Idempotent Handlers

နားလည်ထားရမယ့် အချက်

Webhook delivery ဟာ အတိအကျ တစ်ကြိမ်တည်း ဖြစ်ပေါ်မယ်လို့ အာမခံမထားပါဘူး။ သင့် endpoint က response ပြန်ဖို့ နှေးကွေးရင် ဒါမှမဟုတ် timeout ဖြစ်ရင် provider အများစုက delivery မအောင်မြင်ဘူးလို့ ယူဆပြီး ထပ်ကာထပ်ကာ retry ပို့ပါလိမ့်မယ်။

ဒါက prerequisite course က idempotency သဘောတရားနဲ့ တိုက်ရိုက် ဆက်စပ်ပါတယ်။ Idempotent handler တစ်ခုက event တူတူ ဘယ်နှကြိမ်ရောက်ရောက် ရလဒ်တူတူ ပေးရပါမယ် — duplicate delivery တိုင်းက ဘေးကင်းတဲ့ no-op ဖြစ်သင့်ပါတယ်။

Provider ပို့တဲ့ event တိုင်းမှာ ဒီအတွက်ပဲ unique ID တစ်ခု ပါလေ့ရှိပါတယ် — အဲဒါကို သိမ်းထားပါ၊ စစ်ဆေးပါ၊ ပြီးရင် duplicate တွေဟာ ခြိမ်းခြောက်မှု တစ်ခု မဖြစ်တော့ပါဘူး။

IDEMPOTENT WEBHOOK HANDLING
---------------------------
-----
Receive request
      |
      v
Verify signature (reject if invalid)
      |
      v
Already processed this event ID?
      |
  +---+---+
  |       |
 yes      no
  |       |
  v       v
Acknowledge   Process + record ID
only          + acknowledge
(no reprocessing)

လက်တွေ့ scenario နဲ့ ချိတ်ကြည့်မယ်

အောက်က code က processedEvents set တစ်ခုနဲ့ sideEffects log တစ်ခုကို ထိန်းထားပါတယ် — database table တစ်ခုနေရာမှာ ကိုယ်စားပြုထားတာပါ။ handleWebhookEvent က ID အသစ်ဆိုမှသာ real side-effect logic ကို ထိရောက်ပါတယ်။

Delivery ငါးခု အစဉ်လိုက် ဝင်လာပါတယ် — ပြီးသား တွေ့ဖူးတဲ့ event နှစ်ခု ထပ်ခါဝင်လာတာလည်း ပါပါတယ်၊ retry mechanism အတိအကျပါပဲ။ Result တစ်ခုစီရဲ့ action field ကို sideEffects count နဲ့ နှိုင်းယှဉ်ကြည့်ပါ။

Request ငါးခု ရောက်လာပေမယ့် distinct event သုံးခုပဲ real processing ကို trigger လုပ်ပါတယ်။ ထပ်ခါဝင်လာတဲ့ နှစ်ခုက ACKNOWLEDGED_ONLY ရပြီး order ကို နှစ်ခါ update မလုပ်ဘူးလို့ ဆိုလိုပါတယ်။

• Endpoint က success ကို မြန်မြန်ပြန်မပေးရင် webhook provider တွေက delivery ကို retry ပို့ကြတာမို့ event တူတူ တစ်ကြိမ်ထက်ပို ရောက်လာနိုင်ပါတယ်။
• Idempotent handler တစ်ခုက real work မလုပ်ခင် သိမ်းထားတဲ့ event ID ကို စစ်တာကြောင့် duplicate delivery တွေဟာ ဘေးကင်းတဲ့ no-op ဖြစ်သွားပါတယ်။
• Event အသစ်ဖြစ်ဖြစ် process လုပ်ပြီးသားဖြစ်ဖြစ် မလိုအပ်တဲ့ retry တွေ ရပ်တန့်ဖို့ success status ကို အမြဲမြန်မြန် ပြန်ပေးပါ။

အတူတူ စမ်းရေးကြည့်မယ်

const processedEvents = new Set();
const sideEffects = [];

function handleWebhookEvent(event) {
  if (processedEvents.has(event.id)) {
    return { id: event.id, action: "ACKNOWLEDGED_ONLY", reason: "Already processed (duplicate delivery)" };
  }
  processedEvents.add(event.id);
  sideEffects.push(event.id);
  return { id: event.id, action: "PROCESSED", reason: "New event, side effect applied" };
}

const incomingDeliveries = [
  { id: "evt_001", type: "payment.completed" },
  { id: "evt_002", type: "payment.completed" },
  { id: "evt_001", type: "payment.completed" },
  { id: "evt_003", type: "payment.completed" },
  { id: "evt_002", type: "payment.completed" }
];

const results = incomingDeliveries.map(handleWebhookEvent);
console.log(results);
console.log("Total side effects applied:", sideEffects.length);

[
  { id: 'evt_001', action: 'PROCESSED', reason: 'New event, side effect applied' },
  { id: 'evt_002', action: 'PROCESSED', reason: 'New event, side effect applied' },
  { id: 'evt_001', action: 'ACKNOWLEDGED_ONLY', reason: 'Already processed (duplicate delivery)' },
  { id: 'evt_003', action: 'PROCESSED', reason: 'New event, side effect applied' },
  { id: 'evt_002', action: 'ACKNOWLEDGED_ONLY', reason: 'Already processed (duplicate delivery)' }
]
Total side effects applied: 3

Idempotence — Wikipedia — API Integration & Webhooks