test hiding counts

app/e2e/adapters.ts

@@ -142,7 +142,6 @@ const adapters = {
    },
    nextjs: {
       dir: path.join(basePath, "examples/nextjs"),
-      env: "TEST_TIMEOUT=20000",
       clean: async function () {
          const cwd = path.relative(process.cwd(), this.dir);
          await $`cd ${cwd} && rm -rf .nextjs data.db`;
@@ -196,8 +195,7 @@ async function testAdapter(name: keyof typeof adapters) {
    console.log("proc:", proc.pid, "data:", c.cyan(data));
    //proc.kill();process.exit(0);
 
-   const add_env = "env" in config && config.env ? config.env : "";
-   await $`TEST_URL=${data} TEST_ADAPTER=${name} ${add_env} bun run test:e2e`;
+   await $`TEST_URL=${data} TEST_ADAPTER=${name} bun run test:e2e`;
    console.log("DONE!");
 
    while (!proc.killed) {
@@ -207,8 +205,6 @@ async function testAdapter(name: keyof typeof adapters) {
    }
 }
 
-// run with: TEST_ADAPTER=astro bun run e2e/adapters.ts
-// (modify `test:e2e` to `test:e2e:ui` to see the UI)
 if (process.env.TEST_ADAPTER) {
    await testAdapter(process.env.TEST_ADAPTER as any);
 } else {

app/package.json

@@ -3,7 +3,7 @@
   "type": "module",
   "sideEffects": false,
   "bin": "./dist/cli/index.js",
-  "version": "0.14.0",
+  "version": "0.14.0-rc.2",
   "description": "Lightweight Firebase/Supabase alternative built to run anywhere — incl. Next.js, React Router, Astro, Cloudflare, Bun, Node, AWS Lambda & more.",
   "homepage": "https://bknd.io",
   "repository": {
@@ -70,7 +70,8 @@
     "oauth4webapi": "^2.11.1",
     "object-path-immutable": "^4.1.2",
     "radix-ui": "^1.1.3",
-    "swr": "^2.3.3"
+    "swr": "^2.3.3",
+    "uuid": "^11.1.0"
   },
   "devDependencies": {
     "@aws-sdk/client-s3": "^3.758.0",
@@ -120,7 +121,6 @@
     "tsc-alias": "^1.8.11",
     "tsup": "^8.4.0",
     "tsx": "^4.19.3",
-    "uuid": "^11.1.0",
     "vite": "^6.3.5",
     "vite-tsconfig-paths": "^5.1.4",
     "vitest": "^3.0.9",

app/playwright.config.ts

@@ -3,7 +3,6 @@ import { defineConfig, devices } from "@playwright/test";
 const baseUrl = process.env.TEST_URL || "http://localhost:28623";
 const startCommand = process.env.TEST_START_COMMAND || "bun run dev";
 const autoStart = ["1", "true", undefined].includes(process.env.TEST_AUTO_START);
-const timeout = process.env.TEST_TIMEOUT ? Number.parseInt(process.env.TEST_TIMEOUT) : 5000;
 
 export default defineConfig({
    testMatch: "**/*.e2e-spec.ts",
@@ -13,7 +12,7 @@ export default defineConfig({
    retries: process.env.CI ? 2 : 0,
    workers: process.env.CI ? 1 : undefined,
    reporter: "html",
-   timeout,
+   timeout: 20000,
    use: {
       baseURL: baseUrl,
       trace: "on-first-retry",

app/src/adapter/cloudflare/config.ts

@@ -92,7 +92,7 @@ export function makeConfig<Env extends CloudflareEnv = CloudflareEnv>(
    args?: CfMakeConfigArgs<Env>,
 ) {
    if (!media_registered) {
-      registerMedia(args?.env as any);
+      registerMedia(args as any);
       media_registered = true;
    }
 

app/src/adapter/cloudflare/connection/D1Connection.ts

@@ -22,6 +22,7 @@ export class D1Connection<
 > extends SqliteConnection {
    protected override readonly supported = {
       batching: true,
+      counts: false,
    };
 
    constructor(private config: D1ConnectionConfig<DB>) {

app/src/adapter/vite/vite.adapter.ts

@@ -1,17 +1,24 @@
 import { serveStatic } from "@hono/node-server/serve-static";
-import { type DevServerOptions, default as honoViteDevServer } from "@hono/vite-dev-server";
+import {
+   type DevServerOptions,
+   default as honoViteDevServer,
+} from "@hono/vite-dev-server";
 import type { App } from "bknd";
-import { type RuntimeBkndConfig, createRuntimeApp, type FrameworkOptions } from "bknd/adapter";
+import {
+   type RuntimeBkndConfig,
+   createRuntimeApp,
+   type FrameworkOptions,
+} from "bknd/adapter";
 import { registerLocalMediaAdapter } from "bknd/adapter/node";
 import { devServerConfig } from "./dev-server-config";
-import type { MiddlewareHandler } from "hono";
 
 export type ViteEnv = NodeJS.ProcessEnv;
-export type ViteBkndConfig<Env = ViteEnv> = RuntimeBkndConfig<Env> & {
-   serveStatic?: false | MiddlewareHandler;
-};
+export type ViteBkndConfig<Env = ViteEnv> = RuntimeBkndConfig<Env> & {};
 
-export function addViteScript(html: string, addBkndContext: boolean = true) {
+export function addViteScript(
+   html: string,
+   addBkndContext: boolean = true,
+) {
    return html.replace(
       "</head>",
       `<script type="module">
@@ -41,10 +48,7 @@ async function createApp<ViteEnv>(
                mainPath: "/src/main.tsx",
             },
          },
-         serveStatic: config.serveStatic || [
-            "/assets/*",
-            serveStatic({ root: config.distPath ?? "./" }),
-         ],
+         serveStatic: ["/assets/*", serveStatic({ root: config.distPath ?? "./" })],
       },
       env,
       opts,

app/src/data/api/DataController.ts

@@ -316,7 +316,7 @@ export class DataController extends Controller {
                return this.notFound(c);
             }
             const options = c.req.valid("query") as RepoQuery;
-            const result = await this.em.repository(entity).findMany(options);
+            const result = await this.em.repo(entity).findMany(options);
 
             return c.json(this.repoResult(result), { status: result.data ? 200 : 404 });
          },

app/src/data/connection/Connection.ts

@@ -82,6 +82,7 @@ export abstract class Connection<DB = any> {
    kysely: Kysely<DB>;
    protected readonly supported = {
       batching: false,
+      counts: true,
    };
 
    constructor(

app/src/data/connection/DummyConnection.ts

@@ -3,6 +3,7 @@ import { Connection, type FieldSpec, type SchemaResponse } from "./Connection";
 export class DummyConnection extends Connection {
    protected override readonly supported = {
       batching: true,
+      counts: true,
    };
 
    constructor() {

app/src/data/connection/sqlite/LibsqlConnection.ts

@@ -28,13 +28,13 @@ export class LibsqlConnection extends SqliteConnection {
    private client: Client;
    protected override readonly supported = {
       batching: true,
+      counts: false,
    };
 
    constructor(client: Client);
    constructor(credentials: LibSqlCredentials);
    constructor(clientOrCredentials: Client | LibSqlCredentials) {
       let client: Client;
-      let batching_enabled = true;
       if (clientOrCredentials && "url" in clientOrCredentials) {
          let { url, authToken, protocol } = clientOrCredentials;
          if (protocol && LIBSQL_PROTOCOLS.includes(protocol)) {
@@ -56,7 +56,6 @@ export class LibsqlConnection extends SqliteConnection {
 
       super(kysely, {}, plugins);
       this.client = client;
-      this.supported.batching = batching_enabled;
    }
 
    getClient(): Client {

app/src/data/entities/query/Repository.ts

@@ -27,6 +27,7 @@ export type RepositoryResponse<T = EntityData[]> = RepositoryRawResponse & {
    data: T;
    meta: {
       items: number;
+      has_more?: boolean;
       total?: number;
       count?: number;
       time?: number;
@@ -61,6 +62,10 @@ export class Repository<TBD extends object = DefaultDB, TB extends keyof TBD = a
       public entity: Entity,
       protected options: RepositoryOptions = {},
    ) {
+      this.options = {
+         ...options,
+         includeCounts: options?.includeCounts ?? this.em.connection.supports("counts"),
+      };
       this.emgr = options?.emgr ?? new EventManager(MutatorEvents);
    }
 
@@ -179,6 +184,11 @@ export class Repository<TBD extends object = DefaultDB, TB extends keyof TBD = a
       if (options.limit) validated.limit = options.limit;
       if (options.offset) validated.offset = options.offset;
 
+      // if counts disabled, add +1 to limit
+      if (this.options?.includeCounts === false) {
+         validated.limit = (validated.limit ?? 10) + 1;
+      }
+
       return validated;
    }
 
@@ -210,6 +220,7 @@ export class Repository<TBD extends object = DefaultDB, TB extends keyof TBD = a
 
    protected async performQuery(qb: RepositoryQB): Promise<RepositoryResponse> {
       const entity = this.entity;
+
       const compiled = qb.compile();
 
       const payload = {
@@ -444,6 +455,16 @@ export class Repository<TBD extends object = DefaultDB, TB extends keyof TBD = a
       await this.triggerFindBefore(this.entity, options);
 
       const res = await this.performQuery(qb);
+      if (this.options?.includeCounts === false) {
+         const hasMore = res.data.length === (options.limit ?? 10);
+         res.meta.has_more = hasMore;
+
+         if (hasMore) {
+            res.data = res.data.slice(0, -1);
+            res.result = res.result.slice(0, -1);
+            res.meta.items = res.data.length;
+         }
+      }
 
       await this.triggerFindAfter(this.entity, options, res.data);
       return res as any;

app/src/data/schema/SchemaManager.ts

@@ -333,7 +333,7 @@ export class SchemaManager {
 
             if (config.force) {
                try {
-                  $console.debug("[SchemaManager]", sql);
+                  $console.log("[SchemaManager]", sql);
                   await qb.execute();
                } catch (e) {
                   throw new Error(`Failed to execute query: ${sql}: ${(e as any).message}`);

app/src/modules/Controller.ts

@@ -51,7 +51,6 @@ export class Controller {
 
    protected getEntitiesEnum(em: EntityManager<any>) {
       const entities = em.entities.map((e) => e.name);
-      // @todo: current workaround to allow strings (sometimes building is not fast enough to get the entities)
-      return entities.length > 0 ? s.anyOf([s.string({ enum: entities }), s.string()]) : s.string();
+      return entities.length > 0 ? s.string({ enum: entities }) : s.string();
    }
 }

app/src/modules/server/AdminController.tsx

@@ -50,7 +50,7 @@ export class AdminController extends Controller {
    }
 
    get basepath() {
-      return this.withAdminBasePath();
+      return this.options.basepath ?? "/";
    }
 
    private withBasePath(route: string = "") {

app/src/ui/components/table/DataTable.tsx

@@ -34,6 +34,7 @@ export type DataTableProps<Data> = {
    checkable?: boolean;
    onClickRow?: (row: Data) => void;
    onClickPage?: (page: number) => void;
+   hasMore?: boolean;
    total?: number;
    page?: number;
    perPage?: number;
@@ -59,6 +60,7 @@ export function DataTable<Data extends Record<string, any> = Record<string, any>
    onClickRow,
    onClickPage,
    onClickSort,
+   hasMore,
    total,
    sort,
    page = 1,
@@ -75,7 +77,7 @@ export function DataTable<Data extends Record<string, any> = Record<string, any>
    page = page || 1;
 
    const select = columns && columns.length > 0 ? columns : Object.keys(data?.[0] || {});
-   const pages = Math.max(Math.ceil(total / perPage), 1);
+   const pages = hasMore === undefined ? Math.max(Math.ceil(total / perPage), 1) : undefined;
    const CellRender = renderValue || CellValue;
 
    return (
@@ -104,17 +106,15 @@ export function DataTable<Data extends Record<string, any> = Record<string, any>
                                     <button
                                        type="button"
                                        className={twMerge(
-                                          "py-1.5 rounded-md inline-flex flex-row justify-start items-center gap-1",
-                                          onClickSort
-                                             ? "link hover:bg-primary/5 pl-2.5 pr-1"
-                                             : "px-2.5",
+                                          "link hover:bg-primary/5 py-1.5 rounded-md inline-flex flex-row justify-start items-center gap-1",
+                                          onClickSort ? "pl-2.5 pr-1" : "px-2.5",
                                        )}
                                        onClick={() => onClickSort?.(property)}
                                     >
                                        <span className="text-left text-nowrap whitespace-nowrap">
                                           {label}
                                        </span>
-                                       {(onClickSort || (sort && sort.by === property)) && (
+                                       {onClickSort && (
                                           <SortIndicator sort={sort} field={property} />
                                        )}
                                     </button>
@@ -198,12 +198,14 @@ export function DataTable<Data extends Record<string, any> = Record<string, any>
          </div>
          <div className="flex flex-row items-center justify-between">
             <div className="hidden md:flex text-primary/40">
-               <TableDisplay
-                  perPage={perPage}
-                  page={page}
-                  items={data?.length || 0}
-                  total={total}
-               />
+               {hasMore === undefined ? (
+                  <TableDisplay
+                     perPage={perPage}
+                     page={page}
+                     items={data?.length || 0}
+                     total={total}
+                  />
+               ) : null}
             </div>
             <div className="flex flex-row gap-2 md:gap-10 items-center">
                {perPageOptions && (
@@ -222,11 +224,16 @@ export function DataTable<Data extends Record<string, any> = Record<string, any>
                   </div>
                )}
                <div className="text-primary/40">
-                  Page {page} of {pages}
+                  Page {page} {pages ? `of ${pages}` : ""}
                </div>
                {onClickPage && (
                   <div className="flex flex-row gap-1.5">
-                     <TableNav current={page} total={pages} onClick={onClickPage} />
+                     <TableNav
+                        current={page}
+                        total={pages}
+                        hasMore={hasMore}
+                        onClick={onClickPage}
+                     />
                   </div>
                )}
             </div>
@@ -276,41 +283,59 @@ const TableDisplay = ({ perPage, page, items, total }) => {
       return <>Showing 1 row</>;
    }
 
-   return (
-      <>
-         Showing {perPage * (page - 1) + 1}-{perPage * (page - 1) + items} of {total} rows
-      </>
-   );
+   const text = `Showing ${perPage * (page - 1) + 1}-${perPage * (page - 1) + items}`;
+   if (total) {
+      return `${text} of ${total} rows`;
+   }
+
+   return text;
 };
 
 type TableNavProps = {
    current: number;
-   total: number;
+   total?: number;
+   hasMore?: boolean;
    onClick?: (page: number) => void;
 };
 
-const TableNav: React.FC<TableNavProps> = ({ current, total, onClick }: TableNavProps) => {
+const TableNav: React.FC<TableNavProps> = ({
+   current,
+   total: _total,
+   hasMore: _hasMore,
+   onClick,
+}: TableNavProps) => {
+   const total = _total !== undefined ? _total : _hasMore !== undefined ? current + 1 : current;
+   const hasMore = _hasMore !== undefined ? _hasMore : current < (total ?? 0);
+
    const navMap = [
       { value: 1, Icon: TbChevronsLeft, disabled: current === 1 },
       { value: current - 1, Icon: TbChevronLeft, disabled: current === 1 },
-      { value: current + 1, Icon: TbChevronRight, disabled: current === total },
-      { value: total, Icon: TbChevronsRight, disabled: current === total },
+      { value: current + 1, Icon: TbChevronRight, disabled: !hasMore },
+      {
+         value: _hasMore === undefined ? total : undefined,
+         Icon: TbChevronsRight,
+         disabled: !hasMore,
+      },
    ] as const;
 
-   return navMap.map((nav, key) => (
-      <button
-         role="button"
-         type="button"
-         key={key}
-         disabled={nav.disabled}
-         className="px-2 py-2 border-muted border rounded-md enabled:link text-lg enabled:hover:bg-primary/5 text-primary/90 disabled:opacity-50 disabled:cursor-not-allowed"
-         onClick={() => {
-            const page = nav.value;
-            const safePage = page < 1 ? 1 : page > total ? total : page;
-            onClick?.(safePage);
-         }}
-      >
-         <nav.Icon />
-      </button>
-   ));
+   return navMap.map((nav, key) => {
+      const page = nav.value;
+      if (page === undefined) return null;
+
+      return (
+         <button
+            role="button"
+            type="button"
+            key={key}
+            disabled={nav.disabled}
+            className="px-2 py-2 border-muted border rounded-md enabled:link text-lg enabled:hover:bg-primary/5 text-primary/90 disabled:opacity-50 disabled:cursor-not-allowed"
+            onClick={() => {
+               const safePage = page < 1 ? 1 : page > total ? total : page;
+               onClick?.(safePage);
+            }}
+         >
+            <nav.Icon />
+         </button>
+      );
+   });
 };

app/src/ui/hooks/use-search.ts

@@ -1,44 +1,32 @@
-import { decodeSearch, encodeSearch, mergeObject } from "core/utils";
+import { decodeSearch, encodeSearch, mergeObject, parseDecode } from "core/utils";
 import { isEqual, transform } from "lodash-es";
 import { useLocation, useSearch as useWouterSearch } from "wouter";
-import { type s, parse } from "core/object/schema";
-import { useEffect, useMemo, useState } from "react";
-
-export type UseSearchOptions<Schema extends s.TAnySchema = s.TAnySchema> = {
-   defaultValue?: Partial<s.StaticCoerced<Schema>>;
-   beforeEncode?: (search: Partial<s.StaticCoerced<Schema>>) => object;
-};
+import { type s, parse, cloneSchema } from "core/object/schema";
 
+// @todo: migrate to Typebox
 export function useSearch<Schema extends s.TAnySchema = s.TAnySchema>(
-   schema: Schema,
-   options?: UseSearchOptions<Schema>,
+   _schema: Schema,
+   defaultValue?: Partial<s.StaticCoerced<Schema>>,
 ) {
+   const schema = cloneSchema(_schema as any) as s.TSchema;
    const searchString = useWouterSearch();
    const [location, navigate] = useLocation();
-   const [value, setValue] = useState<s.StaticCoerced<Schema>>(
-      options?.defaultValue ?? ({} as any),
-   );
+   const initial = searchString.length > 0 ? decodeSearch(searchString) : (defaultValue ?? {});
+   const value = parse(schema, initial, {
+      withDefaults: true,
+      clone: true,
+   }) as s.StaticCoerced<Schema>;
 
-   const defaults = useMemo(() => {
-      return mergeObject(
-         // @ts-ignore
-         schema.template({ withOptional: true }),
-         options?.defaultValue ?? {},
-      );
-   }, [JSON.stringify({ schema, dflt: options?.defaultValue })]);
-
-   useEffect(() => {
-      const initial =
-         searchString.length > 0 ? decodeSearch(searchString) : (options?.defaultValue ?? {});
-      const v = parse(schema, Object.assign({}, defaults, initial)) as any;
-      setValue(v);
-   }, [searchString, JSON.stringify(options?.defaultValue), location]);
+   // @ts-ignore
+   const _defaults = mergeObject(schema.template({ withOptional: true }), defaultValue ?? {});
 
    function set<Update extends Partial<s.StaticCoerced<Schema>>>(update: Update): void {
-      const search = getWithoutDefaults(Object.assign({}, value, update), defaults);
-      const prepared = options?.beforeEncode?.(search) ?? search;
-      const encoded = encodeSearch(prepared, { encode: false });
-      navigate(location + (encoded.length > 0 ? "?" + encoded : ""));
+      // @ts-ignore
+      if (schema.validate(update).valid) {
+         const search = getWithoutDefaults(mergeObject(value, update), _defaults);
+         const encoded = encodeSearch(search, { encode: false });
+         navigate(location + (encoded.length > 0 ? "?" + encoded : ""));
+      }
    }
 
    return {

app/src/ui/routes/data/data.$entity.$id.tsx

@@ -257,20 +257,15 @@ function EntityDetailInner({
 }) {
    const other = relation.other(entity);
    const [navigate] = useNavigate();
-   const [search, setSearch] = useState({
+
+   const search = {
       select: other.entity.getSelect(undefined, "table"),
-      sort: other.entity.getDefaultSort(),
       limit: 10,
       offset: 0,
-   });
-
+   };
    // @todo: add custom key for invalidation
-   const $q = useApiQuery(
-      (api) => api.data.readManyByReference(entity.name, id, other.reference, search),
-      {
-         keepPreviousData: true,
-         revalidateOnFocus: true,
-      },
+   const $q = useApiQuery((api) =>
+      api.data.readManyByReference(entity.name, id, other.reference, search),
    );
 
    function handleClickRow(row: Record<string, any>) {
@@ -305,17 +300,11 @@ function EntityDetailInner({
             select={search.select}
             data={$q.data ?? null}
             entity={other.entity}
-            sort={search.sort}
             onClickRow={handleClickRow}
             onClickNew={handleClickNew}
-            page={Math.floor(search.offset / search.limit) + 1}
+            page={1}
             total={$q.data?.body?.meta?.count ?? 1}
-            onClickPage={(page) => {
-               setSearch((s) => ({
-                  ...s,
-                  offset: (page - 1) * s.limit,
-               }));
-            }}
+            /*onClickPage={handleClickPage}*/
          />
       </div>
    );

app/src/ui/routes/data/data.$entity.index.tsx

@@ -35,19 +35,8 @@ export function DataEntityList({ params }) {
    useBrowserTitle(["Data", entity?.label ?? params.entity]);
    const [navigate] = useNavigate();
    const search = useSearch(searchSchema, {
-      defaultValue: {
-         select: entity.getSelect(undefined, "table"),
-         sort: entity.getDefaultSort(),
-      },
-      beforeEncode: (v) => {
-         if ("sort" in v && v.sort) {
-            return {
-               ...v,
-               sort: `${v.sort.dir === "asc" ? "" : "-"}${v.sort.by}`,
-            };
-         }
-         return v;
-      },
+      select: entity.getSelect(undefined, "table"),
+      sort: entity.getDefaultSort(),
    });
 
    const $q = useApiQuery(
@@ -142,6 +131,7 @@ export function DataEntityList({ params }) {
                      perPage={search.value.perPage}
                      perPageOptions={PER_PAGE_OPTIONS}
                      total={meta?.count}
+                     hasMore={meta?.has_more}
                      onClickPage={handleClickPage}
                      onClickPerPage={handleClickPerPage}
                   />

docs/usage/database.mdx

@@ -114,12 +114,12 @@ Example using `@neondatabase/serverless`:
 import { createCustomPostgresConnection } from "@bknd/postgres";
 import { NeonDialect } from "kysely-neon";
 
-const neon = createCustomPostgresConnection(NeonDialect);
+const connection = createCustomPostgresConnection(NeonDialect)({
+   connectionString: process.env.NEON,
+});
 
 serve({
-   connection: neon({
-      connectionString: process.env.NEON,
-   }),
+   connection: connection,
 });
 ```
 
@@ -137,14 +137,14 @@ const xata = new client({
    branch: process.env.XATA_BRANCH,
 });
 
-const xataConnection = createCustomPostgresConnection(XataDialect, {
+const connection = createCustomPostgresConnection(XataDialect, {
    supports: {
       batching: false,
    },
-});
+})({ xata });
 
 serve({
-   connection: xataConnection({ xata }),
+   connection: connection,
 });
 ```
 

examples/astro/astro.config.mjs

@@ -5,6 +5,6 @@ import react from "@astrojs/react";
 
 // https://astro.build/config
 export default defineConfig({
-   output: "server",
-   integrations: [react()],
+   output: "hybrid",
+   integrations: [react()]
 });

packages/postgres/src/PostgresConnection.ts

@@ -16,6 +16,7 @@ export const plugins = [new ParseJSONResultsPlugin()];
 export abstract class PostgresConnection<DB = any> extends Connection<DB> {
    protected override readonly supported = {
       batching: true,
+      counts: true,
    };
 
    constructor(kysely: Kysely<DB>, fn?: Partial<DbFunctions>, _plugins?: KyselyPlugin[]) {