BdoGdZdZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z ddl Z ddlZejdZn #dZYnxYwejat$drVejr8ejj,ejjds ejjaned d Drd aejd krd Zet$[ejd krt$dfdZdZn6t$dfdZejd krdZneZdZdZdZ Gdde!Z"Gddej#Z$de_%d8dZ& e'Z'n #e($re)Z'YnwxYwej*j+Z,dZ-e-ej*_+ej.j/Z0dZ1e1ej._/dZ2dZ3d9d"Z4d#Z5d$Z6ejd%kre7e8d&e9d'nd(Z:d)Z;ej8d*ej<Z=ej8d+ej<Z>ej8d,ej<Z?d-Z@d.ZAd/ZBej8d0ZC d:d3ZDerd4ZEnd5ZEGd6d7e!ZFdS);zr0s/ Z Z!29Q<<: % Z Z Z Z Z Z)LANGUAGELC_ALLLC_CTYPELANGzUTF-8ctj}|dkr|tkrt}t |dsD ddlm}|dd}n0#t$r#tj tt}YnwxYwt |dr| |dSdSdSdS)NASCIIsetdefaultencodingr) load_dynamic_syssys) rgetdefaultencodingupper PREFER_ENChasattrimpr ImportError importlibreloadr)encodingoder__ldms r__resetDefaultEncodingr)8s   &&((#G^^z//1111 4 $, - -****** E&% TT c TTTd())&H%%%%%^11&&s!A44*B! B!strictc t|tr|||S|S#ttf$r |dkr||dcYSwxYwNr*replace) isinstancebytesdecodeUnicodeDecodeErrorUnicodeEncodeErrorxencerrorss r uni_decoder7Ys{#E! 88C  8 0 1###  ((3 " """"#*//.A A ct|tst|S|tdSNr-)r.r/strr0r r4s r uni_stringr=bs3 Au   a&&= *i ( ((rc t|tr|||S|S#ttf$r |dkr||dcYSwxYwr,)r.r;encoder1r2r3s rr7r7gs{#C! 88C  8 0 1###  ((3 " """"#r8ct|tst|S|tdSr:)r.r;r?r r<s rr=r=qs3 Q   q66M ((:y ) ))rcvt|tst|n|dvS)N)1ontrueyes)r.r;boollower)vals r_as_boolrIys4#C-- 1S  yy{{001rcjtjdd\}}|jt|fS)z+ Consistently format exception information N)rexc_info__name__r=)claexcs rformatExceptionInforP~s- LNN2A2 c z#''rc,tj|}|dr |dd}|t ddgvrBtjtj|dz|z}|S)zaCustom function to include directory name if filename is too common Also strip .py at the end z.pyNbase__init__.)r pathbasenameendswithsetdirname)srSs r mbasenamer\s MM% crc$C$ % %%%   "'//!,, - - 3d :$ rc eZdZdZddZdZdS) TraceBackz7Customized traceback to be included in debug messages Fc"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)selfcompresss rrTzTraceBack.__init__s$+$///rcLtjddd}d|D}d|D}|dg}|ddD]O}|d|ddkr |ddxxd |dzz cc<:||Pd d |D}|jre|}t j|j|f}tj d d |}|d krd|t|dz}||_|S)Nd)limitcg|]P}t|dtj|dt |dgQS)rr)r\r rVrZr;r r4s r z&TraceBack.__call__..sX E E E;.sU ' ' 'q qT5 5 5 A$-- $ $6tQqTl 5 5 5rrrz,%s>cNg|]"}t|dd|d#S)r:r)r\ris rrjz&TraceBack.__call__..sD%%%(!oooo 1%%%rz>[^>]*$r z...) traceback extract_stackappendjoinrar rV commonprefixr`resublen) rbftbentries entries_outentrysftb prev_next common_prefixcommon_prefix2s r__call__zTraceBack.__call__s~c***3B3/# E E@C E E E' ' 'G ' ' ''  +qrr{e Ah+b/!$$$OA%%(**u %%#%%% & &$ _97''d(;<<=F9b-88> 4N++,,- -D4; +rN)F)rM __module__ __qualname____doc__rTrrrr^r^sA    rr^ceZdZdZdZdZdS)FormatterWithTraceBackz}Custom formatter which expands %(tb) and %(tbc) with tracebacks TODO: might need locking in case of compressed tracebacks cptjj|g|Rd|i|d|v}t||_dS)Nfmtz%(tbc)s)rc)logging FormatterrTr^_tb)rbrargskwargsrcs rrTzFormatterWithTraceBack.__init__sK Tz!__stopOnIOError..s4rcdSrrrbs rrz!__stopOnIOError..sDr) ryhandlers removeHandlercloser StreamHandlerflush exitOnIOErrorrstderrexit)logSyslogHndlrs r__stopOnIOErrorrs +s6?##+vq)***  <(.00 :4(1+++++ s A??Bc J t||||fi|dS#ttf$r }|jdkrt |d}~wt $rU} d|t |ffdd|DfffD]} t||g|R#YxYwn#Yn xYwYd}~dSYd}~dSd}~wwxYw)aSafe 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,g|]}t|Sr)r=)r as rrjz__safeLog..s111qZ]]111r) __origLogBrokenPipeErrorIOErrorerrnor Exceptionr=)rblevelmsgrrrms r __safeLogrs0 D%d--f----- '"W]]4    !Z__!5611D11134  t tU"T"""""  T 4      44444 sJB"A B"$B 3BB BB  B B BB"c t|dS#ttf$r!}|jdkrt d|d}~wwxYw)zQSafe flush inject stopping endless logging on closed streams (redirected pipe). rN)__origLogFlushrrrr)rbrms r__safeLogFlushr s] '"W]]4sAAAcnd|vrd|ddz}tj|S)zBGet logging.Logger instance with Fail2Ban logger name convention rUz fail2ban.%srn) rpartitionr getLoggernames rrrs94KK --b1 1$$rc  t|ts|rt|}n'tt|}n #t $rtd|zwxYw|S)NzInvalid log level %r)r.intisdigitgetattrrrAttributeError ValueError)valuells r str2LogLevelrs3s(u}}( E 22''2333)E12223 s A A##B %(message)sTc|dkr$|dkrd|z}|dkrd|z}nd|z}|rd|z}n d|z}|rd |z}|stjd d |}|S) z(Custom log format for the verbose runs rrz6 | %(module)15.15s-%(levelno)-2d: %(funcName)-20.20s |rKzB +%(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+)?scdS)Nr[r)ms rrz$getVerbosityFormat..8sSr)rwrx) verbosityraddtimepaddings rgetVerbosityFormatr&sMM]] AC G3]] MPS S33 (3 .3 " c !C3c9#  # 3? )==#>># rcvtdddtj|||S)z>Except hook used to log unhandled exceptions to Fail2Ban log fail2banz Unhandled exception in Fail2Ban:T)rL)rcriticalr__excepthook__)exctyperrrs r excepthookr<sC :$t 555 7E9555rc |sgStttdtjd|DS)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 c6g|]}|Sr)stripr s rrjzsplitwords..Ks EEE17799EEErz[ , ]+)listfilterrFrwsplit)r[s r splitwordsrCsD  ) VDEEbhy!.D.DEEE F FGGGr)rzif 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`|}|r)|}|||S)zHelper to merge dicts. copyupdater4yrs r _merge_dictsr\s2!vvxx188A;;; (rc\|}|r|||S)zCHelper to merge dicts to guarantee a copy result (r is never x). rrs r_merge_copy_dictsrds-ffhh!88A;;; (rz^([^\[]+)(?:\[(.*)\])?\s*$zf\s*([\w\-_\.]+)=(?:"([^"]*)"|\'([^\']*)\'|([^,\]]*))(?:,|\]\s*\[|$|(?P.+))|,?\s*$|(?P.+)zs(?:[^\[\s]+(?:\s*\[\s*(?:[\w\-_\.]+=(?:"[^"]*"|\'[^\']*\'|[^,\]]*)\s*(?:,|\]\s*\[)?\s*)*\])?\s*|\S+)(?=\n\s*|\s+|$)c Bt|}|std|\}}t }|rIt |D]-}|drVtd|d|d|dddfz|drBtd|d|dddfz|d}|sd |d d d Dd}| || </||fS) Nzunexpected option syntaxwrngAz+unexpected syntax at %d after option %r: %srrwrngBz'expected option, wrong syntax at %d: %scg|]}||Srr)r rHs rrjz"extractOptions..s  = = = COCOOOrrKr) OPTION_CREmatchrgroupsdictOPTION_EXTRACT_CREfinditergroupstartr)optionr option_nameoptstr option_optsoptmatchoptrs rextractOptionsr|s   & ! ! /-...||~~fvv ,$--f55 , ,hnnWQ B ^^GhnnQ//1H1H21NFPP Q QQnnW> > ^^GhnnW55ad;B== > >>   3 x = =>>!Aa(( = = ==> @5#kkmm;syy{{[  rc6t|Sr)OPTION_SPLIT_CREfindall)rs rsplitWithOptionsrs  (((rrz <([^ <>]+)>r rc tj}|}t|}t}t|d}i} d} |D].} | |vs| |vr |r#t || r1t|| x} } || } || i}| rX| d}||vr|| | } ;|| ks||dtkrtd| d|d|d| d }|r||d z|z}|$||}| | ||}||| | } t|tst|}| d |z|} ||d dz||<|| | } | X| | krK|| r||| <d} t#|t#|kr|}| || <d | vr|| 0| snK|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 = _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. getRawItemTFrzRproperties contain self referencing definitions and cannot be resolved, fail tag: z , found: z in z , value: N?z<%s>r<)TAG_CREsearchrYr!keyscallablerr=getrendMAX_TAG_REPLACE_COUNTrr.r;r-ridradd)inptags conditionalignoreaddrepl tre_searchtagsdone noRecRepl repCountsrepFlagtagrorgvalrrplcrtagrepls rsubstituteRecursiveTagsrs,n f++  T< ( ( A ' YY[[;&;&c Vmmsd{{HrNs(L   !!!!!! 6;} % % )V ( * *  !!J3:&23:;N;Y;YZa;b;b2z"** c Z Z/Y Z Z Z[[* d&&&  ###t!(####)))) "(####C""$$//**** *111 (((    ++++++++\ 0 0 0 0 0W. 0 0 0    " N  < &,-          ,666HHHugg             RZ5ry A A  RZjlnluww2:wy{zCDD!!!*))) "*^ $ $13` ` ` ` F     ,,,,,,,,,,sAA 4E77FF