⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.72
Server IP:
41.128.143.86
Server:
Linux host.raqmix.cloud 6.8.0-1025-azure #30~22.04.1-Ubuntu SMP Wed Mar 12 15:28:20 UTC 2025 x86_64
Server Software:
Apache
PHP Version:
8.3.23
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3
/
dist-packages
/
fail2ban
/
__pycache__
/
View File Name :
helpers.cpython-310.pyc
o }E]l @ s* d Z dZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl Z z ddlZedZW n dZY e Zedrkejr`ejjdur`ejjds`ejjZn ed d d D rkd Zed fddZdd Zdd Zdd Zdd Zdd Z G dd de Z G d d d ej Z d e_!dGd d Z"ej#j$Z%d!d" Z&e&ej#_$ej'j(Z)d#d$ Z*e*ej'_(d%d& Z+d'd( Z,dHd+d,Z-d-d. Z.d/d0 Z/d1d2 Z0d3d4 Z1e2d5ej3Z4e2d6ej3Z5e2d7ej3Z6d8d9 Z7d:d; Z8d<Z9e2d=Z: > dId@dAZ;erdBdC Z<ndDdC Z<G dEdF dFe Z=dS )Jz<Cyril Jaquier, Arturo 'Buanzo' Busleiman, Yaroslav HalchenkoGPL N)Lock )MyTimez libcap.so.2ANSI_c c s | ] }t |d v V qdS ))N N)osgetenv.0v r 2/usr/lib/python3/dist-packages/fail2ban/helpers.py <genexpr>0 s r )LANGUAGELC_ALLLC_CTYPELANGUTF-8strictc C sL zt | tr | ||W S | W S ttfy% |dkr | |d Y S w )Nr replace) isinstancebytesdecodeUnicodeDecodeErrorUnicodeEncodeError)xencerrorsr r r uni_decode@ s r c C s t | ts t| S | tdS )Nr )r r strr PREFER_ENCr r r r uni_stringI s r# c C s t | dS )Nr )r r" r r r uni_bytesM r$ c C s t | ts t| S | dv S )N)1ontrueyes)r r boollower)valr r r _as_boolP s r- c C s" t dd \} }| jt|fS )z+ Consistently format exception information N )sysexc_info__name__r# )claexcr r r formatExceptionInfoU s r4 c C sR t j| }|dr|dd }|tddgv r't jt j| d | }|S )zaCustom function to include directory name if filename is too common Also strip .py at the end z.pyNbase__init__.)r pathbasenameendswithsetdirname)sr6 r r r mbasenamea s r? c @ s" e Zd ZdZdddZdd ZdS ) TraceBackz7Customized traceback to be included in debug messages Fc C s d| _ || _dS )zInitialize TrackBack metric Parameters ---------- compress : bool if True then prefix common with previous invocation gets replaced with ... r N)_TraceBack__prev_TraceBack__compress)selfcompressr r r r7 r s zTraceBack.__init__c C s t jddd d }dd |D }dd |D }|d g}|dd D ] }|d |d d kr>|d d d |d 7 < q#|| q#d d d |D }| jrt|}tj| j|f}t d d|}|dkrqd|t |d }|| _|S )Nd )limitc S s2 g | ]}t |d tj|d t|d gqS )r r )r? r r9 r= r r r r r r <listcomp> s &z&TraceBack.__call__.<locals>.<listcomp>c S s6 g | ]}|d dv s|d ds|d |d gqS )r )unittestzlogging.__init__r z /unittestr. )r; )r er r r rI s r r z,%s>c S s$ g | ]}d t |d |d f qS )z%s:%sr r )r? rH r r r rI s z>[^>]*$r z...) traceback extract_stackappendjoinrB r r9 commonprefixrA resublen) rC ftbentries entries_outentrysftb prev_next common_prefixcommon_prefix2r r r __call__~ s* zTraceBack.__call__N)F)r1 __module__ __qualname____doc__r7 r^ r r r r r@ n s r@ 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 s6 t jj| g|R d|i| d|v }t|d| _d S )Nfmtz%(tbc)s)rD )logging Formatterr7 r@ _tb)rC rc argskwargsrD r r r r7 s z FormatterWithTraceBack.__init__c C s | |_|_tj| |S N)rf tbctbrd re format)rC recordr r r rl s z FormatterWithTraceBack.formatN)r1 r_ r` ra r7 rl r r r r rb s rb Fc C sh | rt | jr| | jd |rdd |_dd tj_tjr2ztj W n Y t d d S d S )Nr c S d S ri r r r r r <lambda> z!__stopOnIOError.<locals>.<lambda>c S rn ri r rC r r r ro rp ) rU handlers removeHandlercloserd StreamHandlerflush exitOnIOErrorr/ stderrexit)logSyslogHndlrr r r __stopOnIOError s r| c K s zt | |||fi | W dS ttfy& } z |jdkr!t| d}~w tyk } z:z'd|t|ffddd |D fffD ]}z t | |g|R W q@ Y q@W n Y W Y d}~dS W Y d}~dS d}~ww )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 rI z __safeLog.<locals>.<listcomp>) __origLogBrokenPipeErrorIOErrorerrnor| Exceptionr# )rC levelmsgrg rh rK r r r __safeLog s, r c C sB zt | W dS ttfy } z |jdkrtd| d}~ww )zQSafe flush inject stopping endless logging on closed streams (redirected pipe). r} N)__origLogFlushr r r r| )rC rK r r r __safeLogFlush s r c C s$ d| v r d| dd } t| S )zBGet logging.Logger instance with Fail2Ban logger name convention r8 z fail2ban.%srL ) rpartitionrd getLoggernamer r r r s r c C sP zt | ts | rt| }W |S tt| }W |S ty' td| w )NzInvalid log level %r)r intisdigitgetattrrd upperAttributeError ValueError)valuellr r r str2LogLevel s r %(message)sTc C sn | dkr | dkr d| }| dkrd| }nd| }|r d| }n d| }|r*d | }|s5t d d d |}|S ) z(Custom log format for the verbose runs r z6 | %(module)15.15s-%(levelno)-2d: %(funcName)-20.20s |r. 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 )Nr> r )mr r r ro rp z$getVerbosityFormat.<locals>.<lambda>)rS rT ) verbosityrc addtimepaddingr r r getVerbosityFormat s r c C s t djddd t| ||S )z>Except hook used to log unhandled exceptions to Fail2Ban log fail2banz Unhandled exception in Fail2Ban:T)r0 )r criticalr/ __excepthook__)exctyper rN r r r excepthook s r c C s( | sg S t ttdd td| D S )zHelper 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 | ]}| qS r )stripr r r r rI r z splitwords.<locals>.<listcomp>z[\s,]+)listfilterr* rS split)r> r r r splitwords s r c C s |ri | |S | S )zHelper to merge dicts. r r yr r r _merge_dicts s r c C s i | |S )zBHelper to merge dicts to guarantee a copy result (r is never x). r r r r r _merge_copy_dicts& 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 | }|s td| \}}t }|rnt|D ]R}|dr8td|d|d|ddd f |drOtd|d|ddd f |d}|sWqd d |d d d D d }| || < q||fS )Nzunexpected option syntaxwrngAz+unexpected syntax at %d after option %r: %sr r wrngBz'expected option, wrong syntax at %d: %sc S s g | ]}|d ur|qS ri r )r r, r r r rI K s z"extractOptions.<locals>.<listcomp>r. r ) OPTION_CREmatchr groupsdictOPTION_EXTRACT_CREfinditergroupstartr )optionr option_nameoptstr option_optsoptmatchoptr r r r extractOptions; s0 r c C s t | S ri )OPTION_SPLIT_CREfindall)r r r r splitWithOptionsP r% r r z <([^ <>]+)>r r c C s t j}| }t|}t }t|d}i } d} | D ]} | |v s$| |v r%q|r/t|| r/qt|| } } || } || i }| r| d}||v rT|| | } qA|| ks`||dt krjt d| ||| f d}|rw||d | }|du r||}|du r|dur||}|du r|| | } qAt |tst|}| d| |} ||d d ||< || | } | sC| | kr|| r||| < d} t|t| kr| }| || < d | vr|| q| s |S q) 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. getRawItemTFr zpproperties contain self referencing definitions and cannot be resolved, fail tag: %s, found: %s in %s, value: %sN?z<%s>r <)TAG_CREsearchr< hasattrkeyscallabler r# getr endMAX_TAG_REPLACE_COUNTr r r r r idcopyadd)inptags conditionalignoreaddrepl tre_searchtagsdone noRecRepl repCountsrepFlagtagr orgvalr rplcrtagreplr r r substituteRecursiveTags^ sj 'r c C s( z | } td| W dS Y dS )zHelper 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) N)encode_libcapprctlr r r r prctl_set_th_name s r c C rn ri r r r r r r s c s< e Zd ZdZe ZdZ fddZdd 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 s tt| | | _ | j S ri ) _instancesuperr __new__)cls __class__r r r s zBgService.__new__c C s6 d| _ d| _d| _| j| _ttdrtd d S d S )Ni rE set_thresholdr )_BgService__serviceTime_BgService__periodTime_BgService__threshold_BgService__countr gcr rq r r r r7 s zBgService.__init__Fc C s | j d8 _ |s| j dkst | jk rdS tj|s dS z't | jk r/W tj dS t t | j | _| j | _ W tj dS tj w )Nr r FT) r r timer r _mutexacquirereleaser collectr r )rC forcewaitr r r service s zBgService.service)FF) r1 r_ r` ra r r r r r7 r __classcell__r r r r r s r )NN)r TT)r r N)> __author__ __license__r localerd r rS r/ rN threadingr server.mytimer importlibctypesCDLLr getpreferredencodingr! startswithstdoutencodingallr r# r$ r- r4 r? objectr@ re rb rw r| Logger_logr r ru rv r r r r r r r r r compileDOTALLr r r r r r r r r r r r r r <module> s . c