=*f>nSrSrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK J r SSK J r SSK r SSKr\R"S5r\R""5r\R'S5(a\R((aX\R(R*bA\R(R*R'S5(d\R(R*rO\"S S 55(aS r\S 4S jrSrSrSrSrSr"SS\5r"SS\R>5r S\l!S.Sjr"\RFRHr%Sr&\&\RFl$\RNRPr)Sr*\*\RNl(Sr+Sr,S/Sjr-Sr.Sr/S r0S!r1\Rd"S"\Rf5r4\Rd"S#\Rf5r5\Rd"S$\Rf5r6S%r7S&r8S'r9\Rd"S(5r:S0S)jr;\(aS*rr0s Z/Y!299Q<: %/Ys&()LANGUAGELC_ALLLC_CTYPELANGUTF-8strictc[U[5(aURX5$U$![[4a US:waeURUS5s$f=f)Nrreplace) isinstancebytesdecodeUnicodeDecodeErrorUnicodeEncodeError)xencerrorss r uni_decoder @sY"5 ((3  ( /0" x #y !!"s%**)AAcn[U[5(d [U5$UR[S5$)Nr)rrstrr PREFER_ENCrs r uni_stringr%Is)1e Q- Y''c[US5$)Nr)rr$s r uni_bytesr(Ms ar&ch[U[5(d [U5$UR5S;$)N)1ontrueyes)rr"boollower)vals r_as_boolr1Ps.#C--S 1 yy{001r&cd[R"5SSupUR[U54$)z*Consistently format exception information N)sysexc_info__name__r%)claexcs rformatExceptionInfor9Us) LLN2A  z#''r&c [RRU5nURS5(aUSSnU[ SS/5;aB[RR[RR U55S-U-nU$)z_Custom function to include directory name if filename is too common Also strip .py at the end z.pyNbase__init__.)r pathbasenameendswithsetdirname)sr<s r mbasenamerEast MM% cr$C$ %%   "''//!, - 3d :$ r&c(\rSrSrSrSSjrSrSrg) TraceBacknz>Customized traceback to be included in debug messages cSUlXlg)zInitialize TrackBack metric Parameters ---------- compress : bool if True then prefix common with previous invocation gets replaced with ... r N)_TraceBack__prev_TraceBack__compress)selfcompresss rr=TraceBack.__init__rs$+/r&c V[R"SS9SSnUVs/sH@n[US5[RR US5[ US5/PMB nnUVs/sH3nUSS;aMUSRS5(aM)USUS/PM5 nnUS/nUSSH;nUSUS S:XaUS S==S US-- ss'M*URU5 M= S RUVs/sHn[US5<S US<3PM sn5nUR(abUn[RRURU45n [R"S SU 5n U S:waSU[U 5S-nXl U$s snfs snfs snf)Nd)limitrr)unittestzlogging.__init__z /unittestr3z,%s>:z>[^>]*$r z...) traceback extract_stackrEr r?rCr"rAappendjoinrK commonprefixrJresublen) rLftbrentriese entries_outentrysftb prev_next common_prefixcommon_prefix2s r__call__TraceBack.__call__~sc*3B/#@C E@C1IadORWW__QqT*C!I6  E$+ 'Gq qT5 5 A$-- $qtQqTlG' '  +qr{e Ah+b/!$$OA%%(**u  #%#1(!o 1#% &$ __977''d(;<=FF9b-8> 4N+,- -D; +3 E '%sAF) F!:F!F!>"F&) __compress__prevN)F)r6 __module__ __qualname____firstlineno____doc__r=rh__static_attributes__r&rrGrGns r&rGc$\rSrSrSrSrSrSrg)FormatterWithTraceBackz{Custom formatter which expands %(tb) and %(tbc) with tracebacks TODO: might need locking in case of compressed tracebacks cv[RR"U/UQ7SU0UD6 SU;n[US9Ulg)Nfmtz%(tbc)s)rM)logging Formatterr=rG_tb)rLrvargskwargsrMs rr=FormatterWithTraceBack.__init__s; T!__stopOnIOError..s4r&cgr~rqrLs rrrsDr&) r^handlers removeHandlercloserw StreamHandlerflush exitOnIOErrorr4stderrexit)logSyslogHndlrs r__stopOnIOErrorrs| s6??##vq)* (.0 ::((1+ s ;B11B5c d[XX#40UD6 g![[4a!nURS:Xa [ U5 eSnAf[ afnSU[ U544SUVs/sHn[ U5PM Os snfsn444Hn[X/UQ76 M! M=f SnAg! SnAg=fSnAff=f)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: %r) __origLogBrokenPipeErrorIOErrorerrnor Exceptionr%)rLlevelmsgrzr{raas r __safeLogrs D-f- '"WW]4  !Z_!56D1DqZ]D134t t"T"   sT B/< B/ BA3 2B BBBBB'!B*'B**B/c[U5 g![[4a"nURS:Xa [ SU5 eSnAff=f)zXSafe flush inject stopping endless logging on closed streams (redirected pipe). rN)__origLogFlushrrrr)rLras r__safeLogFlushrs< '"WW]4s A;AchSU;aSURS5S-n[R"U5$)zIGet logging.Logger instance with Fail2Ban logger name convention r>z fail2ban.%srT) rpartitionrw getLoggernames rrrs44K -b1 1$$r&c[U[5(dUR5(a [U5nU$[[UR 55nU$![ a [SU-5ef=f)NzInvalid log level %r)rintisdigitgetattrrwupperAttributeError ValueError)valuells r str2LogLevelrsk3su}} E 2  '2  3)E1223s5AAA3cUS:a)US:aSU-nUS:aSU-nO#SU-nU(aSU-nOSU-nU(aS U-nU(d[R"S S U5nU$) z/Custom log format for the verbose runs rz6 | %(module)15.15s-%(levelno)-2d: %(funcName)-20.20s |r3zB +%(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+)?scg)NrDrq)ms rr$getVerbosityFormat.. sSr&)r\r]) verbosityrvaddtimepaddings rgetVerbosityFormatrsxM] AC G3] MPS S3 (3 .3 c !C3c9# # 3 )=#># r&cb[S5RSSS9 [R"XU5$)zEExcept hook used to log unhandled exceptions to Fail2Ban log fail2banz Unhandled exception in Fail2Ban:T)r5)rcriticalr4__excepthook__)exctyperrWs r excepthookrs4 :$t 5 7955r&c U(d/$[[[[R"SU5Vs/sHoR 5PM sn55$s snf)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 z[\s,]+)listfilterr.r\splitstrip)rDr s r splitwordsrsA ) VDbhhy!.DE.D779.DE FGGEsAc U(a0UEUE$U$)zHelper to merge dicts. rqrys r _merge_dictsrs A r&c0UEUE$)zIHelper to merge dicts to guarantee a copy result (r is never x). rqrs r_merge_copy_dictsr&s 1  r&z^([^\[]+)(?:\[(.*)\])?\s*$zf\s*([\w\-_\.]+)=(?:"([^"]*)"|\'([^\']*)\'|([^,\]]*))(?:,|\]\s*\[|$|(?P.+))|,?\s*$|(?P.+)zs(?:[^\[\s]+(?:\s*\[\s*(?:[\w\-_\.]+=(?:"[^"]*"|\'[^\']*\'|[^,\]]*)\s*(?:,|\]\s*\[)?\s*)*\])?\s*|\S+)(?=\n\s*|\s+|$)c [RU5nU(d [S5eUR5up#[ 5nU(Ga![ R U5GHnURS5(aA[SURS5URS5URS5SS4-5eURS5(a1[SURS5URS5SS4-5eURS5nU(dMURS S S 5Vs/sH owcMUPM snSnUR5XFR5'GM X$4$s snf) Nzunexpected option syntaxwrngAz+unexpected syntax at %d after option %r: %srrwrngBz'expected option, wrong syntax at %d: %sr3r) OPTION_CREmatchrgroupsdictOPTION_EXTRACT_CREfinditergroupstartr) optionr option_nameoptstr option_optsoptmatchoptr0rs rextractOptionsr;sT   & ! -..||~v $--f5hnnW B ^^GhnnQ/1H21NFPP QQnnW > ^^GhnnW5a;B== >>  3 x>>!Aa( =(CC( ==> @5#kkm;yy{6    =s 2E0<E0c,[RU5$r~)OPTION_SPLIT_CREfindall)rs rsplitWithOptionsrPs  ((r&rz <([^ <>]+)>c [RnUn[U5n[5n[US5n0nSn UR 5GHn X;dX;aMU(a![ UR U 55(aM8[XZ5=pU"U 5n URU 05nU (Ga1U RS5nX;aU"XR55n M6X:XdURUS5[:a[SU <SU<SU<SU <35eS nU(aURUS -U-5nUcURU5nUc UbU"U5nUcU"XR55n M[U[5(d [U5nU RS U-U5n URUS 5S-X'U"XR!55n U (aGM1X:wa?U"U 5(aXU 'Sn [#U5[#U5:XaUR%5nXU 'S U ;dGMUR'U 5 GM U (dU$GM)aSort 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_CREsearchrBhasattrkeyscallablerr%getrendMAX_TAG_REPLACE_COUNTrrr"rridcopyadd)inptags conditionalignoreaddrepl tre_searchtagsdone noRecRepl repCountsrepFlagtagrorgvalrrplcrtagrepls rsubstituteRecursiveTagsr^s,nn f+  T< (  ' YY[c ms{HHT__S122Hty))5%1 --R 4 771:D ~ E557 #Q  {dhhtQ'*??  D$   D HHTCZ+- .T | HHTNT , T]d | E557 #Q dC D)9$ MM&4- .E$"Q&DJ5'')$AI N o%s^W $x2g; LLNTI  wz  E r&c`UR5n[RSU5 g! g=f)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_libcapprctlrs rprctl_set_th_namer s*  ++-4 ==Ts&)-cgr~rqrs rr r sr&cN^\rSrSrSr\"5rSrU4SjrSr SSjr Sr U=r $) BgServiceizxBackground servicing Prevents memory leak on some platforms/python versions, using forced GC in periodical intervals. Ncn>UR(d[[U]U5UlUR$r~) _instancesuperr __new__)cls __class__s rrBgService.__new__s*  )S!#&= r&cSUlSUlSUlURUl[ [ S5(a[ R "S5 gg)NirP set_thresholdr)_BgService__serviceTime_BgService__periodTime_BgService__threshold_BgService__countrgcrrs rr=BgService.__init__sG"$$$!!$, R!!A"r&cU=RS-slU(d4URS:d#[R"5UR:ag[R R U5(dg[R"5UR:a [R R5 g[R"5 [R"5UR-UlURUl[R R5 g![R R5 f=f)NrrFT) rrtimerr _mutexacquirereleasercollectrr)rLforcewaits rserviceBgService.services,,!, DLL1$ 8J8J(J     ! !$ ' '   kkmd(((    ::< (9(994""4<  9s7#D':A D'' E)__count __periodTime __serviceTime __threshold)FF) r6rlrmrnrorrrrr=r%rp __classcell__)rs@rr r s* &  r&r )NN)z %(message)sTT)r rqN)> __author__ __license__rlocalerwr r\r4rW threadingr server.mytimer importlibctypesCDLLrgetpreferredencodingr# startswithstdoutencodingallr r%r(r1r9rEobjectrGrxrsrrLogger_logrrrrrrrrrrrrrcompileDOTALLrrrrrrrrr r rqr&rr>s1(L   ! ;;} %  ( ( *  !!JJ3::&&23::;N;N;Y;YZa;b;bzz""* Z/Y Z[[*!"(1 (  ++\ 0W.. 0  NN   < &&,,-   ,6H ZZ5ryy A ZZjlnluluw::wy{zCzCD!*) **^ $13` F  ,,U  s H--H4