import async_timeout
from spruned.dependencies.pycoinnet.dnsbootstrap import dns_bootstrap_host_port_q
from spruned.dependencies.pycoinnet.networks import MAINNET, TESTNET
import asyncio

from spruned.application.logging_factory import Logger


async def dns_bootstrap_servers(network=TESTNET, howmany=50):  # pragma: no cover
    host_q = dns_bootstrap_host_port_q(network)
    ad = []
    while 1:
        item = host_q.get()
        try:
            async with async_timeout.timeout(1):
                peer = await item
        except asyncio.TimeoutError:
            try:
                item.close()
            except asyncio.CancelledError:
                Logger.p2p.debug('Cancelled')
            break
        ad.append(peer)
    return ad



import async_timeout
from spruned.dependencies.pycoinnet.dnsbootstrap import dns_bootstrap_host_port_q
from spruned.dependencies.pycoinnet.networks import MAINNET, TESTNET
import asyncio

from spruned.application.logging_factory import Logger


async def dns_bootstrap_servers(network=TESTNET, howmany=50):  # pragma: no cover
    host_q = dns_bootstrap_host_port_q(network)
    ad = []
    while 1:
        item = host_q.get()
        try:
            async with async_timeout.timeout(1):
                peer = await item
        except asyncio.TimeoutError:
            try:
                item.close()
            except asyncio.CancelledError:
                Logger.p2p.debug('Cancelled')
            break
        ad.append(peer)
    return ad



# pragma: no cover