monorail
/
Archipelago
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

MultiServer: send new read_hints datastore values on change (#2558)

This commit is contained in:
Fabian Dill 2024-03-12 19:58:02 +01:00 committed by GitHub
parent c795c72471
commit ae6c16bde1
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
MultiServer.py
View File

@ -707,15 +707,18 @@ class Context:
self.save() # save goal completion flag self.save() # save goal completion flag
def on_new_hint(self, team: int, slot: int): def on_new_hint(self, team: int, slot: int):
key: str = f"_read_hints_{team}_{slot}" self.on_changed_hints(team, slot)
targets: typing.Set[Client] = set(self.stored_data_notification_clients[key])
if targets:
self.broadcast(targets, [{"cmd": "SetReply", "key": key, "value": self.hints[team, slot]}])
self.broadcast(self.clients[team][slot], [{ self.broadcast(self.clients[team][slot], [{
"cmd": "RoomUpdate", "cmd": "RoomUpdate",
"hint_points": get_slot_points(self, team, slot) "hint_points": get_slot_points(self, team, slot)
}]) }])
def on_changed_hints(self, team: int, slot: int):
key: str = f"_read_hints_{team}_{slot}"
targets: typing.Set[Client] = set(self.stored_data_notification_clients[key])
if targets:
self.broadcast(targets, [{"cmd": "SetReply", "key": key, "value": self.hints[team, slot]}])
def on_client_status_change(self, team: int, slot: int): def on_client_status_change(self, team: int, slot: int):
key: str = f"_read_client_status_{team}_{slot}" key: str = f"_read_client_status_{team}_{slot}"
targets: typing.Set[Client] = set(self.stored_data_notification_clients[key]) targets: typing.Set[Client] = set(self.stored_data_notification_clients[key])
@ -975,7 +978,10 @@ def register_location_checks(ctx: Context, team: int, slot: int, locations: typi
"hint_points": get_slot_points(ctx, team, slot), "hint_points": get_slot_points(ctx, team, slot),
"checked_locations": new_locations, # send back new checks only "checked_locations": new_locations, # send back new checks only
}]) }])
old_hints = ctx.hints[team, slot].copy()
ctx.recheck_hints(team, slot)
if old_hints != ctx.hints[team, slot]:
ctx.on_changed_hints(team, slot)
ctx.save() ctx.save()