Update hf-sync-manager.mjs

hf-sync-manager.mjs

@@ -9,7 +9,7 @@
 //     SOUL.md                          <- persona / tone
 //     USER.md                          <- user profile
 //     IDENTITY.md                       <- name / emoji
-//     TOOLS.md                         <- env conventions
+//     TOOLS.md                          <- env conventions
 //     HEARTBEAT.md                     <- periodic tasks
 //     MEMORY.md                        <- long-term memory (iron rules)
 //     memory/YYYY-MM-DD.md             <- daily logs
@@ -37,7 +37,8 @@
 //     Never downloads during runtime (prevents memory flooding)
 //
 // Multi-bot:
-//   Set OPENCLAW_PROFILE env var in HF Space Variables.
+//   Set BOT1_PROFILE / BOT2_PROFILE / BOT3_PROFILE ... in HF Space Variables.
+//   The script will automatically use the first defined BOTx_PROFILE as OPENCLAW_PROFILE.
 //   OpenClaw uses ~/.openclaw/workspace-<profile>/ per profile.
 //   Repo stores each profile under workspace-<profile>/.
 // ============================================================
@@ -54,14 +55,27 @@ var HF_TOKEN     = (process.env.HF_TOKEN      || "").trim();
 var DATASET_ID   = (process.env.HF_DATASET_ID  || "").trim();
 var REPO_DIR     = "/tmp/hf-memory-sync";
 
-// OPENCLAW_PROFILE: if set, workspace is ~/.openclaw/workspace-<profile>/
-// This is OpenClaw's native multi-bot mechanism
-var PROFILE      = (process.env.OPENCLAW_PROFILE || "").trim();
+// --- Multi-bot support ----------------------
+// Automatically detect BOTx_PROFILE from HF Variables
+var PROFILE = "";
+for (let i = 1; i <= 10; i++) { // 支持最多 10 个 bot，可自由扩展
+    let envVar = process.env[`BOT${i}_PROFILE`];
+    if (envVar && envVar.trim()) {
+        PROFILE = envVar.trim();
+        break; // 取第一个存在的 BOTx_PROFILE
+    }
+}
+
+// OPENCLAW_PROFILE fallback (legacy)
+if (!PROFILE) {
+    PROFILE = (process.env.OPENCLAW_PROFILE || "").trim();
+}
+
+// Compute workspace dirs
 var WORKSPACE_DIR = PROFILE
-? path.join(OPENCLAW_DIR, "workspace-" + PROFILE)
-: path.join(OPENCLAW_DIR, "workspace");
+    ? path.join(OPENCLAW_DIR, "workspace-" + PROFILE)
+    : path.join(OPENCLAW_DIR, "workspace");
 
-// Repo folder name for this profile's workspace
 var REPO_WORKSPACE_FOLDER = PROFILE ? "workspace-" + PROFILE : "workspace";
 
 var UPLOAD_INTERVAL = 3 * 60 * 60 * 1000; // 3 hours
@@ -92,100 +106,100 @@ var NEVER_SYNC = [
 // -- helpers ----------------------------------
 
 function log(msg) {
-console.log("[hf-sync] " + msg);
+    console.log("[hf-sync] " + msg);
 }
 
 function sleep(ms) {
-return new Promise(function(resolve) { setTimeout(resolve, ms); });
+    return new Promise(function(resolve) { setTimeout(resolve, ms); });
 }
 
 function repoUrl() {
-return "https://user:" + HF_TOKEN +
-"@huggingface.co/datasets/" + DATASET_ID;
+    return "https://user:" + HF_TOKEN +
+           "@huggingface.co/datasets/" + DATASET_ID;
 }
 
 function git(args) {
-return execSync("git " + args, {
-cwd:     REPO_DIR,
-stdio:   "pipe",
-timeout: 120000,
-env:     Object.assign({}, process.env, { GIT_TERMINAL_PROMPT: "0" })
-}).toString().trim();
+    return execSync("git " + args, {
+        cwd:     REPO_DIR,
+        stdio:   "pipe",
+        timeout: 120000,
+        env:     Object.assign({}, process.env, { GIT_TERMINAL_PROMPT: "0" })
+    }).toString().trim();
 }
 
 function isValidJson(filePath) {
-try {
-if (!fs.existsSync(filePath)) return false;
-var content = fs.readFileSync(filePath, "utf-8").trim();
-if (!content) return false;
-JSON.parse(content);
-return true;
-} catch (e) {
-return false;
-}
+    try {
+        if (!fs.existsSync(filePath)) return false;
+        var content = fs.readFileSync(filePath, "utf-8").trim();
+        if (!content) return false;
+        JSON.parse(content);
+        return true;
+    } catch (e) {
+        return false;
+    }
 }
 
 function copyItem(src, dst) {
-if (fs.statSync(src).isDirectory()) {
-execSync("cp -a " + src + " " + dst, { stdio: "pipe" });
-} else {
-fs.mkdirSync(path.dirname(dst), { recursive: true });
-fs.copyFileSync(src, dst);
-}
+    if (fs.statSync(src).isDirectory()) {
+        execSync("cp -a " + src + " " + dst, { stdio: "pipe" });
+    } else {
+        fs.mkdirSync(path.dirname(dst), { recursive: true });
+        fs.copyFileSync(src, dst);
+    }
 }
 
 // -- git repo setup --------------------------
 
 function ensureRepo() {
-if (fs.existsSync(path.join(REPO_DIR, ".git"))) return;
-execSync("rm -rf " + REPO_DIR, { stdio: "pipe" });
-try {
-execSync(
-"git clone --depth 1 " + repoUrl() + " " + REPO_DIR,
-{
-stdio:   "pipe",
-timeout: 120000,
-env:     Object.assign({}, process.env, { GIT_TERMINAL_PROMPT: "0" })
-}
-);
-} catch (e) {
-fs.mkdirSync(REPO_DIR, { recursive: true });
-execSync("git init " + REPO_DIR, { stdio: "pipe" });
-git("remote add origin " + repoUrl());
-}
-try {
-git("config user.email openclaw@hf.space");
-git("config user.name OpenClaw-Sync");
-git("config pull.rebase false");
-} catch (e) { /* non-fatal */ }
+    if (fs.existsSync(path.join(REPO_DIR, ".git"))) return;
+    execSync("rm -rf " + REPO_DIR, { stdio: "pipe" });
+    try {
+        execSync(
+            "git clone --depth 1 " + repoUrl() + " " + REPO_DIR,
+            {
+                stdio:   "pipe",
+                timeout: 120000,
+                env:     Object.assign({}, process.env, { GIT_TERMINAL_PROMPT: "0" })
+            }
+        );
+    } catch (e) {
+        fs.mkdirSync(REPO_DIR, { recursive: true });
+        execSync("git init " + REPO_DIR, { stdio: "pipe" });
+        git("remote add origin " + repoUrl());
+    }
+    try {
+        git("config user.email openclaw@hf.space");
+        git("config user.name OpenClaw-Sync");
+        git("config pull.rebase false");
+    } catch (e) { /* non-fatal */ }
 }
 
 function pullLatest() {
-try { git("fetch --quiet origin"); } catch (e) { /* ignore */ }
-try {
-git("pull --quiet --no-rebase origin main");
-} catch (e) {
-try { git("pull --quiet --no-rebase origin master"); } catch (e2) { /* no remote yet */ }
-}
+    try { git("fetch --quiet origin"); } catch (e) { /* ignore */ }
+    try {
+        git("pull --quiet --no-rebase origin main");
+    } catch (e) {
+        try { git("pull --quiet --no-rebase origin master"); } catch (e2) { /* no remote yet */ }
+    }
 }
 
 function commitAndPush(label) {
-try {
-git("add -A");
-var changed = git("diff --cached --name-only");
-if (!changed) return 0;
-var count = changed.split("\n").filter(Boolean).length;
-var ts    = new Date().toISOString().replace("T", " ").substring(0, 19);
-var tag   = PROFILE ? "[" + PROFILE + "]" : "";
-git("commit -m \"sync" + tag + " " + ts + "\"");
-try {
-git("push --quiet origin HEAD:main");
-} catch (e) {
-git("push --quiet origin HEAD:master");
-}
-return count;
-} catch (e) {
-log("Commit/push failed: " + e.message);
-return 0;
-}
+    try {
+        git("add -A");
+        var changed = git("diff --cached --name-only");
+        if (!changed) return 0;
+        var count = changed.split("\n").filter(Boolean).length;
+        var ts    = new Date().toISOString().replace("T", " ").substring(0, 19);
+        var tag   = PROFILE ? "[" + PROFILE + "]" : "";
+        git("commit -m \"sync" + tag + " " + ts + "\"");
+        try {
+            git("push --quiet origin HEAD:main");
+        } catch (e) {
+            git("push --quiet origin HEAD:master");
+        }
+        return count;
+    } catch (e) {
+        log("Commit/push failed: " + e.message);
+        return 0;
+    }
 }