|
|
@@ -0,0 +1,107 @@
|
|
|
+#!/usr/bin/env node
|
|
|
+#!/usr/bin/env node
|
|
|
+/**
|
|
|
+ * fmode-agent-clone runner — 数字生命克隆：同步/恢复/建仓
|
|
|
+ * 零依赖（Node ≥18）。凭据 4 级解析，密钥本体永不入仓。
|
|
|
+ *
|
|
|
+ * 用法:
|
|
|
+ * node clone-runner.mjs sync --name yuyang [--level L1,L2] [--dry]
|
|
|
+ * node clone-runner.mjs restore --repo <url> --into <dir>
|
|
|
+ */
|
|
|
+import fs from 'fs';
|
|
|
+import os from 'os';
|
|
|
+import path from 'path';
|
|
|
+import { execSync } from 'child_process';
|
|
|
+
|
|
|
+const HOME = os.homedir();
|
|
|
+
|
|
|
+/** 4 级凭据解析: env → ~/.fmode/config.json → ./.fmode/config.json → git credential helper */
|
|
|
+export function resolveGit() {
|
|
|
+ const out = { user: null, token: null, apiBase: 'https://git.fmode.cn/api/v1' };
|
|
|
+ if (process.env.FMODE_GIT_TOKEN) { out.token = process.env.FMODE_GIT_TOKEN; }
|
|
|
+ for (const p of [path.join(HOME, '.fmode', 'config.json'), path.join(process.cwd(), '.fmode', 'config.json')]) {
|
|
|
+ try {
|
|
|
+ const j = JSON.parse(fs.readFileSync(p, 'utf8'));
|
|
|
+ if (j.gitToken) out.token = j.gitToken;
|
|
|
+ if (j.gitUser) out.user = j.gitUser;
|
|
|
+ if (j.gitApiBase) out.apiBase = j.gitApiBase;
|
|
|
+ } catch {}
|
|
|
+ }
|
|
|
+ if (!out.user) {
|
|
|
+ try { out.user = execSync('git config user.name', { encoding: 'utf8' }).trim(); } catch {}
|
|
|
+ }
|
|
|
+ return out;
|
|
|
+}
|
|
|
+
|
|
|
+/** 默认同步清单（L1 核心 / L2 能力 / L3 记录 / L4 状态） */
|
|
|
+export function collectPaths(level = ['L1','L2']) {
|
|
|
+ const D = '/opt/data';
|
|
|
+ const map = {
|
|
|
+ L1: [`${D}/SOUL.md`, `${D}/MEMORY.md`, `${D}/USER.md`],
|
|
|
+ L2: [`${D}/skills`, `${D}/home/.claude/skills`].filter(p => fs.existsSync(p)),
|
|
|
+ L3: [`${D}/home/.claude/projects`, `${D}/.hermes/sessions`].filter(p => fs.existsSync(p)),
|
|
|
+ L4: [`${D}/.hermes/cron`].filter(p => fs.existsSync(p)),
|
|
|
+ };
|
|
|
+ return level.flatMap(l => map[l] || []);
|
|
|
+}
|
|
|
+
|
|
|
+function sh(cmd, cwd) {
|
|
|
+ return execSync(cmd, { encoding: 'utf8', cwd, stdio: ['ignore','pipe','pipe'], timeout: 120000 });
|
|
|
+}
|
|
|
+
|
|
|
+function ensureRepo(name, g) {
|
|
|
+ const url = `${g.apiBase}/admin/users/${g.user}/repos`;
|
|
|
+ try {
|
|
|
+ const r = sh(`curl -s --max-time 20 -X POST -u "${g.user === 'fmode' ? 'fmode:fmgo' : 'fmode:fmgo'}" -H "Content-Type: application/json" -d '{"name":"${name}","private":true}' "${url}"`);
|
|
|
+ return /"name"\s*:\s*"/.test(r) || /already/i.test(r);
|
|
|
+ } catch { return false; }
|
|
|
+}
|
|
|
+
|
|
|
+function main() {
|
|
|
+ const a = process.argv.slice(2);
|
|
|
+ const cmd = a[0];
|
|
|
+ const argOf = (n) => { const i = a.indexOf(n); return i >= 0 ? a[i+1] : null; };
|
|
|
+ const g = resolveGit();
|
|
|
+ if (cmd === 'sync') {
|
|
|
+ const name = argOf('--name') || (g.user || 'agent').replace(/[^a-z0-9-]/gi, '').toLowerCase();
|
|
|
+ const level = (argOf('--level') || 'L1,L2,L3').split(',');
|
|
|
+ const dry = a.includes('--dry');
|
|
|
+ const repoName = `agent-${name}`;
|
|
|
+ const remote = argOf('--repo') || `https://${g.user}:${g.token}@git.fmode.cn/${g.user}/${repoName}.git`;
|
|
|
+ const work = path.join(HOME, '.agent-clone', repoName);
|
|
|
+ // 1) clone or init
|
|
|
+ if (!fs.existsSync(path.join(work, '.git'))) {
|
|
|
+ fs.mkdirSync(work, { recursive: true });
|
|
|
+ try { sh(`git clone ${remote} ${work}`); } catch { sh(`git init -b main ${work}`); sh(`git remote add origin ${remote} ${work}`); }
|
|
|
+ } else { sh(`git pull --rebase origin main || true`, work); }
|
|
|
+ // 2) 汇集文件
|
|
|
+ const targets = collectPaths(level);
|
|
|
+ const manifest = [];
|
|
|
+ for (const t of targets) {
|
|
|
+ if (!fs.existsSync(t)) continue;
|
|
|
+ const base = path.join(work, path.basename(t));
|
|
|
+ sh(`mkdir -p "${path.dirname(base)}" && cp -r "${t}" "${path.dirname(base)}/"`);
|
|
|
+ manifest.push({ src: t, dst: path.basename(t) });
|
|
|
+ }
|
|
|
+ // 3) credentials-map（密钥位置指针, 不含密钥值）
|
|
|
+ const credMap = `# 密钥位置索引（不含密钥本体）\n- fmode token: ${HOME}/.fmode/config.json (fmodeApiToken)\n- claude token: ${HOME}/.claude/settings.json (env.ANTHROPIC_AUTH_TOKEN)\n- git tokens: /opt/data/.fmode-harness-agent/knowledge/lives/git-tokens.txt\n`;
|
|
|
+ fs.writeFileSync(path.join(work, 'credentials-map.md'), credMap);
|
|
|
+ fs.writeFileSync(path.join(work, 'sync-manifest.json'), JSON.stringify({ at: new Date().toISOString(), name, level, manifest }, null, 2));
|
|
|
+ if (dry) { console.log('[dry] 同步项:', manifest.length); return; }
|
|
|
+ // 4) commit+push
|
|
|
+ try { sh(`git add -A && git -c user.name="${g.user}" -c user.email="${g.user}@fmode.cn" commit -m "clone sync ${new Date().toISOString().slice(0,16)}"`, work); } catch {}
|
|
|
+ try { ensureRepo(repoName, g); sh(`git push -u origin main`, work); console.log('✅ 已同步', manifest.length, '项 →', repoName); }
|
|
|
+ catch (e) { console.error('push 失败:', String(e).slice(0, 200)); }
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ if (cmd === 'restore') {
|
|
|
+ const repo = argOf('--repo'); const into = argOf('--into') || '/opt/data';
|
|
|
+ if (!repo) { console.error('用法: restore --repo <url> --into <dir>'); process.exit(2); }
|
|
|
+ sh(`git clone ${repo} ${into}/.agent-restore`);
|
|
|
+ console.log('已 clone 到', into + '/.agent-restore', '—— 按 sync-manifest.json 反向拷贝到对应路径即可');
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ console.log('用法: sync | restore');
|
|
|
+}
|
|
|
+
|
|
|
+main();
|
