ZiddlZddlZddlZddlmZmZmZmZmZm Z m Z ddl Z ddl m Z ddlmZmZmZmZmZmZGddZdS)N)LiteralSequenceOptionalListUnionAsyncGenerator Awaitable)get_max_items_from_list)UsageLimitExceededErrorInvalidAPIKeyErrorMissingAPIKeyErrorBadRequestErrorForbiddenError TimeoutErrorc)>eZdZdZ dVdeedeedeeeefdeedeed eef d Zd Z d Z d Z dWdede dde dde ddedede de deedeedeee dfdeee dfd ed!ed"ed#ed$ed%ed&ed'ef(d(Z dWdede dde dde ddedede de deedeedeee dfdeee dfd ed!ed"ed#ed$ed%ed&ed'ef(d)Z dXd+eeeefd ed,e dd-e dd!ed$ed%eded.e d'efd/Z dXd+eeeefd ed,e dd-e dd!ed$ed%eded.e d'efd0Z dYd2ed3e d4e d5e d6ed7eed8eed9eedeed:ed ed,e dd-e dd!ed$ed%ed.e d'ef$d;Z dYd2ed3e d4e d5e d6ed7eed8eed9eedeed:ed,e dd ed-e dd!ed$ed%ed.e d'ef$d<Z dZd2ed3e d4e d5e d6ed7eed8eed9eedeed:ed ed!ed%ed'efd=Z dZd2ed3e d4e d5e d6ed7eed8eed9eedeed:ed ed!ed%ed'efd>Z d[dede dde dde de deedeedDe d!ed"ed$ed'efdEZ d\dede dde dde de deedeed!ed"ed$ed'efdGZ d]dede dde d!ed"ed'eef dHZ d^dKedLe dMdNedOedPe dQd!eed'eeedfeeffdRZ d^dKedLe dMdNedOedPe dQd!eed'eeeedfffdSZ!dTed'efdUZ"dS)_AsyncTavilyClientz( Async Tavily API client class. Nnewsgeneralfinanceapi_keycompany_info_tagsproxies api_base_url client_source project_idc,|tjd}|st|pi}|dtjd|dtjdd}d|D}|rd|Dnd}|ptjd } |pd |_t jd d ||pd d| rd| ini|j||_||_ dS)NTAVILY_API_KEYhttpTAVILY_HTTP_PROXYhttpsTAVILY_HTTPS_PROXY)zhttp://zhttps://ci|] \}}||| Sr%).0keyvalues N/root/projects/butler/venv/lib/python3.11/site-packages/tavily/async_tavily.py z.AsyncTavilyClient.__init__..$s$WWWeQVW#uWWWc@i|]\}}|tj|S))proxy)httpxAsyncHTTPTransport)r&schemer-s r)r*z.AsyncTavilyClient.__init__..'s, g g g}vuVU-E::: g g gr+TAVILY_PROJECTzhttps://api.tavily.comzapplication/jsonzBearer z tavily-python)z Content-Type AuthorizationzX-Client-Sourcez X-Project-ID)headersbase_urlmounts) osgetenvrgetitems _api_base_urlr. AsyncClient_client_company_info_tags) selfrrrrrrmapped_proxies proxy_mountstavily_projects r)__init__zAsyncTavilyClient.__init__sf ?i 011G '$&& &-R{{6295H+I+IJJ GRY7K-L-LMM   XW~7K7K7M7MWWW  g gP^PdPdPfPf g g g g  $Bry1A'B'B)E-E( 2!47!4!4#0#CO8FMNN332  '     #4r+cHK|jd{VdS)z7Close the client and release connection pool resources.N)r<acloser>s r)closezAsyncTavilyClient.close=s2l!!###########r+c K|SNr%rEs r) __aenter__zAsyncTavilyClient.__aenter__As  r+c>K|d{VdSrH)rF)r>exc_typeexc_valexc_tbs r) __aexit__zAsyncTavilyClient.__aexit__Ds,jjllr+<query search_depth)basicadvancedfastz ultra-fasttopic)rrr time_range)dayweekmonthyear start_dateend_datedays max_resultsinclude_domainsexclude_domainsinclude_answer)rRrSinclude_raw_content)markdowntextinclude_imagestimeoutcountryauto_parametersinclude_favicon include_usage exact_matchreturncKid|d|d|d|d|d|d|d| d | d |d | d | d | d|d|d|d|d|i}d|D}|r||t|d} |jdt j||d{V}n"#tj$rt|wxYw|j dkr|Sd} | di dd}n#t$rYnwxYw|j dkrt||j dvrt||j dkrt||j dkrt!||) zH Internal search method to send the request to the API. rPrQrUrVr[r\r]rarbr^r_r`rergrhrirjrkci|] \}}||| SrHr%r&kvs r)r*z-AsyncTavilyClient._search..v???A1r+xz/searchcontentrfNdetailerroriii)r9updateminr<postjsondumpsr.TimeoutExceptionr status_coder8 Exceptionr rr rraise_for_status)r>rPrQrUrVr[r\r]r^r_r`rarbrerfrgrhrirjrkkwargsdataresponserxs r)_searchzAsyncTavilyClient._searchGs4 U L  U  *  *     D  n  "#6  ;      n  w   ! " ]# $ ;%  *@????  KK   gs## (!\..y$*TBRBR\c.ddddddddHH% ( ( (w'' ' (  3 & &==?? "F !,,Xr::>>wMM    #s**-f555%66$V,,,%,,(000%,,%f---//111s5B88C<rPrQrUrVr[r\r]r^r_r`rarbrerfrgrhrirjrkr response_dicttavily_resultss r)searchzAsyncTavilyClient.searchs`2gs##*dl5---8D -16-7Aj-7Aj - 5=H - 15 -8C{-.rrr+z/extractrtNrvrwrxryrzr{r|r})r9r~r<rrrr.rrrr8rr rr rr)r>rrerrrfrirjrPrrrrrxs r)_extractzAsyncTavilyClient._extracts$,*.*!2   @????  KK    (!\..z4:dCSCS]d.eeeeeeeeHH% ( ( (w'' ' (  3 & &==?? "F !,,Xr::>>wMM    #s**-f555%66$V,,,%,,(000%,,%f---//111s5A;;B?rrerrrfrirjrPrrrrrs r)extractzAsyncTavilyClient.extracts ,dmD,:,9,2,3 . =L:G27>O . ./5 . . . . . . . . '**9b99&**+;R@@#1 i *8 &'r+url max_depth max_breadthlimit instructions select_pathsselect_domains exclude_pathsallow_externalc^Kid|d|d|d|d|d|d|d|d | d | d | d | d | d|d|d|d|}|r||d|D} |jdt j||d{V}n"#t j$rt|wxYw|j dkr|Sd} | di dd}n#t$rYnwxYw|j dkrt||j dvrt||j dkrt||j dkrt||)zG Internal crawl method to send the request to the API. rrrrrrrrr`rrerrrfrirjrci|] \}}||| SrHr%ros r)r*z,AsyncTavilyClient._crawl..Zrrr+z/crawlrtNrvrwrxryrzr{r|r}r~r9r<rrrr.rrrr8rr rr rr)r>rrrrrrrrr`rrerrrfrirjrrrrrxs r)_crawlzAsyncTavilyClient._crawl,st. 3   ;  U  L  L   n  ]    n  n  ]  f  w   ]! " !2# (  KK   ????? (!\..xDAQAQ[b.ccccccccHH% ( ( (w'' ' (  3 & &==?? "F !,,Xr::>>wMM    #s**-f555%66$V,,,%,,(000%,,%f---//111s.5B$$C(rrrrrrrrr`rrrerrfrirjrrrs r)crawlzAsyncTavilyClient.crawlus0*dk#....7i.0; .+0%.2> . 2> . 4B> .3@-.5DO.4B>.3@-.4B>.,26.-4G.5DO.3@-. 7H6G&,#........ &r+cK||||||||| | | | | d }|r||d|D} |jdt j|| d{V}n"#t j$rt| wxYw|j dkr|Sd} | di d d}n#t$rYnwxYw|j d krt||j d vrt||j d krt||j d krt||)zE Internal map method to send the request to the API. ) rrrrrrrrr`rrerfrjci|] \}}||| SrHr%ros r)r*z*AsyncTavilyClient._map..rrr+z/maprtNrvrwrxryrzr{r|r}r)r>rrrrrrrrr`rrerfrjrrrrxs r)_mapzAsyncTavilyClient._maps("&((,*.,,*    KK   ????? (!\..vtz$?O?OY`.aaaaaaaaHH% ( ( (w'' ' (  3 & &==?? "F !,,Xr::>>wMM    #s**-f555%66$V,,,%,,(000%,,%f---//111s 5A??Brrrrrrrrr`rrerfrjrrs r)mapzAsyncTavilyClient.maps{((di ..70;*/1=1=3A2?4C3A3A,32? . .'- . . . . . . . . r+rRr max_tokensc Kt| d} |j|f||||||ddd| | | d | d{V} | dg}d|D}tjt ||S)a Get the search context for a query. Useful for getting only related content from retrieved websites without having to deal with context extraction and limitation yourself. max_tokens: The maximum number of tokens to return (based on openai token compute). Defaults to 4000. Returns a string of JSON containing the search context up to context limit. rsF) rQrUr]r^r_r`rarbrerfrgriNrc0g|]}|d|ddS)rru)rrur%)r&sources r) z8AsyncTavilyClient.get_search_context../s)^^^F6%=VI5FGG^^^r+)rrr8rrr )r>rPrQrUr]r^r_r`rrfrgrirrsourcescontexts r)get_search_contextz$AsyncTavilyClient.get_search_contexts,gs##*dl5-8D16047B;J;J:??D:?5<3:;J--.4--------  ##Ir22^^V]^^^z1':FFGGGr+rSc Kt|d}|j|f||||||ddd|| | d | d{V} | ddS)z` Q&A search method. Search depth is advanced by default to get the best answer. rsFT) rQrUr]r^r_r`rbrerarfrgriNanswerrwr) r>rPrQrUr]r^r_r`rfrgrirrs r) qna_searchzAsyncTavilyClient.qna_search2s gs##*dl5-8D16047B;J;J?D:?:>5<3:;J--.4--------   2...r+c$ Ktddtffd g}tj fdjDd{VD]!}d|vr||d"t |dd d}|S) z` Company information search method. Search depth is advanced by default to get the best answer. rsrUc LK|dd{VS)NF)rQrUr^rarfrg)r)rUrgr^rPrQr>rfs r)_perform_searchz;AsyncTavilyClient.get_company_info.._perform_search^sTe3?,12=5:07.5 &77777777 7r+c&g|] }|Sr%r%)r&rUrs r)rz6AsyncTavilyClient.get_company_info..hs#*g*g*ge??5+A+A*g*g*gr+Nrc|dS)Nscorer%)xs r)z4AsyncTavilyClient.get_company_info..ms 1W:r+T)r'reverse)rstrasynciogatherr=extendsorted) r>rPrQr^rfrg all_resultsrsorted_resultsrs `````` @r)get_company_infoz"AsyncTavilyClient.get_company_infoTsgs## 7 7 7 7 7 7 7 7 7 7 7 7 !.*g*g*g*gtOf*g*g*ghhhhhhh 4 4DD  ""4 ?333 1E1EtTTTUaVaUabr+Fnumberedinputmodel)miniproauto output_schemastreamcitation_format)rmlaapachicagoc  |||||d d D |r ||r&dttdff fd }|S fd} | S)zJ Internal research method to send the request to the API. )rrrrrci|] \}}||| SrHr%ros r)r*z/AsyncTavilyClient._research..rrr+rlNcvK jddtj4d{V }|jdkr |d{V}t |tr|dn|}n#t$rd}YnwxYw|jdkrt||jdvrt||jd krt||jd krt|td |jd ||23d{V}|r|WV6 dddd{VdS#1d{VswxYwYdS#tj$rt#t$r$}td t%|d}~wwxYw)NPOST /researchrtrvzutf-8z Unknown errorrzr{r|r}zError z: zError during research stream: )r<rrrraread isinstancebytesdecoderr rr r aiter_bytesr.rrr)r error_textchunkerr>rfs r)stream_generatorz5AsyncTavilyClient._research..stream_generatorsO#|22# $ 4 0 0 ' 3  ,,,,,,,, "#/366=3;>>3C3C-C-C-C-C-C-C KUV`bgKhKh-xZ->->w-G-G-Gnx #,===-< = (3s::&=j&I&I I!)!5!F!F&4Z&@&@ @!)!5!rfs r) _make_requestz2AsyncTavilyClient._research.._make_requestsp0%)\%6%6{DJW[L\L\fm%6%n%nnnnnnnHH-000&w///0'3..#==??*F!)!4!4Xr!B!B!F!FwPT!U!U$ +s225f===!->>,V444!-440888!-44-f555&77999s5;A?rrrrrrfrrrrs ` ` @r) _researchzAsyncTavilyClient._researchqs*.   @????  KK    ? # ON5$;,G O O O O O O O OD$#%% % : : : : : : :4!=?? "r+c FK|jd||||||d|}|r|S|d{VS)a Research method to create a research task. Args: input: The research task description (required). model: Research depth - must be either 'mini', 'pro', or 'auto'. output_schema: Schema for the 'structured_output' response format (JSON Schema dict). stream: Whether to stream the research task. citation_format: Citation format - must be either 'numbered', 'mla', 'apa', or 'chicago'. timeout: Optional HTTP request timeout in seconds. **kwargs: Additional custom arguments. Returns: When stream=False: dict - the response dictionary. When stream=True: AsyncGenerator[bytes, None] - iterate over this to get streaming chunks. )rrrrrrfNr%)r) r>rrrrrrfrresults r)researchzAsyncTavilyClient.researchsb2  + /       M<<<<<< r+ request_idcjK |jd|d{V}n$#t$r}td|d}~wwxYw|jdvr|}|Sd} |didd}n#t$rYnwxYw|jdkrt ||jd vrt ||jd krt||jd krt|| ) z Get research results by request_id. Args: request_id: The research request ID. Returns: dict: Research response containing request_id, created_at, completed_at, status, content, and sources. z /research/NzError getting research: )rvrwrxryrzr{r|r}) r<r8rrrr rr rr)r>rrrrrxs r) get_researchzAsyncTavilyClient.get_researchsr <!\--.G:.G.GHHHHHHHHHH < < <:q::;; ; <  : - -==??DKF !,,Xr::>>wMM    #s**-f555%66$V,,,%,,(000%,,%f---//111s&#( A AA .2*4 (}*4!) *4 &c] *4*4*4*4X$$$ PT;?BF" #-1-1HLLP#'$($("& $)M2M2M2""KLM278 M2  >? M2  M2M2M2M2&c]M2&c]M2"$0C(D"DEM2"'tW5G-H'H!IM2!M2M2 !M2""#M2$"%M2& 'M2()M2, -M2M2M2M2bY]DHKO'+%)!%(,6:6:QUUY,0&($(-1-1+/)-'444#*+T#U4$$@A4"))G!H 4 "% 4 # 44#&4'/sm4'/sm4&+49L1M+M%N4+0g>P6Q0Q*R4&*4$4"4 '+!4"'+#4$%)%4&#''4*+4444r$(:>26$("&%):2:2S 3':2!:2##67 :2 ./ :2  :2":2 :2:2 #:2 :2:2:2:2|.2DH<@').2,0#'/3""!$s)S.1"&*"&--@%A"&&89 " % " (, "&*"!"*-" """"L!%"& #'-1/3.204&*&*=A59 #'+%)(,#G2G2G2G2 G2 G2 ! G2 &c] G2 (}G2'smG2!) G2 $G2 $G2&&9:G212G2G2!%G2 #!G2"#&#G2&'G2G2G2G2V&*'+!%(,26483759+/BF+/:>%(,0*.-1#+++"+"%+ + #& + #+3- +%-SM+$,C=+&.c]+%)+$++>#?+%)+$$67+#+&*+ $(!+"(+#+&'++++^!%"& #'-1/3.204&*&* #%)?2?2?2?2 ?2 ?2 ! ?2 &c] ?2 (}?2'sm?2!) ?2 $?2 $?2?2#?2?2?2?2?2F&*'+!%(,26483759+/+/%(*.###"#"%# # #& # #+3- #%-SM#$,C=#&.c]#%)#%)###$(#####NelPY-.45BFBF3724049=(H(H(+(H/67`/a(H)00L(M(H(+ (H /2 (H 3;3- (H3;3-(H.1(H+0(H+.(H37(H'*(H(H(H(HX]gHQ%&,-:>:>*,(,15 / / # /'./X'Y /!((D E / # / '* / +33- /+33- /#( /#& /+/ /" / / / /Hcm2302.2 &)-45^-_-0).  ),  %-TN >;?(,!&R\-1 X#X#X# !67X#"&X# X# $++N#O X# $E? X#^E4K8)D/IJX#X#X#X#x@D-1&+Wa26 % % !% %&;<% '+%  $ % )00S(T % !) % "$ud{(C"CD% % % % N$2'*$2 $$2$2$2$2$2$2r+r)rrr6typingrrrrrrr r.utilsr errorsr r rrrrrr%r+r)rs  VVVVVVVVVVVVVVVVVV ******CCCCCCCCCCCCCCCCJ 2J 2J 2J 2J 2J 2J 2J 2J 2J 2r+