import { Blob } from "https://esm.town/v/pomdtr/lowdb?v=17"; import { type Store } from "npm:@keyvhq/core"; import { type Adapter, Low } from "npm:lowdb"; export type Keyv = Map; export type KeyvLowOptions = { key?: string; }; class MapBlob implements Adapter> { constructor( private blob: Blob>, ) {} read = async () => { const entries = Object.entries(await this.blob.read()); return new Map(entries); }; write = async (data: Keyv) => { const entries = data.entries(); return this.blob.write(Object.fromEntries(entries)); }; } export class KeyvLow implements Store { private adapter: MapBlob; private db: Low>; constructor(options?: KeyvLowOptions) { const key = options?.key ?? "keyv"; this.adapter = new MapBlob(new Blob(key)); this.db = new Low(this.adapter, new Map()); } clear = async () => { await this.db.read(); this.db.data.clear(); return this.db.write(); }; delete = async (key: string) => { await this.db.read(); const result = this.db.data.delete(key); await this.db.write(); return result; }; has = async (key: string) => { await this.db.read(); return this.db.data.has(key); }; get = async (key: string) => { await this.db.read(); return this.db.data.get(key); }; set = async (key: string, value: TValue) => { await this.db.read(); this.db.data.set(key, value); return this.db.write(); }; iterator = (): AsyncGenerator => { return; }; } export const blobStore = createStore(); export function createStore(options?: KeyvLowOptions): Store { return new KeyvLow(options); }

keyvhqBlob

Version 1