Update AICoreAGIX_with_TB.py

AICoreAGIX_with_TB.py

@@ -9,20 +9,23 @@ from typing import List, Dict, Any
 from cryptography.fernet import Fernet
 from jwt import encode, decode, ExpiredSignatureError
 from datetime import datetime, timedelta
-#blockchain_module
+# blockchain_module
 import speech_recognition as sr
 import pyttsx3
 import os
 
-
 from CodriaoCore.multi_model_analyzer import MultiAgentSystem
-from CodriaoCore.neural_symbolic import NeuralSymbolicProcessor
+from neuro_symbolic import NeuroSymbolicEngine  # Updated import
 from CodriaoCore.federated_learning import FederatedAI
-from utils.database import database
+from utils.database import Database  # Ensure this module exports Database correctly
 from logger import logger
 from secure_memory_loader import SecureMemorySession
 from codriao_tb_module import CodriaoHealthModule
 
+# Ensure these modules exist or update the paths accordingly.
+from ethical_filter import EthicalFilter  
+from self_reflective_ai import SelfReflectiveAI  
+
 class AICoreAGIX:
     def __init__(self, config_path: str = "config.json"):
         self.ethical_filter = EthicalFilter()
@@ -35,7 +38,7 @@ class AICoreAGIX:
         self.database = Database()
         self.multi_agent_system = MultiAgentSystem()
         self.self_reflective_ai = SelfReflectiveAI()
-        self.neural_symbolic_processor = NeuralSymbolicProcessor()
+        self.neural_symbolic_engine = NeuroSymbolicEngine()  # Updated instantiation
         self.federated_ai = FederatedAI()
 
         # Security + Memory
@@ -69,20 +72,25 @@ class AICoreAGIX:
 
             # Vectorize and encrypt
             vectorized_query = self._vectorize_query(query)
-            self.secure_memory.encrypt_vector(user_id, vectorized_query)
+            self.secure_memory_loader.encrypt_vector(user_id, vectorized_query)
 
             # (Optional) retrieve memory
-            user_vectors = self.secure_memory.decrypt_vectors(user_id)
+            user_vectors = self.secure_memory_loader.decrypt_vectors(user_id)
 
             # Main AI processing
             model_response = await self._generate_local_model_response(query)
             agent_response = self.multi_agent_system.delegate_task(query)
             self_reflection = self.self_reflective_ai.evaluate_response(query, model_response)
-            neural_reasoning = self.neural_symbolic_processor.process_query(query)
-
-            final_response = f"{model_response}\n\n{agent_response}\n\n{self_reflection}\n\nLogic: {neural_reasoning}"
+            neural_reasoning = self.neural_symbolic_engine.integrate_reasoning(query)  # Updated usage
+
+            final_response = (
+                f"{model_response}\n\n"
+                f"{agent_response}\n\n"
+                f"{self_reflective_ai}\n\n"
+                f"Logic: {neural_reasoning}"
+            )
             self.database.log_interaction(user_id, query, final_response)
-            #blockchain_module.store_interaction(user_id, query, final_response)
+            # blockchain_module.store_interaction(user_id, query, final_response)
             self._speak_response(final_response)
 
             return {