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');
  }
});