dga_gen_async.py

import asyncio
import aiodns
from datetime import datetime
from javarandom import Random

seeds = [2931,1905,1642,1136,1813,1945]
def gen_seed(s):
        year = datetime.today().year
        month = datetime.today().month
        month = month-1
        mask = 0xffffffffffffffff
        print(f"Current seed year={year},month={month}")
        j = year^month^0
        j2 = j*2&mask
        j3 = j2 * ((year&mask)^j2)&mask
        j4 = j3 * ((month&mask)^j3)&mask
        j5 = j4 * (0^j4)&mask
        seed = (j5 + s)&mask
        return seed
def gen_domain():
    domains = []
    for s in seeds:
        r = Random(seed=gen_seed(s))
        for i in range(5000):
            domain = "" 
            for i2 in range(15):
                domain += chr(r.nextInt(25)+97)
            if i%3 == 0:
                domain += ".ru"
            elif i%2 == 0:
                domain += ".su"
            else:
                domain += ".cn"

            domains.append(domain)
    return domains

loop = asyncio.get_event_loop()
resolver = aiodns.DNSResolver(loop=loop)

async def query_dns(domain):
    try:
        r = await resolver.query(domain,'A')
        print("FluBot DGA domain -> ",r,domain)
    except:
        pass

async def query():
    tasks = []
    for d in gen_domain():
        tasks.append( asyncio.ensure_future(query_dns(d)) )
    resps = await asyncio.gather(*tasks)
    print('Finished all !')
    # return await resolver.query(name, query_type)

result = loop.run_until_complete(query())