From 70c2e0df67e76f755db292a5a817c31770267a70 Mon Sep 17 00:00:00 2001 From: Dmitrii Morozov Date: Wed, 10 Apr 2024 00:33:05 +0200 Subject: tmp --- FortniteStatusWrapper.py | 23 +++++++++-------------- 1 file changed, 9 insertions(+), 14 deletions(-) (limited to 'FortniteStatusWrapper.py') diff --git a/FortniteStatusWrapper.py b/FortniteStatusWrapper.py index 6a80348..aa7ee12 100644 --- a/FortniteStatusWrapper.py +++ b/FortniteStatusWrapper.py @@ -1,5 +1,5 @@ from telebot import formatting -import time, threading, schedule +import time from pythonFortniteStatus.FortniteStatus import * __polling_interval__ = 5 @@ -7,7 +7,7 @@ __polling_interval__ = 5 fortniteStatus = FortniteStatus() class Observer: - def update(self, fortniteStatus) -> None: + async def update(self, fortniteStatus) -> None: pass class FortniteStatusWrapper: @@ -15,26 +15,21 @@ class FortniteStatusWrapper: observers = [] fortniteStatus = None - def __init__(self): - schedule.every(__polling_interval__).seconds.do(self.__readStatus) - threading.Thread(target=self.__scheduleHandler, name='fortnite_status_scheduler', daemon=True).start() - self.fortniteStatus = fortniteStatus.getStatus() - - def __scheduleHandler(self): + async def run(self): while True: - schedule.run_pending() - time.sleep(1) + await self.__readStatus() + time.sleep(__polling_interval__) - def __readStatus(self): + async def __readStatus(self): serviceStatusTmp = fortniteStatus.getStatus() if serviceStatusTmp != self.fortniteStatus: - self.notify(serviceStatusTmp) + await self.__notify(serviceStatusTmp) self.fortniteStatus = serviceStatusTmp - def notify(self, fortniteStatus): + async def __notify(self, fortniteStatus): print("Fortnite status changed, notifying observers") for observer in self.observers: - observer.update(fortniteStatus) + await observer.update(fortniteStatus) def attach(self, observer: Observer): self.observers.append(observer) \ No newline at end of file -- cgit v1.2.3