Function getPostgresPool

src/database/postgres.ts:14–29

()

let migrationPromise: Promise<void> | undefined;

export function getPostgresPool(): PgPool {
  if (!config.database.url) {
    throw new Error('Postgres state store requires DATABASE_URL.');
  }
  if (!pool) {
    pool = new Pool({
      connectionString: config.database.url,
      ssl: config.database.ssl
        ? {
            rejectUnauthorized: config.database.sslRejectUnauthorized,
          }
        : undefined,
    });
  }
  return pool;
}

export async function ensurePostgresSchema(client: SqlQueryable = getPostgresPool()): Promise<void> {
  if (client === pool && migrationPromise) return migrationPromise;