78 lines
2.7 KiB
Python
78 lines
2.7 KiB
Python
#!/usr/bin/env python
|
|
|
|
import hashlib
|
|
import sys
|
|
import struct
|
|
import socket
|
|
import time
|
|
from optparse import OptionParser
|
|
|
|
import dns.message
|
|
import dns.name
|
|
import dns.rdataclass
|
|
import dns.rdatatype
|
|
|
|
def _calc_hashkey(qname, secret, qtype):
|
|
qclass = 'IN' # CLASS is fixed for simplicity
|
|
hobj = hashlib.sha256()
|
|
hobj.update(dns.name.from_text(qname).to_wire())
|
|
hobj.update(struct.pack('HH',
|
|
socket.htons(dns.rdatatype.from_text(qtype)),
|
|
socket.htons(dns.rdataclass.from_text(qclass))))
|
|
hobj.update(secret)
|
|
return hobj.hexdigest().upper()
|
|
|
|
def _redis_get(options, key):
|
|
import redis
|
|
return redis.Redis(options.address, int(options.port)).get(key)
|
|
|
|
def _dump_value(options, qname, key, value):
|
|
print(';; query=%s/IN/%s' % (qname, options.qtype))
|
|
print(';; key=%s' % key)
|
|
if value is None:
|
|
print(';; no value')
|
|
return
|
|
if len(value) < 16:
|
|
print(';; broken value, short length: %d' % len(value))
|
|
return
|
|
now = int(time.time())
|
|
timestamp = struct.unpack('!Q', value[-16:-8])[0]
|
|
expire = struct.unpack('!Q', value[-8:])[0]
|
|
print(';; Now=%d, TimeStamp=%d, Expire=%d, TTL=%d' %
|
|
(now, timestamp, expire, max(expire - now, 0)))
|
|
print(dns.message.from_wire(value[:-16]))
|
|
|
|
def main():
|
|
parser = OptionParser(usage='usage: %prog [options] query_name')
|
|
parser.add_option("-a", "--address", dest="address", action="store",
|
|
default='127.0.0.1', help="backend-server address",
|
|
metavar='ADDRESS')
|
|
parser.add_option("-b", "--backend", dest="backend", action="store",
|
|
default='redis', help="backend name",
|
|
metavar='BACKEND')
|
|
parser.add_option("-p", "--port", dest="port", action="store",
|
|
default='6379', help="backend-server port",
|
|
metavar='PORT')
|
|
parser.add_option("-s", "--secret", dest="secret", action="store",
|
|
default='default', help="secret seed", metavar='SECRET')
|
|
parser.add_option("-t", "--qtype", dest="qtype", action="store",
|
|
default='A', help="query RR type", metavar='QTYPE')
|
|
|
|
(options, args) = parser.parse_args()
|
|
if len(args) < 1:
|
|
parser.error('qname is missing')
|
|
if options.backend == 'redis':
|
|
get_func = _redis_get
|
|
else:
|
|
raise Exception('unknown backend name: %s\n' % options.backend)
|
|
key = _calc_hashkey(args[0], options.secret, options.qtype)
|
|
value = get_func(options, key)
|
|
_dump_value(options, args[0], key, value)
|
|
|
|
if __name__ == '__main__':
|
|
try:
|
|
main()
|
|
except Exception as e:
|
|
sys.stderr.write('%s\n' % e)
|
|
exit(1)
|