From 90bdb0746398a92615e982fac45cdbe69d2eef26 Mon Sep 17 00:00:00 2001 From: Nicolas Mowen Date: Tue, 30 Apr 2024 07:27:39 -0600 Subject: [PATCH] Simplify on connect (#11176) --- frigate/comms/ws.py | 4 ---- web/src/api/ws.tsx | 8 +++++++- 2 files changed, 7 insertions(+), 5 deletions(-) diff --git a/frigate/comms/ws.py b/frigate/comms/ws.py index 65b2e8b1a..fccd8db5c 100644 --- a/frigate/comms/ws.py +++ b/frigate/comms/ws.py @@ -50,10 +50,6 @@ class WebSocketClient(Communicator): # type: ignore[misc] class _WebSocketHandler(WebSocket): # type: ignore[misc] receiver = self._dispatcher - def opened(self) -> None: - """A new websocket is opened, we need to send an update message""" - threading.Timer(1.0, self.receiver, ("onConnect", "")).start() - def received_message(self, message: WebSocket.received_message) -> None: try: json_message = json.loads(message.data.decode("utf-8")) diff --git a/web/src/api/ws.tsx b/web/src/api/ws.tsx index abe5c14b2..34fe4b2f0 100644 --- a/web/src/api/ws.tsx +++ b/web/src/api/ws.tsx @@ -65,7 +65,13 @@ function useValue(): useValueReturn { setWsState({ ...wsState, [data.topic]: data.payload }); } }, - onOpen: () => {}, + onOpen: () => { + sendJsonMessage({ + topic: "onConnect", + message: "", + retain: false, + }); + }, shouldReconnect: () => true, });