fix: correctly set the globalMe before the migration when calling createJazzTestAccount

Merge pull request #1241 from garden-co/guido/test
feat: API to setup a test sync in the test environment
2025-01-22 19:19:07 +01:00 · 2025-01-22 18:28:38 +01:00 · 2025-01-22 18:22:16 +01:00 · 2025-01-22 18:22:15 +01:00 · 2025-01-22 18:21:48 +01:00 · 2025-01-22 12:51:45 +01:00
121 changed files with 1044 additions and 337 deletions
--- a/.changeset/flat-files-pump.md
+++ b/.changeset/flat-files-pump.md
@@ -0,0 +1,5 @@
+---
+"jazz-tools": patch
+---
+
+Testing: correctly set the globalMe before the migration when calling createJazzTestAccount
--- a/.changeset/sweet-cooks-happen.md
+++ b/.changeset/sweet-cooks-happen.md
@@ -0,0 +1,5 @@
+---
+"jazz-tools": patch
+---
+
+Add API to setup a test sync in the test environment
--- a/examples/chat-rn-clerk/CHANGELOG.md
+++ b/examples/chat-rn-clerk/CHANGELOG.md
@@ -1,5 +1,14 @@
 # chat-rn-clerk

+## 1.0.54
+
+### Patch Changes
+
+- jazz-react-native@0.9.13
+- jazz-react-native-auth-clerk@0.9.13
+- jazz-tools@0.9.13
+- jazz-react-native-media-images@0.9.13
+
 ## 1.0.53

 ### Patch Changes
--- a/examples/chat-rn-clerk/package.json
+++ b/examples/chat-rn-clerk/package.json
@@ -1,7 +1,7 @@
 {
  "name": "chat-rn-clerk",
  "main": "index.js",
-  "version": "1.0.53",
+  "version": "1.0.54",
  "scripts": {
    "build": "expo export -p ios",
    "start": "expo start",
--- a/examples/chat-rn-clerk/src/auth-context.tsx
+++ b/examples/chat-rn-clerk/src/auth-context.tsx
@@ -1,13 +1,7 @@
 import { useClerk, useUser } from "@clerk/clerk-expo";
 import { JazzProvider, setupKvStore } from "jazz-react-native";
 import { useJazzClerkAuth } from "jazz-react-native-auth-clerk";
-import React, {
-  createContext,
-  PropsWithChildren,
-  useContext,
-  useEffect,
-  useState,
-} from "react";
+import React, { createContext, PropsWithChildren, useContext } from "react";
 import { Text, View } from "react-native";
 const AuthContext = createContext<{
  isAuthenticated: boolean;
@@ -27,15 +21,7 @@ export function JazzAndAuth({ children }: PropsWithChildren) {
  const { isSignedIn, isLoaded: isClerkLoaded } = useUser();
  const clerk = useClerk();
  const [auth, state] = useJazzClerkAuth(clerk, kvStore);
-  const [isAuthenticated, setIsAuthenticated] = useState(false);
-
-  useEffect(() => {
-    if (isSignedIn && isClerkLoaded && auth) {
-      setIsAuthenticated(true);
-    } else {
-      setIsAuthenticated(false);
-    }
-  }, [isSignedIn, isClerkLoaded, auth]);
+  const isAuthenticated = Boolean(isSignedIn && isClerkLoaded && auth);

  return (
    <AuthContext.Provider
--- a/examples/chat-rn/CHANGELOG.md
+++ b/examples/chat-rn/CHANGELOG.md
@@ -1,5 +1,12 @@
 # chat-rn

+## 1.0.51
+
+### Patch Changes
+
+- jazz-react-native@0.9.13
+- jazz-tools@0.9.13
+
 ## 1.0.50

 ### Patch Changes
--- a/examples/chat-rn/package.json
+++ b/examples/chat-rn/package.json
@@ -1,6 +1,6 @@
 {
  "name": "chat-rn",
-  "version": "1.0.50",
+  "version": "1.0.51",
  "main": "index.js",
  "scripts": {
    "build": "expo export -p ios",
--- a/examples/chat-vue/CHANGELOG.md
+++ b/examples/chat-vue/CHANGELOG.md
@@ -1,5 +1,13 @@
 # chat-vue

+## 0.0.38
+
+### Patch Changes
+
+- jazz-browser@0.9.13
+- jazz-tools@0.9.13
+- jazz-vue@0.9.13
+
 ## 0.0.37

 ### Patch Changes
--- a/examples/chat-vue/package.json
+++ b/examples/chat-vue/package.json
@@ -1,6 +1,6 @@
 {
  "name": "chat-vue",
-  "version": "0.0.37",
+  "version": "0.0.38",
  "private": true,
  "type": "module",
  "scripts": {
--- a/examples/chat/CHANGELOG.md
+++ b/examples/chat/CHANGELOG.md
@@ -1,5 +1,13 @@
 # jazz-example-chat

+## 0.0.134
+
+### Patch Changes
+
+- jazz-react@0.9.13
+- jazz-tools@0.9.13
+- jazz-browser-media-images@0.9.13
+
 ## 0.0.133

 ### Patch Changes
--- a/examples/chat/package.json
+++ b/examples/chat/package.json
@@ -1,7 +1,7 @@
 {
  "name": "jazz-example-chat",
  "private": true,
-  "version": "0.0.133",
+  "version": "0.0.134",
  "type": "module",
  "scripts": {
    "dev": "vite",
--- a/examples/clerk/CHANGELOG.md
+++ b/examples/clerk/CHANGELOG.md
@@ -1,5 +1,13 @@
 # minimal-auth-clerk

+## 0.0.33
+
+### Patch Changes
+
+- jazz-react@0.9.13
+- jazz-react-auth-clerk@0.9.13
+- jazz-tools@0.9.13
+
 ## 0.0.32

 ### Patch Changes
--- a/examples/clerk/package.json
+++ b/examples/clerk/package.json
@@ -1,7 +1,7 @@
 {
  "name": "clerk",
  "private": true,
-  "version": "0.0.32",
+  "version": "0.0.33",
  "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.9.12",
+    "jazz-react-auth-clerk": "workspace:0.9.13",
    "jazz-tools": "workspace:*",
    "react": "^18.3.1",
    "react-dom": "^18.3.1"
--- a/examples/file-share-svelte/CHANGELOG.md
+++ b/examples/file-share-svelte/CHANGELOG.md
@@ -1,5 +1,12 @@
 # file-share-svelte

+## 0.0.18
+
+### Patch Changes
+
+- jazz-svelte@0.9.13
+- jazz-tools@0.9.13
+
 ## 0.0.17

 ### Patch Changes
--- a/examples/file-share-svelte/package.json
+++ b/examples/file-share-svelte/package.json
@@ -1,6 +1,6 @@
 {
  "name": "file-share-svelte",
-  "version": "0.0.17",
+  "version": "0.0.18",
  "private": true,
  "type": "module",
  "scripts": {
--- a/examples/form/CHANGELOG.md
+++ b/examples/form/CHANGELOG.md
@@ -1,5 +1,13 @@
 # form

+## 0.0.29
+
+### Patch Changes
+
+- jazz-react@0.9.13
+- jazz-tools@0.9.13
+- jazz-browser-media-images@0.9.13
+
 ## 0.0.28

 ### Patch Changes
--- a/examples/form/package.json
+++ b/examples/form/package.json
@@ -1,7 +1,7 @@
 {
  "name": "form",
  "private": true,
-  "version": "0.0.28",
+  "version": "0.0.29",
  "type": "module",
  "scripts": {
    "dev": "vite",
--- a/examples/image-upload/CHANGELOG.md
+++ b/examples/image-upload/CHANGELOG.md
@@ -1,5 +1,13 @@
 # image-upload

+## 0.0.31
+
+### Patch Changes
+
+- jazz-react@0.9.13
+- jazz-tools@0.9.13
+- jazz-browser-media-images@0.9.13
+
 ## 0.0.30

 ### Patch Changes
--- a/examples/image-upload/package.json
+++ b/examples/image-upload/package.json
@@ -1,7 +1,7 @@
 {
  "name": "image-upload",
  "private": true,
-  "version": "0.0.30",
+  "version": "0.0.31",
  "type": "module",
  "scripts": {
    "dev": "vite",
--- a/examples/inspector/CHANGELOG.md
+++ b/examples/inspector/CHANGELOG.md
@@ -1,5 +1,13 @@
 # jazz-example-inspector

+## 0.0.98
+
+### Patch Changes
+
+- Updated dependencies [8d29e50]
+  - cojson-transport-ws@0.9.13
+  - cojson@0.9.13
+
 ## 0.0.97

 ### Patch Changes
--- a/examples/inspector/package.json
+++ b/examples/inspector/package.json
@@ -1,7 +1,7 @@
 {
  "name": "jazz-inspector-app",
  "private": true,
-  "version": "0.0.97",
+  "version": "0.0.98",
  "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",
-    "cojson": "workspace:0.9.12",
-    "cojson-transport-ws": "workspace:0.9.12",
+    "cojson": "workspace:0.9.13",
+    "cojson-transport-ws": "workspace:0.9.13",
    "hash-slash": "workspace:0.2.1",
    "lucide-react": "^0.274.0",
    "qrcode": "^1.5.3",
--- a/examples/music-player/CHANGELOG.md
+++ b/examples/music-player/CHANGELOG.md
@@ -1,5 +1,13 @@
 # jazz-example-musicplayer

+## 0.0.54
+
+### Patch Changes
+
+- jazz-inspector@0.9.13
+- jazz-react@0.9.13
+- jazz-tools@0.9.13
+
 ## 0.0.53

 ### Patch Changes
--- a/examples/music-player/package.json
+++ b/examples/music-player/package.json
@@ -1,7 +1,7 @@
 {
  "name": "jazz-example-music-player",
  "private": true,
-  "version": "0.0.53",
+  "version": "0.0.54",
  "type": "module",
  "scripts": {
    "dev": "vite",
@@ -18,8 +18,8 @@
    "@radix-ui/react-toast": "^1.1.4",
    "class-variance-authority": "^0.7.0",
    "clsx": "^2.0.0",
-    "jazz-react": "workspace:0.9.12",
-    "jazz-tools": "workspace:0.9.12",
+    "jazz-react": "workspace:0.9.13",
+    "jazz-tools": "workspace:0.9.13",
    "jazz-inspector": "workspace:*",
    "lucide-react": "^0.274.0",
    "react": "^18.3.1",
--- a/examples/onboarding/CHANGELOG.md
+++ b/examples/onboarding/CHANGELOG.md
@@ -1,5 +1,13 @@
 # jazz-example-onboarding

+## 0.0.35
+
+### Patch Changes
+
+- jazz-react@0.9.13
+- jazz-tools@0.9.13
+- jazz-browser-media-images@0.9.13
+
 ## 0.0.34

 ### Patch Changes
--- a/examples/onboarding/package.json
+++ b/examples/onboarding/package.json
@@ -1,7 +1,7 @@
 {
  "name": "jazz-example-onboarding",
  "private": true,
-  "version": "0.0.34",
+  "version": "0.0.35",
  "type": "module",
  "scripts": {
    "dev": "vite",
--- a/examples/organization/CHANGELOG.md
+++ b/examples/organization/CHANGELOG.md
@@ -1,5 +1,12 @@
 # organization

+## 0.0.27
+
+### Patch Changes
+
+- jazz-react@0.9.13
+- jazz-tools@0.9.13
+
 ## 0.0.26

 ### Patch Changes
--- a/examples/organization/package.json
+++ b/examples/organization/package.json
@@ -1,7 +1,7 @@
 {
  "name": "organization",
  "private": true,
-  "version": "0.0.26",
+  "version": "0.0.27",
  "type": "module",
  "scripts": {
    "dev": "vite",
--- a/examples/passkey-svelte/CHANGELOG.md
+++ b/examples/passkey-svelte/CHANGELOG.md
@@ -1,5 +1,11 @@
 # passkey-svelte

+## 0.0.22
+
+### Patch Changes
+
+- jazz-svelte@0.9.13
+
 ## 0.0.21

 ### Patch Changes
--- a/examples/passkey-svelte/package.json
+++ b/examples/passkey-svelte/package.json
@@ -1,6 +1,6 @@
 {
  "name": "passkey-svelte",
-  "version": "0.0.21",
+  "version": "0.0.22",
  "type": "module",
  "private": true,
  "scripts": {
--- a/examples/passkey/CHANGELOG.md
+++ b/examples/passkey/CHANGELOG.md
@@ -1,5 +1,12 @@
 # minimal-auth-passkey

+## 0.0.32
+
+### Patch Changes
+
+- jazz-react@0.9.13
+- jazz-tools@0.9.13
+
 ## 0.0.31

 ### Patch Changes
--- a/examples/passkey/package.json
+++ b/examples/passkey/package.json
@@ -1,7 +1,7 @@
 {
  "name": "passkey",
  "private": true,
-  "version": "0.0.31",
+  "version": "0.0.32",
  "type": "module",
  "scripts": {
    "dev": "vite",
--- a/examples/password-manager/CHANGELOG.md
+++ b/examples/password-manager/CHANGELOG.md
@@ -1,5 +1,12 @@
 # jazz-password-manager

+## 0.0.53
+
+### Patch Changes
+
+- jazz-react@0.9.13
+- jazz-tools@0.9.13
+
 ## 0.0.52

 ### Patch Changes
--- a/examples/password-manager/package.json
+++ b/examples/password-manager/package.json
@@ -1,7 +1,7 @@
 {
  "name": "jazz-password-manager",
  "private": true,
-  "version": "0.0.52",
+  "version": "0.0.53",
  "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.9.12",
-    "jazz-tools": "workspace:0.9.12",
+    "jazz-react": "workspace:0.9.13",
+    "jazz-tools": "workspace:0.9.13",
    "react": "^18.3.1",
    "react-dom": "^18.3.1",
    "react-hook-form": "^7.41.5",
--- a/examples/pets/CHANGELOG.md
+++ b/examples/pets/CHANGELOG.md
@@ -1,5 +1,13 @@
 # jazz-example-pets

+## 0.0.151
+
+### Patch Changes
+
+- jazz-react@0.9.13
+- jazz-tools@0.9.13
+- jazz-browser-media-images@0.9.13
+
 ## 0.0.150

 ### Patch Changes
--- a/examples/pets/package.json
+++ b/examples/pets/package.json
@@ -1,7 +1,7 @@
 {
  "name": "jazz-example-pets",
  "private": true,
-  "version": "0.0.150",
+  "version": "0.0.151",
  "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.9.12",
-    "jazz-react": "workspace:0.9.12",
-    "jazz-tools": "workspace:0.9.12",
+    "jazz-browser-media-images": "workspace:0.9.13",
+    "jazz-react": "workspace:0.9.13",
+    "jazz-tools": "workspace:0.9.13",
    "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.9.12",
+    "jazz-run": "workspace:0.9.13",
    "postcss": "^8.4.27",
    "tailwindcss": "^3.4.15",
    "typescript": "~5.6.2",
--- a/examples/reactions/CHANGELOG.md
+++ b/examples/reactions/CHANGELOG.md
@@ -1,5 +1,13 @@
 # reactions

+## 0.0.31
+
+### Patch Changes
+
+- jazz-react@0.9.13
+- jazz-tools@0.9.13
+- jazz-browser-media-images@0.9.13
+
 ## 0.0.30

 ### Patch Changes
--- a/examples/reactions/package.json
+++ b/examples/reactions/package.json
@@ -1,7 +1,7 @@
 {
  "name": "reactions",
  "private": true,
-  "version": "0.0.30",
+  "version": "0.0.31",
  "type": "module",
  "scripts": {
    "dev": "vite",
--- a/examples/todo-vue/CHANGELOG.md
+++ b/examples/todo-vue/CHANGELOG.md
@@ -1,5 +1,13 @@
 # todo-vue

+## 0.0.36
+
+### Patch Changes
+
+- jazz-browser@0.9.13
+- jazz-tools@0.9.13
+- jazz-vue@0.9.13
+
 ## 0.0.35

 ### Patch Changes
--- a/examples/todo-vue/package.json
+++ b/examples/todo-vue/package.json
@@ -1,6 +1,6 @@
 {
  "name": "todo-vue",
-  "version": "0.0.35",
+  "version": "0.0.36",
  "private": true,
  "type": "module",
  "scripts": {
--- a/examples/todo/CHANGELOG.md
+++ b/examples/todo/CHANGELOG.md
@@ -1,5 +1,12 @@
 # jazz-example-todo

+## 0.0.150
+
+### Patch Changes
+
+- jazz-react@0.9.13
+- jazz-tools@0.9.13
+
 ## 0.0.149

 ### Patch Changes
--- a/examples/todo/package.json
+++ b/examples/todo/package.json
@@ -1,7 +1,7 @@
 {
  "name": "jazz-example-todo",
  "private": true,
-  "version": "0.0.149",
+  "version": "0.0.150",
  "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.9.12",
-    "jazz-tools": "workspace:0.9.12",
+    "jazz-react": "workspace:0.9.13",
+    "jazz-tools": "workspace:0.9.13",
    "lucide-react": "^0.274.0",
    "qrcode": "^1.5.3",
    "react": "^18.3.1",
--- a/examples/version-history/CHANGELOG.md
+++ b/examples/version-history/CHANGELOG.md
@@ -1,5 +1,12 @@
 # version-history

+## 0.0.28
+
+### Patch Changes
+
+- jazz-react@0.9.13
+- jazz-tools@0.9.13
+
 ## 0.0.27

 ### Patch Changes
--- a/examples/version-history/package.json
+++ b/examples/version-history/package.json
@@ -1,7 +1,7 @@
 {
  "name": "version-history",
  "private": true,
-  "version": "0.0.27",
+  "version": "0.0.28",
  "type": "module",
  "scripts": {
    "dev": "vite",
--- a/packages/cojson-storage-indexeddb/CHANGELOG.md
+++ b/packages/cojson-storage-indexeddb/CHANGELOG.md
@@ -1,5 +1,13 @@
 # cojson-storage-indexeddb

+## 0.9.13
+
+### Patch Changes
+
+- Updated dependencies [8d29e50]
+  - cojson-storage@0.9.13
+  - cojson@0.9.13
+
 ## 0.9.12

 ### Patch Changes
--- a/packages/cojson-storage-indexeddb/package.json
+++ b/packages/cojson-storage-indexeddb/package.json
@@ -1,6 +1,6 @@
 {
  "name": "cojson-storage-indexeddb",
-  "version": "0.9.12",
+  "version": "0.9.13",
  "main": "dist/index.js",
  "type": "module",
  "types": "src/index.ts",
--- a/packages/cojson-storage-rn-sqlite/CHANGELOG.md
+++ b/packages/cojson-storage-rn-sqlite/CHANGELOG.md
@@ -1,5 +1,13 @@
 # cojson-storage-sqlite

+## 0.8.56
+
+### Patch Changes
+
+- Updated dependencies [8d29e50]
+  - cojson-storage@0.9.13
+  - cojson@0.9.13
+
 ## 0.8.55

 ### Patch Changes
--- a/packages/cojson-storage-rn-sqlite/package.json
+++ b/packages/cojson-storage-rn-sqlite/package.json
@@ -1,7 +1,7 @@
 {
  "name": "cojson-storage-rn-sqlite",
  "type": "module",
-  "version": "0.8.55",
+  "version": "0.8.56",
  "main": "dist/index.js",
  "types": "src/index.ts",
  "license": "MIT",
--- a/packages/cojson-storage-sqlite/CHANGELOG.md
+++ b/packages/cojson-storage-sqlite/CHANGELOG.md
@@ -1,5 +1,14 @@
 # cojson-storage-sqlite

+## 0.9.13
+
+### Patch Changes
+
+- 8d29e50: Restore the logger wrapper and adapt the API to pino
+- Updated dependencies [8d29e50]
+  - cojson-storage@0.9.13
+  - cojson@0.9.13
+
 ## 0.9.12

 ### Patch Changes
--- a/packages/cojson-storage-sqlite/package.json
+++ b/packages/cojson-storage-sqlite/package.json
@@ -1,13 +1,13 @@
 {
  "name": "cojson-storage-sqlite",
  "type": "module",
-  "version": "0.9.12",
+  "version": "0.9.13",
  "main": "dist/index.js",
  "types": "src/index.ts",
  "license": "MIT",
  "dependencies": {
    "better-sqlite3": "^11.7.0",
-    "cojson": "workspace:0.9.12",
+    "cojson": "workspace:0.9.13",
    "cojson-storage": "workspace:*"
  },
  "devDependencies": {
--- a/packages/cojson-storage-sqlite/src/sqliteClient.ts
+++ b/packages/cojson-storage-sqlite/src/sqliteClient.ts
@@ -1,5 +1,10 @@
 import { Database as DatabaseT } from "better-sqlite3";
-import { CojsonInternalTypes, OutgoingSyncQueue, SessionID } from "cojson";
+import {
+  CojsonInternalTypes,
+  OutgoingSyncQueue,
+  SessionID,
+  logger,
+} from "cojson";
 import RawCoID = CojsonInternalTypes.RawCoID;
 import Signature = CojsonInternalTypes.Signature;
 import Transaction = CojsonInternalTypes.Transaction;
@@ -23,6 +28,10 @@ export type RawTransactionRow = {
  tx: string;
 };

+export function getErrorMessage(error: unknown) {
+  return error instanceof Error ? error.message : "Unknown error";
+}
+
 export class SQLiteClient implements DBClientInterface {
  private readonly db: DatabaseT;
  private readonly toLocalNode: OutgoingSyncQueue;
@@ -48,7 +57,10 @@ export class SQLiteClient implements DBClientInterface {
        header: parsedHeader,
      };
    } catch (e) {
-      console.warn(coValueId, "Invalid JSON in header", e, coValueRow?.header);
+      const headerValue = coValueRow?.header ?? "";
+      logger.warn("Invalid JSON in header: " + headerValue, {
+        id: coValueId,
+      });
      return;
    }
  }
@@ -75,7 +87,7 @@ export class SQLiteClient implements DBClientInterface {
        tx: JSON.parse(transactionRow.tx) as Transaction,
      }));
    } catch (e) {
-      console.warn("Invalid JSON in transaction", e);
+      logger.warn("Invalid JSON in transaction");
      return [];
    }
  }
--- a/packages/cojson-storage-sqlite/src/sqliteNode.ts
+++ b/packages/cojson-storage-sqlite/src/sqliteNode.ts
@@ -4,6 +4,7 @@ import {
  OutgoingSyncQueue,
  Peer,
  cojsonInternals,
+  logger,
 } from "cojson";
 import { SyncManager, TransactionRow } from "cojson-storage";
 import { SQLiteClient } from "./sqliteClient.js";
@@ -40,24 +41,21 @@ export class SQLiteNode {
            await new Promise((resolve) => setTimeout(resolve, 0));
          }
        } 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 },
-            ),
+          logger.error(
+            `Error reading from localNode, handling msg\n\n${JSON.stringify(
+              msg,
+              (k, v) =>
+                k === "changes" || k === "encryptedChanges"
+                  ? v.slice(0, 20) + "..."
+                  : v,
+            )}`,
          );
        }
      }
    };

    processMessages().catch((e) =>
-      console.error("Error in processMessages in sqlite", e),
+      logger.error("Error in processMessages in sqlite", e),
    );
  }

@@ -97,10 +95,7 @@ export class SQLiteNode {
      db.pragma("user_version") as [{ user_version: number }]
    )[0].user_version as number;

-    console.log("DB version", oldVersion);
-
    if (oldVersion === 0) {
-      console.log("Migration 0 -> 1: Basic schema");
      db.prepare(
        `CREATE TABLE IF NOT EXISTS transactions (
                    ses INTEGER,
@@ -138,15 +133,10 @@ export class SQLiteNode {
      ).run();

      db.pragma("user_version = 1");
-      console.log("Migration 0 -> 1: Basic schema - done");
    }

    if (oldVersion <= 1) {
      // fix embarrassing off-by-one error for transaction indices
-      console.log(
-        "Migration 1 -> 2: Fix off-by-one error for transaction indices",
-      );
-
      const txs = db
        .prepare(`SELECT * FROM transactions`)
        .all() as TransactionRow[];
@@ -163,14 +153,9 @@ export class SQLiteNode {
      }

      db.pragma("user_version = 2");
-      console.log(
-        "Migration 1 -> 2: Fix off-by-one error for transaction indices - done",
-      );
    }

    if (oldVersion <= 2) {
-      console.log("Migration 2 -> 3: Add signatureAfter");
-
      db.prepare(
        `CREATE TABLE IF NOT EXISTS signatureAfter (
                    ses INTEGER,
@@ -185,7 +170,6 @@ export class SQLiteNode {
      ).run();

      db.pragma("user_version = 3");
-      console.log("Migration 2 -> 3: Add signatureAfter - done!!");
    }

    return new SQLiteNode(db, fromLocalNode, toLocalNode);
--- a/packages/cojson-storage/CHANGELOG.md
+++ b/packages/cojson-storage/CHANGELOG.md
@@ -1,5 +1,13 @@
 # cojson-storage

+## 0.9.13
+
+### Patch Changes
+
+- 8d29e50: Restore the logger wrapper and adapt the API to pino
+- Updated dependencies [8d29e50]
+  - cojson@0.9.13
+
 ## 0.9.12

 ### Patch Changes
--- a/packages/cojson-storage/package.json
+++ b/packages/cojson-storage/package.json
@@ -1,6 +1,6 @@
 {
  "name": "cojson-storage",
-  "version": "0.9.12",
+  "version": "0.9.13",
  "main": "dist/index.js",
  "type": "module",
  "types": "src/index.ts",
--- a/packages/cojson-storage/src/syncManager.ts
+++ b/packages/cojson-storage/src/syncManager.ts
@@ -6,6 +6,7 @@ import {
  SyncMessage,
  cojsonInternals,
  emptyKnownState,
+  logger,
 } from "cojson";
 import { collectNewTxs, getDependedOnCoValues } from "./syncUtils.js";
 import { DBClientInterface, StoredSessionRow } from "./types.js";
@@ -314,7 +315,7 @@ export class SyncManager {
    return this.toLocalNode
      .push(msg)
      .catch((e) =>
-        console.error(`Error sending ${msg.action} state, id ${msg.id}`, e),
+        logger.error(`Error sending ${msg.action} state, id ${msg.id}`, e),
      );
  }
 }
--- a/packages/cojson-transport-ws/CHANGELOG.md
+++ b/packages/cojson-transport-ws/CHANGELOG.md
@@ -1,5 +1,13 @@
 # cojson-transport-nodejs-ws

+## 0.9.13
+
+### Patch Changes
+
+- 8d29e50: Restore the logger wrapper and adapt the API to pino
+- Updated dependencies [8d29e50]
+  - cojson@0.9.13
+
 ## 0.9.12

 ### Patch Changes
--- a/packages/cojson-transport-ws/package.json
+++ b/packages/cojson-transport-ws/package.json
@@ -1,12 +1,12 @@
 {
  "name": "cojson-transport-ws",
  "type": "module",
-  "version": "0.9.12",
+  "version": "0.9.13",
  "main": "dist/index.js",
  "types": "src/index.ts",
  "license": "MIT",
  "dependencies": {
-    "cojson": "workspace:0.9.12",
+    "cojson": "workspace:0.9.13",
    "typescript": "~5.6.2"
  },
  "scripts": {
--- a/packages/cojson-transport-ws/src/index.ts
+++ b/packages/cojson-transport-ws/src/index.ts
@@ -4,9 +4,10 @@ import {
  PingTimeoutError,
  SyncMessage,
  cojsonInternals,
+  logger,
 } from "cojson";
 import { BatchedOutgoingMessages } from "./BatchedOutgoingMessages.js";
-import { deserializeMessages } from "./serialization.js";
+import { deserializeMessages, getErrorMessage } from "./serialization.js";
 import { AnyWebSocket } from "./types.js";

 export const BUFFER_LIMIT = 100_000;
@@ -136,7 +137,7 @@ export function createWebSocketPeer({
  function handleClose() {
    incoming
      .push("Disconnected")
-      .catch((e) => console.error("Error while pushing disconnect msg", e));
+      .catch((e) => logger.error("Error while pushing disconnect msg", e));
    emitClosedEvent();
  }

@@ -145,7 +146,7 @@ export function createWebSocketPeer({
  const pingTimeout = createPingTimeoutListener(expectPings, () => {
    incoming
      .push("PingTimeout")
-      .catch((e) => console.error("Error while pushing ping timeout", e));
+      .catch((e) => logger.error("Error while pushing ping timeout", e));
    emitClosedEvent();
  });

@@ -156,17 +157,14 @@ export function createWebSocketPeer({

  function handleIncomingMsg(event: { data: unknown }) {
    if (event.data === "") {
-      console.log("client", id, "sent empty message");
      return;
    }

    const result = deserializeMessages(event.data);

    if (!result.ok) {
-      console.error(
-        "Error while deserializing messages",
-        event.data,
-        result.error,
+      logger.warn(
+        "Error while deserializing messages: " + getErrorMessage(result.error),
      );
      return;
    }
@@ -184,7 +182,7 @@ export function createWebSocketPeer({
      if (msg && "action" in msg) {
        incoming
          .push(msg)
-          .catch((e) => console.error("Error while pushing incoming msg", e));
+          .catch((e) => logger.error("Error while pushing incoming msg", e));
      }
    }
  }
@@ -197,7 +195,6 @@ export function createWebSocketPeer({
    outgoing: {
      push: outgoingMessages.sendMessage,
      close() {
-        console.log("Trying to close", id, websocket.readyState);
        outgoingMessages.close();

        websocket.removeEventListener("message", handleIncomingMsg);
--- a/packages/cojson-transport-ws/src/serialization.ts
+++ b/packages/cojson-transport-ws/src/serialization.ts
@@ -1,6 +1,10 @@
-import { SyncMessage } from "cojson";
+import { SyncMessage, logger } from "cojson";
 import { PingMsg } from "./types.js";

+export function getErrorMessage(error: unknown) {
+  return error instanceof Error ? error.message : "Unknown error";
+}
+
 export function addMessageToBacklog(backlog: string, message: SyncMessage) {
  if (!backlog) {
    return JSON.stringify(message);
@@ -24,7 +28,7 @@ export function deserializeMessages(messages: unknown) {
        | PingMsg[],
    } as const;
  } catch (e) {
-    console.error("Error while deserializing messages", e);
+    logger.error("Error while deserializing messages: " + getErrorMessage(e));
    return {
      ok: false,
      error: e,
--- a/packages/cojson/CHANGELOG.md
+++ b/packages/cojson/CHANGELOG.md
@@ -1,5 +1,11 @@
 # cojson

+## 0.9.13
+
+### Patch Changes
+
+- 8d29e50: Restore the logger wrapper and adapt the API to pino
+
 ## 0.9.12

 ### Patch Changes
--- a/packages/cojson/package.json
+++ b/packages/cojson/package.json
@@ -24,7 +24,7 @@
  },
  "type": "module",
  "license": "MIT",
-  "version": "0.9.12",
+  "version": "0.9.13",
  "devDependencies": {
    "@opentelemetry/sdk-metrics": "^1.29.0",
    "@types/jest": "^29.5.3",
--- a/packages/cojson/src/PeerState.ts
+++ b/packages/cojson/src/PeerState.ts
@@ -5,6 +5,7 @@ import {
 } from "./PriorityBasedMessageQueue.js";
 import { TryAddTransactionsError } from "./coValueCore.js";
 import { RawCoID } from "./ids.js";
+import { logger } from "./logger.js";
 import { CO_VALUE_PRIORITY } from "./priority.js";
 import { Peer, SyncMessage } from "./sync.js";

@@ -137,7 +138,10 @@ export class PeerState {
  }

  gracefulShutdown() {
-    console.debug("Gracefully closing", this.id);
+    logger.debug("Gracefully closing", {
+      peerId: this.id,
+      peerRole: this.role,
+    });
    this.closeQueue();
    this.peer.outgoing.close();
    this.closed = true;
--- a/packages/cojson/src/base64url.ts
+++ b/packages/cojson/src/base64url.ts
@@ -43,12 +43,7 @@ export function bytesToBase64url(bytes: Uint8Array) {
  let base64 = decoder.decode(new Uint8Array(encoded.buffer, 0, n));
  if (k === 1) base64 += "==";
  if (k === 2) base64 += "=";
-  // const after = performance.now();
-  // console.log(
-  //     "bytesToBase64url bandwidth in MB/s for length",
-  //     (1000 * bytes.length / (after - before)) / (1024 * 1024),
-  //     bytes.length
-  // );
+
  return base64;
 }

--- a/packages/cojson/src/coValueCore.ts
+++ b/packages/cojson/src/coValueCore.ts
@@ -24,6 +24,7 @@ import {
 import { Stringified, parseJSON, stableStringify } from "./jsonStringify.js";
 import { JsonObject, JsonValue } from "./jsonValue.js";
 import { LocalNode, ResolveAccountAgentError } from "./localNode.js";
+import { logger } from "./logger.js";
 import {
  PermissionsDef as RulesetDef,
  determineValidTransactions,
@@ -209,16 +210,10 @@ export class CoValueCore {
      .andThen((agent) => {
        const signerID = this.crypto.getAgentSignerID(agent);

-        // const beforeHash = performance.now();
        const { expectedNewHash, newStreamingHash } = this.expectedNewHashAfter(
          sessionID,
          newTransactions,
        );
-        // const afterHash = performance.now();
-        // console.log(
-        //     "Hashing took",
-        //     afterHash - beforeHash
-        // );

        if (givenExpectedNewHash && givenExpectedNewHash !== expectedNewHash) {
          return err({
@@ -391,7 +386,6 @@ export class CoValueCore {
      streamingHash.update(transaction);
      const after = performance.now();
      if (after - before > 1) {
-        // console.log("Hashing blocked for", after - before);
        await new Promise((resolve) => setTimeout(resolve, 0));
        before = performance.now();
      }
@@ -540,7 +534,7 @@ export class CoValueCore {
      }

      if (!decryptedChanges) {
-        console.error("Failed to decrypt transaction despite having key");
+        logger.error("Failed to decrypt transaction despite having key");
        continue;
      }

@@ -685,7 +679,7 @@ export class CoValueCore {
          if (secret) {
            return secret as KeySecret;
          } else {
-            console.error(
+            logger.warn(
              `Encrypting ${encryptingKeyID} key didn't decrypt ${keyID}`,
            );
          }
@@ -725,7 +719,7 @@ export class CoValueCore {
              if (secret) {
                return secret as KeySecret;
              } else {
-                console.error(
+                logger.warn(
                  `Encrypting parent ${parentKey.id} key didn't decrypt ${keyID}`,
                );
              }
--- a/packages/cojson/src/coValueState.ts
+++ b/packages/cojson/src/coValueState.ts
@@ -1,6 +1,7 @@
 import { PeerState } from "./PeerState.js";
 import { CoValueCore } from "./coValueCore.js";
 import { RawCoID } from "./ids.js";
+import { logger } from "./logger.js";
 import { PeerID } from "./sync.js";

 export const CO_VALUE_LOADING_MAX_RETRIES = 5;
@@ -282,7 +283,7 @@ async function loadCoValueFromPeers(
          ...coValueEntry.state.coValue.knownState(),
        })
        .catch((err) => {
-          console.error(`Failed to push load message to peer ${peer.id}`, err);
+          logger.warn(`Failed to push load message to peer ${peer.id}`, err);
        });
    } else {
      /**
@@ -296,14 +297,17 @@ async function loadCoValueFromPeers(
          sessions: {},
        })
        .catch((err) => {
-          console.error(`Failed to push load message to peer ${peer.id}`, err);
+          logger.warn(`Failed to push load message to peer ${peer.id}`, err);
        });
    }

    if (coValueEntry.state.type === "loading") {
      const timeout = setTimeout(() => {
        if (coValueEntry.state.type === "loading") {
-          console.error("Failed to load coValue from peer", peer.id);
+          logger.warn("Failed to load coValue from peer", {
+            peerId: peer.id,
+            peerRole: peer.role,
+          });
          coValueEntry.dispatch({
            type: "not-found-in-peer",
            peerId: peer.id,
@@ -356,7 +360,7 @@ function sleep(ms: number) {
 function getPeersWithoutErrors(peers: PeerState[], coValueId: RawCoID) {
  return peers.filter((p) => {
    if (p.erroredCoValues.has(coValueId)) {
-      console.error(
+      logger.warn(
        `Skipping load on errored coValue ${coValueId} from peer ${p.id}`,
      );
      return false;
--- a/packages/cojson/src/coValues/account.ts
+++ b/packages/cojson/src/coValues/account.ts
@@ -16,6 +16,7 @@ import {
 import { AgentID } from "../ids.js";
 import { JsonObject } from "../jsonValue.js";
 import { LocalNode } from "../localNode.js";
+import { logger } from "../logger.js";
 import type { AccountRole } from "../permissions.js";
 import { RawCoMap } from "./coMap.js";
 import { InviteSecret, RawGroup } from "./group.js";
@@ -59,7 +60,7 @@ export class RawAccount<
      );

    if (agents.length !== 1) {
-      console.warn("Account has " + agents.length + " agents", this.id);
+      logger.warn("Account has " + agents.length + " agents", { id: this.id });
    }

    this._cachedCurrentAgentID = agents[0];
--- a/packages/cojson/src/coValues/coList.ts
+++ b/packages/cojson/src/coValues/coList.ts
@@ -133,10 +133,6 @@ export class RawCoListView<
                  change.before.txIndex
                ]?.[change.before.changeIdx];
              if (!beforeEntry) {
-                // console.error(
-                //     "Insertion before missing op " +
-                //         change.before
-                // );
                continue;
              }
              beforeEntry.predecessors.splice(0, 0, {
@@ -156,9 +152,6 @@ export class RawCoListView<
                  change.after.txIndex
                ]?.[change.after.changeIdx];
              if (!afterEntry) {
-                // console.error(
-                //     "Insertion after missing op " + change.after
-                // );
                continue;
              }
              afterEntry.successors.push({
--- a/packages/cojson/src/coValues/coStream.ts
+++ b/packages/cojson/src/coValues/coStream.ts
@@ -3,6 +3,7 @@ import { CoID, RawCoValue } from "../coValue.js";
 import { CoValueCore } from "../coValueCore.js";
 import { AgentID, SessionID, TransactionID } from "../ids.js";
 import { JsonObject, JsonValue } from "../jsonValue.js";
+import { logger } from "../logger.js";
 import { CoValueKnownState } from "../sync.js";
 import { accountOrAgentIDfromSessionID } from "../typeUtils/accountOrAgentIDfromSessionID.js";
 import { isAccountID } from "../typeUtils/isAccountID.js";
@@ -309,7 +310,7 @@ export class RawBinaryCoStreamView<
    const start = items[0];

    if (start?.type !== "start") {
-      console.error("Invalid binary stream start", start);
+      logger.error("Invalid binary stream start", start);
      return;
    }

@@ -328,7 +329,7 @@ export class RawBinaryCoStreamView<
      }

      if (item.type !== "chunk") {
-        console.error("Invalid binary stream chunk", item);
+        logger.error("Invalid binary stream chunk", item);
        return undefined;
      }

@@ -382,7 +383,6 @@ export class RawBinaryCoStream<
    chunk: Uint8Array,
    privacy: "private" | "trusting" = "private",
  ): void {
-    // const before = performance.now();
    this.push(
      {
        type: "chunk",
@@ -391,11 +391,6 @@ export class RawBinaryCoStream<
      privacy,
      false,
    );
-    // const after = performance.now();
-    // console.log(
-    //     "pushBinaryStreamChunk bandwidth in MB/s",
-    //     (1000 * chunk.length) / (after - before) / (1024 * 1024)
-    // );
  }

  endBinaryStream(privacy: "private" | "trusting" = "private") {
--- a/packages/cojson/src/coValues/group.ts
+++ b/packages/cojson/src/coValues/group.ts
@@ -13,6 +13,7 @@ import {
  isParentGroupReference,
 } from "../ids.js";
 import { JsonObject } from "../jsonValue.js";
+import { logger } from "../logger.js";
 import { AccountRole, Role } from "../permissions.js";
 import { expectGroup } from "../typeUtils/expectGroup.js";
 import {
@@ -153,7 +154,7 @@ export class RawGroup<
        child.state.type === "unavailable"
      ) {
        child.loadFromPeers(peers).catch(() => {
-          console.error(`Failed to load child group ${id}`);
+          logger.error(`Failed to load child group ${id}`);
        });
      }

@@ -321,7 +322,7 @@ export class RawGroup<
        const secret = this.core.getReadKey(keyID);

        if (!secret) {
-          console.error("Can't find key", keyID);
+          logger.error("Can't find key " + keyID);
          continue;
        }

--- a/packages/cojson/src/crypto/PureJSCrypto.ts
+++ b/packages/cojson/src/crypto/PureJSCrypto.ts
@@ -7,6 +7,7 @@ import { base64URLtoBytes, bytesToBase64url } from "../base64url.js";
 import { RawCoID, TransactionID } from "../ids.js";
 import { Stringified, stableStringify } from "../jsonStringify.js";
 import { JsonValue } from "../jsonValue.js";
+import { logger } from "../logger.js";
 import {
  CryptoProvider,
  Encrypted,
@@ -192,7 +193,9 @@ export class PureJSCrypto extends CryptoProvider<Blake3State> {
    try {
      return JSON.parse(textDecoder.decode(plaintext));
    } catch (e) {
-      console.error("Failed to decrypt/parse sealed message", e);
+      logger.error(
+        "Failed to decrypt/parse sealed message: " + (e as Error)?.message,
+      );
      return undefined;
    }
  }
--- a/packages/cojson/src/crypto/WasmCrypto.ts
+++ b/packages/cojson/src/crypto/WasmCrypto.ts
@@ -15,6 +15,7 @@ import { base64URLtoBytes, bytesToBase64url } from "../base64url.js";
 import { RawCoID, TransactionID } from "../ids.js";
 import { Stringified, stableStringify } from "../jsonStringify.js";
 import { JsonValue } from "../jsonValue.js";
+import { logger } from "../logger.js";
 import {
  CryptoProvider,
  Encrypted,
@@ -240,8 +241,9 @@ export class WasmCrypto extends CryptoProvider<Uint8Array> {
    try {
      return JSON.parse(textDecoder.decode(plaintext));
    } catch (e) {
-      console.error("Failed to decrypt/parse sealed message", e);
-      return undefined;
+      logger.error(
+        "Failed to decrypt/parse sealed message: " + (e as Error)?.message,
+      );
    }
  }
 }
--- a/packages/cojson/src/crypto/crypto.ts
+++ b/packages/cojson/src/crypto/crypto.ts
@@ -4,6 +4,7 @@ import { AgentID, RawCoID, TransactionID } from "../ids.js";
 import { SessionID } from "../ids.js";
 import { Stringified, parseJSON, stableStringify } from "../jsonStringify.js";
 import { JsonValue } from "../jsonValue.js";
+import { logger } from "../logger.js";

 export type SignerSecret = `signerSecret_z${string}`;
 export type SignerID = `signer_z${string}`;
@@ -159,7 +160,7 @@ export abstract class CryptoProvider<Blake3State = any> {
    try {
      return parseJSON(this.decryptRaw(encrypted, keySecret, nOnceMaterial));
    } catch (e) {
-      console.error("Decryption error", e);
+      logger.error("Decryption error: " + (e as Error)?.message);
      return undefined;
    }
  }
@@ -305,10 +306,7 @@ export class StreamingHash {

  update(value: JsonValue): Uint8Array {
    const encoded = textEncoder.encode(stableStringify(value));
-    // const before = performance.now();
    this.state = this.crypto.blake3IncrementalUpdate(this.state, encoded);
-    // const after = performance.now();
-    // console.log(`Hashing throughput in MB/s`, 1000 * (encoded.length / (after - before)) / (1024 * 1024));
    return encoded;
  }

--- a/packages/cojson/src/exports.ts
+++ b/packages/cojson/src/exports.ts
@@ -74,6 +74,7 @@ import {

 type Value = JsonValue | AnyRawCoValue;

+import { logger } from "./logger.js";
 import { getPriorityFromHeader } from "./priority.js";
 import { FileSystem } from "./storage/FileSystem.js";
 import { BlockFilename, LSMStorage, WalFilename } from "./storage/index.js";
@@ -141,6 +142,7 @@ export {
  emptyKnownState,
  RawCoPlainText,
  stringifyOpID,
+  logger,
 };

 export type {
--- a/packages/cojson/src/localNode.ts
+++ b/packages/cojson/src/localNode.ts
@@ -27,6 +27,7 @@ import {
 } from "./coValues/group.js";
 import { AgentSecret, CryptoProvider } from "./crypto/crypto.js";
 import { AgentID, RawCoID, SessionID, isAgentID } from "./ids.js";
+import { logger } from "./logger.js";
 import { Peer, PeerID, SyncManager } from "./sync.js";
 import { expectGroup } from "./typeUtils/expectGroup.js";

@@ -230,7 +231,7 @@ export class LocalNode {

      return node;
    } catch (e) {
-      console.error("Error withLoadedAccount", e);
+      logger.error("Error withLoadedAccount: " + (e as Error)?.message);
      throw e;
    }
  }
@@ -269,7 +270,9 @@ export class LocalNode {
        this.syncManager.getServerAndStoragePeers(skipLoadingFromPeer);

      await entry.loadFromPeers(peers).catch((e) => {
-        console.error("Error loading from peers", id, e);
+        logger.error("Error loading from peers: " + (e as Error)?.message, {
+          id,
+        });
      });
    }

@@ -311,8 +314,6 @@ export class LocalNode {
    let stopped = false;
    let unsubscribe!: () => void;

-    // console.log("Subscribing to " + id);
-
    this.load(id)
      .then((coValue) => {
        if (stopped) {
@@ -325,11 +326,12 @@ export class LocalNode {
        unsubscribe = coValue.subscribe(callback);
      })
      .catch((e) => {
-        console.error("Error subscribing to ", id, e);
+        logger.error(
+          "Error subscribing to " + id + ": " + (e as Error)?.message,
+        );
      });

    return () => {
-      console.log("Unsubscribing from " + id);
      stopped = true;
      unsubscribe?.();
    };
@@ -390,9 +392,7 @@ export class LocalNode {
      (existingRole === "reader" && inviteRole === "readerInvite") ||
      (existingRole && inviteRole === "writeOnlyInvite")
    ) {
-      console.debug(
-        "Not accepting invite that would replace or downgrade role",
-      );
+      logger.debug("Not accepting invite that would replace or downgrade role");
      return;
    }

--- a/packages/cojson/src/logger.ts
+++ b/packages/cojson/src/logger.ts
@@ -0,0 +1,80 @@
+import type { JsonValue } from "./jsonValue.js";
+
+export enum LogLevel {
+  DEBUG = 0,
+  INFO = 1,
+  WARN = 2,
+  ERROR = 3,
+  NONE = 4,
+}
+
+export interface LogSystem {
+  debug(message: string, attributes?: Record<string, JsonValue>): void;
+  info(message: string, attributes?: Record<string, JsonValue>): void;
+  warn(message: string, attributes?: Record<string, JsonValue>): void;
+  error(message: string, attributes?: Record<string, JsonValue>): void;
+}
+
+// Default console-based logging system
+export class ConsoleLogSystem implements LogSystem {
+  debug(message: string, attributes?: Record<string, JsonValue>) {
+    console.debug(message, attributes);
+  }
+  info(message: string, attributes?: Record<string, JsonValue>) {
+    console.info(message, attributes);
+  }
+  warn(message: string, attributes?: Record<string, JsonValue>) {
+    console.warn(message, attributes);
+  }
+  error(message: string, attributes?: Record<string, JsonValue>) {
+    console.error(message, attributes);
+  }
+}
+
+export class Logger {
+  private level: LogLevel;
+  private logSystem: LogSystem;
+
+  constructor(
+    level: LogLevel = LogLevel.INFO,
+    logSystem: LogSystem = new ConsoleLogSystem(),
+  ) {
+    this.level = level;
+    this.logSystem = logSystem;
+  }
+
+  setLevel(level: LogLevel) {
+    this.level = level;
+  }
+
+  setLogSystem(logSystem: LogSystem) {
+    this.logSystem = logSystem;
+  }
+
+  debug(message: string, attributes?: Record<string, JsonValue>) {
+    if (this.level <= LogLevel.DEBUG) {
+      this.logSystem.debug(message, attributes);
+    }
+  }
+
+  info(message: string, attributes?: Record<string, JsonValue>) {
+    if (this.level <= LogLevel.INFO) {
+      this.logSystem.info(message, attributes);
+    }
+  }
+
+  warn(message: string, attributes?: Record<string, JsonValue>) {
+    if (this.level <= LogLevel.WARN) {
+      this.logSystem.warn(message, attributes);
+    }
+  }
+
+  error(message: string, attributes?: Record<string, JsonValue>) {
+    if (this.level <= LogLevel.ERROR) {
+      this.logSystem.error(message, attributes);
+    }
+  }
+}
+
+// Create default logger instance
+export const logger = new Logger();
--- a/packages/cojson/src/permissions.ts
+++ b/packages/cojson/src/permissions.ts
@@ -14,6 +14,7 @@ import {
 } from "./ids.js";
 import { parseJSON } from "./jsonStringify.js";
 import { JsonValue } from "./jsonValue.js";
+import { logger } from "./logger.js";
 import { accountOrAgentIDfromSessionID } from "./typeUtils/accountOrAgentIDfromSessionID.js";
 import { expectGroup } from "./typeUtils/expectGroup.js";

@@ -41,12 +42,15 @@ export function disablePermissionErrors() {
  logPermissionErrors = false;
 }

-function logPermissionError(...args: unknown[]) {
+function logPermissionError(
+  message: string,
+  attributes?: Record<string, JsonValue>,
+) {
  if (logPermissionErrors === false) {
    return;
  }

-  console.warn(...args);
+  logger.warn("Permission error: " + message, attributes);
 }

 export function determineValidTransactions(
@@ -204,7 +208,6 @@ function determineValidTransactionsForGroup(
  const writeKeys = new Set<string>();

  for (const { sessionID, txIndex, tx } of allTransactionsSorted) {
-    // console.log("before", { memberState, validTransactions });
    const transactor = accountOrAgentIDfromSessionID(sessionID);

    if (tx.privacy === "private") {
@@ -227,17 +230,10 @@ function determineValidTransactionsForGroup(
    try {
      changes = parseJSON(tx.changes);
    } catch (e) {
-      logPermissionError(
-        coValue.id,
-        "Invalid JSON in transaction",
-        e,
+      logPermissionError("Invalid JSON in transaction", {
+        id: coValue.id,
        tx,
-        JSON.stringify(tx.changes, (k, v) =>
-          k === "changes" || k === "encryptedChanges"
-            ? v.slice(0, 20) + "..."
-            : v,
-        ),
-      );
+      });
      continue;
    }

@@ -458,8 +454,6 @@ function determineValidTransactionsForGroup(

    memberState[affectedMember] = change.value;
    validTransactions.push({ txID: { sessionID, txIndex }, tx });
-
-    // console.log("after", { memberState, validTransactions });
  }

  return { validTransactions, memberState };
@@ -473,7 +467,7 @@ function agentInAccountOrMemberInGroup(
    return groupAtTime.currentAgentID().match(
      (agentID) => agentID,
      (e) => {
-        console.error(
+        logger.error(
          "Error while determining current agent ID in valid transactions",
          e,
        );
--- a/packages/cojson/src/storage/FileSystem.ts
+++ b/packages/cojson/src/storage/FileSystem.ts
@@ -87,26 +87,15 @@ export async function writeBlock<WH, RH, FS extends FileSystem<WH, RH>>(
  const headerBytes = textEncoder.encode(JSON.stringify(blockHeader));
  await fs.append(file, headerBytes);

-  // console.log(
-  //     "full file",
-  //     yield* $(
-  //         fs.read(file as unknown as RH, 0, offset + headerBytes.length),
-  //     ),
-  // );
-
  const filename: BlockFilename = `L${level}-${(blockNumber + "").padStart(
    3,
    "0",
  )}-${hash.digest().replace("hash_", "").slice(0, 15)}-H${
    headerBytes.length
  }.jsonl`;
-  // console.log("renaming to" + filename);
  await fs.closeAndRename(file, filename);

  return filename;
-
-  // console.log("Wrote block", filename, blockHeader);
-  // console.log("IDs in block", blockHeader.map(e => e.id));
 }

 export async function writeToWal<WH, RH, FS extends FileSystem<WH, RH>>(
@@ -120,6 +109,5 @@ export async function writeToWal<WH, RH, FS extends FileSystem<WH, RH>>(
    ...chunk,
  };
  const bytes = textEncoder.encode(JSON.stringify(walEntry) + "\n");
-  console.log("writing to WAL", handle, id, bytes.length);
  return fs.append(handle, bytes);
 }
--- a/packages/cojson/src/storage/index.ts
+++ b/packages/cojson/src/storage/index.ts
@@ -2,6 +2,7 @@ import { CoID, RawCoValue } from "../coValue.js";
 import { CoValueHeader, Transaction } from "../coValueCore.js";
 import { Signature } from "../crypto/crypto.js";
 import { RawCoID } from "../ids.js";
+import { logger } from "../logger.js";
 import { connectedPeers } from "../streamUtils.js";
 import {
  CoValueKnownState,
@@ -68,7 +69,6 @@ export class LSMStorage<WH, RH, FS extends FileSystem<WH, RH>> {

    const processMessages = async () => {
      for await (const msg of fromLocalNode) {
-        console.log("Storage msg start", nMsg);
        try {
          if (msg === "Disconnected" || msg === "PingTimeout") {
            throw new Error("Unexpected Disconnected message");
@@ -83,32 +83,30 @@ export class LSMStorage<WH, RH, FS extends FileSystem<WH, RH>> {
            await this.sendNewContent(msg.id, msg, undefined);
          }
        } 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 },
-            ),
+          logger.error(
+            `Error reading from localNode, handling msg\n\n${JSON.stringify(
+              msg,
+              (k, v) =>
+                k === "changes" || k === "encryptedChanges"
+                  ? v.slice(0, 20) + "..."
+                  : v,
+            )}
+            Error: ${e instanceof Error ? e.message : "Unknown error"},
+            `,
          );
        }
-        console.log("Storage msg end", nMsg);
        nMsg++;
      }
    };

    processMessages().catch((e) =>
-      console.error("Error in processMessages in storage", e),
+      logger.error("Error in processMessages in storage", e),
    );

    setTimeout(
      () =>
        this.compact().catch((e) => {
-          console.error("Error while compacting", e);
+          logger.error("Error while compacting", e);
        }),
      20000,
    );
@@ -134,7 +132,7 @@ export class LSMStorage<WH, RH, FS extends FileSystem<WH, RH>> {
          sessions: {},
          asDependencyOf,
        })
-        .catch((e) => console.error("Error while pushing known", e));
+        .catch((e) => logger.error("Error while pushing known", e));

      return;
    }
@@ -190,13 +188,13 @@ export class LSMStorage<WH, RH, FS extends FileSystem<WH, RH>> {
        ...ourKnown,
        asDependencyOf,
      })
-      .catch((e) => console.error("Error while pushing known", e));
+      .catch((e) => logger.error("Error while pushing known", e));

    for (const message of newContentMessages) {
      if (Object.keys(message.new).length === 0) continue;
      this.toLocalNode
        .push(message)
-        .catch((e) => console.error("Error while pushing new content", e));
+        .catch((e) => logger.error("Error while pushing new content", e));
    }

    this.coValues[id] = coValue;
@@ -232,14 +230,13 @@ export class LSMStorage<WH, RH, FS extends FileSystem<WH, RH>> {

    if (!coValue) {
      if (newContent.header) {
-        // console.log("Creating in WAL", newContent.id);
        await this.withWAL((wal) =>
          writeToWal(wal, this.fs, newContent.id, newContentAsChunk),
        );

        this.coValues[newContent.id] = newContentAsChunk;
      } else {
-        console.warn("Incontiguous incoming update for " + newContent.id);
+        logger.warn("Incontiguous incoming update for " + newContent.id);
        return;
      }
    } else {
@@ -264,7 +261,6 @@ export class LSMStorage<WH, RH, FS extends FileSystem<WH, RH>> {
          ),
        );
      } else {
-        // console.log("Appending to WAL", newContent.id);
        await this.withWAL((wal) =>
          writeToWal(wal, this.fs, newContent.id, newContentAsChunk),
        );
@@ -301,8 +297,6 @@ export class LSMStorage<WH, RH, FS extends FileSystem<WH, RH>> {

      const { handle, size } = await this.getBlockHandle(blockFile, fs);

-      // console.log("Attempting to load", id, blockFile);
-
      if (!cachedHeader) {
        cachedHeader = {};
        const header = await readHeader(blockFile, handle, size, fs);
@@ -317,8 +311,6 @@ export class LSMStorage<WH, RH, FS extends FileSystem<WH, RH>> {
      }
      const headerEntry = cachedHeader[id];

-      // console.log("Header entry", id, headerEntry);
-
      if (headerEntry) {
        const nextChunk = await readChunk(handle, headerEntry, fs);
        if (result) {
@@ -354,7 +346,6 @@ export class LSMStorage<WH, RH, FS extends FileSystem<WH, RH>> {

    const coValues = new Map<RawCoID, CoValueChunk>();

-    console.log("Compacting WAL files", walFiles);
    if (walFiles.length === 0) return;

    const oldWal = this.currentWal;
@@ -411,8 +402,6 @@ export class LSMStorage<WH, RH, FS extends FileSystem<WH, RH>> {
      return acc;
    }, 0);

-    console.log([...coValues.keys()], fileNames, highestBlockNumber);
-
    await writeBlock(coValues, MAX_N_LEVELS, highestBlockNumber + 1, this.fs);

    for (const walFile of walFiles) {
@@ -438,15 +427,11 @@ export class LSMStorage<WH, RH, FS extends FileSystem<WH, RH>> {
      blockFilesByLevelInOrder[level]!.push(blockFile);
    }

-    console.log(blockFilesByLevelInOrder);
-
    for (let level = MAX_N_LEVELS; level > 0; level--) {
      const nBlocksDesired = Math.pow(2, level);
      const blocksInLevel = blockFilesByLevelInOrder[level];

      if (blocksInLevel && blocksInLevel.length > nBlocksDesired) {
-        console.log("Compacting blocks in level", level, blocksInLevel);
-
        const coValues = new Map<RawCoID, CoValueChunk>();

        for (const blockFile of blocksInLevel) {
@@ -517,7 +502,7 @@ export class LSMStorage<WH, RH, FS extends FileSystem<WH, RH>> {
    setTimeout(
      () =>
        this.compact().catch((e) => {
-          console.error("Error while compacting", e);
+          logger.error("Error while compacting", e);
        }),
      5000,
    );
--- a/packages/cojson/src/sync.ts
+++ b/packages/cojson/src/sync.ts
@@ -6,6 +6,7 @@ import { CoValueCore } from "./coValueCore.js";
 import { Signature } from "./crypto/crypto.js";
 import { RawCoID, SessionID } from "./ids.js";
 import { LocalNode } from "./localNode.js";
+import { logger } from "./logger.js";
 import { CoValuePriority } from "./priority.js";

 export type CoValueKnownState = {
@@ -22,6 +23,10 @@ export function emptyKnownState(id: RawCoID): CoValueKnownState {
  };
 }

+function getErrorMessage(e: unknown) {
+  return e instanceof Error ? e.message : "Unknown error";
+}
+
 export type SyncMessage =
  | LoadMessage
  | KnownStateMessage
@@ -150,7 +155,7 @@ export class SyncManager {

  async handleSyncMessage(msg: SyncMessage, peer: PeerState) {
    if (peer.erroredCoValues.has(msg.id)) {
-      console.error(
+      logger.warn(
        `Skipping message ${msg.action} on errored coValue ${msg.id} from peer ${peer.id}`,
      );
      return;
@@ -182,7 +187,7 @@ export class SyncManager {

    if (entry.state.type !== "available") {
      entry.loadFromPeers([peer]).catch((e: unknown) => {
-        console.error("Error sending load", e);
+        logger.error("Error sending load: " + getErrorMessage(e));
      });
      return;
    }
@@ -199,7 +204,7 @@ export class SyncManager {
        action: "load",
        ...coValue.knownState(),
      }).catch((e: unknown) => {
-        console.error("Error sending load", e);
+        logger.error("Error sending load: " + getErrorMessage(e));
      });
    }
  }
@@ -229,7 +234,7 @@ export class SyncManager {
        asDependencyOf,
        ...coValue.knownState(),
      }).catch((e: unknown) => {
-        console.error("Error sending known state", e);
+        logger.error("Error sending known state: " + getErrorMessage(e));
      });

      peer.toldKnownState.add(id);
@@ -256,15 +261,8 @@ export class SyncManager {
      const sendPieces = async () => {
        let lastYield = performance.now();
        for (const [_i, piece] of newContentPieces.entries()) {
-          // console.log(
-          //     `${id} -> ${peer.id}: Sending content piece ${i + 1}/${
-          //         newContentPieces.length
-          //     } header: ${!!piece.header}`,
-          //     // Object.values(piece.new).map((s) => s.newTransactions)
-          // );
-
          this.trySendToPeer(peer, piece).catch((e: unknown) => {
-            console.error("Error sending content piece", e);
+            logger.error("Error sending content piece: " + getErrorMessage(e));
          });

          if (performance.now() - lastYield > 10) {
@@ -277,7 +275,7 @@ export class SyncManager {
      };

      sendPieces().catch((e) => {
-        console.error("Error sending new content piece, retrying", e);
+        logger.error("Error sending new content piece, retrying", e);
        peer.optimisticKnownStates.dispatch({
          type: "SET",
          id,
@@ -337,7 +335,10 @@ export class SyncManager {
          return;
        }
        if (msg === "PingTimeout") {
-          console.error("Ping timeout from peer", peer.id);
+          logger.error("Ping timeout from peer", {
+            peerId: peer.id,
+            peerRole: peer.role,
+          });
          return;
        }
        try {
@@ -360,13 +361,22 @@ export class SyncManager {
    processMessages()
      .then(() => {
        if (peer.crashOnClose) {
-          console.error("Unexepcted close from peer", peer.id);
+          logger.error("Unexepcted close from peer", {
+            peerId: peer.id,
+            peerRole: peer.role,
+          });
          this.local.crashed = new Error("Unexpected close from peer");
          throw new Error("Unexpected close from peer");
        }
      })
      .catch((e) => {
-        console.error("Error processing messages from peer", peer.id, e);
+        logger.error(
+          "Error processing messages from peer: " + getErrorMessage(e),
+          {
+            peerId: peer.id,
+            peerRole: peer.role,
+          },
+        );
        if (peer.crashOnClose) {
          this.local.crashed = e;
          throw new Error(e);
@@ -406,13 +416,13 @@ export class SyncManager {
        // where we can get informations about the coValue
        if (msg.header || Object.keys(msg.sessions).length > 0) {
          entry.loadFromPeers([peer]).catch((e) => {
-            console.error("Error loading coValue in handleLoad", e);
+            logger.error("Error loading coValue in handleLoad", e);
          });
        }
        return;
      } else {
        this.local.loadCoValueCore(msg.id, peer.id).catch((e) => {
-          console.error("Error loading coValue in handleLoad", e);
+          logger.error("Error loading coValue in handleLoad", e);
        });
      }
    }
@@ -439,7 +449,7 @@ export class SyncManager {
              header: false,
              sessions: {},
            }).catch((e) => {
-              console.error("Error sending known state back", e);
+              logger.error("Error sending known state back", e);
            });

            return;
@@ -449,7 +459,7 @@ export class SyncManager {
          await this.sendNewContentIncludingDependencies(msg.id, peer);
        })
        .catch((e) => {
-          console.error("Error loading coValue in handleLoad loading state", e);
+          logger.error("Error loading coValue in handleLoad loading state", e);
        });
    }

@@ -484,7 +494,7 @@ export class SyncManager {
              peer.role === "storage" ? undefined : peer.id,
            )
            .catch((e) => {
-              console.error(
+              logger.error(
                `Error loading coValue ${msg.id} to create loading state, as dependency of ${msg.asDependencyOf}`,
                e,
              );
@@ -521,7 +531,7 @@ export class SyncManager {

    if (entry.state.type !== "available") {
      if (!msg.header) {
-        console.error("Expected header to be sent in first message");
+        logger.error("Expected header to be sent in first message");
        return;
      }

@@ -584,7 +594,7 @@ export class SyncManager {
              : t.changes.length,
          )
          .reduce((a, b) => a + b, 0);
-        console.log(
+        logger.debug(
          `Adding incoming transactions took ${(after - before).toFixed(
            2,
          )}ms for ${totalTxLength} bytes = bandwidth: ${(
@@ -602,17 +612,11 @@ export class SyncManager {
      // );

      if (result.isErr()) {
-        console.error(
-          "Failed to add transactions from",
-          peer.id,
-          result.error,
-          msg.id,
-          newTransactions.length + " new transactions",
-          "after: " + newContentForSession.after,
-          "our last known tx idx initially: " + ourKnownTxIdx,
-          "our last known tx idx now: " +
-            coValue.sessionLogs.get(sessionID)?.transactions.length,
-        );
+        logger.error("Failed to add transactions: " + result.error.type, {
+          peerId: peer.id,
+          peerRole: peer.role,
+          id: msg.id,
+        });
        peer.erroredCoValues.set(msg.id, result.error);
        continue;
      }
@@ -633,7 +637,13 @@ export class SyncManager {
        isCorrection: true,
        ...coValue.knownState(),
      }).catch((e) => {
-        console.error("Error sending known state correction", e);
+        logger.error(
+          "Error sending known state correction: " + getErrorMessage(e),
+          {
+            peerId: peer.id,
+            peerRole: peer.role,
+          },
+        );
      });
    } else {
      /**
@@ -647,7 +657,10 @@ export class SyncManager {
        action: "known",
        ...coValue.knownState(),
      }).catch((e: unknown) => {
-        console.error("Error sending known state", e);
+        logger.error("Error sending known state: " + getErrorMessage(e), {
+          peerId: peer.id,
+          peerRole: peer.role,
+        });
      });
    }

@@ -681,9 +694,6 @@ export class SyncManager {
      const done = new Promise<void>((resolve) => {
        queueMicrotask(async () => {
          delete this.requestedSyncs[coValue.id];
-          // if (entry.nRequestsThisTick >= 2) {
-          //     console.log("Syncing", coValue.id, "for", entry.nRequestsThisTick, "requests");
-          // }
          await this.actuallySyncCoValue(coValue);
          resolve();
        });
--- a/packages/cojson/src/tests/PeerState.test.ts
+++ b/packages/cojson/src/tests/PeerState.test.ts
@@ -49,12 +49,9 @@ describe("PeerState", () => {

  test("should perform graceful shutdown", () => {
    const { mockPeer, peerState } = setup();
-    const consoleSpy = vi.spyOn(console, "debug").mockImplementation(() => {});
    peerState.gracefulShutdown();
    expect(mockPeer.outgoing.close).toHaveBeenCalled();
    expect(peerState.closed).toBe(true);
-    expect(consoleSpy).toHaveBeenCalledWith("Gracefully closing", "test-peer");
-    consoleSpy.mockRestore();
  });

  test("should empty the queue when closing", async () => {
--- a/packages/cojson/src/tests/logger.test.ts
+++ b/packages/cojson/src/tests/logger.test.ts
@@ -0,0 +1,149 @@
+import { describe, expect, test, vi } from "vitest";
+import { LogLevel, Logger } from "../logger";
+
+describe("Logger", () => {
+  describe("Log Level Filtering", () => {
+    test("should respect log level hierarchy", () => {
+      const mockLogSystem = {
+        debug: vi.fn(),
+        info: vi.fn(),
+        warn: vi.fn(),
+        error: vi.fn(),
+      };
+
+      const logger = new Logger(LogLevel.WARN, mockLogSystem);
+
+      logger.debug("Debug message");
+      logger.info("Info message");
+      logger.warn("Warning message");
+      logger.error("Error message");
+
+      expect(mockLogSystem.debug).not.toHaveBeenCalled();
+      expect(mockLogSystem.info).not.toHaveBeenCalled();
+      expect(mockLogSystem.warn).toHaveBeenCalledWith(
+        "Warning message",
+        undefined,
+      );
+      expect(mockLogSystem.error).toHaveBeenCalledWith(
+        "Error message",
+        undefined,
+      );
+    });
+
+    test("should pass additional arguments to log system", () => {
+      const mockLogSystem = {
+        debug: vi.fn(),
+        info: vi.fn(),
+        warn: vi.fn(),
+        error: vi.fn(),
+      };
+
+      const logger = new Logger(LogLevel.DEBUG, mockLogSystem);
+
+      logger.debug("Debug message", { foo: "bar" });
+
+      expect(mockLogSystem.debug).toHaveBeenCalledWith("Debug message", {
+        foo: "bar",
+      });
+    });
+  });
+
+  describe("Log System Configuration", () => {
+    test("should allow changing log level at runtime", () => {
+      const mockLogSystem = {
+        debug: vi.fn(),
+        info: vi.fn(),
+        warn: vi.fn(),
+        error: vi.fn(),
+      };
+
+      const logger = new Logger(LogLevel.ERROR, mockLogSystem);
+
+      logger.warn("Warning 1"); // Should not log
+      expect(mockLogSystem.warn).not.toHaveBeenCalled();
+
+      logger.setLevel(LogLevel.WARN);
+      logger.warn("Warning 2"); // Should log
+      expect(mockLogSystem.warn).toHaveBeenCalledWith("Warning 2", undefined);
+    });
+
+    test("should allow changing log system at runtime", () => {
+      const mockLogSystem1 = {
+        debug: vi.fn(),
+        info: vi.fn(),
+        warn: vi.fn(),
+        error: vi.fn(),
+      };
+
+      const mockLogSystem2 = {
+        debug: vi.fn(),
+        info: vi.fn(),
+        warn: vi.fn(),
+        error: vi.fn(),
+      };
+
+      const logger = new Logger(LogLevel.INFO, mockLogSystem1);
+
+      logger.info("Message 1");
+      expect(mockLogSystem1.info).toHaveBeenCalledWith("Message 1", undefined);
+      expect(mockLogSystem2.info).not.toHaveBeenCalled();
+
+      logger.setLogSystem(mockLogSystem2);
+      logger.info("Message 2");
+      expect(mockLogSystem2.info).toHaveBeenCalledWith("Message 2", undefined);
+      expect(mockLogSystem1.info).toHaveBeenCalledTimes(1);
+    });
+  });
+
+  describe("Default Console Log System", () => {
+    test("should use console methods by default", () => {
+      const consoleSpy = {
+        debug: vi.spyOn(console, "debug").mockImplementation(() => {}),
+        info: vi.spyOn(console, "info").mockImplementation(() => {}),
+        warn: vi.spyOn(console, "warn").mockImplementation(() => {}),
+        error: vi.spyOn(console, "error").mockImplementation(() => {}),
+      };
+
+      const logger = new Logger();
+      logger.setLevel(LogLevel.DEBUG);
+      const testMessage = "Test message";
+      const testArgs = { data: "test" };
+
+      logger.debug(testMessage, testArgs);
+      logger.info(testMessage, testArgs);
+      logger.warn(testMessage, testArgs);
+      logger.error(testMessage, testArgs);
+
+      expect(consoleSpy.debug).toHaveBeenCalledWith(testMessage, testArgs);
+      expect(consoleSpy.info).toHaveBeenCalledWith(testMessage, testArgs);
+      expect(consoleSpy.warn).toHaveBeenCalledWith(testMessage, testArgs);
+      expect(consoleSpy.error).toHaveBeenCalledWith(testMessage, testArgs);
+
+      // Cleanup
+      Object.values(consoleSpy).forEach((spy) => spy.mockRestore());
+    });
+  });
+
+  describe("Log Level NONE", () => {
+    test("should not log anything when level is NONE", () => {
+      const mockLogSystem = {
+        debug: vi.fn(),
+        info: vi.fn(),
+        warn: vi.fn(),
+        error: vi.fn(),
+      };
+
+      const logger = new Logger(LogLevel.NONE, mockLogSystem);
+
+      logger.debug("Debug message");
+      logger.info("Info message");
+      logger.warn("Warning message");
+      logger.error("Error message");
+
+      expect(mockLogSystem.debug).not.toHaveBeenCalled();
+      expect(mockLogSystem.info).not.toHaveBeenCalled();
+      expect(mockLogSystem.warn).not.toHaveBeenCalled();
+      expect(mockLogSystem.error).not.toHaveBeenCalled();
+    });
+  });
+});
--- a/packages/jazz-browser-auth-clerk/CHANGELOG.md
+++ b/packages/jazz-browser-auth-clerk/CHANGELOG.md
@@ -1,5 +1,14 @@
 # jazz-browser-media-images

+## 0.9.13
+
+### Patch Changes
+
+- Updated dependencies [8d29e50]
+  - cojson@0.9.13
+  - jazz-browser@0.9.13
+  - jazz-tools@0.9.13
+
 ## 0.9.12

 ### Patch Changes
--- a/packages/jazz-browser-auth-clerk/package.json
+++ b/packages/jazz-browser-auth-clerk/package.json
@@ -1,14 +1,14 @@
 {
  "name": "jazz-browser-auth-clerk",
-  "version": "0.9.12",
+  "version": "0.9.13",
  "type": "module",
  "main": "dist/index.js",
  "types": "src/index.ts",
  "license": "MIT",
  "dependencies": {
-    "cojson": "workspace:0.9.12",
-    "jazz-browser": "workspace:0.9.12",
-    "jazz-tools": "workspace:0.9.12"
+    "cojson": "workspace:0.9.13",
+    "jazz-browser": "workspace:0.9.13",
+    "jazz-tools": "workspace:0.9.13"
  },
  "scripts": {
    "format-and-lint": "biome check .",
--- a/packages/jazz-browser-media-images/CHANGELOG.md
+++ b/packages/jazz-browser-media-images/CHANGELOG.md
@@ -1,5 +1,12 @@
 # jazz-browser-media-images

+## 0.9.13
+
+### Patch Changes
+
+- jazz-browser@0.9.13
+- jazz-tools@0.9.13
+
 ## 0.9.12

 ### Patch Changes
--- a/packages/jazz-browser-media-images/package.json
+++ b/packages/jazz-browser-media-images/package.json
@@ -1,6 +1,6 @@
 {
  "name": "jazz-browser-media-images",
-  "version": "0.9.12",
+  "version": "0.9.13",
  "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.9.12",
-    "jazz-tools": "workspace:0.9.12",
+    "jazz-browser": "workspace:0.9.13",
+    "jazz-tools": "workspace:0.9.13",
    "pica": "^9.0.1",
    "typescript": "~5.6.2"
  },
--- a/packages/jazz-browser/CHANGELOG.md
+++ b/packages/jazz-browser/CHANGELOG.md
@@ -1,5 +1,15 @@
 # jazz-browser

+## 0.9.13
+
+### Patch Changes
+
+- Updated dependencies [8d29e50]
+  - cojson-transport-ws@0.9.13
+  - cojson@0.9.13
+  - cojson-storage-indexeddb@0.9.13
+  - jazz-tools@0.9.13
+
 ## 0.9.12

 ### Patch Changes
--- a/packages/jazz-browser/package.json
+++ b/packages/jazz-browser/package.json
@@ -1,16 +1,16 @@
 {
  "name": "jazz-browser",
-  "version": "0.9.12",
+  "version": "0.9.13",
  "type": "module",
  "main": "dist/index.js",
  "types": "src/index.ts",
  "license": "MIT",
  "dependencies": {
    "@scure/bip39": "^1.3.0",
-    "cojson": "workspace:0.9.12",
-    "cojson-storage-indexeddb": "workspace:0.9.12",
-    "cojson-transport-ws": "workspace:0.9.12",
-    "jazz-tools": "workspace:0.9.12",
+    "cojson": "workspace:0.9.13",
+    "cojson-storage-indexeddb": "workspace:0.9.13",
+    "cojson-transport-ws": "workspace:0.9.13",
+    "jazz-tools": "workspace:0.9.13",
    "typescript": "~5.6.2"
  },
  "scripts": {
--- a/packages/jazz-inspector/CHANGELOG.md
+++ b/packages/jazz-inspector/CHANGELOG.md
@@ -1,5 +1,14 @@
 # jazz-inspector

+## 0.9.13
+
+### Patch Changes
+
+- Updated dependencies [8d29e50]
+  - cojson@0.9.13
+  - jazz-react-core@0.8.54
+  - jazz-tools@0.9.13
+
 ## 0.9.12

 ### Patch Changes
--- a/packages/jazz-inspector/package.json
+++ b/packages/jazz-inspector/package.json
@@ -1,6 +1,6 @@
 {
  "name": "jazz-inspector",
-  "version": "0.9.12",
+  "version": "0.9.13",
  "type": "module",
  "main": "./dist/jazz-inspector.js",
  "types": "./src/app.tsx",
--- a/packages/jazz-nodejs/CHANGELOG.md
+++ b/packages/jazz-nodejs/CHANGELOG.md
@@ -1,5 +1,14 @@
 # jazz-autosub

+## 0.9.13
+
+### Patch Changes
+
+- Updated dependencies [8d29e50]
+  - cojson-transport-ws@0.9.13
+  - cojson@0.9.13
+  - jazz-tools@0.9.13
+
 ## 0.9.12

 ### Patch Changes
--- a/packages/jazz-nodejs/package.json
+++ b/packages/jazz-nodejs/package.json
@@ -5,11 +5,11 @@
  "types": "src/index.ts",
  "type": "module",
  "license": "MIT",
-  "version": "0.9.12",
+  "version": "0.9.13",
  "dependencies": {
-    "cojson": "workspace:0.9.12",
-    "cojson-transport-ws": "workspace:0.9.12",
-    "jazz-tools": "workspace:0.9.12",
+    "cojson": "workspace:0.9.13",
+    "cojson-transport-ws": "workspace:0.9.13",
+    "jazz-tools": "workspace:0.9.13",
    "ws": "^8.14.2"
  },
  "devDependencies": {
--- a/packages/jazz-nodejs/src/test/startSyncServer.test.ts
+++ b/packages/jazz-nodejs/src/test/startSyncServer.test.ts
@@ -0,0 +1,76 @@
+import { randomUUID } from "crypto";
+import { tmpdir } from "os";
+import { join } from "path";
+import { createWorkerAccount } from "jazz-run/createWorkerAccount";
+import { startSyncServer } from "jazz-run/startSyncServer";
+import { CoMap, co } from "jazz-tools";
+import { describe, expect, test } from "vitest";
+import { startWorker } from "../index";
+
+class TestMap extends CoMap {
+  value = co.string;
+}
+
+describe("startSyncServer", () => {
+  test("persists values in storage and loads them after restart", async () => {
+    // Create a temporary database file
+    const dbPath = join(tmpdir(), `test-${randomUUID()}.db`);
+
+    // Start first server instance
+    const server1 = await startSyncServer({
+      port: "0", // Random available port
+      inMemory: false,
+      db: dbPath,
+    });
+
+    const port = (server1.address() as any).port;
+    const syncServer = `ws://localhost:${port}`;
+
+    // Create worker account and start first worker
+    const { accountID, agentSecret } = await createWorkerAccount({
+      name: "test-worker",
+      peer: syncServer,
+    });
+
+    const worker1 = await startWorker({
+      accountID,
+      accountSecret: agentSecret,
+      syncServer,
+    });
+
+    // Create and sync test data
+    const map = TestMap.create({ value: "testValue" });
+
+    // Close first server
+    await worker1.done();
+    server1.close();
+
+    // Start second server instance with same DB
+    const server2 = await startSyncServer({
+      port: "0",
+      inMemory: false,
+      db: dbPath,
+    });
+
+    const port2 = (server2.address() as any).port;
+    const syncServer2 = `ws://localhost:${port2}`;
+
+    // Start second worker with same account
+    const worker2 = await startWorker({
+      accountID,
+      accountSecret: agentSecret,
+      syncServer: syncServer2,
+    });
+
+    // Try to load the previously created map
+    const loadedMap = await TestMap.load(map.id, {});
+
+    // Verify the data persisted
+    expect(loadedMap).not.toBe(null);
+    expect(loadedMap?.value).toBe("testValue");
+
+    // Cleanup
+    await worker2.done();
+    server2.close();
+  });
+});
--- a/packages/jazz-nodejs/src/test/startWorker.test.ts
+++ b/packages/jazz-nodejs/src/test/startWorker.test.ts
@@ -3,7 +3,6 @@ import { startSyncServer } from "jazz-run/startSyncServer";
 import { CoMap, Group, InboxSender, co } from "jazz-tools";
 import { describe, expect, onTestFinished, test } from "vitest";
 import { startWorker } from "../index";
-import { waitFor } from "./utils";

 async function setup() {
  const { server, port } = await setupSyncServer();
--- a/packages/jazz-react-auth-clerk/CHANGELOG.md
+++ b/packages/jazz-react-auth-clerk/CHANGELOG.md
@@ -1,5 +1,15 @@
 # jazz-browser-media-images

+## 0.9.13
+
+### Patch Changes
+
+- Updated dependencies [8d29e50]
+  - cojson@0.9.13
+  - jazz-browser-auth-clerk@0.9.13
+  - jazz-react@0.9.13
+  - jazz-tools@0.9.13
+
 ## 0.9.12

 ### Patch Changes
--- a/packages/jazz-react-auth-clerk/package.json
+++ b/packages/jazz-react-auth-clerk/package.json
@@ -1,15 +1,15 @@
 {
  "name": "jazz-react-auth-clerk",
-  "version": "0.9.12",
+  "version": "0.9.13",
  "type": "module",
  "main": "dist/index.js",
  "types": "src/index.tsx",
  "license": "MIT",
  "dependencies": {
-    "cojson": "workspace:0.9.12",
-    "jazz-browser-auth-clerk": "workspace:0.9.12",
-    "jazz-react": "workspace:0.9.12",
-    "jazz-tools": "workspace:0.9.12"
+    "cojson": "workspace:0.9.13",
+    "jazz-browser-auth-clerk": "workspace:0.9.13",
+    "jazz-react": "workspace:0.9.13",
+    "jazz-tools": "workspace:0.9.13"
  },
  "peerDependencies": {
    "react": "^18.2.0"
--- a/packages/jazz-react-core/CHANGELOG.md
+++ b/packages/jazz-react-core/CHANGELOG.md
@@ -1,5 +1,13 @@
 # jazz-react-core

+## 0.8.54
+
+### Patch Changes
+
+- Updated dependencies [8d29e50]
+  - cojson@0.9.13
+  - jazz-tools@0.9.13
+
 ## 0.8.53

 ### Patch Changes
--- a/packages/jazz-react-core/package.json
+++ b/packages/jazz-react-core/package.json
@@ -1,6 +1,6 @@
 {
  "name": "jazz-react-core",
-  "version": "0.8.53",
+  "version": "0.8.54",
  "type": "module",
  "main": "dist/index.js",
  "types": "src/index.ts",
--- a/packages/jazz-react-core/src/testing.tsx
+++ b/packages/jazz-react-core/src/testing.tsx
@@ -22,4 +22,5 @@ export {
  createJazzTestGuest,
  linkAccounts,
  setActiveAccount,
+  setupJazzTestSync,
 } from "jazz-tools/testing";
--- a/packages/jazz-react-native-auth-clerk/CHANGELOG.md
+++ b/packages/jazz-react-native-auth-clerk/CHANGELOG.md
@@ -1,5 +1,14 @@
 # jazz-react-native-auth-clerk

+## 0.9.13
+
+### Patch Changes
+
+- Updated dependencies [8d29e50]
+  - cojson@0.9.13
+  - jazz-react-native@0.9.13
+  - jazz-tools@0.9.13
+
 ## 0.9.12

 ### Patch Changes
--- a/packages/jazz-react-native-auth-clerk/package.json
+++ b/packages/jazz-react-native-auth-clerk/package.json
@@ -1,6 +1,6 @@
 {
  "name": "jazz-react-native-auth-clerk",
-  "version": "0.9.12",
+  "version": "0.9.13",
  "type": "module",
  "main": "dist/index.js",
  "types": "src/index.ts",
--- a/packages/jazz-react-native-media-images/CHANGELOG.md
+++ b/packages/jazz-react-native-media-images/CHANGELOG.md
@@ -1,5 +1,11 @@
 # jazz-browser-media-images

+## 0.9.13
+
+### Patch Changes
+
+- jazz-tools@0.9.13
+
 ## 0.9.12

 ### Patch Changes
--- a/Show More
+++ b/Show More
Author	SHA1	Message	Date
Guido D'Orsi	7491711b72	fix: correctly set the globalMe before the migration when calling createJazzTestAccount	2025-01-22 19:19:07 +01:00
Guido D'Orsi	483422c0e9	Merge pull request #1241 from garden-co/guido/test feat: API to setup a test sync in the test environment	2025-01-22 18:28:38 +01:00
Guido D'Orsi	3df93cc147	chore: changeset	2025-01-22 18:22:16 +01:00
Guido D'Orsi	d686edfa6c	chore: add tests and use ref to track the current sync server	2025-01-22 18:22:15 +01:00
Giordano Ricci	497b0ade1f	feat: API to setup a test sync in the test environment	2025-01-22 18:21:48 +01:00
Guido D'Orsi	86acbcd0d6	Merge pull request #1237 from garden-co/changeset-release/main Version Packages	2025-01-22 12:51:45 +01:00
github-actions[bot]	9111c85445	Version Packages	2025-01-22 11:46:06 +00:00
Guido D'Orsi	1d87879787	Merge pull request #1231 from garden-co/revert-1229-revert-custom-logger Restore cutom logger	2025-01-22 12:44:53 +01:00
Guido D'Orsi	7c777f2bdf	test: cover the storage regression with a test	2025-01-22 12:41:51 +01:00
Benjamin S. Leveritt	aa8067b8d0	Merge pull request #1234 from garden-co/fix-clerk-example chore: simplify clerk example auth-context	2025-01-22 10:15:21 +00:00
Guido D'Orsi	bd66cdeb78	chore: simplify clerk example auth-context	2025-01-22 10:29:54 +01:00
Guido D'Orsi	8d29e50669	feat: adapt the logger interface to pino	2025-01-21 17:52:40 +01:00
Guido D'Orsi	5a7398d242	Revert "Revert custom logger"	2025-01-21 17:08:37 +01:00