h78ja?rdZddlZddlZddlZddlZddlZddlmZmZddl m Z m Z ddl m Z ddl mZddlZddlZddlmZdd lmZdd lmZe jd z d z d z ZejeZiddddddddddddddddddddd d!d"d#d$d%d&d'd(d)d*d+Zd,ejd-ejd.ee dzd/e fd0Z!d1e d2e"e#e e fd3e d4e dzd/df d5Z$d6e e zd2e"e#e e fd/dfd7Z%d8e e zd2e"e#e e fd/dfd9Z&d:d;d2e"e#e e fdZ)d?e d@e d4e dAe dzdBe'd/df dCZ* ddDdEd1e dFe"e#e e fd3e dAe dzdGe+dzdHe dzdBe'd/dfdIZ,ej-dDJddKZ.ddLZ/e.0d/e fdMZ1e.0ej2dNdOdPQej2dRdSdTQej2dUdVdWdXYej2dZd[d\ej3gd]^ej2d_d`ej3gdadbcej2ddded e+dfgej2dhdide+djgej2dkdldmgej3gdndDe!oej2dpdqdrQej2dsdtdDd:duvej2dwdxdyQej2dzd{d d|Yej2d}d~dQej2dddDdYej2dddDd:dvd1e de dzde de de dzde+dzde+de de dzde dzdGe+dAe dzde'dBe'd >#$  #1gllnnG^DWcFWXXXF      T " " " ##################sA'BB!BFno_colorrec tj}|sd}|rt|dD]\}}|r|ddn|d}t j|dd t|dD]g\}\}}|r-|d vrd nd } |d krdn|} t j|| ddd} n|} |} t j| d| d|s t|nddh|rtdSdS)NTr startz. zN==============================================================================r>rr))bgfg)contenthrefimagesource thumbnailurli,Ndetected_languagelanguager2z )widthinitial_indentsubsequent_indentpreserve_paragraphsz<12)rirjoverline) sysstdoutisatty enumerateclicksechoitems wrap_textCOLORSinput) r:reis_ttyiesepjkvrttitletexts r6 _print_datarJsx Z   F  d!,,,  DAq-3@Q))x)))AC KG 4 4 4 4&qwwyy::: x x 6Aq #$(b#b#bCChjE*+/B*B*BJJE ?#')*2,0 DDED u00$00WRZAg`grvwwwww )  r8cF|ddddddddddd dd dddS) Nfiletyper2:"'site r?/\)replace)r9s r6_sanitize_queryres j"%% b   c      c   c   s   b   r8rpdir_pathproxyverifyc tj|ddd||}|jdkrdt ||ddz }|d5}||jddddS#1swxYwYdSdS#t$r'}t d||Yd}~dSd}~wwxYw)Nrandomr )r impersonateimpersonate_ostimeoutrwbzError download_file url=%s: %r) primpClientget status_coderrTrUrk Exceptionloggerdebug) rprr<rrrespfrWexs r6_download_filerrs: @|%Xh`bkqrrrvv     s " "X$3$/A ) 4<((( ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) # " @@@ 5sB?????????@s<A&B(B BBBBB C)C  CTrresultsthreadspathnamec H|p'|d|dtjtjd}t |dd|dn|}t |5}g} t|d D]\} } |d kr| d n| d } t| d d dd} | t| || d| ||}| |tjt| dddd5}t!| D]+}||d, dddn #1swxYwYddddS#1swxYwYdS)Nr?r@rBTparentsexist_okr ) max_workersr rgimagesrmrlr?rr Downloading2)lengthlabel show_percentshow_posrt)rrGrrHrmkdirrr|rsplitsubmitrappendr} progressbarlenrresultupdate)r9rr;rrrrpathexecutorfuturesrresrpr<rbarfutures r6_download_resultsrs@  _-__%__(,(,2O2O2O___DJJTD111ObbG  0 0 0Hq111  FAs"/8";";#g,,VCsyy~~b177< text_plain text_richrrkz Output formatz2json or filename.json (save the results to a file)ctt||||}|rAd|D}t t ||gd|d St jd|d|d}t jt|tr| n|d S) z+CLI function to extract content from a URL.r)rpr=cli|]1\}}|t|tr|n|2Sr)r3bytesdecode).0rrs r6 zextract..-s<#j#j#jUYUVXYAZ55I5I'Pqxxzzzq#j#j#jr8extractrzURL:  rkN) r r rGrrLrr}rr3rCrD)rpr=rrrr:str_datarks r6rGrGs, ,U33F C C C K KPSY\ K ] ]D P#j#j]a]g]g]i]i#j#j#j?3''(YPPPPPP ?3???###y/ z'5'A'AN7>>###wOOOOOr8c ddlm}n'#t$rtjddYdSwxYw|rt |p|t jd<ddl}| | dS)aStart DDGS MCP server over stdio for local MCP clients. Examples: ddgs mcp # Start MCP server using stdio transport ddgs mcp -pr socks5h://127.0.0.1:9150 # With proxy MCP client configuration: { "mcpServers": { "ddgs": { "command": "ddgs", "args": ["mcp"] } } } r)mcpzCError: MCP dependencies not installed. Run: pip install 'ddgs[mcp]'TerrN DDGS_PROXY) ddgs.api_server.mcprK ImportErrorr}rr osenvironasynciorunrun_stdio_async)r mcp_serverrSs r6rKrK5s(9999999  X^bcccc J#9%#@#@#IE < NNN KK **,,-----s  --z--detachz,Run the server in detached mode (background))rrz--stopzStop the detached server--hostz0.0.0.0zHost to bind the server to--portizPort to bind the server toz--reloadz"Enable auto-reload on code changesdetachstophostportreloadc tjdd|r)tst jdddSt t} tj |dt jd|dnS#t$rt jd |d Yn/t$r#}t jd |dYd}~nd}~wwxYwt d n #t d wxYwdS d dl}d dl} n'#t $rt jddYdSwxYw ddlm} | t jdn$#t $rt jdYnwxYwtj} |rt+|p|| d<|rd dl} t.jdddd|dt3|g} || |j|j| }| d| t jd|jddStt3|j t jd|d|d|j d|rt jd| ddSdSt jd |d||rt jd| dt jd!|r| dtjd<| !d||d"|#dS)$aStart/stop the DDGS API server. Starts a FastAPI server with REST endpoints for search tools. Supports text, image, news, video, and book search. Examples: ddgs api # Start server in foreground ddgs api -d # Start server in detached mode ddgs api -s # Stop the detached server ddgs api --host 127.0.0.1 --port 9000 # Bind to specific host/port ddgs api -pr socks5h://127.0.0.1:9150 # Use proxy Trz2No detached server is running (PID file not found)rLNr*zDDGS API server stopped (PID: )zServer process (PID: z') was not running, cleaning up PID filezFailed to stop server: ) missing_okrzCError: API dependencies not installed. Run: pip install 'ddgs[api]'r )get_dht_servicez6API server starting with distributed DHT cache enabledzKAPI server starting (DHT cache not available - install ddgs[dht] to enable)rNruvicornzddgs.api_server:fastapi_apprWrX)rzstderrenvg?z1Failed to start server: process exited with code z3DDGS API server started in detached mode on http://rz (PID: z Using proxy: z#Starting DDGS API server on http://zPress Ctrl+C to stopinfo)r[r\ log_levelr])" _PID_FILEparentrexistsr}rint read_textstriprQkillProcessLookupErrorOSErrorunlink subprocessrbrP api_serverrarRcopyr timery executablestrPopenDEVNULLsleeppoll returncode write_textpidrT)rYrZr[r\r]rr}rrqrbra proxy_envrtcmdprocesss r6apirWsN,4$777 !!  JKQU V V V V F)%%''--//00 . GC    J>>>> ? ? ? ?! ] ] ] J[s[[[ \ \ \ \ \ @ @ @ J444$ ? ? ? ? ? ? ? ? ? @     - - - -I    - - - -  X^bccccb////// KLLLL bbb `aaaaab !!I I"8"?"?"H5 , ,   N   )    II  "" %% #   3 <<>> % J_7K]__ei j j j j FS--... kkkPTkk]d]hkkklll  B J@y'>@@ A A A A A B B  FFFFFGGG  B J@y'>@@ A A A )***  ?'0'>BJ| $ )      s`-B=<D,="D D,! D *DD,D  D,,E E E<;E<$F%%GG__main__)NNN)r/N)<__doc__rCrDrrQryconcurrent.futuresrrrrpathlibr urllib.parserr}rr2r r r utilsr homerg getLoggerrrrContext Parameterr4rvr7listdictrLrJrIboolrrrrjrgrouprrcommandroptionChoicerrr6r8r;rGrKrrr8r6rs  ????????'''''''' )))))) DIKK( "V +i 7  8 $ $ w u w x   v   y  v ~ | ~         ! ( uuUXz\`O`eh .c.d38n!5.c.UX[_U_.dh....CtC4S#X+?CDCCCC #sTz#d38n)=#$####AFd4S>*$6 3 3     @ @s @c @#* @Y] @bf @ @ @ @"   $sCx. ! :  4Z  Dj   D 43333  dI$7888 dL'GHHH dJ6JKKK dNJ\U\JcJcJc=d=deee dM  5I5I5I(J(JQijjj dORc@[\\\ dHac8PQQQ  H      "+.dJ%nooo dL$Dsttt e+2UVVV e["3QRRR eY%deee dJ3WXXX e\4E[\\\+- +-Dj+- +- +- Tz +- t +- +-+- $J+-d +-+- :+-+- +- !+-" #+-+-+-]\YXfeSRWVutpo/RQ]\kjfeLKIH98L+-\ dI$9::: dL'IJJJ dJ6JKKK dNJ\U\JcJcJc=d=deee dM  5I5I5I(J(JKKK dORc@[\\\ dHac8PQQQ  H ;;; < <  " gxlel3\3\3\&]&]^^^       ,g~LEL9k9k9k,l,lmmm dJ\U\2L2L2L%M%MNNN   eee f f dJ%nooo dL$Dsttt e+2UVVV e["3QRRR eY%deee dJ3WXXX e\4E[\\\5- 5-Dj5- 5- 5- Tz 5- t 5- 5-5- *5- :5-d 5- $J5-:5-d 5-5- $J!5-" :#5-&'5-( )5-*+5-, -5-5-5-]\YXfeSRWVutpo ONnm-_^RQ]\LKfeLKKJ;:j5-p dI$9::: dL'IJJJ dJ6JKKK dNJ\U\JcJcJc=d=deee dM  ___(E(EL^___ dORc@[\\\ dHac8PQQQ  H 333 4 4  " fn<5<8L+M+MNNN dL|u|4O4O4O'P'PQQQ f(|u|=My