From: Elijah Cohen <eli@eli173.com>
Date: Thu, 18 Apr 2019 07:34:33 +0000 (-0500)
Subject: fixed some stuff, maybe it works?
X-Git-Url: https://git.eli173.com/?a=commitdiff_plain;h=b611e3171faabb261cb72be29351d383a5a63eca;p=pong_br

fixed some stuff, maybe it works?

still untested considering user inputs and whatnot
---

diff --git a/server/game.js b/server/game.js
index 9241cbe..1ea9ede 100644
--- a/server/game.js
+++ b/server/game.js
@@ -8,13 +8,15 @@ function Game(players) {
 }
 
 Game.prototype.start = function(ms) {
-    this.timeout = setInterval(this.getNextFrame, ms);
+    var me = this;
+    var tmpfn = function() {me.getNextFrame()};
+    this.timeout = setInterval(tmpfn, ms);
 }
 
 Game.prototype.getNextFrame = function() {
-    // 
+    console.log(this);
     var inputs = this.players.map(function(p) {return p.get_status();});
-    this.state.updateState(inputs);
+    this.state.update(inputs);
     var state = this.state.getState();
     for(var i=0; i<this.players.length;i++) {
 	this.players[i].socket.send(i.toString() + ", " + state);
diff --git a/server/matchmaker.js b/server/matchmaker.js
index ed7c2b6..29f36a0 100644
--- a/server/matchmaker.js
+++ b/server/matchmaker.js
@@ -5,7 +5,7 @@ const MS_PER_FRAME = 500;
 
 const WebSocket = require('ws');
 
-const wss = WebSocket.Server({port: WS_PORT});
+const wss = new WebSocket.Server({port: WS_PORT});
 
 const Player = require('./player.js');
 const Game = require('./game.js');
@@ -13,13 +13,11 @@ const Game = require('./game.js');
 players = [];
 
 
-wss.on('connection', manage_incoming);
-
 
 var manage_incoming = function(ws) {
     var new_player = new Player(ws);
     players.push(new_player);
-    if(players.length > NUM_PLAYERS) {
+    if(players.length >= NUM_PLAYERS) {
 	// is the slicing necessary? I'm not sure I understand js's mechanisms without threads
 	game = new Game(players.slice(0, NUM_PLAYERS));
 	//
@@ -28,3 +26,6 @@ var manage_incoming = function(ws) {
 	players = players.slice(NUM_PLAYERS);
     }
 }
+
+wss.on('connection', manage_incoming);
+