C///

\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/// #!/opt/cloudlinux/venv/bin/python3 -bb # coding=utf-8 # # Copyright © Cloud Linux GmbH & Cloud Linux Software, Inc 2010-2019 All Rights Reserved # # Licensed under CLOUD LINUX LICENSE AGREEMENT # http://cloudlinux.com/docs/LICENSE.TXT import json import platform import re import threading from requests.exceptions import RequestException from clcommon import cpapi, get_lve_version from clcommon.lib.cledition import get_cl_edition_readable from clcommon.utils import get_rhn_systemid_value, get_username from clcommon.lib.network import get_ip_addr, get_hostname from clcommon.cpapi.const import UNKNOWN_CP_NAME from raven import Client from raven.transport import RequestsHTTPTransport from sentry_sdk.transport import HttpTransport from clsentry.utils import get_pkg_version, SENSITIVE_FIELDS class SafeRequestsHTTPTransport(RequestsHTTPTransport): def send(self, url, data, headers): try: super().send(url, data, headers) except RequestException: # We hide errors while sending message to Sentry in varied cases: # problems with network, Sentry server is down, incorrect firewall's rules, etc pass class SafeRequestsHTTPTransportSentrySdk(HttpTransport): def _send_event(self, event): try: super()._send_event(event) except RequestException: # We hide errors while sending message to Sentry in varied cases: # problems with network, Sentry server is down, incorrect firewall's rules, etc pass class ThreadedHttpTransport(HttpTransport): def send_event(self, event): thread = threading.Thread(target=super().send_event, args=(event,)) thread.daemon = True thread.start() class UserlandClient(Client): """ Userland's sentry client with some common settings. """ def __init__(self, dsn, **options): options.update({ 'tags': self._get_user_tags(), 'ignore_exceptions': [ KeyboardInterrupt, ], 'exclude_paths': [ 'sentry', 'raven', ], 'auto_log_stacks': True, 'string_max_length': 1000, 'list_max_length': 100, 'processors': ('clsentry.processors.UserlandSanitize',), # async transport is noisy and prints messages like # 'Sentry is attempting to send 1 pending error messages' 'transport': SafeRequestsHTTPTransport, }) super().__init__(dsn, **options) @classmethod def _get_user_tags(cls): """ Get tags for easy search :rtype: dict """ return get_user_tags() def get_user_tags(): """ Get tags for easy search :rtype: dict """ cp_description = cpapi.get_cp_description() cp_version = cp_description.get('version') if cp_description else None cp_name = cp_description.get('name') if cp_description else UNKNOWN_CP_NAME cp_product = 'WP2' if cpapi.is_wp2_environment() else None return { 'Control Panel Name': cp_name, 'Control Panel Version': cp_version, 'Control Panel Product': cp_product, 'CloudLinux version': get_rhn_systemid_value("os_release"), 'Cloudlinux edition': get_cl_edition_readable(), 'Architecture': get_rhn_systemid_value("architecture"), 'lve_version': get_lve_version()[0], # TODO: use 'include_paths' instead 'lvemanager': get_pkg_version('lvemanager'), 'alt-python27-cllib': get_pkg_version('alt-python27-cllib'), 'lve-stats': get_pkg_version('lve-stats'), 'lve-utils': get_pkg_version('lve-utils'), 'cl-end-server-tools': get_pkg_version('cl-end-server-tools'), 'cl-node-exporter': get_pkg_version('cl-node-exporter'), 'cagefs': get_pkg_version('cagefs'), 'kernel': platform.release(), 'username': get_username(), 'ip_address': get_ip_addr(get_hostname()), 'hostname': get_hostname(), 'system_id': get_rhn_systemid_value("system_id"), } def _sanitize_keyvals(s): """Mask sensitive values in a form-encoded 'key=value&...' string.""" parts = [] for pair in s.split('&'): kv = pair.split('=', 1) if len(kv) == 2 and kv[0].lower() in SENSITIVE_FIELDS: parts.append(kv[0] + '=' + '*********') else: parts.append(pair) return '&'.join(parts) def _sanitize_string(value): """Mask secrets in a JSON / URL / form-encoded string body.""" try: parsed = json.loads(value) except (ValueError, TypeError, RecursionError): pass else: if isinstance(parsed, (dict, list, tuple)): return json.dumps(sanitize_value('', parsed)) # Mask userinfo (user:pass@) in the authority component, independent # of whether a query string is present. if '//' in value and '@' in value: value = re.sub(r'(//)[^/@\s]+@', r'\1*********@', value) # Mask sensitive params in the query string. if '?' in value: base, _, query = value.partition('?') return base + '?' + _sanitize_keyvals(query) if '=' in value: return _sanitize_keyvals(value) return value def sanitize_value(key, value): """Recursively sanitize a single key/value pair. Never raises.""" if isinstance(key, str) and key.lower() in SENSITIVE_FIELDS: return '*********' if isinstance(value, dict): return sanitize_dict(value) if isinstance(value, (list, tuple)):