Function query

server/src/db/client.ts:89–109

(
  text: string,
  params?: any[]
)

 * Automatically retries once on transient connection errors.
 */
export async function query<T extends QueryResultRow = any>(
  text: string,
  params?: any[]
): Promise<QueryResult<T>> {
  const p = getPool();
  const start = process.hrtime.bigint();
  try {
    return await p.query<T>(text, params);
  } catch (err) {
    if (isTransientConnectionError(err)) {
      console.warn("Transient DB connection error, retrying query:", (err as Error).message);
      return p.query<T>(text, params);
    }
    throw err;
  } finally {
    const durationMs = Number(process.hrtime.bigint() - start) / 1e6;
    if (durationMs > SLOW_QUERY_THRESHOLD_MS) {
      logger.warn({ duration_ms: Math.round(durationMs) }, "Slow database query");
    }
  }
}

/**
 * Get a client from the pool for transactions.