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