// SPDX-License-Identifier: 0BSD import { type Store } from "npm:@keyvhq/core"; import { type Adapter, Low } from "npm:lowdb"; export type Keyv = Map; export type KeyvLowOptions = { adapter: Adapter>; }; class MapAdapter implements Adapter> { constructor( private adapter: Adapter>, ) {} read = async () => { const obj = await this.adapter.read() ?? {}; const entries = Object.entries(obj); return new Map(entries); }; write = async (data: Keyv) => { const entries = data.entries(); const obj = Object.fromEntries(entries); return this.adapter.write(obj); }; } export class KeyvLow implements Store { private adapter: MapAdapter; private db: Low>; constructor(options: KeyvLowOptions) { this.adapter = new MapAdapter(options.adapter); this.db = new Low(this.adapter, new Map()); } clear = async (namespace = "") => { await this.db.read(); const keysToDelete = []; for (const key of this.db.data.keys()) { if (key.startsWith(namespace)) { keysToDelete.push(key); } } keysToDelete.forEach(key => this.db.data.delete(key)); 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(); }; async *iterator(namespace = "") { await this.db.read(); for (const key of this.db.data.keys()) { if (key.startsWith(namespace)) { const value = this.db.data.get(key); yield [key, value]; } } } }

keyvhqLow