Edit File: sessions.cpython-37.opt-1.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�uuidZUUID)�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�hexr5 )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, r5 r9 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 ) r7 �did� timestamp�duration�release� environment� user_agent� ip_address�errors�user)r Zuuid4r �utcnow�statusrA �startedrD rE rC rF rG rH �update) r( r7 rA rB rL rC rK rD rE rF rG rH rI 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 )NrG �idZemailZusername)r r r7 �strrA r rJ rB rL rC rD rE rG rF rH rK ) r( r7 rA rB rL rC rK rD rE rF rG rH rI r r r rM � s8 zSession.updatec C s. |d kr| j dkrd}|d k r*| j|d� d S )Nr@ r )rK )rK rM )r( rK 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)r7 ZinitrL rB rK rH rA rC rD rE rG rF �attrs) rO r7 r rL rB rK rH rA rC rD rE rG rF )r( �rvrQ r r r r6 � s. zSession.to_json) NNNNNNNNNNNN) NNNNNNNNNNNN)N)r< r= r> r) rM rP r6 r r r r r? z s4 " $ r? )N)N) r0 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, ;