7|h bdZddlmZmZmZddlmZddlmZddl m Z ddl m Z Gdde Z y ) zWrapper around Dria Retriever.)AnyListOptional)CallbackManagerForRetrieverRun)Document) BaseRetriever)DriaAPIWrapperc eZdZUdZeed<ddedeedeffd Z dded ed ed ed ef d Z de d dfdZ dede d e efdZxZS) DriaRetrieverz*`Dria` retriever using the DriaAPIWrapper. api_wrapperNapi_key contract_idkwargsc Bt||}t|dd|i|y)z Initialize the DriaRetriever with a DriaAPIWrapper instance. Args: api_key: The API key for Dria. contract_id: The contract ID of the knowledge base to interact with. )r rr N)r super__init__)selfr rrr __class__s h/var/www/html/test/engine/venv/lib/python3.12/site-packages/langchain_community/retrievers/dria_index.pyrzDriaRetriever.__init__s&%W+N  ;[;F;name descriptioncategory embeddingreturncB|jj||||}|S)awCreate a new knowledge base in Dria. Args: name: The name of the knowledge base. description: The description of the knowledge base. category: The category of the knowledge base. embedding: The embedding model to use for the knowledge base. Returns: The ID of the created knowledge base. )r create_knowledge_base)rrrrrresponses rrz#DriaRetriever.create_knowledge_bases*&##99 +x rtextsct|Dcgc] }|d|dd}}|jj|ycc}w)zAdd texts to the Dria knowledge base. Args: texts: An iterable of texts and metadatas to add to the knowledge base. Returns: List of IDs representing the added texts. textmetadata)r"r#N)r insert_data)rr r"datas r add_textszDriaRetriever.add_texts4sARWWf4 3CDWW $$T*Xs5query run_managerc |jj|}|Dcgc]}t|d|d|dd}}|Scc}w)a*Retrieve relevant documents from Dria based on a query. Args: query: The query string to search for in the knowledge base. run_manager: Callback manager for the retriever run. Returns: A list of Documents containing the search results. r#idscore)r*r+) page_contentr#)r searchr)rr'r(resultsresultdocss r_get_relevant_documentsz%DriaRetriever._get_relevant_documentsCsd""))%0 "   #J/ &t vgG     s A)N) Unspecifiedjina)__name__ __module__ __qualname____doc__r __annotations__strrrrrrr&rrr1 __classcell__)rs@rr r s4 < <(3- r@s($&&C-38KMKr