]>
diplodocus.org Git - minc/blob - minc
14964500a0dd9a3adeffd735c040eac19a752fd9
5 B<minc> - incorporate mail from a maildir into mh folders
9 B<minc> [B<-m> I<MAX>] [B<-n>]
17 B<minc> incorporates mail from a maildir to a mh folder hierarchy. It
18 takes mail from a maildir folder (not a maildir folder hierarchy),
19 running each message through regular expression based filter and hook
20 functions to determine in which folder to store it or whether it's
21 spam. Post-processing hooks may be applied to each message.
23 As it processes each message, B<minc> prints a line for each message
24 similar to B<inc(1)> and B<scan(1)>. This line includes the folder
25 and message number in which the message was stored, the last 'From'
26 header, and the last 'Subject' header. These fields are truncated to
27 fit in the user's terminal (see COLUMNS in B<ENVIRONMENT> below) in
28 the following proportions: folder (0.1), message number (0.0625), from
29 header (0.175). Any of these may be overridden with $SCAN_P_FOLDER,
30 $SCAN_P_MESSAGE, or $SCAN_P_FROM. The subject always fills out the
38 $SIG{'PIPE'} = 'IGNORE';
42 use Fcntl
qw(O_WRONLY O_EXCL O_CREAT);
44 use File
::Temp
qw(tempfile);
46 use Getopt
::Long
qw(:config gnu_getopt no_ignore_case);
47 use POSIX
qw(strftime WEXITSTATUS WIFEXITED);
52 # If a filter set's header is $MAGIC_TO_TOKEN, that set is compared
53 # against headers matching this regex (taken from procmail).
54 my $MAGIC_TO_REGEX = '^((Original-)?(Resent-)?(To|Cc|Bcc)|(X-Envelope |Apparently(-Resent)?)-To)';
55 my $MAGIC_TO_TOKEN = ' TO';
57 # Mapping of message numbers to array references. The first element is set by
58 # filter_mail to a reference to a header hash for the message; the second is
59 # set by maildier_spam to the name of the message file in the spam maildir.
60 # scan_spam scans this at the end so the user can check for false positives.
69 Dump (using Data::Dumper) the FILTERS list and exit. This is useful
70 for testing the syntax of .minc.
78 Stop processing after I<MAX> messages.
82 Dry run; do not actually incorporate the mail, but log and report to
83 stdout/stderr as normal.
87 Rebuild `mhpath +`/.folders from scratch, processing no mail.
97 my $rebuild_dot_folders;
100 'd' => \
$dumpfilters,
104 'r' => \
$rebuild_dot_folders,
106 $help and pod2usage
(-exitstatus
=>0, -verbose
=>1);
107 @ARGV == 0 or pod2usage
();
117 How many columns the user's terminal can hold, used to print scan
118 lines for each processed message. Defaults to 80.
122 Where the configuration file (.minc) is found. Also,
123 $HOME/Maildir is used for the maildir if MAILDIR is not set.
127 Where mail is delivered.
133 use Env
qw(COLUMNS HOME MAILDIR);
138 die("HOME environment variable must be set.\n");
141 $MAILDIR = "$HOME/Maildir";
150 This file is Perl code (included via the 'require' directive) which
151 may define the FILTERS list, @start_hooks, @filter_hooks,
152 @post_store_hooks, and @stop_hooks.
154 =item `mhpath +`/.folders
156 B<minc> adds all folders it filters into to this file, which is used
157 by lukem's B<new(1)> (XXX need a link).
159 =item `mhpath +`/logs/minc.log
161 Where B<minc> logs what it does, unless in -n mode.
163 =item `mhpath +`/.minc.context
165 B<minc> uses this file for context (i.e. current folder) instead of
166 `mhpath +`/context. This allows you some amount of freedom to use mh
167 while B<minc> is running. For example, you can changed folders without
168 causing a message to be stored in the wrong folder. Care must still
169 be taken, however, about the unseen sequence; if you change it
170 (whether via show, or mark, or anything else) while in the same folder
171 as B<minc>, it is likely the new message B<minc> stores will not end up
179 our (@start_hooks, @stop_hooks, @filter_hooks, @post_store_hooks);
180 our $SCAN_P_FOLDER = 0.1;
181 our $SCAN_P_MESSAGE = 0.0625;
182 our $SCAN_P_FROM = 0.175;
183 our @folder_sort_list = (qr/^inbox$/);
184 our $folder_sorter = sub { sort_by_list
(@_, @folder_sort_list) };
191 my $logfile = $mh . '/logs/minc.log';
193 $ENV{"MHCONTEXT"} = $mh . '/.minc.context';
196 ###############################################################################
202 my $timestamp = strftime
('%b %e %H:%M:%S', localtime);
204 foreach my $part (@_) {
205 if (defined($part)) {
209 # no newlines in the log message, thanks
212 open(LOG
, ">>$logfile") or die("open(>>$logfile): $!");
213 print(LOG
"$timestamp $msg\n") or die("print(>>$logfile): $!");
214 close(LOG
) or die("close($logfile): $!");
218 my ($text, @contents) = @_;
222 $last = $contents[-1];
227 mylog
('<< ', $text, $last);
231 my %headers = %{(shift)};
233 # For an explanation of the %headers structure, see the
234 # get_headers function below.
235 logheader
('From: ', @{$headers{'return-path'}});
236 logheader
('To: ', @{$headers{'to'}});
237 logheader
('Subject: ', @{$headers{'subject'}});
238 logheader
('Message-Id: ', @{$headers{'message-id'}});
242 ###############################################################################
271 foreach $component (split('/', $folder)) {
272 $target = join('/', $target, $component);
273 -d
$target or mkdir($target) or die("mkdir($target): $!");
281 if (not opendir(DIR
, $dir)) {
282 die("opendir($dir): $!");
285 # Initialize $! to 0 (success) because stupid stupid Perl provides
286 # no way to distinguish an error from an empty directory; that
287 # means setting $! to 0 and testing it afterwards is the only way
288 # to detect an error. Real Programmers don't handle errors,
291 @result = readdir(DIR
);
293 die("readdir($dir): $!");
300 STDOUT-
>autoflush(1);
302 print('1 message...');
304 print(@result - 2, ' messages...');
313 sub get_highest_msgnum
{
314 my $mhfolder = shift;
320 if (defined($msgnum_cache{$mhfolder})) {
321 return $msgnum_cache{$mhfolder}++;
324 $dir = "$mh/$mhfolder";
325 if (not opendir(DIR
, $dir)) {
326 die("opendir($dir): $!");
329 # Insert rant from getfiles here.
331 @list = readdir(DIR
);
334 die("readdir($dir): $!");
340 foreach $msgnum (@list) {
342 if ($msgnum =~ /^[0-9]+$/) {
343 if ($msgnum > $highest) {
349 $msgnum_cache{$mhfolder} = $highest;
350 return $msgnum_cache{$mhfolder}++;
357 my $fn = "$mh/$folder/.mh_sequences";
361 if (not open($fh, $fn)) {
362 $!{ENOENT
} or die("open($fn): $!");
369 open($fh, '>', $fn) or die("open(>$fn): $!");
370 for $_ (@sequences) {
375 for my $part (split(' ', $1)) {
377 my ($st, $en) = split('-', $part);
378 if ((defined($en) and ($msgnum >= $st and $msgnum <= $en))
380 # It's already there.
384 if ($st - 1 == $msgnum) {
385 $part = "$msgnum-$en";
387 } elsif ($en + 1 == $msgnum) {
388 $part = "$st-$msgnum";
392 if ($part - 1 == $msgnum) {
393 $part = "$msgnum-$part";
395 } elsif ($part + 1 == $msgnum) {
396 $part = "$part-$msgnum";
401 push(@result, $part);
404 push(@result, $msgnum);
406 print($fh "$seq: ", join(' ', @result), "\n");
412 $marked or print($fh "$seq: $msgnum\n");
413 close($fh) or die("close(>$fn): $!");
418 my $mhfolder = shift;
423 # We must do this even in -n mode because later steps fail without
424 # it. This should be harmless.
427 # This loop is a modified version of the maildir delivery algorithm.
428 $msgnum = get_highest_msgnum
($mhfolder);
429 for ($try = 0; ; $try++) {
431 $mhmsg = "$mh/$mhfolder/$msgnum";
433 if (not stat($mhmsg)) {
435 # Now we have a non-existent file, let's try to create
436 # it. We must create a zero-byte file first because a
437 # file my appear between our happy stat results and
438 # our later rename(2), which would clobber said file.
439 # So attempt to create a file with this name. If it
440 # succeeds, in just a bit here we'll knowingly clobber
441 # this file with the rename(2) call.
443 # Another way to do this is not to use rename(2), but
444 # use link(2) + unlink(2) instead. That's how the
445 # standard maildir algorithm does it. Each method has
446 # a disadvantage: the program may crash between the
447 # link(2) and unlink(2) calls. With the standard
448 # maildir algorithm, that means the message will end
449 # up duplicated. The advantage of creating an empty
450 # file followed by rename(2) is that an extra empty
451 # file is left behind as opposed to a duplicate
452 # message. This is more easily detected by the user.
454 if (sysopen(MSG
, $mhmsg,
455 O_WRONLY
| O_EXCL
| O_CREAT
, 0600)) {
465 # This algorithm is different from the maildir one; let's make
466 # 10 tries instead of 3.
468 die("Attempted filename $mhmsg exists.");
471 # This algorithm is different; i don't think we need to sleep.
475 mylog
('+', $mhfolder);
478 if (not rename($msg, $mhmsg)) {
479 die("rename($msg, $mhmsg): $!");
482 # Mark each message as soon as we store it and bomb if that
483 # fails. While it is slow, it is not safe to store multiple
484 # messages and then have a failure before marking some (or
486 if ($mhfolder ne 'SPAM') {
487 mark
($mhfolder, $msgnum, 'unseen');
494 # Parse a message file into a structure describing the headers. The
495 # structure is a hash of arrays. The hash keys are the names of the
496 # headers found in the message, made all lower-case. Each item in
497 # the hash is an array of header text. The array has one element
498 # per occurrence of the header. Most headers will only have a single
499 # element because they occur only once. The Received header is the
500 # most common header with multiple texts.
504 my $current; # current header, used for unfolding lines
505 my $fieldname; # unmolested header name
506 my $contents; # contents of header
508 open(MSG
, $msg) or die("open(MSG, $msg): $!");
516 # folded header continuation
518 if (not defined($current)) {
519 warn('Malformed message, cannot parse headers.');
523 @{$headers{$current}}[-1] .= $_;
525 ($fieldname) = split(/:/);
526 $current = lc($fieldname);
527 (undef, $contents) = split(/^\Q$fieldname\E:\s*/);
529 if (defined($headers{$current})) {
530 # multiple occurence of same header
531 push(@{$headers{$current}}, $contents);
533 # first occurence of a header
534 $headers{$current} = [$contents];
544 ###############################################################################
549 my %headers = %{(shift)};
563 # Walk the list of filters. This structure is documented in
564 # pod at the end of the program.
565 foreach $filterref (@FILTERS) {
566 @filter = @$filterref;
567 $header = shift(@filter);
569 # Handle filters using the magic TO header specially.
570 if ($header eq $MAGIC_TO_TOKEN) {
571 foreach $header (keys(%headers)) {
572 if ($header =~ /$MAGIC_TO_REGEX/i) {
573 foreach $contents (@{$headers{lc($header)}}) {
574 foreach $pair (@filter) {
575 ($regexp, $expression) = @$pair;
576 if ($contents =~ $regexp) {
577 if (eval "\$result = \"$expression\"") {
586 # Now that it's been processed specially, skip normal handling.
590 # Walk the list of message headers matching the filter's
592 foreach $contents (@{$headers{lc($header)}}) {
593 # Walk the filter's list of regexp/expression pairs.
594 foreach $pair (@filter) {
595 ($regexp, $expression) = @$pair;
596 if ($contents =~ $regexp) {
597 if (eval "\$result = \"$expression\"") {
609 my ($headers, $mhfolder, $msgnum, $nf, $nm, $nF, $ns) = @_;
612 # Sometimes these headers are missing...
613 eval { $from = [@{$headers->{'from'}}]->[-1] };
614 eval { $subject = [@{$headers->{'subject'}}]->[-1] };
615 # Replace garbage characters.
616 for ($from, $subject) {
617 tr/\x00-\x1f\x80-\xff/?/;
619 return sprintf("\%-${nf}s \%${nm}d \%-${nF}s \%s",
620 substr($mhfolder, 0, $nf), substr($msgnum, 0, $nm),
621 substr($from, 0, $nF),
622 substr($subject, 0, $ns));
627 my $msgcount = @_ - 2; # don't count . and ..
628 my $len = length($msgcount);
637 if (-f
"$HOME/.minc") {
638 require "$HOME/.minc";
642 my $nf = int($COLUMNS * $SCAN_P_FOLDER);
643 my $nm = int($COLUMNS * $SCAN_P_MESSAGE);
644 my $nF = int($COLUMNS * $SCAN_P_FROM);
645 my $ns = $COLUMNS - $nf - $nm - $nF - 3;
648 for my $hook (@start_hooks) {
649 my ($handle, @baton) = $hook->();
650 if (defined($handle)) {
651 $batons{$handle} = [@baton];
657 # Print a newline after the incomplete "N messages..." line.
662 ($msg eq '.' or $msg eq '..') and next;
664 my $headers = get_headers
($msg);
665 log_headers
($headers);
668 for my $hook (@filter_hooks) {
669 my $result = $hook->(\
%batons, $headers, $msg);
670 defined($result) and ($mhfolder = $result);
673 defined($mhfolder) or ($mhfolder = find_mh_folder
($msg, $headers));
675 $msgnum = store_message
($msg, $mhfolder);
676 $folders{$mhfolder}++;
682 if ($mhfolder eq 'SPAM') {
684 $SPAM{$msgnum} = [$headers, undef];
687 print(scan_line
($headers, $mhfolder, $msgnum, $nf, $nm, $nF, $ns),
691 for my $hook (@post_store_hooks) {
692 $hook->(\
%batons, $headers, $mhfolder, $msgnum);
696 printf(" \%${len}d SPAM \%${len}d saved \%${len}d/%1d",
697 $spam, $saved, $spam + $saved, $msgcount);
700 defined($maxmsgs) and ($spam + $saved < $maxmsgs or last);
704 for my $hook (@stop_hooks) {
711 sub build_dot_folders
{
723 eval { ($fh, $fn) = tempfile
("$mh/.folders.XXXXX") };
729 for my $folder (sort { $folder_sorter->($a,$b) } keys(%$folders)) {
730 print($fh "$folder\n");
733 if (not close($fh)) {
734 warn("close($fn): $!");
735 unlink($fn) or warn("unlink($fn): $!");
739 rename($fn, "$mh/.folders") or warn("rename($fn, $mh/.folders): $!");
742 sub create_dot_folders
{
743 if (-f
"$HOME/.minc") {
744 require "$HOME/.minc";
748 open(my $fh, '-|', 'folders', '-fast', '-recur')
749 or die("open(folders|): $!");
750 build_dot_folders
(\
%folders, $fh);
754 sub update_dot_folders
{
758 if (not open($fh, "$mh/.folders") and not $!{ENOENT
}) {
759 # For ENOENT, we go ahead and create it, else we error and
761 warn("open($mh/.folders): $!");
765 build_dot_folders
($folders, $fh);
768 # XXX Could use some unification with getfiles...
770 my $dir = "$MAILDIR/spam/new";
772 if (not chdir($dir)) {
773 $!{ENOENT
} or print(STDERR
"skipping maildir spam: chdir($dir): $!\n");
777 if (not opendir(DIR
, '.')) {
778 print(STDERR
"skipping maildir spam: opendir($dir): $!\n");
783 my @spams = readdir(DIR
);
785 print(STDERR
"skipping maildir spam: readdir($dir): $!\n");
791 for my $msg (@spams) {
792 ($msg eq '.' or $msg eq '..') and next;
793 my $msgnum = store_message
($msg, 'SPAM');
794 # Store the original file name for scan_spam in -n mode.
795 $SPAM{$msgnum} = [undef, $msg];
800 my ($msgnum, $header, $tuple, $msg);
802 # Unlike filter_mail, we don't need to print the folder name.
803 # Calculate how many columns would be allocated to it...
804 my $nf = int($COLUMNS * $SCAN_P_FOLDER);
805 # ...and add that amount to COLUMNS to calculate the number of columns to
806 # allocate to msgnum and from snippet, thus filling the line without
807 # printing the folder name.
808 my $nm = int(($COLUMNS + $nf) * $SCAN_P_MESSAGE);
809 my $nF = int(($COLUMNS + $nf) * $SCAN_P_FROM);
810 my $ns = $COLUMNS - $nm - $nF - 3;
812 for $msgnum (sort(keys(%SPAM))) {
813 $tuple = $SPAM{$msgnum};
814 if (defined($tuple->[0])) {
815 # Filed by filter_mail, so we have the header.
816 $header = $tuple->[0];
817 } elsif (defined($tuple->[1])) {
818 # Filed by maildir_spam, so we don't have the header.
820 # The message has been filed, load it from $mh.
821 $msg = "$mh/SPAM/$msgnum";
823 # The message has not been filed, load it from the maildir.
824 # $tuple->[1] is just a basename, not a path; this works
825 # because maildir_spam did chdir(Maildir/spam/new).
828 $header = get_headers
($msg);
831 "BUG: corrupt SPAM tuple, neither element defined",
832 " for message $msgnum\n");
835 print(scan_line
($header, '', $msgnum, 0, $nm, $nF, $ns),
845 require "$HOME/.minc";
846 $Data::Dumper
::Indent
= 1;
847 print(Dumper
(\
@FILTERS));
851 $rebuild_dot_folders and exit(create_dot_folders
);
853 chdir("$MAILDIR/new") or die("chdir($MAILDIR/new): $!");
854 my %folders = filter_mail
(map { $_->[1] }
855 sort { $a->[0] <=> $b->[0] }
857 if (not ($st = stat($_))) {
864 $run and %folders and update_dot_folders
(\
%folders);
873 =head1 THE FILTERS STRUCTURE
875 Each element of @FILTERS is a filter. A filter is itself an array.
876 The first element of a filter is a string, the name of the header this
877 filter acts upon. The header name is not case-sensitive. Each
878 subsequent element of a filter is a pair (i.e. a two-element array):
879 first, a regular expression B<minc> uses to determine whether this
880 filter matches or not, and second, an expression which B<minc>
881 evaluates to get the folder name.
883 B<minc> decides where to store a message by iterating over the
884 @FILTERS array. It tests each regexp of each filter against all
885 headers matching that filter's specified header. As soon as a match
886 is found, B<minc> evaluates the second part of the pair. This part
887 may contain positional parameters from the matched regexp ($1, $2,
888 etc.). The result of this expression is used as the folder name.
890 Multiple occurrences of the same header are preserved and tested
891 individually against the filters. That means, for example, that
892 filters can search all the Received headers for a certain string.
894 It is important to note that all the arrays of the @FILTERS structure
895 are traversed I<in order>. This means the filters can be arranged so
896 that some have priority over others. XXX: get Doug to write an
897 example of having the same header matched more than once.
899 Lastly, B<minc> supports a magic ' TO' header. Filters using this
900 header are matched against a collection of headers related to (and
901 including) the To. Which headers to use is determined by a regular
902 expression borrowed from procmail.
906 Filter hooks take a reference to a hash of batons, a reference to a
907 hash of headers, and the message filename as arguments. It returns
908 undef to decline filtering of this message (thus falling back to
909 subsequent filter hooks, and finally @FILTERS), or the name of the
910 folder to store this message into.
912 One of B<minc>'s global variables is available to the user-defined
913 hooks: $run. This boolean should be honored; hooks should only take
914 real action (i.e. removing or creating files, running external
915 programs, etc.) if $run is non-zero.
917 The baton hash is created simply from the start hooks; if the hook
918 returns at least one defined value, this value is used as the key and
919 all other return values are put into a list reference as the value.
920 This hash is then passed by reference to all filter, post-store, and
923 Post store hooks take a reference to a hash of batons, a reference to
924 a hash of headers, the folder this message was stored in, and its new
927 XXX: need more details about the hook process; for now read the code.
934 ['<([[:graph:]]+)-([[:graph:]]+)\.lists\.sourceforge\.net>', 'l/$1/$2'],
935 ['<([[:graph:]]+?)(-list)?\.freedesktop\.org>', 'l/freedesktop/$1'],
936 ['<swig\.cs\.uchicago\.edu>', 'l/swig'],
940 ['<mailto:([[:graph:]]+)+@([[:graph:]]+)\.apache\.org>', 'l/apache/$2/$1'],
948 The first List-Id filter is a surprisingly effective one which creates
949 appropriate folder names (such as l/htdig/updates and l/rox/devel) for
950 all Sourceforge lists to which i subscribe. Certainly there are lists
951 hosted at Sourceforge which do not work well with this, and this is
952 where it is important to remember that the first match is the one
953 uses. Simply put the more specific rules before this one.
955 The next List-Id example is simple. The swig example demonstrates
956 that the folder name does not have to use a portion of the matched
957 header; you can just hardcode the folder name.
959 The List-Post example is a nice one. Most ASF projects have their own
960 apache.org subdomain, with mailing lists hosted there. So, given a
961 list such as dev@httpd.apache.org, this filter will create the folder
962 name l/apache/httpd/dev.
964 XXX Need hook examples.
968 Written by Eric Gillespie <epg@pretzelnet.org>. Design by Eric
969 Gillespie and Doug Porter <dsp@waterspout.com>.
971 This program is free software; you can redistribute it and/or modify
972 it under the same terms as Perl itself.
977 # cperl-indent-level: 4
978 # perl-indent-level: 4
979 # indent-tabs-mode: nil
982 # vi: set tabstop=4 expandtab: