@tldraw/tlstore - npm Package Compare versions

Comparing version 2.0.0-canary.a722e3e6f079 to 2.0.0-canary.a824168e0a98

dist-cjs/index.d.ts

@@ -568,2 +568,3 @@ import { Atom } from 'signia';
     createSelectedComputedCache: <T, J, V extends R = R>(name: string, selector: (record: V) => T | undefined, derive: (input: T) => J | undefined) => ComputedCache<J, V>;
+    private _integrityChecker?;
     /* Excluded from this release type: ensureStoreIsUsable */
@@ -687,3 +688,3 @@ private _isPossiblyCorrupted;
     migrateStoreSnapshot(storeSnapshot: StoreSnapshot<R>, persistedSchema: SerializedSchema): MigrationResult<StoreSnapshot<R>>;
-    /* Excluded from this release type: ensureStoreIsUsable */
+    /* Excluded from this release type: createIntegrityChecker */
     /* Excluded from this release type: derivePresenceState */
@@ -706,3 +707,3 @@ serialize(): SerializedSchema;
     }) => R;
-    /* Excluded from this release type: ensureStoreIsUsable */
+    /* Excluded from this release type: createIntegrityChecker */
     /* Excluded from this release type: derivePresenceState */
@@ -709,0 +710,0 @@ };

dist-cjs/lib/Store.js

@@ -26,2 +26,3 @@ "use strict";
 module.exports = __toCommonJS(Store_exports);
+var import_utils = require("@tldraw/utils");
 var import_signia = require("signia");
@@ -96,3 +97,3 @@ var import_Cache = require("./Cache");
       },
-      { scheduleEffect: (cb) => requestAnimationFrame(cb) }
+      { scheduleEffect: (cb) => (0, import_utils.throttledRaf)(cb) }
     );
@@ -468,5 +469,7 @@ }
   };
+  _integrityChecker;
   /** @internal */
   ensureStoreIsUsable() {
-    this.schema.ensureStoreIsUsable(this);
+    this._integrityChecker ??= this.schema.createIntegrityChecker(this);
+    this._integrityChecker?.();
   }
@@ -473,0 +476,0 @@ _isPossiblyCorrupted = false;

dist-cjs/lib/StoreSchema.js

@@ -150,4 +150,4 @@ "use strict";
   /** @internal */
-  ensureStoreIsUsable(store) {
-    this.options.ensureStoreIsUsable?.(store);
+  createIntegrityChecker(store) {
+    return this.options.createIntegrityChecker?.(store) ?? void 0;
   }
@@ -154,0 +154,0 @@ /** @internal */

package.json

 {
   "name": "@tldraw/tlstore",
   "description": "A tiny little drawing app (store).",
-  "version": "2.0.0-canary.a722e3e6f079",
+  "version": "2.0.0-canary.a824168e0a98",
   "packageManager": "yarn@3.5.0",
@@ -37,3 +37,3 @@ "author": {
     "test-coverage": "lazy inherit",
-    "build-package": "yarn run -T tsx ../../scripts/build-package.ts",
+    "build": "yarn run -T tsx ../../scripts/build-package.ts",
     "build-api": "yarn run -T tsx ../../scripts/build-api.ts",
@@ -46,3 +46,3 @@ "prepack": "yarn run -T tsx ../../scripts/prepack.ts",
   "dependencies": {
-    "@tldraw/utils": "2.0.0-canary.a722e3e6f079",
+    "@tldraw/utils": "2.0.0-canary.a824168e0a98",
     "lodash.isequal": "^4.5.0",
@@ -49,0 +49,0 @@ "nanoid": "4.0.2"

src/lib/Store.ts

@@ -0,1 +1,2 @@
+import { throttledRaf } from '@tldraw/utils'
 import { atom, Atom, computed, Computed, Reactor, reactor, transact } from 'signia'
@@ -175,3 +176,3 @@ import { BaseRecord, ID } from './BaseRecord'
 			},
-			{ scheduleEffect: (cb) => requestAnimationFrame(cb) }
+			{ scheduleEffect: (cb) => throttledRaf(cb) }
 		)
@@ -625,5 +626,8 @@ }
 
+	private _integrityChecker?: () => void | undefined
+
 	/** @internal */
 	ensureStoreIsUsable() {
-		this.schema.ensureStoreIsUsable(this)
+		this._integrityChecker ??= this.schema.createIntegrityChecker(this)
+		this._integrityChecker?.()
 	}
@@ -630,0 +634,0 @@

src/lib/StoreSchema.ts

@@ -51,3 +51,3 @@ import { getOwnProperty, objectMapValues } from '@tldraw/utils'
 	/** @internal */
-	ensureStoreIsUsable?: (store: Store<R, P>) => void
+	createIntegrityChecker?: (store: Store<R, P>) => void
 	/** @internal */
@@ -244,4 +244,4 @@ derivePresenceState?: (store: Store<R, P>) => Signal<R | null>
 	/** @internal */
-	ensureStoreIsUsable(store: Store<R, P>): void {
-		this.options.ensureStoreIsUsable?.(store)
+	createIntegrityChecker(store: Store<R, P>): (() => void) | undefined {
+		return this.options.createIntegrityChecker?.(store) ?? undefined
 	}
@@ -248,0 +248,0 @@

src/lib/test/recordStore.test.ts

@@ -472,22 +472,29 @@ import { Computed, react, RESET_VALUE, transact } from 'signia'
 	it('flushes history before attaching listeners', async () => {
-		store.put([Author.create({ name: 'J.R.R Tolkein', id: Author.createCustomId('tolkein') })])
-		const firstListener = jest.fn()
-		store.listen(firstListener)
-		expect(firstListener).toHaveBeenCalledTimes(0)
+		try {
+			// @ts-expect-error
+			globalThis.__FORCE_RAF_IN_TESTS__ = true
+			store.put([Author.create({ name: 'J.R.R Tolkein', id: Author.createCustomId('tolkein') })])
+			const firstListener = jest.fn()
+			store.listen(firstListener)
+			expect(firstListener).toHaveBeenCalledTimes(0)
 
-		store.put([Author.create({ name: 'Chips McCoy', id: Author.createCustomId('chips') })])
+			store.put([Author.create({ name: 'Chips McCoy', id: Author.createCustomId('chips') })])
 
-		expect(firstListener).toHaveBeenCalledTimes(0)
+			expect(firstListener).toHaveBeenCalledTimes(0)
 
-		const secondListener = jest.fn()
+			const secondListener = jest.fn()
 
-		store.listen(secondListener)
+			store.listen(secondListener)
 
-		expect(firstListener).toHaveBeenCalledTimes(1)
-		expect(secondListener).toHaveBeenCalledTimes(0)
+			expect(firstListener).toHaveBeenCalledTimes(1)
+			expect(secondListener).toHaveBeenCalledTimes(0)
 
-		await new Promise((resolve) => requestAnimationFrame(resolve))
+			await new Promise((resolve) => requestAnimationFrame(resolve))
 
-		expect(firstListener).toHaveBeenCalledTimes(1)
-		expect(secondListener).toHaveBeenCalledTimes(0)
+			expect(firstListener).toHaveBeenCalledTimes(1)
+			expect(secondListener).toHaveBeenCalledTimes(0)
+		} finally {
+			// @ts-expect-error
+			globalThis.__FORCE_RAF_IN_TESTS__ = false
+		}
 	})
@@ -494,0 +501,0 @@

No alert changes

Improved metrics

Total package byte prevSize

533545

increased by0.24%

Lines of code

9167

increased by0.19%

Dependency changes

• + Added@tldraw/utils@2.0.0-canary.a824168e0a98(transitive)

• - Removed@tldraw/utils@2.0.0-canary.a722e3e6f079(transitive)

• Updated@tldraw/utils@2.0.0-canary.a824168e0a98