+ jHj&0a0t$Rt^RIHt^RIt^RIt^RIt^RIHt^xt Rt !RR4t ]P!4t /tR]R&R R ltR R ltR RltRR/RRlltRRR] /RRlltRRR] RR/RltRRltRRltRR/R ltRR/R!ltR#)"uDThe session owner's server→client requests to a local viewer, and who may settle them. The owner sends a request frame (``tui_gateway/contracts/server_requests.py``: ``sudo``, ``secret``, ``clarify``, the Desktop UI requests) to the viewers attached to a session's event stream and blocks the agent thread until one answers, the turn is interrupted, or it times out: the canonical side of main's sidecar ``tui_gateway/server_requests.py``. A viewer answers with a JSON-RPC response frame (:func:`resolve`) or, for a batch clarify, per question with ``clarify.lock`` (:func:`lock_answer`); both go through :func:`may_settle`, and a batch's terminal result comes from ``tools.clarify_batch.settle_batch``, the rule the sidecar uses too. Values are never published, journaled or logged: they travel only in the viewer's response frame. ) annotationsN) settle_batchg?c$]tRt^tRtRRltRtR#)_PendingNc \P!4VnWnW@nW0nRVnRVnV'd \V4MRVn /Vn R#)N) threadingEventevent session_idmethodeventsvalueresulttupleqidslocked)selfr rr r s&&&&&D/home/ubuntu/.hermes/hermes-agent/gateway/session_server_requests.py__init___Pending.__init__sE__& $    #'E$KT  )r r rr rrr r)NNN)__name__ __module__ __qualname____firstlineno__ __slots__r__static_attributes__rrrrs`I  rrzdict[str, _Pending]_opencV^8dQhRR/#returnboolr)formats"r __annotate__r&-sSStSrcVPPV4pVRJ;'dVRJ;'dVPVJ#)zSTrue when *authority*'s live *session_id* is the very stream a request was sent on.N)sessionsget event_stream) authorityr r lives&&& rowned_byr--sC    ! !* -D t  R Rd 2 R Rt7H7HF7RRrcV^8dQhRR/#r!r)r%s"rr&r&3sCCCrc,^RIHp^RIHp\ WV4'gR#VP W!VP V4R4TPPT4pTRJ;'dYPP49# TdR#i;i)asThe one rule for who may settle an owner request (a response frame or ``clarify.lock``): the request went out on *authority*'s own live stream for that session (session ids repeat across profiles and ``_open`` is process-wide), *actor* holds ``session:respond`` there, and *actor* is attached to that session, the same set of connections the request frame was written to.) SessionRef)RuntimeStoreErrorFzsession:respondN) gateway.session_contractr0hermes_state_runtimer1r- authorize profile_idr(r) subscribersvalues)r+actorr r r0r1r,s&&&& r may_settler93s 46 I6 2 2E:i.B.BJ#OQbc    ! !* -D t  B B)9)9)@)@)B BB s#BBBcV^8dQhRR/#r!r)r%s"rr&r&Ds\\\rc\V\4;'dgRV9;'dZ\VPR4\4;'d3VR,P R4;'dRV9;'gRV9#)zbA viewer's answer to one of the owner's requests: a string ``srq-`` id, a result/error, no method.r idsrq-rerror) isinstancedictr)str startswith)frames&ris_response_framerDDs ud # [ [(= [ [*UYYW[_^aBb [ [d &&v. [ [4<4E4Y4YTYIY\r session_okcR#)Trr r s&&rrHJsDrcV^8dQhRR/#r!r)r%s"rr&r&JsTrc\;_uu_4\PVR,4pVe$V!VPVP4'g RRR4R#\P VR,R4VP e\VP4MRpRRR4RV9dVPR4MRpXe \W44p\V\4'dVPR4MRp\V\4'dTMRXn \V\4'dTMRVn VPP4R# +'giL;i) afSettle the open request *frame* answers; False when nothing (here) waits for that id. ``session_ok(session_id, events)`` lets the caller refuse an answer from a connection not entitled to that session: the caller's own authority must own ``events``, the stream the request was sent on (session ids are only unique per profile, and ``_open`` is process-wide).r<NFr>rrrT)_lockrr)r r poprr@rrr?rArrr set)rCrEpendingrrrs&$ rresolverOJs ))E$K( ?*W-?-?"P"P   %+t$)0)Agnn%t  %,5$8UYYx dF f-#-fd#;#;FJJw E's33EGM)&$77VTGN MM  sAEEAE E$ cancelledcR#FrrrrrHrH`srtimeoutcV^8dQhRR/#)r"r#rAr)r%s"rr&r&`s88mp8rc B\WW#WER7pVe VP#R#)uSend one one-string server→client request (``sudo``, ``secret``: ``ValueResult``) to the session's attached viewers and wait for its ``value``; "" on skip, interrupt, timeout or no viewer.)rPrSr)_askr)r r r paramsrPrSrNs&&&&$$ r ask_viewerrX`s&6v\G#/7==7R7rcR#rRrrrrrHrHgsurrc D\WW#WEVR7pVe VP#R#)a^The same round trip for a structured answer (``clarify``: ``ClarifyResult``): the viewer's ``result`` dict, or None on interrupt, timeout, an error response or no attached viewer. ``qids`` makes it a batch, which always ends with ``{answers: , outcome}`` once asked: ``lock_answer`` (the ``clarify.lock`` verb) answers it per question.)rPrSrN)rVr)r r r rWrPrSrrNs&&&&$$$ rask_viewer_resultr[gs) 6vbfgG$07>>:d:rcV^8dQhRR/#r!r)r%s"rr&r&qsuu4urc&aaa\;_uu_4\;QJd3VVV3Rl\P44F 'gK RM( RM$!VVV3Rl\P444uuRRR4# +'giR#;i)zXWhether a *method* request is open on this live session's stream (the card still waits).c3<"TF@qPS8H;'d&VPSJ;'dVPS8HxKB R#5i)N)r r r ).0pr r r s& r waiting..tsAtes`a<<:-[[!((f2D[[U[I[[essA A A TFN)rKanyrr7)r r r sfffrwaitingrdqsF stejeqeqestssstejeqeqestt s4A? +A?? B cV^8dQhRR/#)r"r#intr)r%s"rr&r&ws  C rc \;_uu_4\\P44UUu.uFRwr4VPV8XgKVP VJgK*VP V8XgK=\PV4NKT pppRRR4XFpVPP4K \V4#uuppi +'giLD;i)zSettle every open *method* request on this live session's stream with no answer, the way a viewer that answered would: the asker reads None and every renderer gets ``request.cancel reason: resolved``.N) rKlistritemsr r r rLr rMlen)r r r ridr`settledrNs&&& rwithdrawrmws 04U[[]0C`0Cfcllj0"56XX5G"LMHHX^L^"599S>0C`   w< ` s.!CC C C /C CC C cR#rRrrGs&&rrHrHsZ_rcr\;_uu_4\PV4pVe2VPe$V!VPVP 4'g RRR4R#WP9d \ V4hW$PV&VPUu.uFqUVP9gKVNK ppV'g3\PVR4\VPRR7Vn RRR4X'gXPP4V#uupi +'giL9;i)aLock one answer of an open batch request (``clarify.lock``; editable until the last lock; ``None`` = skipped). Returns the question ids still unanswered; the lock that empties it settles the request with ``{answers, outcome: submitted}``. ``None`` when no open batch has that id or the caller may not answer its session (expired, or another profile's / session's request: see :func:`resolve`); ``ValueError`` for an unknown question id.N submittedended) rKrr)rr r ValueErrorrrLrrr rM) request_id question_idanswerrErNqid remainings&&&$ r lock_answerrys ))J' ?gll2*WEWEWY`YgYg:h:h  ll *[) )&,{#$+LLNLSw~~4MSSL N IIj$ ')'.. LGN     O s0A D&D&%7D&D!3D!9 H  H( + H; > I )__conditional_annotations____doc__ __future__rrrrtools.clarify_batchrREQUEST_TIMEOUT_SrrLockrKr__annotations__r-r9rDrOrXr[rdrmryrV)rs@rrs # , " S C"\ !@,8 8Wh8;};^o;;u ?_,''r