+ iHj=Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI H t H t H t HtHtHt^RIHt^RIHtHtHt^RIHt^RIHtHtHtHtHtH t H!t!^RI"H#t#H$t$H%t%H&t&]PN!R 4t(R t)R t*^t+],]-]-3,t.]/]0]-] 3,,t1R R lt2RRlt3RRlt4RRlt5RRlt6!RR4t7!RR4t8R.t9R#)uService-level orchestration for LSP clients. :class:`LSPService` bridges the synchronous file_operations layer and the async :class:`agent.lsp.client.LSPClient`: one asyncio loop in a background thread, one lazily spawned client per ``(server_id, workspace_root)`` — servers flagged ``multi_root`` (pyright) get ONE client per ``server_id`` and further roots (typically sibling git worktrees) are attached to the running process via ``workspace/didChangeWorkspaceFolders`` — a **broken-set** of pairs that failed to spawn/initialize (retried only after ``lsp.broken_retry_seconds``; never, by default), and a **delta baseline** per file (``snapshot_baseline()`` runs BEFORE a write; the next ``get_diagnostics_sync()`` returns only diagnostics not in it). Off unless config enables it. ) annotationsN)AnyCallableDictListOptionalTuple)eventlog)DIAGNOSTICS_DOCUMENT_WAIT LSPClient_diagnostic_key) EditChecks)SERVERSUNTRUSTED_SAFE_SERVERS ServerContext ServerDefcustom_serversfind_server_for_filelanguage_id_for) clear_cacheis_trusted_workspaceoperator_workspace_rootsresolve_workspace_for_filezagent.lsp.manageriXc$V^8dQhRRRRRR/#)valuerdefaultfloatreturn)formats"6/home/ubuntu/.hermes/hermes-agent/agent/lsp/manager.py __annotate__r#)s!S5UcXVe \V4#T# \\3dTu#i;iN)r TypeError ValueError)rrs&&r" _float_orr))s4$0uU|=g= z "s))c V^8dQhRRRR/#rrrrOptional[list[str]]r )r!s"r"r#r#0s77c717r$c,Vf.#\V\4'd;\;QJdRV4F 'dK RM RM !RV44'gR#VUu.uF+q'gK \PP V4NK- up#uupi)zYA config list of paths, ``~``-expanded; ``None`` when the value is not a list of strings.Nc3B"TFp\V\4xK R#5ir&) isinstancestr).0ps& r" _path_list..4s-P%QjC.@.@%sFT)r/listallospath expanduser)rr2s& r" _path_listr:0sh } eT " "##-P%-P###-P%-P*P*P+0 65aA !BGG  q !5 66 6s  B+#Bc V^8dQhRRRR/#r+r )r!s"r"r#r#9s(;r$c\V4;pf4\PPR\ V4P 4V#)zY``lsp.exclude_roots``; ``None`` (fail closed: every root excluded) for a malformed value.zlsp.exclude_roots must be a list of glob patterns, e.g. ['~/big-monorepo', '/srv/*/vendor'] (got %s); LSP is skipped for every workspace until the key is fixedr:r event_logwarningtype__name__rrootss& r"_parse_exclude_rootsrD9sCE""+"" RSWX]S^SgSg i Lr$c V^8dQhRRRR/#)rrrrz list[str]r )r!s"r"r#r#BsCIr$c\V4;pf4\PPR\ V4P 4T;'g.#)zC``lsp.trusted_workspaces``; a malformed value trusts nothing extra.zlsp.trusted_workspaces must be a list of directories, e.g. ['~/code/my-app'] (got %s); only the workspaces you launched Hermes or opened a session in are trusted until the key is fixedr=rBs& r"parse_trusted_workspacesrGBsGE""+"" g K  " ;;Br$c(V^8dQhRRRRRRRR/#) rsrvrrootr0trustedboolr_Keyr )r!s"r"r#r#Ls.GGYGcGDGTGr$cXVPVP'd V'dR3#T3#)aCache key for the client serving ``root``: multi-root servers share one process per ``server_id`` across trusted roots; everything else, untrusted roots included, is keyed per resolved project root (a shared process keeps the trust its first root spawned it with).) server_id multi_root)rIrJrKs&&&r" _client_keyrRLs% MMG2 FF FFr$c^]tRt^StRtRRltRRltRRltRR /R R lltR R lt Rt R #)_BackgroundLoopzKA daemon thread owning one asyncio loop; :meth:`run` blocks on a coroutine.cV^8dQhRR/#rrNoner )r!s"r"r#_BackgroundLoop.__annotate__Vs(($(r$c VRVnRVn\P!4VnR#r&)_loop_thread threadingEvent_readyselfs&r"__init___BackgroundLoop.__init__Vs:> 37 oo' r$cV^8dQhRR/#rVr )r!s"r"r#rX[s&&t&r$c VPeR#\P!VPRRR7VnVPP 4VP P RR7R#)Nzhermes-lsp-loopT)targetnamedaemong@timeout)r[r\Thread _run_foreverstartr^waitr_s&r"rl_BackgroundLoop.start[sR << #  ''t/@/@GXaef   %r$cV^8dQhRR/#rVr )r!s"r"r#rXbs  d r$c R\P!4;qn\P!V4VPP 4VP 4VP4R# \dR#i;i TP4i \dii;i;ir&) asyncionew_event_looprZset_event_loopr^set run_foreverclose Exception)r`loops& r"rk_BackgroundLoop._run_foreverbs#2244zt$              sB BA00 A?>A?B&BB& B# B&"B##B&riNc V^8dQhRRRR/#)rriOptional[float]rrr )r!s"r"r#rXns  O s r$c @^RIHpVPf8\P!V4'dVP 4\ R4hV!WP4;pf \ R4hVPVR7# \dTP4hi;i)zCSubmit a coroutine to the loop and block for its result (or raise).)safe_schedule_threadsafezbackground loop not startedzbackground loop not runningrh) agent.async_utilsr}rZrq iscoroutinerv RuntimeErrorresultrwcancel)r`cororir}futs&&$ r"run_BackgroundLoop.runns> :: ""4(( <= =+D**= =C F<= = ::g:. .  JJL  s .BBcV^8dQhRR/#rVr )r!s"r"r#rX}s % %d %r$c VPRuqnVPRuq nVfR#VPVP4VeVP RR7R#R# \dL'i;i)N@rh)rZr[call_soon_threadsafestoprjoin)r`rxthreads& r"r_BackgroundLoop.stop}sp::tj#||T <    % %dii 0   KKK $    sA## A10A1)rZr^r[) rA __module__ __qualname____firstlineno____doc__rarlrkrr__static_attributes__r r$r"rTrTSs*U( &  d  % %r$rTcj]tRt^tRtRRRRRRRRR]RRR R R R R RR R/ RRllt]RRl4tRRlt RRlt RRlt RRlt RRlt RRltRRltR R!ltR"R#ltR$R%ltR&R'ltR(R)ltR*R+ltR,R-ltR.R/ltR0RR1RR2Ri/R3R4lltR5R6ltR7R8R9RR:R/R;R<lltR=R>ltR?R@ltRARBltRCRDltRERFltRGRHlt RjRIRJllt!RKRLRMR/RNROllt"RPRQlt#RRRSlt$]%RTRUl4t&RVRWlt'RXRYlt(RZR[lt)R\R]lt*R^R_lt+R`Ralt,RbRclt-RdRelt.RfRglt/Rht0R#)k LSPServicezbThe process-wide LSP service; use :func:`agent.lsp.get_service` rather than constructing directly.binary_overridesN env_overridesinit_overridesdisabled_servers idle_timeout extra_serversbroken_retry_secondswarmup_timeout exclude_rootstrusted_workspacescTV^8dQhRRRRRRRRRR R R R R RRRRRRRRRRRRRRRR/#)renabledrL wait_moder0 wait_timeoutrinstall_strategyrzOptional[dict[str, list[str]]]rz#Optional[dict[str, dict[str, str]]]rz#Optional[dict[str, dict[str, Any]]]rr,rrzOptional[list[ServerDef]]rrrrrrrWr )r!s"r"r#LSPService.__annotate__s2C2C2C+.2C>C2CWZ2C82C;2C< 2C . 2C  2C12C$2C2C2C 2C 2Cr$c WnVR9dTMRVnW0nW@nT;'g/VnT;'g/VnT;'g/Vn\T;'g.4VnWn \T ;'g.4Vn \RV 4Vn \RV 4Vn\V 4Vn\#V4Vn\4Vn\)\+44Vn\/4VnVP'dVP0P34/Vn/Vn/Vn/Vn\<P>!4Vn RVn!/Vn"\G4Vn$VP'dAVP^8d.VP0PKVPM4RR7R#R#R#)documentrNrrh>fullr)'_enabled _wait_mode _wait_timeout_install_strategy_binary_overrides_env_overrides_init_overridesrt_disabled_servers _idle_timeoutr5_extra_serversmax _broken_retry_warmup_timeoutrD_exclude_rootsrG_trusted_workspaces_untrusted_skipped frozensetr_operator_rootsrTrZrl_clients_broken _spawning _last_usedr\Lock _state_lock_idle_reaper_task_delta_baseliner _edit_checksr_start_idle_reaper)r`rrrrrrrrrrrrrrs&$$$$$$$$$$$$$$r"raLSPService.__init__s '04H'H)j)!1!1!7!7R+11r-33!$%5%;%;!<)/3M4G4GR/H &:;"374H 3V.FGY.Z '*u()A)CD$& === JJ   02 *, 57-/$>>+9=24&L ===T//!3 JJNN4224cN B4=r$cV^8dQhRR/#)rrzOptional[LSPService]r )r!s"r"r#rs& & #7& r$c B^RIHpV!4p\ T\ 4'dTPR4MRp\ T\ 4'dTM/p\TPR\44p^Tu;8d \8d MM\pTPR4;'g/p\ T\ 4'd=TP4UUu/uFwrx\ T\ 4'gKYxbK! uppM/p T!\TPRR44TPR R 4\TPR \44TPR R 4T P4UUu/uFFwrx\ TPR4\ 4'gK,TR,'gK=YxR,bKH uppT P4UUU U u/uFawrx\ TPR4\ 4'gK,YxR,P4U U u/uFwrT \#T 4bK up p bKc up p ppT P4UUu/uF5wrx\ TPR4\ 4'gK,YxR,bK7 uppT P4UUu.uF wrxTPR4'gKTNK" uppT\%T 4\'TPR4R4\'TPR4R4TPR4TPR4R7# \d"p\P RT4Rp?R#Rp?ii;i \\3d \pELi;iuuppiuuppiuup p iuup p ppiuuppiuuppi)zJBuild a service from ``hermes_cli.config``; ``None`` if config can't load.)load_config_readonlyzLSP config load failed: %sNlsprserversrTrrrrautocommandenvinitialization_optionsdisabledrrrrr)rrrrrrrrrrrrrr)hermes_cli.configrrwloggerdebugr/dictgetrDEFAULT_IDLE_TIMEOUTr'r(MIN_IDLE_TIMEOUTitemsrLr r5r0rr)) clsrcfgelsp_cfgr servers_cfgncrkvs & r"create_from_configLSPService.create_from_configs  >&(C%/sD$9$9#''%.t'66'B 0 ^=Q!RSL | .. .,Lkk),22 S]^ikoSpSpK$5$5$7O$7DA:a;N414$7OvxY56kk+z:w{{>;TUV$[[);VD:A--/V/$!!+AEE),Sb41(ut<G1uX^^5EF5ETQq#a&y5EFFSb>GN}}Rtq)!%%0H*I4P;A!9::R,3MMOQODAquuZ?PaaOQ%(1!*7;;7M+NPS!T$W[[1A%BCH!++o6&{{+?@#    LL5q 9 :& 0/L 0P VF>RQs} L.MM;1M;,)N N+ N)N >N N"/N )N= N NN. M9MMM87M8N c V^8dQhRRRR/#)r file_pathr0rzOptional[ServerDef]r )r!s"r"r#rs88S8-@8r$c ~VP'd\WP4MRpT;'g \V4#)zcConfig-declared servers first (they may claim an extension ahead of a built-in), then the registry.N)rr)r`rextras&& r" _server_forLSPService._server_fors5HLH[H[H[$Y0C0CDae77,Y77r$c V^8dQhRRRR/#)rextr0rrLr )r!s"r"r#rsZZSZTZr$c a\;QJd1V3Rl.VPO\O4F 'gK R# R#!V3Rl.VPO\O44#)zZTrue iff a config-declared or built-in server claims ``ext`` (pre-write capture decision).c3^<"TF"pSP4VP9xK$ R#5ir&)lower extensions)r1srs& r"r3/LSPService.handles_extension..s"Y8X1399;!,,.8Xs*-TF)anyrr)r`rs&fr"handles_extensionLSPService.handles_extensionsPsY8X$:M:M8XPW8XYssYsYsY8X$:M:M8XPW8XYYYr$cV^8dQhRR/#)rrrLr )r!s"r"r#rs4r$c VP#)z8Return True iff this service should be consulted at all.)rr_s&r" is_activeLSPService.is_actives }}r$c$V^8dQhRRRRRR/#)rrIrrr0rzOptional[_Key]r )r!s"r"r#rs! , ,y ,S ,^ ,r$c \V4wr4V'd V'gR#VPVPW#4;'gT3# \dTPT3u#i;i)u``(server_id, per-server root)`` broken-set key, or ``None`` when the file isn't gated in. Falls back to the workspace root when the per-server resolver fails — the same key ``_get_or_spawn`` would have used when it failed. N)rrP resolve_rootrw)r`rIrws_rootgateds&&& r" _broken_keyLSPService._broken_keys] 4I>E ,MM3#3#3I#G#R#R7S S ,MM7+ + ,s"AAA$#A$c V^8dQhRRRR/#)rrr0rrLr )r!s"r"r#rsSTr$c  VP'dVPV4MRpVeVPVP9dR#VP W!4pVfR#VP V^,4'd9\ P!VPV^,WPRJR7R#VP4VPW#^,WPV^,44'dR#VPV4'd<\ P!VPV^,WPV4R7R#R#)zTrue iff LSP should run for this file: registered non-disabled server, git workspace, and pair not broken (a failed server costs nothing until ``hermes lsp restart`` / exit).NF)invalid)retry_inT)rrrPrr_root_excludedr log_root_excludedr_note_operator_roots_untrusted_denied_trusted _is_brokenlog_skipped_broken_broken_retry_in)r`rrIkeys&& r" enabled_forLSPService.enabled_fors.2]]]dy) ;#--4+A+AAs. ;   s1v & &  & &s}}c!fiQdQdhlQl m !!#  ! !#1vy--A:O P P ??3    ' ' s1vyShShilSm nr$cV^8dQhRR/#rVr )r!s"r"r#rsDDdDr$c \4;qP8:g8VP;_uu_4VPV,VnRRR4R#R# +'giR#;i)zRemember this thread's ``operator_workspace_roots``. Called where a tool thread enters (it sees the session's cwd; the loop thread that spawns servers does not), so trust is per process: a workspace any session was opened in stays trusted until shutdown.N)rrr)r`rCs& r"rLSPService._note_operator_rootssO2338L8LL!!!'+';';e'C$"!M!!!s A A% c V^8dQhRRRR/#rrJr0rrLr )r!s"r"r#r#sZZSZTZr$c B\WPVP4#r&)rrrr`rJs&&r"rLSPService._trusted#s#D*B*BDDXDXYYr$c$V^8dQhRRRRRR/#)rrIrrJr0rrMr )r!s"r"r#r&s&uuYucudur$c VPV3pW0P9gW0P9dV#\WVP V44#)zThe client key for ``root`` (under ``_state_lock``): a multi-root server started while ``root`` was untrusted keeps its own client after ``root`` becomes trusted, so it is found and released rather than orphaned.)rPrrrRr)r`rIrJowns&&& r" _live_keyLSPService._live_key&sD}}d#]]*c^^.CstUX`d`m`mnr`sIttr$c ,V^8dQhRRRRRRRRRR/#) rrIrrJr0rrKrLrr )r!s"r"r#r-s1YccTX]ar$c 4V'gVP\9dR#VP;_uu_4VPP VPV34RRR4\ P !VPW#4R# +'giL3;i)zTrue iff ``srv`` may run project code and ``root`` is not a trusted workspace (deny by default: only ``UNTRUSTED_SAFE_SERVERS`` start in a checkout the operator has not trusted).FNT)rPrrraddr log_untrusted_skipped)r`rIrJrrKs&&&&&r"rLSPService._untrusted_denied-sd cmm'==      # # ' '(= >&&s}}dF s (B B c V^8dQhRRRR/#rr )r!s"r"r#r7s333343r$c aVPfR#\;QJd)V3RlVP4F 'gK R# R#!V3RlVP44#)zVTrue iff ``root`` matches an ``lsp.exclude_roots`` glob (or the key is misconfigured).Tc3<"TFtp\P!SV4;'gQ\P!SVP\P4\P,R,4xKv R#5i)*N)fnmatch fnmatchcaserstripr7sep)r1patrJs& r"r3,LSPService._root_excluded..;s_31s&&tS1qqW5H5HszzZ\Z`Z`OadfdjdjOjmpOp5qq1s "A?AA?F)rrrs&fr"rLSPService._root_excluded7sY    &s3"113ss 3s 3s3"1133 3r$c V^8dQhRRRR/#)rr rMrrLr )r!s"r"r#r>sdtr$c VPPV4pVfR#\P!4V8dVPP VR4R#R#)zeBroken-set membership; an entry whose retry deadline passed is dropped so the pair gets one more try.NFT)rrtime monotonicpopr`r deadlines&& r"r LSPService._is_broken>sH<<##C(   >> x ' LL  S$ 'r$c V^8dQhRRRR/#)rr rMrr{r )r!s"r"r#rHsWWDW_Wr$c VPPV\P4p\P!V4'dR#\ RV\ P!4, 4#)Nr)rrmathinfisinfrr.r/r1s&& r"r LSPService._broken_retry_inHsH<<##C2zz(++tVS(T^^EU:U1VVr$c V^8dQhRRRR/#)rr rMrrWr )r!s"r"r#rLsjjjjr$c VP^8d'\P!4VP,M\PVP V&R#)N)rr.r/r6r7r)r`r s&&r" _mark_brokenLSPService._mark_brokenLs9EIEWEWZ[E[DNN,t/A/AAaeaiai Sr$c V^8dQhRRRR/#)rrr0rrr )r!s"r"r#rOs h hc he hr$c  VPVP8:d VP#VPV4pVeVPW!4MRpVf VP#VP;_uu_4VP P VPW#^,44pRRR4XeVP'd VP#VP# +'giL>;i)z``wait_timeout`` for a root with a running client; ``max(wait_timeout, warmup_timeout)`` for a cold root, whose first request also pays the spawn/initialize and the server's initial program build.N) rrrrrrrr is_running)r`rrIr clients&& r" _wait_budgetLSPService._wait_budgetOs   4#5#5 5%% %y)25/ds.t ;%% %    ]]&&t~~cq6'BCF%+%7F M  & &y 4E sAB11 C/<)C**C/ post_textownercarryc ,V^8dQhRRRRRRRRRR/#) rrr0pre_textz Optional[str]rPrQrRtupler )r!s"r"r#rms2 - -# -M -Vc - - -=B -r$c  jVPV4'gR#^RIHpVPWW#VVR7#)aNon-blocking post-write check (``agent.lsp.edit_check``): a Future of the diagnostics the edit introduced, or None when LSP doesn't handle the file. Replaces snapshot_baseline + get_diagnostics_sync on the write path, which blocked the write on both waits. ``owner`` = the editing session; ``carry`` = its undelivered notes for the file this check takes over. ``pre_text`` / ``post_text`` = the edit's own before/after content: the check diagnoses these snapshots, never whatever another session has written to the file since.N) edit_check)rTrPrQrR)r  agent.lsprWrl)r`rrTrPrQrRrWs&&$$$$ r"start_edit_checkLSPService.start_edit_checkms= **((_d&+ - -r$c$V^8dQhRRRRRR/#)rabs_pathr0rM_DiagsrrWr )r!s"r"r#r{s&KKCKK4Kr$c PVP;_uu_4VPPVR4W PV&\VP4\8d,VP\ \ VP44KIRRR4R# +'giR#;i)zStore a baseline, refreshing recency (pop + reinsert) so eviction tracks write order. Callers run on arbitrary threads; the multi-step mutation needs the lock (callers don't hold it).N)rrr0len_DELTA_BASELINE_CAPnextiter)r`r\rMs&&&r"rILSPService._set_delta_baseline{s{     $ $Xt 4-2  *d**+.AA((d43G3G.H)IJB   s A4B B% deltaTri line_shiftc ,V^8dQhRRRRRRRRR R /#) rrr0rdrLrir{re(Optional[Callable[[int], Optional[int]]]rr]r )r!s"r"r#rs6'''(,'>M'<' 'r$c DVPV4'g.#VPV4PpVPV4pVeTMVR,pVPP VP WR7VR7pTf\P!YQRR7.#T'dTP#YT4pT'd#\P$!YQ\'T44T#\P(!YQ4T# \dp \T \P4'd.\P!YQ4\PRY4M-\P!YQT 4\PRY4TP!Y4.uRp ? #Rp ? ii;i) aSynchronously open ``file_path``, wait for diagnostics, return them. Never raises. With ``delta`` (default) the result excludes the :meth:`snapshot_baseline`; ``line_shift`` (from :func:`agent.lsp.range_shift.build_line_shift`) remaps that baseline into post-edit coordinates first, so pre-existing diagnostics that merely moved don't look introduced by this edit. ``[]`` when LSP is disabled, nothing matches, or the server can't be spawned. Nr)rKrhz"LSP diagnostics timeout for %s: %sz'LSP diagnostics fetch failed for %s: %szfresh diagnostics)kind)r rrPrCrZr_open_and_wait_asyncrwr/rq TimeoutErrorr log_timeoutrrlog_server_errorrH _apply_deltalog_diagnosticsr_ log_clean) r`rrdrirerPrKrLrMrs &&$$$ r"get_diagnostics_syncLSPService.get_diagnostics_syncsU **I$$Y/99  &&y1F".FSLAJJNN4#<#>#1v.D]]&&tT2F OO  d +  % %c!fc!fc :  s %AC.. C> c$V^8dQhRRRRRR/#rrr0rrrrWr )r!s"r"r#rs!s4r$c VPW4pVe/VPPVP4RR7R#R# \dR#i;i)zUTool-thread bridge of :meth:`_detach_broken`: shuts the client down through the loop.N?rh)rrZrshutdownrwr`rrrBs&&& r"rH LSPService._mark_broken_for_filesQ$$Y4    v0#>   s+A AAc$V^8dQhRRRRRR/#rr )r!s"r"r#rs'TT3T]TW[Tr$c "VPW4pVe2\P!VP4RR7GRjxL R#R#L \d\ P RRR7R#i;i5i)z`Loop-side :meth:`_detach_broken` (``_mark_broken_for_file`` would block on the loop it runs on).Nrrhz$shutdown of broken LSP client failedT)exc_info)rrqwait_forrrwrrrs&&& r"_mark_broken_for_file_async&LSPService._mark_broken_for_file_asyncsg$$Y4   T&&v'8#FFF F T Cd S Ts:A6)A A A A6 A "A3/A62A33A6cV^8dQhRR/#rVr )r!s"r"r#rs  $ r$c *VP'gR#VPPVP4RR7VPP4\4R# \d!p\ P RT4Rp?LLRp?ii;i)z3Tear down all clients and stop the background loop.N$@rhzLSP shutdown error: %s) rrZr_shutdown_asyncrwrrrr)r`rs& r"rLSPService.shutdownsi}}}  6 JJNN4//14N @   6 LL11 5 5 6s+A'' B2B  BcV^8dQhRR/#)rrzdict[str, Any]r )r!s"r"r#rs  N r$c daSP;_uu_4SPP4Uu.uFJpRVPRVPR\ VP 4RVPRVP/NKL ppSPP4UUu.uF#wr4\P!4V8gK!VNK% ppp\V3RlSP44pRRR4RSPR SP R SP"R SP$R XR XR\SP&4RSP(RSP*RSP,e\ SP,4MRR\ SP.4RX/ #uupiuuppi +'giL;i)z;Return a snapshot of the service for ``hermes lsp status``.rPworkspace_rootworkspace_foldersstaterunningc3h<"TF'pSPV^,4'dK#VxK) R#5i)N)r)r1pairr`s& r"r3(LSPService.get_status..s'f0Gt}}]abc]dOett0Gs 2 2NrrrrclientsbrokenrrrrINVALIDruntrusted_skipped)rrvaluesrPrr5rrrArrr.r/sortedrrrrrrrrrr)r`rrr r2r untrustedsf r" get_statusLSPService.get_statussx    --/0Aakk+;Q=M=M$d1+>+>&?!''S\^_^j^jl/  04||/A/A/Cc/Cmct~~GWZbGbcc/CFcf0G0GffI t}}k4??NTXTfTf  6 6 7HV\ t'='= > "D$6$68H$J^J^ $:M:M:YT$"5"56_h $t'?'?"@BUW`    d  s/FAFF"F F "F F F/ c$V^8dQhRRRRRR/#)rrr0rKr{rr]r )r!s"r"r#r s'^^s^O^W]^r$c Z"VPVRVR7GRjxL ;'g.#L5i)T)snapshotrKN)rj)r`rrKs&&&r"rGLSPService._snapshot_async s/..y4PV.WW]][]]Ws+) ++rFrKc(V^8dQhRRRRRRRR/#) rrr0rrLrKr{rzOptional[_Diags]r )r!s"r"r#rs2[[[+/[AP[ [r$c |"VPV4GRjxL pVfR#VPV4pVPV\W4R7GRjxL pV'gVP V4GRjxL TP YVP VeTM VPR7GRjxL pTPT4T'd\TPTRR74#R#LLLuLA \dApT'd\PRT4M\PRY4Rp?R#Rp?ii;i5i)aQOpen + wait for FRESH diagnostics: ``[]`` = checked clean, ``None`` = no verdict in budget. Callers must not substitute stale data for either. ``snapshot`` mode (pre-write baseline) skips didSave; both modes wait at most ``budget`` (``lsp.wait_timeout`` unless the caller computed a cold-root warm-up budget via :meth:`_wait_budget`). N) language_id)moderizsnapshot open/wait failed: %szopen/wait failed for %s: %sT fresh_only) _get_or_spawnr open_filer save_filewait_for_diagnosticsrrrwrr_touchr5diagnostics_for) r`rrrKrBrIversionr|rs &&$$ r"rjLSPService._open_and_wait_asyncs)))44 > ""9-C",,YOT]Dc,ddG&&y111 55"("4$:L:L6E FKPtF**9*FGZVZZ'5 e1  E  ( ( B 3 <  ! !#-->--c2 D(5<5M5M5O5]5]5__H~~c2      t 4**3== =  '~~h77BHAS**3== ]Y] ] "--cAAF~!!3==$"78%%%)/MM#&+/99;DOOC(&##CMM48    '!!!""3-"==??!#W   > 8)) %%''  =A&%%"!!!!""3-"!!!==??!#sA3S6B'SS4A'OA O(1OASO S)OOOS P!S(Q =P">:Q 81P%);Q $S8P9S3S O  SO*P S PPSPS"Q % P6 0 Q 9 Q S S!R > S R S0SSc(V^8dQhRRRRRRRR/#)rrIrrBr rJr0rr )r!s"r"r#r|s( 9CIr$c h"VP'dVPV4GRjxL V#L5i)zXMulti-root servers: announce ``root`` to the shared process instead of spawning another.N)rQadd_workspace_folder)rIrBrJs&&&r"rLSPService._attach_root{s. >>>--d3 3 3  4s '202c(V^8dQhRRRRRRRR/#) rrIrrJr0rKrLrrr )r!s"r"r#rs)ydObr$c "\W PVPVPVPVR7pVP W$4pVf.\ P!VPVP4R#\VPVPVPVPVPVPVP;'g VP R7pVP#4GRjxL V#L \$d-p\ P&!TPY'4Rp?R#Rp?ii;i5i)zRResolve the binary and start a client; ``None`` (after logging) when either fails.)rrrrrrKN)rPrrrcwdrseed_diagnostics_on_first_push)rrrrr build_spawnr log_server_unavailablerPr rrrrrrseed_first_pushrlrwr)r`rIrJrKctxspecrBrs&&&& r"rLSPService._spawn_clients2H2H[_[q[q--d>R>R  t) <  + +CMM3== ImmD4G4GQUQ]Q]cgckck1L1L+/+N+N+e+eRUReRe   ,,.  !   % %cmmT = sHCEE*D=D>DED D=!D82E8D==Ec V^8dQhRRRR/#)rrBr rrWr )r!s"r"r#rs77Y747r$c VP;_uu_4VPP4F.wr#W1JgK \P!4VPV&K0 RRR4R# +'giR#;i)zdRefresh last-used; guarded on membership so a client reaped mid-operation can't resurrect its entry.N)rrrr.r)r`rBr rs&& r"rLSPService._touchsO    ----/;+/99;DOOC(0   s"A,&A,, A= cV^8dQhRR/#rVr )r!s"r"r#rsOO$Or$c `"\P!VP44VnR#5ir&)rq create_task_idle_reaper_looprr_s&r"rLSPService._start_idle_reapers!!(!4!4T5K5K5M!Ns,.cV^8dQhRR/#rVr )r!s"r"r#rs C C Cr$c :"\RVP4p\P!V4GRjxL VP 4GRjxL K:LL \P dh\ d"p\PRT4Rp?KzRp?ii;i5i)gN@NzLSP idle reaper sweep error: %s) minrrqsleep_reap_idle_oncerrwrr)r`intervalrs& r"rLSPService._idle_reaper_loopstT//0--) ) ) C**,,, *,))  C >BB CsP1BABA A ABAB6B7B BBBcV^8dQhRR/#rVr )r!s"r"r#rs l lt lr$c "\P!4VP, pVP;_uu_4VPUu.uF'q PP V^4V8gK%VNK) ppVUu.uFq PP V4NK ppVFpVPP VR4K! RRR4X'dl\P!VUu.uFqUPVP3NK upVP4\P!RV4RR/GRjxL VPRRR7GRjxL R#uupiuupi +'giL;iuupiLDL*5i)r<Nc3@"TFqP4xK R#5ir&rr1rBs& r"r3-LSPService._reap_idle_once.."K7??#4#47return_exceptionsTcJ\PPV4'*#r&)r7r8isdir)folders&r",LSPService._reap_idle_once..sBGGMM&4I0Ir$zworkspace root deletedreason)r.rrrrrr0r log_reapedrPrrqgather _detach_roots)r`cutoffr  idle_keysrrs& r"rLSPService._reap_idle_onces0t111    (, ^ 9L9LSRS9TW]9] I^9BC#}}((-GC ##C.!    ' R'Q++q/?/?!@' RTXTfTf g.."K7"Kd_cd d d  !IRj kkk_C  !S d lsp;FE, "E"3E"9E,?#E'"'E, FF- E? 2F?FFFF" E,, E< 7FFc V^8dQhRRRR/#)rrr0rintr )r!s"r"r#rsr$c VP'g^#\PPV4pVPP VP V4RR7# \d"p\PRY#4Rp?^#Rp?ii;i)uShut down the clients serving ``workspace_root`` or any root beneath it; returns how many. Called by the worktree cleanup paths BEFORE ``git worktree remove`` so a gateway that outlives the session does not keep the language server (and its stdio pipes) alive for a tree that no longer exists. Multi-root servers only drop the folder. Idempotent; best-effort — never blocks removal. g.@rhzLSP release of %s failed: %sN) rr7r8rJrZr_release_asyncrwrr)r`rrJrs&& r"release_workspaceLSPService.release_workspacesk}}}ww~. ::>>$"5"5d";T>J J  LL7 A s+A!! B ,BB c V^8dQhRRRR/#)rrJr0rrr )r!s"r"r#rsr$c a"RV3RllpVP;_uu_4VPP4Uu.uFq3P4'dKVNK ppVPP 4UUu/uFwrVV!V^,4'dKWVbK uppVnVP Uu.uFqr!V4'gKVNK upFpVP VK RRR4X'd!\P!VRR7GRjxL VPVRR7GRjxL p \4V #uupiuuppiuupi +'giLo;iLNL55i)c V^8dQhRRRR/#)rr8r0rrLr )r!s"r"r#/LSPService._release_async..__annotate__s B B B Br$cj<VS8H;'g'VPS\P,4#r&) startswithr7r()r8rJs&r"_under)LSPService._release_async.._unders&4<AA4??4"&&=#A Ar$Nrrhzworkspace releasedr) rrrrrrrrqrmrr) r`rJrrpendingr r2r2r8releaseds &f r"r LSPService._release_asyncs B B    &*nn&;&;&=P&=sXXZss&=GP?C||?Q?Q?Sj?Smc[abefgbh[iMCM?SjDL$($8$8F$8qF1I$8F((.G ,,w5 5 5++F;O+PP QjF  6Ps{E)EEE E?E E #E:E E E+E);E)E%E)1E'2E)E E"  E)'E)c$V^8dQhRRRRRR/#)ris_gonezCallable[[str], bool]rr0rrr )r!s"r"r#rs#+@SUXr$c 6"VP;_uu_4VPP4UUu.uF-wr4\\ WP 44'gK+VNK/ pppVUu.uFq0PP V4NK ppVFpVPP VR4K! VPP4UUu.uF/qDVP Uu.uFqq!V4'gKVNK up3NK1 pppRRR4XF(wrV Fp V PV 4GRjxL K K* X'db\P!VUu.uFqDPVP 3NK upV4\"P$!RV4RR/GRjxL \'V4#uuppiuupiuupiuuppi +'giL;iL \d"p \PRY4Rp ? KRp ? ii;iuupiLn5i)a!Shared teardown primitive for :meth:`release_workspace` and the reaper. Clients whose every workspace folder ``is_gone`` are detached under ``_state_lock`` and shut down; multi-root clients that still serve other folders only drop the gone ones. Returns the number of clients shut down. Nz$LSP folder removal for %s failed: %sc3@"TFqP4xK R#5ir&rrs& r"r3+LSPService._detach_roots..rrrT)rrrr6maprr0rrremove_workspace_folderrwrrr log_releasedrPrrqrr_) r`rrr r dead_keysrftrimsrBfoldersrrs &&$ r"rLSPService._detach_rootss   +/==+>+>+@k+@CGUhUhHiDj+@Ik9BC#}}((-GC ##C.!RVR_R_RfRfRhiRhQQ%8%8G%8GAJ!!%8GHRhEi  %OF!T 88@@@" %   ! !G"TGqKK1A1A#BG"TV\ ].."K7"Kd_cd d d7|lCHi  A TLL!GSST#U dsHG(F8 "F8 (G/#F>AGG )G=GG GH#G#7G!8G#<H H H(H(H)H8 GG G G H!G## H.H H H HcV^8dQhRR/#rVr )r!s"r"r#rs W Wt Wr$c 0"VP;pe8RVnVP4\P!VRR7GRjxL VP;_uu_4\ VP P44pVP P4VPP4VPP4RRR4\P!RX4RR/GRjxL R#L +'giL9;iL5i)NT)rc3@"TFqP4xK R#5ir&r)r1rs& r"r3-LSPService._shutdown_async..s=Wzz||Wrr) rrrqrrr5rrclearrr)r`reaperrs& r"rLSPService._shutdown_asyncs,, ,F 9%)D " MMO..4@ @ @    4==//12G MM   ! LL   OO ! ! #  nn=W=VQUVVV A   Ws7ADC?DA2D(D8D9D D D)rrrrrrrrrrrrrrrrrZrrrrrrrrr r&)1rArrrrrra classmethodrrrrrr rrrrrr r r=rCrNrYrIrqrnrrHrrrrGrjrxr staticmethodrrrrrrr r rrrr r$r"rrsl2C;?2C>B2C?C 2C 15 2C 3 2C482C'*2C!$2C"2C#'2Ch& & P8 Z  ,(DZu3Wj hJ" -fj -04 -EG -K'/3'PT'?C'R(*T  *^ [27[SW[< Z?"B 07O C l "0 W Wr$r):r __future__rrqr%loggingr6r7r\r.typingrrrrrrrXr agent.lsp.clientr r r rwagent.lsp.edit_checkr agent.lsp.serversrrrrrrragent.lsp.workspacerrrr getLoggerrrr`rrUr0rMr5rr]r)r:rDrGrRrTr__all__r r$r"r6s #  ==__+xw   . / S#X d38n 7G4%4%nw Ww Wt .r$