Идемпотентность и retry: чтение кода и запросов

Сниппет 1 — хендлер dedup

func handleCharge(ctx context.Context, db *sql.DB, key string, body []byte) (*Resp, error) {
    var existing Row
    err := db.QueryRowContext(ctx,
        `SELECT response_body, status FROM idempotency_keys WHERE key = $1`, key,
    ).Scan(&existing.Body, &existing.Status)
    if err == sql.ErrNoRows {
        // строки ещё нет -> трактуем как new
        db.ExecContext(ctx,
            `INSERT INTO idempotency_keys (key, fingerprint, status) VALUES ($1, $2, 'in_progress')`,
            key, fingerprint(body))
        return process(ctx, db, key, body) // выполняет списание
    }
    return replay(existing), nil
}

Сниппет 2 — цикл retry

async function callWithRetry(fn, maxAttempts = 6) {
  let delay = 200;
  for (let attempt = 0; attempt < maxAttempts; attempt++) {
    try {
      return await fn();
    } catch (err) {
      if (attempt === maxAttempts - 1) throw err;
      await sleep(delay);          // фиксированное удвоение, без случайности
      delay = Math.min(30000, delay * 2);
    }
  }
}

Сниппет 3 — переход состояния

-- запрос пришёл; строка для этого ключа уже есть
BEGIN;
  SELECT status FROM idempotency_keys WHERE key = $1;       -- читает 'in_progress'
  -- приложение видит in_progress, но всё равно вызывает платёжный провайдер...
  -- провайдер успешен, затем:
  UPDATE idempotency_keys
     SET status = 'completed', response_body = $2
   WHERE key = $1;
COMMIT;

Сниппет 4 — inbox-консьюмер

BEGIN;
  INSERT INTO processed_events (event_id) VALUES ($1)
    ON CONFLICT (event_id) DO NOTHING;
  -- применяется всегда, независимо от того, сделала ли вставка выше что-либо:
  UPDATE inventory SET reserved = reserved + $qty WHERE sku = $sku;
COMMIT;