beauty-bookings/server-dist/lib/create-kv.js

import { createStorage } from "unstorage";
import fsDriver from "unstorage/drivers/fs";
const STORAGE_PATH = "./.storage"; // It is .gitignored
export function createKV(name) {
    const storage = createStorage({
        driver: fsDriver({ base: `${STORAGE_PATH}/${name}` }),
    });
    // Async generator to play work well with oRPC live queries
    async function* subscribe() {
        let resolve;
        let promise = new Promise((r) => (resolve = r));
        const unwatch = await storage.watch((event, key) => {
            resolve({ event, key });
            promise = new Promise((r) => (resolve = r));
        });
        try {
            while (true)
                yield await promise;
        }
        finally {
            await unwatch();
        }
    }
    return {
        ...storage,
        getAllItems: async () => {
            const keys = await storage.getKeys();
            const values = await storage.getItems(keys);
            return values.map(({ value }) => value);
        },
        subscribe,
    };
}