client.py

import socket
import threading
import pickle
import runtimeREF

TCP_PORT = 6969
ip_range = '.'.join(runtimeREF.HOSTIP.split('.')[0:3]) + '.'
connection = None
threads = []


def send(arg):
    connection.send(pickle.dumps(arg))

def onConnect(arg):
    threading.Thread(target=runtimeREF.fnDir[52], args=(arg,)).start()
    threading.Thread(target=runtimeREF.updateClients, args=(arg,)).start()

def connect(ip_address):
    global connection
    try:
        s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        s.settimeout(1)
        s.connect((ip_address, TCP_PORT))
        connection = s
        connection.settimeout(None)
        print(f"TCP Server at {ip_address}:{TCP_PORT}")
    except:
        s.close()
        pass


def getServer():
    for i in range(1, 256):
        ip_address = ip_range + str(i)
        thread = threading.Thread(target=connect, args=(ip_address,))
        thread.start()
        threads.append(thread)

    for thread in threads:
        thread.join()

    if (connection == None):
        return False
    return True


if __name__ == "__main__":
    if (getServer()):
        send("UwU")
        while True:
            try:
                data = connection.recv(1024)
            except ConnectionResetError:
                print("disconnected")
                break
            if not data:
                print("disconnected")
                break
            # unpickling after checks to prevent error `EOFError: Ran out of input`
            data = pickle.loads(data)
            print(data)