Wala shell

Advanced PHP File Manager

Server IP: 127.0.0.1 | PHP Version: 8.3.30 | Domains Hosted: 54

Name	Size	Last Modified	Actions
📁 ..	-	2026-03-27 02:38
📄 __init__.py # 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 import sentry_sdk from clcommon.utils import get_rhn_systemid_value, get_username from clcommon.lib.network import get_ip_addr, get_hostname from clsentry.client import ( UserlandClient, SafeRequestsHTTPTransportSentrySdk, ThreadedHttpTransport, get_user_tags, before_send ) from clsentry.utils import get_pkg_version from raven.handlers.logging import SentryHandler from raven.conf import setup_logging from sentry_sdk.integrations.logging import LoggingIntegration CLLIB_DSN = 'https://9713d1296f804031b058b8f2d789d7ac:8ddacae32d8246cf8b25cf826bf3fc0a@cl.sentry.cloudlinux.com/12' __all__ = ('init_sentry_client', 'init_cllib_sentry_client', 'init_sentry_sdk_client') def init_sentry_client(project, release, dsn, handle=True, custom_length=None): """ @deprecated use init_sentry_sdk_client Create generic sentry client and install logging hooks """ sentry = UserlandClient(dsn, release=release) # set user context settings, like id or email sentry.user_context({ 'id': get_rhn_systemid_value('system_id') or get_ip_addr(get_hostname()) or get_hostname() or get_username() }) # and also set project name sentry.tags['Project'] = project if custom_length: sentry.string_max_length = custom_length if handle: # setup handler, so we can track logging.error's handler = SentryHandler(sentry, level=logging.ERROR) setup_logging(handler) return sentry def init_cllib_sentry_client(): """ Create sentry client for cllib package and install logging hooks """ return init_sentry_client( 'python-cllib', release=get_pkg_version('alt-python27-cllib'), dsn=CLLIB_DSN) def init_sentry_sdk_client(project, release, dsn, handle=True, custom_length=1000, transport=SafeRequestsHTTPTransportSentrySdk, environment=None): """ Initialize the Sentry SDK client and configure logging integration. :param project: Project name. :param release: Application release version. :param dsn: Sentry DSN. :param handle: Enable logging integration (default: True). :param custom_length: Max length for captured values (default: 1000). :param transport: Transport method, can be 'threading' or a transport class. :param environment: Environment name (default: None). If None or empty string, defaults to production environment. :return: Configured Sentry SDK instance. """ sentry_sdk.init( dsn=dsn, release=release, environment=environment or None, transport=ThreadedHttpTransport if transport == 'threading' else transport, ignore_errors=[KeyboardInterrupt], max_value_length=custom_length, before_send=before_send, attach_stacktrace=True, _experiments={"auto_enabling_integrations": False}, integrations=[LoggingIntegration(level=logging.ERROR, event_level=logging.ERROR)] if handle else [], ) with sentry_sdk.configure_scope() as scope: scope.set_user({ 'id': get_rhn_systemid_value('system_id') or get_ip_addr(get_hostname()) or get_hostname() or get_username() }) for key, value in get_user_tags().items(): scope.set_tag(key, value) scope.set_tag("Project", project) return sentry_sdk def sentry_sdk_send_message(message: str, level: str = "info", tags: dict = None, extra: dict = None, attachments: list[dict] = None, user: dict = None, fingerprint: list = None, contexts: dict = None, transaction: str = None): """ Send a message to Sentry with additional context. :param message: The text of the message. :param level: Logging level (debug, info, warning, error, fatal). :param tags: Additional tags (dict). For example: {"foo": "bar"} :param extra: Additional data (dict). For example: {"foo": "bar"} :param attachments: Additional files (list). With "path" or "bytes", "filename", and optional "content_type. :param user: User information (dict). With "id", and "username". :param fingerprint: Fingerprint information (list). For example: ["my-custom-events-group"] :param contexts: Additional context data (dict). For example: {"character": {"age": 19}} :param transaction: Transaction name (string). For example: UserListView Docs: https://docs.sentry.io/platforms/python/enriching-events/ """ with sentry_sdk.push_scope() as scope: if tags: for key, value in tags.items(): scope.set_tag(key, value) if extra: for key, value in extra.items(): scope.set_extra(key, value) if attachments: for attachment in attachments: scope.add_attachment(**attachment) if user: scope.set_user(user) if fingerprint: scope.fingerprint = fingerprint if contexts: for key, value in contexts.items(): scope.set_context(key, value) if transaction: scope.set_transaction_name(transaction) sentry_sdk.capture_message(message, level=level)	5.32 KB	2026-02-10 15:10
📁 __pycache__	-	2026-03-19 15:49
📄 client.py #!/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 platform 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_event(event, hint): def sanitize_dict(data): for key, value in data.items(): if key.lower() in SENSITIVE_FIELDS: data[key] = '*********' elif isinstance(value, dict): sanitize_dict(value) return data if "request" in event and isinstance(event["request"], dict): event["request"] = sanitize_dict(event["request"]) return event def before_send(event, hint): exception_values = event.get("exception", {}).get("values", []) if exception_values: stacktrace = exception_values[0].get("stacktrace", {}) frames = stacktrace.get("frames", []) if frames and "sentry" in frames[-1].get("module", ""): return None log_record = hint.get("log_record") if log_record: fingerprint = getattr(log_record, "fingerprint", None) if fingerprint: event["fingerprint"] = [fingerprint] return sanitize_event(event, hint)	4.97 KB	2026-02-10 15:10
📄 processors.py #!/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 """Module for all sentry processors related code""" from raven.processors import SanitizePasswordsProcessor from clsentry.utils import SENSITIVE_FIELDS class UserlandSanitize(SanitizePasswordsProcessor): """ Beside from default SanitizePasswordsProcessor algorithm, also search key-values in query-like strings. Also sanitize some additional fields. """ FIELDS = frozenset(SENSITIVE_FIELDS) def sanitize(self, item, value): new_value = super().sanitize(item, value) if new_value == value and isinstance(value, str) and '=' in value: new_value = self._sanitize_keyvals(value, '&') return new_value	901 B	2026-02-10 15:10
📄 utils.py #!/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 os from clcommon.utils import get_file_lines PACKAGES_FILES_PATH = '/usr/share/cloudlinux' SENSITIVE_FIELDS = [ 'password', 'secret', 'passwd', 'authorization', 'api_key', 'apikey', 'sentry_dsn', 'access_token', 'email', 'token', 'pass', ] def get_pkg_version(package): """ Get package version using rpm or None if any error or package absent. :type package: str :rtype: str\|None """ # First we try to read package version from file try: file_lines = get_file_lines(os.path.join(PACKAGES_FILES_PATH, package)) if file_lines: return file_lines[0].strip().split(".el", 1)[0] except (OSError, IOError, IndexError): return None	987 B	2026-02-10 15:10

Terminal