X-Git-Url: http://www.git.stargrave.org/?p=public-inbox.git;a=blobdiff_plain;f=script%2Fpublic-inbox-learn;h=8b8e1b7732938bc8369813866fed9dad59ae6de6;hp=38c83243f8971e63859fe4261b7ba4d521ff2335;hb=refs%2Fheads%2Fmaster;hpb=24d417a8943d6ddac8f903731918c97d0f034c5b diff --git a/script/public-inbox-learn b/script/public-inbox-learn index 38c83243..8b8e1b77 100755 --- a/script/public-inbox-learn +++ b/script/public-inbox-learn @@ -1,31 +1,45 @@ #!/usr/bin/perl -w -# Copyright (C) 2014-2015 all contributors -# License: AGPLv3 or later (https://www.gnu.org/licenses/agpl-3.0.txt) +# Copyright (C) 2014-2021 all contributors +# License: AGPL-3.0+ # # Used for training spam (via SpamAssassin) and removing messages from a # public-inbox -my $usage = "$0 (spam|ham) < /path/to/message"; +my $help = < 0); +GetOptions(\%opt, qw(all help|h)) or die $help; + +my $train = shift or die $help; if ($train !~ /\A(?:ham|spam|rm)\z/) { - die "`$train' not recognized.\nusage: $usage\n"; + die "`$train' not recognized.\n$help"; } +die "--all only works with `rm'\n" if $opt{all} && $train ne 'rm'; my $spamc = PublicInbox::Spamcheck::Spamc->new; -my $pi_config = PublicInbox::Config->new; +my $pi_cfg = PublicInbox::Config->new; my $err; -my $mime = PublicInbox::MIME->new(eval { - local $/; - my $data = scalar ; +my $mime = PublicInbox::Eml->new(do{ + defined(my $data = do { local $/; }) or die "read STDIN: $!\n"; $data =~ s/\A[\r\n]*From [^\r\n]*\r?\n//s; if ($train ne 'rm') { @@ -39,41 +53,29 @@ my $mime = PublicInbox::MIME->new(eval { }; $err = $@; } - $data + \$data }); -# get all recipients -my %dests; -foreach my $h (qw(Cc To)) { - my $val = $mime->header($h) or next; - foreach my $email (PublicInbox::Address::emails($val)) { - $dests{lc($email)} = 1; - } -} - -require PublicInbox::MDA if $train eq "ham"; +sub remove_or_add ($$$$) { + my ($ibx, $train, $mime, $addr) = @_; -# n.b. message may be cross-posted to multiple public-inboxes -foreach my $recipient (keys %dests) { - my $dst = $pi_config->lookup($recipient) or next; - my $git_dir = $dst->{mainrepo} or next; - my $git = PublicInbox::Git->new($git_dir); # We do not touch GIT_COMMITTER_* env here so we can track # who trained the message. - my $name = $ENV{GIT_COMMITTER_NAME} || $dst->{name}; - my $email = $ENV{GIT_COMMITTER_EMAIL} || $recipient; - my $im = PublicInbox::Import->new($git, $name, $email); + $ibx->{name} = $ENV{GIT_COMMITTER_NAME} // $ibx->{name}; + $ibx->{-primary_address} = $ENV{GIT_COMMITTER_EMAIL} // $addr; + $ibx = PublicInbox::InboxWritable->new($ibx); + my $im = $ibx->importer(0); - if ($train eq "spam" || $train eq "rm") { + if ($train eq "rm") { # This needs to be idempotent, as my inotify trainer # may train for each cross-posted message, and this # script already learns for every list in # ~/.public-inbox/config - $im->remove($mime); - } else { # $train eq "ham" + $im->remove($mime, $train); + } elsif ($train eq "ham") { # no checking for spam here, we assume the message has # been reviewed by a human at this point: - PublicInbox::MDA->set_list_headers($mime, $dst); + PublicInbox::MDA->set_list_headers($mime, $ibx); # Ham messages are trained when they're marked into # a SEEN state, so this is idempotent: @@ -82,6 +84,41 @@ foreach my $recipient (keys %dests) { $im->done; } +# spam is removed from all known inboxes since it is often Bcc:-ed +if ($train eq 'spam' || ($train eq 'rm' && $opt{all})) { + $pi_cfg->each_inbox(sub { + my ($ibx) = @_; + $ibx = PublicInbox::InboxWritable->new($ibx); + my $im = $ibx->importer(0); + $im->remove($mime, $train); + $im->done; + }); +} else { + require PublicInbox::MDA; + + # get all recipients + my %dests; # address => + for ($mime->header('Cc'), $mime->header('To')) { + foreach my $addr (PublicInbox::Address::emails($_)) { + $addr = lc($addr); + $dests{$addr} //= $pi_cfg->lookup($addr) // 0; + } + } + + # n.b. message may be cross-posted to multiple public-inboxes + my %seen; + while (my ($addr, $ibx) = each %dests) { + next unless ref($ibx); # $ibx may be 0 + next if $seen{"$ibx"}++; + remove_or_add($ibx, $train, $mime, $addr); + } + my $dests = PublicInbox::MDA->inboxes_for_list_id($pi_cfg, $mime); + for my $ibx (@$dests) { + next if $seen{"$ibx"}++; + remove_or_add($ibx, $train, $mime, $ibx->{-primary_address}); + } +} + if ($err) { warn $err; exit 1;