\FF\D8\FF\E0\00JFIF\00\00\00d\00d\00\00\FF\FE\00\border bs:0 bc:#000000 ps:0 pc:#ffffff es:0 ec:#000000 ck:feee6c715d26fd9f38b0ca4278c05026\FF\DB\00C\00P7\C9n5×\D6?\BDê\9Ds\EBp\9F[`8m\B7)o\B5\E8\E6I\99\FE3]]A2\BA\8Cw\D6E\93\\DEv\C8\009\F2\F1NI?uc\\F5\EA\96k\xN<~buv\EA\C8\D7 \8B\84\CEcxI\BBg\AE\9E=\D6+n\EC\80\C8A\8C\AE\EB\CF\D5\DA\E9"2\A4\B9j5\EB\F3W\B63\96\B30Yu\DA\FC8\ED\DF\E7Ms\FB\F1\8E\B3\FA\EA\E8\E6(\883zs\F2_\8DFk\8Bh \00\8C\DCw\D3R\B5+6X\BA\B2\C4j\AB0\B4\FCMw\C2I\8E\9B\E3\A9~9u\FA\D3l\80\C8%p\EE\FDn2€ \00 $\FEj\C4e\A9\DB\~\95\A7\A5\80EK\BB\8DDsP\00@@AD'k\CF\E8\DB\D2(\80\9AK\D3\85\D6lb\F2\BA\8C*\80\00)\95 59\A3R:\F3\CE"\B6\80\88\00\00i1u4ê\E9\F2á\A6\A2\FACM\93WMb*\E0*\00\00\00\00\00(\A8\80\00\00\80\00\00\00\00\00\00\00\00\00\FF\D9 C/// # coding=utf-8 # # Copyright © Cloud Linux GmbH & Cloud Linux Software, Inc 2010-2020 All Rights Reserved # # Licensed under CLOUD LINUX LICENSE AGREEMENT # http://cloudlinux.com/docs/LICENCE.TXT # import json import os import requests import subprocess import shutil from clcommon.lib.consts import ( DEFAULT_JWT_ES_TOKEN_PATH, PUSHGATEWAY_ADDRESS, DISABLE_CMT_FILE, ) def client_activation_data(raise_exception=False) -> dict: """ Check that client is activated. Absence of JWT token means that client can have volume license like GoDaddy In this case we return False. Also we return False in case of some errors: - Errors during request of status from CM - Malformed JWT token - Incorrect answer from CM """ try: with open(DEFAULT_JWT_ES_TOKEN_PATH, "r", encoding="utf-8") as f: token = f.read().strip() req = requests.get( f'{PUSHGATEWAY_ADDRESS}/api/cm/get_backend_activation', headers={"X-Auth": token}, timeout=25, ) req.raise_for_status() activation_info = req.json() except ( json.JSONDecodeError, requests.exceptions.RequestException, OSError, KeyError, IOError, ): if raise_exception: raise # we do not want to raise for cldiag return {} return activation_info def is_client_enabled(raise_exception=False) -> bool: return client_activation_data(raise_exception).get('activate', False) def collect_cmt_request_debug(cmt_domain): """ Several checks for CM - ping cmt domain - ping something that MUST be accessible - traceroute to CM """ process_results = [] ping_binary = shutil.which('ping') if ping_binary: ping_process = subprocess.run([ping_binary, '-c', '5', cmt_domain], check=False, capture_output=True, text=True) ping_external_process = subprocess.run([ping_binary, '-c', '5', 'google.com'], check=False, capture_output=True, text=True) ping_cloudlinux = subprocess.run([ping_binary, '-c', '5', 'cloudlinux.com'], check=False, ca