Spaces:
Runtime error
Runtime error
Rename codrioagix to Codriaoagix.py
Browse files
codrioagix β Codriaoagix.py
RENAMED
|
@@ -21,6 +21,7 @@ from components.neural_symbolic import NeuralSymbolicProcessor
|
|
| 21 |
from components.federated_learning import FederatedAI
|
| 22 |
from utils.database import Database
|
| 23 |
from utils.logger import logger
|
|
|
|
| 24 |
|
| 25 |
|
| 26 |
class AICoreAGIX:
|
|
@@ -40,6 +41,7 @@ class AICoreAGIX:
|
|
| 40 |
self.federated_ai = FederatedAI()
|
| 41 |
self._encryption_key = Fernet.generate_key()
|
| 42 |
self.jwt_secret = "your_jwt_secret_key"
|
|
|
|
| 43 |
self.speech_engine = pyttsx3.init()
|
| 44 |
|
| 45 |
async def generate_response(self, query: str, user_id: int) -> Dict[str, Any]:
|
|
@@ -51,10 +53,14 @@ class AICoreAGIX:
|
|
| 51 |
if result["status"] == "flagged":
|
| 52 |
logger.warning(result["warning"])
|
| 53 |
|
| 54 |
-
#
|
| 55 |
vectorized_query = self._vectorize_query(query)
|
| 56 |
-
self.
|
| 57 |
|
|
|
|
|
|
|
|
|
|
|
|
|
| 58 |
model_response = await self._generate_local_model_response(query)
|
| 59 |
agent_response = self.multi_agent_system.delegate_task(query)
|
| 60 |
self_reflection = self.self_reflective_ai.evaluate_response(query, model_response)
|
|
|
|
| 21 |
from components.federated_learning import FederatedAI
|
| 22 |
from utils.database import Database
|
| 23 |
from utils.logger import logger
|
| 24 |
+
from secure_memory import SecureMemorySession
|
| 25 |
|
| 26 |
|
| 27 |
class AICoreAGIX:
|
|
|
|
| 41 |
self.federated_ai = FederatedAI()
|
| 42 |
self._encryption_key = Fernet.generate_key()
|
| 43 |
self.jwt_secret = "your_jwt_secret_key"
|
| 44 |
+
self.secure_memory = SecureMemorySession(self._encryption_key)
|
| 45 |
self.speech_engine = pyttsx3.init()
|
| 46 |
|
| 47 |
async def generate_response(self, query: str, user_id: int) -> Dict[str, Any]:
|
|
|
|
| 53 |
if result["status"] == "flagged":
|
| 54 |
logger.warning(result["warning"])
|
| 55 |
|
| 56 |
+
# Vectorize and encrypt
|
| 57 |
vectorized_query = self._vectorize_query(query)
|
| 58 |
+
self.secure_memory.encrypt_vector(user_id, vectorized_query)
|
| 59 |
|
| 60 |
+
# (Optional) retrieve memory for continuity
|
| 61 |
+
user_vectors = self.secure_memory.decrypt_vectors(user_id)
|
| 62 |
+
|
| 63 |
+
# Main pipeline
|
| 64 |
model_response = await self._generate_local_model_response(query)
|
| 65 |
agent_response = self.multi_agent_system.delegate_task(query)
|
| 66 |
self_reflection = self.self_reflective_ai.evaluate_response(query, model_response)
|