yj JdZddlmZddlmZddlmZmZdd ZddZ ddZ dS)zAFail-closed URL identity normalization for model/provider routes.) annotations)Any)urlsplit urlunsplitbase_urlrreturnstrct|pd}|sdStd|Dr|Sd|dddv} t|}|j}|jr|s|S|j}d|vr3|dd\}}|d|}n|}|j} n#ttf$r|cYSwxYw|j ddd } | d sd |vrd |d }| || fdvr|d | }d|j vr&|j dddd|}|j } | dr |s | d d } t||| |jdf} |r |js| dz } | S)zz+normalize_route_base_url..s- - -3t99  - - - - - -?#r%@[:]N>httpPhttpsi/)r anysplitrhostnameschemelowerport TypeError ValueErrornetlocrsplit startswithpathendswithrquery) rrawhad_query_delimiterparsedr%r&addresszonehostr( route_hostr. normalizeds rnormalize_route_base_urlr9 s3 hn"  C r - - - - --- 3!2!21!55 #?} H J$$&& (??$NN322MGTmmoo....DD>>##D{ z " %%c1--b1JS!!SD[[4{{{ VTN2PPP fm-&&sA..q1::D:: ;D }}S"5CRCyVT4rBCCJ6<c s C1A+CC32C3configured_model active_modelconfigured_base_urlactive_base_urlconfigured_provideractive_providerboolct|pd}|r)|t|pdkrdS ddlm}|||||S#t$rYdSwxYw)zTrue when a configured ``model.context_length`` pin no longer matches its runtime route. Fail-closed: any error during route comparison returns ``True`` (drop the pin) so a stale window never silently inflates the compression threshold. r Tr)_context_route_mismatch)r stripagent.agent_initrB Exception)r:r;r<r=r>r?rBs rshould_clear_context_pinrF2s+1r2288::,L4FB0G0G0M0M0O0OOOt <<<<<<&&        ttsA$$ A21A2c ZKddl}|t||||||d{VS)uVAsync wrapper for ``should_clear_context_pin``. Offloads the route comparison to a worker thread so async gateway handlers never run it on the event loop — the resolution chain is cache-only (``allow_network=False``) but can still do cold-start disk I/O. Shares all logic with the sync version — no code duplication. rN)asyncio to_threadrF)r:r;r<r=r>r?rHs rshould_clear_context_pin_asyncrJOs\NNN""       rN)rrrr )r:rr;rr<rr=rr>rr?rrr@) __doc__ __future__rtypingr urllib.parserrr9rFrJrrrPsGG""""""--------&&&&R:r