File: //usr/lib/python3.6/site-packages/fail2ban/__pycache__/helpers.cpython-36.opt-1.pyc
3
TB(dcG � @ s� d Z dZddlZddlZddlZddlZddlZddlZddlZddl m
Z
ddl m Z ddl
Z
yddlZejd�ZW n dZY nX ej� atjd�r�ejr�ejjdk r�ejjjd� r�ejjaned d
� dOD ��r�daejdPk � r�dd� Zet� [ejdQk�r tdfdd�Zdd� Zn.tdfdd�Zej� j � dk�rHdd� Zne Zdd� Z d d � Z d d � Z G d d!� d!e!�Z"G d"d#� d#ej#�Z$d$e_%dRd%d&�Z&ye'Z'W n e(k
�r� e)Z'Y nX ej*j+Z,d'd(� Z-e-ej*_+ej.j/Z0d)d*� Z1e1ej._/d+d,� Z2d-d.� Z3dSd1d2�Z4d3d4� Z5d5d6� Z6ejdTk�r2e7e8d8e9d9�� nd:d;� Z:d<d=� Z;ej8d>ej<�Z=ej8d?ej<�Z>ej8d@ej<�Z?dAdB� Z@dCdD� ZAdEZBej8dF�ZCdGf dfdHdI�ZDe�r�dJdK� ZEndLdK� ZEG dMdN� dNe!�ZFdS )Uz<Cyril Jaquier, Arturo 'Buanzo' Busleiman, Yaroslav HalchenkoZGPL� N)�Lock� )�MyTimez libcap.so.2ZANSI_c c s | ]}t j|�dkV qd S )N� )Nr )�os�getenv)�.0�v� r
� /usr/lib/python3.6/helpers.py� <genexpr>0 s r �LANGUAGE�LC_ALL�LC_CTYPE�LANGzUTF-8� c C s� t j� j� }|dkr�|tj� kr�t }t|d�slyddlm} |dd�}W n" tk
rj tjt � t }Y nX t|d�r�|j | � d S )N�ASCII�setdefaultencodingr )� load_dynamic�_sys�sys)
r �getdefaultencoding�upper�
PREFER_ENC�hasattr�impr � ImportError�reloadr )�encodingZoder Z__ldmr
r
r �__resetDefaultEncoding8 s
r �strictc C sJ yt | t�r| j||�S | S ttfk
rD |dkr8� | j|d�S X d S )Nr �replace)�
isinstance�bytes�decode�UnicodeDecodeError�UnicodeEncodeError)�x�enc�errorsr
r
r �
uni_decodeY s
r* c C s t | t�st| �S | jtd�S )Nr! )r" r# �strr$ r )r' r
r
r �
uni_stringb s
r, c C sJ yt | t�r| j||�S | S ttfk
rD |dkr8� | j|d�S X d S )Nr r! )r" r+ �encoder% r& )r' r( r) r
r
r r* g s
c C s t | t�st| �S | jtd�S )Nr! )r" r+ r- r )r' r
r
r r, q s
c C s t | t�st| �S | j� dkS )N�1�on�true�yes)r. r/ r0 r1 )r" r+ �bool�lower)�valr
r
r �_as_booly s r5 c C s" t j� dd� \} }| jt|�fS )z+ Consistently format exception information N� )r �exc_info�__name__r, )Zcla�excr
r
r �formatExceptionInfo~ s r: c C sR t jj| �}|jd�r"|dd� }|tddg�krNt jjt jj| ��d | }|S )zaCustom function to include directory name if filename is too common
Also strip .py at the end
z.pyNr �base�__init__�.���)r �path�basename�endswith�set�dirname)�sr; r
r
r � mbasename� s
rE c @ s" e Zd ZdZddd�Zdd� ZdS ) � TraceBackz7Customized traceback to be included in debug messages
Fc C s d| _ || _dS )z�Initialize TrackBack metric
Parameters
----------
compress : bool
if True then prefix common with previous invocation gets
replaced with ...
r N)�_TraceBack__prev�_TraceBack__compress)�self�compressr
r
r r< � s zTraceBack.__init__c C s� t jdd�d d� }dd� |D �}dd� |D �}|d g}xP|dd � D ]@}|d |d d kr~|d d d |d 7 < qH|j|� qHW d
jd d� |D ��}| jr�|}tjj| j|f�}t j
d d
|�}|d
kr�d|t |�d � }|| _|S )N�d )�limitr6 c S s2 g | ]*}t |d �tjj|d �t|d �g�qS )r r )rE r r? rC r+ )r r' r
r
r �
<listcomp>� s z&TraceBack.__call__.<locals>.<listcomp>c S s6 g | ].}|d dkp |d j d�s|d |d g�qS )r �unittest�logging.__init__r z /unittestr6 )rN rO )rA )r �er
r
r rM � s r r z,%s�>c S s$ g | ] }d t |d �|d f �qS )z%s:%sr r )rE )r r' r
r
r rM � s z>[^>]*$r z...������rS ) � traceback�
extract_stack�append�joinrH r r? � commonprefixrG �re�sub�len) rI ZftbZentriesZ entries_out�entryZsftbZ prev_nextZ
common_prefixZcommon_prefix2r
r
r �__call__� s$
zTraceBack.__call__N)F)r8 �
__module__� __qualname__�__doc__r< r] r
r
r
r rF � s
rF c @ s e Zd ZdZdd� Zdd� ZdS )�FormatterWithTraceBackz}Custom formatter which expands %(tb) and %(tbc) with tracebacks
TODO: might need locking in case of compressed tracebacks
c O s4 t jj| f|�d|i|�� d|k}t|d�| _d S )N�fmtz%(tbc)s)rJ )�logging� Formatterr< rF �_tb)rI rb �args�kwargsrJ r
r
r r< � s z FormatterWithTraceBack.__init__c C s | j � |_|_tjj| |�S )N)re Ztbc�tbrc rd �format)rI �recordr
r
r ri � s z FormatterWithTraceBack.formatN)r8 r^ r_ r` r< ri r
r
r
r ra � s ra Fc C sh | r t | j�r | j| jd � |r,dd� |_dd� tj_tjrdytj j� W n Y nX tj
d� d S )Nr c S s d S )Nr
r
r
r
r �<lambda>� s z!__stopOnIOError.<locals>.<lambda>c S s d S )Nr
)rI r
r
r rk � s ) r[ ZhandlersZ
removeHandler�closerc �
StreamHandler�flush�
exitOnIOErrorr �stderr�exit)ZlogSysZlogHndlrr
r
r �__stopOnIOError� s
rr c K s� yt | |||f|� W n� ttfk
rP } z|jdkr>t| � � W Y dd}~X n� tk
r� } zhyTxNd|t|�ffddd� |D �fffD ]&}yt | |f|�� W q� Y q�X q�W W n Y nX W Y dd}~X nX dS )a� Safe log inject to avoid possible errors by unsafe log-handlers,
concat, str. conversion, representation fails, etc.
Used to intrude exception-safe _log-method instead of _log-method
of Logger class to be always safe by logging and to get more-info about.
See testSafeLogging test-case for more information. At least the errors
covered in phase 3 seems to affected in all known pypy/python versions
until now.
� Nzlogging failed: %r on %sz
args: %rc S s g | ] }t |��qS r
)r, )r �ar
r
r rM � s z __safeLog.<locals>.<listcomp>)� __origLog�BrokenPipeError�IOError�errnorr � Exceptionr, )rI �level�msgrf rg rP r
r
r � __safeLog� s"
r| c C sN y t | � W n< ttfk
rH } z |jdkr6td| � � W Y dd}~X nX dS )zQSafe flush inject stopping endless logging on closed streams (redirected pipe).
rs N)�__origLogFlushrv rw rx rr )rI rP r
r
r �__safeLogFlush
s
r~ c C s$ d| krd| j d�d } tj| �S )zBGet logging.Logger instance with Fail2Ban logger name convention
r= z fail2ban.%sr rS )�
rpartitionrc � getLogger)�namer
r
r r� s r� c C sT y.t | t�s| j� r t| �}ntt| j� �}W n tk
rN td| ��Y nX |S )NzInvalid log level %r)r" �int�isdigit�getattrrc r �AttributeError�
ValueError)�valueZllr
r
r � str2LogLevel s
r� � %(message)sTc C sn | dkr@| dkrd| }| dkr*d| }qTd| }|rTd| }nd| }|rTd | }|sjt jd
d d � |�}|S )
z(Custom log format for the verbose runs
r r z6 | %(module)15.15s-%(levelno)-2d: %(funcName)-20.20s |r6 zB +%(relativeCreated)5d %(thread)X %(name)-25.25s %(levelname)-5.5sz %(thread)X %(levelname)-5.5sz %(asctime)-15sz)%(name)-24s[%(process)d]: %(levelname)-7sz %(asctime)s z(?<=\))-?\d+(?:\.\d+)?sc S s dS )NrD r
)�mr
r
r rk 8 s z$getVerbosityFormat.<locals>.<lambda>)rY rZ )� verbosityrb ZaddtimeZpaddingr
r
r �getVerbosityFormat& s
r� c C s t d�jddd� tj| ||�S )z>Except hook used to log unhandled exceptions to Fail2Ban log
Zfail2banz Unhandled exception in Fail2Ban:T)r7 )r� Zcriticalr �__excepthook__)�exctyper� rT r
r
r �
excepthook< s
r� c C s( | sg S t ttdd� tjd| �D ���S )z�Helper to split words on any comma, space, or a new line
Returns empty list if input is empty (or None) and filters
out empty entries
c S s g | ] }|j � �qS r
)�strip)r r r
r
r rM K s z splitwords.<locals>.<listcomp>z[ ,
]+)�list�filterr2 rY �split)rD r
r
r �
splitwordsC s r� � z�if 1:
def _merge_dicts(x, y):
"""Helper to merge dicts.
"""
if y:
return {**x, **y}
return x
def _merge_copy_dicts(x, y):
"""Helper to merge dicts to guarantee a copy result (r is never x).
"""
return {**x, **y}
�execc C s | }|r| j � }|j|� |S )zHelper to merge dicts.
)�copy�update)r' �y�rr
r
r � _merge_dicts\ s
r� c C s | j � }|r|j|� |S )zCHelper to merge dicts to guarantee a copy result (r is never x).
)r� r� )r' r� r� r
r
r �_merge_copy_dictsd s
r� z^([^\[]+)(?:\[(.*)\])?\s*$zf\s*([\w\-_\.]+)=(?:"([^"]*)"|\'([^\']*)\'|([^,\]]*))(?:,|\]\s*\[|$|(?P<wrngA>.+))|,?\s*$|(?P<wrngB>.+)zs(?:[^\[\s]+(?:\s*\[\s*(?:[\w\-_\.]+=(?:"[^"]*"|\'[^\']*\'|[^,\]]*)\s*(?:,|\]\s*\[)?\s*)*\])?\s*|\S+)(?=\n\s*|\s+|$)c C s� t j| �}|std��|j� \}}t� }|r�x�tj|�D ]�}|jd�rrtd|jd�|jd�|jd�dd� f ��|jd�r�td|jd�|jd�dd� f ��|jd�}|s�q8d d
� |jd d d
�D �d }|j � ||j � < q8W ||fS )Nzunexpected option syntaxZwrngAz+unexpected syntax at %d after option %r: %sr r � ZwrngBz'expected option, wrong syntax at %d: %sc S s g | ]}|d k r|�qS )Nr
)r r4 r
r
r rM � s z"extractOptions.<locals>.<listcomp>r6 r � )
�
OPTION_CRE�matchr� �groups�dict�OPTION_EXTRACT_CRE�finditer�group�startr� )�optionr� Z option_nameZoptstrZ option_optsZoptmatch�optr� r
r
r �extractOptions| s&
(
r� c C s
t j| �S )N)�OPTION_SPLIT_CRE�findall)r� r
r
r �splitWithOptions� s r� r� z <([^ <>]+)>r c C s� t j}| }t|�}t� }t|d�}i }�x�d} �x�|j� D �]�}
|
|ks:|
|krRq:|rft|j|
��rfq:t||
� } } || �}
|j|
i �}�x|
�r�|
j d�}||kr�|| |
j
� �}
q�||
ks�|j|d�t kr�t d|
||| f ��d}|r�|j|d | �}|dk�r,|j|�}|dk�r,|dk �r,||�}|dk�rF|| |
j
� �}
q�t
|t��sZt|�}| jd| |�} |j|d�d ||< || |
j� �}
q�W | | k�r�|| ��r�|||
< d } t|�t| �k�r�| j� }| ||
< d
| kr:|j|
� q:W | s*P q*W |S ) a| Sort out tag definitions within other tags.
Since v.0.9.2 supports embedded interpolation (see test cases for examples).
so: becomes:
a = 3 a = 3
b = <a>_3 b = 3_3
Parameters
----------
inptags : dict
Dictionary of tags(keys) and their values.
Returns
-------
dict
Dictionary of tags(keys) and their values, with tags
within the values recursively replaced.
�
getRawItemFr zpproperties contain self referencing definitions and cannot be resolved, fail tag: %s, found: %s in %s, value: %sN�?z<%s>r T�<)�TAG_CRE�searchrB r �keys�callabler� r, �getr� �end�MAX_TAG_REPLACE_COUNTr� r" r+ r! r� �idr� �add)ZinptagsZ conditional�ignoreZaddreplZ
tre_searchZtags�doneZ noRecReplZ repCountsZrepFlag�tagr� Zorgvalr� ZrplcZrtag�replr
r
r �substituteRecursiveTags� sh
r� c C s> y,t jdkr| j� } nt| �} tjd| � W n Y nX dS )z�Helper to set real thread name (used for identification and diagnostic purposes).
Side effect: name can be silently truncated to 15 bytes (16 bytes with NTS zero)
r � N)r )r � version_infor- r# �_libcapZprctl)r� r
r
r �prctl_set_th_name s
r� c C s d S )Nr
)r� r
r
r r� s c s< e Zd ZdZe� ZdZ� fdd�Zdd� Zd
dd �Z � Z
S ) � BgServicez{Background servicing
Prevents memory leak on some platforms/python versions,
using forced GC in periodical intervals.
Nc s | j stt| �j| �| _ | j S )N)� _instance�superr� �__new__)�cls)� __class__r
r r� s zBgService.__new__c C s2 d| _ d| _d| _| j| _ttd�r.tjd� d S )Ni���� rK �
set_thresholdr i �)�_BgService__serviceTime�_BgService__periodTime�_BgService__threshold�_BgService__countr �gcr� )rI r
r
r r< $ s
zBgService.__init__Fc
C s� | j d8 _ | r0| j dks,tj� | jk r0dS tjj|�s@dS z6tj� | jk rTdS tj� tj� | j | _| j
| _ dS tjj � X dS )Nr r FT) r� r Ztimer� r� �_mutex�acquirer� Zcollectr� r� �release)rI �force�waitr
r
r �service/ s zBgService.service)FF) r8 r^ r_ r` r r� r� r� r< r� �
__classcell__r
r
)r� r r� s r� )r
r r r )r )r )NN)r� TT)r r� )G�
__author__Z __license__r� Zlocalerc r rY r rT Z threadingr Z
server.mytimer r ZctypesZCDLLr� �getpreferredencodingr �
startswith�stdoutr �allr� r r* r, r r r+ r5 r: rE �objectrF rd ra ro rr rv � NameErrorrw ZLoggerZ_logru r| rm rn r} r~ r� r� r� r� r� �eval�compile�__file__r� r� �DOTALLr� r� r� r� r� r� r� r� r� r� r
r
r
r �<module> s�
"
.
b