Merge pull request #5356 from ConnectAI-E/feature/indexdb

fix: hydrated for indexedDB
This commit is contained in:
Lloyd Zhou 2024-09-04 19:14:18 +08:00 committed by GitHub
commit 85704570f3
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 19 additions and 1 deletions

View File

@ -4,7 +4,8 @@ import { get, set, del, clear } from "idb-keyval";
class IndexedDBStorage implements StateStorage { class IndexedDBStorage implements StateStorage {
public async getItem(name: string): Promise<string | null> { public async getItem(name: string): Promise<string | null> {
try { try {
return (await get(name)) || localStorage.getItem(name); const value = (await get(name)) || localStorage.getItem(name);
return value;
} catch (error) { } catch (error) {
return localStorage.getItem(name); return localStorage.getItem(name);
} }
@ -12,6 +13,11 @@ class IndexedDBStorage implements StateStorage {
public async setItem(name: string, value: string): Promise<void> { public async setItem(name: string, value: string): Promise<void> {
try { try {
const _value = JSON.parse(value);
if (!_value?.state?._hasHydrated) {
console.warn("skip setItem", name);
return;
}
await set(name, value); await set(name, value);
} catch (error) { } catch (error) {
localStorage.setItem(name, value); localStorage.setItem(name, value);

View File

@ -14,9 +14,11 @@ type SecondParam<T> = T extends (
type MakeUpdater<T> = { type MakeUpdater<T> = {
lastUpdateTime: number; lastUpdateTime: number;
_hasHydrated: boolean;
markUpdate: () => void; markUpdate: () => void;
update: Updater<T>; update: Updater<T>;
setHasHydrated: (state: boolean) => void;
}; };
type SetStoreState<T> = ( type SetStoreState<T> = (
@ -33,12 +35,19 @@ export function createPersistStore<T extends object, M>(
persistOptions: SecondParam<typeof persist<T & M & MakeUpdater<T>>>, persistOptions: SecondParam<typeof persist<T & M & MakeUpdater<T>>>,
) { ) {
persistOptions.storage = createJSONStorage(() => indexedDBStorage); persistOptions.storage = createJSONStorage(() => indexedDBStorage);
const oldOonRehydrateStorage = persistOptions?.onRehydrateStorage;
persistOptions.onRehydrateStorage = (state) => {
oldOonRehydrateStorage?.(state);
return () => state.setHasHydrated(true);
};
return create( return create(
persist( persist(
combine( combine(
{ {
...state, ...state,
lastUpdateTime: 0, lastUpdateTime: 0,
_hasHydrated: false,
}, },
(set, get) => { (set, get) => {
return { return {
@ -57,6 +66,9 @@ export function createPersistStore<T extends object, M>(
lastUpdateTime: Date.now(), lastUpdateTime: Date.now(),
}); });
}, },
setHasHydrated: (state: boolean) => {
set({ _hasHydrated: state } as Partial<T & M & MakeUpdater<T>>);
},
} as M & MakeUpdater<T>; } as M & MakeUpdater<T>;
}, },
), ),