XMAN Replicator

Path: /opt/imunify360/venv/lib/python3.11/site-packages/sentry_sdk/integrations/

Name	Size	Rights	Date	Actions
[.]	<DIR>	drwxr-xr-x	2026-05-27 11:12	🔄 🗑️ 🗑️📁 ⬇️ 🔒
[..]	<DIR>	drwxr-xr-x	2026-05-27 11:12	🔄 🗑️ 🗑️📁 ⬇️ 🔒
__init__.py	6,509 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
[__pycache__]	<DIR>	drwxr-xr-x	2026-05-27 11:13	🔄 🗑️ 🗑️📁 ⬇️ 🔒
_wsgi_common.py	4,763 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
aiohttp.py	7,960 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
argv.py	945 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
asgi.py	8,368 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
atexit.py	1,837 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
aws_lambda.py	12,941 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
beam.py	5,662 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
boto3.py	3,727 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
bottle.py	6,187 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
celery.py	9,119 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
chalice.py	4,573 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
dedupe.py	1,166 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
[django]	<DIR>	drwxr-xr-x	2026-05-27 11:12	🔄 🗑️ 🗑️📁 ⬇️ 🔒
excepthook.py	2,190 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
executing.py	2,023 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
falcon.py	6,796 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
flask.py	7,428 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
gcp.py	7,382 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
gnu_backtrace.py	2,912 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
logging.py	7,573 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
modules.py	1,393 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
pure_eval.py	4,520 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
pyramid.py	7,072 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
redis.py	3,075 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
rq.py	4,791 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
sanic.py	7,709 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
serverless.py	1,971 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
[spark]	<DIR>	drwxr-xr-x	2026-05-27 11:12	🔄 🗑️ 🗑️📁 ⬇️ 🔒
sqlalchemy.py	2,939 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
stdlib.py	7,348 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
threading.py	2,856 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
tornado.py	7,001 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
trytond.py	1,728 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒
wsgi.py	10,374 B	-rw-r--r--	2026-04-14 09:45	✏️ 🔄 🗑️ ⬇️ 🔒

View: pure_eval.py

from __future__ import absolute_import

import ast

from sentry_sdk import Hub, serializer
from sentry_sdk._types import MYPY
from sentry_sdk.integrations import Integration, DidNotEnable
from sentry_sdk.scope import add_global_event_processor
from sentry_sdk.utils import walk_exception_chain, iter_stacks

if MYPY:
    from typing import Optional, Dict, Any, Tuple, List
    from types import FrameType

    from sentry_sdk._types import Event, Hint

try:
    import executing
except ImportError:
    raise DidNotEnable("executing is not installed")

try:
    import pure_eval
except ImportError:
    raise DidNotEnable("pure_eval is not installed")

try:
    # Used implicitly, just testing it's available
    import asttokens  # noqa
except ImportError:
    raise DidNotEnable("asttokens is not installed")


class PureEvalIntegration(Integration):
    identifier = "pure_eval"

    @staticmethod
    def setup_once():
        # type: () -> None

        @add_global_event_processor
        def add_executing_info(event, hint):
            # type: (Event, Optional[Hint]) -> Optional[Event]
            if Hub.current.get_integration(PureEvalIntegration) is None:
                return event

            if hint is None:
                return event

            exc_info = hint.get("exc_info", None)

            if exc_info is None:
                return event

            exception = event.get("exception", None)

            if exception is None:
                return event

            values = exception.get("values", None)

            if values is None:
                return event

            for exception, (_exc_type, _exc_value, exc_tb) in zip(
                reversed(values), walk_exception_chain(exc_info)
            ):
                sentry_frames = [
                    frame
                    for frame in exception.get("stacktrace", {}).get("frames", [])
                    if frame.get("function")
                ]
                tbs = list(iter_stacks(exc_tb))
                if len(sentry_frames) != len(tbs):
                    continue

                for sentry_frame, tb in zip(sentry_frames, tbs):
                    sentry_frame["vars"] = (
                        pure_eval_frame(tb.tb_frame) or sentry_frame["vars"]
                    )
            return event


def pure_eval_frame(frame):
    # type: (FrameType) -> Dict[str, Any]
    source = executing.Source.for_frame(frame)
    if not source.tree:
        return {}

    statements = source.statements_at_line(frame.f_lineno)
    if not statements:
        return {}

    scope = stmt = list(statements)[0]
    while True:
        # Get the parent first in case the original statement is already
        # a function definition, e.g. if we're calling a decorator
        # In that case we still want the surrounding scope, not that function
        scope = scope.parent
        if isinstance(scope, (ast.FunctionDef, ast.ClassDef, ast.Module)):
            break

    evaluator = pure_eval.Evaluator.from_frame(frame)
    expressions = evaluator.interesting_expressions_grouped(scope)

    def closeness(expression):
        # type: (Tuple[List[Any], Any]) -> Tuple[int, int]
        # Prioritise expressions with a node closer to the statement executed
        # without being after that statement
        # A higher return value is better - the expression will appear
        # earlier in the list of values and is less likely to be trimmed
        nodes, _value = expression

        def start(n):
            # type: (ast.expr) -> Tuple[int, int]
            return (n.lineno, n.col_offset)

        nodes_before_stmt = [
            node for node in nodes if start(node) < stmt.last_token.end
        ]
        if nodes_before_stmt:
            # The position of the last node before or in the statement
            return max(start(node) for node in nodes_before_stmt)
        else:
            # The position of the first node after the statement
            # Negative means it's always lower priority than nodes that come before
            # Less negative means closer to the statement and higher priority
            lineno, col_offset = min(start(node) for node in nodes)
            return (-lineno, -col_offset)

    # This adds the first_token and last_token attributes to nodes
    atok = source.asttokens()

    expressions.sort(key=closeness, reverse=True)
    return {
        atok.get_text(nodes[0]): value
        for nodes, value in expressions[: serializer.MAX_DATABAG_BREADTH]
    }

🛸 XMAN Replicator

View: pure_eval.py

PHP Console

SQL Console