j`?rdZddlZddlZddlZddlZddlZddlmZmZddl m Z m Z ddl m Z ddl mZddlZddlZddlmZdd lmZdd lmZe j.d z d z d z Zej2eZiddddddddddddddddddddd d!d"d#d$d%d&d'd(d)d*d+Zd,ej:d-ej<d.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,ejZdDJddKZ.ddLZ/e.jad/e fdMZ1e.jaejddNdOdPQejddRdSdTQejddUdVdWdXYejddZd[d\ejfgd]^ejdd_d`ejfgdadbcejdddded e+dfgejddhdide+djgejddkdldmgejfgdndDe!oejddpdqdrQejddsdtdDd:duvejddwdxdyQejddzd{d d|Yejdd}d~dQejddddDdYejddddDd:dvd1e de dzde de de dzde+dzde+de de dzde dzdGe+dAe dzde'dBe'd#$ 1gllnG^^DWcFWFWXF      T " ###s ABB Fno_colorrec tjj}|sd}|rt|dD]\}}|r|ddn|d}t j |dd t|j dD]d\}\}}|r-|d vrd nd } |d k(rdn|} t j|| ddd} n|} |} t j | d| d|s t|nddf|styy)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_datarJs  ZZ   F  d!, DAq-3QCwxj)A3aC KKG 4&qwwy: x 6Aq#$(b#bChjE*+/B*BJE ??##')*2,0 DED uSk$0WRZ`grvw x'  r8c|jddjddjddjddjddjd djd djddS) Nfiletyper2:"'site r?/\)replace)r9s r6_sanitize_queryresi j"% b  c    c  c  s  b  r8rpdir_pathproxyverifycv tj|ddd|j|}|jdk(rGt ||ddz }|j d5}|j |jdddyy#1swYyxYw#t$r!}tjd||Yd}~yd}~wwxYw)Nrandomr )r impersonateimpersonate_ostimeoutrwbzError download_file url=%s: %r) primpClientget status_coderrTrUrk Exceptionloggerdebug) rprr<rrrespfrWexs r6_download_filerrs @||%Xh`bkqrvv     s "X$3/A ) 4<<( ) ) # ) ) @ 5sB??@s6ABB8BB B B B8B33B8Trresultsthreadspathnamec |xs-|d|dtjtjd}t |j dd|dn|}t |5}g} t|d D]t\} } |d k(r| d n| d } t| jd djdd} |jt| || d| ||}| j|vtjt| dddd5}t!| D]#}|j#|j%d% ddddddy#1swYxYw#1swYyxYw)Nr?r@rBTparentsexist_okr ) max_workersr rgimagesrmrlr?rr Downloading2)lengthlabel show_percentshow_posrt)rrGrrHrmkdirrr|rsplitsubmitrappendr} progressbarlenrresultupdate)r9rr;rrrrpathexecutorfuturesrresrpr<rbarfutures r6_download_resultsrsi  _-%(,,(,,2OP]1^_DJTD1ObG  0Hq1 FAs"/8";#g,VCsyy~b177>#wO $ks-Cc ddlm}|r t |xs|t jd<ddl}|j|jy#t$rtjddYywxYw)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.mcprG ImportErrorr}rr osenvironasynciorunrun_stdio_async)r mcp_serverrOs r6rGrG4sc(9  #9%#@#IE <  KK **,-  X^bcsA A10A1z--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 tjjdd|rtjst j ddyt tjj} tj|dt j d|dtjd y d dl}d dl} ddlm} | t j dtj&j)} |rt+|xs|| d<|rd dl} t.j0dddd|dt3|g} |j5| |j6|j6| }| j9d|j;%t j d|j<dytj?t3|j@t j d|d|d|j@d|rt j d| dyyt j d |d||rt j d| dt j d!|r| dtj&d<| jCd||d"|#y#t$rt j d |d Yt$r%}t j d |dYd}~Ed}~wwxYw#tjd wxYw#t $rt j ddYywxYw#t $rt j dYlwxYw)$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)rHNr*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)rJruvicornzddgs.api_server:fastapi_apprSrT)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)rWrX log_levelrY)" _PID_FILEparentrexistsr}rint read_textstriprMkillProcessLookupErrorOSErrorunlink subprocessr^rL api_serverr]rNcopyr timery executablestrPopenDEVNULLsleeppoll returncode write_textpidrP)rUrVrWrXrYrryrrmr^r] proxy_envrpcmdprocesss r6apir}Vs,4$7 ! JJKQU V )%%'--/0 . GGC  JJ7uA> ?     - b/ KL  !I "8"?"H5 ,  NN   )    I  "" %%%% #  3 <<> % JJJ7K]K]J^_ei j S-. HaPTvU\]d]h]h\iijkl  JJy'>&?@ A   8avFG  JJy'>&?@ A )* '0'>BJJ| $ )  I" ] JJ.se3Z[ \ @ JJ04$ ? ? @     -  X^bc b `absZrs)  ?' ) DIIK( "V +i 7   8 $ w u w x   v   y  v ~ | ~         ! ( uuUXz\`O`eh .c.d38n!5.c.UX[_U_.dh.CtC4S#X+?CDC #sTz#d38n)=#$#AFd4S>*$6 3 3  @ @s @c @#* @Y] @bf @"   $sCx. ! :  4Z  Dj   D 43  dI$78 dL'GH dJ6JK dNJ\U\\Jc=de dM  5I(JQij dORc@[\ dHac8PQ  H    "),dJ%no dL$Dst e+2UV e["3QR eY%de dJ3WX e\4E[\+- +-Dj+- +- +- Tz +- t +- +-+- $J+-d +-+- :+-+- +- !+-" #+-]YfSWup-R]kfLI9J+-\ dI$9: dL'IJ dJ6JK dNJ\U\\Jc=de dM  5I(JK dORc@[\ dHac8PQ  H ; <  " gxlell3\&]^    ,g~LELL9k,lm dJ\U\\2L%MN   e f dJ%no dL$Dst e+2UV e["3QR eY%de dJ3WX 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-]YfSWup On-_R]LfLK;j5-p dI$9: dL'IJ dJ6JK dNJ\U\\Jc=de dM  _(EL^_ dORc@[\ dHac8PQ  H 3 4  " fn<5<<8L+MN dL|u||4O'PQ f(|u||=My