Ian/support count

.github/workflows/node.js.yml

@@ -20,3 +20,5 @@ jobs:
       - run: npm ci
       - run: npm run lint
       - run: npm test
+      - run: npm run build
+      - run: npx pkg-pr-new publish

convex/queries.test.ts

@@ -18,6 +18,16 @@ test("collect", async () => {
   ]);
 });
 
+test("count", async () => {
+  const t = convexTest(schema);
+  await t.run(async (ctx) => {
+    await ctx.db.insert("messages", { author: "sarah", body: "hello1" });
+    await ctx.db.insert("messages", { author: "sarah", body: "hello2" });
+  });
+  const count = await t.query(api.queries.count);
+  expect(count).toStrictEqual(2);
+});
+
 test("withIndex", async () => {
   const t = convexTest(schema);
   const messages = await t.run(async (ctx) => {

convex/queries.ts

@@ -7,6 +7,10 @@ export const list = query(async (ctx) => {
   return await ctx.db.query("messages").collect();
 });
 
+export const count = query(async (ctx) => {
+  return await (ctx.db.query("messages") as any).count();
+});
+
 /// order
 
 export const lastN = query({

index.ts

@@ -965,7 +965,7 @@ function validateValidator(validator: ValidatorJSON, value: any) {
       }
       if (!isValid) {
         throw new Error(
-          `Validator error: Expected one of ${validator.value.map((v) => v.type).join(", ")}, got \`${JSON.stringify(value)}\``,
+          `Validator error: Expected one of ${validator.value.map((v) => v.type).join(", ")}, got \`${JSON.stringify(convexToJson(value))}\``,
         );
       }
       return;
@@ -1291,6 +1291,23 @@ function asyncSyscallImpl() {
           Math.random();
         return JSON.stringify(convexToJson(url));
       }
+      case "1.0/count": {
+        const { table } = args;
+        const queryId = db.startQuery({
+          source: { type: "FullTableScan", tableName: table, order: "asc" },
+          operators: [],
+        });
+        let count = 0;
+        // eslint-disable-next-line no-constant-condition
+        while (true) {
+          const result = db.queryNext(queryId);
+          if (result.done) {
+            break;
+          }
+          count += 1;
+        }
+        return JSON.stringify(count);
+      }
       default: {
         throw new Error(
           `\`convexTest\` does not support async syscall: "${op}"`,