X-Git-Url: https://git.cworth.org/git?a=blobdiff_plain;f=empathy.js;h=7710892819235061d0710b14386c2cc1d8786877;hb=678fbabe0f69470625606f59b84e87ae1d60c110;hp=7b27ee40c5d196866b19036455c66e6b5ebe713e;hpb=3dae3833cb5247943e27649a9b16639c2187c8c5;p=empires-server

diff --git a/empathy.js b/empathy.js
index 7b27ee4..7710892 100644
--- a/empathy.js
+++ b/empathy.js
@@ -148,6 +148,20 @@ class Empathy extends Game {
     return true;
   }
 
+  toggle_vote_against(prompt_id, session_id) {
+    const player = this.players_by_session[session_id];
+
+    const prompt = this.state.prompts.find(p => p.id === prompt_id);
+    if (! prompt || ! player)
+      return false;
+
+    prompt.toggle_vote_against(player.name);
+
+    this.broadcast_event_object('prompt', prompt);
+
+    return true;
+  }
+
   /* Returns true on success, false for prompt not found. */
   start(prompt_id) {
     const prompt = this.state.prompts.find(p => p.id === prompt_id);
@@ -572,6 +586,7 @@ class Prompt {
     this.items = items;
     this.prompt = prompt;
     this.votes = [];
+    this.votes_against = [];
   }
 
   toggle_vote(player_name) {
@@ -580,6 +595,13 @@ class Prompt {
     else
       this.votes.push(player_name);
   }
+
+  toggle_vote_against(player_name) {
+    if (this.votes_against.find(v => v === player_name))
+      this.votes_against = this.votes_against.filter(v => v !== player_name);
+    else
+      this.votes_against.push(player_name);
+  }
 }
 
 router.post('/prompts', (request, response) => {
@@ -600,6 +622,16 @@ router.post('/vote/:prompt_id([0-9]+)', (request, response) => {
     response.sendStatus(404);
 });
 
+router.post('/vote_against/:prompt_id([0-9]+)', (request, response) => {
+  const game = request.game;
+  const prompt_id = parseInt(request.params.prompt_id, 10);
+
+  if (game.toggle_vote_against(prompt_id, request.session.id))
+    response.send('');
+  else
+    response.sendStatus(404);
+});
+
 router.post('/start/:prompt_id([0-9]+)', (request, response) => {
   const game = request.game;
   const prompt_id = parseInt(request.params.prompt_id, 10);
@@ -663,7 +695,8 @@ router.post('/judged/:prompt_id([0-9]+)', (request, response) => {
 
   /* If every player who answered has also judged, then there's no
    * need to wait for anything else. */
-  if (game.state.players_judged.length >= game.state.players_answered.length)
+  const judged_set = new Set(game.state.players_judged);
+  if ([...game.state.players_answered].filter(x => !judged_set.has(x)).length === 0)
     game.compute_scores();
 });