#!/usr/bin/perl
$|++;
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:s' => \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};
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_details = get_geoip_details( $row->{source_ip} );
print " $geoip_details";
my $dns_hostname = get_dns_hostname( $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 get_geoip_details {
my $ip = shift;
return if ! defined $geoip_opt;
$geoip_opt ||= 'city,country_code,continent_code';
$gip ||= get_geoip_db();
return if ! $gip;
if ($ip =~ /^\d+\.\d+\.\d+\.\d+$/) {
$ip = '::ffff:'.$ip;
}
my $r = $gip->record_by_addr_v6($ip) or return '';
my @result;
my @fields = split(',', $geoip_opt);
my @allowed = qw(
country_code
country_code3
country_name
region
region_name
city
postal_code
latitude
longitude
time_zone
area_code
continent_code
metro_code
);
foreach my $f (@fields) {
next if ! grep {$_ eq $f} @allowed;
next if ! $r->${f}();
push @result, $r->${f}();
}
return join(', ', @result);
}
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/ GeoIPCityv6 GeoLiteCityv6 /) {
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;
}
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;
};
exit;
Hide Show 115 lines of Pod