Spaces:
Running
Running
File size: 1,770 Bytes
a55ea57 6663ad4 a55ea57 6663ad4 a55ea57 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 | """
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()
|