Compare commits

..

1 Commits

Author SHA1 Message Date
Guido D'Orsi
bc33e98dc4 Revert "perf: optimize queue processing under heavy load" 2025-01-21 16:15:15 +01:00
128 changed files with 369 additions and 2272 deletions

View File

@@ -1,53 +1,5 @@
# chat-rn-clerk
## 1.0.57
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-react-native-auth-clerk@0.9.16
- jazz-tools@0.9.16
- jazz-react-native@0.9.16
- jazz-react-native-media-images@0.9.16
## 1.0.56
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-react-native@0.9.15
- jazz-react-native-auth-clerk@0.9.15
- jazz-react-native-media-images@0.9.15
## 1.0.55
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-react-native@0.9.14
- jazz-react-native-auth-clerk@0.9.14
- jazz-react-native-media-images@0.9.14
## 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
- jazz-react-native@0.9.12
- jazz-react-native-auth-clerk@0.9.12
- jazz-tools@0.9.12
- jazz-react-native-media-images@0.9.12
## 1.0.52
### Patch Changes

View File

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

View File

@@ -1,7 +1,13 @@
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 } from "react";
import React, {
createContext,
PropsWithChildren,
useContext,
useEffect,
useState,
} from "react";
import { Text, View } from "react-native";
const AuthContext = createContext<{
isAuthenticated: boolean;
@@ -21,7 +27,15 @@ export function JazzAndAuth({ children }: PropsWithChildren) {
const { isSignedIn, isLoaded: isClerkLoaded } = useUser();
const clerk = useClerk();
const [auth, state] = useJazzClerkAuth(clerk, kvStore);
const isAuthenticated = Boolean(isSignedIn && isClerkLoaded && auth);
const [isAuthenticated, setIsAuthenticated] = useState(false);
useEffect(() => {
if (isSignedIn && isClerkLoaded && auth) {
setIsAuthenticated(true);
} else {
setIsAuthenticated(false);
}
}, [isSignedIn, isClerkLoaded, auth]);
return (
<AuthContext.Provider

View File

@@ -1,43 +1,5 @@
# chat-rn
## 1.0.54
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-react-native@0.9.16
## 1.0.53
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-react-native@0.9.15
## 1.0.52
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-react-native@0.9.14
## 1.0.51
### Patch Changes
- jazz-react-native@0.9.13
- jazz-tools@0.9.13
## 1.0.50
### Patch Changes
- jazz-react-native@0.9.12
- jazz-tools@0.9.12
## 1.0.49
### Patch Changes

View File

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

View File

@@ -1,48 +1,5 @@
# chat-vue
## 0.0.41
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-browser@0.9.16
- jazz-vue@0.9.16
## 0.0.40
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-browser@0.9.15
- jazz-vue@0.9.15
## 0.0.39
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-browser@0.9.14
- jazz-vue@0.9.14
## 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
- jazz-browser@0.9.12
- jazz-tools@0.9.12
- jazz-vue@0.9.12
## 0.0.36
### Patch Changes

View File

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

View File

@@ -1,48 +1,5 @@
# jazz-example-chat
## 0.0.137
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-browser-media-images@0.9.16
- jazz-react@0.9.16
## 0.0.136
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-browser-media-images@0.9.15
- jazz-react@0.9.15
## 0.0.135
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-browser-media-images@0.9.14
- jazz-react@0.9.14
## 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
- jazz-react@0.9.12
- jazz-tools@0.9.12
- jazz-browser-media-images@0.9.12
## 0.0.132
### Patch Changes

View File

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

View File

@@ -1,48 +1,5 @@
# minimal-auth-clerk
## 0.0.36
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-react-auth-clerk@0.9.16
- jazz-tools@0.9.16
- jazz-react@0.9.16
## 0.0.35
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-react@0.9.15
- jazz-react-auth-clerk@0.9.15
## 0.0.34
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-react@0.9.14
- jazz-react-auth-clerk@0.9.14
## 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
- jazz-react@0.9.12
- jazz-react-auth-clerk@0.9.12
- jazz-tools@0.9.12
## 0.0.31
### Patch Changes

View File

@@ -15,11 +15,11 @@ You can either
Create a new Jazz project, and use this example as a template.
```bash
npm create jazz-app@latest --example clerk --project-name clerk
npm create jazz-app@latest --start clerk --project-name clerk
```
or
```bash
npx create-jazz-app@latest --example clerk --project-name clerk
npx create-jazz-app@latest --start clerk --project-name clerk
```
Go to the new project directory.

View File

@@ -1,7 +1,7 @@
{
"name": "clerk",
"private": true,
"version": "0.0.36",
"version": "0.0.31",
"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.16",
"jazz-react-auth-clerk": "workspace:0.9.11",
"jazz-tools": "workspace:*",
"react": "^18.3.1",
"react-dom": "^18.3.1"

View File

@@ -1,43 +1,5 @@
# file-share-svelte
## 0.0.21
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-svelte@0.9.16
## 0.0.20
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-svelte@0.9.15
## 0.0.19
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-svelte@0.9.14
## 0.0.18
### Patch Changes
- jazz-svelte@0.9.13
- jazz-tools@0.9.13
## 0.0.17
### Patch Changes
- jazz-svelte@0.9.12
- jazz-tools@0.9.12
## 0.0.16
### Patch Changes

View File

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

View File

@@ -1,48 +1,5 @@
# form
## 0.0.32
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-browser-media-images@0.9.16
- jazz-react@0.9.16
## 0.0.31
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-browser-media-images@0.9.15
- jazz-react@0.9.15
## 0.0.30
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-browser-media-images@0.9.14
- jazz-react@0.9.14
## 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
- jazz-react@0.9.12
- jazz-tools@0.9.12
- jazz-browser-media-images@0.9.12
## 0.0.27
### Patch Changes

View File

@@ -28,11 +28,11 @@ You can either
Create a new Jazz project, and use this example as a template.
```bash
npm create jazz-app@latest --example form --project-name form
npm create jazz-app@latest --start form --project-name form
```
or
```bash
npx create-jazz-app@latest --example form --project-name form
npx create-jazz-app@latest --start form --project-name form
```
Go to the new project directory.

View File

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

View File

@@ -1,48 +1,5 @@
# image-upload
## 0.0.34
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-browser-media-images@0.9.16
- jazz-react@0.9.16
## 0.0.33
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-browser-media-images@0.9.15
- jazz-react@0.9.15
## 0.0.32
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-browser-media-images@0.9.14
- jazz-react@0.9.14
## 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
- jazz-react@0.9.12
- jazz-tools@0.9.12
- jazz-browser-media-images@0.9.12
## 0.0.29
### Patch Changes

View File

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

View File

@@ -1,21 +1,5 @@
# 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
- Updated dependencies [15d4b2a]
- cojson-transport-ws@0.9.12
- cojson@0.9.12
## 0.0.96
### Patch Changes

View File

@@ -1,7 +1,7 @@
{
"name": "jazz-inspector-app",
"private": true,
"version": "0.0.98",
"version": "0.0.96",
"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.13",
"cojson-transport-ws": "workspace:0.9.13",
"cojson": "workspace:0.9.11",
"cojson-transport-ws": "workspace:0.9.11",
"hash-slash": "workspace:0.2.1",
"lucide-react": "^0.274.0",
"qrcode": "^1.5.3",

View File

@@ -1,48 +1,5 @@
# jazz-example-musicplayer
## 0.0.57
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-inspector@0.9.16
- jazz-react@0.9.16
## 0.0.56
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-inspector@0.9.15
- jazz-react@0.9.15
## 0.0.55
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-inspector@0.9.14
- jazz-react@0.9.14
## 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
- jazz-inspector@0.9.12
- jazz-react@0.9.12
- jazz-tools@0.9.12
## 0.0.52
### Patch Changes

View File

@@ -1,7 +1,7 @@
{
"name": "jazz-example-music-player",
"private": true,
"version": "0.0.57",
"version": "0.0.52",
"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.16",
"jazz-tools": "workspace:0.9.16",
"jazz-react": "workspace:0.9.11",
"jazz-tools": "workspace:0.9.11",
"jazz-inspector": "workspace:*",
"lucide-react": "^0.274.0",
"react": "^18.3.1",

View File

@@ -1,48 +1,5 @@
# jazz-example-onboarding
## 0.0.38
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-browser-media-images@0.9.16
- jazz-react@0.9.16
## 0.0.37
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-browser-media-images@0.9.15
- jazz-react@0.9.15
## 0.0.36
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-browser-media-images@0.9.14
- jazz-react@0.9.14
## 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
- jazz-react@0.9.12
- jazz-tools@0.9.12
- jazz-browser-media-images@0.9.12
## 0.0.33
### Patch Changes

View File

@@ -1,7 +1,7 @@
{
"name": "jazz-example-onboarding",
"private": true,
"version": "0.0.38",
"version": "0.0.33",
"type": "module",
"scripts": {
"dev": "vite",

View File

@@ -1,43 +1,5 @@
# organization
## 0.0.30
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-react@0.9.16
## 0.0.29
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-react@0.9.15
## 0.0.28
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-react@0.9.14
## 0.0.27
### Patch Changes
- jazz-react@0.9.13
- jazz-tools@0.9.13
## 0.0.26
### Patch Changes
- jazz-react@0.9.12
- jazz-tools@0.9.12
## 0.0.25
### Patch Changes

View File

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

View File

@@ -1,35 +1,5 @@
# passkey-svelte
## 0.0.25
### Patch Changes
- jazz-svelte@0.9.16
## 0.0.24
### Patch Changes
- jazz-svelte@0.9.15
## 0.0.23
### Patch Changes
- jazz-svelte@0.9.14
## 0.0.22
### Patch Changes
- jazz-svelte@0.9.13
## 0.0.21
### Patch Changes
- jazz-svelte@0.9.12
## 0.0.20
### Patch Changes

View File

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

View File

@@ -1,43 +1,5 @@
# minimal-auth-passkey
## 0.0.35
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-react@0.9.16
## 0.0.34
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-react@0.9.15
## 0.0.33
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-react@0.9.14
## 0.0.32
### Patch Changes
- jazz-react@0.9.13
- jazz-tools@0.9.13
## 0.0.31
### Patch Changes
- jazz-react@0.9.12
- jazz-tools@0.9.12
## 0.0.30
### Patch Changes

View File

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

View File

@@ -1,43 +1,5 @@
# jazz-password-manager
## 0.0.56
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-react@0.9.16
## 0.0.55
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-react@0.9.15
## 0.0.54
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-react@0.9.14
## 0.0.53
### Patch Changes
- jazz-react@0.9.13
- jazz-tools@0.9.13
## 0.0.52
### Patch Changes
- jazz-react@0.9.12
- jazz-tools@0.9.12
## 0.0.51
### Patch Changes

View File

@@ -1,7 +1,7 @@
{
"name": "jazz-password-manager",
"private": true,
"version": "0.0.56",
"version": "0.0.51",
"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.16",
"jazz-tools": "workspace:0.9.16",
"jazz-react": "workspace:0.9.11",
"jazz-tools": "workspace:0.9.11",
"react": "^18.3.1",
"react-dom": "^18.3.1",
"react-hook-form": "^7.41.5",

View File

@@ -1,48 +1,5 @@
# jazz-example-pets
## 0.0.154
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-browser-media-images@0.9.16
- jazz-react@0.9.16
## 0.0.153
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-browser-media-images@0.9.15
- jazz-react@0.9.15
## 0.0.152
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-browser-media-images@0.9.14
- jazz-react@0.9.14
## 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
- jazz-react@0.9.12
- jazz-tools@0.9.12
- jazz-browser-media-images@0.9.12
## 0.0.149
### Patch Changes

View File

@@ -1,7 +1,7 @@
{
"name": "jazz-example-pets",
"private": true,
"version": "0.0.154",
"version": "0.0.149",
"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.16",
"jazz-react": "workspace:0.9.16",
"jazz-tools": "workspace:0.9.16",
"jazz-browser-media-images": "workspace:0.9.11",
"jazz-react": "workspace:0.9.11",
"jazz-tools": "workspace:0.9.11",
"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.16",
"jazz-run": "workspace:0.9.11",
"postcss": "^8.4.27",
"tailwindcss": "^3.4.15",
"typescript": "~5.6.2",

View File

@@ -1,48 +1,5 @@
# reactions
## 0.0.34
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-browser-media-images@0.9.16
- jazz-react@0.9.16
## 0.0.33
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-browser-media-images@0.9.15
- jazz-react@0.9.15
## 0.0.32
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-browser-media-images@0.9.14
- jazz-react@0.9.14
## 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
- jazz-react@0.9.12
- jazz-tools@0.9.12
- jazz-browser-media-images@0.9.12
## 0.0.29
### Patch Changes

View File

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

View File

@@ -1,48 +1,5 @@
# todo-vue
## 0.0.39
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-browser@0.9.16
- jazz-vue@0.9.16
## 0.0.38
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-browser@0.9.15
- jazz-vue@0.9.15
## 0.0.37
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-browser@0.9.14
- jazz-vue@0.9.14
## 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
- jazz-browser@0.9.12
- jazz-tools@0.9.12
- jazz-vue@0.9.12
## 0.0.34
### Patch Changes

View File

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

View File

@@ -1,43 +1,5 @@
# jazz-example-todo
## 0.0.153
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-react@0.9.16
## 0.0.152
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-react@0.9.15
## 0.0.151
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-react@0.9.14
## 0.0.150
### Patch Changes
- jazz-react@0.9.13
- jazz-tools@0.9.13
## 0.0.149
### Patch Changes
- jazz-react@0.9.12
- jazz-tools@0.9.12
## 0.0.148
### Patch Changes

View File

@@ -1,7 +1,7 @@
{
"name": "jazz-example-todo",
"private": true,
"version": "0.0.153",
"version": "0.0.148",
"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.16",
"jazz-tools": "workspace:0.9.16",
"jazz-react": "workspace:0.9.11",
"jazz-tools": "workspace:0.9.11",
"lucide-react": "^0.274.0",
"qrcode": "^1.5.3",
"react": "^18.3.1",

View File

@@ -1,43 +1,5 @@
# version-history
## 0.0.31
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-react@0.9.16
## 0.0.30
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-react@0.9.15
## 0.0.29
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-react@0.9.14
## 0.0.28
### Patch Changes
- jazz-react@0.9.13
- jazz-tools@0.9.13
## 0.0.27
### Patch Changes
- jazz-react@0.9.12
- jazz-tools@0.9.12
## 0.0.26
### Patch Changes

View File

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

View File

@@ -132,7 +132,7 @@ As you develop your app, you'll likely want to
- initialise data in a user's `root` and `profile`
- add more data to your `root` and `profile` schemas
You can achieve both by overriding the `migrate()` method on your `Account` schema class.
You can achieve both by overriding the static `migrate()` method on your `Account` schema class.
### When migrations run

View File

@@ -1,21 +1,5 @@
# 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
- Updated dependencies [15d4b2a]
- cojson-storage@0.9.12
- cojson@0.9.12
## 0.9.11
### Patch Changes

View File

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

View File

@@ -1,21 +1,5 @@
# 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
- Updated dependencies [15d4b2a]
- cojson-storage@0.9.12
- cojson@0.9.12
## 0.8.54
### Patch Changes

View File

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

View File

@@ -1,23 +1,5 @@
# 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
- 15d4b2a: Revert the custom logger
- Updated dependencies [15d4b2a]
- cojson-storage@0.9.12
- cojson@0.9.12
## 0.9.11
### Patch Changes

View File

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

View File

@@ -28,10 +28,6 @@ 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;
@@ -57,10 +53,7 @@ export class SQLiteClient implements DBClientInterface {
header: parsedHeader,
};
} catch (e) {
const headerValue = coValueRow?.header ?? "";
logger.warn("Invalid JSON in header: " + headerValue, {
id: coValueId,
});
logger.warn(coValueId, "Invalid JSON in header", e, coValueRow?.header);
return;
}
}
@@ -87,7 +80,7 @@ export class SQLiteClient implements DBClientInterface {
tx: JSON.parse(transactionRow.tx) as Transaction,
}));
} catch (e) {
logger.warn("Invalid JSON in transaction");
logger.warn("Invalid JSON in transaction", e);
return [];
}
}

View File

@@ -49,14 +49,15 @@ export class SQLiteNode {
? v.slice(0, 20) + "..."
: v,
)}`,
e,
);
}
}
};
processMessages().catch((e) =>
logger.error("Error in processMessages in sqlite", e),
);
processMessages().catch((e) =>
logger.error("Error in processMessages in sqlite", e),
);
};
}
static async asPeer({

View File

@@ -1,21 +1,5 @@
# 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
- 15d4b2a: Revert the custom logger
- Updated dependencies [15d4b2a]
- cojson@0.9.12
## 0.9.11
### Patch Changes

View File

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

View File

@@ -1,21 +1,5 @@
# 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
- 15d4b2a: Revert the custom logger
- Updated dependencies [15d4b2a]
- cojson@0.9.12
## 0.9.11
### Patch Changes

View File

@@ -1,12 +1,12 @@
{
"name": "cojson-transport-ws",
"type": "module",
"version": "0.9.13",
"version": "0.9.11",
"main": "dist/index.js",
"types": "src/index.ts",
"license": "MIT",
"dependencies": {
"cojson": "workspace:0.9.13",
"cojson": "workspace:0.9.11",
"typescript": "~5.6.2"
},
"scripts": {

View File

@@ -7,7 +7,7 @@ import {
logger,
} from "cojson";
import { BatchedOutgoingMessages } from "./BatchedOutgoingMessages.js";
import { deserializeMessages, getErrorMessage } from "./serialization.js";
import { deserializeMessages } from "./serialization.js";
import { AnyWebSocket } from "./types.js";
export const BUFFER_LIMIT = 100_000;
@@ -164,7 +164,9 @@ export function createWebSocketPeer({
if (!result.ok) {
logger.warn(
"Error while deserializing messages: " + getErrorMessage(result.error),
"Error while deserializing messages",
event.data,
result.error,
);
return;
}

View File

@@ -1,10 +1,6 @@
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);
@@ -28,7 +24,7 @@ export function deserializeMessages(messages: unknown) {
| PingMsg[],
} as const;
} catch (e) {
logger.error("Error while deserializing messages: " + getErrorMessage(e));
logger.error("Error while deserializing messages", e);
return {
ok: false,
error: e,

View File

@@ -1,17 +1,5 @@
# cojson
## 0.9.13
### Patch Changes
- 8d29e50: Restore the logger wrapper and adapt the API to pino
## 0.9.12
### Patch Changes
- 15d4b2a: Revert the custom logger
## 0.9.11
### Patch Changes

View File

@@ -24,7 +24,7 @@
},
"type": "module",
"license": "MIT",
"version": "0.9.13",
"version": "0.9.11",
"devDependencies": {
"@opentelemetry/sdk-metrics": "^1.29.0",
"@types/jest": "^29.5.3",

View File

@@ -93,7 +93,7 @@ export class PeerState {
this.processing = true;
let entry: QueueEntry<SyncMessage> | undefined;
let entry: QueueEntry | undefined;
while ((entry = this.queue.pull())) {
// Awaiting the push to send one message at a time
// This way when the peer is "under pressure" we can enqueue all
@@ -130,7 +130,7 @@ export class PeerState {
}
private closeQueue() {
let entry: QueueEntry<SyncMessage> | undefined;
let entry: QueueEntry | undefined;
while ((entry = this.queue.pull())) {
// Using resolve here to avoid unnecessary noise in the logs
entry.resolve();
@@ -138,10 +138,7 @@ export class PeerState {
}
gracefulShutdown() {
logger.debug("Gracefully closing", {
peerId: this.id,
peerRole: this.role,
});
logger.debug("Gracefully closing", this.id);
this.closeQueue();
this.peer.outgoing.close();
this.closed = true;

View File

@@ -18,12 +18,11 @@ function promiseWithResolvers<R>() {
};
}
export type QueueEntry<V> = {
msg: V;
export type QueueEntry = {
msg: SyncMessage;
promise: Promise<void>;
resolve: () => void;
reject: (_: unknown) => void;
next: QueueEntry<V> | undefined;
};
/**
@@ -34,68 +33,10 @@ type Tuple<T, N extends number, A extends unknown[] = []> = A extends {
}
? A
: Tuple<T, N, [...A, T]>;
type QueueTuple = Tuple<Queue<SyncMessage>, 8>;
class Queue<V> {
head: QueueEntry<V> | undefined = undefined;
tail: QueueEntry<V> | undefined = undefined;
push(msg: V) {
const { promise, resolve, reject } = promiseWithResolvers<void>();
const entry: QueueEntry<V> = {
msg,
promise,
resolve,
reject,
next: undefined,
};
if (this.head === undefined) {
this.head = entry;
} else {
if (this.tail === undefined) {
throw new Error("Tail is null but head is not");
}
this.tail.next = entry;
}
this.tail = entry;
return entry;
}
pull() {
const entry = this.head;
if (entry) {
this.head = entry.next;
}
if (this.head === undefined) {
this.tail = undefined;
}
return entry;
}
isNonEmpty() {
return this.head !== undefined;
}
}
type QueueTuple = Tuple<QueueEntry[], 8>;
export class PriorityBasedMessageQueue {
private queues: QueueTuple = [
new Queue(),
new Queue(),
new Queue(),
new Queue(),
new Queue(),
new Queue(),
new Queue(),
new Queue(),
];
private queues: QueueTuple = [[], [], [], [], [], [], [], []];
queueSizeCounter = metrics
.getMeter("cojson")
.createUpDownCounter("jazz.messagequeue.size", {
@@ -111,19 +52,22 @@ export class PriorityBasedMessageQueue {
constructor(private defaultPriority: CoValuePriority) {}
public push(msg: SyncMessage) {
const { promise, resolve, reject } = promiseWithResolvers<void>();
const entry: QueueEntry = { msg, promise, resolve, reject };
const priority = "priority" in msg ? msg.priority : this.defaultPriority;
const entry = this.getQueue(priority).push(msg);
this.getQueue(priority).push(entry);
this.queueSizeCounter.add(1, {
priority,
});
return entry.promise;
return promise;
}
public pull() {
const priority = this.queues.findIndex((queue) => queue.isNonEmpty());
const priority = this.queues.findIndex((queue) => queue.length > 0);
if (priority === -1) {
return;
@@ -133,6 +77,6 @@ export class PriorityBasedMessageQueue {
priority,
});
return this.queues[priority]?.pull();
return this.queues[priority]?.shift();
}
}

View File

@@ -304,10 +304,7 @@ async function loadCoValueFromPeers(
if (coValueEntry.state.type === "loading") {
const timeout = setTimeout(() => {
if (coValueEntry.state.type === "loading") {
logger.warn("Failed to load coValue from peer", {
peerId: peer.id,
peerRole: peer.role,
});
logger.warn("Failed to load coValue from peer", peer.id);
coValueEntry.dispatch({
type: "not-found-in-peer",
peerId: peer.id,

View File

@@ -60,7 +60,7 @@ export class RawAccount<
);
if (agents.length !== 1) {
logger.warn("Account has " + agents.length + " agents", { id: this.id });
logger.warn("Account has " + agents.length + " agents", this.id);
}
this._cachedCurrentAgentID = agents[0];

View File

@@ -322,7 +322,7 @@ export class RawGroup<
const secret = this.core.getReadKey(keyID);
if (!secret) {
logger.error("Can't find key " + keyID);
logger.error("Can't find key", keyID);
continue;
}

View File

@@ -193,9 +193,7 @@ export class PureJSCrypto extends CryptoProvider<Blake3State> {
try {
return JSON.parse(textDecoder.decode(plaintext));
} catch (e) {
logger.error(
"Failed to decrypt/parse sealed message: " + (e as Error)?.message,
);
logger.error("Failed to decrypt/parse sealed message", e);
return undefined;
}
}

View File

@@ -241,9 +241,8 @@ export class WasmCrypto extends CryptoProvider<Uint8Array> {
try {
return JSON.parse(textDecoder.decode(plaintext));
} catch (e) {
logger.error(
"Failed to decrypt/parse sealed message: " + (e as Error)?.message,
);
logger.error("Failed to decrypt/parse sealed message", e);
return undefined;
}
}
}

View File

@@ -160,7 +160,7 @@ export abstract class CryptoProvider<Blake3State = any> {
try {
return parseJSON(this.decryptRaw(encrypted, keySecret, nOnceMaterial));
} catch (e) {
logger.error("Decryption error: " + (e as Error)?.message);
logger.error("Decryption error", e);
return undefined;
}
}

View File

@@ -231,7 +231,7 @@ export class LocalNode {
return node;
} catch (e) {
logger.error("Error withLoadedAccount: " + (e as Error)?.message);
logger.error("Error withLoadedAccount", e);
throw e;
}
}
@@ -270,9 +270,7 @@ export class LocalNode {
this.syncManager.getServerAndStoragePeers(skipLoadingFromPeer);
await entry.loadFromPeers(peers).catch((e) => {
logger.error("Error loading from peers: " + (e as Error)?.message, {
id,
});
logger.error("Error loading from peers", id, e);
});
}
@@ -326,9 +324,7 @@ export class LocalNode {
unsubscribe = coValue.subscribe(callback);
})
.catch((e) => {
logger.error(
"Error subscribing to " + id + ": " + (e as Error)?.message,
);
logger.error("Error subscribing to ", id, e);
});
return () => {

View File

@@ -1,5 +1,3 @@
import type { JsonValue } from "./jsonValue.js";
export enum LogLevel {
DEBUG = 0,
INFO = 1,
@@ -9,25 +7,25 @@ export enum LogLevel {
}
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;
debug(message: string, ...args: any[]): void;
info(message: string, ...args: any[]): void;
warn(message: string, ...args: any[]): void;
error(message: string, ...args: any[]): void;
}
// Default console-based logging system
export class ConsoleLogSystem implements LogSystem {
debug(message: string, attributes?: Record<string, JsonValue>) {
console.debug(message, attributes);
debug(message: string, ...args: any[]) {
console.debug(message, ...args);
}
info(message: string, attributes?: Record<string, JsonValue>) {
console.info(message, attributes);
info(message: string, ...args: any[]) {
console.info(message, ...args);
}
warn(message: string, attributes?: Record<string, JsonValue>) {
console.warn(message, attributes);
warn(message: string, ...args: any[]) {
console.warn(message, ...args);
}
error(message: string, attributes?: Record<string, JsonValue>) {
console.error(message, attributes);
error(message: string, ...args: any[]) {
console.error(message, ...args);
}
}
@@ -51,27 +49,27 @@ export class Logger {
this.logSystem = logSystem;
}
debug(message: string, attributes?: Record<string, JsonValue>) {
debug(message: string, ...args: any[]) {
if (this.level <= LogLevel.DEBUG) {
this.logSystem.debug(message, attributes);
this.logSystem.debug(message, ...args);
}
}
info(message: string, attributes?: Record<string, JsonValue>) {
info(message: string, ...args: any[]) {
if (this.level <= LogLevel.INFO) {
this.logSystem.info(message, attributes);
this.logSystem.info(message, ...args);
}
}
warn(message: string, attributes?: Record<string, JsonValue>) {
warn(message: string, ...args: any[]) {
if (this.level <= LogLevel.WARN) {
this.logSystem.warn(message, attributes);
this.logSystem.warn(message, ...args);
}
}
error(message: string, attributes?: Record<string, JsonValue>) {
error(message: string, ...args: any[]) {
if (this.level <= LogLevel.ERROR) {
this.logSystem.error(message, attributes);
this.logSystem.error(message, ...args);
}
}
}

View File

@@ -42,15 +42,12 @@ export function disablePermissionErrors() {
logPermissionErrors = false;
}
function logPermissionError(
message: string,
attributes?: Record<string, JsonValue>,
) {
function logPermissionError(...args: unknown[]) {
if (logPermissionErrors === false) {
return;
}
logger.warn("Permission error: " + message, attributes);
logger.warn("Permission error", ...args);
}
export function determineValidTransactions(
@@ -230,10 +227,17 @@ function determineValidTransactionsForGroup(
try {
changes = parseJSON(tx.changes);
} catch (e) {
logPermissionError("Invalid JSON in transaction", {
id: coValue.id,
logPermissionError(
coValue.id,
"Invalid JSON in transaction",
e,
tx,
});
JSON.stringify(tx.changes, (k, v) =>
k === "changes" || k === "encryptedChanges"
? v.slice(0, 20) + "..."
: v,
),
);
continue;
}

View File

@@ -90,9 +90,8 @@ export class LSMStorage<WH, RH, FS extends FileSystem<WH, RH>> {
k === "changes" || k === "encryptedChanges"
? v.slice(0, 20) + "..."
: v,
)}
Error: ${e instanceof Error ? e.message : "Unknown error"},
`,
)}`,
e,
);
}
nMsg++;
@@ -242,7 +241,7 @@ export class LSMStorage<WH, RH, FS extends FileSystem<WH, RH>> {
} else {
const merged = mergeChunks(coValue, newContentAsChunk);
if (merged === "nonContigous") {
console.warn(
logger.warn(
"Non-contigous new content for " + newContent.id,
Object.entries(coValue.sessionEntries).map(([session, entries]) =>
entries.map((entry) => ({
@@ -317,7 +316,7 @@ export class LSMStorage<WH, RH, FS extends FileSystem<WH, RH>> {
const merged = mergeChunks(result, nextChunk);
if (merged === "nonContigous") {
console.warn(
logger.warn(
"Non-contigous chunks while loading " + id,
result,
nextChunk,
@@ -376,7 +375,7 @@ export class LSMStorage<WH, RH, FS extends FileSystem<WH, RH>> {
if (existingChunk) {
const merged = mergeChunks(existingChunk, chunk);
if (merged === "nonContigous") {
console.log(
logger.info(
"Non-contigous chunks in " + chunk.id + ", " + fileName,
existingChunk,
chunk,
@@ -450,7 +449,7 @@ export class LSMStorage<WH, RH, FS extends FileSystem<WH, RH>> {
if (existingChunk) {
const merged = mergeChunks(existingChunk, chunk);
if (merged === "nonContigous") {
console.log(
logger.info(
"Non-contigous chunks in " + entry.id + ", " + blockFile,
existingChunk,
chunk,

View File

@@ -23,10 +23,6 @@ export function emptyKnownState(id: RawCoID): CoValueKnownState {
};
}
function getErrorMessage(e: unknown) {
return e instanceof Error ? e.message : "Unknown error";
}
export type SyncMessage =
| LoadMessage
| KnownStateMessage
@@ -187,7 +183,7 @@ export class SyncManager {
if (entry.state.type !== "available") {
entry.loadFromPeers([peer]).catch((e: unknown) => {
logger.error("Error sending load: " + getErrorMessage(e));
logger.error("Error sending load", e);
});
return;
}
@@ -204,7 +200,7 @@ export class SyncManager {
action: "load",
...coValue.knownState(),
}).catch((e: unknown) => {
logger.error("Error sending load: " + getErrorMessage(e));
logger.error("Error sending load", e);
});
}
}
@@ -234,7 +230,7 @@ export class SyncManager {
asDependencyOf,
...coValue.knownState(),
}).catch((e: unknown) => {
logger.error("Error sending known state: " + getErrorMessage(e));
logger.error("Error sending known state", e);
});
peer.toldKnownState.add(id);
@@ -262,7 +258,7 @@ export class SyncManager {
let lastYield = performance.now();
for (const [_i, piece] of newContentPieces.entries()) {
this.trySendToPeer(peer, piece).catch((e: unknown) => {
logger.error("Error sending content piece: " + getErrorMessage(e));
logger.error("Error sending content piece", e);
});
if (performance.now() - lastYield > 10) {
@@ -335,10 +331,7 @@ export class SyncManager {
return;
}
if (msg === "PingTimeout") {
logger.error("Ping timeout from peer", {
peerId: peer.id,
peerRole: peer.role,
});
logger.error("Ping timeout from peer", peer.id);
return;
}
try {
@@ -361,22 +354,13 @@ export class SyncManager {
processMessages()
.then(() => {
if (peer.crashOnClose) {
logger.error("Unexepcted close from peer", {
peerId: peer.id,
peerRole: peer.role,
});
logger.warn("Unexepcted close from peer", peer.id);
this.local.crashed = new Error("Unexpected close from peer");
throw new Error("Unexpected close from peer");
}
})
.catch((e) => {
logger.error(
"Error processing messages from peer: " + getErrorMessage(e),
{
peerId: peer.id,
peerRole: peer.role,
},
);
logger.error("Error processing messages from peer", peer.id, e);
if (peer.crashOnClose) {
this.local.crashed = e;
throw new Error(e);
@@ -612,11 +596,17 @@ export class SyncManager {
// );
if (result.isErr()) {
logger.error("Failed to add transactions: " + result.error.type, {
peerId: peer.id,
peerRole: peer.role,
id: msg.id,
});
logger.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,
);
peer.erroredCoValues.set(msg.id, result.error);
continue;
}
@@ -637,13 +627,7 @@ export class SyncManager {
isCorrection: true,
...coValue.knownState(),
}).catch((e) => {
logger.error(
"Error sending known state correction: " + getErrorMessage(e),
{
peerId: peer.id,
peerRole: peer.role,
},
);
logger.error("Error sending known state correction", e);
});
} else {
/**
@@ -657,10 +641,7 @@ export class SyncManager {
action: "known",
...coValue.knownState(),
}).catch((e: unknown) => {
logger.error("Error sending known state: " + getErrorMessage(e), {
peerId: peer.id,
peerRole: peer.role,
});
logger.error("Error sending known state", e);
});
}

View File

@@ -22,7 +22,7 @@ describe("PriorityBasedMessageQueue", () => {
const { queue } = setup();
expect(queue["defaultPriority"]).toBe(CO_VALUE_PRIORITY.MEDIUM);
expect(queue["queues"].length).toBe(8);
expect(queue["queues"].every((q) => !q.isNonEmpty())).toBe(true);
expect(queue["queues"].every((q) => q.length === 0)).toBe(true);
});
test("should push message with default priority", async () => {

View File

@@ -20,14 +20,8 @@ describe("Logger", () => {
expect(mockLogSystem.debug).not.toHaveBeenCalled();
expect(mockLogSystem.info).not.toHaveBeenCalled();
expect(mockLogSystem.warn).toHaveBeenCalledWith(
"Warning message",
undefined,
);
expect(mockLogSystem.error).toHaveBeenCalledWith(
"Error message",
undefined,
);
expect(mockLogSystem.warn).toHaveBeenCalledWith("Warning message");
expect(mockLogSystem.error).toHaveBeenCalledWith("Error message");
});
test("should pass additional arguments to log system", () => {
@@ -39,12 +33,14 @@ describe("Logger", () => {
};
const logger = new Logger(LogLevel.DEBUG, mockLogSystem);
const additionalArgs = [{ foo: "bar" }, 42, "extra"];
logger.debug("Debug message", { foo: "bar" });
logger.debug("Debug message", ...additionalArgs);
expect(mockLogSystem.debug).toHaveBeenCalledWith("Debug message", {
foo: "bar",
});
expect(mockLogSystem.debug).toHaveBeenCalledWith(
"Debug message",
...additionalArgs,
);
});
});
@@ -64,7 +60,7 @@ describe("Logger", () => {
logger.setLevel(LogLevel.WARN);
logger.warn("Warning 2"); // Should log
expect(mockLogSystem.warn).toHaveBeenCalledWith("Warning 2", undefined);
expect(mockLogSystem.warn).toHaveBeenCalledWith("Warning 2");
});
test("should allow changing log system at runtime", () => {
@@ -85,12 +81,12 @@ describe("Logger", () => {
const logger = new Logger(LogLevel.INFO, mockLogSystem1);
logger.info("Message 1");
expect(mockLogSystem1.info).toHaveBeenCalledWith("Message 1", undefined);
expect(mockLogSystem1.info).toHaveBeenCalledWith("Message 1");
expect(mockLogSystem2.info).not.toHaveBeenCalled();
logger.setLogSystem(mockLogSystem2);
logger.info("Message 2");
expect(mockLogSystem2.info).toHaveBeenCalledWith("Message 2", undefined);
expect(mockLogSystem2.info).toHaveBeenCalledWith("Message 2");
expect(mockLogSystem1.info).toHaveBeenCalledTimes(1);
});
});
@@ -107,17 +103,17 @@ describe("Logger", () => {
const logger = new Logger();
logger.setLevel(LogLevel.DEBUG);
const testMessage = "Test message";
const testArgs = { data: "test" };
const testArgs = [{ data: "test" }, 123];
logger.debug(testMessage, testArgs);
logger.info(testMessage, testArgs);
logger.warn(testMessage, testArgs);
logger.error(testMessage, testArgs);
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);
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());

View File

@@ -1,11 +1,5 @@
# create-jazz-app
## 0.1.8
### Patch Changes
- 0fc4f24: fix create-jazz-app fails if no starter param
## 0.1.7
### Patch Changes

View File

@@ -5,7 +5,7 @@
"types": "src/index.ts",
"type": "module",
"license": "MIT",
"version": "0.1.8",
"version": "0.1.7",
"bin": {
"create-jazz-app": "./dist/index.js"
},

View File

@@ -263,8 +263,7 @@ async function promptUser(
return {
...answers,
...partialOptions,
template:
answers.starter || partialOptions.starter || partialOptions.example,
template: partialOptions.starter || partialOptions.example,
} as ScaffoldOptions;
}

View File

@@ -1,50 +1,5 @@
# jazz-browser-media-images
## 0.9.16
### Patch Changes
- 24b3b6a: Extract friendly user name for profile creation when authenticating using Clerk with a regular email address.
Email passed to creationProps when using Clerk auth
Clear stored Clerk credentials on logout
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-browser@0.9.16
## 0.9.15
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-browser@0.9.15
## 0.9.14
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-browser@0.9.14
## 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
- Updated dependencies [15d4b2a]
- cojson@0.9.12
- jazz-browser@0.9.12
- jazz-tools@0.9.12
## 0.9.11
### Patch Changes

View File

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

View File

@@ -1,6 +1,8 @@
import { AgentSecret } from "cojson";
import { Account, AuthMethod, AuthResult, Credentials, ID } from "jazz-tools";
const localStorageKey = "jazz-clerk-auth";
export type MinimalClerkClient = {
user:
| {
@@ -8,10 +10,6 @@ export type MinimalClerkClient = {
unsafeMetadata: Record<string, any>;
fullName: string | null;
username: string | null;
firstName: string | null;
primaryEmailAddress: {
emailAddress: string;
} | null;
id: string;
update: (args: {
// eslint-disable-next-line @typescript-eslint/no-explicit-any
@@ -23,8 +21,6 @@ export type MinimalClerkClient = {
signOut: () => Promise<void>;
};
const localStorageKey = "jazz-clerk-auth";
function saveCredentialsToLocalStorage(credentials: Credentials) {
localStorage.setItem(
localStorageKey,
@@ -35,10 +31,6 @@ function saveCredentialsToLocalStorage(credentials: Credentials) {
);
}
function clearStoredCredentials() {
localStorage.removeItem(localStorageKey);
}
export class BrowserClerkAuth implements AuthMethod {
constructor(
public driver: BrowserClerkAuth.Driver,
@@ -46,21 +38,8 @@ export class BrowserClerkAuth implements AuthMethod {
) {}
async start(): Promise<AuthResult> {
// clear localStorage if the current Clerk user doesn't match stored credentials
let locallyStoredCredentials = localStorage.getItem(localStorageKey);
if (locallyStoredCredentials && this.clerkClient.user) {
try {
const stored = JSON.parse(locallyStoredCredentials);
const clerkMetadata = this.clerkClient.user.unsafeMetadata;
if (clerkMetadata.jazzAccountID !== stored.accountID) {
clearStoredCredentials();
}
} catch (e) {
clearStoredCredentials();
}
}
locallyStoredCredentials = localStorage.getItem(localStorageKey);
// Check local storage for credentials
const locallyStoredCredentials = localStorage.getItem(localStorageKey);
if (locallyStoredCredentials) {
try {
@@ -74,7 +53,7 @@ export class BrowserClerkAuth implements AuthMethod {
this.driver.onError(error);
},
logOut: () => {
clearStoredCredentials();
localStorage.removeItem(localStorageKey);
void this.clerkClient.signOut();
},
};
@@ -107,7 +86,6 @@ export class BrowserClerkAuth implements AuthMethod {
this.driver.onError(error);
},
logOut: () => {
clearStoredCredentials();
void this.clerkClient.signOut();
},
};
@@ -118,15 +96,8 @@ export class BrowserClerkAuth implements AuthMethod {
creationProps: {
name:
this.clerkClient.user.fullName ||
this.clerkClient.user.firstName ||
this.clerkClient.user.username ||
this.clerkClient.user.primaryEmailAddress?.emailAddress?.split(
"@",
)[0] ||
this.clerkClient.user.id,
other: {
email: this.clerkClient.user.primaryEmailAddress?.emailAddress,
},
},
saveCredentials: async ({ accountID, secret }: Credentials) => {
saveCredentialsToLocalStorage({
@@ -145,7 +116,6 @@ export class BrowserClerkAuth implements AuthMethod {
this.driver.onError(error);
},
logOut: () => {
clearStoredCredentials();
void this.clerkClient.signOut();
},
};

View File

@@ -30,8 +30,6 @@ describe("BrowserClerkAuth", () => {
unsafeMetadata: {},
fullName: "Test User",
username: "testuser",
firstName: null,
primaryEmailAddress: null,
id: "test-id",
update: vi.fn(),
},
@@ -77,8 +75,6 @@ describe("BrowserClerkAuth", () => {
},
fullName: "Test User",
username: "testuser",
firstName: null,
primaryEmailAddress: null,
id: "test-id",
update: vi.fn(),
},
@@ -119,68 +115,5 @@ describe("BrowserClerkAuth", () => {
expect(mockClerkClient.signOut).toHaveBeenCalled();
});
it("should resolve name from available user fields", async () => {
const testCases = [
{
user: {
unsafeMetadata: {},
fullName: "Full Name",
firstName: null,
username: null,
primaryEmailAddress: null,
id: "test-id",
update: vi.fn(),
},
expected: "Full Name",
},
{
user: {
unsafeMetadata: {},
fullName: null,
firstName: "First",
username: null,
primaryEmailAddress: null,
id: "test-id",
update: vi.fn(),
},
expected: "First",
},
{
user: {
unsafeMetadata: {},
fullName: null,
firstName: null,
username: "username123",
primaryEmailAddress: null,
id: "test-id",
update: vi.fn(),
},
expected: "username123",
},
{
user: {
unsafeMetadata: {},
fullName: null,
firstName: null,
username: null,
primaryEmailAddress: { emailAddress: "test@example.com" },
id: "test-id",
update: vi.fn(),
},
expected: "test",
},
];
for (const { user, expected } of testCases) {
const auth = new BrowserClerkAuth(mockDriver, {
...mockClerkClient,
user,
});
const result = await auth.start();
expect(result.type).toBe("new");
expect((result as any).creationProps.name).toBe(expected);
}
});
});
});

View File

@@ -1,43 +1,5 @@
# jazz-browser-media-images
## 0.9.16
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-browser@0.9.16
## 0.9.15
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-browser@0.9.15
## 0.9.14
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-browser@0.9.14
## 0.9.13
### Patch Changes
- jazz-browser@0.9.13
- jazz-tools@0.9.13
## 0.9.12
### Patch Changes
- jazz-browser@0.9.12
- jazz-tools@0.9.12
## 0.9.11
### Patch Changes

View File

@@ -1,6 +1,6 @@
{
"name": "jazz-browser-media-images",
"version": "0.9.16",
"version": "0.9.11",
"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.16",
"jazz-tools": "workspace:0.9.16",
"jazz-browser": "workspace:0.9.11",
"jazz-tools": "workspace:0.9.11",
"pica": "^9.0.1",
"typescript": "~5.6.2"
},

View File

@@ -1,46 +1,5 @@
# jazz-browser
## 0.9.16
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
## 0.9.15
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
## 0.9.14
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
## 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
- Updated dependencies [15d4b2a]
- cojson-transport-ws@0.9.12
- cojson@0.9.12
- cojson-storage-indexeddb@0.9.12
- jazz-tools@0.9.12
## 0.9.11
### Patch Changes

View File

@@ -1,16 +1,16 @@
{
"name": "jazz-browser",
"version": "0.9.16",
"version": "0.9.11",
"type": "module",
"main": "dist/index.js",
"types": "src/index.ts",
"license": "MIT",
"dependencies": {
"@scure/bip39": "^1.3.0",
"cojson": "workspace:0.9.13",
"cojson-storage-indexeddb": "workspace:0.9.13",
"cojson-transport-ws": "workspace:0.9.13",
"jazz-tools": "workspace:0.9.16",
"cojson": "workspace:0.9.11",
"cojson-storage-indexeddb": "workspace:0.9.11",
"cojson-transport-ws": "workspace:0.9.11",
"jazz-tools": "workspace:0.9.11",
"typescript": "~5.6.2"
},
"scripts": {

View File

@@ -1,47 +1,5 @@
# jazz-inspector
## 0.9.16
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-react-core@0.8.57
## 0.9.15
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-react-core@0.8.56
## 0.9.14
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-react-core@0.8.55
## 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
- Updated dependencies [15d4b2a]
- cojson@0.9.12
- jazz-react-core@0.8.53
- jazz-tools@0.9.12
## 0.9.11
### Patch Changes

View File

@@ -1,6 +1,6 @@
{
"name": "jazz-inspector",
"version": "0.9.16",
"version": "0.9.11",
"type": "module",
"main": "./dist/jazz-inspector.js",
"types": "./src/app.tsx",

View File

@@ -1,44 +1,5 @@
# jazz-autosub
## 0.9.16
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
## 0.9.15
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
## 0.9.14
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
## 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
- Updated dependencies [15d4b2a]
- cojson-transport-ws@0.9.12
- cojson@0.9.12
- jazz-tools@0.9.12
## 0.9.11
### Patch Changes

View File

@@ -5,11 +5,11 @@
"types": "src/index.ts",
"type": "module",
"license": "MIT",
"version": "0.9.16",
"version": "0.9.11",
"dependencies": {
"cojson": "workspace:0.9.13",
"cojson-transport-ws": "workspace:0.9.13",
"jazz-tools": "workspace:0.9.16",
"cojson": "workspace:0.9.11",
"cojson-transport-ws": "workspace:0.9.11",
"jazz-tools": "workspace:0.9.11",
"ws": "^8.14.2"
},
"devDependencies": {

View File

@@ -1,76 +0,0 @@
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();
});
});

View File

@@ -3,6 +3,7 @@ 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();

View File

@@ -1,55 +1,5 @@
# jazz-browser-media-images
## 0.9.16
### Patch Changes
- 24b3b6a: Extract friendly user name for profile creation when authenticating using Clerk with a regular email address.
Email passed to creationProps when using Clerk auth
Clear stored Clerk credentials on logout
- Updated dependencies [24b3b6a]
- jazz-browser-auth-clerk@0.9.16
- jazz-tools@0.9.16
- jazz-react@0.9.16
## 0.9.15
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-browser-auth-clerk@0.9.15
- jazz-react@0.9.15
## 0.9.14
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-browser-auth-clerk@0.9.14
- jazz-react@0.9.14
## 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
- Updated dependencies [15d4b2a]
- cojson@0.9.12
- jazz-browser-auth-clerk@0.9.12
- jazz-react@0.9.12
- jazz-tools@0.9.12
## 0.9.11
### Patch Changes

View File

@@ -1,15 +1,15 @@
{
"name": "jazz-react-auth-clerk",
"version": "0.9.16",
"version": "0.9.11",
"type": "module",
"main": "dist/index.js",
"types": "src/index.tsx",
"license": "MIT",
"dependencies": {
"cojson": "workspace:0.9.13",
"jazz-browser-auth-clerk": "workspace:0.9.16",
"jazz-react": "workspace:0.9.16",
"jazz-tools": "workspace:0.9.16"
"cojson": "workspace:0.9.11",
"jazz-browser-auth-clerk": "workspace:0.9.11",
"jazz-react": "workspace:0.9.11",
"jazz-tools": "workspace:0.9.11"
},
"peerDependencies": {
"react": "^18.2.0"

View File

@@ -1,7 +1,14 @@
import { BrowserClerkAuth, MinimalClerkClient } from "jazz-browser-auth-clerk";
import {
BrowserClerkAuth,
type MinimalClerkClient,
} from "jazz-browser-auth-clerk";
import { useMemo, useState } from "react";
export function useJazzClerkAuth(clerk: MinimalClerkClient) {
export function useJazzClerkAuth(
clerk: MinimalClerkClient & {
signOut: () => Promise<unknown>;
},
) {
const [state, setState] = useState<{ errors: string[] }>({ errors: [] });
const authMethod = useMemo(() => {

View File

@@ -1,42 +1,5 @@
# jazz-react-core
## 0.8.57
### Patch Changes
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
## 0.8.56
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
## 0.8.55
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
## 0.8.54
### Patch Changes
- Updated dependencies [8d29e50]
- cojson@0.9.13
- jazz-tools@0.9.13
## 0.8.53
### Patch Changes
- Updated dependencies [15d4b2a]
- cojson@0.9.12
- jazz-tools@0.9.12
## 0.8.52
### Patch Changes

View File

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

View File

@@ -22,5 +22,4 @@ export {
createJazzTestGuest,
linkAccounts,
setActiveAccount,
setupJazzTestSync,
} from "jazz-tools/testing";

View File

@@ -1,50 +1,5 @@
# jazz-react-native-auth-clerk
## 0.9.16
### Patch Changes
- 24b3b6a: Extract friendly user name for profile creation when authenticating using Clerk with a regular email address.
Email passed to creationProps when using Clerk auth
Clear stored Clerk credentials on logout
- Updated dependencies [24b3b6a]
- jazz-tools@0.9.16
- jazz-react-native@0.9.16
## 0.9.15
### Patch Changes
- Updated dependencies [7491711]
- jazz-tools@0.9.15
- jazz-react-native@0.9.15
## 0.9.14
### Patch Changes
- Updated dependencies [3df93cc]
- jazz-tools@0.9.14
- jazz-react-native@0.9.14
## 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
- Updated dependencies [15d4b2a]
- cojson@0.9.12
- jazz-react-native@0.9.12
- jazz-tools@0.9.12
## 0.9.11
### Patch Changes

View File

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

Some files were not shown because too many files have changed in this diff Show More