Method handleMigrateScan

packages/memos-core/src/viewer/server.ts:4015–4131

(res: http.ServerResponse)

  }

  private handleMigrateScan(res: http.ServerResponse): void {
    try {
      const ocHome = this.getOpenClawHome();
      const memoryDir = path.join(ocHome, "memory");
      const agentsDir = path.join(ocHome, "agents");

      const sqliteFiles: Array<{ file: string; chunks: number }> = [];
      if (fs.existsSync(memoryDir)) {
        for (const f of fs.readdirSync(memoryDir)) {
          if (f.endsWith(".sqlite")) {
            try {
              const Database = require("better-sqlite3");
              const db = new Database(path.join(memoryDir, f), { readonly: true });
              const row = db.prepare("SELECT COUNT(*) as cnt FROM chunks").get() as { cnt: number };
              sqliteFiles.push({ file: f, chunks: row.cnt });
              db.close();
            } catch { /* skip unreadable */ }
          }
        }
      }

      let sessionCount = 0;
      let messageCount = 0;
      if (fs.existsSync(agentsDir)) {
        for (const entry of fs.readdirSync(agentsDir, { withFileTypes: true })) {
          if (!entry.isDirectory()) continue;
          const sessDir = path.join(agentsDir, entry.name, "sessions");
          if (!fs.existsSync(sessDir)) continue;
          const jsonlFiles = fs.readdirSync(sessDir).filter(f => f.includes(".jsonl"));
          sessionCount += jsonlFiles.length;
          for (const f of jsonlFiles) {
            try {
              const content = fs.readFileSync(path.join(sessDir, f), "utf-8");
              const lines = content.split("\n").filter(l => l.trim());
              for (const line of lines) {
                try {
                  const obj = JSON.parse(line);
                  if (obj.type === "message") {
                    const role = obj.message?.role ?? obj.role;
                    if (role === "user" || role === "assistant") {
                      const mc = obj.message?.content ?? obj.content;
                      let txt = "";
                      if (typeof mc === "string") txt = mc;
                      else if (Array.isArray(mc)) txt = mc.filter((p: any) => p.type === "text" && p.text).map((p: any) => p.text).join("\n");
                      else txt = JSON.stringify(mc);
                      if (role === "user") txt = stripInboundMetadata(txt);
                      if (txt && txt.length >= 10) messageCount++;
                    }
                  }
                } catch { /* skip bad lines */ }
              }
            } catch { /* skip unreadable */ }
          }
        }
      }

      const cfgPath = this.getOpenClawConfigPath();
      let hasEmbedding = false;