Function startInit

packages/core/src/db/create-get-db.ts:65–108

()

  let _dbReady: Promise<any> | undefined;

  function startInit(): Promise<any> {
    if (_dbReady) return _dbReady;

    const url = getDatabaseUrl("file:./data/app.db");
    const dialect = getDialect();

    // D1 only if dialect detected it (DATABASE_URL takes priority)
    if (dialect === "d1") {
      const d1 = globalThis.__cf_env?.DB;
      if (d1) {
        _db = drizzleD1(d1, { schema }) as unknown as LibSQLDatabase<T>;
        _dbReady = Promise.resolve(_db);
        return _dbReady;
      }
    }

    if (dialect === "postgres") {
      if (isNeonUrl(url)) {
        _dbReady = getNeonServerlessDrizzle().then(({ drizzle, Pool }) => {
          const pool = new Pool({ connectionString: url });
          _db = drizzle(pool, { schema });
        });
      } else {
        _dbReady = getPgDrizzle().then(({ drizzle, postgres }) => {
          const client = postgres(url, {
            onnotice: () => {},
            idle_timeout: 240,
            max_lifetime: 60 * 30,
            connect_timeout: 10,
            ...(url.includes("supabase") ? { prepare: false } : {}),
          });
          _db = drizzle(client, { schema });
        });
      }
    } else {
      _dbReady = getLibsqlDrizzle().then(({ drizzle }) => {
        _db = drizzle({
          connection: { url, authToken: getDatabaseAuthToken() },
          schema,
        });
      });
    }
    return _dbReady;
  }

  /**
   * Create a lazy proxy that records property accesses and method calls,