on_open && ws.send()

[Dpsley]

Hi, I just started working with this recently and I can't understand why I can't send a message after opening a socket using run_forever(), does all the logic have to be in on_open, because so far I get that the socket is already closed

class Connector:
    def on_message(self, ws, message):
        print(data)
        
    def on_open(self, ws):
        print("opened")
        ws.send(json.dumps({"function": "test"}))
    
    def on_error(self, ws, error):
        print(ws)
        print(error)
        
    def on_close(self, ws, close_status_code, close_msg):
        try:
            if self.ws:
                self.ws.close()
        except Exception as ex:
            print(f"Error in close: {ex}")
            
    def __init__(self, ip):
        self.ws = websocket.WebSocketApp(f'ws://{self.ip}:25000/',
                                         on_open=self.on_open,
                                         on_message=self.on_message,
                                         on_error=self.on_error,
                                         on_close=self.on_close)
                                         
    def run_websocket(self):
        websocket.enableTrace(False)
        self.ws.run_forever()
                
socket_holder = Connector("192.168.88.2")
socket_holder.run_websocket()
socket_holder.ws.send_text('test')

[eness-1]

cause the ws.run_forever() method is a blocking method, the program won't continue executing beyond the line self.ws.run_forever(). If you want to send() while run_forever() is running, you may need to run run_forever() in the background as a listener, like this.
`

target_fun = self.ws.run_forever

daemon = threading.Thread(target=target_fun)

daemon.daemon = True

daemon.start()

socket_holder.ws.send_text('test')

`

[Dpsley]

Hi, thanks for the reply. Did I understand correctly?

wws = WMFMachineErrorConnector2("192.168.88.2")
daemon = threading.Thread(target=wws.run_websocket)
daemon.daemon = True
daemon.start()
wws.ws.send_text('test')

[eness-1]

y

[Dpsley]

but i getting a exception about already closed socket before sending a "test" message

[Dpsley]

If i using threads in the on_open function thats working but i would like to sending and using outside this.