🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-06-14 14:29:39 | PHP 8.1.34
📂
/ (Root)
/
usr
/
lib
/
python3.9
/
site-packages
/
fail2ban
/
server
/
__pycache__
📍 /usr/lib/python3.9/site-packages/fail2ban/server/__pycache__
🔄 Refresh
✏️
Editing: observer.cpython-39.pyc
Read Only
a =�*f�D � @ s� d Z dZdZddlZddlmZ ddlmZ ddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZdd lmZ dd lmZ dd lmZ ee�ZG d d � d e�ZG dd� d�Ze� ZdS )zSerg G. Brester (sebres)z"Copyright (c) 2014 Serg G. BresterZGPL� N� )� JailThread)�FailManagerEmpty� )� getLogger)�MyTime)�Utilsc sN e Zd ZdZejd Z� fdd�Zdd� Zdd� Zd d � Z d d � Z d d� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� ZdGd$d%�Z� fd&d'�ZdHd*d+�Zed,d-� �ZdId.d/�ZdJd0d1�Z ed2d3� �Z e j d4d3� �Z ed5d6� �Z d7d8� Z d9d:� Z!d;d<� Z"G d=d>� d>�Z#d?d@� Z$dAdB� Z%dCdD� Z&dEdF� Z'� Z(S )K�ObserverThreada8 Handles observing a database, managing bad ips and ban increment. Parameters ---------- Attributes ---------- daemon ident name status active : bool Control the state of the thread. idle : bool Control the idle state of the thread. sleeptime : int The time the thread sleeps for in the loop. � c sZ t t| �jdd� d| _t�� | _g | _t�� | _ d| _ i | _ d| _ d | _ d| _d| _d S )Nz f2b/observer)�nameT�< Fi )�superr �__init__�idle� threading�RLock� _queue_lock�_queue�Event�_notify� sleeptime�_timers�_paused�_ObserverThread__db�"_ObserverThread__db_purge_interval�daemon��self�� __class__� �</usr/lib/python3.9/site-packages/fail2ban/server/observer.pyr ? s zObserverThread.__init__c C s0 z | j | W S ty* td| ��Y n0 d S )NzInvalid event index : %s�r �KeyError�r �ir r r! � __getitem__T s zObserverThread.__getitem__c C s0 z | j |= W n ty* td| ��Y n0 d S )NzInvalid event index: %sr" r$ r r r! � __delitem__Z s zObserverThread.__delitem__c C s t | j�S �N)�iterr r r r r! �__iter__` s zObserverThread.__iter__c C s t | j�S r( )�lenr r r r r! �__len__c s zObserverThread.__len__c C s dS )NFr )r �otherr r r! �__eq__f s zObserverThread.__eq__c C s t | �S r( )�idr r r r! �__hash__i s zObserverThread.__hash__c G sD | j �|d�}|dur |�� t�|| j|�}|| j |< |�� dS )z�Add a named timer event to queue will start (and wake) in 'starttime' seconds Previous timer event with same name will be canceled and trigger self into queue after new 'starttime' value N)r �get�cancelr �Timer�add�start)r r � starttime�event�tr r r! �add_named_timerl s z ObserverThread.add_named_timerc G s^ t jdurB|rBt�tj| jt �� | t�� | |f�}|�� dS t�|| j |�}|�� dS )zJAdd a timer event to queue will start (and wake) in 'starttime' seconds N) r ZmyTimer r3 r �DEFAULT_SLEEP_INTERVAL� _delayedEvent�timer5 r4 )r r6 r7 r8 r r r! � add_timery s �zObserverThread.add_timerc C sR t �� |kst�� |kr.| jdg|�R � d S t�tj| j|||f�}|�� d S )Nr ) r r< r= r r3 r r: r; r5 )r Z endMyTimeZendTimer7 r8 r r r! r; � s �z ObserverThread._delayedEventc C s | j s| j}|r|�� dS )z1Notify wakeup (sets /and resets/ notify event) N)r r �set)r �nr r r! � pulse_notify� s zObserverThread.pulse_notifyc G s> | j � | j�|� W d � n1 s(0 Y | �� dS )z5Add a event to queue and notify thread to wake up. N)r r �appendr@ �r r7 r r r! r4 � s *zObserverThread.addc G s6 | j � | j�|� W d � n1 s(0 Y dS )z<Add a event to queue without notifying thread to wake up. N)r r rA rB r r r! �add_wn� s zObserverThread.add_wnc G s ||� d S r( r )r �l�argsr r r! � call_lambda� s zObserverThread.call_lambdac C s t �d� | �d| jd� | j| j| j| j| j| j | j dd� dd� d� }�zJ| � d� | j �rzd | _ | j�s0z�d }| j�& t| j�r�| j�d �}W d � n1 s�0 Y |d u r�W �q0|d }t|d �s�|�|�p�t| |�}||d d � � W qd t�y, } z t jd |dd� W Y d }~qdd }~0 0 qd| j}|�rbd| _ |�| j� |�� | j�rxqVqVt � t j � | j sV�qzqVt �dt| j�� d | _W n6 t�y� } z t jd|dd� W Y d }~n d }~0 0 | j� g | _W d � n1 �s�0 Y d| _ dS )z�Main loop for Threading. This function is the main loop of the thread. Returns ------- bool True when the thread exits nicely. zObserver start...�DB_PURGE�db_purgec S s dS �Nr r r r r r! �<lambda>� � z$ObserverThread.run.<locals>.<lambda>c S s dS rI r r r r r! rJ � rK ) �call�db_setrH �is_aliveZ is_activer5 �stop�nop�shutdownrN FNr r �%sT��exc_infoz&Observer stopped, %s events remaining.z Observer stopped after error: %s)!�logSys�infor9 r rF rM rH �isAlive�isActiver5 rO r4 �activer r r r+ r �pop�callabler1 �getattr� Exception�errorr �waitr �clearr< �sleepr r: �is_full)r Z_ObserverThread__methZev�meth�er? r r r! �run� s^ � * ( &&zObserverThread.runc C s dS )NTr r r r r! rW � s zObserverThread.isAliveNc C s | j S r( )rY )r ZfromStrr r r! rX s zObserverThread.isActivec s> | j �$ | js tt| ��� W d � n1 s00 Y d S r( )r rY r r r5 r r r r! r5 s zObserverThread.start� Tc C s� | j r�| jr�t�d|� | j�0 | �d� | j}| j�� d | _W d � n1 sT0 Y | �|�sl|r�|�� d| _ d| _ d | _ n|| _| � t |d��o�| j S dS )Nz-Observer stop ... try to end queue %s secondsrQ FTg �?)rY r rU rV r rC r> � wait_emptyr` r r � wait_idle�minrb )r ZwtimeZ forceQuitr? r r r! rO s $zObserverThread.stopc C s< | j �" t| j�rdndW d � S 1 s.0 Y d S )NTF)r r+ r r r r r! rb # s zObserverThread.is_fullc C s� t �tj� |dur t� � | }| jdurH| �d� | jrH| jrH| � � | jrr|durdt� � |krdqrt �tj� qH| � d� | j S )zWWait observer is running and returns if observer has no more events (queue is empty) NrP g����MbP?) r< ra r r: r r rC rb r r@ rh �r r rd r r r! rg ( s zObserverThread.wait_emptyc C sZ t �tj� | jrdS |dur*t� � | }| jsT|durFt� � |krFqTt �tj� q*| jS )zJWait observer is running and returns if observer idle (observer sleeps) TN)r< ra r r: r r rj r r r! rh < s zObserverThread.wait_idlec C s | j S r( )r r r r r! �pausedJ s zObserverThread.pausedc C s | j |krd S || _ | �� d S r( )r r@ )r �pauser r r! rk N s c C s dS )z/Status of observer to be implemented. [TODO] )� rm r r r r r! �statusW s zObserverThread.statusc C s || _ d S r( )r )r �dbr r r! rM a s zObserverThread.db_setc C s2 t �d� | jd ur | j�� | �d| jd� d S )Nz Purge database event occurredrG rH )rU �debugr �purger9 r r r r r! rH d s zObserverThread.db_purgec C s� |� � r|�d�sdS |�� }|�� }t�d|j|� d}d}d}�z|jj� � }|j } | dur�| � ||�D ]8\}}} t ||� � �}d|dk r�|nd> d d } q�qlt||�}|dur�||kr�t�d|j|||� W dS |dkr�W dS t�d |j|t�|�||||k�rd nd � |jj�||d d �}|�|� ||k�rJ|j�|� W n@ t�y� } z&tjd | t�� tjkd� W Y d} ~ n d} ~ 0 0 dS )z} Notify observer a failure for ip was found Observer will check ip was known (bad) and possibly increase an retry count � incrementNz [%s] Observer: failure found %sr r � r z8[%s] Ignore failure %s before last ban %s < %s, restoredz%[%s] Found %s, bad - %s, %s # -> %s%sz, Banrm TrR rS )rW �getBanTimeExtra�getID�getTimerU rp r �filterZ failManagerZ getMaxRetry�database�getBan�max� getBanCountri rV r �time2strZ addFailure� setBanCountZ performBanr] r^ �getEffectiveLevel�logging�DEBUG) r �jail�ticket�ipZunixTime�banCountZ retryCount� timeOfBanZmaxRetryro � lastBanTimerd r r r! � failureFoundo sD � � zObserverThread.failureFoundc @ s e Zd Zdd� ZdS )zObserverThread.BanTimeIncrc C s || _ || _d S r( )ZTimeZCount)r �banTimer� r r r! r � s z#ObserverThread.BanTimeIncr.__init__N��__name__� __module__� __qualname__r r r r r! � BanTimeIncr� s r� c C s |� � }|d | �||��S )N� evformula)rt r� )r r� r� r� �ber r r! � calcBanTime� s zObserverThread.calcBanTimec C s@ |� � r|js|S |�� }|�� }|}z�|dkr�|�dd�r�|jj|||�dd�d�D ]�\}}} ||�� krz|�|d � t� d|||� |dkr�|d | � ||��}|� |� |� � |kr�t� d |j||t�|�t�|�t�|�f � nd |_ q�qVW n@ t�y: } z&tjd | t�� tjkd � W Y d } ~ n d } ~ 0 0 |S )ztCheck for IP address to increment ban time (if was already banned). Returns ------- float new ban time. r rr F� overalljails)r� r z"IP %s was already banned: %s #, %sr� z/[%s] IP %s is bad: %s # last %s - incr %s to %sTrR rS N)rW rx rt ru r1 ry r{ r} rU rp r� � setBanTimerv rV r r r| � seconds2str�restoredr] r^ r~ r r� ) r r� r� r� r� r� Z orgBanTimer� r� r� rd r r r! � incrBanTime� s2 � � 0zObserverThread.incrBanTimec C s� |j r dS �z6|}|�� }t�d|j||� |dkrh|�� du rh| �|||�}|dks^||krh|�|� |dkr�|�� | }t � |�t � |�f}|t � � k r�t�d|d � W dS nd}||k�r tj d|j||�� g|�R � t�d d |j|||f� | �td td || d ��| j||� |jdu�r@|j �s@|j�||� W n@ t�y� } z&tjd |t�� tjkd� W Y d}~n d}~0 0 dS )�� Notify observer a ban occurred for ip Observer will check ip was known (bad) and possibly increase/prolong a ban time Secondary we will actualize the bans and bips (bad ip) in database Nz [%s] Observer: ban found %s, %s���zIgnore old bantime %sr F)Z permanentZinfinitez$[%s] Increase Ban %s (%d # %s -> %s)rf z [%s] Observer: prolong %s in %sr r rR rS )r� ru rU rp r � getBanTimer� r� rv r r� r| r< Znoticer{ �logr= ri rz � prolongBanrx ZaddBanr] r^ r~ r r� ) r r� r� �btimeZoldbtimer� ZbendtimeZlogtimerd r r r! �banFound� s: ��&zObserverThread.banFoundc C sv z2|� � }|�� }t�d|j||� |j�|� W n> typ } z&tjd|t� � t j kd� W Y d}~n d}~0 0 dS )r� z [%s] Observer: prolong %s, %srR rS N) r� ru rU rp r �actionsZ _prolongBanr] r^ r~ r r� )r r� r� r� r� rd r r r! r� � s zObserverThread.prolongBan)N)rf T)N)N))r� r� r� �__doc__r r: r r& r' r* r, r. r0 r9 r= r; r@ r4 rC rF re rW rX r5 rO �propertyrb rg rh rk �setterrn rM rH r� r� r� r� r� r� � __classcell__r r r r! r ( sN P 2)*r c @ s e Zd Zdd� ZdS )� _Observersc C s d | _ d S r( )ZMainr r r r! r s z_Observers.__init__Nr� r r r r! r� s r� )� __author__Z __copyright__Z __license__r Z jailthreadr Z failmanagerr �osr r< ZdatetimeZmathZjsonZrandom�sysZhelpersr Zmytimer Zutilsr r� rU r r� Z Observersr r r r! �<module> s" 8 h
💾 Save Changes
❌ Cancel