Extract vote collection function

result-app/server.js

@@ -45,17 +45,24 @@ function getVotes(client) {
     if (err) {
       console.error("Error performing query: " + err);
     } else {
-      var data = result.rows.reduce(function(obj, row) {
+      var votes = collectVotesFromResult(result);
-        obj[row.vote] = row.count;
+      io.sockets.emit("scores", JSON.stringify(votes));
-        return obj;
-      }, {});
-      io.sockets.emit("scores", JSON.stringify(data));
     }
 
     setTimeout(function() {getVotes(client) }, 1000);
   });
 }
 
+function collectVotesFromResult(result) {
+  var votes = {a: 0, b: 0};
+
+  result.rows.forEach(function (row) {
+    votes[row.vote] = parseInt(row.count);
+  });
+
+  return votes;
+}
+
 app.use(cookieParser());
 app.use(bodyParser());
 app.use(methodOverride('X-HTTP-Method-Override'));