yj UdZddlmZddlZddlZddlZddlmZddlm Z m Z m Z m Z m Z mZmZejeZdZdZejZejZdaded <d&dZd'dZd(dZe ddd)dZd*d Zeee dd!d+d"Z d,d-d%Z!dS).z9Background keepalive for long-lived Nous Portal sessions.) annotationsN)Optional)!ACCESS_TOKEN_REFRESH_SKEW_SECONDSNOUS_INVOKE_JWT_MIN_TTL_SECONDS AuthError_agent_key_is_usable _is_expiringget_provider_auth_state resolve_nous_runtime_credentialsi`T<Optional[threading.Thread]_keepalive_threadvalueOptional[float]returnfloatc|t|S ttjddS#ttf$rYdSwxYw)NHERMES_NOUS_TIMEOUT_SECONDS15g.@)rosgetenv TypeError ValueError)rs D/home/ragecks/.hermes/hermes-agent/hermes_cli/nous_auth_keepalive.py_timeout_secondsrs[ U||RYC  DC;;D stop_eventthreading.Eventinterval_secondsinitial_delay_secondsNonec|dkr||rdS|sstartr/r0rMs rstart_nous_auth_keepaliver[so1t !!  (->-G-G-I-I ($!!!!!!!! %,"!#$'(8$9$9),Q4I0J0J)K)K'*2s3F/G/G'H'H#2  &     !!! 2333 '!!!!!!!!!!!!!!!!!!s'DB>DDD@timeoutc2t5t}tdddn #1swxYwY|*|r||t5t|urdaddddS#1swxYwYdS)z@Stop the keepalive thread. Intended for graceful shutdown/tests.N)r])rTrrVsetrUjoin)r]threads rstop_nous_auth_keepaliverbs "foo// G $$$ %%  & & $ %%%%%%%%%%%%%%%%%%s!5993 B  BB)rrrr)rrrr)r&r'rr()r&r'r;rrr<) rDrErFr'rGr'r&r'r;rrrH) rFr'rGr'r&r'r;rrr )r\)r]rrrH)"__doc__ __future__rloggingrrXtypingrhermes_cli.authrrrrr r r getLogger__name__r/$NOUS_AUTH_KEEPALIVE_INTERVAL_SECONDS)NOUS_AUTH_KEEPALIVE_INITIAL_DELAY_SECONDSLockrTEventrVr__annotations__rr$r9rCrLr[rbr%rrps???""""""   8 $ $'2$,.) ).""!)/##044444))))\ ?'+      F*****A!J>'+ !!!!!!D % % % % % % %r%