diff --git a/src/core/udp_server.py b/src/core/udp_server.py index dcbff0e..e6fde79 100644 --- a/src/core/udp_server.py +++ b/src/core/udp_server.py @@ -33,13 +33,13 @@ class UDPServer(asyncio.DatagramTransport): if client: match code: case "p": # Ping packet - # TODO: Call event onSentPing + ev.call_event("onSentPing") self.transport.sendto(b"p", addr) case "Z": # Position packet if client._udp_sock != (self.transport, addr): client._udp_sock = (self.transport, addr) self.log.debug(f"Set UDP Sock for CID: {cid}") - # TODO: Call event onChangePosition + ev.call_event("onChangePosition") if client: await client._send(data[2:], to_all=True, to_self=False, to_udp=True) case _: diff --git a/src/modules/EventsSystem/events_system.py b/src/modules/EventsSystem/events_system.py index 77aedf4..0eda1d2 100644 --- a/src/modules/EventsSystem/events_system.py +++ b/src/modules/EventsSystem/events_system.py @@ -31,6 +31,8 @@ class EventsSystem: "onCarDelete": [], "onCarEdited": [], "onCarReset": [], + "onSentPing": [], # Only sync + "onChangePosition": [], # Only sync "onServerStopped": [], } self.__async_events = { @@ -86,7 +88,8 @@ class EventsSystem: return funcs_data def call_event(self, event_name, *args, **kwargs): - self.log.debug(f"Calling sync event: '{event_name}'") + if event_name not in ["onChangePosition", "onSentPing"]: # UDP events + self.log.debug(f"Calling sync event: '{event_name}'") funcs_data = [] if event_name in self.__events.keys():