File Coverage

blib/lib/Net/DNS/Async/Simple.pm

Criterion	Covered	Total	%
statement	31	35	88.5
branch	7	12	58.3
condition	1	3	33.3
subroutine	6	6	100.0
pod	1	1	100.0
total	46	57	80.7

package Net::DNS::Async::Simple;
$Net::DNS::Async::Simple::VERSION = '1.161060';
use Modern::Perl;
use Net::DNS::Async;
use Data::Dumper;

sub massDNSLookup {
    my $list = shift
        or die 'Net::DNS::Async::Simple: one argument required';
    die 'Net::DNS::Async::Simple: first required argument must be an ARRAY reference'
        if not ref $list or ref $list ne 'ARRAY';
    my $async = new Net::DNS::Async(QueueSize => 20, Retries => 3);

    my $callback = sub {
        my ($index, $response) = @_;
        if(not $response) {     #timeout
            $list->[$index]->{timeout} = 1;
            return;
        }
        my @answers = $response->answer;
        if(not scalar @answers) {
            $list->[$index]->{error} = "returned no answers via";
            return;
        }
        foreach my $answer (@answers) {
            if(ref $answer eq 'Net::DNS::RR::A') {
                $list->[$index]->{name} = $answer->name;
                $list->[$index]->{address} = $answer->address;
            } elsif(ref $answer eq 'Net::DNS::RR::PTR') {
                $list->[$index]->{ptrdname} = $answer->ptrdname;
            }
        }
    };

    my $i = 0;
    while($list->[$i]) {
        my $j = $i;
        $async->add(
            sub {
                $callback->($j, @_)
            }, @{$list->[$j]->{query}}
        );
        $i++;
    }
    $async->await;
    return undef;
}

1;

__END__