._raw_helpers5v % ? " % $ %s 0rr)iter)cmdsr rrs @@r build_raw_inputr#s T IG% rctdg}|dk(sJtjt5|dddy#1swYyxYw)z"Quick test of our helper function.cmd1N)r#pytestraisesr) raw_inputs r test_build_raw_inputr)'sD)I ;&  x  s AA cdtiS)N __builtins__)r+r rr build_localsr,2s L ))rcBKtjjt}t gd}|j |d|tjj |d{|j\}}|jgdk(sJy7/w)z Run some basic commands through the interpreter while capturing stdout. Ensure that the interpreted prints the expected results.  repl_locals) zx = 1zprint(f'{x=}')'hello'z def func():z print(x + 1)rzfunc()zasync def afunc():z return 4rz await afunc() import sysz"sys.stdout.write('hello stdout\n')r(N)zx=1r024z hello stdout13) trio_replTrioInteractiveConsoler,r#setattrrun_repl readouterr splitlinescapsys monkeypatchconsoler(out_errs r test_basic_interactionrB6sjj//LN/KG I,i8 **  g &&&!!#IC >> Q QQ Q'sA+B-B.0BcHKtjjt}t dg}|j |d|t jt5tjj|d{dddy7 #1swYyxYww)Nr.zraise SystemExitr() r5r6r7r,r#r8r&r' SystemExitr9)r>r?r(s r "test_system_exits_quit_interpreterrE[sjj//LN/KG  I i8 z "+jj!!'***++*++s0A!B"##BBB B"BBB"c8Ktjjt}t gd}|j |d|tjj |d{|j\}}d|vsJd|vsJd|vsJy7*w)Nr.)z"import signal, trio, trio.lowlevelzasync def f():zh trio.lowlevel.spawn_system_task( trio.to_thread.run_sync, signal.raise_signal, signal.SIGINT, )z await trio.sleep_forever()z print('should not see this')rz await f()z print('AFTER KeyboardInterrupt')r(KeyboardInterruptshouldzAFTER KeyboardInterruptr5r6r7r,r#r8r9r:r=r>r?r(r@errs r test_KI_interruptsrLgsjj//LN/KG Ii8 **  g &&&  "HC # %% % 3   $ ++ + 'A+B-B.+Bc Ktjjt}t gd}|j |d|tjj |d{|j\}}d|vsJy7w)Nr.)r1if sys.version_info < (3, 11):/ from exceptiongroup import BaseExceptionGrouprz>3>>48 JD ??a  rctjdk7rytjd}|j sy|j dk(S)NlinuxFz /proc/sys/dev/tty/legacy_tiocstiT1)rfplatformpathlibPathexists read_text)sysctls r should_try_newline_injectionrtsB ||w \\< =F ==?!S((rz"the ioctl we use is disabled in CI)reasonctjdk7sJddl}|j\}}|dk(r6t j tj gtj dddgd}|jds+|t j|dz }|jds+t|jd}t j|d |jd s+|t j|dz }|jd s+|jd d k(sJt|jd}t j|tj|jd s+|t j|dz }|jd s+d |vsJt|jd}t j|dt j|tj|jd s+|t j|dz }|jd s+d |vsJt|jt j |t j"|ddy)Nwin32r-urbr5rsimport trio >>> iprint("hello!") >>> hello!KeyboardInterruptsprint("hello!"))rfrnptyforkosexeclprgendswithreadprintdecodewritecountkillsignalSIGINTclosewaitpid)rpidpty_fdbuffers r test_ki_newline_injectionrs <<7 "" " ((*KC ax #..HCNND$#GHFoo45"''&$''oo45 &--/ FHHV)*oog&"''&$''oog& << "a '' ' &--/ FGGCoog&"''&$''oog& 6 )) ) &--/ FHHV'(GGCoog&"''&$''oog& 6 )) ) &--/HHVJJsAqrc J Ktj4d{}|jttjt j dddgtjtjtjt jdk(rtjndd{}|j4d{d}|j23d{}||z }|jdd jd s0t|j!d}|j"j%d d{|j23d{}||z }|jd s d |vsJt|j!t jdk(rkd}|j"j%dd{|j23d{}||z }|jd s t|j!d}|j"j%dd{|j23d{}||z }|jd s t|j!t jdk(rt&j(nt&j*}t-j.|j0|t jdk(r$|j"j%d d{n#|j"j%d d{d}|j23d{}||z }|jd s d|vsJt|j!|j"j%dd{d}d}|j23d{}||z }|jdd jdr$|s"t-j.|j0|d}|jd sed|vsJd|vsJt|j!|j"j%dd{d}d}|j23d{}||z }|jdd jdr$|s"t-j.|j0|d}|jd sed|vsJd|vsJt|j!dddd{|j2j5dddd{y777o7[6477677n6W77 67X777#6 776]7767v#1d{7swYxYw7c#1d{7swYyxYww)Nrxrbr5rwr)stdoutstderrstdin creationflagsrs  simport trio >>> ryrzr{sIimport ctypes; ctypes.windll.kernel32.SetConsoleCtrlHandler(None, False) sWimport coverage; trio.lowlevel.enable_ki_protection(coverage.pytracer.PyTracer._trace) r}s+print("READY"); await trio.sleep_forever() FsREADY Tstrios/import time; print("READY"); time.sleep(99999) s Traceback)r5 open_nurserystartr run_processrfrgrdPIPESTDOUTrnCREATE_NEW_PROCESS_GROUPrreplacerrrrsend_allr CTRL_C_EVENTrrrr cancel_scopecancel)nurseryprocrpart signal_sentkilleds r test_ki_in_replr<s  "v&v&g]]   tV4!!(( ooEH\\U\E\jAAbc     ;;g #g #F"kk  d$>>'51::;OP &--/ "F**%%&:; ; ;"kk  d$??7+& && &--/ "||w&jj))a#'++$dNFw/fmmo&F**%%k  #kk  d$??7+ &--/ " 251H&--fmmK GGDHHk *||w&jj))%000jj))%000F"kk  d$??7+'61 11 &--/ "**%%&UV V VFF"kk  d$>>'51:::FvGGDHHk2!F??7+f$ $$'61 11 &--/ "**%%C  FF"kk  d$>>'51:::FvGGDHHk2!F??7+6) ))'61 11 &--/ "Og #g #T ##%mv&v&v&  g # k < k+  k11 k W k   kyg #g #g #g #v&v&v&v&sHV#T.V#BV0T11VT4V U7T:T7 T: 'U7:U7T=U7UU UU73AU7UU7U U U U77:U71U2U7UU U U7"BU7U#U7$U%U77U!;U <U!?U7>U7U$U7*U*.U' /U*2AU7AU7U-U7(U3,U0 -U30AU7 &U73 V>U5?V V#(V )V#1V4V7T::U7=U7UU7U7 U  U7U7UU7U7U7U!!U7$U7'U**U7-U70U33U75V7V =V>V V V#V V V V#)r"z list[str]rr)rNone)rzdict[str, object])r=zpytest.CaptureFixture[str]r>pytest.MonkeyPatchrr)r>rrr)rbool) __future__rrrorrdrf functoolsrtypingrr& trio._replr5rr#r)r,rBrErLrSrVr\r^r`rjrtmarkskipifrrr rr rsf"    5x5&*"R &"R#"R "RJ +, &,#, ,8- &-#- -.- &-#- -0( &(#( (() &)#) )$( &(#( (0  )$&& /1 1hw&r