Повтор запроса не должен списывать деньги дважды

create table payment_request (
  idempotency_key uuid        primary key,
  account_id      bigint      not null,
  request_hash    text        not null,
  status          text        not null
    check (status in ('in_progress', 'succeeded', 'failed')),
  response        jsonb,
  operation_id    bigint      references operation(id),
  created_at      timestamptz not null default now()
);

-- Журнал операций: только вставка. Отмена — новая запись со знаком минус,
-- а не update и тем более не delete.
create table operation (
  id         bigserial   primary key,
  account_id bigint      not null,
  amount     numeric(20, 4) not null,
  kind       text        not null,
  reverses   bigint      references operation(id),
  created_at timestamptz not null default now()
);

async function charge(req: ChargeRequest) {
  const hash = sha256(canonicalJson(req.body));

  // Пытаемся занять ключ. Если он уже занят — это повтор.
  const claimed = await db.insertIgnoreConflict('payment_request', {
    idempotency_key: req.key,
    account_id: req.accountId,
    request_hash: hash,
    status: 'in_progress',
  });

  if (!claimed) {
    const prev = await db.get('payment_request', req.key);

    // Тот же ключ, другое тело — клиент ошибся или пытается подменить сумму.
    if (prev.request_hash !== hash) throw new Conflict('key_reused');

    // Первый запрос ещё в работе: просим повторить позже, но не проводим второй раз.
    if (prev.status === 'in_progress') throw new Retry('in_progress');

    // Повтор завершённого запроса — отдаём ТОТ ЖЕ ответ, а не новый.
    return prev.response;
  }

  const result = await db.transaction(async (tx) => {
    const op = await tx.insert('operation', {
      account_id: req.accountId,
      amount: -req.body.amount,
      kind: 'charge',
    });

    // Вызов провайдера НЕ здесь: сеть внутри транзакции — это способ
    // получить откат в базе при уже ушедших деньгах. Кладём задание
    // в исходящую очередь той же транзакцией.
    await tx.insert('outbox', { type: 'provider.charge', operation_id: op.id });

    return { operationId: op.id };
  });

  await db.update('payment_request', req.key, {
    status: 'succeeded',
    response: result,
    operation_id: result.operationId,
  });

  return result;
}