#!/usr/bin/perl
our $VERSION = '1.20160612';
$|++;
my %command_line_options = (
'author:s' => \my $author,
'from_dom:s' => \my $from,
'begin:s' => \my $begin,
'end:s' => \my $end,
'disposition:s' => \my $disposition,
'dkim:s' => \my $dkim,
'spf:s' => \my $spf,
'dns' => \my $dns_opt,
'geoip' => \my $geoip_opt,
'help' => \my $help,
'verbose' => \my $verbose,
);
GetOptions (%command_line_options);
my $report = Mail::DMARC::Report->new;
my $gip;
pod2usage if $help;
my $reports = $report->store->retrieve(
(defined $from ? (from_domain => $from ) : () ),
(defined $author ? (author => $author ) : () ),
(defined $begin ? (begin => $begin ) : () ),
(defined $end ? (end => $end ) : () ),
);
print_header();
foreach my $report_ref ( reverse @$reports ) {
my $rows = $report->store->backend->get_rr( rid => $report_ref->{rid} )->{rows};
next if $disposition && ! grep { $_->{disposition} eq $disposition } @$rows;
next if $dkim && ! grep { $_->{dkim} eq $dkim } @$rows;
next if $spf && ! grep { $_->{spf } eq $spf } @$rows;
print_record($report_ref);
print_rows( $rows );
print "\n";
}
sub print_record {
my $rec = shift;
printf "%3s %26s %15s\n", @$rec{qw/ rid author begin /};
return;
};
sub print_rows {
my $rows = shift;
foreach my $row ( @$rows ) {
no warnings;
next if $disposition && $disposition ne $row->{disposition};
next if $dkim && $dkim ne $row->{dkim};
next if $spf && $spf ne $row->{spf};
my $dns_hostname = get_dns_hostname( $row->{source_ip} );
printf " | -- %3s %20s %39s %13s %7s %7s", @$row{qw/ count header_from source_ip disposition dkim spf /};
foreach my $r ( @{ $row->{reasons} } ) {
print ' ' . $r->{type};
print "( $r->{comment} )" if $r->{comment};
};
my $geoip = print_geoip( $row->{source_ip} );
print " $dns_hostname\n";
}
return;
};
sub print_header {
printf "%3s %26s %15s\n", qw[ ID Author Report-Start ];
printf " | -- %3s %20s %39s %13s %7s %7s\n", 'Qty','From','IP','Disposition','DKIM','SPF';
return;
};
sub print_geoip {
my $ip = shift;
return if ! $geoip_opt;
$gip ||= get_geoip_db();
return if ! $gip;
my $r = $gip->record_by_addr($ip) or return '';
my $country_code = $r->country_code();
my $country_name = $r->country_name();
my $continent = $r->continent_code();
my $city = $r->city;
print $city ? " $city," : ' ';
print " $country_code, $continent";
return;
}
sub get_dns_hostname {
my $ip = shift;
return if ! $dns_opt;
my @answers = $report->has_dns_rr('PTR', $ip);
return '' if 0 == scalar @answers;
return $answers[0] if scalar @answers >= 1;
print Dumper(\@answers);
return;
};
sub get_geoip_db {
return $gip if $gip;
eval "require Geo::IP";
if ($@) {
warn "unable to load Geo::IP\n";
return;
};
foreach my $local ( '/usr/local', '/opt/local', '/usr' ) {
my $db_dir = "$local/share/GeoIP";
foreach my $db (qw/ GeoIPCity GeoLiteCity /) {
if (-f "$db_dir/$db.dat") {
print "using db $db" if $verbose;
$gip = Geo::IP->open("$db_dir/$db.dat");
}
last if $gip;
}
last if $gip;
};
return $gip;
}
exit;
Hide Show 103 lines of Pod