ó Pü½cc@s•dZddlZddlZddlZddlZddlmZddlmZddl m Z ddl m Z ddl m Z ddl mZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlmZdZye e!fWne"k rIdZ dZ!nXddd„ƒYZ#dee#fd„ƒYZ$d„Z%d„Z&d„Z'dS(sBounce queue runner.iÿÿÿÿN(tMIMEText(t MIMEMessage(t parseaddr(tmm_cfg(tUtils(tLockFile(tNotAMemberError(tUserNotification(t _BounceInfo(t BouncerAPI(tRunner(tget_switchboard(tsyslog(t_s, iit BounceMixincBs>eZd„Zd„Zd„Zd„Zd„Zd„ZRS(cCsQtjjtjdtjƒƒ|_d|_d|_ t j ƒtj |_ dS(Nsbounce-events-%05d.pcki( tostpathtjoinRtDATA_DIRtgetpidt_bounce_events_filetNonet_bounce_events_fpt _bouncecntttimetREGISTER_BOUNCES_EVERYt _nextaction(tself((s9/export/web/mailman/mailman/Mailman/Queue/BounceRunner.pyt__init__4s !   cCsÊtjƒd }|jdkr[tjdƒ}zt|jdƒ|_Wdtj|ƒXnx0|D](}tj ||||f|jdƒqbW|jj ƒtj |jj ƒƒ|j t|ƒ7_ dS(Niisa+bi(Rt localtimeRRRtumasktopenRtcPickletdumptflushtfsynctfilenoRtlen(Rtlistnametaddrstmsgttodaytomasktaddr((s9/export/web/mailman/mailman/Mailman/Queue/BounceRunner.pyt_queue_bounces[s  cCsgtdd||jƒi}|jjdƒx…tr³y"tj|jƒ\}}}}Wn4tk r|}tdd|ƒntk rPnX|j |gƒj |||fƒq/Wx}|j ƒD]o}|j |ƒ}|j ƒzBx1||D]%\}}}|j||d|ƒqîW|jƒWd|jƒXqÁW|jjƒd|_tj|jƒd|_dS(Ntbounces%s processing %s queued bouncesisError reading bounce events: %stday(R RRtseektTrueR tloadt ValueErrortEOFErrort setdefaulttappendtkeyst _open_listtLocktregisterBouncetSavetUnlocktcloseRRtunlinkR(RteventsR&R+R.R(tetmlist((s9/export/web/mailman/mailman/Mailman/Queue/BounceRunner.pyt_register_bouncesjs0   " &   cCs |jdkr|jƒndS(Ni(RRA(R((s9/export/web/mailman/mailman/Mailman/Queue/BounceRunner.pyt_cleanup‰scCsLtjƒ}|j|ks*|jdkr.dS|tj|_|jƒdS(Ni(RRRRRRA(Rtnow((s9/export/web/mailman/mailman/Mailman/Queue/BounceRunner.pyt _doperiodics  cCsÎ|jƒ}|s|jƒnz”|j|ƒ\}}}yd|j|ƒ}|swt|dtjƒd |jƒ}n|j|||ƒ|s|j ƒnWnt k r±nXWd|sÉ|j ƒnXdS(Ngi( tLockedR8t pend_confirmt getBounceInfoRRRt bounce_you_are_disabled_warningstdisableBouncingMemberR:RR;(RR@ttokentlockedtopR+tbmsgtinfo((s9/export/web/mailman/mailman/Mailman/Queue/BounceRunner.pyt _probe_bounce•s&    (t__name__t __module__RR,RARBRDRO(((s9/export/web/mailman/mailman/Mailman/Queue/BounceRunner.pyR3s  '    t BounceRunnercBs;eZejZddd„Zd„Zej Z d„Z RS(icCs$tj|||ƒtj|ƒdS(N(R RR(Rtslicet numslices((s9/export/web/mailman/mailman/Mailman/Queue/BounceRunner.pyR¸sc CsÎ|jƒttjƒ}|jƒjƒtjjƒkro|j||d|jdt j ddƒddƒdS|j dƒt j |j dƒkrÔ|j||dt j dd ƒgdt j ddƒddƒdS|j sádSt||ƒ}|rtj||ƒtjkrfdSnNt||ƒ}|rA|j||ƒdStj||ƒ}|tjkrfdStd|ƒ}|s±td d |jƒ|j d d ƒƒt||ƒdS|j|jƒ||ƒdS(Ntrecipst envsendertextratloopt nodecorateitfromtbouncestownerR-s1%s: bounce message w/no discernable addresses: %ss message-idsn/a(tLoadR Rt OUTQUEUE_DIRt internal_nametlowertMAILMAN_SITE_LISTtenqueueR\Rtget_site_emailtgett host_nametbounce_processingt verp_bounceR t ScanMessagestStopt verp_probeROtfilterRR t maybe_forwardR,(RR@R(tmsgdatatoutqR'RJ((s9/export/web/mailman/mailman/Mailman/Queue/BounceRunner.pyt_dispose¼sL      cCstj|ƒtj|ƒdS(N(RRBR (R((s9/export/web/mailman/mailman/Mailman/Queue/BounceRunner.pyRBs N( RPRQRtBOUNCEQUEUE_DIRtQDIRRRRoRRDRB(((s9/export/web/mailman/mailman/Mailman/Queue/BounceRunner.pyRRµs   [ c Csþtj|jƒƒ\}}g}x'd D]}|j|j|gƒƒq(Wx¬|D]¤}t|ƒd}|stqRntjtj |ƒ}|s•qRny5||j dƒkr³wRnd|j dd ƒ} Wn%t k rñt d d tj ƒgSX| gSWdS( Nttos delivered-tos envelope-tos apparently-toiR[s%s@%stmailboxthostterrors4VERP_REGEXP doesn't yield the right match groups: %s(Rrs delivered-tos envelope-tos apparently-to( Rt ParseEmailtGetBouncesEmailtextendtget_allRtretsearchRt VERP_REGEXPtgroupt IndexErrorR ( R@R(tbmailboxtbdomaintvalstheadertfieldRrtmoR+((s9/export/web/mailman/mailman/Mailman/Queue/BounceRunner.pyRgs*    c Cstj|jƒƒ\}}g}x'd D]}|j|j|gƒƒq(WxÅ|D]½}t|ƒd}|stqRntjtj |ƒ}|s•qRnyS||j dƒkr³wRn|j dƒ} |j | dt ƒ} | dk rç| SWqRtk rtd d tj ƒqRXqRWdS( NRrs delivered-tos envelope-tos apparently-toiR[RJtexpungeRus:VERP_PROBE_REGEXP doesn't yield the right match groups: %s(Rrs delivered-tos envelope-tos apparently-to(RRvRwRxRyRRzR{RtVERP_PROBE_REGEXPR}RFtFalseRR~R ( R@R(RR€RR‚RƒRrR„RJtdata((s9/export/web/mailman/mailman/Mailman/Queue/BounceRunner.pyRj?s0    cCsž|jru|jdddƒd}|j|dtdƒdtdƒd d ƒtd d |jƒ|jd dƒƒn%td d|jƒ|jd dƒƒdS(Ntadmintabsoluteis/bouncettexts*The attached message was received as a bounce, but either the bounce format was not recognized, or no member addresses could be extracted from it. This mailing list has been configured to send all unrecognized bounce messages to the list administrator(s). For more information see: %(adminurl)s tsubjectsUncaught bounce notificationt tomoderatorsiR-s+%s: forwarding unrecognized, message-id: %ss message-idsn/as+%s: discarding unrecognized, message-id: %s(t&bounce_unrecognized_goes_to_list_ownert GetScriptURLtForwardMessageR R R_Rd(R@R(tadminurl((s9/export/web/mailman/mailman/Mailman/Queue/BounceRunner.pyRlbs      (((t__doc__RRzRR temail.MIMETextRtemail.MIMEMessageRt email.UtilsRtMailmanRRRtMailman.ErrorsRtMailman.MessageRtMailman.BouncerRtMailman.BouncersR tMailman.Queue.RunnerR tMailman.Queue.sbcacheR tMailman.Logging.SyslogR t Mailman.i18nR t COMMASPACER0R‡t NameErrorRRRRgRjRl(((s9/export/web/mailman/mailman/Mailman/Queue/BounceRunner.pyts:      ‚j #