#!/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()