123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183
import { Doc, Path, ShareAddress } from "../util/doc-types.ts";import { ReplicaIsClosedError } from "../util/errors.ts";import { ReplicaDriverMemory } from "./replica-driver-memory.ts";
//--------------------------------------------------
import { Logger } from "../util/log.ts";import { checkShareIsValid } from "../core-validators/addresses.ts";let logger = new Logger("storage driver localStorage", "gold");
//================================================================================type SerializedDriverDocs = {  byPathAndAuthor: Record<string, Doc>;  byPathNewestFirst: Record<Path, Doc[]>;};
function isSerializedDriverDocs(value: any): value is SerializedDriverDocs {  // check if data we've loaded from localStorage is actually in the format we expect  if (typeof value !== "object") {    return false;  }  return ("byPathAndAuthor" in value && "byPathNewestFirst" in value);}
/** A replica driver which perists to LocalStorage, which stores a maximum of five megabytes per domain. If you're storing multiple shares, this limit will be divided among all their replicas. * Works in browsers and Deno. */export class ReplicaDriverLocalStorage extends ReplicaDriverMemory {  _localStorageKeyConfig: string;  _localStorageKeyDocs: string;
  /**   * @param share - The address of the share the replica belongs to.   */  constructor(share: ShareAddress) {    super(share);    logger.debug("constructor");
    // each config item starts with this prefix and gets its own entry in localstorage    this._localStorageKeyConfig = `stonesoup:config:${share}`; // TODO: change this to "earthstar:..." later    // but all docs are stored together inside this one item, as a giant JSON object    this._localStorageKeyDocs = `stonesoup:documents:pathandauthor:${share}`;
    const existingData = localStorage.getItem(this._localStorageKeyDocs);    if (existingData !== null) {      logger.debug("...constructor: loading data from localStorage");      const parsed = JSON.parse(existingData);
      if (!isSerializedDriverDocs(parsed)) {        console.warn(          `localStorage data could not be parsed for share ${share}`,        );        return;      }
      this.docByPathAndAuthor = new Map(        Object.entries(parsed.byPathAndAuthor),      );      this.docsByPathNewestFirst = new Map(        Object.entries(parsed.byPathNewestFirst),      );
      const localIndexes = Array.from(this.docByPathAndAuthor.values()).map((        doc,      ) => doc._localIndex as number);      this._maxLocalIndex = Math.max(...localIndexes);    } else {      logger.debug(        "...constructor: there was no existing data in localStorage",      );    }
    logger.debug("...constructor is done.");  }
  //--------------------------------------------------  // LIFECYCLE
  // isClosed(): inherited  close(erase: boolean) {    logger.debug("close");    if (this._isClosed) throw new ReplicaIsClosedError();    if (erase) {      logger.debug("...close: and erase");      this._configKv = {};      this._maxLocalIndex = -1;      this.docsByPathNewestFirst.clear();      this.docByPathAndAuthor.clear();
      logger.debug("...close: erasing localStorage");      localStorage.removeItem(this._localStorageKeyDocs);      for (let key of this._listConfigKeysSync()) {        this._deleteConfigSync(key);      }      logger.debug("...close: erasing is done");    }    this._isClosed = true;    logger.debug("...close is done.");
    return Promise.resolve();  }
  //--------------------------------------------------  // CONFIG
  // synchronous versions for internal use
  _getConfigSync(key: string): string | undefined {    if (this._isClosed) throw new ReplicaIsClosedError();    key = `${this._localStorageKeyConfig}:${key}`;    let result = localStorage.getItem(key);    return result === null ? undefined : result;  }
  _setConfigSync(key: string, value: string): void {    if (this._isClosed) throw new ReplicaIsClosedError();    key = `${this._localStorageKeyConfig}:${key}`;    localStorage.setItem(key, value);  }
  _listConfigKeysSync(): string[] {    if (this._isClosed) throw new ReplicaIsClosedError();    let keys = Object.keys(localStorage)      .filter((key) => key.startsWith(this._localStorageKeyConfig + ":"))      .map((key) => key.slice(this._localStorageKeyConfig.length + 1));    keys.sort();    return keys;  }
  _deleteConfigSync(key: string): boolean {    if (this._isClosed) throw new ReplicaIsClosedError();    let hadIt = this._getConfigSync(key);    key = `${this._localStorageKeyConfig}:${key}`;    localStorage.removeItem(key);    return hadIt !== undefined;  }
  // async versions to match the IStorageDriverAsync interface
  async getConfig(key: string): Promise<string | undefined> {    return this._getConfigSync(key);  }  async setConfig(key: string, value: string): Promise<void> {    return this._setConfigSync(key, value);  }  async listConfigKeys(): Promise<string[]> {    return this._listConfigKeysSync();  }  async deleteConfig(key: string): Promise<boolean> {    return this._deleteConfigSync(key);  }
  //--------------------------------------------------  // GET
  // getMaxLocalIndex(): inherited  // queryDocs(query: Query): inherited
  //--------------------------------------------------  // SET
  async upsert(doc: Doc): Promise<Doc> {    if (this._isClosed) throw new ReplicaIsClosedError();    const upsertedDoc = await super.upsert(doc);
    // After every upsert, for now, we save everything    // to localStorage as a single giant JSON blob.    // TODO: debounce this, only do it every 1 second or something
    const docsToBeSerialised: SerializedDriverDocs = {      byPathAndAuthor: Object.fromEntries(this.docByPathAndAuthor),      byPathNewestFirst: Object.fromEntries(this.docsByPathNewestFirst),    };
    localStorage.setItem(      this._localStorageKeyDocs,      JSON.stringify(docsToBeSerialised),    );
    return upsertedDoc;  }}