o ưieD@sdZddlZddlZddlmZddlmZmZmZm Z m Z m Z ddl Z ddl Z ddlmZddlmZddlmZddlmZdd lmZdd lmZmZmZmZmZmZm Z dd l!m"Z"m#Z#dd l$m%Z%eZ& d,d e e e fddZ' d,de efddZ(e#          d-de e)de e e)de ede ede ee)e)fde ee)efde ee)efde ee)efde e e*e j+fde e)defddZ,e#          d-de e)de e e)de ede ede ee)e)fde ee)efde ee)efde ee)efde e e*e j+fde e)de eeeeefffd d!Z-e#         d.d"e)d#e e)e e)fd$e ed%e e.d&e ed'e e/de ee)efde ee)efde ee)efde e e*e j+fde e)defd(d)Z0e#         d.d"e)d#e e)e e)fd$e ed%e e.d&e ed'e e/de ee)efde ee)efde ee)efde e e*e j+fde e)de eeeeefffd*d+Z1dS)/z@ LiteLLM SDK Functions for Creating and Searching Vector Stores N)partial)Any CoroutineDictListOptionalUnion)request_timeout)get_llm_provider)Logging)BaseLLMHTTPHandler)GenericLiteLLMParams)&VectorStoreCreateOptionalRequestParamsVectorStoreCreateResponseVectorStoreFileCountsVectorStoreResultContent&VectorStoreSearchOptionalRequestParamsVectorStoreSearchResponseVectorStoreSearchResult)ProviderConfigManagerclient)VectorStoreRequestUtils mock_resultscCs.|durtdtdddgdg}tdd|d S) z%Mock response for vector store searchNgffffff?z5This is a sample search result from the vector store.text)rtype)Zscorecontentz vector_store.search_results.pagez sample query)objectZ search_querydata)rrrrrQ/home/app/Keep/.python/lib/python3.10/site-packages/litellm/vector_stores/main.py!mock_vector_store_search_response$s r! mock_responsec Cs8|durtdddddtdddddddddddd }|S) z%Mock response for vector store createNZ vs_mock123Z vector_storeiEezMock Vector Storer)Z in_progress completedfailed cancelledtotalr#) idrZ created_atnamebytesZ file_countsstatus expires_afterZ expires_atZlast_active_atmetadata)rrr"rrr !mock_vector_store_create_response<s*r.r(file_idsr+chunking_strategyr, extra_headers extra_query extra_bodytimeoutcustom_llm_providerreturnc  st} zFt} d| d<| durd} ttf|||||||||| d | } t}t|j| }| d|IdH}t |rF|IdH}|WS|}|WSt y`}z t j d| || | dd}~ww)z' Async: Create a vector store. TacreateNopenai) r(r/r+r0r,r1r2r3r4r5modelr5Zoriginal_exceptionZcompletion_kwargs extra_kwargs) localsasyncioget_event_looprcreate contextvars copy_contextrunrun_in_executor iscoroutine Exceptionlitellmexception_type)r(r/r+r0r,r1r2r3r4r5kwargs local_varsloopfuncctxfunc_with_context init_responseresponseerrr r7XsR    r7c  KsPt} z| d} | dd} | dddu}tdi| }|jr3t|jtr3ttdi|jdWS| dur9d} d | vrIt | ddd \}} }}nd}| } t j t | |d }|durbtd | | | t| }| jdd |i|d| i| dtj||| || |||pt|| dd }|WSty}z t jd| || | dd}~ww)a Create a vector store. Args: name: The name of the vector store. file_ids: A list of File IDs that the vector store should use. expires_after: The expiration policy for the vector store. chunking_strategy: The chunking strategy used to chunk the file(s). metadata: Set of 16 key-value pairs that can be attached to an object. Returns: VectorStoreCreateResponse containing the created vector store details. litellm_logging_objlitellm_call_idNr7FTr-r8/r:r5litellm_paramsproviderapi_typez)Vector store create is not supported for r(r:Zoptional_paramsrUr5r) #vector_store_create_optional_paramsvector_store_provider_configr5rU logging_objr1r3r4 _is_asyncrr9r)r<getpopr r" isinstancedictr.rr r!get_provider_vector_stores_configrF LlmProviders ValueErrorupdaterZ0get_requested_vector_store_create_optional_paramupdate_environment_variablesbase_llm_http_handlerZvector_store_create_handlerr rErG)r(r/r+r0r,r1r2r3r4r5rHrIrQrRr]rUrX_r[rZrOrPrrr r?s     r?vector_store_idqueryfiltersmax_num_resultsranking_options rewrite_queryc st} zGt} d| d<| durd} ttf|||||||||| | d | }t}t|j|}| d|IdH}t |rG|IdH}|WS|}|WSt ya}z t j d| || | dd}~ww)zg Async: Search a vector store for relevant chunks based on a query and file attributes filter. TasearchNr8) rirjrkrlrmrnr1r2r3r4r5r9) r<r=r>rsearchr@rArBrCrDrErFrG)rirjrkrlrmrnr1r2r3r4r5rHrIrJrKrLrMrNrOrPrrr rosT    roc Kst} z| d} | dd}| dddu}| d|}tjdur=|dur=z tj|}| |Wn ty<Ynwtdd|i| }|j rbt |j t t frbd}t |j t r\|j }t |dWS| durhd } d | vrxt| ddd \}} }}nd}| } tjt| |d }|durtd | | | tj| |d}| j|||d|||d|jdd| dtj||||| || ||| pt|| dd }|WSty}z tjd| || | dd}~ww)a[ Search a vector store for relevant chunks based on a query and file attributes filter. Args: vector_store_id: The ID of the vector store to search. query: A query string or array for the search. filters: Optional filter to apply based on file attributes. max_num_results: Maximum number of results to return (1-50, default 10). ranking_options: Optional ranking options for search. rewrite_query: Whether to rewrite the natural language query for vector search. Returns: VectorStoreSearchResponse containing the search results. rQrRNroFTrirr8rSrTrVz)Vector store search is not supported for )r[)rirj)rRri)Z exclude_nonerYr) rirj#vector_store_search_optional_paramsr[r5rUr\r1r3r4r]rr9r)r<r^r_rFZvector_store_registryZ get_credentials_for_vector_storererEr r"r`strlistr!r rrbrcrdrZ0get_requested_vector_store_search_optional_paramrfZ model_dumprgZvector_store_search_handlerr rG)rirjrkrlrmrnr1r2r3r4r5rHrIrQrRr]Zvector_store_id_for_credentialsZregistry_credentialsrUrrXrhr[rqrOrPrrr rpSs           rp)N) NNNNNNNNNN) NNNNNNNNN)2__doc__r=r@ functoolsrtypingrrrrrrZhttpxrFZlitellm.constantsr Z1litellm.litellm_core_utils.get_llm_provider_logicr Z*litellm.litellm_core_utils.litellm_loggingr ZLiteLLMLoggingObjZ*litellm.llms.custom_httpx.llm_http_handlerr Zlitellm.types.routerr Zlitellm.types.vector_storesrrrrrrrZ litellm.utilsrrZlitellm.vector_stores.utilsrrgr!r.rrfloatTimeoutr7r?intboolrorprrrr sD       $          ?      w     B