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/// # 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 logging # NOQA import os import time import traceback from types import TracebackType # NOQA from typing import Dict, Set, Tuple, Type # NOQA from urllib.error import URLError import raven.processors from raven import Client from raven.transport import ThreadedHTTPTransport import lvestats.version from clcommon import cpapi, get_lve_version from clcommon.utils import get_rhn_systemid_value DSN = "https://9713d1296f804031b058b8f2d789d7ac@cl.sentry.cloudlinux.com/12" class RemoveConnectString(raven.processors.Processor): def filter_stacktrace(self, data): # type: (Dict) -> None for frame in data.get('frames', []): for variables in frame.get('vars', []): if isinstance(variables, dict): variables.pop('connect_string', None) class LveStatsSentryFilter(object): _record_list_file = "/var/lve/errors_record_list" _last_clean = time.time() _record_list_cache = set() # type: Set[str] @classmethod def clear_record_list(cls): # type: () -> None cls._record_list_cache = set() try: os.unlink(cls._record_list_file) except OSError: pass @classmethod def _clean_muted_records(cls): if cls._last_clean < time.time() - 43200: # more than 12 hours cls.clear_record_list() cls._last_clean = time.time() def in_record_list(self, record_fingerprint): # type: (str) -> bool try: with open(self._record_list_file, 'r', encoding='utf-8') as f: result = [line.rstrip('\n') for line in f] except IOError: return False else: return record_fingerprint in result def append_to_record_list(self, record_fingerprint): # type: (str) -> None self._record_list_cache.add(record_fingerprint) try: with open(self._record_list_file, "a", encoding='utf-8') as f: f.write(record_fingerprint + '\n') except IOError: pass def filter(self, record): # type: (logging.LogRecord) -> bool return self.check_fingerprint_absent( record.name, record.lineno, str(record.msg)[:25], record.exc_info[0].__name__ if record.exc_info else "") def check_fingerprint_absent(self, name, lineno, message, exc_name): # type: (str, int, str, str) -> bool if not os.environ.get('LVESTATSWITHOUTSENTR1Y'): record_fingerprint = repr(f"{name}.{lineno}.{message}.{exc_name}") self._clean_muted_records() if record_fingerprint in self._record_list_cache: return False elif self.in_record_list(record_fingerprint): self._record_list_cache.add(record_fingerprint) return False else: self.append_to_record_list(record_fingerprint) return True else: return False class SafeThreadedHTTPTransport(ThreadedHTTPTransport): def send_sync(self, url, data, headers, success_cb, failure_cb): try: super().send_sync(url, data, headers, success_cb, failure_cb) except URLError: # 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 LveStatsSentryClient(Client): _filter = LveStatsSentryFilter() def is_new_exception(self, exc_info): # type: (Tuple[Type, Exception, TracebackType]) -> bool type_, _, tb = exc_info filepath, line_no, _, _ = traceback.extract_tb(tb)[-1] name = os.path.basename(filepath) # 'message' param is not used here # line number and file must be enough return self._filter.check_fingerprint_absent( name, line_no, '', type_.__name__) def should_capture(self, exc_info): # type: (Tuple[Type, Exception, TracebackType]) -> bool return super().should_capture(exc_info) and self.is_new_exception(exc_info) def init_sentry_client(): client = LveStatsSentryClient( DSN, transport=SafeThreadedHTTPTransport, ) # uncomment for lower issues count # c