U h@shdZddlZddlmZmZmZddlZddlZddlm Z m Z m Z ddl m Z dZGddde ZdS) zUtil that calls Tavily Search API. In order to set this up, follow instructions at: https://docs.tavily.com/docs/tavily-api/introduction N)DictListOptional) BaseModel SecretStrroot_validatorget_from_dict_or_envzhttps://api.tavily.comc @seZdZUdZeed<GdddZeddeeddd Z d d ggd d d fe e e e e e e e e e e e ee ee eed ddZd d ggd d d fe e e e e e e e e e e e ee ee ee ed ddZd d ggd d d fe e e e e e e e e e e e ee ee eed ddZd d ggd d d fe e e e e e e e e e e e ee ee ee ed ddZe ee edddZdS)TavilySearchAPIWrapperzWrapper for Tavily Search API.tavily_api_keyc@seZdZdZdS)zTavilySearchAPIWrapper.ConfigZforbidN)__name__ __module__ __qualname__extrarrO/tmp/pip-unpacked-wheel-9gdii04g/langchain_community/utilities/tavily_search.pyConfigsrT)pre)valuesreturncCst|dd}||d<|S)z9Validate that api key and endpoint exists in environment.r ZTAVILY_API_KEYr)clsrr rrrvalidate_environmentsz+TavilySearchAPIWrapper.validate_environmentZadvancedF) query max_results search_depthinclude_domainsexclude_domainsinclude_answerinclude_raw_contentinclude_imagesrc CsB|j||||||||d } tjtd| d} | | S)N Zapi_keyrrrrrrrr /searchjson)r get_secret_valuerequestspostTAVILY_API_URLraise_for_statusr$) selfrrrrrrrr paramsresponserrr raw_results$s  z"TavilySearchAPIWrapper.raw_resultsc Cs(|j||||||||d} || dS)aRun query through Tavily Search and return metadata. Args: query: The query to search for. max_results: The maximum number of results to return. search_depth: The depth of the search. Can be "basic" or "advanced". include_domains: A list of domains to include in the search. exclude_domains: A list of domains to exclude from the search. include_answer: Whether to include the answer in the results. include_raw_content: Whether to include the raw content in the results. include_images: Whether to include images in the results. Returns: query: The query that was searched for. follow_up_questions: A list of follow up questions. response_time: The response time of the query. answer: The answer to the query. images: A list of images. results: A list of dictionaries containing the results: title: The title of the result. url: The url of the result. content: The content of the result. score: The score of the result. raw_content: The raw content of the result. )rrrrrrr results)r- clean_results) r*rrrrrrrr Zraw_search_resultsrrrr.Bs# zTavilySearchAPIWrapper.resultsc s8tdf dd } | IdH} t| S)z6Get results from the Tavily Search API asynchronously.)rc sjd }t4IdH}|jtd|d4IdH^}|jdkr|IdH}|W5QIdHRW5QIdHRStd|jd|j W5QIdHRXW5QIdHRXdS)Nr!r"r#zError z: ) r r%aiohttpZ ClientSessionr'r(statustext Exceptionreason)r+sessionresdata rrrr rrrrr*rrfetchs   (z7TavilySearchAPIWrapper.raw_results_async..fetchN)strr$loads) r*rrrrrrrr r:Zresults_json_strrr9rraw_results_asyncqs" z(TavilySearchAPIWrapper.raw_results_asyncc s.|j||||||||dIdH} || dS)N)rrrrrrrr r.)r=r/) r*rrrrrrrr Z results_jsonrrr results_asyncs  z$TavilySearchAPIWrapper.results_async)r.rcCs*g}|D]}||d|ddq|S)z%Clean results from Tavily Search API.urlcontent)r?r@)append)r*r.r/resultrrrr/sz$TavilySearchAPIWrapper.clean_resultsN)r r r__doc__r__annotations__rrrrr;rintrboolr-r.r=r>r/rrrrr s     !   2   (   r )rCr$typingrrrr1r&Zlangchain_core.pydantic_v1rrrZlangchain_core.utilsr r(r rrrrs