X-Git-Url: https://git.cworth.org/git?p=empires-server;a=blobdiff_plain;f=game.js;h=0023257e796c1f56e49e2fe62742c6ec1f35454b;hp=4649b56704a41f8c103e492c09560344cfadb299;hb=d7b96ee0316021fa7a5e428950e2d8a9d8754582;hpb=13553d82c4746db09ce801421f0e9a5efcc300bb diff --git a/game.js b/game.js index 4649b56..0023257 100644 --- a/game.js +++ b/game.js @@ -9,6 +9,7 @@ class Player { this.name = name; this.connections = [connection]; this.team = no_team; + this.active = true; } add_connection(connection) { @@ -58,6 +59,7 @@ class Game { this.id = id; this.players = []; this.players_by_session = {}; + this.active_players = 0; this.next_player_id = 1; this.teams = []; this.state = { @@ -163,6 +165,14 @@ class Game { /* First see if we already have a player object for this session. */ const existing = this.players_by_session[session.id]; if (existing) { + if (! existing.active) { + /* If we're re-activating a previously idled player, then we + * need to alert everyone that this player is now back. + */ + existing.active = true; + this.active_players++; + this.broadcast_event("player-enter", existing.info_json()); + } existing.add_connection(connection); return existing; } @@ -186,11 +196,11 @@ class Game { /* Broadcast before adding player to list (to avoid announcing the * new player to itself). */ - const player_data = JSON.stringify({ id: player.id, name: player.name }); - this.broadcast_event("player-enter", player_data); + this.broadcast_event("player-enter", player.info_json()); this.players.push(player); this.players_by_session[session.id] = player; + this.active_players++; this.next_player_id++; /* After adding the player to the list, and if we are already past @@ -214,9 +224,9 @@ class Game { remove_player_connection(player, connection) { const remaining = player.remove_connection(connection); if (remaining === 0) { + player.active = false; + this.active_players--; const player_data = JSON.stringify({ id: player.id }); - this.players.filter(p => p !== player); - delete this.players_by_session[player.session_id]; this.broadcast_event("player-exit", player_data); } } @@ -266,8 +276,8 @@ class Game { /* And the player-info event. */ response.write(`event: player-info\ndata: ${player.info_json()}\n\n`); - /* As well as player-enter events for all existing players. */ - this.players.filter(p => p !== player).forEach(p => { + /* As well as player-enter events for all existing, active players. */ + this.players.filter(p => p !== player && p.active).forEach(p => { response.write(`event: player-enter\ndata: ${p.info_json()}\n\n`); });