+ jHj<TRt^RIHt^RIt^RIHt^RIHtHt^RI t ^RI t ^RI H t ^RI t ^RIHtRt^tRtR t^tR tR!tR t!R R ]4t!RR]4tRtRtRt!RR]4t!RR]P@4t!Rt"!RR4t#RRRRRR/RRllt$]R"R l4t%R#)#zFTransport-only RPC client. Closing a viewer never stops its authority.) annotationsN)deque)asynccontextmanagersuppress)Path)CANONICAL_GATEWAY_PROTOCOLzhermes-gateway-ticket.z--api-key on resume must be the key this session was launched with (a session launched without --api-key keeps its profile credentials).ii@cVPPRR4PRR4R,pV\\V,.3#)a ``(url, subprotocols)`` for dialing the owner's canonical WebSocket with a session ticket. The owner accepts exactly one ticket subprotocol beside ``GATEWAY_WS_PROTOCOL`` and echoes the latter; callers check ``ws.subprotocol == GATEWAY_WS_PROTOCOL`` after the upgrade.zhttps:zwss:zhttp:zws:z/api/ws) api_originreplaceGATEWAY_WS_PROTOCOLGATEWAY_WS_TICKET_PREFIX)endpointticketurls&& >/home/ubuntu/.hermes/hermes-agent/hermes_cli/gateway_client.pygateway_ws_targetr%sF    % %h 7 ? ? OR[ [C $&>&GH HHc]tRt^.tRtR#)GatewayClientErrorN)__name__ __module__ __qualname____firstlineno____static_attributes__rrrrr.srrc0a]tRt^2tRtRV3RlltRtV;t#)GatewayRPCErroraA received owner refusal, distinct from an ambiguous transport failure. ``str(exc)`` is the bounded reason code; ``code`` is the frame's numeric JSON-RPC code (``None`` when absent or not an int) and ``data`` its bounded, scalar-only ``error.data`` mapping.c T<\SV`V4W nT;'g/VnR#N)super__init__codedata)selfreasonr!r" __class__s&&&&rr GatewayRPCError.__init__8s"   JJB r)r!r"NNrrrr__doc__r r __classcell__r%s@rrr2s` rrc\V\4'd9VPRR4P4'd\ V4^P8:dV#R#)_N) isinstancestrr isalnumlenvalues&r_bounded_reasonr5>sBuc**u}}S"/E/M/M/O/OTWX]T^bdTd5njnnrcaRo\V\4'g/#/pVP4Fwr#\V4^8g'\V\4'd\V4^@8dK=S!V4'dW1V&KQ\V\ 4'gKi\V4^8:gK{\ ;QJdV3RlV4F 'dK RM RM!V3RlV44'gK\ V4W&K V#)zAt most 16 short keys whose values are bool/int/None, short strings or short lists of them; anything else (nested objects, raw remote diagnostics) is dropped, never forwarded.cVRJ;'gE\V\\34;'g'\V\4;'d\ V4^8*#r)r/boolintr0r2r3s&rscalar#_bounded_error_data..scalarEsD}pp 54+ >pp:eUXCYCoCo^abg^hlo^oprc34<"TF pS!V4xK R#5irr).0itemr:s& r &_bounded_error_data..OsAa[`SW&,,[`sFT)r/dictitemsr2r0listall)r"outkeyr4r:s& @r_bounded_error_datarGBsq dD ! ! Cjjl  s8r>C!5!5SB  %==H t $ $Ur)9ccAa[`AacccAa[`Aa>a>aE{CH # Jrc\V\4'dTM/p\VPR44pVPR4p\ VPRR44;'g\ VPR44p\ T;'gR\V\ 4'd\V\4'gW!4#RV4#)aThe ``GatewayRPCError`` for one received ``error`` member: only bounded reason codes, never raw remote diagnostics. A free-text message (``unknown method: x``) falls back to the bounded ``data.reason`` the owner sends beside it, then to ``request_failed``.r"r!messagerequest_failedr$N)r/rArGgetr5rr9r8)errorr"r!r$s& r rpc_errorrMTs t,,E"E uyy0 1D 99V D UYYy2BC D k kX\X`X`aiXjHkF 655%5#-dC#8#8DRVAWAW4 ii]acg iirc,a]tRt^`tRtV3RltRtV;t#)GatewayUnavailableErrorzNo ready owner to dial: ``state`` is ``ensure_gateway_runtime``'s verdict (``draining`` while an update holds the install, ``starting`` past the deadline, ...). Nothing was submitted.c 2<\SV`V4W nR#r)rr state)r#rIrQr%s&&&rr GatewayUnavailableError.__init__ds ! r)rQr(r+s@rrOrO`s^rrOcBa]tRt^itRtV3RltV3RltRRltRtV;t #) EventQueuezThe client's bounded event queue plus an ordered overflow behind it: each ``get`` refills the queue from the overflow, so items arrive in read order and ``qsize``/``full`` see only the queue.c <\SV`V4\4Vn^Vn\ P !4VnR#)N)rr roverflowoverflow_bytesasyncioEventmoved)r#maxsizer%s&&rr EventQueue.__init__ms. ! ]]_ rc <\SV`4pVP'dEVPP4wr#V;PV,un\SV`V4VP P4V#r)r_getrWpopleftrX_putr[set)r#r>sizeheldr%s& rr_EventQueue._getss[w|~ ===..0JD   4 '  GL   rc VP'gVPV4R#VPP W!34V;P V, unR# \PdLNi;i)z?Queue *item* behind everything already read, never dropping it.N)rW put_nowaitrY QueueFullappendrX)r#r>rcs&&&rholdEventQueue.hold|s`}}} % d\* t#$$  sAA65A6)r[rWrX)rV) rrrrr)r r_rjrr*r+s@rrTrTisi%  $ $rrTcz\V\4'dVPV4R#VPV4R#)z[Queue a local item (ACP's post-ack recovery) behind every frame read so far; never dropped.N)r/rTrjrg)eventsr>s&&r put_behindrns)&*%% D$rcH]tRt^tRtRtRtRtRtRt RR/R lt R t R#) GatewayClientc ^Wn\RR7Vn/Vn^VnRVnR#))r\N) websocketrTrmpendingsequencereader)r#rss&&rr GatewayClient.__init__s(" .    rc VPpVP'*;'g\VP4\8;'dVP\ 8;'de\ ;QJd4RVPP44F 'gK R# R#!RVPP444#)zKeep reading past a full queue: nothing is held, or an awaited answer may sit behind the held frames (its waiter may be the queue's only consumer) and the overflow has room.c3J"TFqP4'*xK R#5ir)done)r=futures& rr?)GatewayClient._read_on..sJ4I& %%4Is!#TF) rmrWr2EVENT_OVERFLOW_FRAMESrXEVENT_OVERFLOW_BYTESanyrtvalues)r#rms& r_read_onGatewayClient._read_ons??"LL  #8 8 K KV=R=RUi=i K KJDLL4G4G4IJ L LJDLL4G4G4IJJ Lrc "VPPW4VP4'dR#\P!\ 4;_uu_4GRjxL VP4'gSVPP P4VPP P4GRjxL KhRRR4GRjxL R#L~LL +GRjxL 'giR#;i5ir) rmrjrrYtimeoutEVENT_STALL_TIMEOUTr[clearwait)r#framercs&&&r_deliverGatewayClient._delivers % ==?? ??#6777mmoo !!'')kk'',,...877/8777sgAC>CC> C!7A C!CC! C>CC>C!C>!C; 'C*( C; 3C; 5 C>c `"\P!VP44VnV#5ir)rY create_task_readrv)r#s&r __aenter__GatewayClient.__aenter__s"))$**,7  s,.c "VPP4\\P4;_uu_4VPGRjxL RRR4R#L +'giR#;i5ir)rvcancelrrYCancelledError)r#excs&*r __aexit__GatewayClient.__aexit__sI  g,, - -++  . - . - -s.*>*> &&( KK  U #'(z{E,,--/{{}}((/0 {{!!$++*>*>*> &&( KK  U #sJ+ C;C9C5C9AC;:AC;C;.C7/C;5C97C;9C;:G ;DG DG ;J+4J+ J+)7J+ :D8D9;D4D5D8D:DDD77D:)rmrtrvrurs) rrrrr rrrrrrrrrrrprps2L / $6(D((rrppurpose interactivescopesubjectc V^8dQhRRRR/#)homerreturnr0r)formats"r __annotate__rs!!$!ad!rc"a^RIHp^RIHpHpV!W4p\ P !R^R^RRRRVPR VPR V/V'dR V/M/CV'dR V/M/C/4P4R ,p\PR8Xd^RI H p V !W^4p M\P!4^,p V!V^4;_uu_4p V P!V4\#4p R V 9dV \P!4, p V ^8:d \%R4hV P'V 4V P)R4pV'd!\+V 4\+V4,R8d \%R4hV P-V4KRRR4V!\/X 44o\0;QJdGV3RlRVPR VPR^/P344F 'gK RM< RM8!V3RlRVPR VPR^/P3444'g5\5SP7R4\84'dSR,'g \%R4hSR,# +'giL;i)rV)control_home_for)connect_private_identify_responseprotocolrverbzsession-ticketr profile_id instance_idrrr nt)query_runtime_controlzGateway bootstrap timed outrriz"Invalid gateway bootstrap responseNc3P<"TFwrSPV4V8gxK R#5ir)rK)r=kvgrants& rr?"_session_ticket..s( *599Q<1 *s#&runtime_protocolTFrz0Gateway bootstrap identity changed; retry launch)hermes_cli.gateway_runtimer$hermes_cli.gateway_runtime_discoveryrrrrrrencodeosname!gateway.runtime_bootstrap_windowsrtime monotonicsendall bytearrayr settimeoutrecvr2extendbytesrrBr/rKr0)rr rrrrrrrequestrr"deadlinepeerrchunkrs&&$$$ @r_session_ticketrs(;X D +Djj*aq&:JHh))=(:N:NPY[bW$GU "WJQ9g2FWYW 5G ww$K$TA6>>#a' T1 % % LL !;Dt#!DNN$44Q;,-JKK' $D CJ 6 >,-QRR E"$& uT{ +E s h))=(:N:NPbde* eg* sss h))=(:N:NPbde* eg*  8!4c::%// !STT ?#& %sA:I>>I>> J c "^RIHp^RIHp^RIHpHpHp^RIH pVeRM-\PPRR4P4pRp VeA\P!\ V!V!44VVR7GRjxL p \#W 4wrEMDV'd;V!V4p V P$R9gV P&'g \)R 4hTp EMV!V!44p \P!W]R R 7GRjxL pV!V4'g\+VR R4pVP,R 8Xd"V'd\/RV 2VP04hV'dRV R2MRp\/RVP0 RVP,;'gR V 2VP04hVP2p\P!\ W4GRjxL p \#W 4wrV!W^ RRR7;_uu_4GRjxL pV 'd!VP4\68wd \)R4h\9V4;_uu_4GRjxL pV5xRRR4GRjxL RRR4GRjxL R#ELELfLLwL5L" +GRjxL 'giL9;iL0 +GRjxL 'giR#;i \(dh\:\<3dp\)R4ThRp?ii;i5i)aeAttach to this home's owner. ``endpoint``: an already-discovered ready owner to dial as-is (maintenance that must never start a gateway); default ensures one, starting it if needed. ``subject``: mint the ticket for this principal (the caller's authenticated dashboard user) rather than the socket identity; only a peer the owner already trusts may name one.)connect)get_hermes_home) attachableensure_gateway_runtimegateway_profile_home)urlsplitNr.HERMES_TUI_GATEWAY_URL)rz9Invalid explicit gateway WebSocket URL; no local fallbackT) idle_exitdetailruntime_exitedzGateway could not start: z ()zGateway z: not_ready) subprotocols open_timeoutmax_sizeproxyz2Gateway protocol mismatch; update/restart requiredz,Gateway connection failed; no local fallback>wswss)websockets.asyncio.clientrhermes_constantsrrrrr urllib.parserrenvironrKstriprY to_threadrrschemehostnamergetattr reason_coderOrQr subprotocolr rprr)r rrrrrrrremote protocolsrrparsedrrrrclientrs&& rconnect_gatewayr sn 20cc%'RRZZ^^I4  JI2J J/J J/$K)K,K.J/0J2J4J :I=; J J JJ/J, J J, $J, &J/*K,J//K K KKKrr')&r) __future__rrY collectionsr contextlibrrrrpathlibrrgateway.session_contractrr r rRESUME_KEY_MISMATCHCOMPRESS_RPC_TIMEOUTrr}r~rrrrr5rGrMrOQueuerTrnrprr rrrrsL"4  W3_ &I   ( o$ i0$$> N(N(b!]!$!X\!H3Z3Zr