renamed file to fix dependency and library imports

socket_py/socket.py → socket_py/socket_py.py

@@ -13,7 +13,7 @@
 # websockets
 import websockets
 import asyncio
-from socket import socket, AF_INET, SOCK_DGRAM
+from socket import socket, AF_INET, SOCK_DGRAM, SOL_SOCKET, SO_BROADCAST, gethostbyname, gethostname
 
 # utility libraries
 import operator
@@ -22,6 +22,7 @@
 import json
 from json import JSONDecodeError
 import credentials
+from time import sleep
 
 DEBUG = False
 
@@ -41,6 +42,9 @@
 window = None
 app = None
 
+# broadcast port and ID
+PORT = 50000
+ID = "smartsocket"
 
 class State(Enum):
     disconnected = 0
@@ -97,14 +101,6 @@ def terminateThread(self, process):
             # thread was not created yet
             pass
 
-    def connectWS(self):
-        self.updateInfoCenter('')
-        self.updateInfo('Searching for smart sockets...')
-
-        # start websocket
-        self.ws_thread = WSConnection()
-        self.ws_thread.start()
-
 
 # ethereum node functionality
 class Node(QThread):
@@ -148,7 +144,14 @@ def __init__(self, parent=window):
         self.threadActive = False
 
     def run(self):
-        pass
+        s = socket(AF_INET, SOCK_DGRAM)  # create UDP socket
+        s.bind(('', 0))
+        s.setsockopt(SOL_SOCKET, SO_BROADCAST, 1)  # this is a broadcast socket
+        while 1:
+            data = ID
+            s.sendto(data.encode('utf-8'), ('<broadcast>', PORT))
+            print("sent service announcement")
+            sleep(1)
 
 
 def main():