email-processor/feedback-loop-processor.pl email-processor/lib/bounce_db.pm @@ -1 +1,2 @@ /doc +/email-processor/*.txt .gitignore @@ -1,6 +1,11 @@ #!/usr/bin/env perl use strict; +use Cwd; +use File::Basename; + +our $SELF_DIR = dirname(Cwd::abs_path(__FILE__)); +require $SELF_DIR . '/lib/bounce_db.pm'; use DBI; use Mail::DeliveryStatus::BounceParser; @@ -46,53 +51,3 @@ for my $report ($bounce->reports) { exit(0); -#------------------------------------------------------------------------------- -sub RegisterBounce($$$) { - my ($email, $reason, $dbh) = @_; - print "BOUNCE: $email with reason $reason\n"; - - my ($email_user, $email_domain) = split(/\@/, lc($email)); - unless ($email_user && $email_domain) { - print "Invalid email address!\n"; - exit(1); - } - my $domain_id = RegisterBounceDomain($email_domain, $dbh); - - my $level = ($reason eq 'over_quota') ? 'soft' : 'hard'; - RegisterBounceEmail($email_user, $domain_id, $reason, $level, $dbh); -} - -#------------------------------------------------------------------------------- -sub RegisterBounceDomain($$) { - my ($domain, $dbh) = @_; - - # Lookup domain name - my $sth = $dbh->prepare("SELECT id FROM $domains_table WHERE name = ? AND name_crc32 = CRC32(?)"); - $sth->execute($domain, $domain); - my $row = $sth->fetchrow_hashref; - return $row->{id} if $row; - - # If not found, create it - print "Registering domain: $domain\n"; - $sth = $dbh->prepare("INSERT INTO $domains_table SET name = ?, name_crc32 = CRC32(?)"); - $sth->execute($domain, $domain); - return $dbh->{'mysql_insertid'}; -} - -#------------------------------------------------------------------------------- -sub RegisterBounceEmail($$$$$) { - my ($email_user, $domain_id, $reason, $level, $dbh) = @_; - - my $sql = " - INSERT INTO $blacklist_table SET - domain_id = ?, - user_crc32 = CRC32(?), - user = ?, - source = 'bounce', - level = ?, - reason = ?, - created_at = NOW() - "; - my $sth = $dbh->prepare($sql); - $sth->execute($domain_id, $email_user, $email_user, $level, $reason); -} email-processor/bounce-processor.pl eafc2ff0ba88edd6ed54eed27fd615724a02fd3c Alexey Kovyrin alexey@kovyrin.net http://github.com/kovyrin/bounces-handler/commit/02c44480c685b86b35bf43b2725ae5db74d8eebf 02c44480c685b86b35bf43b2725ae5db74d8eebf 2008-08-04T19:13:15-07:00 2008-08-04T19:13:15-07:00 Simple feedback loops processor added 466591b4e08edb3efbba845cbb0664c851731bcc Alexey Kovyrin alexey@kovyrin.net