From c03e009d01ebe2e55a4383e934385dabd9ea0749 Mon Sep 17 00:00:00 2001 From: Wojciech Kosior Date: Fri, 29 May 2020 12:58:12 +0200 Subject: move sources to src/ --- perform_queries.py | 39 --------------------------------------- 1 file changed, 39 deletions(-) delete mode 100755 perform_queries.py (limited to 'perform_queries.py') 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() -- cgit v1.2.3