+ lHjDRt^RIHt^RIt^RIHt]P !4tRRltRRlt RR lt R R/R R llt R Rlt RRlt RRltRRltRRltRRltRRltRRltRRltR#)z7Additive transport membership for shared live sessions.) annotationsN) bind_modulecV^8dQhRR/#)returnbool)formats"C/home/ubuntu/.hermes/hermes-agent/tui_gateway/session_transports.py __annotate__r s33$3cVRJ;'dTV\J;'dDV\J;'d4\V\\34'*;'d\ V4'*#)zEExclude the process fallback sink, parked sentinel, and closed peers.N)_detached_ws_transport_stdio_transport isinstance_DropTransportStdioTransport_transport_is_dead transports&r _transport_is_live_peerr sj T ! 2 2!77 2 2!11 2 2y>>*JKK 2 2'y11 3r c V^8dQhRRRR/#rsession dict | Nonerrr)r s"r r r sPPPDPr cV'dVe\V4'dR#VPR4pW!J;'g*\V\4;'dVP V4#)NFr)rgetrFanoutTransportcontains)rrexistings&& r _session_transport_containsr s[ i'+=i+H+H{{;'H   P P8_-NN(2C2CI2NPr c V^8dQhRRRR/#)rrrrlistr)r s"r r r sEEkEdEr cT;'g/PR4p\V\4'dVP4MV.pVUu.uFp\ V4'gKVNK up#uupir)rrr transportsr)rrpeerspeers& r _session_live_transportsr'sZ 2"";/H%//%J%JH   !QYPZE" DUT&=d&CDDU DD Ds A*!A* excludingc V^8dQhRRRR/#rr)r s"r r r "sTTTDTr ca\;QJd(V3Rl\V44F 'gK R# R#!V3Rl\V444#)c3*<"TFqSJxK R#5iNr).0r&r(s& r ._session_has_live_transport..#sS1R9$1RsTF)anyr')rr(s&dr _session_has_live_transportr1"s8 3S1I'1RS33S3S3S1I'1RS SSr cV^8dQhRR/#)rr str | Noner)r s"r r r &s*r c\VRR4p\PV4'dD\VR,4P 4 R\VR,4P 4 2#R#)z``:`` the WS-upgrade credential authenticated for ``transport``, or None for the legacy token, stdio and the PTY child's server-internal credential. The prefix keeps a basic-auth ``alice`` and an OIDC ``alice`` apart. auth_identityNprovider:user_id)getattr_methods_browser_control_is_authenticated_identitystrstrip)ridentitys& r _transport_auth_user_idr?&s_y/48H::8DDhz*+1134Ac(9:M6N6T6T6V5WXX r c V^8dQhRRRR/#)rrrrr3r)r s"r r r 0s==;=:=r cnT;'g/pRV9d VR,#\VPR44#)zThe login ``session`` was created under, stamped on the record as ``auth_user_id``. A second window turns the transport slot into a FanoutTransport, which names no login, so only a record without the slot reads its transport. auth_user_idr)r?r)rs&r _session_auth_user_idrC0s6mmG ~&& "7;;{#; <.Cs!YQXo>>tDDQXs!TF) tui_gatewayrHtui_gateway.wsrJr' _sessionsrrr0)rErJr&clientsrHs& @r _session_client_answers_requestsrR:su ,* 8s9K Ln LPZ[_Pmtt LGn; Y Y##YQXY##Y#Y#YQXYYYos BBc V^8dQhRRRR/#)rrEr<rr"r)r s"r r r FsYYCYDYr c^RIHp^RIHp\ \ P V44Uu.uF1p\W24'gKVPV4'gK/VNK3 up#uupi)uThe live WebSocket clients attached to *sid* that advertised answering server→client requests: the windows whose unanimous "not shown here" settles a window-owned request (server_requests.py).rGrI) rNrHrOrJr'rPrrrL)rErHrJr&s& r _session_answering_clientsrUFs_,*5immC6HI YIT$, 1@1Q1QRV1W DI YY YsA'A'A'c V^8dQhRRRR/#)rrdictrNoner)r s"r r r Os S S ST Sr c\V4pVfR#\V4pW28wd4\PRVP R4T;'gRV4R#R#)zvOwnership is not enforced; a second login sharing a session is only logged, and the agent keeps the creator's user id.NzVSession %s keeps the user id %s it was created with; a client logged in as %s attached session_keyz(none))r?rCloggerwarningr)rr attachingcreators&& r _warn_foreign_loginr_OsT( 2I#G,Go{{=173F3Fh  Sr c V^8dQhRRRR/#rr)r s"r r r [s  { $ r c V'dVfR#\;_uu_4\V\4'd>VP4Uu.uFp\ W4NK pp\ V4uuRRR4#VP R4p\V4'd3\V\4'dVPV4RRR4R#\V4'g,\V4'd RRR4R#WR&RRR4R#WAJd RRR4R#\V\4'dOVPV4'g \W4VPV4VPV4uuRRR4#\W4\V4'd\WA4VR&MWR&RRR4R#uupi +'giR#;i)zJAdd live peers; flatten captured queued fanouts without nesting authority.NFrT)_session_transport_lockrrr$_attach_session_transportr0rrdetachrr1rr_attach)rrr&attachedrs&& r rcrc[su i' i 1 1NWMaMaMcdMcT1'@McHdx= ! ;;{+ i ( ((O44 * ! 'y11*733 ! $-K  !  # ! $ h 0 0$$Y//#G7 OOI &$$Y/- ! . G/ "8 , ,#28#GGK #,K 9 ! e ! sH)F4F/ F41A F4#F42F4F4,F4>,F450F4/F44 G c V^8dQhRRRR/#rr)r s"r r r ~sII{I$Ir c V'gR#\;_uu_4VPR4;'g/PVR4VPR4p\V\4'd{VP V4VPR4;'g/p\ V4F?pVPV4'd\V4'gK-VPVR4KA \WR7uuRRR4# +'giR#;i)zGRemove membership; return whether another live client prevents parking.FviewersNr)r() rbrpoprrrdr"rrr1)rrrriviewers&& r _detach_session_transportrl~s  Y  % %2**9d;;;{+ h 0 0 OOI &kk),22Gw-((004Fv4N4NKK-( +7H ! sA;C<6C<!C<< D cV^8dQhRR/#)rrzlist[tuple[str, dict]]r)r s"r r r s B B2H Br c\;_uu_4.p\P4F{wr#VPR4pW@JgO\ V\ 4'dVP V4'g"YPR4;'g/9gKiVPW#34K} RRR4XUUu.uFwr#\W04'dKW#3NK upp# +'giL:;iuuppi)zIRemove even closed/pruned peers' viewer entries; return clientless slots.rriN) _sessions_lockrPitemsrrrrappendrl)rrfrErrs& r _detach_transport_from_sessionsrrs %OO-LC{{;/H%!(O<<ARARS\A]A] [[%;%A%ArB/ . 08 Bx|s,W@ SNx BB  Bs*AC.CCC2C* C* C' cV^8dQhRR/#)rrrXr)r s"r r r s###r c.\\4V4R#r,)rglobals)servers&r registerrws 6"r )__doc__ __future__r threadingtui_gateway.method_ctxrRLockrbrr r'r1r?rCrRrUr_rcrlrrrwrr r r}sr=".$//+3PE T4T= ZY S FI$ B#r