transaction-with-retry.ts

export async function transactionWithRetry<T>(
  manager: EntityManager,
  runInTx: (tx: QueryRunner) => Promise<T>,
  options: TxOptions = { retries: 10 },
) {
  const maxRetries = options.retries;
  const backoffInterval = 100;
  let tries = 1;

  while (tries <= maxRetries) {
    const { connection } = manager;
    const qr = connection.createQueryRunner();
    try {
      await qr.startTransaction();
      const result = await runInTx(qr);
      await qr.commitTransaction();

      return result;
    } catch (e) {
      tries += 1;
      await qr.rollbackTransaction();

      if (e.code === '23505') {
        await new Promise((resolve) => {
          setTimeout(() => {
            logger.debug('Conflict. Backing off...', { tries });
            resolve(null);
          }, tries * backoffInterval);
        });
      } else {
        logger.error(`${e.code}: ${e.message}`, e);
        throw e;
      }
    } finally {
      await qr.release();
    }
  }
}