withDbTransaction.ts

export const withDbTransaction = <
  P extends { dbConnection: DatabaseConnection },
  R,
  T extends (args: P) => Promise<R>
>(
  logic: T,
): T => {
  return (async (args: Parameters<T>[0]) => {
    await args.dbConnection.beginTransaction(); // begin transaction
    try {
      const result = await logic({ ...args }); // run the request
      await args.dbConnection.commit(); // commit if successful
      return result;
    } catch (error) {
      await args.dbConnection.rollback(); // rollback if not successful
      throw error;
    }
  }) as T;
};