Padra/oracle/broadcast.py

import socket
import threading

        
class Broadcast():

    def __init__(self,  broadcastPort,socketPort): 
        """ ,broadcast """ # TODO Broadcast
        self.socketPort = socketPort
        self.sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
        self.sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
        self.sock.bind(('', broadcastPort)) # TODO Broadcast
        t1 = threading.Thread(target=self.listen)
        t1.start()
        print("Broadcast Listener is created")

    def listen(self):
        while True:
            msg, addr = self.sock.recvfrom(1024)
            print("\n Message",msg," from ",addr)
            self.sock.sendto(bytes(str(self.socketPort),'utf-8'),addr)