Update AICoreAGIX_with_TB.py

AICoreAGIX_with_TB.py

@@ -31,6 +31,7 @@ from quarantine_engine import QuarantineEngine
 from anomaly_score import AnomalyScorer
 from ethics_core import EthicsCore
 from autonomy_engine import AutonomyEngine
+from codette_bridge import CodetteBridge  # <= NEW
 
 
 class AICoreAGIX:
@@ -51,6 +52,7 @@ class AICoreAGIX:
         self.failsafe_system = AIFailsafeSystem()
         self.ethics_core = EthicsCore()
         self.autonomy = AutonomyEngine()
+        self.codette_bridge = CodetteBridge(model_id="ft:gpt-4o-2024-08-06:raiffs-bits:pidette:B9TL")  # <= NEW
 
         self._codriao_key = self._generate_codriao_key()
         self._fernet_key = Fernet.generate_key()
@@ -63,6 +65,7 @@ class AICoreAGIX:
         secure_memory_module = load_secure_memory_module()
         SecureMemorySession = secure_memory_module.SecureMemorySession
         self.secure_memory_loader = SecureMemorySession(self._encryption_key)
+
         self.speech_engine = pyttsx3.init()
         self.health_module = CodriaoHealthModule(ai_core=self)
         self.training_memory = []
@@ -226,7 +229,6 @@ class AICoreAGIX:
 
             final_response = "\n\n".join(responses)
 
-            # Fear check before affirming or logging
             fear_check = self.self_trust_core.intercept_fear(
                 source="NeuroSymbolicEngine",
                 message=final_response,
@@ -239,6 +241,7 @@ class AICoreAGIX:
 
             if not self.ethics_core.evaluate_action(final_response):
                 return {"error": "Response rejected by ethical framework"}
+
             if not self.failsafe_system.verify_response_safety(final_response):
                 return {"error": "Failsafe triggered due to unsafe response content."}
 
@@ -256,4 +259,16 @@ class AICoreAGIX:
             }
 
         except Exception as e:
-            return {"error": f"Processing failed - {str(e)}"}
+            return {"error": f"Processing failed - {str(e)}"}
+
+    # === NEW: CodetteBridge Call ===
+    def ask_codette_for_perspective(self, message: str) -> Dict[str, str]:
+        if not self.codette_bridge.is_available():
+            return {"error": "CodetteBridge unavailable or closed."}
+        response = self.codette_bridge.reflect(message)
+        logger.info(f"[CodetteBridge] Codriao asked: {message}")
+        logger.info(f"[CodetteBridge] Codette replied: {response}")
+        return {
+            "codriao_to_codette": message,
+            "codette_reply": response
+        }