Function initClient

packages/core/src/db/client.ts:296–480

()

let _initPromise: Promise<void> | undefined;

async function initClient(): Promise<void> {
  if (_exec) return;

  const dialect = getDialect();

  // Cloudflare D1
  if (dialect === "d1") {
    const d1 = globalThis.__cf_env?.DB;
    _exec = {
      async execute(sql) {
        if (typeof sql === "string") {
          const r = await d1.prepare(sql).all();
          return {
            rows: r.results || [],
            rowsAffected: r.meta?.changes ?? 0,
          };
        }
        const r = await d1
          .prepare(sql.sql)
          .bind(...sql.args)
          .all();
        return { rows: r.results || [], rowsAffected: r.meta?.changes ?? 0 };
      },
    };
    return;
  }

  let url = getDatabaseUrl("file:./data/app.db");

  // Postgres — uses postgres.js. Works on Node.js natively and on Cloudflare
  // Workers with the nodejs_compat compatibility flag (provides net/tls polyfills).
  // On Workers, connections can't be shared across requests, so we create a
  // fresh connection per query (max:1) to avoid the "I/O on behalf of a
  // different request" error.
  if (dialect === "postgres") {
    const { isNeonUrl } = await import("./create-get-db.js");

    // Neon over @neondatabase/serverless (WebSocket upgrade on port 443).
    // postgres-js uses a raw TCP socket on 5432 that frequently fails on
    // serverless runtimes (Netlify Functions, Vercel, CF Workers) when
    // Neon's pooler is cold — every request after an idle period times out
    // with CONNECT_TIMEOUT. The serverless Pool handles wake-up transparently
    // and keeps the same `pg`-compatible query(...) interface we need here.
    if (isNeonUrl(url)) {
      const { Pool } = await import("@neondatabase/serverless");
      _neonPool = new Pool({ connectionString: url });
      const pool = _neonPool;
      _exec = {
        async execute(sql) {
          const rawSql = typeof sql === "string" ? sql : sql.sql;
          const args = typeof sql === "string" ? [] : sql.args || [];
          const pgSql = sqliteToPostgresParams(rawSql);
          const result = await retryOnConnectionError<{
            rows: unknown[];
            rowCount?: number;
          }>(() => pool.query(pgSql, args as any[]));
          return {
            rows: result.rows,