aboutsummaryrefslogtreecommitdiffstats
path: root/bin/get_catalog
blob: 4c069ac5d0f370f05d45d7b26d6bdd4dd3284c34 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
#! /usr/bin/env python3
# vim:set noet sw=8 ts=8 sts=8:

import sys, socket
import dns.query
import dns.name
import dns.rdatatype
import dns.zone

def resolve(hostname):
	try:
		addrs = socket.getaddrinfo(
				hostname, 53, proto=socket.IPPROTO_UDP)
		return list(dict.fromkeys([addr[4][0] for addr in addrs]))
	except Exception as e:
		raise (Exception(f"resolving {hostname}: {e}"))

def axfr(zonename, hostname):
	addrs = resolve(hostname)
	last_exc = None

	for addr in addrs:
		try:
			name = dns.name.from_unicode(zonename)
			zone = dns.zone.Zone(origin=name)
			dns.query.inbound_xfr(addr, zone)
			return zone
		except Exception as e:
			last_exc = e
	raise (last_exc)

def print_catalog(zone):
	def origin(node):
		try:
			return [
				''.join(s.decode('utf-8') for s in rdata.strings)
				for rdata in
					zone.find_node(f"origin.ext.{node}")
						.find_rdataset(dns.rdataclass.IN,
							       dns.rdatatype.TXT)
			]
		except KeyError:
			return []

	nodes = [node
		 for (name, node) in zone.nodes.items()
		 if len(name) == 2 and name[1] == b"zones"
		    and not "dn42" in origin(name)]

	ptrs = [str(ptr.target).rstrip('.')
		for node in nodes
		for rdataset in node.rdatasets
			if rdataset.rdtype == dns.rdatatype.PTR
		for ptr in rdataset]

	print("\n".join(ptrs))

def main():
	if len(sys.argv) != 3:
		print(f"Usage: {sys.argv[0]} <zone> <server>", file=sys.stderr)
		return 1

	zone_name = sys.argv[1]
	server = sys.argv[2]

	try:
		zone = axfr(zone_name, server)
		print_catalog(zone)
	except Exception as e:
		print(f"Failed to load catalog: {e}", file=sys.stderr)
		return 1

	return 0

if __name__ == "__main__":
	sys.exit(main())