chiark / gitweb /
Bugfixes.
[chiark-utils.git] / scripts / named-conf
1 #!/usr/bin/perl -w
2
3 use strict;
4 use IO::File;
5 use Data::Dumper;
6 use POSIX;
7
8 use vars qw($quis
9             $mode $doall
10             $etcfile $where
11             $debug $needglue $localonly $verbosity);
12
13 $quis= $0; $quis =~ s,.*/,,;
14
15 $mode= '';
16 $doall= 0;
17 $etcfile= "/etc/bind/chiark-conf-gen.zones";
18 $where= '<built-in>';
19 $debug= 0;
20 $needglue= 2;
21 $localonly= 0;
22 $verbosity= 1;
23
24 use vars qw($dig_owner $dig_type $dig_rdata);
25
26 while (@ARGV && $ARGV[0] =~ m/^\-/) {
27     $_= shift @ARGV;
28     if (s/^\-\-//) {
29         last if m/^$/;
30         if (m/^(yes|no|force)$/) { m/^./; $mode= $&; }
31         elsif (m/^all$/) { $doall=1; }
32         elsif (m/^config$/) { $etcfile= loarg(); $where= '--config option'; }
33         elsif (m/^glueless$/) { $needglue--; }
34         elsif (m/^localonly$/) { $localonly=1; }
35         elsif (m/^quiet$/) { $verbosity=0; }
36         elsif (m/^verbose$/) { $verbosity=2; }
37         else { usageerr("unknown option --$_"); }
38     } else {
39         s/^\-//;
40         last if m/^$/;
41         while (m/^./) {
42             if (s/^[ynf]//) { $mode=$&; }
43             elsif (s/^A//) { $doall=1; }
44             elsif (s/^C//) { $etcfile= soarg(); $where= '-C option'; }
45             elsif (s/^D//) { $debug++; }
46             elsif (s/^g//) { $needglue--; }
47             elsif (s/^l//) { $localonly=1; }
48             elsif (s/^q//) { $verbosity=0; }
49             elsif (s/^v//) { $verbosity=2; }
50             else { usageerr("unknown option -$&"); }
51         }
52     }
53 }
54
55 sub loarg() { usageerr("missing option value") if !@ARGV; return shift @ARGV; }
56 sub soarg() { my ($rv); $rv=$_; $_=''; return length $rv ? $rv : loarg(); }
57
58 usageerr("-g may be specified at most twice") if $needglue<0;
59 usageerr("-D may be specified at most twice") if $debug>2;
60 usageerr("must specify either -f|-y|-n or zones (and not both)")
61     if !!$mode == !!@ARGV;
62
63 sub usageerr ($) {
64     die
65 "$_[0]
66 usage: named-conf-regen [-rvq] -f|-y|-n|<zone>...\n".
67 "operation modes:\n".
68 " -f --force   install without checking\n".
69 " -y --yes     check and install\n".
70 " -n --no      check only\n".
71 "additional options:\n".
72 " -q --quiet   no output for OK zones\n".
73 " -v --verbose extra verbose\n";
74 }
75
76 cfg_fail("config filename $etcfile should not be directory")
77     if $etcfile =~ m,/$,;
78
79 use vars qw($default_dir);
80 $default_dir= $etcfile =~ m,^.*/, ? $& : './';
81
82 use vars qw($slave_dir $slave_prefix $slave_suffix);
83 $slave_dir= 'slave';
84 $slave_prefix= '';
85 $slave_suffix= '';
86
87 use vars qw(@self_ns @self_soa @self_addr);
88 @self_ns= @self_soa= @self_addr= ();
89
90 use vars qw(%zone_cfg @zone_cfg_list);
91 %zone_cfg= ();
92 @zone_cfg_list= ();
93
94 use vars qw($output $default_output %output_contents);
95 $output= '';
96 $default_output= '';
97 %output_contents= ();
98
99 use vars qw($check $install);
100 $check= $mode !~ m/^f/;
101 $install= $mode =~ m/^[yf]/;
102
103 read_config($etcfile);
104 debug_dump('@zone_cfg_list %zone_cfg');
105 process_zones($mode ? @zone_cfg_list : @ARGV);
106 debug_dump('%output_contents');
107 output_files() if $install;
108
109 exit 0;
110
111 #-------------------- configuration reading
112
113 sub cfg_fail ($) { die "$quis: $where:\n $_[0]\n"; }
114
115 sub read_config ($) {
116     my ($if) = @_;
117     my ($fh,$z,@self,$before,
118         $mod,$dir,$prefix,$suffix,$subfile,$lprefix,$lsuffix,$zf);
119     local ($_);
120
121     $fh= new IO::File $if,'r' or cfg_fail("open $if:\n $!");
122     $before= '';
123     for (;;) {
124         if (!defined($_= <$fh>)) {
125             cfg_fail("read config file $if:\n $!") if $fh->error();
126             last;
127         }
128         chomp; s/\s+$//;
129         if (m/\\$/) { $before.= $_; next; }
130         $_= $before.$_;
131         $before= '';
132         s/^\s+//;
133         $where= "$if:$.";
134         next if m/^\#/;
135         last if m/^end$/;
136         next unless m/\S/;
137         if (m/^self(\-ns|\-soa|)\s+(\S.*\S)/) {
138             @self= split /\s+/, $2;
139             @self_ns= @self if $1 ne '-soa';
140             @self_soa= @self if $1 ne '-ns';
141         } elsif (m/^self\-addr\s+([0-9. \t]+)/) {
142             @self_addr= split /\s+/, $1;
143         } elsif (m,^
144                  primary\-dir ([*?]?)
145                  \s+ (\S+)/([^/ \t]*)
146                  (?: \s+ ([^/ \t]*) (?: (/.+) )?
147                   )?
148                  $,x) {
149             ($mod, $dir, $prefix, $suffix, $subfile) =
150                 ($1,qualify($2),$3,$4,$5);
151             $suffix= '' if !defined $suffix;
152             $subfile= '' if !defined $subfile;
153             $suffix= '_db' if !length $suffix && !length $subfile;
154             if (-d "$dir/$prefix") { $dir.='/'; $dir.=$prefix; $prefix=''; }
155             opendir D, $dir or cfg_fail("open primary-dir $dir:\n $!");
156             $lprefix= length $prefix; $lsuffix= length $suffix;
157             while (defined($_= readdir D)) {
158                 next if m/^\./ && !$lprefix;
159                 next unless length > $lprefix+$lsuffix;
160                 next unless substr($_,0,$lprefix) eq $prefix;
161                 next unless substr($_,length($_)-$lsuffix) eq $suffix;
162                 $z= substr($_,$lprefix,length($_)-($lprefix+$lsuffix));
163                 $zf= $dir.'/'.$prefix.$z.$suffix.$subfile;
164                 if (!stat $zf) {
165                     next if length $subfile && $! == &ENOENT;
166                     cfg_fail("cannot stat zonefile $zf:\n $!");
167                 }
168                 -f _ or cfg_fail("zonefile $zf is not a plain file");
169                 zone_conf($z,'primary','p',$mod,$zf);
170             }
171             closedir D or cfg_fail("close primary-dir $dir:\n $!");
172         } elsif (m/^primary([*?]?)\s+(\S+)\s+(\S+)$/) {
173             zone_conf($2,'primary','p',$1,qualify($3));
174         } elsif (m/^published([*?]?)\s+(\S+)\s+([0-9.\t]+)$/) {
175             zone_conf($2,'published','s',$1,'',$3);
176         } elsif (m/^stealth([*?]?)\s+(\S+)\s+([0-9. \t]+)$/) {
177             zone_conf($2,'stealth','u',$1,'',split /\s+/, $3);
178         } elsif (m/^slave\-dir\s+(\S+)(?:(?:\s+(\S+))\s+(\S+))?$/) {
179             ($slave_dir, $slave_prefix, $slave_suffix) = (qualify($1),$2,$3);
180             $slave_prefix='' if !defined $slave_prefix;
181             $slave_suffix='' if !defined $slave_suffix;
182         } elsif (m/^output\s+bind8\+(\S+)$/) {
183             cfg_fail("default output may not apply to only some zones")
184                 if @zone_cfg_list && length $default_output;
185             set_output(qualify($1));
186         } elsif (m/^include\s+(\S+)$/) {
187             read_config($1);
188         } else {
189             cfg_fail("unknown configuration directive".
190                      " or incorrect syntax or arguments");
191         }
192     }
193     $fh->close or cfg_fail("close config file $if:\n $!");
194 }
195
196 sub qualify ($) {
197     my ($i) = @_;
198     $i= "$default_dir$i" unless $i =~ m,^/,;
199     return $i;
200 }
201
202 sub zone_conf ($$$$$@) {
203     my ($zone,$style,$sabbr,$mod,$file,@servers) = @_;
204     my ($sfx,$aref);
205     $file= qualify("$slave_dir/$slave_prefix".$zone.$slave_suffix)
206         unless length $file;
207     if (!length $output) {
208         $default_output= qualify('chiark-conf-gen.bind8')
209             unless length $default_output;
210         set_output($default_output);
211     }
212     cfg_fail("redefined zone $zone\n".
213              " earlier definition $zone_cfg{$zone}{'where'}")
214         if exists $zone_cfg{$zone};
215     $zone_cfg{$zone}{'where'}= $where;
216     $zone_cfg{$zone}{'file'}= $file;
217     $zone_cfg{$zone}{'style_p'}= $style.$mod;
218     $zone_cfg{$zone}{'s'}= $sabbr.$mod; # p)rimary s)econdary u)npub f)oreign
219     $zone_cfg{$zone}{'servers'}= [ @servers ];
220     foreach $sfx (qw(soa ns addr)) {
221         { no strict 'refs'; $aref= [ @{ "self_$sfx" } ]; }
222         @$aref or cfg_fail("failed to specify self-$sfx before zone");
223         $zone_cfg{$zone}{"self_$sfx"}= $aref;
224     }
225     $zone_cfg{$zone}{'output'}= $output;
226     push @zone_cfg_list, $zone;
227 }
228
229 sub set_output($) {
230     my ($newout) = @_;
231     $output= $newout;
232     $output_contents{$output}= '';
233 }
234
235
236 #-------------------- checking
237
238 use vars qw($zone $cfg $warnings);
239 $warnings= 0;
240
241 sub progress ($) {
242     return if !$verbosity;
243     print "$_[0]\n";
244 }
245
246 sub verbose ($) {
247     return if $verbosity<2;
248     print "    $_[0]\n";
249 }
250
251 sub process_zones (@) {
252     my (@zones) = @_;
253     local ($zone,$cfg);
254
255     foreach $zone (@zones) {
256         $cfg= $zone_cfg{$zone} || {
257             'style_p' => 'foreign',
258             's' => 'f',
259             'servers' => [ ],
260             };
261         progress(sprintf "%-40s %s", $zone, $$cfg{'style_p'});
262         if ($check && ($doall || $cfg->{'s'} !~ m/\?/)) {
263             eval {
264                 if ($localonly && $cfg->{'s'} =~ m/f/) {
265                     zone_warning("foreign zone specified with -l");
266                 } elsif ($cfg->{'s'} =~ m/\*/ ||
267                          ($localonly && $cfg->{'s'} !~ m/p/)) {
268                     zone_check_local();
269                 } else {
270                     zone_check_full();
271                 }
272             };
273             zone_warning("checks failed: $@") if length $@;
274         }
275         $output_contents{$$cfg{'output'}} .= zone_output()
276             if $install;
277     }
278     print STDERR "$quis: $warnings warnings\n" or die $!
279         if $warnings;
280 }
281
282 sub zone_warning ($) {
283     my ($w) = @_;
284     $w =~ s/\n$//;
285     $w =~ s,\n, // ,g;
286     print STDERR "$zone: warning: $w\n" or die $!;
287     $warnings++;
288 }
289
290 sub zone_warnmore ($) {
291     print STDERR "$zone:  $_[0]\n" or die $!;
292 }
293
294 use vars qw(%delgs); # $delgs{$nameserver_list} = [ $whosaidandwhy ]
295 use vars qw(%auths); # $auths{$nameserver_list} = [ $whosaidandwhy ]
296 use vars qw(%glue);  # $glue{$name}{$addr_list} = [ $whosaidandwhy ]
297 use vars qw(%soas);  # $soa{"$origin $serial"} = [ $whosaidandwhy ]
298 use vars qw(%addr_is_ok %warned_glueless %warned_mynameaddr);
299 use vars qw($delg_to_us);
300 use vars qw(@to_check); # ($addr,$whyask,$is_auth,$glueless_ok, ...)
301 use vars qw(@to_check_soa); # ($addr,$whyask, ...)
302
303 sub zone_check_full () {
304     zone_reset();
305     zone_investigate();
306     zone_consistency();
307     zone_servers_ok();
308 }
309
310 sub zone_reset() {
311     %delgs= %auths= %glue= %soas=
312         %warned_glueless= %warned_mynameaddr=
313             %addr_is_ok= ();
314     $delg_to_us= 0;
315     @to_check= @to_check_soa= ();
316 }
317
318 sub zone_investigate() {
319     my ($super_zone, @super_nsnames,
320         $super_ns, @super_ns_addrs, $s, $wa, $is_auth,
321         %nsrrset_checked, %soa_checked, $addr, $glueless_ok, $rcode);
322
323     $super_zone= $zone;
324     for (;;) {
325         debug_trace("zone $zone superzone $super_zone");
326         $super_zone =~ s/^[^.]+\.// or die "no superzone ? ($super_zone)\n";
327         ($rcode,@super_nsnames)= lookup($super_zone,'ns-','06');
328         last if !$rcode;
329     }
330     for $super_ns (@super_nsnames) {
331         $super_ns= lc $super_ns;
332         ($rcode,@super_ns_addrs)= lookup($super_ns,'a','0');
333         foreach $addr (@super_ns_addrs) {
334             push @to_check,
335                  $addr,
336                  "$super_ns, server for $super_zone",
337                  0, 0;
338         }
339     }
340     for (;;) {
341         # We do these in order so that we always do NS RRset checks on
342         # nameservers that came from other NS RRsets first; otherwise
343         # we might set nsrrset_checked due to a glueless_ok check,
344         # and then not check for gluefulness later.
345         debug_dump('@to_check @to_check_soa');
346         if (($addr,$wa,$is_auth,$glueless_ok,@to_check) = @to_check) {
347             push @to_check_soa, $addr, $wa if $is_auth;
348             next if $nsrrset_checked{$addr}++;
349             zone_check_nsrrset($addr, "[$addr] $wa",
350                                $is_auth, $glueless_ok);
351         } elsif (($addr,$wa,@to_check_soa) = @to_check_soa) {
352             next if $soa_checked{$addr}++;
353             zone_check_soa($addr,"[$addr] $wa","[$addr] NS");
354         } else {
355             last;
356         }
357     }
358 }
359
360 sub zone_check_nsrrset ($$$$) {
361     my ($uaddr,$ww, $is_auth, $glueless_ok) = @_;
362     my (@s, $s, %s2g, @glue, $glue, $delgs_or_auths, $wwn);
363     verbose("checking delegation by $ww");
364     dig(sub {
365         if ($dig_type eq 'ns' && $dig_owner eq $zone) {
366             $s2g{lc $dig_rdata} = [ ];
367         } elsif ($dig_type eq 'a' && exists $s2g{$dig_owner}) {
368             $wwn= "in glue from $ww";
369             push @to_check, $dig_rdata, "$dig_owner, $wwn", 1, 0;
370             zone_server_addr($dig_rdata,$dig_owner,$wwn,"NS [$uaddr]",0);
371             push @{ $s2g{$dig_owner} }, $dig_rdata;
372         }
373     },
374              $zone,'ns',$uaddr);
375     if (!%s2g) { zone_warning("unable to find NS RRset at $ww"); return; }
376     elsif (keys %s2g == 1) { zone_warning("only one nameserver at $ww"); }
377     @s= sort keys %s2g;
378     foreach $s (@s) {
379         @glue= @{ $s2g{$s} };
380         if (!@glue) {
381             zone_warning("glueless NS $s,".
382                          ($needglue<=1 ? " (eg)" : "").
383                          " from $ww")
384                 unless $glueless_ok || !$needglue ||
385                        ($needglue<=1 && $warned_glueless{$s}++);
386             next;
387         }
388         $glue= join ' ', sort @glue;
389         push @{ $glue{$s}{$glue} }, $ww;
390     }
391     $s= join ' ', @s;
392     $delgs_or_auths= $is_auth ? \%auths : \%delgs;
393     push @{ $delgs_or_auths->{$s} }, $ww;
394 }
395
396 sub zone_server_addr ($$$$$) {
397     my ($addr,$name,$ww,$wwq,$is_soa) = @_;
398     $addr_is_ok{$addr}= "$name ($wwq)"
399         if $is_soa || $cfg->{'s'} =~ m/u/;
400     zone_warning("configured as stealth but we [$addr]".
401                  " are published ($name $wwq)")
402         if $cfg->{'s'} =~ m/u/ && grep { $_ eq $addr } @self_addr;
403
404     my ($name_is_self, $addr_is_self);
405     $name_is_self= grep { $_ eq $name }
406         @{ $cfg->{$is_soa ? 'self_soa' : 'self_ns'} };
407     $addr_is_self= grep { $_ eq $addr }
408         @{ $cfg->{'self_addr'} };
409     if ($name_is_self && !$addr_is_self) {
410         zone_warning("our name $name with wrong address [$addr], (eg) $ww")
411             unless $warned_mynameaddr{$name}{$addr}++;
412     } elsif (!$name_is_self && $addr_is_self) {
413         zone_warning(($is_soa ? "SOA ORIGIN maps to" : "allegedly served by").
414                      " us [$addr] with wrong name $name, (eg) $ww")
415             unless $warned_mynameaddr{$name}{$addr}++;
416     }
417     $delg_to_us=1 if $name_is_self;
418 }
419
420 sub zone_check_soa ($$$) {
421     my ($uaddr,$ww,$wwq) = @_;
422     my ($lame,$origin,$got,$rcode,@soa_addrs,$soa_addr,$wwn);
423     verbose("checking service at $wwq");
424     $lame= 'dead or lame';
425     dig(sub {
426         if ($dig_type eq 'flags:') {
427             $lame= $dig_rdata =~ m/ aa / ? '' : 'lame';
428         } elsif ($dig_type eq 'soa' && $dig_owner eq $zone && !$lame) {
429             die "several SOAs ? $ww" if defined $origin;
430             $got= $dig_rdata;
431             $got =~ m/^(\S+) \d+/ or die "$got ?";
432             $origin= $1;
433         }
434     },
435              $zone,'soa',$uaddr);
436     $lame= 'broken' if !$lame && !defined $origin;
437     if ($lame) { zone_warning("$lame server $ww"); return; }
438     push @{ $soas{$got} }, $ww;
439     ($rcode,@soa_addrs)= lookup($origin,'a','0');
440     foreach $soa_addr (@soa_addrs) {
441         $wwn= "SOA ORIGIN from $ww";
442         zone_server_addr($soa_addr,$origin,$wwn,"SOA [$uaddr]",1);
443         push @to_check, $soa_addr, "$origin, $wwn";
444     }
445 }
446
447 sub zone_consistency() {
448     my ($d, $org_ser, $origin, $a, $h, $self_soa);
449     zone_consistency_set('delegations',\%delgs);
450     foreach $d (keys %delgs) { delete $auths{$d}; }
451     zone_consistency_set('zone nameserver rrset',\%auths);
452     foreach $h (keys %glue) {
453         zone_consistency_set("glue for $h", $glue{$h});
454     }
455     zone_consistency_set("SOA ORIGIN and SERIAL",\%soas);
456     $self_soa= $cfg->{'self_soa'};
457     if ($cfg->{'s'} =~ m/p/) {
458         foreach $org_ser (keys %soas) {
459             $org_ser =~ m/^(\S+) \d+$/ or die "$org_ser ?";
460             $origin= $1;
461             next if grep { $_ eq $origin } @$self_soa;
462             zone_warning("SOA ORIGIN $origin is not our name (@$self_soa),".
463                          " eg from ".($soas{$org_ser}[0]));
464         }
465     }
466 }
467
468 sub zone_servers_ok () {
469     my ($showok);
470     if (%addr_is_ok) {
471         $showok= 0;
472         foreach $a (@{ $cfg->{'servers'} }) {
473             next if exists $addr_is_ok{$a};
474             zone_warning("we slave from $a"); $showok=1;
475         }
476         if ($showok) {
477             foreach $a (keys %addr_is_ok) {
478                 zone_warnmore("permitted master [$a] $addr_is_ok{$a}");
479             }
480         }
481     }
482     if ($cfg->{'s'} =~ m/s/ && !$delg_to_us) {
483         zone_warning("we are supposedly published secondary,".
484                      " but not listed as a nameserver");
485     }
486 }
487
488 sub zone_consistency_set ($%) {
489     my ($msg,$set) = @_;
490     my ($d,$o);
491     if (keys(%$set) > 1) {
492         zone_warning("inconsistent $msg:");
493         foreach $d (keys %$set) {
494             foreach $o (@{ $set->{$d} }) { zone_warnmore(" $d from $o"); }
495         }
496     }
497 }
498
499 sub zone_check_local () {
500     zone_reset();
501     zone_servers_simplefind();
502     zone_servers_ok();
503 }
504
505 sub zone_servers_simplefind () {
506     my ($rcode,@nsnames,$ns,@soas,$origin);
507
508     ($rcode,@nsnames)= lookup($zone,'ns-','0');
509     foreach $ns (@nsnames) { zone_server_simple($ns,'NS',0); }
510
511     ($rcode,@soas)= lookup($zone,'soa','0');
512     die "multiple SOA RRs in set!  @soas ?" if @soas!=1;
513     $soas[0] =~ m/^(\S+)\s/ or die "SOA ? $_";
514     zone_server_simple(domain_canon($1),'SOA',1);
515 }
516
517 sub zone_server_simple ($$$) {
518     my ($name,$ww,$is_soa) = @_;
519     my ($rcode,@addrs,$addr);
520     ($rcode,@addrs)= lookup($name,'a','0');
521     foreach $addr (@addrs) { zone_server_addr($addr,$name,$ww,$ww,$is_soa); }
522 }
523
524 #-------------------- outputting
525
526 sub zone_output () {
527     my ($o,$m);
528
529     $o= "zone \"$zone\" {\n";
530     if ($$cfg{'s'} =~ m/p/) {
531         $o.= "    type master;\n";
532     } else {
533         $o.= "    type slave;\n".
534              "    masters {\n";
535         foreach $m (@{ $$cfg{'servers'} }) { $o.= "        $m;\n"; }
536         $o.= "    };\n";
537     }
538     $o.= "    file \"$$cfg{'file'}\";\n";
539     $o.= "};\n";
540     return $o;
541 }
542
543 sub output_files () {
544     my ($fn,$ofn,$mfn,$l,$dir, $maxmode,$h,@to_install);
545     
546     foreach $ofn (keys %output_contents) {
547         $fn= $ofn; $mfn= "output file $fn";
548         for (;;) {
549             if (!lstat $fn) {
550                 $! == &ENOENT or die "$quis: stat $mfn:\n $!\n";
551                 $maxmode= 0666;
552                 last;
553             } elsif (-f _) {
554                 $maxmode= (stat _)[2];
555                 last;
556             } elsif (-l _) {
557                 defined($l= readlink $fn)
558                     or die "$quis: readlink $mfn:\n $!\n";
559                 $dir= $fn =~ m,^.*/, ? $& : './';
560                 $fn= "$dir$l" unless $l =~ m,^/,;
561                 $mfn= "output file $fn (symlink target of $ofn)";
562             } else {
563                 die "$quis: output file $mfn exists but is not a file".
564                     " (or symlink to one)";
565             }
566         }
567         unlink "$fn.new" or $! == &ENOENT or
568             die "$quis: cannot clear out old .new version of $mfn:\n $!";
569         $h= new IO::File "$fn.new",'w',$maxmode
570             or die("$quis: create .new version of $mfn:\n $!");
571         print $h
572             "# generated by $quis, do not edit\n",
573             $output_contents{$ofn}
574             or die "$quis: write data to .new version of $mfn:\n $!";
575         $h->close
576             or die "$quis: close .new version of $mfn:\n $!";
577         push @to_install, $fn,$mfn;
578     }
579
580     while (($fn,$mfn, @to_install) = @to_install) {
581         rename "$fn.new",$fn
582             or die "$quis: install new version of $mfn:\n $!";
583     }
584 }
585
586 #-------------------- general utilities
587
588 sub debug_dump ($) {
589     my ($vn);
590     return unless $debug>1;
591     local $Data::Dumper::Terse=1;
592     foreach $vn (split /\s+/, $_[0]) {
593         print "$vn := ", eval "Dumper(\\$vn)";
594     }
595 }
596
597 sub debug_trace ($) {
598     return unless $debug;
599     print "D $_[0]\n";
600 }
601
602 sub lookup ($$$) {
603     my ($domain,$type,$okrcodes) = @_;
604     my ($c,$h,@result);
605     debug_trace("lookup ==> (->$okrcodes) $domain $type");
606     $h= new IO::Handle;
607
608     defined($c= open $h, "-|") or die "$quis: fork adnshost:\n $!\n";
609     if (!$c) {
610         exec 'adnshost','-Fi','+Do','+Dt','+Dc','-Cf',"-t$type",
611              '-',"$domain.";
612         die "$quis: exec adnshost:\n $!\n";
613     }
614     @result= $h->getlines();
615     $h->error and die "$quis: read from adnshost:\n $!\n";
616     chomp @result;
617     $!=0; $h->close;
618     die "$quis: lookup -t$type $domain $okrcodes failed $? $! @result\n"
619         if $! or $?>6 or index($okrcodes,$?)<0;
620     debug_trace("lookup <== $? @result");
621     return ($?,@result);
622 }
623
624
625 sub dig (&$$$) {
626     my ($eachrr, $qowner,$qtype,$qaddr) = @_;
627     # also pseudo-rr with type `flags:'
628     my ($h,$inmid,$irdata,$c);
629     local ($_);
630
631     debug_trace("dig ==> \@$qaddr $qowner $qtype");
632
633     $h= new IO::Handle;
634     defined($c= open $h, "-|") or die "$quis: fork dig:\n $!\n";
635     if (!$c) {
636         open STDERR, ">&STDOUT" or die $!;
637         exec ('dig',
638               '+nodef','+nosea','+nodebug','+norecurse',
639               "\@$qaddr",'-t',$qtype,$qowner);
640         die "$quis: exec dig:\n $!\n";
641     }
642     $inmid='';
643     for (;;) {
644         if (!defined($_= $h->getline())) {
645             $h->error() and die "$quis: read from dig:\n $!\n";
646             last;
647         }
648         chomp;
649         if (length $inmid) {
650             s/^\s+/ / or die "$inmid // $_ ?";
651             s/\;.*$//;
652             $_= $inmid.$_;
653             $inmid='';
654             s/$/ \(/ unless s/\s*\)\s*$//;
655         }
656         if (s/\s*\(\s*$//) { $inmid= $_; next; }
657         if (m/^\;\; flags\:( [-0-9a-z ]+)\;/) {
658             $dig_owner=''; $dig_type='flags:'; $dig_rdata= "$1 ";
659             debug_trace("dig  f: $dig_rdata");
660             &$eachrr;
661         } elsif (m/^\;/) {
662         } elsif (!m/\S/) {
663         } elsif (m/^([-.0-9a-z]+)\s+\d\w+\s+in\s+([a-z]+)\s+(\S.*)/i) {
664             $dig_owner=domain_canon($1); $dig_type=lc $2; $irdata=$3;
665             if ($dig_type eq 'a') {
666                 $irdata =~ m/^[.0-9]+$/ or die "$irdata ?";
667                 $dig_rdata= $&;
668             } elsif ($dig_type eq 'ns') {
669                 $irdata =~ m/^[-.0-9a-z]+$/i or die "bad nameserver $irdata ?";
670                 $dig_rdata= domain_canon($irdata);
671             } elsif ($dig_type eq 'soa') {
672                 $irdata =~ m/^([-.0-9a-z]+)\s+.*\s+(\d+)(?:\s+\d\w+){4}$/i
673                     or die "bad SOA $irdata ?";
674                 $dig_rdata= domain_canon($1).' '.$2;
675             } else {
676                 debug_trace("ignoring uknown RR type $dig_type");
677                 next;
678             }
679             debug_trace("dig  $dig_owner $dig_type $dig_rdata");
680             &$eachrr;
681         } else {
682             debug_trace("ignoring unknown dig output $_");
683         }
684     }
685     $h->close;
686     debug_trace("dig <== gave $?");
687 }
688
689 sub domain_canon ($) {
690     local ($_) = @_;
691     s/(.)\.$/$1/;
692     die "domain $_ ?" unless m/^[0-9a-z]/i;
693     return lc $_;
694 }