chore: changeset

.changeset/large-crabs-fry.md

@@ -0,0 +1,8 @@
+---
+"jazz-react-auth-clerk": patch
+"jazz-react-core": patch
+"hash-slash": patch
+"jazz-react": patch
+---
+
+Add React 19 to the peer dependencies

.changeset/selfish-llamas-pump.md

@@ -0,0 +1,8 @@
+---
+"cojson-storage-indexeddb": patch
+"cojson-storage-rn-sqlite": patch
+"cojson-storage-sqlite": patch
+"cojson-storage": patch
+---
+
+Improve rollback on error when failing to add new content

.changeset/serious-ants-smile.md

@@ -0,0 +1,5 @@
+---
+"cojson": patch
+---
+
+Ports Wasm crypto functions to use exported library `jazz-crypto-rs`

examples/chat-rn-clerk/CHANGELOG.md

@@ -1,15 +1,5 @@
 # chat-rn-clerk
 
-## 1.0.71
-
-### Patch Changes
-
-- Updated dependencies [ada802b]
-  - jazz-tools@0.10.6
-  - jazz-react-native@0.10.6
-  - jazz-react-native-auth-clerk@0.10.6
-  - jazz-react-native-media-images@0.10.6
-
 ## 1.0.70
 
 ### Patch Changes

examples/chat-rn-clerk/package.json

@@ -1,7 +1,7 @@
 {
   "name": "chat-rn-clerk",
   "main": "index.js",
-  "version": "1.0.71",
+  "version": "1.0.70",
   "scripts": {
     "build": "expo export -p ios",
     "start": "expo start",

examples/chat-rn/CHANGELOG.md

@@ -1,13 +1,5 @@
 # chat-rn
 
-## 1.0.68
-
-### Patch Changes
-
-- Updated dependencies [ada802b]
-  - jazz-tools@0.10.6
-  - jazz-react-native@0.10.6
-
 ## 1.0.67
 
 ### Patch Changes

examples/chat-rn/package.json

@@ -1,6 +1,6 @@
 {
   "name": "chat-rn",
-  "version": "1.0.68",
+  "version": "1.0.67",
   "main": "index.js",
   "scripts": {
     "build": "expo export -p ios",

examples/chat-vue/CHANGELOG.md

@@ -1,14 +1,5 @@
 # chat-vue
 
-## 0.0.55
-
-### Patch Changes
-
-- Updated dependencies [ada802b]
-  - jazz-tools@0.10.6
-  - jazz-browser@0.10.6
-  - jazz-vue@0.10.6
-
 ## 0.0.54
 
 ### Patch Changes

examples/chat-vue/package.json

@@ -1,6 +1,6 @@
 {
   "name": "chat-vue",
-  "version": "0.0.55",
+  "version": "0.0.54",
   "private": true,
   "type": "module",
   "scripts": {

examples/chat/CHANGELOG.md

@@ -1,16 +1,5 @@
 # jazz-example-chat
 
-## 0.0.151
-
-### Patch Changes
-
-- Updated dependencies [1d71ca1]
-- Updated dependencies [ada802b]
-  - hash-slash@0.2.2
-  - jazz-react@0.10.6
-  - jazz-tools@0.10.6
-  - jazz-browser-media-images@0.10.6
-
 ## 0.0.150
 
 ### Patch Changes

examples/chat/package.json

@@ -1,7 +1,7 @@
 {
   "name": "jazz-example-chat",
   "private": true,
-  "version": "0.0.151",
+  "version": "0.0.150",
   "type": "module",
   "scripts": {
     "dev": "vite",

examples/clerk/CHANGELOG.md

@@ -1,15 +1,5 @@
 # minimal-auth-clerk
 
-## 0.0.50
-
-### Patch Changes
-
-- Updated dependencies [1d71ca1]
-- Updated dependencies [ada802b]
-  - jazz-react-auth-clerk@0.10.6
-  - jazz-react@0.10.6
-  - jazz-tools@0.10.6
-
 ## 0.0.49
 
 ### Patch Changes

examples/clerk/package.json

@@ -1,7 +1,7 @@
 {
   "name": "clerk",
   "private": true,
-  "version": "0.0.50",
+  "version": "0.0.49",
   "type": "module",
   "scripts": {
     "dev": "vite",
@@ -13,7 +13,7 @@
   "dependencies": {
     "@clerk/clerk-react": "^5.4.1",
     "jazz-react": "workspace:*",
-    "jazz-react-auth-clerk": "workspace:0.10.6",
+    "jazz-react-auth-clerk": "workspace:0.10.5",
     "jazz-tools": "workspace:*",
     "react": "^18.3.1",
     "react-dom": "^18.3.1"

examples/file-share-svelte/CHANGELOG.md

@@ -1,13 +1,5 @@
 # file-share-svelte
 
-## 0.0.35
-
-### Patch Changes
-
-- Updated dependencies [ada802b]
-  - jazz-tools@0.10.6
-  - jazz-svelte@0.10.6
-
 ## 0.0.34
 
 ### Patch Changes

examples/file-share-svelte/package.json

@@ -1,6 +1,6 @@
 {
   "name": "file-share-svelte",
-  "version": "0.0.35",
+  "version": "0.0.34",
   "private": true,
   "type": "module",
   "scripts": {

examples/form/CHANGELOG.md

@@ -1,16 +1,5 @@
 # form
 
-## 0.0.46
-
-### Patch Changes
-
-- Updated dependencies [1d71ca1]
-- Updated dependencies [ada802b]
-  - hash-slash@0.2.2
-  - jazz-react@0.10.6
-  - jazz-tools@0.10.6
-  - jazz-browser-media-images@0.10.6
-
 ## 0.0.45
 
 ### Patch Changes

examples/form/package.json

@@ -1,7 +1,7 @@
 {
   "name": "form",
   "private": true,
-  "version": "0.0.46",
+  "version": "0.0.45",
   "type": "module",
   "scripts": {
     "dev": "vite",

examples/image-upload/CHANGELOG.md

@@ -1,15 +1,5 @@
 # image-upload
 
-## 0.0.48
-
-### Patch Changes
-
-- Updated dependencies [1d71ca1]
-- Updated dependencies [ada802b]
-  - jazz-react@0.10.6
-  - jazz-tools@0.10.6
-  - jazz-browser-media-images@0.10.6
-
 ## 0.0.47
 
 ### Patch Changes

examples/image-upload/package.json

@@ -1,7 +1,7 @@
 {
   "name": "image-upload",
   "private": true,
-  "version": "0.0.48",
+  "version": "0.0.47",
   "type": "module",
   "scripts": {
     "dev": "vite",

examples/inspector/CHANGELOG.md

@@ -1,15 +1,5 @@
 # jazz-example-inspector
 
-## 0.0.107
-
-### Patch Changes
-
-- Updated dependencies [1d71ca1]
-- Updated dependencies [5c76e37]
-  - hash-slash@0.2.2
-  - cojson@0.10.6
-  - cojson-transport-ws@0.10.6
-
 ## 0.0.106
 
 ### Patch Changes

examples/inspector/package.json

@@ -1,7 +1,7 @@
 {
   "name": "jazz-inspector-app",
   "private": true,
-  "version": "0.0.107",
+  "version": "0.0.106",
   "type": "module",
   "scripts": {
     "dev": "vite",
@@ -16,9 +16,9 @@
     "@radix-ui/react-toast": "^1.1.4",
     "class-variance-authority": "^0.7.0",
     "clsx": "^2.0.0",
-    "cojson": "workspace:0.10.6",
-    "cojson-transport-ws": "workspace:0.10.6",
-    "hash-slash": "workspace:0.2.2",
+    "cojson": "workspace:0.10.4",
+    "cojson-transport-ws": "workspace:0.10.4",
+    "hash-slash": "workspace:0.2.1",
     "lucide-react": "^0.274.0",
     "qrcode": "^1.5.3",
     "react": "^18.3.1",

examples/music-player/CHANGELOG.md

@@ -1,15 +1,5 @@
 # jazz-example-musicplayer
 
-## 0.0.72
-
-### Patch Changes
-
-- Updated dependencies [1d71ca1]
-- Updated dependencies [ada802b]
-  - jazz-react@0.10.6
-  - jazz-tools@0.10.6
-  - jazz-inspector@0.10.6
-
 ## 0.0.71
 
 ### Patch Changes

examples/music-player/package.json

@@ -1,7 +1,7 @@
 {
   "name": "jazz-example-music-player",
   "private": true,
-  "version": "0.0.72",
+  "version": "0.0.71",
   "type": "module",
   "scripts": {
     "dev": "vite",
@@ -22,8 +22,8 @@
     "class-variance-authority": "^0.7.0",
     "clsx": "^2.0.0",
     "jazz-inspector": "workspace:*",
-    "jazz-react": "workspace:0.10.6",
-    "jazz-tools": "workspace:0.10.6",
+    "jazz-react": "workspace:0.10.5",
+    "jazz-tools": "workspace:0.10.5",
     "lucide-react": "^0.274.0",
     "react": "^18.3.1",
     "react-dom": "^18.3.1",

examples/organization/CHANGELOG.md

@@ -1,14 +1,5 @@
 # organization
 
-## 0.0.44
-
-### Patch Changes
-
-- Updated dependencies [1d71ca1]
-- Updated dependencies [ada802b]
-  - jazz-react@0.10.6
-  - jazz-tools@0.10.6
-
 ## 0.0.43
 
 ### Patch Changes

examples/organization/package.json

@@ -1,7 +1,7 @@
 {
   "name": "organization",
   "private": true,
-  "version": "0.0.44",
+  "version": "0.0.43",
   "type": "module",
   "scripts": {
     "dev": "vite",

examples/passkey-svelte/CHANGELOG.md

@@ -1,11 +1,5 @@
 # passkey-svelte
 
-## 0.0.39
-
-### Patch Changes
-
-- jazz-svelte@0.10.6
-
 ## 0.0.38
 
 ### Patch Changes

examples/passkey-svelte/package.json

@@ -1,6 +1,6 @@
 {
   "name": "passkey-svelte",
-  "version": "0.0.39",
+  "version": "0.0.38",
   "type": "module",
   "private": true,
   "scripts": {

examples/passkey/CHANGELOG.md

@@ -1,14 +1,5 @@
 # minimal-auth-passkey
 
-## 0.0.49
-
-### Patch Changes
-
-- Updated dependencies [1d71ca1]
-- Updated dependencies [ada802b]
-  - jazz-react@0.10.6
-  - jazz-tools@0.10.6
-
 ## 0.0.48
 
 ### Patch Changes

examples/passkey/package.json

@@ -1,7 +1,7 @@
 {
   "name": "passkey",
   "private": true,
-  "version": "0.0.49",
+  "version": "0.0.48",
   "type": "module",
   "scripts": {
     "dev": "vite",

examples/passphrase/CHANGELOG.md

@@ -1,14 +1,5 @@
 # passphrase
 
-## 0.0.46
-
-### Patch Changes
-
-- Updated dependencies [1d71ca1]
-- Updated dependencies [ada802b]
-  - jazz-react@0.10.6
-  - jazz-tools@0.10.6
-
 ## 0.0.45
 
 ### Patch Changes

examples/passphrase/package.json

@@ -1,7 +1,7 @@
 {
   "name": "passphrase",
   "private": true,
-  "version": "0.0.46",
+  "version": "0.0.45",
   "type": "module",
   "scripts": {
     "dev": "vite",

examples/password-manager/CHANGELOG.md

@@ -1,14 +1,5 @@
 # jazz-password-manager
 
-## 0.0.70
-
-### Patch Changes
-
-- Updated dependencies [1d71ca1]
-- Updated dependencies [ada802b]
-  - jazz-react@0.10.6
-  - jazz-tools@0.10.6
-
 ## 0.0.69
 
 ### Patch Changes

examples/password-manager/package.json

@@ -1,7 +1,7 @@
 {
   "name": "jazz-password-manager",
   "private": true,
-  "version": "0.0.70",
+  "version": "0.0.69",
   "type": "module",
   "scripts": {
     "dev": "vite",
@@ -12,8 +12,8 @@
     "clean-install": "rm -rf node_modules pnpm-lock.yaml && pnpm install"
   },
   "dependencies": {
-    "jazz-react": "workspace:0.10.6",
-    "jazz-tools": "workspace:0.10.6",
+    "jazz-react": "workspace:0.10.5",
+    "jazz-tools": "workspace:0.10.5",
     "react": "^18.3.1",
     "react-dom": "^18.3.1",
     "react-hook-form": "^7.41.5",

examples/pets/CHANGELOG.md

@@ -1,15 +1,5 @@
 # jazz-example-pets
 
-## 0.0.168
-
-### Patch Changes
-
-- Updated dependencies [1d71ca1]
-- Updated dependencies [ada802b]
-  - jazz-react@0.10.6
-  - jazz-tools@0.10.6
-  - jazz-browser-media-images@0.10.6
-
 ## 0.0.167
 
 ### Patch Changes

examples/pets/package.json

@@ -1,7 +1,7 @@
 {
   "name": "jazz-example-pets",
   "private": true,
-  "version": "0.0.168",
+  "version": "0.0.167",
   "type": "module",
   "scripts": {
     "dev": "vite",
@@ -19,9 +19,9 @@
     "@radix-ui/react-toast": "^1.1.4",
     "class-variance-authority": "^0.7.0",
     "clsx": "^2.0.0",
-    "jazz-browser-media-images": "workspace:0.10.6",
-    "jazz-react": "workspace:0.10.6",
-    "jazz-tools": "workspace:0.10.6",
+    "jazz-browser-media-images": "workspace:0.10.5",
+    "jazz-react": "workspace:0.10.5",
+    "jazz-tools": "workspace:0.10.5",
     "lucide-react": "^0.274.0",
     "qrcode": "^1.5.3",
     "react": "^18.3.1",
@@ -41,7 +41,7 @@
     "@vitejs/plugin-react-swc": "^3.3.2",
     "autoprefixer": "^10.4.20",
     "is-ci": "^3.0.1",
-    "jazz-run": "workspace:0.10.6",
+    "jazz-run": "workspace:0.10.5",
     "postcss": "^8.4.27",
     "tailwindcss": "^3.4.17",
     "typescript": "~5.6.2",

examples/reactions/CHANGELOG.md

@@ -1,16 +1,5 @@
 # reactions
 
-## 0.0.48
-
-### Patch Changes
-
-- Updated dependencies [1d71ca1]
-- Updated dependencies [ada802b]
-  - hash-slash@0.2.2
-  - jazz-react@0.10.6
-  - jazz-tools@0.10.6
-  - jazz-browser-media-images@0.10.6
-
 ## 0.0.47
 
 ### Patch Changes

examples/reactions/package.json

@@ -1,7 +1,7 @@
 {
   "name": "reactions",
   "private": true,
-  "version": "0.0.48",
+  "version": "0.0.47",
   "type": "module",
   "scripts": {
     "dev": "vite",

examples/todo-vue/CHANGELOG.md

@@ -1,14 +1,5 @@
 # todo-vue
 
-## 0.0.53
-
-### Patch Changes
-
-- Updated dependencies [ada802b]
-  - jazz-tools@0.10.6
-  - jazz-browser@0.10.6
-  - jazz-vue@0.10.6
-
 ## 0.0.52
 
 ### Patch Changes

examples/todo-vue/package.json

@@ -1,6 +1,6 @@
 {
   "name": "todo-vue",
-  "version": "0.0.53",
+  "version": "0.0.52",
   "private": true,
   "type": "module",
   "scripts": {

examples/todo/CHANGELOG.md

@@ -1,14 +1,5 @@
 # jazz-example-todo
 
-## 0.0.167
-
-### Patch Changes
-
-- Updated dependencies [1d71ca1]
-- Updated dependencies [ada802b]
-  - jazz-react@0.10.6
-  - jazz-tools@0.10.6
-
 ## 0.0.166
 
 ### Patch Changes

examples/todo/package.json

@@ -1,7 +1,7 @@
 {
   "name": "jazz-example-todo",
   "private": true,
-  "version": "0.0.167",
+  "version": "0.0.166",
   "type": "module",
   "scripts": {
     "dev": "vite",
@@ -16,8 +16,8 @@
     "@radix-ui/react-toast": "^1.1.4",
     "class-variance-authority": "^0.7.0",
     "clsx": "^2.0.0",
-    "jazz-react": "workspace:0.10.6",
-    "jazz-tools": "workspace:0.10.6",
+    "jazz-react": "workspace:0.10.5",
+    "jazz-tools": "workspace:0.10.5",
     "lucide-react": "^0.274.0",
     "qrcode": "^1.5.3",
     "react": "^18.3.1",

examples/version-history/CHANGELOG.md

@@ -1,14 +1,5 @@
 # version-history
 
-## 0.0.45
-
-### Patch Changes
-
-- Updated dependencies [1d71ca1]
-- Updated dependencies [ada802b]
-  - jazz-react@0.10.6
-  - jazz-tools@0.10.6
-
 ## 0.0.44
 
 ### Patch Changes

examples/version-history/package.json

@@ -1,7 +1,7 @@
 {
   "name": "version-history",
   "private": true,
-  "version": "0.0.45",
+  "version": "0.0.44",
   "type": "module",
   "scripts": {
     "dev": "vite",

flake.lock

@@ -20,11 +20,11 @@
     },
     "nixpkgs": {
       "locked": {
-        "lastModified": 1739580444,
-        "narHash": "sha256-+/bSz4EAVbqz8/HsIGLroF8aNaO8bLRL7WfACN+24g4=",
+        "lastModified": 1737885589,
+        "narHash": "sha256-Zf0hSrtzaM1DEz8//+Xs51k/wdSajticVrATqDrfQjg=",
         "owner": "nixos",
         "repo": "nixpkgs",
-        "rev": "8bb37161a0488b89830168b81c48aed11569cb93",
+        "rev": "852ff1d9e153d8875a83602e03fdef8a63f0ecf8",
         "type": "github"
       },
       "original": {

flake.nix

@@ -18,7 +18,6 @@
           buildInputs = with pkgs; [
             # General development
             git
-            turbo
             
             # JS development
             nodejs_22

homepage/design-system/src/app/components/atoms/Icon.tsx

@@ -8,7 +8,6 @@ import {
   ChevronRight,
   CodeIcon,
   CopyIcon,
-  FileLock2Icon,
   FileTextIcon,
   FingerprintIcon,
   FolderArchiveIcon,
@@ -62,7 +61,6 @@ const icons = {
   newsletter: MailIcon,
   offline: WifiOffIcon,
   package: BoxIcon,
-  permissions: FileLock2Icon,
   social: UsersIcon,
   spatialPresence: MousePointerSquareDashedIcon,
   tableOfContents: ScrollIcon,
@@ -119,7 +117,7 @@ export function Icon({
   className?: string;
 } & React.SVGProps<SVGSVGElement>) {
   if (!icon && (!name || !icons.hasOwnProperty(name))) {
-    throw new Error(`Icon not found: ${name}`);
+    throw new Error(`Icon not found`);
   }
 
   // @ts-ignore

homepage/homepage/generate-docs/llms-full.mjs

@@ -303,6 +303,7 @@ async function generateDetailedDocs(docs) {
     for (const page of section.pages) {
       output.push(`#### ${page.title}\n`);
       const content = await readMdxContent(page.url);
+      console.log(content);
       if (content) {
         // If the content contains framework-specific implementations, they're already properly formatted
         // Otherwise, just add the content directly

homepage/homepage/turbo.json

@@ -7,7 +7,7 @@
     },
     "build:generate-docs": {
       "inputs": ["../../../packages/*/src/**"],
-      "outputs": ["typedoc/**", "public/llms.txt", "public/llms-full.txt"],
+      "outputs": ["typedoc/**"],
       "dependsOn": ["^build"]
     },
     "dev": {

packages/cojson-storage-indexeddb/CHANGELOG.md

@@ -1,13 +1,5 @@
 # cojson-storage-indexeddb
 
-## 0.10.6
-
-### Patch Changes
-
-- Updated dependencies [5c76e37]
-  - cojson@0.10.6
-  - cojson-storage@0.10.6
-
 ## 0.10.4
 
 ### Patch Changes

packages/cojson-storage-indexeddb/package.json

@@ -1,6 +1,6 @@
 {
   "name": "cojson-storage-indexeddb",
-  "version": "0.10.6",
+  "version": "0.10.4",
   "main": "dist/index.js",
   "type": "module",
   "types": "src/index.ts",

packages/cojson-storage-indexeddb/src/CoJsonIDBTransaction.ts

@@ -0,0 +1,111 @@
+export type StoreName =
+  | "coValues"
+  | "sessions"
+  | "transactions"
+  | "signatureAfter";
+
+// A access unit for the IndexedDB Jazz database
+// It's a wrapper around the IDBTransaction object that helps on batching multiple operations
+// in a single transaction.
+export class CoJsonIDBTransaction {
+  db: IDBDatabase;
+  tx: IDBTransaction;
+
+  pendingRequests: ((txEntry: this) => void)[] = [];
+  rejectHandlers: (() => void)[] = [];
+
+  id = Math.random();
+
+  running = false;
+  failed = false;
+  done = false;
+
+  constructor(db: IDBDatabase) {
+    this.db = db;
+
+    this.tx = this.db.transaction(
+      ["coValues", "sessions", "transactions", "signatureAfter"],
+      "readwrite",
+    );
+
+    this.tx.oncomplete = () => {
+      this.done = true;
+    };
+    this.tx.onabort = () => {
+      this.done = true;
+    };
+  }
+
+  startedAt = performance.now();
+  isReusable() {
+    const delta = performance.now() - this.startedAt;
+    return !this.done && delta <= 20;
+  }
+
+  getObjectStore(name: StoreName) {
+    return this.tx.objectStore(name);
+  }
+
+  private pushRequest<T>(
+    handler: (txEntry: this, next: () => void) => Promise<T>,
+  ) {
+    const next = () => {
+      const next = this.pendingRequests.shift();
+
+      if (next) {
+        next(this);
+      } else {
+        this.running = false;
+        this.done = true;
+      }
+    };
+
+    if (this.running) {
+      return new Promise<T>((resolve, reject) => {
+        this.rejectHandlers.push(reject);
+        this.pendingRequests.push(async () => {
+          try {
+            const result = await handler(this, next);
+            resolve(result);
+          } catch (error) {
+            reject(error);
+          }
+        });
+      });
+    }
+
+    this.running = true;
+    return handler(this, next);
+  }
+
+  handleRequest<T>(handler: (txEntry: this) => IDBRequest<T>) {
+    return this.pushRequest<T>((txEntry, next) => {
+      return new Promise<T>((resolve, reject) => {
+        const request = handler(txEntry);
+
+        request.onerror = () => {
+          this.failed = true;
+          this.tx.abort();
+          console.error(request.error);
+          reject(request.error);
+
+          // Don't leave any pending promise
+          for (const handler of this.rejectHandlers) {
+            handler();
+          }
+        };
+
+        request.onsuccess = () => {
+          resolve(request.result as T);
+          next();
+        };
+      });
+    });
+  }
+
+  commit() {
+    if (!this.done) {
+      this.tx.commit();
+    }
+  }
+}

packages/cojson-storage-indexeddb/src/idbClient.ts

@@ -1,4 +1,4 @@
-import type { CojsonInternalTypes, RawCoID } from "cojson";
+import type { CojsonInternalTypes, RawCoID, SessionID } from "cojson";
 import type {
   CoValueRow,
   DBClientInterface,
@@ -8,119 +8,60 @@ import type {
   StoredSessionRow,
   TransactionRow,
 } from "cojson-storage";
-import { SyncPromise } from "./syncPromises.js";
+import { CoJsonIDBTransaction } from "./CoJsonIDBTransaction.js";
 
 export class IDBClient implements DBClientInterface {
   private db;
 
-  currentTx:
-    | {
-        id: number;
-        tx: IDBTransaction;
-        stores: {
-          coValues: IDBObjectStore;
-          sessions: IDBObjectStore;
-          transactions: IDBObjectStore;
-          signatureAfter: IDBObjectStore;
-        };
-        startedAt: number;
-        pendingRequests: ((txEntry: {
-          stores: {
-            coValues: IDBObjectStore;
-            sessions: IDBObjectStore;
-            transactions: IDBObjectStore;
-            signatureAfter: IDBObjectStore;
-          };
-        }) => void)[];
-      }
-    | undefined;
-
-  currentTxID = 0;
+  activeTransaction: CoJsonIDBTransaction | undefined;
+  autoBatchingTransaction: CoJsonIDBTransaction | undefined;
 
   constructor(db: IDBDatabase) {
     this.db = db;
   }
 
   makeRequest<T>(
-    handler: (stores: {
-      coValues: IDBObjectStore;
-      sessions: IDBObjectStore;
-      transactions: IDBObjectStore;
-      signatureAfter: IDBObjectStore;
-    }) => IDBRequest,
-  ): SyncPromise<T> {
-    return new SyncPromise((resolve, reject) => {
-      let txEntry = this.currentTx;
+    handler: (txEntry: CoJsonIDBTransaction) => IDBRequest<T>,
+  ): Promise<T> {
+    if (this.activeTransaction) {
+      return this.activeTransaction.handleRequest<T>(handler);
+    }
 
-      const requestEntry = ({
-        stores,
-      }: {
-        stores: {
-          coValues: IDBObjectStore;
-          sessions: IDBObjectStore;
-          transactions: IDBObjectStore;
-          signatureAfter: IDBObjectStore;
-        };
-      }) => {
-        const request = handler(stores);
-        request.onerror = () => {
-          console.error("Error in request", request.error);
-          this.currentTx = undefined;
-          reject(request.error);
-        };
-        request.onsuccess = () => {
-          const value = request.result as T;
-          resolve(value);
+    if (this.autoBatchingTransaction?.isReusable()) {
+      return this.autoBatchingTransaction.handleRequest<T>(handler);
+    }
 
-          const next = txEntry?.pendingRequests.shift();
+    const tx = new CoJsonIDBTransaction(this.db);
 
-          if (next) {
-            next({ stores });
-          } else {
-            if (this.currentTx === txEntry) {
-              this.currentTx = undefined;
-            }
-          }
-        };
-      };
+    this.autoBatchingTransaction = tx;
 
-      // Transaction batching
-      if (!txEntry || performance.now() - txEntry.startedAt > 20) {
-        const tx = this.db.transaction(
-          ["coValues", "sessions", "transactions", "signatureAfter"],
-          "readwrite",
-        );
-        txEntry = {
-          id: this.currentTxID++,
-          tx,
-          stores: {
-            coValues: tx.objectStore("coValues"),
-            sessions: tx.objectStore("sessions"),
-            transactions: tx.objectStore("transactions"),
-            signatureAfter: tx.objectStore("signatureAfter"),
-          },
-          startedAt: performance.now(),
-          pendingRequests: [],
-        };
-
-        this.currentTx = txEntry;
-
-        requestEntry(txEntry);
-      } else {
-        txEntry.pendingRequests.push(requestEntry);
-      }
-    });
+    return tx.handleRequest<T>(handler);
   }
 
   async getCoValue(coValueId: RawCoID): Promise<StoredCoValueRow | undefined> {
-    return this.makeRequest<StoredCoValueRow | undefined>(({ coValues }) =>
-      coValues.index("coValuesById").get(coValueId),
+    return this.makeRequest<StoredCoValueRow | undefined>((tx) =>
+      tx.getObjectStore("coValues").index("coValuesById").get(coValueId),
     );
   }
 
   async getCoValueSessions(coValueRowId: number): Promise<StoredSessionRow[]> {
-    return this.makeRequest<StoredSessionRow[]>(({ sessions }) =>
-      sessions.index("sessionsByCoValue").getAll(coValueRowId),
+    return this.makeRequest<StoredSessionRow[]>((tx) =>
+      tx
+        .getObjectStore("sessions")
+        .index("sessionsByCoValue")
+        .getAll(coValueRowId),
+    );
+  }
+
+  async getSingleCoValueSession(
+    coValueRowId: number,
+    sessionID: SessionID,
+  ): Promise<StoredSessionRow | undefined> {
+    return this.makeRequest<StoredSessionRow>((tx) =>
+      tx
+        .getObjectStore("sessions")
+        .index("uniqueSessions")
+        .get([coValueRowId, sessionID]),
     );
   }
 
@@ -128,13 +69,15 @@ export class IDBClient implements DBClientInterface {
     sessionRowId: number,
     firstNewTxIdx: number,
   ): Promise<TransactionRow[]> {
-    return this.makeRequest<TransactionRow[]>(({ transactions }) =>
-      transactions.getAll(
-        IDBKeyRange.bound(
-          [sessionRowId, firstNewTxIdx],
-          [sessionRowId, Number.POSITIVE_INFINITY],
+    return this.makeRequest<TransactionRow[]>((tx) =>
+      tx
+        .getObjectStore("transactions")
+        .getAll(
+          IDBKeyRange.bound(
+            [sessionRowId, firstNewTxIdx],
+            [sessionRowId, Number.POSITIVE_INFINITY],
+          ),
         ),
-      ),
     );
   }
 
@@ -142,9 +85,10 @@ export class IDBClient implements DBClientInterface {
     sessionRowId: number,
     firstNewTxIdx: number,
   ): Promise<SignatureAfterRow[]> {
-    return this.makeRequest<SignatureAfterRow[]>(
-      ({ signatureAfter }: { signatureAfter: IDBObjectStore }) =>
-        signatureAfter.getAll(
+    return this.makeRequest<SignatureAfterRow[]>((tx) =>
+      tx
+        .getObjectStore("signatureAfter")
+        .getAll(
           IDBKeyRange.bound(
             [sessionRowId, firstNewTxIdx],
             [sessionRowId, Number.POSITIVE_INFINITY],
@@ -160,8 +104,8 @@ export class IDBClient implements DBClientInterface {
       throw new Error(`Header is required, coId: ${msg.id}`);
     }
 
-    return (await this.makeRequest<IDBValidKey>(({ coValues }) =>
-      coValues.put({
+    return (await this.makeRequest<IDBValidKey>((tx) =>
+      tx.getObjectStore("coValues").put({
         id: msg.id,
         // biome-ignore lint/style/noNonNullAssertion: TODO(JAZZ-561): Review
         header: msg.header!,
@@ -176,25 +120,26 @@ export class IDBClient implements DBClientInterface {
     sessionUpdate: SessionRow;
     sessionRow?: StoredSessionRow;
   }): Promise<number> {
-    return this.makeRequest<number>(({ sessions }) =>
-      sessions.put(
-        sessionRow?.rowID
-          ? {
-              rowID: sessionRow.rowID,
-              ...sessionUpdate,
-            }
-          : sessionUpdate,
-      ),
+    return this.makeRequest<number>(
+      (tx) =>
+        tx.getObjectStore("sessions").put(
+          sessionRow?.rowID
+            ? {
+                rowID: sessionRow.rowID,
+                ...sessionUpdate,
+              }
+            : sessionUpdate,
+        ) as IDBRequest<number>,
     );
   }
 
-  addTransaction(
+  async addTransaction(
     sessionRowID: number,
     idx: number,
     newTransaction: CojsonInternalTypes.Transaction,
   ) {
-    return this.makeRequest(({ transactions }) =>
-      transactions.add({
+    await this.makeRequest((tx) =>
+      tx.getObjectStore("transactions").add({
         ses: sessionRowID,
         idx,
         tx: newTransaction,
@@ -211,8 +156,8 @@ export class IDBClient implements DBClientInterface {
     idx: number;
     signature: CojsonInternalTypes.Signature;
   }) {
-    return this.makeRequest(({ signatureAfter }) =>
-      signatureAfter.put({
+    return this.makeRequest((tx) =>
+      tx.getObjectStore("signatureAfter").put({
         ses: sessionRowID,
         idx,
         signature,
@@ -220,7 +165,24 @@ export class IDBClient implements DBClientInterface {
     );
   }
 
-  async unitOfWork(operationsCallback: () => unknown[]) {
-    return Promise.all(operationsCallback());
+  closeTransaction(tx: CoJsonIDBTransaction) {
+    tx.commit();
+
+    if (tx === this.activeTransaction) {
+      this.activeTransaction = undefined;
+    }
+  }
+
+  async transaction(operationsCallback: () => unknown) {
+    const tx = new CoJsonIDBTransaction(this.db);
+
+    this.activeTransaction = tx;
+
+    try {
+      await operationsCallback();
+      tx.commit(); // Tells the browser to not wait for another possible request and commit the transaction immediately
+    } finally {
+      this.activeTransaction = undefined;
+    }
   }
 }

packages/cojson-storage-indexeddb/src/idbNode.ts

@@ -33,18 +33,7 @@ export class IDBNode {
           }
           await this.syncManager.handleSyncMessage(msg);
         } catch (e) {
-          console.error(
-            new Error(
-              `Error reading from localNode, handling msg\n\n${JSON.stringify(
-                msg,
-                (k, v) =>
-                  k === "changes" || k === "encryptedChanges"
-                    ? `${v.slice(0, 20)}...`
-                    : v,
-              )}`,
-              { cause: e },
-            ),
-          );
+          console.error(e);
         }
       }
     };

packages/cojson-storage-indexeddb/src/syncPromises.ts

@@ -1,224 +0,0 @@
-const isFunction = (func: any) => typeof func === "function";
-
-const isObject = (supposedObject: any) =>
-  typeof supposedObject === "object" &&
-  supposedObject !== null &&
-  !Array.isArray(supposedObject);
-
-const isThenable = (obj: any) => isObject(obj) && isFunction(obj.then);
-
-const identity = (co: any) => co;
-
-export { identity, isFunction, isObject, isThenable };
-
-enum States {
-  PENDING = "PENDING",
-  RESOLVED = "RESOLVED",
-  REJECTED = "REJECTED",
-}
-
-interface Handler<T, U> {
-  onSuccess: HandlerOnSuccess<T, U>;
-  onFail: HandlerOnFail<U>;
-}
-
-type HandlerOnSuccess<T, U = any> = (value: T) => U | Thenable<U>;
-type HandlerOnFail<U = any> = (reason: any) => U | Thenable<U>;
-type Finally<U> = () => U | Thenable<U>;
-
-interface Thenable<T> {
-  then<U>(
-    onSuccess?: HandlerOnSuccess<T, U>,
-    onFail?: HandlerOnFail<U>,
-  ): Thenable<U>;
-  then<U>(
-    onSuccess?: HandlerOnSuccess<T, U>,
-    onFail?: (reason: any) => void,
-  ): Thenable<U>;
-}
-
-type Resolve<R> = (value?: R | Thenable<R>) => void;
-type Reject = (value?: any) => void;
-
-export class SyncPromise<T> {
-  private state: States = States.PENDING;
-  private handlers: Handler<T, any>[] = [];
-  private value: T | any;
-
-  public constructor(callback: (resolve: Resolve<T>, reject: Reject) => void) {
-    try {
-      callback(this.resolve as Resolve<T>, this.reject);
-    } catch (e) {
-      this.reject(e);
-    }
-  }
-
-  private resolve = (value: T) => {
-    return this.setResult(value, States.RESOLVED);
-  };
-
-  private reject = (reason: any) => {
-    return this.setResult(reason, States.REJECTED);
-  };
-
-  private setResult = (value: T | any, state: States) => {
-    const set = () => {
-      if (this.state !== States.PENDING) {
-        return null;
-      }
-
-      if (isThenable(value)) {
-        return (value as Thenable<T>).then(this.resolve, this.reject);
-      }
-
-      this.value = value;
-      this.state = state;
-
-      return this.executeHandlers();
-    };
-
-    void set();
-  };
-
-  private executeHandlers = () => {
-    if (this.state === States.PENDING) {
-      return null;
-    }
-
-    for (const handler of this.handlers) {
-      if (this.state === States.REJECTED) {
-        handler.onFail(this.value);
-      } else {
-        handler.onSuccess(this.value);
-      }
-    }
-
-    this.handlers = [];
-  };
-
-  private attachHandler = (handler: Handler<T, any>) => {
-    this.handlers = [...this.handlers, handler];
-
-    this.executeHandlers();
-  };
-
-  // biome-ignore lint/suspicious/noThenProperty: TODO(JAZZ-561): Review
-  public then<U>(onSuccess: HandlerOnSuccess<T, U>, onFail?: HandlerOnFail<U>) {
-    return new SyncPromise<U>((resolve, reject) => {
-      return this.attachHandler({
-        onSuccess: (result) => {
-          try {
-            return resolve(onSuccess(result));
-          } catch (e) {
-            return reject(e);
-          }
-        },
-        onFail: (reason) => {
-          if (!onFail) {
-            return reject(reason);
-          }
-
-          try {
-            return resolve(onFail(reason));
-          } catch (e) {
-            return reject(e);
-          }
-        },
-      });
-    });
-  }
-
-  public catch<U>(onFail: HandlerOnFail<U>) {
-    return this.then<U>(identity, onFail);
-  }
-
-  // methods
-
-  public toString() {
-    return "[object SyncPromise]";
-  }
-
-  public finally<U>(cb: Finally<U>) {
-    return new SyncPromise<U>((resolve, reject) => {
-      let co: U | any;
-      let isRejected: boolean;
-
-      return this.then(
-        (value) => {
-          isRejected = false;
-          co = value;
-          return cb();
-        },
-        (reason) => {
-          isRejected = true;
-          co = reason;
-          return cb();
-        },
-      ).then(() => {
-        if (isRejected) {
-          return reject(co);
-        }
-
-        return resolve(co);
-      });
-    });
-  }
-
-  public spread<U>(handler: (...args: any[]) => U) {
-    return this.then<U>((collection) => {
-      if (Array.isArray(collection)) {
-        return handler(...collection);
-      }
-
-      return handler(collection);
-    });
-  }
-
-  // static
-
-  public static resolve<U = any>(value?: U | Thenable<U>) {
-    return new SyncPromise<U>((resolve) => {
-      return resolve(value);
-    });
-  }
-
-  public static reject<U>(reason?: any) {
-    return new SyncPromise<U>((_resolve, reject) => {
-      return reject(reason);
-    });
-  }
-
-  public static all<U = any>(collection: (U | Thenable<U>)[]) {
-    return new SyncPromise<U[]>((resolve, reject) => {
-      if (!Array.isArray(collection)) {
-        return reject(new TypeError("An array must be provided."));
-      }
-
-      if (collection.length === 0) {
-        return resolve([]);
-      }
-
-      let counter = collection.length;
-      const resolvedCollection: U[] = [];
-
-      const tryResolve = (value: U, index: number) => {
-        counter -= 1;
-        resolvedCollection[index] = value;
-
-        if (counter !== 0) {
-          return null;
-        }
-
-        return resolve(resolvedCollection);
-      };
-
-      return collection.forEach((item, index) => {
-        return SyncPromise.resolve(item)
-          .then((value) => {
-            return tryResolve(value, index);
-          })
-          .catch(reject);
-      });
-    });
-  }
-}

packages/cojson-storage-indexeddb/src/tests/CoJsonIDBTransaction.test.ts

@@ -0,0 +1,170 @@
+import { afterEach, beforeEach, describe, expect, test } from "vitest";
+import { CoJsonIDBTransaction } from "../CoJsonIDBTransaction";
+
+const TEST_DB_NAME = "test-cojson-idb-transaction";
+
+describe("CoJsonIDBTransaction", () => {
+  let db: IDBDatabase;
+
+  beforeEach(async () => {
+    // Create test database
+    await new Promise<void>((resolve, reject) => {
+      const request = indexedDB.open(TEST_DB_NAME, 1);
+
+      request.onerror = () => reject(request.error);
+
+      request.onupgradeneeded = (event) => {
+        const db = request.result;
+        // Create test stores
+        db.createObjectStore("coValues", { keyPath: "id" });
+        const sessions = db.createObjectStore("sessions", { keyPath: "id" });
+        sessions.createIndex("uniqueSessions", ["coValue", "sessionID"], {
+          unique: true,
+        });
+        db.createObjectStore("transactions", { keyPath: "id" });
+        db.createObjectStore("signatureAfter", { keyPath: "id" });
+      };
+
+      request.onsuccess = () => {
+        db = request.result;
+        resolve();
+      };
+    });
+  });
+
+  afterEach(async () => {
+    // Close and delete test database
+    db.close();
+    await new Promise<void>((resolve, reject) => {
+      const request = indexedDB.deleteDatabase(TEST_DB_NAME);
+      request.onerror = () => reject(request.error);
+      request.onsuccess = () => resolve();
+    });
+  });
+
+  test("handles successful write and read operations", async () => {
+    const tx = new CoJsonIDBTransaction(db);
+
+    // Write test
+    await tx.handleRequest((tx) =>
+      tx.getObjectStore("coValues").put({
+        id: "test1",
+        value: "hello",
+      }),
+    );
+
+    // Read test
+    const readTx = new CoJsonIDBTransaction(db);
+    const result = await readTx.handleRequest((tx) =>
+      tx.getObjectStore("coValues").get("test1"),
+    );
+
+    expect(result).toEqual({
+      id: "test1",
+      value: "hello",
+    });
+  });
+
+  test("handles multiple operations in single transaction", async () => {
+    const tx = new CoJsonIDBTransaction(db);
+
+    // Multiple writes
+    await Promise.all([
+      tx.handleRequest((tx) =>
+        tx.getObjectStore("coValues").put({
+          id: "test1",
+          value: "hello",
+        }),
+      ),
+      tx.handleRequest((tx) =>
+        tx.getObjectStore("coValues").put({
+          id: "test2",
+          value: "world",
+        }),
+      ),
+    ]);
+
+    // Read results
+    const readTx = new CoJsonIDBTransaction(db);
+    const [result1, result2] = await Promise.all([
+      readTx.handleRequest((tx) => tx.getObjectStore("coValues").get("test1")),
+      readTx.handleRequest((tx) => tx.getObjectStore("coValues").get("test2")),
+    ]);
+
+    expect(result1).toEqual({
+      id: "test1",
+      value: "hello",
+    });
+    expect(result2).toEqual({
+      id: "test2",
+      value: "world",
+    });
+  });
+
+  test("handles transaction across multiple stores", async () => {
+    const tx = new CoJsonIDBTransaction(db);
+
+    await Promise.all([
+      tx.handleRequest((tx) =>
+        tx.getObjectStore("coValues").put({
+          id: "value1",
+          data: "value data",
+        }),
+      ),
+      tx.handleRequest((tx) =>
+        tx.getObjectStore("sessions").put({
+          id: "session1",
+          data: "session data",
+        }),
+      ),
+    ]);
+
+    const readTx = new CoJsonIDBTransaction(db);
+    const [valueResult, sessionResult] = await Promise.all([
+      readTx.handleRequest((tx) => tx.getObjectStore("coValues").get("value1")),
+      readTx.handleRequest((tx) =>
+        tx.getObjectStore("sessions").get("session1"),
+      ),
+    ]);
+
+    expect(valueResult).toEqual({
+      id: "value1",
+      data: "value data",
+    });
+    expect(sessionResult).toEqual({
+      id: "session1",
+      data: "session data",
+    });
+  });
+
+  test("handles failed transactions", async () => {
+    const tx = new CoJsonIDBTransaction(db);
+
+    await expect(
+      tx.handleRequest((tx) =>
+        tx.getObjectStore("sessions").put({
+          id: 1,
+          coValue: "value1",
+          sessionID: "session1",
+          data: "session data",
+        }),
+      ),
+    ).resolves.toBe(1);
+
+    expect(tx.failed).toBe(false);
+
+    const badTx = new CoJsonIDBTransaction(db);
+    await expect(
+      badTx.handleRequest((tx) =>
+        tx.getObjectStore("sessions").put({
+          id: 2,
+          coValue: "value1",
+          sessionID: "session1",
+          data: "session data",
+        }),
+      ),
+    ).rejects.toThrow();
+
+    expect(badTx.failed).toBe(true);
+  });
+});

packages/cojson-storage-rn-sqlite/CHANGELOG.md

@@ -1,13 +1,5 @@
 # cojson-storage-sqlite
 
-## 0.8.64
-
-### Patch Changes
-
-- Updated dependencies [5c76e37]
-  - cojson@0.10.6
-  - cojson-storage@0.10.6
-
 ## 0.8.63
 
 ### Patch Changes

packages/cojson-storage-rn-sqlite/package.json

@@ -1,7 +1,7 @@
 {
   "name": "cojson-storage-rn-sqlite",
   "type": "module",
-  "version": "0.8.64",
+  "version": "0.8.63",
   "main": "dist/index.js",
   "types": "src/index.ts",
   "license": "MIT",

packages/cojson-storage-rn-sqlite/src/client.ts

@@ -1,5 +1,10 @@
 import { type DB as DatabaseT } from "@op-engineering/op-sqlite";
-import { CojsonInternalTypes, type OutgoingSyncQueue, RawCoID } from "cojson";
+import {
+  CojsonInternalTypes,
+  type OutgoingSyncQueue,
+  RawCoID,
+  SessionID,
+} from "cojson";
 import type {
   DBClientInterface,
   SessionRow,
@@ -48,6 +53,17 @@ export class SQLiteClient implements DBClientInterface {
     return rows as StoredSessionRow[];
   }
 
+  async getSingleCoValueSession(
+    coValueRowId: number,
+    sessionID: SessionID,
+  ): Promise<StoredSessionRow | undefined> {
+    const { rows } = await this.db.execute(
+      "SELECT * FROM sessions WHERE coValue = ? AND sessionID = ?",
+      [coValueRowId, sessionID],
+    );
+    return rows[0] as StoredSessionRow | undefined;
+  }
+
   async getNewTransactionInSession(
     sessionRowId: number,
     firstNewTxIdx: number,
@@ -142,12 +158,10 @@ export class SQLiteClient implements DBClientInterface {
     );
   }
 
-  async unitOfWork(
-    operationsCallback: () => Promise<unknown>[],
-  ): Promise<void> {
+  async transaction(operationsCallback: () => unknown) {
     try {
       await this.db.transaction(async () => {
-        await Promise.all(operationsCallback());
+        await operationsCallback();
       });
     } catch (e) {
       console.error("Transaction failed:", e);

packages/cojson-storage-sqlite/CHANGELOG.md

@@ -1,13 +1,5 @@
 # cojson-storage-sqlite
 
-## 0.10.6
-
-### Patch Changes
-
-- Updated dependencies [5c76e37]
-  - cojson@0.10.6
-  - cojson-storage@0.10.6
-
 ## 0.10.4
 
 ### Patch Changes

packages/cojson-storage-sqlite/package.json

@@ -1,13 +1,13 @@
 {
   "name": "cojson-storage-sqlite",
   "type": "module",
-  "version": "0.10.6",
+  "version": "0.10.4",
   "main": "dist/index.js",
   "types": "src/index.ts",
   "license": "MIT",
   "dependencies": {
     "better-sqlite3": "^11.7.0",
-    "cojson": "workspace:0.10.6",
+    "cojson": "workspace:0.10.4",
     "cojson-storage": "workspace:*"
   },
   "devDependencies": {

packages/cojson-storage-sqlite/src/sqliteClient.ts

@@ -71,6 +71,17 @@ export class SQLiteClient implements DBClientInterface {
       .all(coValueRowId) as StoredSessionRow[];
   }
 
+  getSingleCoValueSession(
+    coValueRowId: number,
+    sessionID: SessionID,
+  ): StoredSessionRow | undefined {
+    return this.db
+      .prepare<[number, string]>(
+        `SELECT * FROM sessions WHERE coValue = ? AND sessionID = ?`,
+      )
+      .get(coValueRowId, sessionID) as StoredSessionRow | undefined;
+  }
+
   getNewTransactionInSession(
     sessionRowId: number,
     firstNewTxIdx: number,
@@ -159,7 +170,7 @@ export class SQLiteClient implements DBClientInterface {
       .run(sessionRowID, idx, signature);
   }
 
-  unitOfWork(operationsCallback: () => any[]) {
+  transaction(operationsCallback: () => unknown) {
     this.db.transaction(operationsCallback)();
   }
 }

packages/cojson-storage/CHANGELOG.md

@@ -1,12 +1,5 @@
 # cojson-storage
 
-## 0.10.6
-
-### Patch Changes
-
-- Updated dependencies [5c76e37]
-  - cojson@0.10.6
-
 ## 0.10.4
 
 ### Patch Changes

packages/cojson-storage/package.json

@@ -1,6 +1,6 @@
 {
   "name": "cojson-storage",
-  "version": "0.10.6",
+  "version": "0.10.4",
   "main": "dist/index.js",
   "type": "module",
   "types": "src/index.ts",

packages/cojson-storage/src/syncManager.ts

@@ -200,15 +200,6 @@ export class SyncManager {
       ? coValueRow.rowID
       : await this.dbClient.addCoValue(msg);
 
-    const allOurSessionsEntries =
-      await this.dbClient.getCoValueSessions(storedCoValueRowID);
-
-    const allOurSessions: {
-      [sessionID: SessionID]: StoredSessionRow;
-    } = Object.fromEntries(
-      allOurSessionsEntries.map((row) => [row.sessionID, row]),
-    );
-
     const ourKnown: CojsonInternalTypes.CoValueKnownState = {
       id: msg.id,
       header: true,
@@ -217,9 +208,13 @@ export class SyncManager {
 
     let invalidAssumptions = false;
 
-    await this.dbClient.unitOfWork(() =>
-      (Object.keys(msg.new) as SessionID[]).map((sessionID) => {
-        const sessionRow = allOurSessions[sessionID];
+    for (const sessionID of Object.keys(msg.new) as SessionID[]) {
+      await this.dbClient.transaction(async () => {
+        const sessionRow = await this.dbClient.getSingleCoValueSession(
+          storedCoValueRowID,
+          sessionID,
+        );
+
         if (sessionRow) {
           ourKnown.sessions[sessionRow.sessionID] = sessionRow.lastIdx;
         }
@@ -229,8 +224,8 @@ export class SyncManager {
         } else {
           return this.putNewTxs(msg, sessionID, sessionRow, storedCoValueRowID);
         }
-      }),
-    );
+      });
+    }
 
     if (invalidAssumptions) {
       this.sendStateMessage({

packages/cojson-storage/src/tests/syncManager.test.ts

@@ -45,9 +45,11 @@ describe("DB sync manager", () => {
   const DBClient = vi.fn();
   DBClient.prototype.getCoValue = vi.fn();
   DBClient.prototype.getCoValueSessions = vi.fn();
+  DBClient.prototype.getSingleCoValueSession = vi.fn();
+  DBClient.prototype.getNewTransactionInSession = vi.fn();
   DBClient.prototype.addSessionUpdate = vi.fn();
   DBClient.prototype.addTransaction = vi.fn();
-  DBClient.prototype.unitOfWork = vi.fn((callback) => Promise.all(callback()));
+  DBClient.prototype.transaction = vi.fn((callback) => callback());
 
   beforeEach(async () => {
     const idbClient = new DBClient() as unknown as Mocked<DBClientInterface>;

packages/cojson-storage/src/types.ts

@@ -41,6 +41,11 @@ export interface DBClientInterface {
     coValueRowId: number,
   ): Promise<StoredSessionRow[]> | StoredSessionRow[];
 
+  getSingleCoValueSession(
+    coValueRowId: number,
+    sessionID: SessionID,
+  ): Promise<StoredSessionRow | undefined> | StoredSessionRow | undefined;
+
   getNewTransactionInSession(
     sessionRowId: number,
     firstNewTxIdx: number,
@@ -79,5 +84,5 @@ export interface DBClientInterface {
     signature: Signature;
   }): Promise<number> | void | unknown;
 
-  unitOfWork(operationsCallback: () => unknown[]): Promise<unknown> | void;
+  transaction(callback: () => unknown): Promise<unknown> | void;
 }

packages/cojson-transport-ws/CHANGELOG.md

@@ -1,12 +1,5 @@
 # cojson-transport-nodejs-ws
 
-## 0.10.6
-
-### Patch Changes
-
-- Updated dependencies [5c76e37]
-  - cojson@0.10.6
-
 ## 0.10.4
 
 ### Patch Changes

packages/cojson-transport-ws/package.json

@@ -1,7 +1,7 @@
 {
   "name": "cojson-transport-ws",
   "type": "module",
-  "version": "0.10.6",
+  "version": "0.10.4",
   "main": "dist/index.js",
   "types": "src/index.ts",
   "license": "MIT",

packages/cojson/CHANGELOG.md

@@ -1,11 +1,5 @@
 # cojson
 
-## 0.10.6
-
-### Patch Changes
-
-- 5c76e37: Ports Wasm crypto functions to use exported library `jazz-crypto-rs`
-
 ## 0.10.4
 
 ### Patch Changes

packages/cojson/package.json

@@ -25,7 +25,7 @@
   },
   "type": "module",
   "license": "MIT",
-  "version": "0.10.6",
+  "version": "0.10.4",
   "devDependencies": {
     "@opentelemetry/sdk-metrics": "^1.29.0",
     "typescript": "~5.6.2",

packages/hash-slash/CHANGELOG.md

@@ -1,49 +1,43 @@
 # hash-slash
 
-## 0.2.2
-
-### Patch Changes
-
-- 1d71ca1: Add React 19 to the peer dependencies
-
 ## 0.2.1
 
 ### Patch Changes
 
-- Parent-frame friendlier naviation
+-   Parent-frame friendlier naviation
 
 ## 0.2.0
 
 ### Minor Changes
 
-- e299c3e: New simplified API
+-   e299c3e: New simplified API
 
 ### Patch Changes
 
-- 60d5ca2: Allow fall-through of routes
-- 69ac514: Use effect schema much less
-- 627d895: Get rid of Co namespace
+-   60d5ca2: Allow fall-through of routes
+-   69ac514: Use effect schema much less
+-   627d895: Get rid of Co namespace
 
 ## 0.2.0-alpha.3
 
 ### Patch Changes
 
-- Allow fall-through of routes
+-   Allow fall-through of routes
 
 ## 0.2.0-alpha.2
 
 ### Patch Changes
 
-- Get rid of Co namespace
+-   Get rid of Co namespace
 
 ## 0.2.0-alpha.1
 
 ### Patch Changes
 
-- Use effect schema much less
+-   Use effect schema much less
 
 ## 0.2.0-alpha.0
 
 ### Minor Changes
 
-- New simplified API
+-   New simplified API

packages/hash-slash/package.json

@@ -1,6 +1,6 @@
 {
   "name": "hash-slash",
-  "version": "0.2.2",
+  "version": "0.2.1",
   "type": "module",
   "main": "dist/index.js",
   "types": "src/index.tsx",

packages/jazz-auth-clerk/CHANGELOG.md

@@ -1,15 +1,5 @@
 # jazz-browser-media-images
 
-## 0.10.6
-
-### Patch Changes
-
-- Updated dependencies [5c76e37]
-- Updated dependencies [ada802b]
-  - cojson@0.10.6
-  - jazz-tools@0.10.6
-  - jazz-browser@0.10.6
-
 ## 0.10.5
 
 ### Patch Changes

packages/jazz-auth-clerk/package.json

@@ -1,14 +1,14 @@
 {
   "name": "jazz-auth-clerk",
-  "version": "0.10.6",
+  "version": "0.10.5",
   "type": "module",
   "main": "dist/index.js",
   "types": "src/index.ts",
   "license": "MIT",
   "dependencies": {
-    "cojson": "workspace:0.10.6",
-    "jazz-browser": "workspace:0.10.6",
-    "jazz-tools": "workspace:0.10.6"
+    "cojson": "workspace:0.10.4",
+    "jazz-browser": "workspace:0.10.5",
+    "jazz-tools": "workspace:0.10.5"
   },
   "scripts": {
     "format-and-lint": "biome check .",

packages/jazz-browser-media-images/CHANGELOG.md

@@ -1,13 +1,5 @@
 # jazz-browser-media-images
 
-## 0.10.6
-
-### Patch Changes
-
-- Updated dependencies [ada802b]
-  - jazz-tools@0.10.6
-  - jazz-browser@0.10.6
-
 ## 0.10.5
 
 ### Patch Changes

packages/jazz-browser-media-images/package.json

@@ -1,6 +1,6 @@
 {
   "name": "jazz-browser-media-images",
-  "version": "0.10.6",
+  "version": "0.10.5",
   "type": "module",
   "main": "dist/index.js",
   "types": "src/index.ts",
@@ -8,8 +8,8 @@
   "dependencies": {
     "@types/image-blob-reduce": "^4.1.1",
     "image-blob-reduce": "^4.1.0",
-    "jazz-browser": "workspace:0.10.6",
-    "jazz-tools": "workspace:0.10.6",
+    "jazz-browser": "workspace:0.10.5",
+    "jazz-tools": "workspace:0.10.5",
     "pica": "^9.0.1",
     "typescript": "~5.6.2"
   },

packages/jazz-browser/CHANGELOG.md

@@ -1,16 +1,5 @@
 # jazz-browser
 
-## 0.10.6
-
-### Patch Changes
-
-- Updated dependencies [5c76e37]
-- Updated dependencies [ada802b]
-  - cojson@0.10.6
-  - jazz-tools@0.10.6
-  - cojson-storage-indexeddb@0.10.6
-  - cojson-transport-ws@0.10.6
-
 ## 0.10.5
 
 ### Patch Changes

packages/jazz-browser/package.json

@@ -1,6 +1,6 @@
 {
   "name": "jazz-browser",
-  "version": "0.10.6",
+  "version": "0.10.5",
   "type": "module",
   "main": "dist/index.js",
   "types": "src/index.ts",

packages/jazz-inspector/CHANGELOG.md

@@ -1,16 +1,5 @@
 # jazz-inspector
 
-## 0.10.6
-
-### Patch Changes
-
-- Updated dependencies [1d71ca1]
-- Updated dependencies [5c76e37]
-- Updated dependencies [ada802b]
-  - jazz-react-core@0.10.6
-  - cojson@0.10.6
-  - jazz-tools@0.10.6
-
 ## 0.10.5
 
 ### Patch Changes

packages/jazz-inspector/package.json

@@ -1,13 +1,10 @@
 {
   "name": "jazz-inspector",
-  "version": "0.10.6",
+  "version": "0.10.5",
   "type": "module",
   "main": "./dist/app.js",
   "types": "./dist/app.d.ts",
-  "files": [
-    "dist/**",
-    "src"
-  ],
+  "files": ["dist/**", "src"],
   "scripts": {
     "dev": "vite build --watch",
     "build": "rm -rf ./dist && tsc --sourceMap --outDir dist",

packages/jazz-nodejs/CHANGELOG.md

@@ -1,15 +1,5 @@
 # jazz-autosub
 
-## 0.10.6
-
-### Patch Changes
-
-- Updated dependencies [5c76e37]
-- Updated dependencies [ada802b]
-  - cojson@0.10.6
-  - jazz-tools@0.10.6
-  - cojson-transport-ws@0.10.6
-
 ## 0.10.5
 
 ### Patch Changes

packages/jazz-nodejs/package.json

@@ -5,7 +5,7 @@
   "types": "src/index.ts",
   "type": "module",
   "license": "MIT",
-  "version": "0.10.6",
+  "version": "0.10.5",
   "dependencies": {
     "cojson": "workspace:*",
     "cojson-transport-ws": "workspace:*",

packages/jazz-react-auth-clerk/CHANGELOG.md

@@ -1,18 +1,5 @@
 # jazz-browser-media-images
 
-## 0.10.6
-
-### Patch Changes
-
-- 1d71ca1: Add React 19 to the peer dependencies
-- Updated dependencies [1d71ca1]
-- Updated dependencies [5c76e37]
-- Updated dependencies [ada802b]
-  - jazz-react@0.10.6
-  - cojson@0.10.6
-  - jazz-tools@0.10.6
-  - jazz-auth-clerk@0.10.6
-
 ## 0.10.5
 
 ### Patch Changes

packages/jazz-react-auth-clerk/package.json

@@ -1,6 +1,6 @@
 {
   "name": "jazz-react-auth-clerk",
-  "version": "0.10.6",
+  "version": "0.10.5",
   "type": "module",
   "main": "dist/index.js",
   "types": "src/index.tsx",

packages/jazz-react-core/CHANGELOG.md

@@ -1,15 +1,5 @@
 # jazz-react-core
 
-## 0.10.6
-
-### Patch Changes
-
-- 1d71ca1: Add React 19 to the peer dependencies
-- Updated dependencies [5c76e37]
-- Updated dependencies [ada802b]
-  - cojson@0.10.6
-  - jazz-tools@0.10.6
-
 ## 0.10.5
 
 ### Patch Changes

packages/jazz-react-core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "jazz-react-core",
-  "version": "0.10.6",
+  "version": "0.10.5",
   "type": "module",
   "main": "dist/index.js",
   "types": "src/index.ts",

packages/jazz-react-native-auth-clerk/CHANGELOG.md

@@ -1,16 +1,5 @@
 # jazz-react-native-auth-clerk
 
-## 0.10.6
-
-### Patch Changes
-
-- Updated dependencies [5c76e37]
-- Updated dependencies [ada802b]
-  - cojson@0.10.6
-  - jazz-tools@0.10.6
-  - jazz-react-native@0.10.6
-  - jazz-auth-clerk@0.10.6
-
 ## 0.10.5
 
 ### Patch Changes

packages/jazz-react-native-auth-clerk/package.json

@@ -1,6 +1,6 @@
 {
   "name": "jazz-react-native-auth-clerk",
-  "version": "0.10.6",
+  "version": "0.10.5",
   "type": "module",
   "main": "dist/index.js",
   "types": "src/index.tsx",

packages/jazz-react-native-media-images/CHANGELOG.md

@@ -1,12 +1,5 @@
 # jazz-browser-media-images
 
-## 0.10.6
-
-### Patch Changes
-
-- Updated dependencies [ada802b]
-  - jazz-tools@0.10.6
-
 ## 0.10.5
 
 ### Patch Changes

packages/jazz-react-native-media-images/package.json

@@ -1,6 +1,6 @@
 {
   "name": "jazz-react-native-media-images",
-  "version": "0.10.6",
+  "version": "0.10.5",
   "type": "module",
   "main": "dist/index.js",
   "types": "src/index.ts",

packages/jazz-react-native/CHANGELOG.md

@@ -1,18 +1,5 @@
 # jazz-browser
 
-## 0.10.6
-
-### Patch Changes
-
-- Updated dependencies [1d71ca1]
-- Updated dependencies [5c76e37]
-- Updated dependencies [ada802b]
-  - jazz-react-core@0.10.6
-  - cojson@0.10.6
-  - jazz-tools@0.10.6
-  - cojson-storage-rn-sqlite@0.8.64
-  - cojson-transport-ws@0.10.6
-
 ## 0.10.5
 
 ### Patch Changes

packages/jazz-react-native/package.json

@@ -1,6 +1,6 @@
 {
   "name": "jazz-react-native",
-  "version": "0.10.6",
+  "version": "0.10.5",
   "type": "module",
   "main": "./dist/index.js",
   "module": "./dist/index.js",

packages/jazz-react/CHANGELOG.md

@@ -1,18 +1,5 @@
 # jazz-react
 
-## 0.10.6
-
-### Patch Changes
-
-- 1d71ca1: Add React 19 to the peer dependencies
-- Updated dependencies [1d71ca1]
-- Updated dependencies [5c76e37]
-- Updated dependencies [ada802b]
-  - jazz-react-core@0.10.6
-  - cojson@0.10.6
-  - jazz-tools@0.10.6
-  - jazz-browser@0.10.6
-
 ## 0.10.5
 
 ### Patch Changes

packages/jazz-react/package.json

@@ -1,6 +1,6 @@
 {
   "name": "jazz-react",
-  "version": "0.10.6",
+  "version": "0.10.5",
   "type": "module",
   "main": "dist/index.js",
   "types": "src/index.ts",
@@ -17,10 +17,10 @@
   },
   "dependencies": {
     "@scure/bip39": "^1.3.0",
-    "cojson": "workspace:0.10.6",
-    "jazz-browser": "workspace:0.10.6",
+    "cojson": "workspace:0.10.4",
+    "jazz-browser": "workspace:0.10.5",
     "jazz-react-core": "workspace:*",
-    "jazz-tools": "workspace:0.10.6"
+    "jazz-tools": "workspace:0.10.5"
   },
   "devDependencies": {
     "@testing-library/dom": "^10.4.0",

packages/jazz-run/CHANGELOG.md

@@ -1,16 +1,5 @@
 # jazz-run
 
-## 0.10.6
-
-### Patch Changes
-
-- Updated dependencies [5c76e37]
-- Updated dependencies [ada802b]
-  - cojson@0.10.6
-  - jazz-tools@0.10.6
-  - cojson-storage-sqlite@0.10.6
-  - cojson-transport-ws@0.10.6
-
 ## 0.10.5
 
 ### Patch Changes

packages/jazz-run/package.json

@@ -3,7 +3,7 @@
   "bin": "./dist/index.js",
   "type": "module",
   "license": "MIT",
-  "version": "0.10.6",
+  "version": "0.10.5",
   "exports": {
     "./startSyncServer": {
       "import": "./dist/startSyncServer.js",
@@ -28,11 +28,11 @@
     "@effect/printer-ansi": "^0.34.5",
     "@effect/schema": "^0.71.1",
     "@effect/typeclass": "^0.25.5",
-    "cojson": "workspace:0.10.6",
-    "cojson-storage-sqlite": "workspace:0.10.6",
-    "cojson-transport-ws": "workspace:0.10.6",
+    "cojson": "workspace:0.10.4",
+    "cojson-storage-sqlite": "workspace:0.10.4",
+    "cojson-transport-ws": "workspace:0.10.4",
     "effect": "^3.6.5",
-    "jazz-tools": "workspace:0.10.6",
+    "jazz-tools": "workspace:0.10.5",
     "ws": "^8.14.2"
   },
   "devDependencies": {

packages/jazz-svelte/CHANGELOG.md

@@ -1,15 +1,5 @@
 # jazz-svelte
 
-## 0.10.6
-
-### Patch Changes
-
-- Updated dependencies [5c76e37]
-- Updated dependencies [ada802b]
-  - cojson@0.10.6
-  - jazz-tools@0.10.6
-  - jazz-browser@0.10.6
-
 ## 0.10.5
 
 ### Patch Changes

packages/jazz-svelte/package.json

@@ -1,6 +1,6 @@
 {
   "name": "jazz-svelte",
-  "version": "0.10.6",
+  "version": "0.10.5",
   "scripts": {
     "dev": "vite dev",
     "build": "vite build && npm run package",

packages/jazz-tools/CHANGELOG.md

@@ -1,13 +1,5 @@
 # jazz-tools
 
-## 0.10.6
-
-### Patch Changes
-
-- ada802b: Fix Clerk credentials migration
-- Updated dependencies [5c76e37]
-  - cojson@0.10.6
-
 ## 0.10.5
 
 ### Patch Changes

packages/jazz-tools/package.json

@@ -17,7 +17,7 @@
   },
   "type": "module",
   "license": "MIT",
-  "version": "0.10.6",
+  "version": "0.10.5",
   "dependencies": {
     "@scure/bip39": "^1.3.0",
     "cojson": "workspace:*"