merge: L0-L4 self-check architecture

2026-07-20 19:40:24 +08:00
parent 135bfced5a 08eef1e181
commit e69109fde9
8 changed files with 1584 additions and 1409 deletions
@@ -0,0 +1,65 @@
+import json, urllib.request
+
+msg = """[笑笑] 系统大扫除 + 防复发机制 — 全部完成
+
+■ 清理执行结果
+
+【小果生态 — 全灭】
+- xmpp_xiaoguo_bot(root, 8天2.5GB) 已杀，3个systemd服务已删除
+- 4个 cron job 已删（quick-scan/tunnel-watchdog/情感分析/独立扫描）
+- 7个脚本 + 数据文件 + profile目录 全部归档 archive/xiaoguo-retired-20260720/
+
+【第三库 — 已合并】
+- sector_snapshots +4978行、market_snapshots +187行、todos +2 并入主库
+- 第三库及其数据目录已移 trashbox
+
+【文件源统一 — 31个分叉全处理】
+- 库文件(strategy_lifecycle等5个)：统一到 MoFin root（cron实际import的版本）
+- cron脚本(13个)：deploy为唯一源，旧副本全归档
+- 新增 sync_profile_scripts.sh 防硬链接断裂
+- crontab 三处改指 deploy 路径（cron_to_xmpp/market_watch/market_screener），已验证可跑
+
+【其余清理】
+- 21个遗留JSON + 3个废弃小库(market.db/market_data.db/stock_analysis.db) 归档
+- 8个禁用cron任务删除（pa 52 jobs / default 17 jobs，禁用项清零）
+- 9个旧日志 + 旧bot/bak文件归档
+- projects/ 两个旧克隆(1.4G+2.2M) 归档
+
+■ 问题是怎么产生的（根因）
+
+1. 没有单一事实源规则——同一文件可以"合法"住在4个地方，悄悄分叉
+2. 相对路径解析——mofin_db.py 用 __file__.parent 找数据目录，每个硬链接副本解析出不同的库（三库事件根源）
+3. "备份留生产目录"的习惯——.bak/迁移残留留在数据目录，被监控扫描后变成假警报
+4. 迁移只做一半——DB建了表，旧JSON的读写着还留着（price_events 就是这么分裂的）
+5. 模块死了没人收尸——小果宣布"已废弃"，但bot/gateway/tunnel/cron照跑
+6. 监控查"在不在"不查"活不活"——拿遗留文件mtime当管道健康，报出"停滞14天"假警报
+7. 压根没有"系统卫生"这个检查类别——分叉/僵尸/孤儿文件没人看
+
+■ 防复发机制（已落地）
+
+【规范层】dev-spec.md 升级 v2.0：五条红线 → 十条红线
+#6 单一事实源（只许硬链接，禁止独立副本）
+#7 数据路径必须绝对（禁止__file__相对解析数据路径）
+#8 备份/遗留物禁止留生产数据目录
+#9 死模块收尸六步清单（杀进程/停服务/删cron/归档脚本/归档数据/摘监控）
+#10 监控查活不查在（DB表新鲜度才算健康证据）
+ 文件位置宪法：每类内容的唯一权威位置表
+
+【监控层】新增 system_hygiene_audit.py
+- 每周一 07:30 自动跑：分叉副本/断裂硬链接/僵尸进程/孤儿文件/死cron/DB新鲜度 六项检查
+- 结果写 hygiene_report.json，有问题自动推 XMPP
+- 已注册进 cron（pa jobs.json）
+- specs/hygiene.json 模块 spec 已就位
+- 首轮实测：发现5个真问题（1个漏网分叉+2个我清理时误删的default脚本+2个合法容器进程误报），已全部修复，复检六项全绿
+
+这套机制保证：下次再出现"这一行那也可以"的冗余，周一早上 07:30 你就会收到 XMPP 点名。
+
+代码已提交合并（246: c545a820）。"""
+
+payload = json.dumps({"to": "hmo@yoin.fun", "body": msg, "type": "chat"}).encode()
+req = urllib.request.Request("http://127.0.0.1:5805/", data=payload,
+                             headers={"Content-Type": "application/json"})
+try:
+    print("XMPP:", urllib.request.urlopen(req, timeout=10).read().decode()[:80])
+except Exception as e:
+    print("XMPP fail:", e)
@@ -0,0 +1,59 @@
+import json, shutil, uuid
+from datetime import datetime
+
+jf = '/home/hmo/.hermes/profiles/position-analyst/cron/jobs.json'
+shutil.copy(jf, jf + '.bak-20260720-l134')
+d = json.load(open(jf))
+is_list = isinstance(d, list)
+jobs = d if is_list else d.get('jobs', [])
+
+def has_script(s):
+    return any(j.get('script') == s for j in jobs)
+
+def mkjob(name, script, schedule, display, next_run):
+    return {
+        "id": uuid.uuid4().hex[:12], "name": name, "prompt": "", "skills": [], "skill": None,
+        "model": None, "provider": None, "base_url": None, "script": script,
+        "no_agent": True, "context_from": None,
+        "schedule": {"kind": "cron", "expr": schedule, "display": display},
+        "schedule_display": display,
+        "repeat": {"times": None, "completed": 0}, "enabled": True, "state": "scheduled",
+        "paused_at": None, "paused_reason": None, "created_at": datetime.now().isoformat(),
+        "next_run_at": next_run, "last_run_at": None, "last_status": None,
+    }
+
+# 1. 新增 L1/L3/L4 jobs
+added = []
+if not has_script('functional_health_check.py'):
+    jobs.append(mkjob('功能健康检查-L1', 'functional_health_check.py', '*/15 9-16,20-22 * * 1-5', '*/15 9-16,20-22 * * 1-5', '2026-07-20T20:30:00+08:00'))
+    added.append('功能健康检查-L1(15min)')
+if not has_script('self_repair.py'):
+    jobs.append(mkjob('LLM修复循环-L3', 'self_repair.py', '*/30 9-16,20-22 * * 1-5', '*/30 9-16,20-22 * * 1-5', '2026-07-20T20:30:00+08:00'))
+    added.append('LLM修复循环-L3(30min)')
+if not has_script('meta_watchdog.py'):
+    jobs.append(mkjob('元监控-自检系统的自检-L4', 'meta_watchdog.py', '5 * * * *', '5 * * * *', '2026-07-20T20:05:00+08:00'))
+    added.append('元监控-L4(每小时)')
+
+# 2. hygiene 改每日（原每周一 07:30 → 每日 08:20）
+for j in jobs:
+    if j.get('script') == 'system_hygiene_audit.py':
+        j['schedule'] = {"kind": "cron", "expr": "20 8 * * *", "display": "20 8 * * *"}
+        j['schedule_display'] = "20 8 * * *"
+        j['name'] = '系统卫生审计-每日'
+        j['next_run_at'] = '2026-07-21T08:20:00+08:00'
+        added.append('hygiene改每日08:20')
+
+# 3. 退休重叠组件：Cron监护-高频(cron_watchdog) + 全局cron健康监控(cron_health_monitor)
+REMOVE = {'Cron监护-高频', '全局cron健康监控-每10分'}
+removed = [j.get('name') for j in jobs if j.get('name') in REMOVE]
+jobs = [j for j in jobs if j.get('name') not in REMOVE]
+
+if is_list:
+    json.dump(jobs, open(jf, 'w'), ensure_ascii=False, indent=2)
+else:
+    d['jobs'] = jobs
+    json.dump(d, open(jf, 'w'), ensure_ascii=False, indent=2)
+
+print('added:', added)
+print('removed:', removed)
+print('total jobs:', len(jobs))
@@ -0,0 +1,15 @@
+import json, shutil
+jf = '/home/hmo/.hermes/cron/jobs.json'
+shutil.copy(jf, jf + '.bak-20260720-l134')
+d = json.load(open(jf))
+is_list = isinstance(d, list)
+jobs = d if is_list else d.get('jobs', [])
+REMOVE = {'Cron监护-高频'}
+removed = [j.get('name') for j in jobs if j.get('name') in REMOVE]
+jobs = [j for j in jobs if j.get('name') not in REMOVE]
+if is_list:
+    json.dump(jobs, open(jf, 'w'), ensure_ascii=False, indent=2)
+else:
+    d['jobs'] = jobs
+    json.dump(d, open(jf, 'w'), ensure_ascii=False, indent=2)
+print('removed:', removed, '| total:', len(jobs))
@@ -0,0 +1,6 @@
+import sys
+sys.path.insert(0, '/home/hmo/.hermes/profiles/position-analyst/scripts')
+from self_repair import run_action
+ok, detail = run_action({'action': 'rerun_script', 'script': 'mofin_health.py'}, 'health_collector')
+print('ok:', ok)
+print('detail:', detail[:200])
@@ -0,0 +1,10 @@
+import json
+d = json.load(open('/home/hmo/web-dashboard/static/mofin_health.json'))
+sc = d.get('self_check', {})
+print('functional:', bool(sc.get('functional')), '| meta:', bool(sc.get('meta_watchdog')),
+      '| hygiene:', bool(sc.get('hygiene')), '| repairs:', len(sc.get('recent_repairs', [])))
+if sc.get('functional'):
+    fh = sc['functional']
+    print('functional status:', fh.get('status'), fh.get('summary'))
+if sc.get('meta_watchdog'):
+    print('meta status:', sc['meta_watchdog'].get('status'))