From 49629d2177be1b5b2756bd36aa3d93721a5227d7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Hanno=20J=2E=20G=C3=B6decke?= Date: Tue, 30 Jul 2024 18:06:44 +0200 Subject: [PATCH 1/5] add failing test --- tests/unit/onyxTest.ts | 32 ++++++++++++++++++++++++++++++++ 1 file changed, 32 insertions(+) diff --git a/tests/unit/onyxTest.ts b/tests/unit/onyxTest.ts index 5b8ceb8d..f5abb204 100644 --- a/tests/unit/onyxTest.ts +++ b/tests/unit/onyxTest.ts @@ -9,6 +9,8 @@ import type GenericCollection from '../utils/GenericCollection'; const ONYX_KEYS = { TEST_KEY: 'test', OTHER_TEST: 'otherTest', + // Special case: this key is not a collection key, but it has an underscore in its name + KEY_WITH_UNDERSCORE: 'nvp_test', COLLECTION: { TEST_KEY: 'test_', TEST_CONNECT_COLLECTION: 'testConnectCollection_', @@ -25,6 +27,7 @@ Onyx.init({ keys: ONYX_KEYS, initialKeyStates: { [ONYX_KEYS.OTHER_TEST]: 42, + [ONYX_KEYS.KEY_WITH_UNDERSCORE]: 'default', }, }); @@ -199,6 +202,35 @@ describe('Onyx', () => { }); }); + it('should notify key subscribers that use a underscore in their name', () => { + const mockCallback = jest.fn(); + connectionID = Onyx.connect({ + key: ONYX_KEYS.KEY_WITH_UNDERSCORE, + callback: mockCallback, + }); + + return waitForPromisesToResolve() + .then(() => mockCallback.mockReset()) + .then(() => Onyx.set(ONYX_KEYS.KEY_WITH_UNDERSCORE, 'test')) + .then(() => { + expect(mockCallback).toHaveBeenCalledTimes(1); + expect(mockCallback).toHaveBeenLastCalledWith('test', ONYX_KEYS.KEY_WITH_UNDERSCORE); + mockCallback.mockReset(); + return Onyx.clear(); + }) + .then(() => { + expect(mockCallback).toHaveBeenCalledTimes(1); + expect(mockCallback).toHaveBeenCalledWith('default', ONYX_KEYS.KEY_WITH_UNDERSCORE); + }) + .then(() => Onyx.set(ONYX_KEYS.KEY_WITH_UNDERSCORE, 'default')) + .then(() => mockCallback.mockReset()) + .then(() => Onyx.set(ONYX_KEYS.KEY_WITH_UNDERSCORE, 'test')) + .then(() => { + expect(mockCallback).toHaveBeenCalledTimes(1); + expect(mockCallback).toHaveBeenCalledWith('test', ONYX_KEYS.KEY_WITH_UNDERSCORE); + }); + }); + it('should not notify subscribers after they have disconnected', () => { let testKeyValue: unknown; connectionID = Onyx.connect({ From 219b117a9dc80978e4a95659d149a14b2d011b34 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Hanno=20J=2E=20G=C3=B6decke?= Date: Tue, 30 Jul 2024 21:56:04 +0200 Subject: [PATCH 2/5] fix: Onyx.clear handle collections correctly --- lib/Onyx.ts | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/lib/Onyx.ts b/lib/Onyx.ts index f927f353..bac64805 100644 --- a/lib/Onyx.ts +++ b/lib/Onyx.ts @@ -586,12 +586,14 @@ function clear(keysToPreserve: OnyxKey[] = []): Promise { const newValue = defaultKeyStates[key] ?? null; if (newValue !== oldValue) { cache.set(key, newValue); - const collectionKey = key.substring(0, key.indexOf('_') + 1); - if (collectionKey) { + + const potentialCollectionKey = OnyxUtils.getCollectionKey(key); + if (OnyxUtils.isCollectionKey(potentialCollectionKey)) { + const [collectionKey, memberKey] = OnyxUtils.splitCollectionMemberKey(key); if (!keyValuesToResetAsCollection[collectionKey]) { keyValuesToResetAsCollection[collectionKey] = {}; } - keyValuesToResetAsCollection[collectionKey]![key] = newValue ?? undefined; + keyValuesToResetAsCollection[collectionKey]![memberKey] = newValue ?? undefined; } else { keyValuesToResetIndividually[key] = newValue ?? undefined; } @@ -612,6 +614,7 @@ function clear(keysToPreserve: OnyxKey[] = []): Promise { Object.entries(keyValuesToResetIndividually).forEach(([key, value]) => { updatePromises.push(OnyxUtils.scheduleSubscriberUpdate(key, value, cache.get(key, false))); }); + console.log(keyValuesToResetAsCollection); Object.entries(keyValuesToResetAsCollection).forEach(([key, value]) => { updatePromises.push(OnyxUtils.scheduleNotifyCollectionSubscribers(key, value)); }); From ff482576d944dd9134450cdb2deb38c4555a0098 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Hanno=20J=2E=20G=C3=B6decke?= Date: Tue, 30 Jul 2024 21:56:16 +0200 Subject: [PATCH 3/5] cleanup splitCollectionMemberKey --- lib/OnyxUtils.ts | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/lib/OnyxUtils.ts b/lib/OnyxUtils.ts index cac8b0b1..48f42258 100644 --- a/lib/OnyxUtils.ts +++ b/lib/OnyxUtils.ts @@ -403,14 +403,16 @@ function isCollectionMemberKey(collect * @param key - The collection member key to split. * @returns A tuple where the first element is the collection part and the second element is the ID part. */ -function splitCollectionMemberKey(key: TKey): [TKey extends `${infer Prefix}_${string}` ? `${Prefix}_` : never, string] { +function splitCollectionMemberKey(key: TKey): [CollectionKeyType, string] { const underscoreIndex = key.lastIndexOf('_'); if (underscoreIndex === -1) { throw new Error(`Invalid ${key} key provided, only collection keys are allowed.`); } - return [key.substring(0, underscoreIndex + 1) as TKey extends `${infer Prefix}_${string}` ? `${Prefix}_` : never, key.substring(underscoreIndex + 1)]; + const collectionKey = key.substring(0, underscoreIndex + 1) as CollectionKeyType; + const memberKey = key.substring(underscoreIndex + 1); + return [collectionKey, memberKey]; } /** From 63d5a7b7fcd477cd81f28837f0176531163d920f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Hanno=20J=2E=20G=C3=B6decke?= Date: Tue, 30 Jul 2024 22:01:54 +0200 Subject: [PATCH 4/5] remove debug log --- lib/Onyx.ts | 1 - 1 file changed, 1 deletion(-) diff --git a/lib/Onyx.ts b/lib/Onyx.ts index bac64805..5e5e55b7 100644 --- a/lib/Onyx.ts +++ b/lib/Onyx.ts @@ -614,7 +614,6 @@ function clear(keysToPreserve: OnyxKey[] = []): Promise { Object.entries(keyValuesToResetIndividually).forEach(([key, value]) => { updatePromises.push(OnyxUtils.scheduleSubscriberUpdate(key, value, cache.get(key, false))); }); - console.log(keyValuesToResetAsCollection); Object.entries(keyValuesToResetAsCollection).forEach(([key, value]) => { updatePromises.push(OnyxUtils.scheduleNotifyCollectionSubscribers(key, value)); }); From 8de144757e3b30caf9a205d900733f4302a05a5e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Hanno=20J=2E=20G=C3=B6decke?= Date: Tue, 30 Jul 2024 22:08:00 +0200 Subject: [PATCH 5/5] fix use full collection member key as object key --- lib/Onyx.ts | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/lib/Onyx.ts b/lib/Onyx.ts index 5e5e55b7..aef24863 100644 --- a/lib/Onyx.ts +++ b/lib/Onyx.ts @@ -587,13 +587,12 @@ function clear(keysToPreserve: OnyxKey[] = []): Promise { if (newValue !== oldValue) { cache.set(key, newValue); - const potentialCollectionKey = OnyxUtils.getCollectionKey(key); - if (OnyxUtils.isCollectionKey(potentialCollectionKey)) { - const [collectionKey, memberKey] = OnyxUtils.splitCollectionMemberKey(key); + const collectionKey = OnyxUtils.getCollectionKey(key); + if (OnyxUtils.isCollectionKey(collectionKey)) { if (!keyValuesToResetAsCollection[collectionKey]) { keyValuesToResetAsCollection[collectionKey] = {}; } - keyValuesToResetAsCollection[collectionKey]![memberKey] = newValue ?? undefined; + keyValuesToResetAsCollection[collectionKey]![key] = newValue ?? undefined; } else { keyValuesToResetIndividually[key] = newValue ?? undefined; }