X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=script%2Fpublic-inbox-learn;h=d2d665d580b5f4803d2afd66fd45b333b4c1a99b;hb=bc6b44cd7feee7e83ef1dcf26092808f92f757d9;hp=75294a0a8e44e9368fc0b98d7db38d1d8a71152b;hpb=7174681c0165008ac16ed1d323f6d95b6d0570a3;p=public-inbox.git diff --git a/script/public-inbox-learn b/script/public-inbox-learn index 75294a0a..d2d665d5 100755 --- a/script/public-inbox-learn +++ b/script/public-inbox-learn @@ -1,6 +1,6 @@ #!/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-2019 all contributors +# License: AGPL-3.0+ # # Used for training spam (via SpamAssassin) and removing messages from a # public-inbox @@ -8,11 +8,8 @@ my $usage = "$0 (spam|ham) < /path/to/message"; use strict; use warnings; use PublicInbox::Config; -use PublicInbox::Git; -use PublicInbox::Import; +use PublicInbox::InboxWritable; use PublicInbox::MIME; -use Email::MIME::ContentType; -$Email::MIME::ContentType::STRICT_PARAMS = 0; # user input is imperfect use PublicInbox::Address; use PublicInbox::Spamcheck::Spamc; my $train = shift or die "usage: $usage\n"; @@ -42,56 +39,54 @@ my $mime = PublicInbox::MIME->new(eval { $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; - } -} - +# spam is removed from all known inboxes if ($train eq 'spam') { $pi_config->each_inbox(sub { my ($ibx) = @_; - my $git = $ibx->git; - my $name = $ibx->{name}; - my $addr = $ibx->{-primary_address}; - my $im = PublicInbox::Import->new($git, $name, $addr, $ibx); - $im->remove($mime); + $ibx = PublicInbox::InboxWritable->new($ibx); + my $im = $ibx->importer(0); + $im->remove($mime, 'spam'); $im->done; }); -} +} else { + require PublicInbox::MDA if $train eq "ham"; -require PublicInbox::MDA if $train eq "ham"; + # 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_config->lookup($addr) // 0; + } + } -# 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); + # n.b. message may be cross-posted to multiple public-inboxes + while (my ($addr, $dst) = each %dests) { + next unless ref($dst); + # We do not touch GIT_COMMITTER_* env here so we can track + # who trained the message. + $dst->{name} = $ENV{GIT_COMMITTER_NAME} || $dst->{name}; + $dst->{-primary_address} = $ENV{GIT_COMMITTER_EMAIL} || $addr; + $dst = PublicInbox::InboxWritable->new($dst); + my $im = $dst->importer(0); - if ($train eq "spam" || $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, $train); - } else { # $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); + 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, $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); - # Ham messages are trained when they're marked into - # a SEEN state, so this is idempotent: - $im->add($mime); + # Ham messages are trained when they're marked into + # a SEEN state, so this is idempotent: + $im->add($mime); + } + $im->done; } - $im->done; } if ($err) {