Edit File: sessions.cpython-37.pyc
B Z~�_� � @ s� d dl Z d dlZd dlZd dlmZ d dlmZmZ d dlmZ d dl m Z d dl m Z e r�d dl Z d dlmZ d dlmZ d d lmZ d d lmZ d d lmZ d d l mZ dd d�Zeddd��Zdd� ZdZG dd� de�ZG dd� de�ZdS )� N)�datetime)�Thread�Lock)�contextmanager)�MYPY)�format_timestamp)�Optional)�Union)�Any)�Dict)� Generator)� SessionStatusc C sD | dkrt jj} | jj}|dkr@| jr2| jjd ni }|�d�}|S )z<Utility function to find out if session tracking is enabled.NZ _experiments�auto_session_tracking)� sentry_sdk�Hub�currentZscopeZ _force_auto_session_trackingZclient�options�get)�hub� should_track�exp� r �D/opt/alt/python37/lib/python3.7/site-packages/sentry_sdk/sessions.py� is_auto_session_tracking_enabled s r c c sB | dkrt jj} t| �}|r$| �� z dV W d|r<| �� X dS )z8Starts and stops a session automatically around a block.N)r r r r Z start_sessionZ end_session)r r r r r r # s r c C s t | tj�r| S t�| �S )N)� isinstance�uuid�UUID)�valr r r � _make_uuid3 s r )�exitedZabnormalZcrashedc @ s> e Zd Zddd�Zdd� Zdd� Zdd � Zd d � Zd d � ZdS )�SessionFlusher� c C s0 || _ || _i | _d | _t� | _d | _d| _d S )NT)� flush_func�flush_interval�pending�_threadr � _thread_lock�_thread_for_pid�_running)�selfr" r# r r r �__init__@ s zSessionFlusher.__init__c C s" | j }i | _ | �t|�� �� d S )N)r$ r" �list�values)r) r$ r r r �flushN s zSessionFlusher.flushc s� � j t�� kr � jd k r d S � j�V � j t�� kr@� jd k r@d S � fdd�}t|d�}d|_|�� |� _t�� � _ W d Q R X d S )Nc s0 x*� j r*t�� j� � jr� j r� �� qW d S )N)r( �time�sleepr# r$ r- r )r) r r r% \ s z/SessionFlusher._ensure_running.<locals>._thread)�targetT)r' �os�getpidr% r& r �daemon�start)r) r% �threadr )r) r �_ensure_runningT s z SessionFlusher._ensure_runningc C s |� � | j|jj< | �� d S )N)�to_jsonr$ �sid�hexr6 )r) Zsessionr r r � add_sessionj s zSessionFlusher.add_sessionc C s d| _ d S )NF)r( )r) r r r �killq s zSessionFlusher.killc C s | � � d S )N)r; )r) r r r �__del__u s zSessionFlusher.__del__N)r! ) �__name__� __module__� __qualname__r* r- r6 r: r; r< r r r r r ? s r c @ s2 e Zd Zd dd�Zd dd�Zd dd�Zdd � ZdS ) �SessionNc C s� |d krt �� }|d kr t�� }|d kr,d}|| _d | _|| _d | _d | _d | _ d | _ d | _ d| _ | j ||||||| | | | d� d S )N�okr ) r8 �did� timestamp�duration�release� environment� user_agent� ip_address�errors�user)r Zuuid4r �utcnow�statusrB �startedrE rF rD rG rH rI �update) r) r8 rB rC rM rD rL rE rF rG rH rI rJ r r r r* { s4 zSession.__init__c C s� | r<| d kr| � d�} |d kr<| � d�p:| � d�p:| � d�}|d k rNt|�| _|d k r`t|�| _|d krpt�� }|| _|d k r�|| _|d k r�|| _ |d k r�|| _ |d k r�|| _ | d k r�| | _ | d k r�| | _ | d k r�| | _|d k r�|| _d S )NrH �id�email�username)r r r8 �strrB r rK rC rM rD rE rF rH rG rI rL ) r) r8 rB rC rM rD rL rE rF rG rH rI rJ r r r rN � s8 zSession.updatec C s. |d kr| j dkrd}|d k r*| j|d� d S )NrA r )rL )rL rN )r) rL r r r �close� s z Session.closec C s� t | j�dt| j�t| j�| jd�}| jr4| j|d< | jd k rH| j|d< | jd k r\| j|d< i }| j d k rt| j |d< | j d k r�| j |d< | j d k r�| j |d< | j d k r�| j |d < |r�||d < |S ) NT)r8 �initrM rC rL rI rB rD rE rF rH rG �attrs) rR r8 r rM rC rL rI rB rD rE rF rH rG )r) �rvrU r r r r7 � s. zSession.to_json) NNNNNNNNNNNN) NNNNNNNNNNNN)N)r= r> r? r* rN rS r7 r r r r r@ z s4 " $ r@ )N)N) r1 r r. r � threadingr r � contextlibr Zsentry_sdk._typesr Zsentry_sdk.utilsr r �typingr r r r r r r r r ZTERMINAL_SESSION_STATES�objectr r@ r r r r �<module> s, ;