Webhook 重試機制

app.post('/webhooks/kyren', async (req, res) => {
  // ... 驗證簽名 ...

  const event = JSON.parse(req.body.toString());

  try {
    await database.transaction(async tx => {
      // 按唯一事件 ID 原子插入；重複事件返回 false。
      if (!await tx.processedEvents.insertIfAbsent(event.id)) return;
      await processEvent(tx, event);
    });
    res.status(200).send('OK');
  } catch (error) {
    res.status(500).send('Retry later');
  }
});

app.post('/webhooks/kyren', async (req, res) => {
  // ... 驗證簽名 ...

  const event = JSON.parse(req.body.toString());

  try {
    // 只有持久化完成後才返回；event.id 具有唯一約束。
    await webhookInbox.insertIfAbsent(event.id, event);
    res.status(200).send('OK');
  } catch (error) {
    res.status(503).send('Retry later');
  }
});