Class BethPersistCache

packages/beth-stack/src/cache/old-persist.ts:67–388

}

export class BethPersistCache {
  private callBackMap: Map<
    string,
    {
      callBack: () => Promise<any>;
      tags: string[];
      location: "memory" | "json";
    }
  >;
  private pendingMap: Map<string, Promise<any>>;
  private inMemoryDataCache: Map<string, any>;
  private jsonDataCache: Database;
  private intervals: Set<Timer>;
  private keys: Set<string>;
  private inInitialLoad: Set<string>;
  private config: GlobalCacheConfig;
  private neverSeeded: Set<string>;
  private toReThrow: Map<string, any>;

  constructor() {
    this.callBackMap = new Map();
    this.inMemoryDataCache = new Map();
    this.intervals = new Set();
    this.pendingMap = new Map();
    this.keys = new Set();
    this.inInitialLoad = new Set();
    this.neverSeeded = new Set();
    this.toReThrow = new Map();
    this.config = {
      log: false,
      defaultCacheOptions: {
        persist: "json",
        revalidate: Infinity,
        tags: [],
        seedImmediately: true,
      },
      returnStaleWhileRevalidate: true,
      onRevalidateErrorReturnStale: true,
      rethrowOnUnseededError: false,
    };

    if (existsSync("beth-cache.sqlite")) unlinkSync("beth-cache.sqlite");
    this.jsonDataCache = new Database("beth-cache.sqlite", {
      readwrite: true,
      create: true,
    });
    this.jsonDataCache.run(`
      CREATE TABLE IF NOT EXISTS cache (
        key TEXT PRIMARY KEY,
        value TEXT NOT NULL
      );
    `);
  }

  public setConfig(config: Partial<GlobalCacheConfig>) {
    this.config.defaultCacheOptions = {
      ...this.config.defaultCacheOptions,
      ...config.defaultCacheOptions,