X-Git-Url: https://plomlompom.com/repos/berlin_corona.txt?a=blobdiff_plain;f=plomrogue%2Fgame.py;h=3b0b25f3afeacd77b732578e847a002982adf904;hb=8d0b5840b7df40ee883fdcf2fa1b4cd1d39e26fa;hp=6e8afdf83182dded8a25c735b94dc7cdc2a7095a;hpb=54d8db95b3bb690b712ec09179922829d0c68a54;p=plomrogue2 diff --git a/plomrogue/game.py b/plomrogue/game.py index 6e8afdf..3b0b25f 100755 --- a/plomrogue/game.py +++ b/plomrogue/game.py @@ -117,7 +117,7 @@ class Game(GameBase): def __init__(self, save_file, *args, **kwargs): super().__init__(*args, **kwargs) self.changed = True - self.changed_fovs = True + self.changed_tiles = [] self.io = GameIO(self, save_file) self.tasks = {} self.thing_types = {} @@ -210,6 +210,22 @@ class Game(GameBase): return '/O O\\' + '| oo |' + '\\>-- 0: + t_old = self.get_thing(id_) + t = self.thing_types[type_](self, id_=id_, position=position) + if t_old: + self.things[self.things.index(t_old)] = t + else: + self.things += [t] + self.record_fov_change(t.position) + return t + def send_gamestate(self, connection_id=None): """Send out game state data relevant to clients.""" @@ -229,8 +245,8 @@ class Game(GameBase): player.prepare_multiprocessible_fov_stencil() #! player_fovs += [player._fov] player_fov_ids += [player.id_] + print('DEBUG regen FOV for', player.id_) if len(player_fovs) > 0: - print('DEBUG regenerating FOVs') pool = multiprocessing.Pool() new_fovs = pool.map(FovMap.init_terrain, [fov for fov in player_fovs]) #! pool.close() @@ -282,6 +298,11 @@ class Game(GameBase): quote(annotation)), c_id) self.io.send('GAME_STATE_COMPLETE') + def record_fov_change(self, position): + big_yx, little_yx = position + self.changed_tiles += [self.map_geometry.undouble_yxyx(big_yx, + little_yx)] + def run_tick(self): to_delete = [] for connection_id in self.sessions: @@ -294,8 +315,7 @@ class Game(GameBase): t = self.get_player(connection_id) if hasattr(t, 'name'): self.io.send('CHAT ' + quote(t.name + ' left the map.')) - self.things.remove(t) - self.changed_fovs = True + self.remove_thing(t) to_delete += [connection_id] for connection_id in to_delete: del self.sessions[connection_id] @@ -312,18 +332,34 @@ class Game(GameBase): for connection_id in [c_id for c_id in self.sessions if self.sessions[c_id]['thing_id'] == t.id_]: self.io.send('PLAY_ERROR ' + quote(str(e)), connection_id) - if self.changed_fovs: - for t in [t for t in self.things]: - t.invalidate_map_view() if self.changed: self.turn += 1 # send_gamestate() can be rather expensive, due to among other reasons - # re-calculating each player's FOV, so don't send it out too often + # re-calculating players' FOVs, so don't send it out too often if self.last_send_gamestate < \ datetime.datetime.now() -self.send_gamestate_interval: + if len(self.changed_tiles) > 0: + for t in [t for t in self.things if t.type_ == 'Player']: + fov_radius = 12 # TODO: un-hardcode + absolute_position =\ + self.map_geometry.undouble_yxyx(t.position[0], + t.position[1]) + y_range_start = absolute_position.y - fov_radius + y_range_end = absolute_position.y + fov_radius + x_range_start = absolute_position.x - fov_radius + x_range_end = absolute_position.x + fov_radius + for position in self.changed_tiles: + if position.y < y_range_start\ + or position.y > y_range_end: + continue + if position.x < x_range_start\ + or position.x > x_range_end: + continue + t.invalidate_map_view() + break self.send_gamestate() self.changed = False - self.changed_fovs = False + self.changed_tiles = [] self.save() self.last_send_gamestate = datetime.datetime.now()