+ lHj1Rt^RIHt^RIt^RIt^RIt^RIt^RIHtH t ^RI H t H t H t HtHtHt^RIHtHtHtHtHt]P.!]4tRt!RR]4t]!R R 44t]!R R 44t!R R]4tR#)zOne backend-owned connection operation per ``manage_connections`` call. Pure data; its only I/O is one local log line per state change and per settle.) annotationsN) dataclassfield)AnyCallableClassVarDictListOptional)Actor SettleReason TargetStateallowedresolvesgr@c]tRt^tRtR#)IllegalTransitionN)__name__ __module__ __qualname____firstlineno____static_attributes__r?/home/ubuntu/.hermes/hermes-agent/tools/connectors/operation.pyrrsrrc8]tRt^t$R]R&R]R&R]R&]P tR]R&RtR]R&Rt R]R &R t R ]R &R t R ]R &R t R ]R&Rt R]R&]!]R7tR]R&]!]R7tR]R&R tR ]R&R tR ]R&R tR ]R&]RRl4tRR/RRlltR tR #)!Targetstrnamekindactionr statedetail instructionsN Optional[str] connect_url connection_idattemptfloat next_read_atdefault_factoryzlist[dict[str, Any]] required_envdict[str, Any]extraphasealias repair_idcV^8dQhRR/#returnboolr)formats"r __annotate__Target.__annotate__6s//$/rc B\VPVP4#N)rrr selfs&rresolvedTarget.resolved5s 4::..rwith_urlTc V^8dQhRRRR/#)r5rAr7r6r.r)r8s"rr9r:9sDNrc  *RVPRVPRVPRVPPRVP /pVP 'dVP VR&VP'd/VP\P8XdVPVR&VP'dVPVR&VP'dVPVR&V'd"VP'dVPVR &VP'dVPVR &VP'dVPVR &VP'dVPVR &VP!VP"4V#) rrrr r?r1r0r"r#r%r&r'r-)rrrr valuer?r1r0r initiatedr"r#r%r&r'r-updater/)r>rAouts&$ rsnapshotTarget.snapshot9s-%tyy&$))Xt{{\ceieoeoeueu)4==: :::::CL :::$** (=(==::CL ;;; KKCM    "&"3"3C  (((!%!1!1C     #'#5#5C <<<!\\C N    "&"3"3C  4:: rr)rrrr__annotations__r pendingr r"r#r%r&r'r*rlistr-dictr/r0r1r2propertyr?rHrrrrrrs I I K$,,E;,FCL#!%K%#'M='!G]!L%*/t)DL&D!$7E>7E=E=#I}# //4rrc]tRt^Pt$RtR]R&R]R&RtR]R&RtR]R &RtR ]R &Rt R ]R &] !RR7t R]R&] !] PR7t R]R&RtR]R&RtR]R&RtR]R&^tR]R&] !]P&RR7tR]R&] !RRR7tR ]R!&] !]P,RR7tR"]R#&R$R%ltR&R'ltR(RR)RR*RR+R/R,R-lltR.]P8R/R/R0R1lltR2R3ltR4R5lt] R6R7l4t!] R8R9l4t"RMR:R;llt#RMR<R=llt$R>R?lt%R@RA/RBRCllt&R@RA/RDREllt'R@RA/RFRGllt(R@RA/RHRIllt)RJRKlt*RLt+R#)NConnectionOperationNzcClassVar[Optional[Callable[[ConnectionOperation, Optional[dict[str, Any]], dict[str, Any]], None]]] on_changez list[Target]targetsr!r session_key profile_keyr$ tool_call_idz Optional[Any]callc N\P!4PR,#):N N)uuiduuid4hexrrrConnectionOperation._stzz|/?/?/Drr+op_idr) created_atr( deadline_atOptional[float] settled_atzOptional[SettleReason] settled_byintseqF)r,reprzthreading.Eventwake)defaultrfOptional[dict[str, Any]]_settled_snapshotzthreading.Lock_lockcV^8dQhRR/#)r5r6Noner)r8s"rr9 ConnectionOperation.__annotate__lsLLtLrc fVP'gVP\,VnR#R#r<)r`r_OPERATION_DEADLINE_SECONDSr=s&r __post_init__!ConnectionOperation.__post_init__ls%#1KKD  rc V^8dQhRRRR/#)r5rrr6zOptional[Target]r)r8s"rr9rnpsGG3G#3Grc Da\V3RlVP4R4#)c3L<"TFqPS8XgKVxK R#5ir<)r).0trs& r -ConnectionOperation.target..qs? 1$QQ s$ $N)nextrR)r>rs&frtargetConnectionOperation.targetps? ?FFrr"r%r&r'c<V^8dQhRRRRRRRRR RR RR RR R RR/ #)r5rrtor actorr r"r$r%r&r'r/rr6rir)r8s"rr9rnssX   ( 16 CP " :G Yf   " rc VPV4p V f\RV: 24hVP;_uu_4V PV8Xd RRR4R#\ V P V PV4V8wdL\V P RV RV PP RVP RVP 2 4hRVRV PP R VP R VP /p W)nVeWInV PV R &VeWYnVeWin VeWyn V'd\V4V n VP4p RRR4\PR VP VX R,VP VP 4VP"P%4VP'V X 4V # +'giL};i) 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 r{fromr~rr"z#connection op %s: %s %s -> %s by %s)r{rrkr rrrDr"r%r&r'rMr/ _bump_lockedloggerinfor^rgset_changed) r>rr~rr"r%r&r'r/r{changerHs &&&&$$$$, r transitionConnectionOperation.transitionssT" >#odX$>? ? ZZZ||r!Zv{{FLL"5>'6;;-qbASAS@TTXY[YaYaXbbfglgrgrfs(tuuffll.@.@$RY[`[f[fgFL! & %}}F8 &%0"('4$"!(#E{ ((*H%&  94::tVTZ^]_]e]eglgrgrs  fh' -ZsGC'G> G G# rr0c 0V^8dQhRRRRRRRRRRR R /#) r5rrr%r$r"rr r0r6rmr)r8s"rr9rns9((C(((TY($(04(rc  VPV4pVf\RV: 24hVP;_uu_4W&nW6nWVnRVRVP PRVP PRVPRV/pVP4pRRR4VPP4VPXX4R# +'giL>;i)a%Replace a target's link, detail and install phase without a state change (a repeated failure, or the next step of an install). ``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.Nrr{rr~rr") r{rrkr%r"r0r rDrrgrr) r>rr%r"rr0r{rrHs &&$$$$ rrefreshConnectionOperation.refreshsT" >#odX$>? ? ZZZ!, "M Lffll.@.@$ HZHZ\cejepep(F((*H   fh'Zs A!C C cV^8dQhRR/#r5r6r.r)r8s"rr9rns % %n %rc pVPfV;P^, unVP4#)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).)rjre_result_lockedr=s&rr ConnectionOperation._bump_lockeds,  ! ! ) HHMH""$$rc$V^8dQhRRRRRR/#)r5rrirHr.r6rmr)r8s"rr9rns#))7)>)VZ)rc N\V4PpVe V!WV4R#R#r<)typerQ)r>rrHhooks&&& rrConnectionOperation._changeds&Dz##   x ( rcV^8dQhRR/#r4r)r8s"rr9rnsLLdLrc \VP4;'dI\;QJd&RVP4F 'dK R# R#!RVP44#)c38"TFqPxK R#5ir<)r?rvrws& rrx3ConnectionOperation.all_resolved..s)Kl**lsFT)r7rRallr=s&r all_resolved ConnectionOperation.all_resolvedsDDLL!KKcc)Kdll)KccKcKc)Kdll)K&KKrcV^8dQhRR/#r4r)r8s"rr9rns+++rc VPRJ#r<)rbr=s&rsettledConnectionOperation.settledsd**rc V^8dQhRRRR/#)r5nowrar6r)r)r8s"rr9rnsRR_RRrc \RVPVf \P!4, 4#T, 4#)r()maxr`time)r>rs&&rremaining_seconds%ConnectionOperation.remaining_secondss/3((3;DIIKPQQCPQQrc$V^8dQhRRRRRR/#)r5byr rrar6r7r)r8s"rr9rns!Otrc VP;_uu_4VPe RRR4R#Vf\P!4MTVnWnVPF,pVP 'dK\ PVnK. VP4Vn RPRVP44pRRR4\PRVPVPX4VP P#4VP%RVP4R# +'giLt;i)z5Compare-and-set: the first caller freezes the result.NFz, c3j"TF)qP RVPP 2xK+ R#5i)=N)rr rDrs& rrx-ConnectionOperation.settle..s% SlFF81QWW]]O!rrr{outcomess&&& rsettleConnectionOperation.settles ZZZ*Z.1[diikcDO O,,#.#<#rrws&$ r_snapshot_locked$ConnectionOperation._snapshot_lockedsr TZZ 488 4++ $// 4???$////  M 1 I 6 M   Ns*Bc V^8dQhRRRR/#rr)r8s"rr9rns::4:>:rc VPefVPR,Uu.uFp\V4NK ppV'gVFpVPRR4K \VPVR7#VPVR7#uupi)NrRr%)rRr)rjrMpopr)r>rrwrRs&$ rr"ConnectionOperation._result_lockeds{  ! ! -(,(>(>y(IJ(I1tAw(IGJ AEE-.!..@ @$$y$99 KsBc V^8dQhRRRR/#rr)r8s"rr9rns<rs&$rrHConnectionOperation.snapshots( ZZZ&&&;ZZZs 2 A c V^8dQhRRRR/#rr)r8s"rr9rns4>rc JVP;_uu_4VPVR7pRRR4XR,F'pVPRR4VPRR4K) VPR4fV#^RIHp^RIHpVR,F~pVPRR4VPR 4R 8XdVPR 4MRpV'gKHVP\V4R R 7pV!VRR7wrV'gKzWR&K V# +'giL;i)rNrRr&r?rb)registry)build_catalog_listing_with_formr#rmcptoolsT)quieti) max_tokens tools_listing) rkrrgettools.registryrtools.tool_search_catalogrget_definitionsr) r>rresultr{rrnames definitionslisting_forms &$ rrConnectionOperation.results ZZZ((9(=FY''F JJ - JJz4 (( ::l # +M+MY''F JJ~t ,+1::f+=+FFJJw'DE"223u:T2JK<[UYZNGw*1'( -Zs D D" cV^8dQhRR/#rr)r8s"rr9rnsrc  bVP;_uu_4VPUu.uFqP4NK ppVPpRRR4RVPRXRVP R\ RX/pVP'dVPVR&V#uupi +'giL\;i)zThe ``connection.request`` payload and the resume snapshot: identity, live target snapshots (links included, the panel owns them), server-owned deadline.Nr^rer`timeout_secondsrRrU)rkrRrHrer^r`rprU)r>rwrRrepayloads& rrequest_payload#ConnectionOperation.request_payloadsZZZ-1\\:\zz|\G:((C TZZ 3 4++ 9 w #     &*&7&7GN #;ZsBBBB B. )rjr`rbrcr<),rrrrrQrJrSrTrUrVrr^rr_r`rbrcre threadingEventrgrjLockrkrqr{rr userrrrrNrrrrrrrrHrrrrrrrPrPPs  KK"&L-&D-'DEE3Edii8J8K"&J&)-J&-CL!)//ND/N2752Q/Q!)..uME>MLG SW %) JN im D(\a\f\f('+(( %) LL++R"L D :$:rs># (@@YY   8 $#   33 3l FF FR+r