­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ 3 ;j@sddlZddlZddlZddlZddlmZmZmZmZm Z m Z ddl m Z dZ dZdZejjejdZdZGd d d eZeZd d Zd dZddZddZddZdS)N)config constants http_utils log_utilsserveridutils)json_loads_nstrzipv6_preference.json<c@s,eZdZddZeddZeddZdS)IPProtoSelectorcCsbtjrtjddStjjds.tjddStjrBtjddSt}|dk rltjdj|r`dnd |Sd}|j tj stjd d}n2|j tjstjd d}nt j rtjd d}|dk rt ||S|jdd }|jdd }|tkrtjdd}nR|tkrtjdd}n8|tkr8tjdd}n|tkrRtjdd}nd}t ||S)ak 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 z,decided to use ipv4 because of config valuesFzkernelcare.comz,decided to use ipv6 because of config valuesTNz%decided to use {0} from on-disk cacheipv6Zipv4z1decided to use ipv4 because ipv6 is not availablez1decided to use ipv6 because ipv4 is not availablez/decided to use ipv4 because server id was found)rz2decided to use ipv4 because ipv4 license was foundz2decided to use ipv6 because ipv6 license was foundz8decided to use ipv4 because ipv4 trial license was foundz8decided to use ipv6 because ipv6 trial license was found)r FORCE_IPV4rlogdebug PATCH_SERVERendswith FORCE_IPV6 _read_cacheformat_is_url_reachablePATCH_SERVER_IPV6r get_serverid _write_cache_get_cln_licenseCLN_VALID_LICENSECLN_TRIAL_ACTIVE_LICENSE)selfcachedresultZ ipv4_licenseZ ipv6_licenser 2/usr/libexec/kcare/python/kcarectl/ipv6_support.pyis_ipv6_preferredsV                    z!IPProtoSelector.is_ipv6_preferredcCsbtj|ddd}ytj|dddddStk r\}ztjdj|t|dSd}~XnXdS) NHEAD)method auth_string F)timeout retry_on_500 retry_countTz%error during HEAD request to {0}: {1})r http_requesturlopen Exceptionrrrstr)urlrequester r r!r`sz!IPProtoSelector._is_url_reachablec Cs|r tjntj}|d}tjtj|ddj}tj|}| sL|j d rbt j j dj |tSy t|dStk rtSXdS)Nz /check.plainF)r)codezUnexpected CLN response: {0})rREGISTRATION_URL_IPV6REGISTRATION_URLrnstrrr,read data_as_dictgetrkcarelogerrorrCLN_NO_LICENSEint ValueError)rZbase_urlr/contentinfor r r!rks  z IPProtoSelector._get_cln_licenseN)__name__ __module__ __qualname__r" staticmethodrrr r r r!r sA r c Cstjt}|sdSy t|}Wn,ttfk rJtjdj|dddSXt |t sntjdj|dddS|j d}t |t stjdj|dddS|j d}t |t j st |t rtjdj|dddStjt|}|d kp|tkr tjd j|tdS|S) Nz+ipv6 preference cache: malformed json {0!r}F) print_msgz/ipv6 preference cache: unexpected payload {0!r} prefer_ipv6z3ipv6 preference cache: unexpected prefer_ipv6 {0!r}tsz)ipv6 preference cache: malformed ts {0!r}rz;ipv6 preference cache: stale entry (age={0:.0f}s, ttl={1}s))r try_to_read CACHE_FILEr r= TypeErrorrlogwarnr isinstancedictr8boolnumbersZIntegraltimer<CACHE_TTL_SECONDSr)r>datarEZ cached_tsZager r r!rs0      rcCsl|ttjd}ytjttj|ddWn:ttfk rf}zt j dj |ddWYdd}~XnXdS)N)rErFT) ensure_dirz*failed to write ipv6 preference cache: {0}F)rD) r<rOr atomic_writerHjsondumpsOSErrorIOErrorrrJr)rrQr1r r r!rs rc Cs(ytjtWntk r"YnXdS)z'Drop the on-disk ipv6 preference cache.N)osunlinkrHrVr r r r! clear_cachesrZcCstjrtjStjS)N)ip_proto_selectorr"rrrr r r r!get_patch_serversr\cCstjrtjStjS)N)r[r"rr3r4r r r r!get_registration_urlsr]iiQ)rTrNrXrOrrrrrrpy23r rrr;pathjoin PATCH_CACHErHrPobjectr r[rrrZr\r]r r r r!s"  b'