diff --git a/LinksAwakeningClient.py b/LinksAwakeningClient.py index aac6c2f2..2f2c94f6 100644 --- a/LinksAwakeningClient.py +++ b/LinksAwakeningClient.py @@ -506,7 +506,7 @@ class LinksAwakeningContext(CommonContext): la_task = None client = None # TODO: does this need to re-read on reset? - found_checks = [] + found_checks = set() last_resend = time.time() magpie_enabled = False @@ -558,10 +558,6 @@ class LinksAwakeningContext(CommonContext): self.ui = LADXManager(self) self.ui_task = asyncio.create_task(self.ui.async_run(), name="UI") - - async def send_checks(self): - message = [{"cmd": "LocationChecks", "locations": self.found_checks}] - await self.send_msgs(message) async def send_new_entrances(self, entrances: typing.Dict[str, str]): # Store the entrances we find on the server for future sessions @@ -613,8 +609,8 @@ class LinksAwakeningContext(CommonContext): self.client.pending_deathlink = True def new_checks(self, item_ids, ladxr_ids): - self.found_checks += item_ids - create_task_log_exception(self.send_checks()) + self.found_checks.update(item_ids) + create_task_log_exception(self.check_locations(self.found_checks)) if self.magpie_enabled: create_task_log_exception(self.magpie.send_new_checks(ladxr_ids)) @@ -721,7 +717,7 @@ class LinksAwakeningContext(CommonContext): if self.last_resend + 5.0 < now: self.last_resend = now - await self.send_checks() + await self.check_locations(self.found_checks) if self.magpie_enabled: try: self.magpie.set_checks(self.client.tracker.all_checks)