aboutsummaryrefslogtreecommitdiff
path: root/perform_queries.py
diff options
context:
space:
mode:
authorWojciech Kosior <kwojtus@protonmail.com>2020-05-29 12:58:12 +0200
committerWojciech Kosior <kwojtus@protonmail.com>2020-05-29 12:58:12 +0200
commitc03e009d01ebe2e55a4383e934385dabd9ea0749 (patch)
tree95228b48146ae05e19005246831b450171f901ac /perform_queries.py
parent459fd487fcbdc33fcccddbf4c82eae048275ba51 (diff)
download0tdns-c03e009d01ebe2e55a4383e934385dabd9ea0749.tar.gz
0tdns-c03e009d01ebe2e55a4383e934385dabd9ea0749.zip
move sources to src/
Diffstat (limited to 'perform_queries.py')
-rwxr-xr-xperform_queries.py39
1 files changed, 0 insertions, 39 deletions
diff --git a/perform_queries.py b/perform_queries.py
deleted file mode 100755
index 4762e14..0000000
--- a/perform_queries.py
+++ /dev/null
@@ -1,39 +0,0 @@
-#!/bin/python3
-
-import unbound
-
-def query_planned_queries(hour, vpn_id):
- # TODO query database
- # for now, return some sample thought-up data
- return (
- # dns server IP | dns server id | service_id | service_name
- ("195.98.79.117", 23, ((89, "devuan.org"),
- (44, "gry.pl"),
- (112, "invidio.us"))),
- ("192.71.245.208", 33, ((77, "debian.org"),
- (22, "nie.ma.takiej.domeny"),
- (100, "onet.pl")))
- )
-
-def resolve_call_back(mydata, status, result):
- dns_id, service_id = mydata
- # TODO write to database
- print("callback called for {}".format(result.qname))
- if status==0 and result.havedata:
- print("Result:",result.data.address_list)
-
-# hour from argv | vpn_id in database
-contexts = []
-for dns_addr, dns_id, services in query_planned_queries("1999-01-08 04:00", 11):
- ctx = unbound.ub_ctx()
- ctx.set_fwd(dns_addr)
- for service_id, service_name in services:
- print(service_name)
- print("starting resolution: {} through {}".format(service_name, dns_addr))
- ctx.resolve_async(service_name, (dns_id, service_id),
- resolve_call_back,
- unbound.RR_TYPE_A, unbound.RR_CLASS_IN)
- contexts.append(ctx)
-
-for ctx in contexts:
- ctx.wait()