ESP-NOW uasyncio, sending heartbeat to multiple peers

[dtuando]

I'm having issues sending heartbeats to multiple peers using the example given on sending to one peer.

import aioespnow
import uasyncio as asyncio

# A WLAN interface must be active to send()/recv()
network.WLAN(network.STA_IF).active(True)

e = aioespnow.AIOESPNow()  # Returns AIOESPNow enhanced with async support
e.active(True)


peers = [b'\xaa\xaa\xaa\xaa\xaa\xaa', b'\xbb\xbb\xbb\xbb\xbb\xbb]
for i in peers:
    e.add_peer(i)

# Send a periodic ping to a peer
async def heartbeat(e, peer, period=30):
    while True:
        if not await e.asend(peer, b'ping'):
            print("Heartbeat: peer not responding:", peer)
        else:
            print("Heartbeat: ping", peer)
        await asyncio.sleep(period)

# Echo any received messages back to the sender
async def echo_server(e):
    async for mac, msg in e:
        print("Echo:", msg)
        try:
            await e.asend(mac, msg)
        except OSError as err:
            if len(err.args) > 1 and err.args[1] == 'ESP_ERR_ESPNOW_NOT_FOUND':
                e.add_peer(mac)
                await e.asend(mac, msg)

async def main(e, peer, timeout, period):
    asyncio.create_task(heartbeat(e, peer, period))
    asyncio.create_task(echo_server(e))
    await asyncio.sleep(timeout)

asyncio.run(main(e, peer, 120, 10))

The issue I'm having is that I can't figure out how to run the async code when I have a list peers instead of one peer.

[dtuando]

I figured it out!

changed

async def heartbeat(e, peer, period=30):
    while True:
        if not await e.asend(peer, b'ping'):
            print("Heartbeat: peer not responding:", peer)
        else:
            print("Heartbeat: ping", peer)
        await asyncio.sleep(period)

to this

async def heartbeat(e, peers, period=30):
    while True:
        for i in peers:
            if not await e.asend(i, b'ping'):
                print("Heartbeat: peer not responding:", i)
            else:
                print("Heartbeat: ping", i)
            await asyncio.sleep(period)

[glenn20]

A suggested improvement: You probably mean that every period seconds you want to send a heartbeat to every peer int he list. If so, the sleep should not be inside the inner loop.

async def heartbeat(e, peers, period=30):
    while True:
        for i in peers:
            if not await e.asend(i, b'ping'):
                print("Heartbeat: peer not responding:", i)
            else:
                print("Heartbeat: ping", i)
        await asyncio.sleep(period)