a
=Æ*fÕ? ã @ sR d Z dZdZddlZddlZddlmZmZ ddlm Z ee
ƒZ G dd „ d ƒZ dS )
z
Cyril Jaquierz Copyright (c) 2004 Cyril JaquierZGPLé Né )Ú getLoggerÚlogging)Úversionc @ s> e Zd Zdd„ Zdd„ Zdd„ Zddd „Zd
d „ Zd d
„ ZdS )Ú Transmitterc C s || _ d| _d S )Nr )Ú_Transmitter__serverÚ_Transmitter__quiet)ÚselfZserver© r
ú?/usr/lib/python3.9/site-packages/fail2ban/server/transmitter.pyÚ__init__, s zTransmitter.__init__c
C sr t dd|¡ z| |¡}d|f}W nH tyl } z0t jd||t ¡ tjkd d|f}W Y d }~n
d }~0 0 |S )Né z Command: %rr z"Command %r has failed. Received %r)Úexc_infoé )ÚlogSysÚlogÚ _Transmitter__commandHandlerÚ ExceptionÚerrorZgetEffectiveLevelr ÚDEBUG)r ÚcommandÚretZackÚer
r
r Úproceed6 s
þ zTransmitter.proceedc
C sF |d }|dkrdS |dkrp|d }|dkr:t d|f ƒ‚z |d }W n ty\ d }Y n0 | j ||¡ |S |d
krŒ| |dd … d ¡S |d kr¦| |dd … ¡S |d
krÆ|d }| j |¡ d S |dkrt|ƒdkrè| j ¡ n.|d dkr| j ¡ n|d }| j |¡ d S |dkrž|dd… }d| _
zH| jj |dd iŽ |d D ]}| |¡ qRW d| _
| jj |ddiŽ nd| _
| jj |ddiŽ 0 dS |dkröt|ƒdkrö|dd … }t|ƒdkrè|d dkrè| j
¡ S | j
d |¡S |dkr| j d |dd … ¡S |dkr,|dd … S |dkrDt d¡ dS |dkr†d| _
z$|d D ]}| |¡ q^W d| _
nd| _
0 d S |dkrª|d }t t|ƒ¡ d S |d kr¾| j ¡ S |d krÚ| |dd … ¡S |d krö| |dd … ¡S |d v r| j dd ¡S |d!kr tjS |d"kr:t |d ¡ d S t d#ƒ‚d S )$Nr ZpingZpongÚaddr ú--allzReserved name %rr Úautoz multi-setTÚsetÚstartÚstopÚreloadé ZbeginFZOKZunbanÚbannedZechoz
server-statusz
Status: readyz Server readyz
server-streamÚsleepZ flushlogsÚgetÚstatus)ÚstatsZ statisticZ
statisticsr& r z config-errorzInvalid command)r Ú
IndexErrorr ZaddJailÚ_Transmitter__commandSetZ startJailÚlenÚquitZ stopAllJailZstopJailr Z reloadJailsr Ú
setUnbanIPr" r ÚdebugÚtimer# ÚfloatZ flushLogsÚ_Transmitter__commandGetr% r r )r r ÚnameZbackendZoptsÚcmdÚvaluer
r
r Z__commandHandlerH sœ
ÿ
z Transmitter.__commandHandlerFc C sJ |d }|dkr8|d }| j |¡ | jr.d S | j ¡ S |dkrt|d }| j |¡rh| jr^d S | j ¡ S tdƒ‚
nÀ|dkr°|d }| j |¡r¤| jršd S | j ¡ S tdƒ‚
n„|dkrÚ|d }| j |¡ | jrÖd S |S |d k rø|d }| j
|¡S |d
kr@| j |d ¡ | j ¡ }|d u r*d S | jr6d S |j
S nô|d kr”| j ¡ }|d u rpt tjd ¡ d S t|d ƒ|_| jrŠd S |jS n |d
krä| j ¡ }|d u rÄt tjd¡ d S |d |_| jrÚd S |jS nP|d dkrN|d dkr| j |d¡ n&|d dkr.| j |d¡ ntdƒ‚| jrBd S | j |¡S |d dkrŠ|d }| j ||¡ | jr~d S | j |¡S |d dkrÒ|dd … D ]}| j ||¡ q¤| jrÆd S | j |¡S |d dkr|d }| j ||¡ | jrd S | j |¡S |d dkrJ|d }| j ||¡ | jr>d S | j |¡S |d dkr†|d }| j ||¡ | jrzd S | j |¡S |d dkr |d }d}t |ƒd krâ|d !¡ d krÆd}n|d !¡ d krøt"d ƒ‚nt |ƒd krøt"d!ƒ‚| j #|||¡ | jrd S | j $|¡S |d d"kr\|d }| j %||¡ | jrPd S | j $|¡S |d d#kr˜|d }| j &||¡ | jrŒd S | j '|¡S |d d$krØ|dd … }| j (||¡ | jrÌd S | j )|¡S |d d%kr|dd … }| j *||¡ | jr d S | j )|¡S |d d&krf|d }| j +||¡ | jrHd S | j ,|¡}|rb| -¡ S d'S |d d(kr°|d }| j j.|||d) |r˜dS | jr¤d S | j /|¡S |d d*krðt|d ƒ}| j 0||¡ | jräd S | j /|¡S |d d+kr:|d }| j j1|||d) |r"dS | jr.d S | j 2|¡S |d d,krzt|d ƒ}| j 3||¡ | jrnd S | j 2|¡S |d d-kr¶|d }| j 4||¡ | jrªd S | j 5|¡S |d d.krò|d }| j 6||¡ | jræd S | j 7|¡S |d d/kr.|d }| j 8||¡ | jr"d S | j 9|¡S |d d0krj|d }| j :||¡ | jr^d S | j ;|¡S |d d1krª|d }| j <|t|ƒ¡ | jržd S | j =|¡S |d d2krê|d }| j >|t|ƒ¡ | jrÞd S | j ?|¡S |d d3kr*|d }| j @|t|ƒ¡ | jr d S | j A|¡S |d d4krf|d }| j B||¡ | jrZd S | j C|¡S |d d5kr |dd … }| jrŒd S | j jD|g|¢R Ž S |d Ed6¡rö|d }|d t d6ƒd … }| j F|||¡ | jrèd S | j G||¡S |d d7k r |dd … }| j H||¡S |d d8k rnd} |d d9k rL|dd … }nd} |d d … }| j jI||| d:S |d d;k rØ|d g}
t |ƒd k r°|
J|d tK L|d ¡g¡ | j jM|g|
¢R Ž | j rÐd S |
d S |d dd?|
¡ |
d }tPtQ| |d ƒƒ
r”t |
ƒdk
rztK L|
d ¡ni }tQ| |ƒf i |¤Ž n|
d }tR| ||ƒ
q2dS |d }tPtQ| |d ƒƒ r
t |ƒd k
rætK L|d ¡ni }| j
röd S tQ| |ƒf i |¤ŽS |d }tR| ||ƒ | j r*d S tQ| |ƒS td@|d f ƒ‚d S )ANr Úloglevelr Ú logtargetzFailed to change log targetÚ syslogsocketz Failed to change syslog socketZ allowipv6ÚthreadÚdbfileÚ dbmaxmatchesz6dbmaxmatches setting was not in effect since no db yetÚ
dbpurgeagez4dbpurgeage setting was not in effect since no db yetZidler ZonTZoffFz*Invalid idle option, must be 'on' or 'off'Ú
ignoreselfZ addignoreipZ delignoreipÚ
ignorecommandÚ ignorecacheZ
addlogpathé r! ÚtailÚheadz$File option must be 'head' or 'tail'z$Only one file can be added at a timeZ
dellogpathÚ logencodingZaddjournalmatchZdeljournalmatchÚ prefregexÚ Z addfailregex)ÚmultipleZ delfailregexZaddignoreregexZdelignoreregexÚusednsÚfindtimeÚ datepatternÚ logtimezoneÚ
maxmatchesÚmaxretryÚmaxlinesÚbantimeZattemptúbantime.ÚbanipZunbanipz--report-absent)ÚifexistsZ addactionZ delactionÚactionr
z %rz9Invalid command %r (no set action or not yet implemented))Sr Z setLogLevelr Ú getLogLevelZ setLogTargetÚ getLogTargetr ZsetSyslogSocketÚgetSyslogSocketZsetIPv6IsAllowedZsetThreadOptionsZ setDatabaseÚ getDatabaseÚfilenamer r r ZMSGÚintÚ
maxMatchesÚpurgeageZ setIdleJailZ getIdleJailZ
setIgnoreSelfÚ
getIgnoreSelfZ addIgnoreIPÚ getIgnoreIPZ delIgnoreIPZsetIgnoreCommandÚgetIgnoreCommandZsetIgnoreCacheÚgetIgnoreCacher) ÚlowerÚ
ValueErrorZ
addLogPathÚ
getLogPathZ
delLogPathZsetLogEncodingÚgetLogEncodingZaddJournalMatchÚgetJournalMatchZdelJournalMatchZ setPrefRegexÚ getPrefRegexÚgetRegexZ addFailRegexÚ getFailRegexZ delFailRegexZaddIgnoreRegexÚgetIgnoreRegexZdelIgnoreRegexZ setUseDnsÚ getUseDnsZ setFindTimeÚ getFindTimeZsetDatePatternÚgetDatePatternZsetLogTimeZoneÚgetLogTimeZoneZ
setMaxMatchesÚ
getMaxMatchesZ setMaxRetryÚ getMaxRetryZ setMaxLinesÚ getMaxLinesZ
setBanTimeÚ
getBanTimeZ addAttemptIPÚ
startswithZsetBanTimeExtraÚgetBanTimeExtraZsetBanIPr+ ÚextendÚjsonÚloadsZ addActionZ delActionÚ getActionÚcallableÚgetattrÚsetattr)r r rC r0 r2 Údbr> ÚvÚoptrN ÚargsÚ
actionnamerO r1 Z actionkeyÚ actionvaluer
r
r Z __commandSetœ sÞ
zTransmitter.__commandSetc s |d }|dkr| j ¡ S |dkr,| j ¡ S |dkr>| j ¡ S |dkrP| j ¡ S |dkrx| j ¡ }|d u rnd S |jS nŒ|dkr | j ¡ }|d u r–d S |jS nd|dkrÈ| j ¡ }|d u r¾d S |jS n<|d d
k rì| j ||d d … ¡S |d d kr| j
|¡S |d d
kr | j |¡S |d dkr:| j |¡S |d dkrT| j
|¡S |d dkrn| j |¡S |d dkrˆ| j |¡S |d dkr¢| j |¡S |d dkrÎ| j |¡}|rÊ| ¡ S dS |d dkrè| j |¡S |d dkr| j |¡S |d dkr | j |¡S |d dkr6| j |¡S |d dkrP| j |¡S |d dkrj| j |¡S |d dkr„| j |¡S |d d krž| j |¡S |d d kr¸| j |¡S |d d krÒ| j |¡S |d d kr| j j |t |ƒd ko |d d kd!S |d d"¡r8|d t d"ƒd … }| j ||¡S |d d#krZt!| j "|¡ #¡ ƒS |d d$kr|d }|d% }| j $||¡‰ t%ˆ |ƒS |d d&krÊ|d }| j $||¡‰ ‡ fd'd(„t&ˆ ƒD ƒS |d d)kr|d }| j $||¡‰ ‡ fd*d(„t&ˆ ƒD ƒS t'd+ƒ‚d S ),Nr r3 r4 r5 r6 r7 r8 r9 r r" r Zlogpathr@ Z journalmatchr: Zignoreipr; r< rA rB Z failregexZ ignoreregexrD rE rF rG rH rI rJ rK rM z --with-time)ZwithTimerL ÚactionsrO r! Zactionpropertiesc s( g | ] }| d ¡sttˆ |ƒƒs|‘qS ©Ú_©rm rs rt ©Ú.0Úkey©rO r
r Ú
ö s
þz,Transmitter.__commandGet..Z
actionmethodsc s( g | ] }| d ¡sttˆ |ƒƒr|‘qS r} r r€ rƒ r
r r„ ý s ÿz6Invalid command (no get action or not yet implemented))(r rP rQ rR ZgetThreadOptionsrS rT rV rW r" r^ r_ r` rX rY rZ r[ ra rb rc rd re rf rg rh ri rj rk rl Z
getBanListr) rm rn ÚlistZ
getActionsÚkeysrr rt Údirr )r r r0 rv rw rx rz r{ r
rƒ r Z __commandGet s´
ÿ
ÿ
ÿzTransmitter.__commandGetc C s€ t |ƒdkr| j ¡ S t |ƒdkrtt |ƒdkrt|d }t |ƒdkrJ|d nd}|dkrd| j d|¡S | jj||dS tdƒ‚d S )Nr r r Zbasicr )ÚflavorzInvalid command (no status))r) r r% Z
statusJailr )r r r0 rˆ r
r
r r% s
zTransmitter.statusN)F) Ú__name__Ú
__module__Ú __qualname__r r r r( r/ r% r
r
r
r r % s
T
er )
Ú
__author__Z
__copyright__Z __license__r- rp Zhelpersr r rB r r‰ r r r
r
r
r Ú s