Class NNStorage

apps/web/src/interfaces/storage.ts:44–262

const APP_SALT = "oVzKtazBo7d8sb7TBvY9jw";

export class NNStorage implements IStorage {
  database: IKVStore;

  constructor(
    name: string,
    private readonly keyStore: () => IKeyStore | null = () => null,
    persistence: DatabasePersistence = "db"
  ) {
    this.database =
      persistence === "memory"
        ? new MemoryKVStore()
        : isFeatureSupported("indexedDB")
        ? new IndexedDBKVStore(name, "keyvaluepairs")
        : new LocalStorageKVStore();
  }

  async migrate() {
    if (!this.keyStore) return;
    const user = await this.read<User>("user");
    if (!user) return;

    const key = await this._getCryptoKey(`_uk_@${user.email}`);
    if (!key) return;

    await this.database.deleteMany([
      `_uk_@${user.email}`,
      `_uk_@${user.email}@_k`
    ]);
    await this.keyStore()?.setValue("userEncryptionKey", key);
  }

  read<T>(key: string): Promise<T | undefined> {
    if (!key) return Promise.resolve(undefined);
    return this.database.get(key);
  }

  readMulti<T>(keys: string[]): Promise<[string, T][]> {
    if (keys.length <= 0) return Promise.resolve([]);
    return this.database.getMany(keys.sort());
  }

  writeMulti<T>(entries: [string, T][]) {
    return this.database.setMany(entries);
  }

  write<T>(key: string, data: T) {
    return this.database.set(key, data);
  }

  remove(key: string) {
    return this.database.delete(key);
  }

  removeMulti(keys: string[]) {
    return this.database.deleteMany(keys);
  }

  clear() {