Spaces:
Running
Running
| """ | |
| File: /system.py | |
| Created Date: Monday December 1st 2025 | |
| Author: Christian Nonis <alch.infoemail@gmail.com> | |
| ----- | |
| Last Modified: Monday December 1st 2025 10:13:27 pm | |
| Modified By: Christian Nonis <alch.infoemail@gmail.com> | |
| ----- | |
| """ | |
| import asyncio | |
| from src.services.brain_identity import validate_brain_id | |
| from src.services.api.constants.requests import CreateBrainRequest | |
| from src.services.brain_lifecycle import BrainLifecycleService | |
| from src.services.data.main import data_adapter | |
| async def get_brains_list(): | |
| """ | |
| Get the list of brains. | |
| """ | |
| result = await asyncio.to_thread(data_adapter.get_brains_list) | |
| return result | |
| async def create_new_brain(request: CreateBrainRequest): | |
| """ | |
| Create a new brain | |
| """ | |
| brain_id = validate_brain_id(request.brain_id) | |
| result = await asyncio.to_thread(data_adapter.create_brain, brain_id) | |
| return result | |
| def get_brain_lifecycle_service() -> BrainLifecycleService: | |
| # Import lazily so lightweight system-route tests do not initialize every | |
| # configured storage client before a lifecycle operation is requested. | |
| from src.core.instances import ( | |
| cache_adapter, | |
| graph_adapter, | |
| vector_store_adapter, | |
| ) | |
| return BrainLifecycleService( | |
| data_client=data_adapter.data, | |
| graph_client=graph_adapter.graph, | |
| vector_client=vector_store_adapter.vector_store, | |
| cache_client=cache_adapter.cache, | |
| ) | |
| async def clear_brain(brain_id: str, service: BrainLifecycleService): | |
| result = await asyncio.to_thread(service.clear, brain_id) | |
| return result.as_dict() | |
| async def delete_brain(brain_id: str, service: BrainLifecycleService): | |
| result = await asyncio.to_thread(service.delete, brain_id) | |
| return result.as_dict() | |