gd-chess-server - server for my chess game


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104

/*jshint esversion: 6 */
const WebSocket = require("ws");
const gdCom = require("@gd-com/utils");

const PORT = process.env.PORT || 3000;

const wss = new WebSocket.Server({ port: PORT });

const HEADERS = {
  move: "M",
  joinrequest: "J",
  hostrequest: "H",
  stopgame: "K",
  ping: "P",
};

let games = {};

function send_packet(string, header, client) {
  const packet = gdCom.putVar({ data: string, header: header });
  client.send(packet);
}

console.log(`Server started on port ${PORT}`);
wss.on("connection", (ws) => {
  console.log("client connected");

  // on message recieved
  ws.on("message", (message) => {
    let recieve = gdCom.getVar(Buffer.from(message)).value;
    let data = recieve.data;
    let header = recieve.header;
    console.log(`packet ${data} recieved with header ${header}`);
    if (header) {
      switch (header) {
        case HEADERS.move:
          handle_move(data);
          break;
        case HEADERS.joinrequest:
          handle_joinrequest(data, ws);
          break;
        case HEADERS.hostrequest:
          handle_hostrequest(data, ws);
          break;
        case HEADERS.stopgame:
          handle_stop(data);
          break;
        case HEADERS.ping:
          send_packet("", HEADERS.ping, ws);
          break;
        default:
          console.log(`header ${header} unknown`);
          break;
      }
    }
  });
});

function handle_move(data) {
  if (games[data.gamecode] !== undefined) {
    console.log("move: " + data.move);
    games[data.gamecode].forEach((client) => {
      send_packet(data, HEADERS.move, client);
    });
  }
  console.log("game not found!");
}

function handle_joinrequest(data, ws) {
  console.log("joinrequest");
  if (games[data] !== undefined) {
    if (games[data].length < 2) {
      if (games[data][0] !== ws) {
        send_packet("Y", HEADERS.joinrequest, ws);
        games[data].push(ws);
      } else {
        send_packet("err: you have already joined", HEADERS.joinrequest, ws);
      }
    } else {
      send_packet("err: game full", HEADERS.joinrequest, ws);
    }
  } else {
    send_packet("err: game does not exist", HEADERS.joinrequest, ws);
  }
}

function handle_hostrequest(data, ws) {
  console.log("hostrequest");
  if (games[data] === undefined) {
    games[data] = [ws];
    send_packet("Y", HEADERS.hostrequest, ws);
    console.log(`game ${data} created`);
  } else {
    send_packet("err: game already exists", HEADERS.hostrequest, ws);
  }
}

function handle_stop(data) {
  console.log("stopgame " + data);
  games[data].forEach((client) => {
    send_packet("", HEADERS.stopgame, client);
  });
  delete games[data];
}