224 lines
5.7 KiB
Perl
224 lines
5.7 KiB
Perl
package App::Netdisco::Util::DNS;
|
||
|
||
use strict;
|
||
use warnings;
|
||
use Dancer ':script';
|
||
|
||
use Net::DNS;
|
||
use Scalar::Util qw/blessed reftype/;
|
||
use NetAddr::IP::Lite ':lower';
|
||
|
||
use base 'Exporter';
|
||
our @EXPORT = ();
|
||
our @EXPORT_OK = qw/hostname_from_ip ipv4_from_hostname/;
|
||
our %EXPORT_TAGS = (all => \@EXPORT_OK);
|
||
|
||
=head1 NAME
|
||
|
||
App::Netdisco::Util::DNS
|
||
|
||
=head1 DESCRIPTION
|
||
|
||
A set of helper subroutines to support parts of the Netdisco application.
|
||
|
||
There are no default exports, however the C<:all> tag will export all
|
||
subroutines.
|
||
|
||
=head1 EXPORT_OK
|
||
|
||
=head2 hostname_from_ip( $ip, \%opts? )
|
||
|
||
Given an IP address (either IPv4 or IPv6), return the canonical hostname.
|
||
|
||
C<< %opts >> can override the various timeouts available in
|
||
L<Net::DNS::Resolver>:
|
||
|
||
=over 4
|
||
|
||
=item C<tcp_timeout>: 120 (seconds)
|
||
|
||
=item C<udp_timeout>: 30 (seconds)
|
||
|
||
=item C<retry>: 4 (attempts)
|
||
|
||
=item C<retrans>: 5 (timeout)
|
||
|
||
=back
|
||
|
||
Returns C<undef> if no PTR record exists for the IP.
|
||
|
||
=cut
|
||
|
||
sub hostname_from_ip {
|
||
my ($ip, $opts) = @_;
|
||
return unless $ip;
|
||
my $skip = setting('dns')->{'no'};
|
||
my $ETCHOSTS = setting('dns')->{'ETCHOSTS'};
|
||
|
||
return if check_acl_no_ipaddr_only($ip, $skip);
|
||
|
||
# check /etc/hosts file and short-circuit if found
|
||
foreach my $name (reverse sort keys %$ETCHOSTS) {
|
||
if ($ETCHOSTS->{$name}->[0]->[0] eq $ip) {
|
||
return $name;
|
||
}
|
||
}
|
||
|
||
my $res = Net::DNS::Resolver->new;
|
||
$res->tcp_timeout($opts->{tcp_timeout} || 120);
|
||
$res->udp_timeout($opts->{udp_timeout} || 30);
|
||
$res->retry($opts->{retry} || 4);
|
||
$res->retrans($opts->{retrans} || 5);
|
||
my $query = $res->search($ip);
|
||
|
||
if ($query) {
|
||
foreach my $rr ($query->answer) {
|
||
next unless $rr->type eq "PTR";
|
||
return $rr->ptrdname;
|
||
}
|
||
}
|
||
|
||
return undef;
|
||
}
|
||
|
||
=head2 ipv4_from_hostname( $name )
|
||
|
||
Given a host name will return the first IPv4 address.
|
||
|
||
Returns C<undef> if no A record exists for the name.
|
||
|
||
=cut
|
||
|
||
sub ipv4_from_hostname {
|
||
my $name = shift;
|
||
return unless $name;
|
||
my $ETCHOSTS = setting('dns')->{'ETCHOSTS'};
|
||
|
||
# check /etc/hosts file and short-circuit if found
|
||
if (exists $ETCHOSTS->{$name} and $ETCHOSTS->{$name}->[0]->[0]) {
|
||
my $ip = NetAddr::IP::Lite->new($ETCHOSTS->{$name}->[0]->[0]);
|
||
return $ip->addr if $ip and $ip->bits == 32;
|
||
}
|
||
|
||
my $res = Net::DNS::Resolver->new;
|
||
my $query = $res->search($name);
|
||
|
||
if ($query) {
|
||
foreach my $rr ($query->answer) {
|
||
next unless $rr->type eq "A";
|
||
return $rr->address;
|
||
}
|
||
}
|
||
|
||
return undef;
|
||
}
|
||
|
||
# to avoid circular dependency with App::Netdisco::Util::Permission
|
||
# supports IP addresses and CIDR blocks only
|
||
|
||
sub check_acl_no_ipaddr_only {
|
||
my ($thing, $config) = @_;
|
||
return 0 unless defined $thing and defined $config;
|
||
|
||
my $real_ip = $thing;
|
||
if (blessed $thing) {
|
||
$real_ip = ($thing->can('alias') ? $thing->alias : (
|
||
$thing->can('ip') ? $thing->ip : (
|
||
$thing->can('addr') ? $thing->addr : $thing )));
|
||
}
|
||
return 0 if !defined $real_ip
|
||
or blessed $real_ip; # class we do not understand
|
||
|
||
$config = [$config] if ref '' eq ref $config;
|
||
if (ref [] ne ref $config) {
|
||
error "error: acl is not a single item or list (cannot compare to $real_ip)";
|
||
return 0;
|
||
}
|
||
my $all = (scalar grep {$_ eq 'op:and'} @$config);
|
||
|
||
# common case of using plain IP in ACL, so string compare for speed
|
||
my $find = (scalar grep {not reftype $_ and $_ eq $real_ip} @$config);
|
||
return 1 if $find and not $all;
|
||
|
||
my $addr = NetAddr::IP::Lite->new($real_ip) or return 0;
|
||
|
||
INLIST: foreach (@$config) {
|
||
my $item = $_; # must copy so that we can modify safely
|
||
next INLIST if !defined $item or $item eq 'op:and';
|
||
|
||
my $neg = ($item =~ s/^!//);
|
||
|
||
if ($item =~ m/^group:(.+)$/) {
|
||
my $group = $1;
|
||
setting('host_groups')->{$group} ||= [];
|
||
|
||
if ($neg xor check_acl_no_ipaddr_only($thing, setting('host_groups')->{$group})) {
|
||
return 1 if not $all;
|
||
}
|
||
else {
|
||
return 0 if $all;
|
||
}
|
||
next INLIST;
|
||
}
|
||
|
||
if ($item =~ m/[:.]([a-f0-9]+)-([a-f0-9]+)$/i) {
|
||
my $first = $1;
|
||
my $last = $2;
|
||
|
||
if ($item =~ m/:/) {
|
||
next INLIST if $addr->bits != 128 and not $all;
|
||
|
||
$first = hex $first;
|
||
$last = hex $last;
|
||
|
||
(my $header = $item) =~ s/:[^:]+$/:/;
|
||
foreach my $part ($first .. $last) {
|
||
my $ip = NetAddr::IP::Lite->new($header . sprintf('%x',$part) . '/128')
|
||
or next;
|
||
if ($neg xor ($ip == $addr)) {
|
||
return 1 if not $all;
|
||
next INLIST;
|
||
}
|
||
}
|
||
return 0 if (not $neg and $all);
|
||
return 1 if ($neg and not $all);
|
||
}
|
||
else {
|
||
next INLIST if $addr->bits != 32 and not $all;
|
||
|
||
(my $header = $item) =~ s/\.[^.]+$/./;
|
||
foreach my $part ($first .. $last) {
|
||
my $ip = NetAddr::IP::Lite->new($header . $part . '/32')
|
||
or next;
|
||
if ($neg xor ($ip == $addr)) {
|
||
return 1 if not $all;
|
||
next INLIST;
|
||
}
|
||
}
|
||
return 0 if (not $neg and $all);
|
||
return 1 if ($neg and not $all);
|
||
}
|
||
next INLIST;
|
||
}
|
||
|
||
# could be something in error, and IP/host is only option left
|
||
next INLIST if ref $item;
|
||
|
||
my $ip = NetAddr::IP::Lite->new($item)
|
||
or next INLIST;
|
||
next INLIST if $ip->bits != $addr->bits and not $all;
|
||
|
||
if ($neg xor ($ip->contains($addr))) {
|
||
return 1 if not $all;
|
||
}
|
||
else {
|
||
return 0 if $all;
|
||
}
|
||
next INLIST;
|
||
}
|
||
|
||
return ($all ? 1 : 0);
|
||
}
|
||
|
||
1;
|