{h# ddlZddlZddlZddlmZddlmZddlmZm Z ddl Z ddl Z ddl m Z ddlmZmZddlmZddlmZmZddlmZdd lmZdd lmZmZmZmZdd lm Z ejBe"Z#ejHd k(rgd ngdZ%dZ&de'e(e(ffdZ)GddeZ*eejVfde*de fdZ,de(de(fdZ-dejVdfde(de.e(de'e(e(fdzde dee(zdzf dZ/d de ezde0ddfdZ1y)!N)asynccontextmanager)Path)LiteralTextIO)Process)MemoryObjectReceiveStreamMemoryObjectSendStream)TextReceiveStream) BaseModelField)terminate_posix_process_tree)FallbackProcesscreate_windows_processget_windows_executable_commandterminate_windows_process_tree)SessionMessagewin32) APPDATA HOMEDRIVEHOMEPATH LOCALAPPDATAPATHPROCESSOR_ARCHITECTURE SYSTEMDRIVE SYSTEMROOTTEMPUSERNAME USERPROFILE)HOMELOGNAMErSHELLTERMUSER@returnci}tD];}tjj|}|%|j dr7|||<=|S)zo Returns a default environment object including only environment variables deemed safe to inherit. z())DEFAULT_INHERITED_ENV_VARSosenvironget startswith)envkeyvalues Z/var/www/html/hubwallet-dev/venv/lib/python3.12/site-packages/mcp/client/stdio/__init__.pyget_default_environmentr02sS C)  s# =    D ! C  JceZdZUeed< eeZeeed< dZe eefdzed< dZ ee zdzed< dZ eed< d Z ed ed <y) StdioServerParameterscommand)default_factoryargsNr,cwdzutf-8encodingstrict)r9ignorereplaceencoding_error_handler)__name__ __module__ __qualname__str__annotations__r listr6r,dictr7rr8r<rr1r/r3r3Gs} L4D1D$s)1;!%Cc3h$ % "Ctd !AHc FNG$ABMr1r3servererrlogc 6 Ktjd\ }tjd\} tj}t |j j itj n t|jd{ fd} fd}tj4d{}4d{|j||j| ||fjr# jjd{ tjt 5j#d{ddd|jd{|jd{ jd{ jd{dddd{dddd{y7P#t$rf|jd{7|jd{7 jd{7 jd{7wxYw777<#t$rYFwxYw7#1swYxYw#t$$rt'd{7Y?t($rYJwxYw7;7&77#jr4 jjd{7n#t$rYnwxYw tjt 5j#d{7dddn #1swYnxYwn-#t$$rt'd{7Ynt($rYnwxYw|jd{7|jd{7 jd{7 jd{7wxYw7#1d{7swYxYw7#1d{7swYyxYww)z Client transport for stdio: this will connect to a server by spawning a process and communicating with it over stdin/stdout. rN)r4r6r,rFr7cKjsJd 4d{d}tj j j23d{}||zj d}|j }|D]F} t jj|}t|}j|d{Hy77v#t$r$}j|d{7Yd}~vd}~wwxYw7;6dddd{7y#1d{7swYyxYw#tj$r*tjjd{7YywxYww)Nz Opened process is missing stdoutr8errors )stdoutr r8r<splitpoptypesJSONRPCMessagemodel_validate_json ExceptionsendranyioClosedResourceErrorlowlevel checkpoint) bufferchunklineslinemessageexcsession_messageprocessread_stream_writerrEs r/ stdout_readerz#stdio_client..stdout_readersX~~AAA~ .) G G#4NN#__!88$GG% $e^2248E"YY[F %G%&+&:&:&N&Nt&TG +9*A055oFFFG GG )%"4"9"9#">>>$% G!$ G G G G G&(( ...++- - - .sE(D(C D(/DDC D*DC#DC> D D( D C; C6 +C. ,C6 1D6C; ;DD D( D D(E(D%D D%!D($E(%D((4E%EE%"E($E%%E(cKjsJd 4d{23d{}|jjdd}jj|dzj j j d{r7x7o7 6dddd{7y#1d{7swYyxYw#tj$r*tjjd{7YywxYww)NzOpened process is missing stdinT)by_alias exclude_nonerLrJ) stdinr]model_dump_jsonrTencoder8r<rUrVrWrX)r_jsonr`rEwrite_stream_readers r/ stdin_writerz"stdio_client..stdin_writers}}???} .*  -@/*22BBD_cBdD!--,,,,%+__#)#@#@- .A     (( ...++- - - .sDCBCB0BBBA$B0BB0CBB0B0 C)B,*C/D0C6B9 7C>CDC4D9C<:D?DDD)rUcreate_memory_object_stream_get_executable_commandr4#_create_platform_compatible_processr6r,r0r7OSErroraclosecreate_task_group start_soonrfrS fail_afterPROCESS_TERMINATION_TIMEOUTwait TimeoutError_terminate_process_treeProcessLookupError) rErF read_stream write_streamr4rbrktgr`rarjs ` @@@r/ stdio_clientr|hs',&G&G&J# (-(I(I!(L%L%)&..9<@F @V<+-<<\s\u   .4." !"/"/%'"/"/ m$ l# /|+ + }}!--..000 %%&AB)!,,.(()$$& & &%%' ' '$++- - -%,,. . .E"/"/"/"/"/s    """!!### '')))!((*** d"/"/1 ))) 7.g666%   ' ' - .+}}!--..000  %%&AB)!,,.(())) 7.g666%  $$& & &%%' ' '$++- - -%,,. . .E"/"/"/"/"/"/"/"/s1PA(G3 G0!G3%&P I% PPI(P#O+>K O+I./I+0I.5JJ"I> #J'J/O+J=O+KO+2K3O+ K O+ PO(P P*P+P0G33I"HI"(H+)I"II"II""P(P+I.. I;7O+:I;;O+>JJ JJ:%J( &J:+O+.J:6O+9J::O+O+O+O+ O%K:3K6 4K:9O%: L O%L O% M#M 7L:8M = MM MO%M= *M-+M= 0O%2M= :O%<M= =O%N O%,N/ -O%O O%O! O%%O+(P+O> 1O42O> 9PPP P PPr4cBtjdk(r t|S|S)z Get the correct executable command normalized for the current platform. Args: command: Base command (e.g., 'uvx', 'npx') Returns: str: Platform-appropriate command r)sysplatformr)r4s r/rmrms  ||w-g66r1r6r,r7cKtjdk(rt|||||d{}|Stj|g||||dd{}|S7-7w)z Creates a subprocess in a platform-compatible way. Unix: Creates process in a new session/process group for killpg support Windows: Creates process in a Job Object for reliable child termination rNT)r,stderrr7start_new_session)r~rrrU open_process)r4r6r,rFr7r`s r/rnrnsq ||w.wc63OO N**  t "    NP s!&AA&AAAAr`timeout_secondscKtjdk(rt||d{yt|tsJt ||d{y7,7w)af Terminate a process and all its children using platform-specific methods. Unix: Uses os.killpg() for atomic process group termination Windows: Uses Job Objects via pywin32 for reliable child process cleanup Args: process: The process to terminate timeout_seconds: Timeout in seconds before force killing (default: 2.0) rN)r~rr isinstancerr )r`rs r/rwrwsS ||w,WoFFF'7+++*7ODDD G Es!#AA&A A AA)r$)2loggingr(r~ contextlibrpathlibrtypingrrrUanyio.lowlevel anyio.abcranyio.streams.memoryrr anyio.streams.textr pydanticr r mcp.typesrPmcp.os.posix.utilitiesr mcp.os.win32.utilitiesrrrrmcp.shared.messager getLoggerr=loggerrr'rtrCr@r0r3rr|rmrBrnfloatrwrDr1r/rsY *" R0%? .   8 $" ||w  >&"c3h*IBGJzzm/4m/fm/m/` S S &"&ZZ!   s) c3h$    d  6E7_+DEW\EgkEr1