/[pxelator]/lib/PXElator/dnsd.pm
This is repository of my old source code which isn't updated any more. Go to git.rot13.org for current projects!
ViewVC logotype

Diff of /lib/PXElator/dnsd.pm

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 122 by dpavlin, Mon Aug 3 08:57:59 2009 UTC revision 259 by dpavlin, Tue Aug 18 22:02:11 2009 UTC
# Line 4  use warnings; Line 4  use warnings;
4  use strict;  use strict;
5    
6  use Net::DNS::Nameserver;  use Net::DNS::Nameserver;
7    use Net::DNS::Resolver;
8  use Data::Dump qw/dump/;  use Data::Dump qw/dump/;
9    use CouchDB;
10    
11    use server;
12    our $debug = server::debug;
13    
14    my $res = Net::DNS::Resolver->new(
15    #       nameserver => [ '10.60.0.1' ],
16            recurse => 1,
17            debug => $debug,
18    );
19    
20    our $ptr_cache;
21    sub name_ip {
22            my ( $name, $ip ) = @_;
23            $ptr_cache->{ join('.', reverse split(/\./, $ip)) } = $name;
24            return $ip;
25    }
26    
27  sub reply_handler {  sub reply_handler {
28          my ($qname, $qclass, $qtype, $peerhost,$query,$conn) = @_;          my ($qname, $qclass, $qtype, $peerhost,$query,$conn) = @_;
29          my ($rcode, @ans, @auth, @add);          my ($rcode, @ans, @auth, @add);
30    
31          print "Received query from $peerhost to ". $conn->{"sockhost"}. "\n";          $debug = server::debug;
32          $query->print;  
33            my $audit = {
34                    qname => $qname,
35                    qclass => $qclass,
36                    qtype => $qtype,
37                    peerhost =>  $peerhost,
38                    sockhost => $conn->{"sockhost"},
39                    source => 'unknown',
40            };
41    
42            $query->print if $debug;
43    
44            my $local = $1     if $qname =~ m{^(.+)\.\Q$server::domain_name\E$};
45               $local = $qname if $qname !~ m{\.};
46    
47                    my $ttl = 3600;
48          if ($qtype eq "A" && $qname eq "foo.example.com" ) {  
49                  my ($ttl, $rdata) = (3600, "10.1.2.3");          if ( $local ) {
50                  push @ans, Net::DNS::RR->new("$qname $ttl $qclass $qtype $rdata");                  warn "local[$local] $qname $qtype";
51                  $rcode = "NOERROR";                  $rcode = "NOERROR";
52          }elsif( $qname eq "foo.example.com" ) {                  my $rdata;
53                    if ( $qtype eq "A" && $local eq "server" ) {
54                            $rdata = name_ip( $local, $server::ip );
55                            $audit->{source} = 'local';
56                    } else {
57                            $rcode = "NXDOMAIN";
58                    }
59    
60                    push @ans, Net::DNS::RR->new("$qname $ttl $qclass $qtype $rdata") if $ttl;
61    
62            } elsif ( $qtype eq 'PTR' && $qname =~ m{^([0-9\.]*)\.in-addr\.arpa$} ) {
63                            if ( my $rdata = $ptr_cache->{$1} ) {
64                                    $rdata .= '.' . $server::domain_name;
65                                    push @ans, Net::DNS::RR->new("$qname $ttl $qclass $qtype $rdata");
66                                    $audit->{source} = 'PTR';
67                            } else {
68    warn "## ",dump( $ptr_cache );
69                                    $rcode = "NXDOMAIN";
70                            }
71            } elsif ( my $packet = $res->query( $qname, $qtype ) ) {
72    
73                    $audit->{source} = 'upstream';
74                    $packet->print;
75                    push @ans, $_ foreach $packet->answer;
76                  $rcode = "NOERROR";                  $rcode = "NOERROR";
77    
78          }else{          } else {
79                   $rcode = "NXDOMAIN";                  # not found
80                    $rcode = "NXDOMAIN";
81          }          }
82    
83            warn "rcode: $rcode ",dump( @ans );
84    
85            $audit->{rcode} = $rcode;
86            $audit->{ans} = [ map {
87                    my $data;
88                    foreach my $n ( keys %$_ ) {
89                            $data->{$n} = $_->{$n};
90                    }
91                    $data;
92            } @ans ];
93    
94            CouchDB::audit( 'response', $audit );
95    
96          # mark the answer as authoritive (by setting the 'aa' flag          # mark the answer as authoritive (by setting the 'aa' flag
97          return ($rcode, \@ans, \@auth, \@add, { aa => 1 });          return ($rcode, \@ans, \@auth, \@add, { aa => 1 });
98  }  }
# Line 32  sub reply_handler { Line 100  sub reply_handler {
100  sub start {  sub start {
101          my $ns = Net::DNS::Nameserver->new(          my $ns = Net::DNS::Nameserver->new(
102                  LocalPort    => 53,                  LocalPort    => 53,
103                  ReplyHandler => \&reply_handler,                  ReplyHandler => sub {
104                  Verbose      => 1,                          server->refresh;
105                            reply_handler(@_);
106                    },
107                    Verbose      => $debug,
108          ) || die "couldn't create nameserver object\n";          ) || die "couldn't create nameserver object\n";
109    
110          warn dump( $ns );          CouchDB::audit('start', { port => 53, domain_name => $server::domain_name });
111            warn "DNS $server::domain_name";
112    
113          $ns->main_loop;          $ns->main_loop;
114  }  }
115    
116  1;  1;
Legend:
Removed from v.122  
changed lines
  Added in v.259
  ViewVC Help
Powered by ViewVC 1.1.26