OwlCyberSecurity - MANAGER
Edit File: transport.cpython-38.pyc
U ��\' � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZmZ d dl m Z d dl m Z m Z mZ d dlmZ zd dlmZ W n e k r� d dl mZ Y nX G dd � d e �Z G d d � d e �Z G d d � d e �Z!dd� Z"dS )� )�print_functionN)�datetime� timedelta)�VERSION)�Dsn�logger�capture_internal_exceptions)�BackgroundWorker)� getproxiesc @ s@ e Zd ZdZdZd dd�Zdd� Zddd�Zd d � Zd d � Z dS )� TransportzWBaseclass for all transports. A transport is used to send an event to sentry. Nc C s, || _ |r"|d r"t|d �| _nd | _d S )N�dsn)�optionsr � parsed_dsn)�selfr � r �E/opt/alt/python38/lib/python3.8/site-packages/sentry_sdk/transport.py�__init__( s zTransport.__init__c C s t � �dS )zdThis gets invoked with the event dictionary when an event should be sent to sentry. N)�NotImplementedError�r �eventr r r � capture_event0 s zTransport.capture_eventc C s dS )z=Wait `timeout` seconds for the current events to be sent out.Nr �r �timeout�callbackr r r �flush6 s zTransport.flushc C s dS )z Forcefully kills the transport.Nr �r r r r �kill: s zTransport.killc C s& z | � � W n tk r Y nX d S �N)r � Exceptionr r r r �__del__? s zTransport.__del__)N)N) �__name__� __module__� __qualname__�__doc__r r r r r r r r r r r s r c @ sJ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zdd d�Z dd� Z d S )� HttpTransportzThe default HTTP transport.c C sv t �| |� t� | _| j�dt �| _d | _t j � � | _ || _ | j| j|d |d |d d�| _ddlm} || _d S )Nzsentry.python/%s� http_proxy� https_proxy�ca_certs)r% r& r' r )�Hub)r r r �_workerr Zto_authr �_auth�_disabled_until�urllib3�utilZRetry�_retryr � _make_pool�_poolZ sentry_sdkr( �hub_cls)r r r( r r r r J s � zHttpTransport.__init__c C s2 | j d k r"t�� | j k r d S d | _ t�� }tj|dd�� }|�tj |dd�� d�� W 5 Q R X t � d|� d�ppd|d | jj| jjf � | jjd t| jj�|�� t| j�� �d d d �d�}z`|jdkr�t�� t| j� |�p�dd� | _ W �2d S |jdk�s|jdk �rt � d|j|j � W 5 |�� X d | _ d S )N�w)�fileobj�modeF)� allow_nanzutf-8z&Sending %s event [%s] to %s project:%s�level�errorZevent_idZPOSTzapplication/json�gzip)z X-Sentry-Authz Content-TypezContent-Encoding)�body�headersi� �< )�secondsi, �� z%Unexpected status code: %s (body: %s)) r+ r �utcnow�io�BytesIOr8 ZGzipFile�write�json�dumps�encoder �debug�getr �hostZ project_idr0 �request�strr* Z store_api_url�getvalueZ to_header�close�statusr r. Zget_retry_afterr7 �data)r r r9 �f�responser r r � _send_event^ sN $ ��� �� � � zHttpTransport._send_eventc C s dd|pt �� d�S )N� Z CERT_REQUIRED)Z num_poolsZ cert_reqsr' )�certifi�where)r r' r r r �_get_pool_options� s �z HttpTransport._get_pool_optionsc C sP |j dkr|p|}|s$t� �|j �}| �|�}|r@tj|f|�S tjf |�S d S )N�https)�schemer rF rT r, � ProxyManager� PoolManager)r r r% r& r' �proxy�optsr r r r/ � s zHttpTransport._make_poolc s( �j j�� ��fdd�}�j�|� d S )Nc s0 ��" t � � ��� � W 5 Q R X W 5 Q R X d S r )r rP r �r Zhubr r r �send_event_wrapper� s z7HttpTransport.capture_event.<locals>.send_event_wrapper)r1 �currentr) Zsubmit)r r r\ r r[ r r � s zHttpTransport.capture_eventNc C s$ t �d� |dkr | j�||� d S )NzFlushing HTTP transportr )r rE r) r r r r r r � s zHttpTransport.flushc C s t �d� | j�� d S )NzKilling HTTP transport)r rE r) r r r r r r � s zHttpTransport.kill)N) r r! r" r# r rP rT r/ r r r r r r r r$ G s 1 r$ c @ s e Zd Zdd� Zdd� ZdS )�_FunctionTransportc C s t �| � || _d S r )r r �_func)r �funcr r r r � s z_FunctionTransport.__init__c C s | � |� d S r )r_ r r r r r � s z _FunctionTransport.capture_eventN)r r! r" r r r r r r r^ � s r^ c C sj | d }|d krt }n@zt|t� W n, tk rP t|�rHt|� Y S | Y S X |}| d rf|| �S d S )NZ transportr )r$ � issubclass�type� TypeError�callabler^ )r Z ref_transportZ transport_clsr r r �make_transport� s re )#� __future__r rB r? r, rR r8 r r Zsentry_sdk.constsr Zsentry_sdk.utilsr r r Zsentry_sdk.workerr Z ClientOptionsZTypeZAny�Optional�Dict�Union�CallablerX rW Zurllib.requestr � ImportError�urllib�objectr r$ r^ re r r r r �<module> s" '|