Method exp

migrate/providers/zep.js:31–53

()

    }
  }
  async exp() {
    const o = p.join(this.c.o, 'zep_export.jsonl'),
      w = fs.createWriteStream(o);
    console.log('[ZEP] Listing sessions...');
    const ss = await this.fss();
    console.log(`[ZEP] Found ${ss.length} sessions`);
    let tm = 0,
      tc = 0;
    for (let i = 0; i < ss.length; i++) {
      const s = ss[i];
      tc++;
      if (tc % 100 === 0)
        console.log(`[ZEP] Progress: ${tc}/${ss.length} sessions`);
      const mm = await this.fsm(s.session_id);
      for (const m of mm) {
        w.write(JSON.stringify(this.n(m, s)) + '\n');
        tm++;
      }
    }
    w.end();
    console.log(`[ZEP] Exported ${tm} memories from ${tc} sessions`);
    return o;
  }
  async fss() {
    const ss = [];
    let pg = 1,