Files
ldap2dns/scripts/data2ldif.pl
Ben Klang 293e832003 * Add new TXT record handling
* Change struct resourcerecord SRV member names to be consistent with other members


git-svn-id: https://svn.alkaloid.net/gpl/ldap2dns/trunk@457 06cd67b6-e706-0410-b29e-9de616bca6e9
2008-07-24 18:16:47 +00:00

461 lines
17 KiB
Perl
Executable File

#!/usr/bin/perl
# $Id$
use strict;
use warnings;
use POSIX qw(strftime);
my $file = $ARGV[0];
my $output = $ARGV[1];
my $rejout;
my $basedn = $ARGV[2];
my %domains; # Keep track of which domains for which we have
# already written an SOA
my $outfh;
my $rejfh;
my $newserial = strftime("%Y%m%d01", localtime);
my $errorrecs = 0;
if (!defined($file)) {
print STDERR "\n";
print STDERR " Must specify path to 'data' file to read\n";
print STDERR "\n";
usage();
die("Should never get here\n");
}
if (!defined($output)) {
print STDERR "\n";
print STDERR " Must specify path to output LDIF data\n";
print STDERR "\n";
usage();
die("Should never get here\n");
}
if (!defined($basedn)) {
print STDERR "\n";
print STDERR " Must specify a base DN as the third argument\n";
print STDERR "\n";
usage();
die("Should never get here\n");
}
if ($output eq '-') {
$output = "/dev/stdout";
# Rejects are already printed to STDERR by default. No need to duplicate
$rejout = "/dev/null";
} else {
$rejout = "$output.rej";
}
open($outfh, ">$output") or die ("Unable to open $output for writing!");
open($rejfh, ">$rejout") or die ("Unable to open $rejout for writing");
$basedn =~ /^ou=([^,]+)/;
my $baserdn = $1;
if (!$baserdn) {
print STDERR "Unable to determine branch node for DNS data from supplied DN\n";
print STDERR "Put an \"ou=foo\" branch in the DN\n";
die;
}
# Create the base DN for DNS entries
print $outfh "
# Generated by data2ldif.pl, part of the ldap2dns package
# (C) 2005-2006 Ben Klang <ben\@alkaloid.net>
# http://projects.alkaloid.net
dn: $basedn
objectClass: top
objectClass: organizationalUnit
ou: $baserdn
";
# We run in two iterations. The first attempts to enumerate all zones
# for which we have records and create SOAs in LDAP. The reason for this is
# zones are used as a container for all records so they must be in place before
# we start to add any zone data. While it takes longer, this mechanism ensures
# the proper sequence.
open(DATA, $file) or die ("Unable to open $file for reading\n");
LINE: while(<DATA>) {
chomp;
for ($_) {
/^\s*#/ && do {
# Found a comment
next LINE;
};
/^-/ && do {
# Found a disabled A record
print STDERR "Ignoring disabled record: $_\n";
$errorrecs++;
print $rejfh "$_\n";
next LINE;
};
/^%/ && do {
# Location definition: %code:1.2.3.4
my ($loc, $ip) = split /:/;
$loc =~ s/^%//;
print $outfh "dn: dnslocation=$loc,$basedn\n";
print $outfh "objectClass: top\n";
print $outfh "objectClass: dnsloccodes\n";
print $outfh "dnslocation: $loc\n";
if (defined($ip) && $ip) {
print $outfh "dnsipaddr: $ip\n";
} else {
print $outfh "dnsipaddr: :\n";
}
print $outfh "\n";
next LINE;
}; # End location definition
/^Z/ && do {
my ($domain, $master, $admin, $serial, $refresh, $retry, $expire,
$minimum, $ttl, $timestamp, $loc) = split /:/;
$domain =~ s/^Z//;
print $outfh "dn: cn=$domain,$basedn\n";
print $outfh "objectClass: top\n";
print $outfh "objectClass: dnszone\n";
print $outfh "cn: $domain\n";
print $outfh "dnszonename: $domain\n";
print $outfh "dnszonemaster: $master\n";
print $outfh "dnsadminmailbox: $admin\n";
if ($serial) {
print $outfh "dnsserial: $serial\n";
} else {
print $outfh "dnsserial: $newserial\n";
}
if ($refresh) { print $outfh "dnsrefresh: $refresh\n"; }
if ($retry) { print $outfh "dnsretry: $retry\n"; }
if ($expire) { print $outfh "dnsexpire: $expire\n"; }
if ($minimum) { print $outfh "dnsminimum: $minimum\n"; }
if ($ttl) { print $outfh "dnsttl: $ttl\n"; }
if ($timestamp) { print $outfh "dnstimestamp: $timestamp\n"; }
if ($loc) { print $outfh "dnslocation: $loc\n"; }
print $outfh "\n";
}; # End SOA record
/^\./ && do {
# NS+SOA+A Record
my ($fqdn, $ip, $x, $ttl, $timestamp, $loc) = split /:/;
$fqdn =~ s/^\.//;
if (!length($x)) {
print STDERR "Missing hostname in NS/A/SOA record: $_\n";
$errorrecs++;
print $rejfh "$_\n";
next LINE;
}
my $domain = $fqdn;
if (defined($domains{$domain})) {
# We've already generated an SOA for this domain
next LINE;
}
print $outfh "dn: cn=$domain,$basedn\n";
print $outfh "objectClass: top\n";
print $outfh "objectClass: dnszone\n";
print $outfh "cn: $domain\n";
print $outfh "dnszonename: $domain\n";
print $outfh "dnszonemaster: $x";
# If $x contains a period treat it as fully qualified
if ($x =~ /\./) {
print $outfh ".";
}
print $outfh "\n";
print $outfh "dnsadminmailbox: hostmaster.$domain\n";
print $outfh "dnsserial: $newserial\n";
if (defined($ttl)) { print $outfh "dnsttl: $ttl\n"; }
if (defined($timestamp)) { print $outfh "dnstimestamp: $timestamp\n"; }
if (defined($loc)) { print $outfh "dnslocation: $loc\n"; }
print $outfh "\n";
$domains{$domain} = 1;
next LINE;
};
} # End for($_) block
} # End LINE while(<DATA>)
# Done with zone SOAs, being with resource records
seek(DATA, 0, 0) or die ("Unable to seek $file for reading\n");
LINE: while(<DATA>) {
chomp;
for ($_) {
/^\s*#/ && do {
# Found a comment
next LINE;
};
/^-/ && do {
# Found a disabled. User was warned above
next LINE;
};
/^\./ && do {
# Found NS + A + SOA (SOA handled above)
my ($fqdn, $ip, $x, $ttl, $timestamp, $loc) = split /:/;
$fqdn =~ s/^\.//;
if (!defined($ip)) { $ip = ""; }
if (!defined($x)) { $x = ""; }
if (!defined($ttl)) { $ttl = ""; }
if (!defined($timestamp)) { $timestamp = ""; }
if (!defined($loc)) { $loc = ""; }
my $id = "NSA-$fqdn-$ip-$x-$ttl-$timestamp-$loc";
my $domain = $fqdn;
print $outfh "dn: cn=$id,cn=$domain,$basedn\n";
print $outfh "objectClass: top\n";
print $outfh "objectClass: dnszone\n";
print $outfh "objectClass: dnsrrset\n";
print $outfh "cn: $id\n";
print $outfh "dnstype: ns\n";
print $outfh "dnsdomainname: $fqdn.\n";
if ($x) { print $outfh "dnscname: $x"; }
# If $x contains a period treat it as fully qualified
if ($x =~ /\./) {
print $outfh ".";
}
print $outfh "\n";
if ($ip) { print $outfh "dnsipaddr: $ip\n"; }
if ($ttl) { print $outfh "dnsttl: $ttl\n"; }
if ($timestamp) { print $outfh "dnstimestamp: $timestamp\n"; }
if ($loc) { print $outfh "dnsloc: $loc\n"; }
print $outfh "\n";
next LINE;
};
/^&/ && do {
# Found NS
my ($fqdn, $ip, $x, $ttl, $timestamp, $loc) = split /:/;
$fqdn =~ s/^&//;
if (!defined($ip)) { $ip = ""; }
if (!defined($x)) { $x = ""; }
if (!defined($ttl)) { $ttl = ""; }
if (!defined($timestamp)) { $timestamp = ""; }
if (!defined($loc)) { $loc = ""; }
my $id = "NS-$fqdn-$ip-$x-$ttl-$timestamp-$loc";
my $domain = $fqdn;
print $outfh "dn: cn=$id,cn=$domain,$basedn\n";
print $outfh "objectClass: top\n";
print $outfh "objectClass: dnszone\n";
print $outfh "objectClass: dnsrrset\n";
print $outfh "cn: $id\n";
print $outfh "dnstype: ns\n";
print $outfh "dnsdomainname: $fqdn.\n";
if ($ip) { print $outfh "dnsipaddr: $ip\n"; }
if ($x) { print $outfh "dnscname: $x.\n"; }
if ($ttl) { print $outfh "dnsttl: $ttl\n"; }
if ($timestamp) { print $outfh "dnstimestamp: $timestamp\n"; }
if ($loc) { print $outfh "dnsloc: $loc\n"; }
print $outfh "\n";
next LINE;
};
/^=/ && do {
# Found an A + PTR
my ($fqdn, $ip, $ttl, $timestamp, $loc) = split /:/;
$fqdn =~ s/^=//;
if (!defined($ip)) { $ip = ""; }
if (!defined($ttl)) { $ttl = ""; }
if (!defined($timestamp)) { $timestamp = ""; }
if (!defined($loc)) { $loc = ""; }
my $id = "APTR-$fqdn-$ip-$ttl-$timestamp-$loc";
my $domain = getdomain($fqdn);
print $outfh "dn: cn=$id,cn=$domain,$basedn\n";
print $outfh "objectClass: top\n";
print $outfh "objectClass: dnszone\n";
print $outfh "objectClass: dnsrrset\n";
print $outfh "cn: $id\n";
print $outfh "dnstype: a\n";
print $outfh "dnsdomainname: $fqdn.\n";
if ($ip) { print $outfh "dnscipaddr: $ip\n"; }
if ($ttl) { print $outfh "dnsttl: $ttl\n"; }
if ($timestamp) { print $outfh "dnstimestamp: $timestamp\n"; }
if ($loc) { print $outfh "dnsloc: $loc\n"; }
print $outfh "\n";
next LINE;
};
/^\+/ && do {
# Found an A
my ($fqdn, $ip, $ttl, $timestamp, $loc) = split /:/;
$fqdn =~ s/^\+//;
if (!defined($ip)) { $ip = ""; }
if (!defined($ttl)) { $ttl = ""; }
if (!defined($timestamp)) { $timestamp = ""; }
if (!defined($loc)) { $loc = ""; }
my $id = "A-$fqdn-$ip-$ttl-$timestamp-$loc";
my $domain = getdomain($fqdn);
print $outfh "dn: cn=$id,cn=$domain,$basedn\n";
print $outfh "objectClass: top\n";
print $outfh "objectClass: dnszone\n";
print $outfh "objectClass: dnsrrset\n";
print $outfh "cn: $id\n";
print $outfh "dnstype: a\n";
print $outfh "dnsdomainname: $fqdn.\n";
if ($ip) { print $outfh "dnsipaddr: $ip\n"; }
if ($ttl) { print $outfh "dnsttl: $ttl\n"; }
if ($timestamp) { print $outfh "dnstimestamp: $timestamp\n"; }
if ($loc) { print $outfh "dnsloc: $loc\n"; }
print $outfh "\n";
next LINE;
};
/^@/ && do {
# Found an MX
my ($fqdn, $ip, $x, $dist, $ttl, $timestamp, $loc) = split /:/;
$fqdn =~ s/^@//;
if (!defined($ip)) { $ip = ""; }
if (!defined($x)) { $x = ""; }
if (!defined($dist)) { $dist = ""; }
if (!defined($ttl)) { $ttl = ""; }
if (!defined($timestamp)) { $timestamp = ""; }
if (!defined($loc)) { $loc = ""; }
my $id = "MX-$fqdn-$ip-$x-$dist-$ttl-$timestamp-$loc";
my $domain = getdomain($fqdn);
print $outfh "dn: cn=$id,cn=$domain,$basedn\n";
print $outfh "objectClass: top\n";
print $outfh "objectClass: dnszone\n";
print $outfh "objectClass: dnsrrset\n";
print $outfh "cn: $id\n";
print $outfh "dnstype: mx\n";
print $outfh "dnsdomainname: $fqdn.\n";
if ($ip) { print $outfh "dnsipaddr: $ip\n" };
if ($x) { print $outfh "dnscname: $x.\n"; }
if ($dist) { print $outfh "dnspreference: $dist\n"; }
if ($ttl) { print $outfh "dnsttl: $ttl\n"; }
if ($timestamp) { print $outfh "dnstimestamp: $timestamp\n"; }
if ($loc) { print $outfh "dnsloc: $loc\n"; }
print $outfh "\n";
next LINE;
};
/^'/ && do {
# Found a TXT record
my ($fqdn, $s, $ttl, $timestamp, $loc) = split /:/;
$fqdn =~ s/^'//;
if (!defined($ttl)) { $ttl = ""; }
if (!defined($timestamp)) { $timestamp = ""; }
if (!defined($loc)) { $loc = ""; }
my $id = "TXT-$fqdn-$ttl-$timestamp-$loc";
my $domain = getdomain($fqdn);
print $outfh "dn: cn=$id,cn=$domain,$basedn\n";
print $outfh "objectClass: top\n";
print $outfh "objectClass: dnszone\n";
print $outfh "objectClass: dnsrrset\n";
print $outfh "cn: $id\n";
print $outfh "dnstype: txt\n";
print $outfh "dnsdomainname: $fqdn.\n";
print $outfh "dnstxt: $s\n";
if ($ttl) { print $outfh "dnsttl: $ttl\n"; }
if ($timestamp) { print $outfh "dnstimestamp: $timestamp\n"; }
if ($loc) { print $outfh "dnsloc: $loc\n"; }
print $outfh "\n";
next LINE;
};
/^\^/ && do {
# Found an PTR
my ($fqdn, $ptr, $ttl, $timestamp, $loc) = split /:/;
$fqdn =~ s/^\^//;
if (!defined($ttl)) { $ttl = ""; }
if (!defined($timestamp)) { $timestamp = ""; }
if (!defined($loc)) { $loc = ""; }
my $id = "$fqdn-$ptr-$ttl-$timestamp-$loc";
my $domain = getdomain($fqdn);
print $outfh "dn: cn=$id,cn=$domain,$basedn\n";
print $outfh "objectClass: top\n";
print $outfh "objectClass: dnszone\n";
print $outfh "objectClass: dnsrrset\n";
print $outfh "cn: $id\n";
print $outfh "dnstype: ptr\n";
print $outfh "dnscname: $fqdn.\n";
print $outfh "dnsipaddr: $ptr\n";
if ($ttl) { print $outfh "dnsttl: $ttl\n"; }
if ($timestamp) { print $outfh "dnstimestamp: $timestamp\n"; }
if ($loc) { print $outfh "dnsloc: $loc\n"; }
print $outfh "\n";
next LINE;
};
/^C/ && do {
# Found a CNAME
my ($fqdn, $p, $ttl, $timestamp, $loc) = split /:/;
$fqdn =~ s/^C//;
if (!defined($ttl)) { $ttl = ""; }
if (!defined($timestamp)) { $timestamp = ""; }
if (!defined($loc)) { $loc = ""; }
my $id = "CNAME-$fqdn-$p-$ttl-$timestamp-$loc";
my $domain = getdomain($fqdn);
print $outfh "dn: cn=$id,cn=$domain,$basedn\n";
print $outfh "objectClass: top\n";
print $outfh "objectClass: dnszone\n";
print $outfh "objectClass: dnsrrset\n";
print $outfh "cn: $id\n";
print $outfh "dnstype: cname\n";
print $outfh "dnsdomainname: $fqdn.\n";
print $outfh "dnscname: $p.\n";
if ($ttl) { print $outfh "dnsttl: $ttl\n"; }
if ($timestamp) { print $outfh "dnstimestamp: $timestamp\n"; }
if ($loc) { print $outfh "dnsloc: $loc\n"; }
print $outfh "\n";
next LINE;
};
/^:/ && do {
# Found unsupported "unknown record"
print STDERR "Ignoring \"unknown record\": $_\n";
$errorrecs++;
print $rejfh "$_\n";
next LINE;
}
} # End for($_) block
} # End LINE while(<DATA>)
print STDERR "\n";
if ($errorrecs) {
print STDERR "$errorrecs records were found containing errors. Please inspect $rejout\n";
print STDERR "for details. DNS TXT and TinyDNS \"unknown record\" formats are not supported\n";
}
print STDERR "Completed successfully\n";
exit 0;
sub getdomain
{
my $fqdn = shift(@_);
# strip off characters up to the first '.' leaving the domain
$fqdn =~ /[^\.]*\.(.*)/;
return $1;
}
sub usage
{
print STDERR "Usage: $0 <input> <output> <basedn>\n";
print STDERR "\n";
print STDERR "This script takes a standard TinyDNS \"data\" file as input\n";
print STDERR "and generates an LDIF format output suitable for use with\n";
print STDERR "this \"ldap2dns\" package. If any unsupported or otherwise erroring records\n";
print STDERR "are found in the input, they are printed to both STDERR as well as\n";
print STDERR "\"<output>.rej\" , Currently unsupported are DNS TXT and the\n";
print STDERR "TinyDNS \"unknown record\" format. There is planned support for\n";
print STDERR "DNS TXT and DNS SRV (in \"unknown record\" format) in the near future\n";
print STDERR "\n";
print STDERR "<output> may be either a filename or \"-\" for STDOUT. If STDOUT is used\n";
print STDERR "as the output then no <output>.rej file is created and error records\n";
print STDERR "are only printed to STDERR\n";
print STDERR "\n";
print STDERR "Example: $0 data data.ldif ou=DNS,dc=example,dc=com\n";
print STDERR "\n";
exit 1;
}