߲jt,dZddlmZddlZddlZddlZddlmZmZddl m Z m Z m Z m Z mZmZddlmZmZmZmZmZdZGdd eZeGd d ZeGd d ZGddeZy)zZOne backend-owned connection operation per ``manage_connections`` call. Pure data, no I/O.) annotationsN) dataclassfield)AnyCallableClassVarDictListOptional)RESOLVED_STATESActor SettleReason TargetStateallowedgr@c eZdZy)IllegalTransitionN)__name__ __module__ __qualname__?/home/ubuntu/.hermes/hermes-agent/tools/connectors/operation.pyrrsrrceZdZUded<ded<ded<ej Zded<dZded<dZded <d Z d ed <d Z d ed <d Z d ed<dZ ded<e eZded<e eZded<eddZddddZy )Targetstrnamekindactionrstatedetail instructionsN Optional[str] connect_url connection_idattemptfloat next_read_atdefault_factoryzList[Dict[str, Any]] required_envDict[str, Any]extrac&|jtvSN)rr selfs rresolvedzTarget.resolved+szz_,,rTwith_urlc|j|j|j|jjd}|j r|j |d<|j r|j |d<|r|jr|j|d<|jr|j|d<|jr|j|d<|jr|j|d<|j|j|S)N)rrrrr!r"r$r%r&r,) rrrrvaluer!r"r$r%r&r,updater.)r2r5outs rsnapshotzTarget.snapshot/s'+yy$))t{{eieoeoeueuv ;; KKCM   "&"3"3C  ((!%!1!1C    #'#5#5C <<!\\C N   "&"3"3C  4:: rreturnbool)r5r=r<r-)rrr__annotations__rpendingrr!r"r$r%r&r)rlistr,dictr.propertyr3r:rrrrrs I I K$,,E;,FCL#!%K%#'M='!G]!L%*/t)DL&D!$7E>7 --,0rrcPeZdZUdZded<ded<dZded<dZded <dZd ed <ed Z ded<ee j Z ded<dZ ded<dZ ded<dZded<dZded<eej"dZded<eddZded <eej(dZd!ed"<d7d#Zd8d$Zddddd% d9d&Zej4d'd:d(Zd;d)Zdd?d-Z!d>d@d.Z"d=d/Z#d0d1dAd2Z$d0d1dAd3Z%d0d1dAd4Z&d0d1dAd5Z'd;d6Z(y)BConnectionOperationNzeClassVar[Optional[Callable[['ConnectionOperation', Optional[Dict[str, Any]], Dict[str, Any]], None]]] on_changez List[Target]targetsr r session_key profile_keyr# tool_call_idcDtjjddS)N )uuiduuid4hexrrrzConnectionOperation.Nstzz|/?/?/Drr*op_idr( created_atr' deadline_atOptional[float] settled_atzOptional[SettleReason] settled_byrintseqF)r+reprzthreading.Eventwake)defaultrXOptional[Dict[str, Any]]_settled_snapshotzthreading.Lock_lockcN|js|jtz|_yyr0)rRrQOPERATION_DEADLINE_SECONDSr1s r __post_init__z!ConnectionOperation.__post_init__[s"#1KKD  rcBtfd|jDdS)Nc3BK|]}|jk(s|ywr0)r).0trs r z-ConnectionOperation.target..`s?1$Q?s)nextrF)r2rs `rtargetzConnectionOperation.target_s? ?FFr)r!r$r%r&c |j|} | td||j5| j|k(r dddyt | j | j||k7rKt| j d|d| jj d|j d|j || jj |j |j d} || _||| _| j| d<||| _||| _ ||| _ |rt|| _ |j} ddd|jj|j!  | S#1swY7xYw) zMove one target; the contract decides whether ``actor`` may. Returns the change, or None when the target is already in ``to``. Allowed after settlement: the frozen result stays.Nunknown target  z: z -> z by )rgfromtoactorr!)rgrr]rrrr7r!r$r%r&rAr. _bump_lockedrYset_changed) r2rrlrmr!r$r%r&r.rgchanger:s r transitionzConnectionOperation.transitionbsnT" >#odX$>? ? ZZ +||r! + +v{{FLL"5>'6;;-qbASAS@TTXY[YaYaXbbfglgrgrfs(tuu $fll.@.@[`[f[fgFFL! & %}}F8 &%0"('4$"!(#E{ ((*H% +&  fh' + + +sE8C:E88F)rmc|j|}|td||j5||_||_||j j |j j |j |d}|j}ddd|jj|jy#1swY6xYw)aReplace a target's link and detail without a state change (a repeated failure). ``actor`` says who produced the new text: a second failure of a backend attempt is the backend's report, not the user's move, and the frame must not claim otherwise.Nri)rgrkrlrmr!) rgrr]r$r!rr7rnrYrorp)r2rr$r!rmrgrqr:s rrefreshzConnectionOperation.refreshs T" >#odX$>? ? ZZ +!,F "FM $fll.@.@ HZHZejepep &(F((*H  +  fh' + +s AB<<Ccd|j|xjdz c_|jS)aAdvance the write counter and take the snapshot that frame carries. Both happen under ``_lock`` so a second writer cannot backdate this frame with its own state. After settlement the frozen snapshot is the frame, seq included: a later write changes nothing the renderer can see, so it must not leave the operation naming a seq no frame carried (the resume snapshot would wait for a frame that never comes).)r\rW_result_lockedr1s rrnz ConnectionOperation._bump_lockeds,  ! ! ) HHMH""$$rcHt|j}| ||||yyr0)typerE)r2rqr:hooks rrpzConnectionOperation._changeds(Dz##   vx ( rcht|jxrtd|jDS)Nc34K|]}|jywr0)r3)rcrds rrez3ConnectionOperation.all_resolved..s)K!**)Ks)r=rFallr1s r all_resolvedz ConnectionOperation.all_resolveds%DLL!Kc)Kdll)K&KKrc|jduSr0)rTr1s rsettledzConnectionOperation.settledsd**rcltd|j|tjz S|z S)Nr')maxrRtime)r2nows rremaining_secondsz%ConnectionOperation.remaining_secondss/3((3;DIIKPQQCPQQrc|j5|j dddy|tjn||_||_|jD]$}|j rt j|_&|j|_ ddd|jj|jd|jy#1swY@xYw)z5Compare-and-set: the first caller freezes the result.NFT)r]rTrrUrFr3r not_connectedrrnr\rYrorp)r2byrrgs rsettlezConnectionOperation.settles ZZ 9* 9 9.1[diikcDO DO,, =#.#<#(>y(IJ1tAwJGJ /AEE-./..@ @$$y$99 KsA6cj|j5|j|cdddS#1swYyxYw)Nr)r]rw)r2rs rr:zConnectionOperation.snapshots/ ZZ <&&&; < < ((9(=F >Y' .F JJ - . ::l # +M+MY' 2F JJ~t ,+1::f+=+FFJJw'DE"223u:T2JK<[UYZNGU*1' 2 + > >s CC%c.|j5|jDcgc]}|j}}|j}ddd|j|j t d}|jr|j|d<|Scc}w#1swYKxYw)zThe ``connection.request`` payload and the resume snapshot: identity, live target snapshots (links included, the panel owns them), server-owned deadline.N)rPrWrRtimeout_secondsrFrI)r]rFr:rWrPrRr_rI)r2rdrFrWpayloads rrequest_payloadz#ConnectionOperation.request_payloadsZZ -1\\:qzz|:G:((C ZZ++9 #    &*&7&7GN #;  sB BB B  B)r<None)rrr<zOptional[Target])rrrlrrmr r!r#r$r#r%r#r&r#r.rr<r[) rrr$r#r!rrmr r<r)r<r-)rqr[r:r-r<rr;r0)rrSr<r()rrrrSr<r=)rr=r<r-))rrrrEr>rGrHrIrrPrrQrRrTrUrW threadingEventrYr\Lockr]r`rgrrr userrtrnrprBr~rrrrrrwr:rrrrrrDrDAs  KK"&L-&'DEE3Edii8J8K"&J&)-J&-CL!)//ND/N2752Q/Q!)..uME>MLGTX%)$im(16CP":GYf " B]b\f\f(" %) LL++R L59 37:-1<+/0rrDceZdZdZy)DetachedOperationN)rrrrErrrrrsIrr)__doc__ __future__rrrrL dataclassesrrtypingrrrr r r tools.connectors.contractr r rrrr_ ValueErrorrrrDrrrrrs{`" (@@``#   (( (V }} }@+r