Ch# SSKrSSKrSSKrSSKJr SSKJr SSKJrJ r SSK r SSK r SSK J r SSKJrJr SSKJr SSKJrJr SSKJr SS KJr SS KJrJrJrJr SS KJ r \RB"\"5r#\RHS :Xa/S QO/SQr%Sr&S\'\(\(44Sjr)"SS\5r*\\RV4S\*S\ 4Sjj5r,S\(S\(4Sjr-S\RVS4S\(S\.\(S\'\(\(4S-S\ S\\(-S-4 Sjjr/S S\ \-S\0SS4Sjjr1g)!N)asynccontextmanager)Path)LiteralTextIO)Process)MemoryObjectReceiveStreamMemoryObjectSendStream)TextReceiveStream) BaseModelField)terminate_posix_process_tree)FallbackProcesscreate_windows_processget_windows_executable_commandterminate_windows_process_tree)SessionMessagewin32) APPDATA HOMEDRIVEHOMEPATH LOCALAPPDATAPATHPATHEXTPROCESSOR_ARCHITECTURE SYSTEMDRIVE SYSTEMROOTTEMPUSERNAME USERPROFILE)HOMELOGNAMErSHELLTERMUSER@returnc0n[HCn[RRU5nUcM'UR S5(aM?X U'ME U$)zc Returns a default environment object including only environment variables deemed safe to inherit. z())DEFAULT_INHERITED_ENV_VARSosenvironget startswith)envkeyvalues S/home/james-whalen/.local/lib/python3.13/site-packages/mcp/client/stdio/__init__.pyget_default_environmentr13sO C) s# =    D ! ! C* Jc\rSrSr%\\S'\"\S9r\\\S'Sr \ \\4S-\S'Sr \\ -S-\S'Sr \\S 'S r\S \S 'S rg)StdioServerParametersHcommand)default_factoryargsNr-cwdzutf-8encodingstrict)r;ignorereplaceencoding_error_handler)__name__ __module__ __qualname____firstlineno__str__annotations__r listr8r-dictr9rr:r>r__static_attributes__r?r2r0r4r4Hs} L4D1D$s)1;!%Cc3h$ % "Ctd !AHc FNG$ABMr2r4servererrlogc ^^^ ^ # [R"S5um n[R"S5unm [TR5n[ UTR TR b0[5ETR EO [5UTRS9IShvN mUU U4SjnUUU 4Sjn[R"5IShvN nTIShvN URU5 URU5 X#47v TR(a#TRR5IShvN [R"[ 5 TR#5IShvN SSS5 UR5IShvN UR5IShvN T R5IShvN T R5IShvN SSS5IShvN SSS5IShvN gGNX![af UR5IShvN UR5IShvN T R5IShvN T R5IShvN ef=fGNGNGN>![a GNIf=fGN!,(df  GN#=f![$a ['T5IShvN GNG[(a GNSf=fGNDGN/GNGN!TR(a5TRR5IShvN O![a Of=f[R"[ 5 TR#5IShvN SSS5 O@!,(df  O2=f![$a ['T5IShvN O[(a Of=fUR5IShvN UR5IShvN T R5IShvN T R5IShvN f=fGN%!,IShvN (df  GN;=fGN3!,IShvN (df  g=f7f)z~ Client transport for stdio: this will connect to a server by spawning a process and communicating with it over stdin/stdout. rN)r6r8r-rJr9c># TR(dS5eTIShvN Sn[TRT RT RS9ShvN nX-R S5nUR 5nUHGn[ RRU5n[U5nTRU5IShvN MI M{NNx![a:n[RS5 TRU5IShvN SnAMSnAff=fNU SSS5IShvN g!,IShvN (df  g=f![Ra* [R R#5IShvN gf=f7f)Nz Opened process is missing stdoutr:errors z+Failed to parse JSONRPC message from server)stdoutr r:r>splitpoptypesJSONRPCMessagemodel_validate_json Exceptionlogger exceptionsendranyioClosedResourceErrorlowlevel checkpoint) bufferchunklineslinemessageexcsession_messageprocessread_stream_writerrIs r0 stdout_reader#stdio_client..stdout_readersA~~AAA~ .))#4NN#__!88$G% $^2248E"YY[F %%&+&:&:&N&Nt&TG +9*A055oFFF!&*G )%",,-Z["4"9"9#">>>$% G#$*)))))((( ...++- - - .sF ECE,D.DCD)D.C$D.D  D.ED D )D D D D.D D.D. E'D*(E-F .E4D7 5 EEF E5F=F>FF FF c ># TR(dS5eTIShvN TShvN nURRSSS9nTRRUS-R TR TR S95IShvN MmNsNjN SSS5IShvN g!,IShvN (df  g=f![Ra* [RR5IShvN gf=f7f)NzOpened process is missing stdinT)by_alias exclude_nonerPrN) stdinrcmodel_dump_jsonrZencoder:r>r[r\r]r^)rejsonrfrIwrite_stream_readers r0 stdin_writer"stdio_client..stdin_writers}}???} .**-@/*22BBD_cBdD!--,,,,%+__#)#@#@-+.A+*****(( ...++- - - .sD C BC B0BBBAB0BB0C BB0B0 C )B,*C /D 0C6B9 7 CC D C 5D?DDD DD )r[create_memory_object_stream_get_executable_commandr6#_create_platform_compatible_processr8r-r1r9OSErroraclosecreate_task_group start_soonrmrW fail_afterPROCESS_TERMINATION_TIMEOUTwait TimeoutError_terminate_process_treeProcessLookupError) rIrJ read_stream write_streamr6rhrrtgrfrgrqs ` @@@r0 stdio_clientrisA',&G&G&J# (-(I(I!(L%L%)&..9<@F @V<+-<<\s\u   .6." !!R m$ l# /+ + }}!--..000 %%&AB!,,.((C$$& & &%%' ' '$++- - -%,,. . .A  "!!w    """!!### '')))!((*** h "1 )CB 7.g666%   ' ' - .+}}!--..000  %%&AB!,,.((CBB 7.g666%  $$& & &%%' ' '$++- - -%,,. . .A  "!!!s3QA&G; G8!G;%)QI.QP(I1P(#P KP I76I47I7<JJ *J +J /J7P  K P "K#P :K;P KP  P("P#P(' Q2P%3Q8G;;I+HI+1H42I+ I  I+#I&$I++Q1P(4I77 JP JP J  J JP JK 5J8 6K ;P > K P  K  P P P P P-L L LP L PL P"M0<M MM M0P M-)M0,P-M00N N  N P N PN P2N5 3P O P$O' %P=P >PP P( P" P P" P(%Q(P?.P1 / P?;Qr6cD[RS:Xa [U5$U$)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)r6s r0rurus  ||w-g66r2r8r-r9c# [RS:Xa[XX#U5IShvN nU$[R"U/UQUUUSS9IShvN nU$N+N7f)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-stderrr9start_new_session)rrrr[ open_process)r6r8r-rJr9rfs r0rvrvsk ||w.wc3OO N**  t "    NP s!%AA$A A AArftimeout_secondsc# [RS:Xa[X5IShvN g[U[5(de[ X5IShvN gN0N7f)aJ 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)rrr isinstancerr )rfrs r0rrsP ||w,WFFF'7++++*7DDD G Es!#AA*AAAA)r%)2loggingr)r contextlibrpathlibrtypingrrr[anyio.lowlevel anyio.abcranyio.streams.memoryrr anyio.streams.textr pydanticr r mcp.typesrTmcp.os.posix.utilitiesr mcp.os.win32.utilitiesrrrrmcp.shared.messager getLoggerr@rXrr(r|rGrDr1r4rrrurFrvfloatrr?r2r0rsW *" R0%? .   8 $$ ||w  >!("c3h*IBGJzzn/4n/fn/n/b S S &"&ZZ!   s) c3h$    d  6E7_+DEW\EgkEr2