File: //usr/libexec/kcare/python/kcarectl/ipv6_support.pyo
�
%��ic @ s d d l Z d d l Z d d l Z d d l Z d d l m Z m Z m Z m Z m Z m
Z
d d l m Z e
r� d d l m Z n d Z d Z d Z e j j e j d � Z d Z d e f d � � YZ e � Z d
� Z d � Z d � Z d � Z d � Z d S( i����Ni ( t configt constantst
http_utilst log_utilst serveridt utils( t json_loads_nstr( t Optionali i s ipv6_preference.jsoni i< t IPProtoSelectorc B s/ e Z d � Z e d � � Z e d � � Z RS( c C s� t j r t j d � t St j j d � s= t j d � t St j rW t j d � t St � } | d k r� t j d j | r� d n d � � | Sd } | j t j
� s� t j d � t } nJ | j t j � s� t j d � t } n" t j � r
t j d � t } n | d k r$t | � | S| j d t � } | j d t � } | t k rjt j d
� t } nl | t k r�t j d � t } nJ | t k r�t j d � t } n( | t k r�t j d
� t } n t } t | � | S( sk
Choose ipv6 if it is more suitable.
Checks order:
- check config values (it is faster) - eportal setup and FORCE_IPVx
- then check each proto availability using HEAD requests
- then check if we have server_id, it means we don't expect an ip license
- and finally we need to check if there is an ip license
s, decided to use ipv4 because of config valuess kernelcare.coms, decided to use ipv6 because of config valuess% decided to use {0} from on-disk cachet ipv6t ipv4s1 decided to use ipv4 because ipv6 is not availables1 decided to use ipv6 because ipv4 is not availables/ decided to use ipv4 because server id was founds2 decided to use ipv4 because ipv4 license was founds2 decided to use ipv6 because ipv6 license was founds8 decided to use ipv4 because ipv4 trial license was founds8 decided to use ipv6 because ipv6 trial license was foundN( R t
FORCE_IPV4R t logdebugt Falset PATCH_SERVERt endswitht
FORCE_IPV6t Truet _read_cachet Nonet formatt _is_url_reachablet PATCH_SERVER_IPV6R t get_serveridt _write_cachet _get_cln_licenset CLN_VALID_LICENSEt CLN_TRIAL_ACTIVE_LICENSE( t selft cachedt resultt ipv4_licenset ipv6_license( ( s2 /usr/libexec/kcare/python/kcarectl/ipv6_support.pyt is_ipv6_preferred sV
"
c C s| t j | d d d d �} y' t j | d d d t d d �t SWn3 t k
rw } t j d j | t
| � � � t SXd S(
Nt methodt HEADt auth_stringt timeouti
t retry_on_500t retry_counti s% error during HEAD request to {0}: {1}( R t http_requestR t urlopenR
R t ExceptionR R R t str( t urlt requestt e( ( s2 /usr/libexec/kcare/python/kcarectl/ipv6_support.pyR ` s c C s� | r t j n t j } | d } t j t j | d t �j � � } t j | � } | sl | j
d � r� t j j
d j | � � t Sy t | d � SWn t k
r� t SXd S( Ns /check.plainR& t codes Unexpected CLN response: {0}( R t REGISTRATION_URL_IPV6t REGISTRATION_URLR t nstrR R) R
t readt data_as_dictt getR t kcarelogt errorR t CLN_NO_LICENSEt intt
ValueError( R t base_urlR, t contentt info( ( s2 /usr/libexec/kcare/python/kcarectl/ipv6_support.pyR k s
$
( t __name__t
__module__R! t staticmethodR R ( ( ( s2 /usr/libexec/kcare/python/kcarectl/ipv6_support.pyR s A c C sm t j t � } | s d Sy t | � } Wn4 t t f k
r_ t j d j | � d t
�d SXt | t � s� t j d j | � d t
�d S| j
d � } t | t � s� t j d j | � d t
�d S| j
d � } t | t j � s� t | t � r t j d j | � d t
�d St j � t | � } | d k sL| t k rit j d j | t � � d S| S(
Ns+ ipv6 preference cache: malformed json {0!r}t print_msgs/ ipv6 preference cache: unexpected payload {0!r}t prefer_ipv6s3 ipv6 preference cache: unexpected prefer_ipv6 {0!r}t tss) ipv6 preference cache: malformed ts {0!r}i s; ipv6 preference cache: stale entry (age={0:.0f}s, ttl={1}s)( R t try_to_readt
CACHE_FILER R R: t TypeErrorR t logwarnR R
t
isinstancet dictR5 t boolt numberst Integralt timeR9 t CACHE_TTL_SECONDSR ( R< t dataRB t cached_tst age( ( s2 /usr/libexec/kcare/python/kcarectl/ipv6_support.pyR � s0 " c C s i | d 6t t j � � d 6} y# t j t t j | � d t �Wn5 t t f k
rz } t
j d j | � d t
�n Xd S( NRB RC t
ensure_dirs* failed to write ipv6 preference cache: {0}RA ( R9 RM R t atomic_writeRE t jsont dumpsR t OSErrort IOErrorR RG R R
( R RO R. ( ( s2 /usr/libexec/kcare/python/kcarectl/ipv6_support.pyR � s #c C s) y t j t � Wn t k
r$ n Xd S( s' Drop the on-disk ipv6 preference cache.N( t ost unlinkRE RV ( ( ( s2 /usr/libexec/kcare/python/kcarectl/ipv6_support.pyt clear_cache� s
c C s t j � r t j St j S( N( t ip_proto_selectorR! R R R ( ( ( s2 /usr/libexec/kcare/python/kcarectl/ipv6_support.pyt get_patch_server� s c C s t j � r t j St j S( N( R[ R! R R0 R1 ( ( ( s2 /usr/libexec/kcare/python/kcarectl/ipv6_support.pyt get_registration_url� s i� i�Q ( RT RK RX RM t R R R R R R t py23R R
t typingR R R R8 t patht joint PATCH_CACHERE RN t objectR R[ R R RZ R\ R] ( ( ( s2 /usr/libexec/kcare/python/kcarectl/ipv6_support.pyt <module> s& .b '