File size: 1,764 Bytes
29cdc9d 41b685b 29cdc9d 41b685b 29cdc9d 41b685b | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 | #!/usr/bin/env python3
import os
import json
import time
from src.ide_kernel.kernel import SovereignKernel
from src.ide_kernel.validator import KernelValidator
from src.ide_kernel.ledger import ProjectLedger
class SelfHealingLoop:
def __init__(self, workspace_path=None):
self.root = os.path.abspath(workspace_path or os.getcwd())
self.failure_file = os.path.join(self.root, "failure_report.json")
self.kernel = SovereignKernel(self.root)
self.ledger = ProjectLedger(self.root)
def run(self):
print("[LOOP] Self-healing active. Watching for failures...")
while True:
if os.path.exists(self.failure_file):
with open(self.failure_file, 'r') as f:
report = json.load(f)
task = report.get("original_task", {})
intent = task.get("intent")
print(f"[LOOP] Failure detected for: {intent}. Attempting recovery...")
try:
if intent == "scaffold":
self.kernel.scaffold_module(task.get("module_name"))
else:
self.kernel.write_code(task.get("file"), task.get("code"))
success, output = KernelValidator.run_tests(self.root)
if success:
self.ledger.update_state(intent, "Recovered")
print(f"[LOOP] Recovery successful: {intent}")
os.remove(self.failure_file)
else:
print(f"[LOOP] Recovery failed. Manual review needed.\n{output}")
except Exception as e:
print(f"[LOOP] Critical recovery error: {e}")
time.sleep(3)
|