Method initDB

fbi/fbi.ts:111–139

()

  private cachePath = ""; // persist path for sync flush on cleanup
  private cachePersistTimer: ReturnType<typeof setTimeout> | null = null;
  private coldSweepTimer: ReturnType<typeof setInterval> | null = null;

  /** remove messages older than 30 days from a chat cache, return true if any pruned */
  private pruneExpired(chat: CachedChat): boolean {
    const cutoff = Math.floor(Date.now() / 1000) - CACHE_EXPIRE_SECS;
    const before = chat.msgs.length;
    chat.msgs = chat.msgs.filter(m => m.date > cutoff);
    return chat.msgs.length !== before;
  }

  constructor() {
    super();
    this.initDB().catch((e) => {
      console.error("[fbi] initDB error", e);
      this.ready = true; // continue with fresh state
    });
  }

  /* ====== bootstrap ====== */

  private async initDB() {
    const p = path.join(createDirectoryInAssets("fbi"), "db.json");
    this.configDb = await JSONFilePreset<FbiConfig>(p, CONFIG_DEF);
    // ensure cacheLimit has a default
    if (typeof this.configDb.data.cacheLimit !== "number") {
      this.configDb.data.cacheLimit = CACHE_LIMIT_DEF;
      await this.configDb.write();
    }
    for (const [k, v] of Object.entries(this.configDb.data.surveillance)) this.sv.set(k, v as SvEntry);
    // load cache from separate file — tolerate corrupt/truncated JSON
    const cp = path.join(createDirectoryInAssets("fbi"), "cache.json");
    this.cachePath = cp;