test: the pins' store doubles hold the caller's limit (check:objectql-double-limit)

Claude-Session: https://claude.ai/code/session_017ErfyP2Rx7XWHJA27QjyUi
Co-authored-by: Claude <noreply@anthropic.com>

Author: claude

packages/objectql/src/write-result-declared-fields-conformance.test.ts

@@ -60,17 +60,21 @@ function makeSqlShapedStore() {
     }
     return true;
   };
-  const run = (o: string, ast?: { where?: Row }): Row[] =>
-    Array.from(tableFor(o).values()).filter((r) => matches(r, ast?.where)).map((r) => ({ ...r }));
+  const run = (o: string, ast?: { where?: Row; limit?: number }): Row[] => {
+    const rows = Array.from(tableFor(o).values()).filter((r) => matches(r, ast?.where));
+    // The caller's bound, after the filter, by presence.
+    const page = typeof ast?.limit === 'number' ? rows.slice(0, ast.limit) : rows;
+    return page.map((r) => ({ ...r }));
+  };
   let seq = 0;
   const driver = {
     name: 'store-sql-shaped', version: '0.0.0', supports: {},
     async connect(): Promise<void> {},
     async disconnect(): Promise<void> {},
     async checkHealth(): Promise<boolean> { return true; },
     async execute(): Promise<null> { return null; },
-    async find(o: string, ast?: { where?: Row }): Promise<Row[]> { return run(o, ast); },
-    async findOne(o: string, ast?: { where?: Row }): Promise<Row | null> { return run(o, ast)[0] ?? null; },
+    async find(o: string, ast?: { where?: Row; limit?: number }): Promise<Row[]> { return run(o, ast); },
+    async findOne(o: string, ast?: { where?: Row; limit?: number }): Promise<Row | null> { return run(o, ast)[0] ?? null; },
     async create(o: string, data: Row): Promise<Row> {
       seq += 1;
       // `returning('*')`: every physical column, an unwritten one null.

packages/plugins/plugin-audit/src/audit-ledger-declared-fields.test.ts

@@ -74,17 +74,20 @@ function makeSqlShapedStore() {
     return t;
   };
   const copy = <T,>(r: T): T => (r == null ? r : JSON.parse(JSON.stringify(r)));
-  const run = (o: string, where?: Row): Row[] =>
-    Array.from(tableFor(o).values())
-      .filter((r) => Object.entries(where ?? {}).every(([k, v]) => k.startsWith('$') || (r[k] ?? null) === (v ?? null)))
-      .map(copy);
+  const run = (o: string, where?: Row, limit?: number): Row[] => {
+    const rows = Array.from(tableFor(o).values())
+      .filter((r) => Object.entries(where ?? {}).every(([k, v]) => k.startsWith('$') || (r[k] ?? null) === (v ?? null)));
+    // The caller's bound, after the filter, by presence.
+    const page = typeof limit === 'number' ? rows.slice(0, limit) : rows;
+    return page.map(copy);
+  };
   let seq = 0;
   const driver: any = {
     name: 'store-sql-shaped', version: '0.0.0', supports: {},
     async connect() {}, async disconnect() {}, async checkHealth() { return true; },
     async execute() { return null; },
-    async find(o: string, ast?: { where?: Row }) { return run(o, ast?.where); },
-    async findOne(o: string, ast?: { where?: Row }) { return run(o, ast?.where)[0] ?? null; },
+    async find(o: string, ast?: { where?: Row; limit?: number }) { return run(o, ast?.where, ast?.limit); },
+    async findOne(o: string, ast?: { where?: Row; limit?: number }) { return run(o, ast?.where, ast?.limit)[0] ?? null; },
     async create(o: string, data: Row) {
       seq += 1;
       const retired = o === CONTACT ? Object.fromEntries(RETIRED.map((c) => [c, null])) : {};

packages/plugins/plugin-webhooks/src/webhook-payload-declared-fields.test.ts

@@ -58,19 +58,22 @@ function makeSqlShapedStore() {
         if (!t) { t = new Map<string, Row>(); tables.set(o, t); }
         return t;
     };
-    const run = (o: string, where?: Row): Row[] =>
-        Array.from(tableFor(o).values())
-            .filter((r) => Object.entries(where ?? {}).every(([k, v]) => k.startsWith('$') || (r[k] ?? null) === (v ?? null)))
-            .map((r) => ({ ...r }));
+    const run = (o: string, where?: Row, limit?: number): Row[] => {
+        const rows = Array.from(tableFor(o).values())
+            .filter((r) => Object.entries(where ?? {}).every(([k, v]) => k.startsWith('$') || (r[k] ?? null) === (v ?? null)));
+        // The caller's bound, after the filter, by presence.
+        const page = typeof limit === 'number' ? rows.slice(0, limit) : rows;
+        return page.map((r) => ({ ...r }));
+    };
     let seq = 0;
     const driver = {
         name: 'store-sql-shaped', version: '0.0.0', supports: {},
         async connect(): Promise<void> {},
         async disconnect(): Promise<void> {},
         async checkHealth(): Promise<boolean> { return true; },
         async execute(): Promise<null> { return null; },
-        async find(o: string, ast?: { where?: Row }): Promise<Row[]> { return run(o, ast?.where); },
-        async findOne(o: string, ast?: { where?: Row }): Promise<Row | null> { return run(o, ast?.where)[0] ?? null; },
+        async find(o: string, ast?: { where?: Row; limit?: number }): Promise<Row[]> { return run(o, ast?.where, ast?.limit); },
+        async findOne(o: string, ast?: { where?: Row; limit?: number }): Promise<Row | null> { return run(o, ast?.where, ast?.limit)[0] ?? null; },
         async create(o: string, data: Row): Promise<Row> {
             seq += 1;
             const retired = o === CONTACT ? Object.fromEntries(RETIRED.map((c) => [c, null])) : {};