+ 0jJaRt:0tRt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI H t H t ^RI Ht^RIHt^RIHtHt^RIHt^RIHtHt^RIt^RIHt^R IHt^R IHtHt^R I H!t!^R I"H#t#^R I$H%t%^RI&H't']PP!])4t*Rt+Rt,Rt-Rs.]^kRs/]^k]P`!4t1Rs2]^kRs3]^kRRlt4]Pj!]44RRlt6RRlt7RRlt8!RR4t9R#)zDDGS class implementation.N)ThreadPoolExecutorwait)ceil)Path)randomshuffle) TracebackType)AnyClassVar)BaseSearchEngine)ENGINES) DDGSExceptionTimeoutException) HttpClient)ResultsAggregator)SimpleFilterRanker)_expand_proxy_tb_aliaszhttp://localhost:4479$@g?cV^8dQhRR/#returnN)formats"^/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/ddgs/ddgs.py __annotate__r*s&#&#d&#c\Pe\PP4fm\P R\PP 4\PP 4\PPRR7R\n\ea\P4'dG\P\P4\e\P!RR7Rs Rs\"e\"P%R R 7RsR#R# \dp\PRT4\PP4\PPRR7Rp?L \d&p\PRT4Rp?Rp?EL(Rp?ii;iRp?ii;i R\ni;i \d!p\PRT4Rp?LRp?ii;i Rs Rsi;i \d"p\PR T4Rp?ELRp?ii;i Rsi;i) z/Cleanup any spawned API server process on exit.Nz%Stopping spawned API server (PID: %d)g@timeoutzFailed to stop API server: %rg@zFailed to kill API server: %rzFailed to stop async loop: %rT)rz%Failed to shutdown cache executor: %r)DDGS _api_processpollloggerinfopid terminater Exceptiondebugkill _async_loop is_runningcall_soon_threadsafestop _async_threadjoin_cache_executorshutdown)exs r_cleanup_api_processr3*s $ %  %%'/ CTEVEVEZEZ[!!++-!!&&s&3!%D ;#9#9#;#; !  , ,[-=-= >(""3"/K M" #  $ $$ $ /#O #1 B LL8" = B!!&&(!!&&s&33 B  LL8" = = >K M F LL@" E E F#OsB D8AG(H8 GG>FG G (G>GGG  GGG G%( H3H HHHH I *III  IIc$V^8dQhR\/#rr)r)rs"rrrWs/rc8\f\^RR7s\#)z@Get shared thread pool executor for background cache operations.z DDGS-Cache max_workersthread_name_prefix)r0rrrr_get_cache_executorr:Ws,|\ rc8V^8dQhR\P/#r5)primpClient)rs"rrr`s%,,rcL\f\P!^R7s\#)z+Get or create the shared primp HTTP client.r) _http_clientr<r=rrr_get_http_clientr@`s||A. rc8V^8dQhR\P/#r5)asyncioAbstractEventLoop)rs"rrrhs22rc&\fm\;_uu_4\fH\P!4sRRlp\P !VRR7s\ P4RRR4\#\# +'gi\#;i)z.__annotate__ps..4.rcb\P!\4\P4R#N)rBset_event_loopr* run_foreverrrr _run_loop"_get_async_loop.._run_loopps**;7++-rT)targetdaemon)r* _network_lockrBnew_event_loop threadingThreadr.start)rKs r_get_async_looprThsj ]"%446 .!* 0 0 $ O ##% ;] s AA;; B c ta]tRt^ytoRtRtRtRtR/RRRRRR/V3RlR llltV3R lR lt R0V3R lR llt V3RlRlt V3RlRlt V3RlRlt V3RlRltR1RRRRRRR^ R^RR/V3RlR llltV3R!lR"ltV3R#lR$ltV3R%lR&ltV3R'lR(ltV3R)lR*ltR2V3R+lR,lltV3R-ltR.tVtR#)3r a^DDGS | Dux Distributed Global Search. A metasearch library that aggregates results from diverse web search services. Args: proxy: The proxy to use for the search. Defaults to None. timeout: The timeout for the search. Defaults to 5. verify: bool (True to verify, False to skip) or str path to a PEM file. Defaults to True. Attributes: threads: The maximum number of threads per search. Defaults to None (automatic, based on max_results). Raises: DDGSException: If an error occurs during the search. Example: >>> from ddgs import DDGS >>> results = DDGS().search("python") NverifyTapi_url spawn_apiFc v<V^8dQhRS[R,RS[R,RS[S[,RS[R,RS[RR/#)rproxyNrrVrWrXr)strintbool)r __classdict__s"rrDDGS.__annotate__sW++Tz+t+ s + t ++ +rc"\V4;'g \PPR4VnW nW0nW@nWPn/Vn VP'd'\PfVP4R#R#R#) DDGS_PROXYN) rosenvironget_proxy_timeout_verify_api_url _spawn_api_engines_cacher _network_client_ensure_network_running)selfrZrrVrWrXs&&&$$$r__init__ DDGS.__init__so-U3SSrzz~~l7S    #   ===T119  ( ( *:=rc<V^8dQhRR/#)rrr r)rr^s"rrr_s6rc V#)z7Enter the context manager and return the DDGS instance.rrms&r __enter__DDGS.__enter__s rcj<V^8dQhRS[S[,R,RS[R,RS[R,RR/#)rexc_typeNexc_valexc_tbr)type BaseExceptionr)rr^s"rrr_sG((}%,(%($ (  (rc R#)zExit the context manager.Nr)rmrvrwrxs&&&&r__exit__ DDGS.__exit__src<V^8dQhRR/#rr)rr^s"rrr_sIXIXIXrc  \PeR#\;_uu_4\Pe RRR4R#VP;'g\p\ 4P V R24pVP^8Xd:^RIH pV!VR7\n\PRV4RRR4R#VP'Ed*\P e!\P P#4e\%\'\(P*4P,4p/\.P0CRV \.P2 \.P0P RR 4 2/Cp\4P6!\(P*R R R R .V\4P8\4P8RRR7\n\PR\P P:4\>P>!4p\>P>!4V, \@8d\ 4P V R24pVP^8XdMv\@\>P>!4V, , pV^8:dMF\>PB!\E\FV44K\P=R4RRR4R#^RIH pV!VR7\n\PRV4RRR4R# \d\PR4ELw\d"p\PRT4Rp?ELRp?ii;i \d*p\P=RT4Rp?RRR4R#Rp?ii;i \dELDi;i \d\PR4Li;i +'giR#;i)zpEnsure the network service is running. If not running, spawn a new ddgs api process only if spawn_api is True. Nz/health) DhtClient)rWzNetwork client ready: %sz7DHT dependencies not available - network cache disabledzAPI health check failed: %rPATHz-mddgsapiz-dT)envstdoutstderrstart_new_sessiontextz"Spawned ddgs api service (PID: %d)zFailed to spawn ddgs api: %rz/Timed out waiting for ddgs api service to start)$r rkrOrhDEFAULT_API_URLr@rd status_codedhtrr#r$ ImportErrorr(r'rir!r"r[rsys executableparentrbrcpathsep subprocessPopenDEVNULLr%warningtimeNETWORK_START_TIMEOUTsleepminNETWORK_CHECK_INTERVAL) rmrWresprr2venv_binr start_time remainings & rrlDDGS._ensure_network_runnings    +  ]##/]mm66G @')-- .AB##s*.+4W+ED(KK :GD]+D$5$5$=ARARAWAWAYAe"4#7#>#>?HgRZZgH:bjj\"**..Y_acJdIe1fgC(2(8(8vudC)11)11*.! )D%KK DdFWFWF[F[\ J))+ *-BB+-11WIW2EFD''3./ 2TYY[:5MN > 35yABPQq]v X*'0'A$ 6@]  X VW @ :B?? @"!NN#A2FM]H!$ X VW XA]]sOOOALO2O C6M(?:O:-N'A-O.N1 M%7O:M%M%M O M%%O( N3N ONO N.*O-N..O1 OOOO O( c <V^8dQhRS[/#r5)r )rr^s"rrr_s$$S$rc "\P#)zdGet the network client for caching. Returns: DhtClient instance if available, None otherwise. )r rkrrs&r_get_network_clientDDGS._get_network_clients###rcV<V^8dQhRS[RS[S[S[S[3,,RS[RR/#)rqueryresultscategoryrN)r[listdictr )rr^s"rrr_ s@'''d38n%' '  'rc aaaaVP4oS'gR#RVVVV3Rllp\4pVPV4R#)z$Cache search results asynchronously.NcV^8dQhRR/#rr)rs"rr/DDGS._cache_results_async..__annotate__s 5 5t 5rc<\4p\P!SPSSS4V4pVP RR7\ P RS4R# \d"p\ P RT4Rp?R#Rp?ii;i)rrzCached results: %szCache failed: %rN)rTrBrun_coroutine_threadsafecacheresultr#r(r')loopfuturer2rnetworkrrs r _cache_worker0DDGS._cache_results_async.._cache_workersp 5&( 99'--wX`:acgh d + 159 5 /44 5sAA B *BB )rr:submit)rmrrrrexecutorrs&fff @r_cache_results_asyncDDGS._cache_results_async s9**,  5 5'( &rcL<V^8dQhRS[RS[RS[S[S[,,/#)rrbackendr)r[rr r )rr^s"rrr_ s4==== s# $ =rc  v\V\4'dRPV4pVPR4Uu.uFq3P 4NK pp\\ V,P 44p\V4RV9gRV9d.TpVR8Xd$RR.VUu.uF qwR9gK VNK up,pMTp.p.p VFKp \ V,PV 4;p 'dVPV 4K:V PV 4KM V 'dH\PRRP\V 44RP\V444.p VFp WP9d%V PVPV ,4K7V !VPVPVP R 7p WPV &V PV 4K V 'g(\PR 4VP#VR4#V P%R R R 7V #uupiuupi)a~Retrieve a list of search engine instances for a given category and backend. Args: category: The category of search engines (e.g., 'text', 'images', etc.). backend: A single or comma-delimited backends. Defaults to "auto". Returns: A list of initialized search engine instances corresponding to the specified category and backend. Instances are cached for reuse. ,autoallr wikipedia grokipediaz9%s - backends do not exist or are disabled. Available: %sz, rZrrVz backend is not set. Using 'auto'c&VP\3#rH)priorityr)es&r#DDGS._get_engines..\s ajj&%9rT)keyreverse)rr) isinstancerr/splitstripr keysrrdappendr#rsortedrjrerfrg _get_enginessort)rmrrx backend_list engine_keysrkengine_classes invalid_keysr engine_class instancesengine_instances&&& rrDDGS._get_engines s gt $ $hhw'G+2==+=>+=a += >78,1134   \ !Ul%:D6!#\25nARmImaa5nnD C&x044S99|9%%l3##C(   NNK &./ &-.  *L222  !4!4\!BC#/T[[$--`d`l`l"m4C##L1  1+ NN= >$$Xv6 6 94HW? 6osH1"H6/H6regionzus-en safesearchmoderate timelimit max_resultspagerrc<V^8dQhRS[RS[RS[R,RS[RS[RS[R,RS[R,R S[R S[R S[R S[S[S[S[3,,/ #) rrrkeywordsNrrrrrrkwargsr)r[r\rrr )rr^s"rrr__sg8g8g8g8* g8  g8g8:g84Zg8g8g8g8 d38n g8rc FT;'gTpV'gRp \V 4hVP4p V 'de\4p \P!V P W!4V 4pVP RR7pV'd\PRV4V#VPW4p\VUu0uFpVPkK up4p\4p\0Rm4pV'd$\V\!V^ , 4^,4MTp\"P$'d\V\"P$4p/Rpp\'VRR7;_uu_4p\)V^R 7EFwppVPV9dKVP*!VP,V3R VR VR VR V/V BpVVV&\V4V8gVV8d\/VVP0RR7wppVP34FVwppVV9gKVP 4;p'd/VP5V4VP7VP4KVKX VUu/uF pVVV,bK ppV'gEK\V4V8gEKM RRR4VP=4p \?4p!V!PAV V4p V 'd+V 'dVPCVV V4V'dV RV#T #RV 9d \EV4h\T;'gR4h \d"p\PRT4Rp?ELRp?ii;iuupi \d0pTp\P9RTP:T4Rp?EKRp?ii;iuupi +'giEL ;i)aPerform a search across engines in the given category. Args: category: The category of search engines (e.g., 'text', 'images', etc.). query: The search query. keywords: Deprecated alias for `query`. region: The region to use for the search (e.g., us-en, uk-en, ru-ru, etc.). safesearch: The safesearch setting (e.g., on, moderate, off). timelimit: The timelimit for the search (e.g., d, w, m, y) or custom date range. max_results: The maximum number of results to return. Defaults to 10. page: The page of results to return. Defaults to 1. backend: A single or comma-delimited backends. Defaults to "auto". **kwargs: Additional keyword arguments to pass to the search engines. Returns: A list of dictionaries containing the search results. zquery is mandatory.g?rz Cache hit: %szCache check failed: %rNr r7)rSrrrrFIRST_EXCEPTION)r return_whenzError in engine %s: %rz timed outzNo results found.>urlhrefimage embed_url)#r rrTrBr get_cachedrr#r(r'rlenprovidersetrrrr threadsr enumeratersearchrrfitemsextendaddr$name extract_dictsrrankrr)"rmrrrrrrrrrrmsgrrrcachedr2enginesenginelen_unique_providersseen_providersresults_aggregatorr8futureserrridonenot_doneff_enginerrrankers"&&&&$$$$$$, r _search_syncDDGS._search_sync_sG@!!E'C$ $**,  ;&( 99':L:LU:]_cds3LL%8!M##H6"'#J'FOO'#JK#&5;LLq:rOZc.[25E0F0JK`t <<<k4<<8K4 KF S SW_&wa88 6??n4!MM" *  (   #)w<;.!{2B%)'4==Vg%hND('.}} 89Y() ?1?$6$=$=a$@$2$6$6x7H7H$I$3(77??hq'!*}hG?;3'9#:k#I99T>%224#%++gu- ))%(C,77rMs     7" "7#&*)   8 $)%) (-11 04 4)- -&#T$%"{Q{Qr