Function createSqliteTestFumaDb

packages/core/sdk/src/sqlite-test-db.ts:34–83

(
  options: CreateSqliteTestFumaDbOptions<TTables>,
)

}

export const createSqliteTestFumaDb = async <const TTables extends FumaTables>(
  options: CreateSqliteTestFumaDbOptions<TTables>,
): Promise<SqliteTestFumaDb<TTables>> => {
  const version = options.version ?? "1.0.0";
  const namespace = options.namespace ?? "executor_test";
  if (options.path && options.path !== ":memory:") {
    mkdirSync(dirname(options.path), { recursive: true });
  }
  // libSQL `:memory:` is a single connection per client, matching the test's
  // single-handle expectation. foreign_keys is per-connection (no shared
  // handle to inherit it), so set it on this one.
  const url =
    !options.path || options.path === ":memory:" ? ":memory:" : `file:${resolve(options.path)}`;
  const client = createClient({ url });
  await client.execute("PRAGMA foreign_keys = ON");

  const schema = createDrizzleRuntimeSchemaFromTables({
    tables: options.tables,
    namespace,
    version,
    provider: "sqlite",
  });
  const drizzleDb = drizzle({ client, schema });

  for (const statement of createDrizzleRuntimeSchemaSqlFromTables({
    tables: options.tables,
    namespace,
    version,
    provider: "sqlite",
  })) {
    await client.execute(statement);
  }

  const { db, fuma } = createExecutorFumaDb(drizzleDb, {
    tables: options.tables,
    namespace,
    version,
    provider: "sqlite",
  });

  return {
    db,
    fuma,
    drizzle: drizzleDb,
    client,
    close: async () => {
      client.close();
    },
  };
};