;ò ¢)?Bc@s¿dZdkZdkZdkZdklZdklZdkl Z dkl Z dk l Z dk lZdklZd klZeid eieiBƒZd efd „ƒYZdS( s®Maildir pre-queue runner. Most MTAs can be configured to deliver messages to a `Maildir'[1]. This runner will read messages from a maildir's new/ directory and inject them into Mailman's qfiles/in directory for processing in the normal pipeline. This delivery mechanism contrasts with mail program delivery, where incoming messages end up in qfiles/in via the MTA executing the scripts/post script (and likewise for the other -aliases for each mailing list). The advantage to Maildir delivery is that it is more efficient; there's no need to fork an intervening program just to take the message from the MTA's standard output, to the qfiles/in directory. [1] http://cr.yp.to/proto/maildir.html We're going to use the :info flag == 1, experimental status flag for our own purposes. The :1 can be followed by one of these letters: - P means that MaildirRunner's in the process of parsing and enqueuing the message. If successful, it will delete the file. - X means something failed during the parse/enqueue phase. An error message will be logged to log/error and the file will be renamed :1,X. MaildirRunner will never automatically return to this file, but once the problem is fixed, you can manually move the file back to the new/ directory and MaildirRunner will attempt to re-process it. At some point we may do this automatically. See the variable USE_MAILDIR in Defaults.py.in for enabling this delivery mechanism. N(sParser(s parseaddr(smm_cfg(sUtils(sMessage(sRunner(sget_switchboard(ssyslogs ^ # start of string (?P[^-@]+) # listname@ or listname-subq@ (?: # non-grouping - # dash separator (?P[^-+@]+) # everything up to + or - or @ )? # if it exists s MaildirRunnercBs)tZedd„Zd„Zd„ZRS(NicCsRd|_tiitidƒ|_tiitidƒ|_t t ƒ|_ dS(Nisnewscur( sselfs_stopsosspathsjoinsmm_cfgs MAILDIR_DIRs_dirs_cursParsersMessages_parser(sselfsslices numslices((s+/var/mailman/Mailman/Queue/MaildirRunner.pys__init__Ts cCstiƒ}yti|iƒ} Wn3tj o'}|i t i jo‚ndSnXx¤| D]œ}ti i|i|ƒ}ti i|i|dƒ} ti i|i|dƒ}yti|| ƒWnBtj o6}|i t i joq_ntdd|ƒ‚nXy²t| ƒ}z|ii|ƒ} Wd|iƒXg}x0dddfD]}|i| i|gƒƒqWWx˜|D]m} t | ƒd } | oqnt"i#| ƒ}| oqn|i%d d ƒ\}}||joPqqWtdd |ƒti| |ƒw_hd |<}|d dfjot)t*i+ƒ}nY|djod |d