dexie-solid.ts

export function createDexieStore<T extends StoreNode>(
    querier: () => T | undefined | Promise<T | undefined>,
): WithLoadingState<T> {
    const [store, setStore] = createStore<WithLoadingState<T>>({
        __loading: true,
    });
    const observable = liveQuery(querier);
    const signal = from<T | undefined>(observable);
    createEffect(() => {
        const data = signal();
        if (data) {
            setStore(reconcile({ ...data, __loading: false }, { merge: true }));
        }
    });
    return store;
}

export function createDexieResource<T extends StoreNode>(
    querier: () => T | undefined | Promise<T | undefined>,
): ResourceReturn<T> {
    const store = createDexieStore(querier);
    let loaded = false;
    return createResource(store, (theStore) => {
        if (theStore.__loading) {
            return new Promise((resolve) => {
                createEffect(() => {
                    if (!store.__loading && !loaded) {
                        loaded = true;
                        resolve(store as T);
                    }
                });
            });
        }
        return Promise.resolve(store as T);
    });
}