""" machine to machine messaging via infrastructure """

udps = object()

def init(listen_addr):
    # The server socket needs to be set up and ready waiting for any incoming messages 
    # even when we are not checking at the very moment. One thread - we don't wait and listen!
    global udps
    import socket
    udps = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    udps.settimeout(0) # do not block this socket on read

def deinit():
    global udps

def msg_check():
    global udps
        message, fr_addr = udps.recvfrom(10)
    except: # catch timeout exception
        message = ''
        fr_addr = ('',0)
    return(message, fr_addr)

def msg_send(destination_addr, message):
    import socket
    udpc = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    # we let Python figure out which network interface to use - no bind
    udpc.sendto(message, destination_addr)

def test(listen_ip, dest_ip):
    import socket
    # we can open the server on all network interfaces or only one defined by a non-zero IP
    listen_addr = socket.getaddrinfo(listen_ip, 473)[0][-1]
    # set up button
    from machine import Pin
    button = Pin(0)
    button.init(Pin.IN, Pin.PULL_UP)
    butstate = button.value()
    while True:
        if button.value()!=butstate:
            butstate = button.value()
            if butstate==0:
                # technically we can pick a different destination IP address each time
                dest_addr = socket.getaddrinfo(dest_ip, 473)[0][-1]
                msg_send(dest_addr, 'pressed')
        msg, frm = msg_check()
        if len(msg)>0:
            print('received: ', msg)
    # end of the forever test loop

if __name__ == "__main__":
    import network
    # local_ip = network.WLAN(network.STA_IF).ifconfig()[0]
    local_ip = ''
    to_ip    = '' # <--- encode the IP address reported by the other station
    test(local_ip, to_ip)

""" all ESPs connected to infrastructure
import network
network.WLAN(network.STA_IF).connect('malilab', 'dram-portable-lab-key')