aDriv4 website!

Linux premium3.web-hosting.com 4.18.0-553.54.1.lve.el8.x86_64 #1 SMP Wed Jun 4 13:01:13 UTC 2025 x86_64
LiteSpeed
198.54.126.141

File Name : _log_batcher.py

import os
import random
import threading
from datetime import datetime, timezone
from typing import Optional, List, Callable, TYPE_CHECKING, Any

from sentry_sdk.utils import format_timestamp, safe_repr
from sentry_sdk.envelope import Envelope, Item, PayloadRef

if TYPE_CHECKING:
    from sentry_sdk._types import Log

class LogBatcher:
    MAX_LOGS_BEFORE_FLUSH = 100
    FLUSH_WAIT_TIME = 5.0

def __init__(
        self,
        capture_func,  # type: Callable[[Envelope], None]
    ):
        # type: (...) -> None
        self._log_buffer = []  # type: List[Log]
        self._capture_func = capture_func
        self._running = True
        self._lock = threading.Lock()

self._flush_event = threading.Event()  # type: threading.Event

self._flusher = None  # type: Optional[threading.Thread]
        self._flusher_pid = None  # type: Optional[int]

def _ensure_thread(self):
        # type: (...) -> bool
        """For forking processes we might need to restart this thread.
        This ensures that our process actually has that thread running.
        """
        if not self._running:
            return False

pid = os.getpid()
        if self._flusher_pid == pid:
            return True

with self._lock:
            # Recheck to make sure another thread didn't get here and start the
            # the flusher in the meantime
            if self._flusher_pid == pid:
                return True

self._flusher_pid = pid

self._flusher = threading.Thread(target=self._flush_loop)
            self._flusher.daemon = True

try:
                self._flusher.start()
            except RuntimeError:
                # Unfortunately at this point the interpreter is in a state that no
                # longer allows us to spawn a thread and we have to bail.
                self._running = False
                return False

return True

def _flush_loop(self):
        # type: (...) -> None
        while self._running:
            self._flush_event.wait(self.FLUSH_WAIT_TIME + random.random())
            self._flush_event.clear()
            self._flush()

def add(
        self,
        log,  # type: Log
    ):
        # type: (...) -> None
        if not self._ensure_thread() or self._flusher is None:
            return None

with self._lock:
            self._log_buffer.append(log)
            if len(self._log_buffer) >= self.MAX_LOGS_BEFORE_FLUSH:
                self._flush_event.set()

def kill(self):
        # type: (...) -> None
        if self._flusher is None:
            return

self._running = False
        self._flush_event.set()
        self._flusher = None

def flush(self):
        # type: (...) -> None
        self._flush()

@staticmethod
    def _log_to_transport_format(log):
        # type: (Log) -> Any
        def format_attribute(val):
            # type: (int | float | str | bool) -> Any
            if isinstance(val, bool):
                return {"value": val, "type": "boolean"}
            if isinstance(val, int):
                return {"value": val, "type": "integer"}
            if isinstance(val, float):
                return {"value": val, "type": "double"}
            if isinstance(val, str):
                return {"value": val, "type": "string"}
            return {"value": safe_repr(val), "type": "string"}

if "sentry.severity_number" not in log["attributes"]:
            log["attributes"]["sentry.severity_number"] = log["severity_number"]
        if "sentry.severity_text" not in log["attributes"]:
            log["attributes"]["sentry.severity_text"] = log["severity_text"]

res = {
            "timestamp": int(log["time_unix_nano"]) / 1.0e9,
            "trace_id": log.get("trace_id", "00000000-0000-0000-0000-000000000000"),
            "level": str(log["severity_text"]),
            "body": str(log["body"]),
            "attributes": {
                k: format_attribute(v) for (k, v) in log["attributes"].items()
            },
        }

return res

def _flush(self):
        # type: (...) -> Optional[Envelope]

envelope = Envelope(
            headers={"sent_at": format_timestamp(datetime.now(timezone.utc))}
        )
        with self._lock:
            if len(self._log_buffer) == 0:
                return None

envelope.add_item(
                Item(
                    type="log",
                    content_type="application/vnd.sentry.items.log+json",
                    headers={
                        "item_count": len(self._log_buffer),
                    },
                    payload=PayloadRef(
                        json={
                            "items": [
                                self._log_to_transport_format(log)
                                for log in self._log_buffer
                            ]
                        }
                    ),
                )
            )
            self._log_buffer.clear()

self._capture_func(envelope)
        return envelope

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	root/root	0755	2025-05-23 08:31:58
..	dir	-	root/root	0755	2025-05-23 08:31:59
__pycache__	dir	-	root/root	0755	2025-05-23 08:31:58
ai	dir	-	root/root	0755	2025-05-23 08:31:58
crons	dir	-	root/root	0755	2025-05-23 08:31:58
integrations	dir	-	root/root	0755	2025-05-23 08:31:58
profiler	dir	-	root/root	0755	2025-05-23 08:31:58
__init__.py	text/x-script.python	1.19 KB	root/root	0644	2025-05-23 08:31:58
_compat.py	text/x-script.python	3.04 KB	root/root	0644	2025-05-23 08:31:58
_init_implementation.py	text/x-script.python	2.5 KB	root/root	0644	2025-05-23 08:31:58
_log_batcher.py	text/x-script.python	4.97 KB	root/root	0644	2025-05-23 08:31:58
_lru_cache.py	text/x-script.python	1.2 KB	root/root	0644	2025-05-23 08:31:58
_queue.py	text/plain	10.99 KB	root/root	0644	2025-05-23 08:31:58
_types.py	text/x-script.python	10.22 KB	root/root	0644	2025-05-23 08:31:58
_werkzeug.py	text/plain	3.65 KB	root/root	0644	2025-05-23 08:31:58
api.py	text/x-script.python	11.59 KB	root/root	0644	2025-05-23 08:31:58
attachments.py	text/x-script.python	3.04 KB	root/root	0644	2025-05-23 08:31:58
client.py	text/x-script.python	37.14 KB	root/root	0644	2025-05-23 08:31:58
consts.py	text/x-script.python	39.68 KB	root/root	0644	2025-05-23 08:31:58
debug.py	text/x-script.python	1019 B	root/root	0644	2025-05-23 08:31:58
envelope.py	text/x-script.python	10.11 KB	root/root	0644	2025-05-23 08:31:58
feature_flags.py	text/x-script.python	2.18 KB	root/root	0644	2025-05-23 08:31:58
hub.py	text/x-script.python	25.07 KB	root/root	0644	2025-05-23 08:31:58
logger.py	text/x-script.python	1.62 KB	root/root	0644	2025-05-23 08:31:58
metrics.py	text/x-script.python	29.21 KB	root/root	0644	2025-05-23 08:31:58
monitor.py	text/x-script.python	3.62 KB	root/root	0644	2025-05-23 08:31:58
py.typed	application/x-empty	0 B	root/root	0644	2025-05-23 08:31:58
scope.py	text/x-script.python	61.85 KB	root/root	0644	2025-05-23 08:31:58
scrubber.py	text/x-script.python	5.92 KB	root/root	0644	2025-05-23 08:31:58
serializer.py	text/x-script.python	12.78 KB	root/root	0644	2025-05-23 08:31:58
session.py	text/x-script.python	5.44 KB	root/root	0644	2025-05-23 08:31:58
sessions.py	text/x-script.python	8.97 KB	root/root	0644	2025-05-23 08:31:58
spotlight.py	text/x-script.python	8.47 KB	root/root	0644	2025-05-23 08:31:58
tracing.py	text/x-script.python	46.99 KB	root/root	0644	2025-05-23 08:31:58
tracing_utils.py	text/x-script.python	28.14 KB	root/root	0644	2025-05-23 08:31:58
transport.py	text/x-script.python	31.84 KB	root/root	0644	2025-05-23 08:31:58
types.py	text/plain	1.19 KB	root/root	0644	2025-05-23 08:31:58
utils.py	text/x-script.python	57.98 KB	root/root	0644	2025-05-23 08:31:58
worker.py	text/x-script.python	4.36 KB	root/root	0644	2025-05-23 08:31:58

For more Private tool come to me!

https://t.me/aDriv4vz