Function _open_api_chat_response

astrbot/dashboard/api/open_api.py:88–125

(
    post_data: dict[str, Any],
    auth: AuthContext,
    open_api_service: OpenApiService,
    chat_service: ChatService,
)

async def _open_api_chat_response(
    post_data: dict[str, Any],
    auth: AuthContext,
    open_api_service: OpenApiService,
    chat_service: ChatService,
) -> StreamingResponse | JSONResponse:
    if auth.via != "api_key":
        return await _build_streaming_chat_response(
            chat_service,
            auth.username,
            post_data,
        )

    try:
        (
            effective_username,
            session_id,
            config_id,
        ) = await open_api_service.prepare_chat_send(
            post_data,
            _get_chat_config_list(open_api_service),
        )
    except OpenApiServiceError as exc:
        return _open_api_error(str(exc))

    config_err = await open_api_service.update_session_config_route(
        username=effective_username,
        session_id=session_id,
        config_id=config_id,
    )
    if config_err:
        return _open_api_error(config_err)

    return await _build_streaming_chat_response(
        chat_service,
        effective_username,
        post_data,
    )


async def _insert_webchat_user_message(