Pr 34

.github/workflows/python-ci.yml

@@ -15,14 +15,14 @@ jobs:
 
     steps:
       - name: Checkout repository
-        uses: actions/checkout@v4
+        uses: actions/checkout@v5
 
       - name: Configure Python Path
         run: |
-          echo "PYTHONPATH=$PWD:$PWD/services:$PWD/services/guardian" >> $GITHUB_ENV
+          echo "PYTHONPATH=$PWD:$PWD/src:$PWD/services:$PWD/services/guardian" >> $GITHUB_ENV
 
       - name: Set up Python
-        uses: actions/setup-python@v5
+        uses: actions/setup-python@v6
         with:
           python-version: "3.12"
 
@@ -37,9 +37,6 @@ jobs:
       - name: Compile check
         run: python -m compileall services
 
-      - name: Run tests
-        run: python -m pytest -v
-
-      - name: Coverage
-        run: python -m pytest --cov=services.guardian --cov-config=.coveragerc.guardian --cov-config=.coveragerc --cov-report=term-missing --cov-fail-under=0
+      - name: Run tests with coverage
+        run: python -m pytest -v --cov=services.guardian --cov-config=.coveragerc --cov-report=term-missing --cov-fail-under=0
 

.gitignore

@@ -10,4 +10,11 @@ __pycache__/
 *.before_mother_brain
 *.runtime_backup
 .env.local
+<<<<<<< HEAD
+<<<<<<< HEAD
+=======
 guardian_audit.json
+>>>>>>> origin/main
+=======
+guardian_audit.json
+>>>>>>> origin/main

ai/client.py

@@ -11,6 +11,24 @@ def generate(prompt: str, model: str = "gemini-3.5-flash") -> str:
         return "AI Runtime Mock Ready"
 
     api_key = os.getenv("GEMINI_API_KEY")
+
+    client = genai.Client(
+        api_key=api_key
+    )
+
+    try:
+        response = client.models.generate_content(
+            model="gemini-3.5-flash",
+            contents=prompt
+        )
+
+        return response.text
+
+    except ClientError as e:
+
+        if e.code == 429:
+            return "AI Runtime Quota Limited - Fallback Mode"
+
     client = genai.Client(api_key=api_key)
 
     try:

ai_gateway/action_engine.py

@@ -0,0 +1,35 @@
+from datetime import datetime
+
+
+class ActionEngine:
+
+    def __init__(self):
+        self.actions = []
+
+
+    def create(self, decision):
+
+        action = {
+            "action": decision.get(
+                "action",
+                "NO_ACTION"
+            ),
+            "risk_level": decision.get(
+                "risk",
+                {}
+            ).get(
+                "risk_level",
+                "UNKNOWN"
+            ),
+            "status": "PLANNED",
+            "timestamp": datetime.utcnow().isoformat()
+        }
+
+
+        self.actions.append(action)
+
+        return action
+
+
+    def history(self):
+        return self.actions

ai_gateway/aeon_ai_gateway.py

@@ -1,34 +1,138 @@
+import os
+
 from ai_gateway.gemini_provider import GeminiProvider
+from ai_gateway.qwen_adapter import QwenAdapter
+from ai_gateway.health import ProviderHealth
+from ai_gateway.router import ProviderRouter
+from ai_gateway.metrics import GatewayMetrics
+from ai_gateway.circuit_breaker import CircuitBreaker
+from ai_gateway.events import EventBus
+from ai_gateway.telemetry import Telemetry
+from ai_gateway.risk import RiskAnalyzer
+from ai_gateway.guardian import Guardian
+from ai_gateway.command_center import CommandCenter
+from ai_gateway.approval import ApprovalGate
+from ai_gateway.audit import AuditTrail
+from ai_gateway.rollback import RollbackEngine
+from ai_gateway.action_engine import ActionEngine
+from ai_gateway.policy import PolicyGuard
+from ai_gateway.executor import Executor
+from ai_gateway.decision import DecisionContract
 
 
 class AEONAI:
 
-    def __init__(self):
-        self.provider = GeminiProvider()
+    def __init__(self, provider=None):
+        self.health = ProviderHealth()
+        self.router = ProviderRouter()
+        self.metrics = GatewayMetrics()
+        self.breaker = CircuitBreaker()
+        self.events = EventBus()
+        self.telemetry = Telemetry()
+        self.risk = RiskAnalyzer()
+        self.guardian = Guardian()
+        self.command = CommandCenter()
+        self.approval = ApprovalGate()
+        self.audit = AuditTrail()
+        self.rollback = RollbackEngine()
+        self.actions = ActionEngine()
+        self.policy = PolicyGuard()
+        self.executor = Executor()
+        self.decision = DecisionContract()
+
+        provider = provider or os.getenv(
+            "AEON_LLM_PROVIDER",
+            "gemini"
+        )
+
+        if provider == "qwen":
+
+            self.provider = QwenAdapter(
+                {
+                    "model": os.getenv(
+                        "QWEN_MODEL",
+                        "qwen-max"
+                    ),
+                    "api_key": os.getenv(
+                        "DASHSCOPE_API_KEY",
+                        ""
+                    )
+                }
+            )
+
+            self.mode = "qwen"
+
+        else:
+
+            self.provider = GeminiProvider()
+            self.mode = "gemini"
+
+        self.health.check(self.mode, self.provider)
+        self.router.register(self.mode, self.provider)
+
 
 
     def analyze(self, event):
 
         prompt = f"""
 You are AEON MATRIX Mother Brain AI.
 
-System:
-- Autonomous Logistics Operating System
-- WMS Intelligence
-- Digital Twin
-- Command Center
-- Predictive Operations
-- AI Governance
-
 Analyze operational event:
 
 {event}
 
 Return:
+
 1. Situation
 2. Risk
 3. Prediction
 4. Recommended Action
 """
 
-        return self.provider.generate(prompt)
+
+        result = self.router.execute(
+            prompt,
+            self.breaker
+        )
+
+
+        self.events.publish(
+            "AI_DECISION",
+            {
+                "provider": self.mode,
+                "event": event
+            }
+        )
+
+
+        self.telemetry.capture(
+            self.mode,
+            event,
+            result
+        )
+
+
+        risk = self.risk.analyze(
+            event
+        )
+
+
+        guardian_result = self.guardian.evaluate(
+            risk
+        )
+
+
+        final_decision = self.decision.build(
+            result,
+            guardian_result
+        )
+
+
+        self.events.publish(
+            "GUARDIAN_DECISION",
+            final_decision
+        )
+
+
+        return final_decision
+

ai_gateway/approval.py

@@ -0,0 +1,24 @@
+from datetime import datetime
+
+
+class ApprovalGate:
+
+    def __init__(self):
+        self.records=[]
+
+
+    def approve(self, action):
+
+        record={
+            "action":action,
+            "approved":True,
+            "timestamp":datetime.utcnow().isoformat()
+        }
+
+        self.records.append(record)
+
+        return record
+
+
+    def history(self):
+        return self.records

ai_gateway/audit.py

@@ -0,0 +1,19 @@
+from datetime import datetime
+
+
+class AuditTrail:
+
+    def __init__(self):
+        self.logs=[]
+
+
+    def record(self,event):
+
+        self.logs.append({
+            "event":event,
+            "time":datetime.utcnow().isoformat()
+        })
+
+
+    def report(self):
+        return self.logs

ai_gateway/circuit_breaker.py

@@ -0,0 +1,52 @@
+from datetime import datetime
+
+
+class CircuitBreaker:
+
+    def __init__(self, threshold=3):
+        self.threshold = threshold
+        self.failures = {}
+        self.state = {}
+
+    def record_success(self, provider):
+
+        self.failures[provider] = 0
+        self.state[provider] = {
+            "status": "CLOSED",
+            "updated": datetime.utcnow().isoformat()
+        }
+
+
+    def record_failure(self, provider):
+
+        if provider not in self.failures:
+            self.failures[provider] = 0
+
+        self.failures[provider] += 1
+
+
+        if self.failures[provider] >= self.threshold:
+            self.state[provider] = {
+                "status": "OPEN",
+                "updated": datetime.utcnow().isoformat()
+            }
+
+        else:
+            self.state[provider] = {
+                "status": "DEGRADED",
+                "updated": datetime.utcnow().isoformat()
+            }
+
+
+    def allow(self, provider):
+
+        status = self.state.get(
+            provider,
+            {"status":"CLOSED"}
+        )
+
+        return status["status"] != "OPEN"
+
+
+    def report(self):
+        return self.state

ai_gateway/command_center.py

@@ -0,0 +1,11 @@
+
+class CommandCenter:
+
+
+    def status(self):
+
+        return {
+            "system":"AEON MATRIX",
+            "mode":"AUTONOMOUS GOVERNANCE",
+            "status":"ONLINE"
+        }

ai_gateway/decision.py

@@ -0,0 +1,20 @@
+class DecisionContract:
+
+
+    def build(
+        self,
+        analysis,
+        guardian
+    ):
+
+        return {
+
+            "analysis": analysis,
+
+            "guardian":
+                guardian,
+
+            "status":
+                "DECISION_READY"
+
+        }