clone-runner.mjs 5.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119
  1. #!/usr/bin/env node
  2. /**
  3. * fmode-agent-clone runner — 数字生命克隆:同步/恢复/建仓
  4. * 零依赖(Node ≥18)。凭据 4 级解析,密钥本体永不入仓。
  5. *
  6. * 用法:
  7. * node clone-runner.mjs sync --name yuyang [--level L1,L2] [--dry]
  8. * node clone-runner.mjs restore --repo <url> --into <dir>
  9. */
  10. import fs from 'fs';
  11. import os from 'os';
  12. import path from 'path';
  13. import { execSync } from 'child_process';
  14. const HOME = os.homedir();
  15. /** 5 级凭据解析(第0级为文档级自举说明):
  16. * 第0级: sessionToken —— ⚠️ Gogs API 不接受 sessionToken(网页 cookie i_like_gogs 仅网页会话有效),
  17. * 且 Gogs 无"sessionToken 换 git token"的签发端点 → git token 必须一次性初始化(见 README)。
  18. * 第1-4级: env → ~/.fmode/config.json → ./.fmode/config.json → git credential helper */
  19. export function resolveGit() {
  20. const out = { user: null, token: null, apiBase: 'https://git.fmode.cn/api/v1' };
  21. if (process.env.FMODE_GIT_TOKEN) { out.token = process.env.FMODE_GIT_TOKEN; }
  22. for (const p of [path.join(HOME, '.fmode', 'config.json'), path.join(process.cwd(), '.fmode', 'config.json')]) {
  23. try {
  24. const j = JSON.parse(fs.readFileSync(p, 'utf8'));
  25. if (j.gitToken) out.token = j.gitToken;
  26. if (j.gitUser) out.user = j.gitUser;
  27. if (j.gitApiBase) out.apiBase = j.gitApiBase;
  28. } catch {}
  29. }
  30. if (!out.user) {
  31. try { out.user = execSync('git config user.name', { encoding: 'utf8' }).trim(); } catch {}
  32. }
  33. return out;
  34. }
  35. /** 默认同步清单(L1 核心 / L2 能力 / L3 记录 / L4 状态) */
  36. export function collectPaths(level = ['L1','L2']) {
  37. const D = '/opt/data';
  38. const map = {
  39. L1: [`${D}/SOUL.md`, `${D}/MEMORY.md`, `${D}/USER.md`],
  40. L2: [`${D}/skills`, `${D}/home/.claude/skills`].filter(p => fs.existsSync(p)),
  41. L3: [`${D}/home/.claude/projects`, `${D}/.hermes/sessions`].filter(p => fs.existsSync(p)),
  42. L4: [`${D}/.hermes/cron`].filter(p => fs.existsSync(p)),
  43. };
  44. return level.flatMap(l => map[l] || []);
  45. }
  46. function sh(cmd, cwd) {
  47. return execSync(cmd, { encoding: 'utf8', cwd, stdio: ['ignore','pipe','pipe'], timeout: 120000 });
  48. }
  49. function ensureRepo(name, g) {
  50. const url = `${g.apiBase}/admin/users/${g.user}/repos`;
  51. if (!g.token) {
  52. console.error('git token 缺失——Gogs API 不接受 sessionToken 自举,请先完成一次性初始化(见 README「凭据」章节):');
  53. console.error(` curl -u "<user>:<password>" -X POST "${g.apiBase.replace('/api/v1', '')}/api/v1/users/<user>/tokens" -H "Content-Type: application/json" -d '{"name":"agent-clone"}'`);
  54. return false;
  55. }
  56. try {
  57. const r = sh(`curl -s --max-time 20 -X POST -H "Authorization: token ${g.token}" -H "Content-Type: application/json" -d '{"name":"${name}","private":true}' "${url}"`);
  58. return /"name"\s*:\s*"/.test(r) || /already/i.test(r);
  59. } catch { return false;
  60. }
  61. }
  62. function main() {
  63. const a = process.argv.slice(2);
  64. const cmd = a[0];
  65. const argOf = (n) => { const i = a.indexOf(n); return i >= 0 ? a[i+1] : null; };
  66. const g = resolveGit();
  67. if (cmd === 'sync') {
  68. const name = argOf('--name') || (g.user || 'agent').replace(/[^a-z0-9-]/gi, '').toLowerCase();
  69. const level = (argOf('--level') || 'L1,L2,L3').split(',');
  70. const dry = a.includes('--dry');
  71. const repoName = `agent-${name}`;
  72. const remote = argOf('--repo') || `https://${g.user}:${g.token}@git.fmode.cn/${g.user}/${repoName}.git`;
  73. const work = path.join(HOME, '.agent-clone', repoName);
  74. // 1) clone or init
  75. if (!fs.existsSync(path.join(work, '.git'))) {
  76. fs.mkdirSync(work, { recursive: true });
  77. try { sh(`git clone ${remote} ${work}`); } catch { sh(`git init -b main ${work}`); sh(`git remote add origin ${remote} ${work}`); }
  78. } else { sh(`git pull --rebase origin main || true`, work); }
  79. // 2) 汇集文件
  80. const targets = collectPaths(level);
  81. const manifest = [];
  82. for (const t of targets) {
  83. if (!fs.existsSync(t)) continue;
  84. const base = path.join(work, path.basename(t));
  85. sh(`mkdir -p "${path.dirname(base)}" && cp -r "${t}" "${path.dirname(base)}/"`);
  86. manifest.push({ src: t, dst: path.basename(t) });
  87. }
  88. // 3) credentials-map(密钥位置指针, 不含密钥值)
  89. 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`;
  90. fs.writeFileSync(path.join(work, 'credentials-map.md'), credMap);
  91. fs.writeFileSync(path.join(work, 'sync-manifest.json'), JSON.stringify({ at: new Date().toISOString(), name, level, manifest }, null, 2));
  92. if (dry) { console.log('[dry] 同步项:', manifest.length); return; }
  93. // 4) commit+push
  94. 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 {}
  95. if (!g.token) {
  96. console.error('push 失败: git token 缺失(FMODE_GIT_TOKEN 或 ~/.fmode/config.json 的 gitToken)。Gogs 不支持 sessionToken 自举,请先一次性初始化 token(见 README「凭据」章节)。');
  97. return;
  98. }
  99. try { if (ensureRepo(repoName, g)) { sh(`git push -u origin main`, work); console.log('✅ 已同步', manifest.length, '项 →', repoName); } }
  100. catch (e) { console.error('push 失败:', String(e).slice(0, 200)); }
  101. return;
  102. }
  103. if (cmd === 'restore') {
  104. const repo = argOf('--repo'); const into = argOf('--into') || '/opt/data';
  105. if (!repo) { console.error('用法: restore --repo <url> --into <dir>'); process.exit(2); }
  106. sh(`git clone ${repo} ${into}/.agent-restore`);
  107. console.log('已 clone 到', into + '/.agent-restore', '—— 按 sync-manifest.json 反向拷贝到对应路径即可');
  108. return;
  109. }
  110. console.log('用法: sync | restore');
  111. }
  112. main();