km 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
Zedd Zd ZdZ G d de Z G d de ZdS ) N)datetime)ThreadLock)contextmanager)MYPY)format_timestamp)Optional)Union)Any)Dict) Generator)
SessionStatusc | t j j } | j j }|0| j r| j j d ni }| d }|S )z>r )exitedabnormalcrashedc 6 e Zd Z d dZd Zd Zd Zd Zd ZdS )
SessionFlusher
c || _ || _ i | _ d | _ t | _ d | _ d| _ d S )NT)
flush_funcflush_intervalpending_threadr _thread_lock_thread_for_pid_running)selfr1 r2 s r __init__zSessionFlusher.__init__@ s@ % , FF #
r c | j }i | _ | t | d S r$ )r3 r1 listvalues)r8 r3 s r flushzSessionFlusher.flushN s: , W^^ - -../////r c j t j k r j d S j 5 j t j k r j d d d d S fd}t | }d|_ | | _ t j _ d d d n # 1 swxY w Y d S )Nc j rDt j j j r j r j Bd S d S r$ )r7 timesleepr2 r3 r= r8 s r r4 z/SessionFlusher._ensure_running.._thread\ s` m %Jt 2333| %
%
m % % % % %r )targetT)r6 osgetpidr4 r5 r daemonstart)r8 r4 threads ` r _ensure_runningz SessionFlusher._ensure_runningT s" 29;; . .4<3K4
/ /#ry{{22t|7O / / / / / / / /
%
%
%
%
% 7+++F FM LLNNN!DL#%9;;D / / / / / / / / / / / / / / / ts %B; AB;;B?B?c z | | j |j j < | d S r$ )to_jsonr3 sidhexrI )r8 sessions r add_sessionzSessionFlusher.add_sessionj s6 )0(9(9 W[_% r c d| _ d S )NF)r7 rB s r killzSessionFlusher.killq s
r c . | d S r$ )rQ rB s r __del__zSessionFlusher.__del__u s r N)r/ ) __name__
__module__ __qualname__r9 r= rI rO rQ rS r r r. r. ? sx 0 0 0 , r r. c ^ e Zd Z ddZ ddZ ddZd ZdS )SessionNc
|t j }|t j }|d}|| _ d | _ || _ d | _ d | _ d | _ d | _
d | _ d| _ |
||||||| |
| |
d S )Nokr )
rL did timestampdurationrelease environment
user_agent
ip_addresserrorsuser)r& uuid4r utcnowstatusr\ startedr_ r` r^ ra rb rc update
r8 rL r\ r] rh r^ rg r_ r` ra rb rc rd s
r r9 zSession.__init__{ s ;*,,C ? o''G >F
#!!
r c
| rX|
| d }
|?| d p)| d p| d }|t | | _ |t | | _ |t j }|| _ ||| _ ||| _ ||| _
||| _ |
|
| _ | | | _
| | | _ | || _ d S d S )Nrb idemailusername)r r) rL strr\ r rf r] rh r^ r_ r` rb ra rc rg rj s
r ri zSession.update s
" R! !XXl 3 3
{hhtnnQ(9(9QTXXj=Q=Q ?!#DH ?3xxDH ))I" "DL $DM "DL " *D ! (DO ! (DO DK DKKK r c X |
| j dk rd}|| | d S d S )Nr[ r* )rg )rg ri )r8 rg s r closez
Session.close sB >dkT 1 1 F KKvK & & & & & r c t | j dt | j t | j | j d}| j r
| j |d< | j
| j |d< | j
| j |d< i }| j
| j |d< | j
| j
|d< | j
| j |d< | j
| j |d < |r||d
< |S ) NT)rL initrh r] rg rc r\ r^ r_ r` rb ra attrs)
ro rL r rh r] rg rc r\ r^ r_ r` rb ra )r8 rvrt s r rK zSession.to_json s tx==' 55)$.99k
; ' ;BxL 8 BuI = $ !]BzN < # #|E) '#'#3E- ? &"&/E, ? &"&/E, BwK r ) NNNNNNNNNNNNr$ )rT rU rV r9 ri rq rK rW r r rY rY z s
+
+
+
+
^
.! .! .! .!b ' ' ' ' r rY r$ ) rD r& r@ r threadingr r
contextlibr sentry_sdk._typesr sentry_sdk.utilsr r typingr r
r r r
r r r r) TERMINAL_SESSION_STATESobjectr. rY rW r r r} s " " " " " " " " % % % % % % " " " " " " - - - - - - 0 ////// < 8 8 8 8 8V 8 8 8vB B B B Bf B B B B Br