Initialize with required repository dependency injection. Args: repo: Repository instance for database operations

Initialize the chat service with repository and cache dependencies. Args: repo: Chat repository for database access (req

Initialize repository with database session. Args: db: SQLAlchemy session (sync or async)

Initialize repository with async database session. Args: db: AsyncSession

Initialize Session Context Manager Args: timeout_minutes: Session timeout in minutes

Initialize Ask Pipeline Args: llm: LLM provider for agents qdrant_manager: Qdrant manager for MDL retrieval

Initialize Historical Question Retrieval Args: qdrant_manager: Qdrant manager instance llm: LLM provider for

Args: py_type: The schema type to validate against.

Generate simple natural language answer (placeholder for M4) TODO: Replace with AnswerSummarizationAgent in M4

Decorator to handle Redis connection errors

Add a new chat message asynchronously. Args: message_data: Dictionary containing message attributes Returns:

Add HATEOAS links to a response dictionary. Args: response_data: Response data dictionary to add links to resource_type: Typ

Add message to session

Add pagination headers to a response. Args: response: The response to add headers to request: The original request t

Analyze a chat request and generate insights. Args: request: FastAPI request object dto: Chat data repo: Repository

Handle all API errors with standardized format.

Ask a question with streaming response Args: request: Question request with project_id, question, etc. qdrant: Qdrant manage

Wrapper for asynchronous functions.

Decorator for endpoint functions to cache their responses. Example usage: @router.get("/example") @cached_response(ttl_seconds=60)

Check if the user has exceeded their rate limit. This is a secondary check beyond the middleware rate limit. It enforces user-specific l

Synchronous intent classification (for compatibility)

Clean up all datasource connections. Should be called during application shutdown.

Clean up expired adapter connections. Returns: Number of connections closed

Remove expired sessions

Clear all cache entries

Clear all cache entries - use with caution!

Get or create Qdrant client

Get or create async Qdrant client

Close Qdrant connection

Close all SQLite connections in the pool (static method).

Close all Qdrant connections

Get a raw asyncpg connection with automatic resource management. Yields: asyncpg.Connection: Direct asyncpg connection

Get the database connection URL.

Count total number of entities asynchronously. Returns: Total count

Count total number of entities synchronously. Returns: Total count

创建用户

创建会话

创建会话

Create a new project

Create a new project

Create a new model

Create new entity asynchronously. Args: entity: Entity to create Returns: Created entity with ID po

Create a new chat session asynchronously. Args: session_data: Dictionary containing session attributes Returns:

Create collection if it doesn't exist

Create a new datasource with connection information. Args: data: Datasource creation data db: Database session Returns:

Create a new datasource. Args: datasource_data: Datasource data dictionary Returns: New datasource

Create a new MDL model

Create a new MDL project

Create new entity synchronously. Args: entity: Entity to create Returns: Created entity with ID pop

创建用户（仅管理员） **需要鉴权**: 是（管理员） **请求参数**: - username: 用户名 - email: 邮箱 - password: 密码 - is_admin: 是否管理员（默认 false）