Function withPostgresTransaction

src/database/postgres.ts:38–52

(callback: (client: PoolClient) => Promise<T>)

}

export async function withPostgresTransaction<T>(callback: (client: PoolClient) => Promise<T>): Promise<T> {
  const client = await getPostgresPool().connect();
  try {
    await ensurePostgresSchema();
    await client.query('BEGIN');
    const result = await callback(client);
    await client.query('COMMIT');
    return result;
  } catch (error) {
    await client.query('ROLLBACK');
    throw error;
  } finally {
    client.release();
  }
}

async function runMigrations(client: SqlQueryable): Promise<void> {
  await client.query(`