Integrated implementation of the NDS final project from

Ertug Obalar, Jens Patzelt and Milad Tousi

Author: VolkerChristian

TikTakToe/TikTakToeGameModel.cpp

@@ -1,9 +1,10 @@
 /*
- * tiktaktoe - a game using SnodeC
- * Copyright (C) 2021 Volker Christian <[email protected]>
+ * TikTakToe - a demo game using the snode.c framework
+ * Copyright (C) 2020, 2021 Volker Christian <[email protected]>
+ * Copyright (C) 2021 Ertug Obalar, Jens Patzelt and Milad Tousi
  *
  * This program is free software: you can redistribute it and/or modify
- * it under the terms of the GNU Lesser General Public License as published
+ * it under the terms of the GNU General Public License as published
  * by the Free Software Foundation, either version 3 of the License, or
  * (at your option) any later version.
  *
@@ -18,44 +19,138 @@
 
 #include "TikTakToeGameModel.h"
 
+#include <log/Logger.h>
 #include <map>               // for operator==
 #include <nlohmann/json.hpp> // for basic_json<>::object_t, basic_json<>::v...
 
 TikTakToeGameModel TikTakToeGameModel::gameModel;
 
-void TikTakToeGameModel::playersMove(const std::string& player, int cellID) {
+void TikTakToeGameModel::playersMove(const std::string& player, int cell) {
     if (player == players[whosNext]) {
-        int cellValue = 0;
+        board[cell] = whosNext == 0 ? 1 : -1;
 
-        if (player == "red") {
-            cellValue = 1;
-        } else if (player == "blue") {
-            cellValue = -1;
+        switch (checkState(board)) {
+            case 1:
+                state = "update";
+                break;
+
+            case 2:
+                state = "tie";
+                score[1]++;
+                break;
+
+            case 3:
+                state = "win";
+                if (whosNext == 0)
+                    score[0]++;
+                else
+                    score[2]++;
+                winner = player;
+                break;
+        }
+
+        whosNext = whosNext == 0 ? 1 : 0;
+    }
+}
+
+int TikTakToeGameModel::checkState(int board[]) {
+    int count = 0;
+
+    // Horizontal Win Check
+    for (int i = 0; i < 3; i++) {
+        for (int j = 0; j < 3; j++) {
+            count += board[i * 3 + j];
+        }
+
+        if (count == 3 || count == -3) {
+            for (int j = 0; j < 3; j++) {
+                board[i * 3 + j] *= 2;
+            }
+
+            return 3;
+        } else {
+            count = 0;
+        }
+    }
+
+    // Vertical Win Check
+    for (int i = 0; i < 3; i++) {
+        for (int j = 0; j < 3; j++) {
+            count += board[i + j * 3];
+        }
+
+        if (count == 3 || count == -3) {
+            for (int j = 0; j < 3; j++) {
+                board[i + j * 3] *= 2;
+            }
+
+            return 3;
+        } else {
+            count = 0;
+        }
+    }
+
+    //  Left Diagonal Win Check
+    {
+        for (int i = 0; i < 3; i++) {
+            count += board[i * 4];
         }
 
-        board[cellID] = cellValue;
+        if (count == 3 || count == -3) {
+            for (int i = 0; i < 3; i++) {
+                board[i * 4] *= 2;
+            }
 
-        if (whosNext >= 1) {
-            whosNext = 0;
+            return 3;
         } else {
-            whosNext += 1;
+            count = 0;
         }
     }
+
+    // Right Diagonal Win Check
+    {
+        for (int i = 0; i < 3; i++) {
+            count += board[i * 2 + 2];
+        }
+
+        if (count == 3 || count == -3) {
+            for (int i = 0; i < 3; i++) {
+                board[i * 2 + 2] *= 2;
+            }
+
+            return 3;
+        } else {
+            count = 0;
+        }
+    }
+
+    // Ongoing Check
+    for (int i = 0; i < 9; i++) {
+        if (board[i] == 0)
+            return 1;
+    }
+
+    // Return Tie
+    return 2;
 }
 
 void TikTakToeGameModel::resetBoard() {
-    whosNext = 0;
     for (int i = 0; i < 9; i++) {
         board[i] = 0;
     }
+
+    state = "reset";
+    winner = "";
 }
 
 nlohmann::json TikTakToeGameModel::updateClientState() {
     nlohmann::json message;
 
-    message["type"] = "update";
-    message["whosTurn"] = players[whosNext];
     message["board"] = board;
+    message["score"] = score;
+    message["state"] = state;
+    message["winner"] = winner;
+    message["leader"] = players[whosNext];
 
     return message;
 }

TikTakToe/TikTakToeGameModel.h

@@ -1,9 +1,10 @@
 /*
- * tiktaktoe - a game using SnodeC
- * Copyright (C) 2021 Volker Christian <[email protected]>
+ * TikTakToe - a demo game using the snode.c framework
+ * Copyright (C) 2020, 2021 Volker Christian <[email protected]>
+ * Copyright (C) 2021 Ertug Obalar, Jens Patzelt and Milad Tousi
  *
  * This program is free software: you can redistribute it and/or modify
- * it under the terms of the GNU Lesser General Public License as published
+ * it under the terms of the GNU General Public License as published
  * by the Free Software Foundation, either version 3 of the License, or
  * (at your option) any later version.
  *
@@ -19,29 +20,35 @@
 #ifndef TIKTAKTOEGAMEMODEL_H
 #define TIKTAKTOEGAMEMODEL_H
 
-#include <nlohmann/json_fwd.hpp> // for json
+#include <nlohmann/json_fwd.hpp>
 #include <string>
 
 class TikTakToeGameModel {
 protected:
     TikTakToeGameModel() = default;
 
 public:
-    void playersMove(const std::string& player, int cellID);
+    void playersMove(const std::string& player, int cell);
     void resetBoard();
+    int checkState(int board[]);
+
     nlohmann::json updateClientState();
 
     static TikTakToeGameModel& getGameModel();
 
 protected:
-    std::string players[2] = {"red", "blue"};
+    std::string players[2] = {"player_1", "player_2"};
+    std::string winner = "";
+    std::string state = "setup";
+
+    int board[9] = {0, 0, 0, 0, 0, 0, 0, 0, 0};
+    int score[3] = {0, 0, 0};
     int whosNext = 0;
     int numPlayers = 0;
-    int board[9] = {0, 0, 0, 0, 0, 0, 0, 0, 0};
 
     friend class TikTakToeSubProtocol;
 
     static TikTakToeGameModel gameModel;
 };
 
-#endif // TIKTAKTOEGAMEMODEL_H
+#endif

TikTakToe/TikTakToeSubProtocol.cpp

@@ -1,9 +1,10 @@
 /*
- * tiktaktoe - a game using SnodeC
- * Copyright (C) 2021 Volker Christian <[email protected]>
+ * TikTakToe - a demo game using the snode.c framework
+ * Copyright (C) 2020, 2021 Volker Christian <[email protected]>
+ * Copyright (C) 2021 Ertug Obalar, Jens Patzelt and Milad Tousi
  *
  * This program is free software: you can redistribute it and/or modify
- * it under the terms of the GNU Lesser General Public License as published
+ * it under the terms of the GNU General Public License as published
  * by the Free Software Foundation, either version 3 of the License, or
  * (at your option) any later version.
  *
@@ -22,8 +23,9 @@
 #include "config.h"
 
 #include <log/Logger.h>
-#include <net/timer/IntervalTimer.h> // for IntervalTimer
 #include <nlohmann/json.hpp>
+#include <web/http/server/Request.h>
+#include <web/http/server/Response.h>
 
 TikTakToeSubProtocol::TikTakToeSubProtocol(const std::string& name, TikTakToeGameModel& gameModel)
     : web::websocket::server::SubProtocol(name)
@@ -45,55 +47,58 @@ TikTakToeSubProtocol::~TikTakToeSubProtocol() {
 }
 
 void TikTakToeSubProtocol::onConnected() {
-    VLOG(0) << "TikTakToe on connected:";
+    // VLOG(0) << "TikTakToe on connected:";
 
-    VLOG(0) << "\tServer: " + getLocalAddressAsString();
-    VLOG(0) << "\tClient: " + getRemoteAddressAsString();
+    // VLOG(0) << "\tServer: " + getLocalAddressAsString();
+    // VLOG(0) << "\tClient: " + getRemoteAddressAsString();
 
-    VLOG(0) << "\tNumPlayers: " << gameModel.numPlayers;
+    // VLOG(0) << "\tNumPlayers: " << gameModel.numPlayers;
 
     if (gameModel.numPlayers < 2) {
         nlohmann::json json;
 
-        json["type"] = "setup";
-        json["playerData"]["whosTurn"] = gameModel.players[gameModel.whosNext];
-        json["playerData"]["playerID"] = gameModel.players[gameModel.numPlayers++];
-        json["playerData"]["board"] = gameModel.board;
-
-        VLOG(0) << "Json: " << json.dump();
+        json["board"] = gameModel.board;
+        json["score"] = gameModel.score;
+        json["state"] = gameModel.state;
+        json["winner"] = gameModel.winner;
+        json["leader"] = gameModel.players[gameModel.whosNext];
+        json["player"] = gameModel.players[gameModel.numPlayers++];
 
         sendMessage(json.dump());
-
         activePlayer = true;
+
+        VLOG(0) << "JSON: " << json.dump();
     } else {
         sendClose();
+
+        VLOG(0) << "sendClose";
     }
 }
 
-void TikTakToeSubProtocol::onMessageStart(int opCode) {
-    VLOG(0) << "TikTakToe on Message Start - OpCode: " << opCode;
+void TikTakToeSubProtocol::onMessageStart([[maybe_unused]] int opCode) {
+    // VLOG(0) << "TikTakToe on Message Start - OpCode: " << opCode;
 }
 
-void TikTakToeSubProtocol::onMessageData(const char* junk, std::size_t junkLen) {
+void TikTakToeSubProtocol::onMessageData(const char* junk, size_t junkLen) {
     data += std::string(junk, junkLen);
 }
 
 void TikTakToeSubProtocol::onMessageEnd() {
-    VLOG(0) << "TikTakToe on Data: " << data;
+    // VLOG(0) << "TikTakToe on Data: " << data;
 
     nlohmann::json action = nlohmann::json::parse(data);
 
     VLOG(0) << "Action dump: " << action.dump();
 
     if (action["type"] == "move") {
-        gameModel.playersMove(action["playerID"], action["cellID"]);
+        gameModel.playersMove(action["player"], action["cell"]);
         nlohmann::json message = gameModel.updateClientState();
 
-        /* // also possible
-                forEachClient([&message](SubProtocol* client) {
-                    client->sendMessage(message.dump());
-                });
-        */
+        sendBroadcast(message.dump());
+        VLOG(0) << "SendMessage Dump: " << message.dump();
+    } else if (action["type"] == "reset") {
+        gameModel.resetBoard();
+        nlohmann::json message = gameModel.updateClientState();
 
         sendBroadcast(message.dump());
         VLOG(0) << "SendMessage Dump: " << message.dump();
@@ -107,12 +112,12 @@ void TikTakToeSubProtocol::onMessageError(uint16_t errnum) {
 }
 
 void TikTakToeSubProtocol::onPongReceived() {
-    VLOG(0) << "TikTakToe on Pong received";
+    // VLOG(0) << "TikTakToe on Pong received";
     flyingPings = 0;
 }
 
 void TikTakToeSubProtocol::onDisconnected() {
-    VLOG(0) << "TikTakToe on disconnected:";
+    // VLOG(0) << "TikTakToe on disconnected:";
 
     if (activePlayer) {
         gameModel.numPlayers--;
@@ -122,6 +127,6 @@ void TikTakToeSubProtocol::onDisconnected() {
         }
     }
 
-    VLOG(0) << "\tServer: " + getLocalAddressAsString();
-    VLOG(0) << "\tClient: " + getRemoteAddressAsString();
+    // VLOG(0) << "\tServer: " + getLocalAddressAsString();
+    // VLOG(0) << "\tClient: " + getRemoteAddressAsString();
 }

TikTakToe/TikTakToeSubProtocol.h

@@ -1,9 +1,10 @@
 /*
- * tiktaktoe - a game using SnodeC
- * Copyright (C) 2021 Volker Christian <[email protected]>
+ * TikTakToe - a demo game using the snode.c framework
+ * Copyright (C) 2020, 2021 Volker Christian <[email protected]>
+ * Copyright (C) 2021 Ertug Obalar, Jens Patzelt and Milad Tousi
  *
  * This program is free software: you can redistribute it and/or modify
- * it under the terms of the GNU Lesser General Public License as published
+ * it under the terms of the GNU General Public License as published
  * by the Free Software Foundation, either version 3 of the License, or
  * (at your option) any later version.
  *
@@ -21,12 +22,9 @@
 
 class TikTakToeGameModel;
 
+#include <net/timer/IntervalTimer.h>
 #include <web/websocket/server/SubProtocol.h>
 
-namespace net::timer {
-    class Timer;
-} // namespace net::timer
-
 class TikTakToeSubProtocol : public web::websocket::server::SubProtocol {
 public:
     TikTakToeSubProtocol(const std::string& name, TikTakToeGameModel& game);
@@ -35,7 +33,7 @@ class TikTakToeSubProtocol : public web::websocket::server::SubProtocol {
 
     void onConnected() override;
     void onMessageStart(int opCode) override;
-    void onMessageData(const char* junk, std::size_t junkLen) override;
+    void onMessageData(const char* junk, size_t junkLen) override;
     void onMessageEnd() override;
     void onMessageError(uint16_t errnum) override;
     void onPongReceived() override;
@@ -48,11 +46,9 @@ class TikTakToeSubProtocol : public web::websocket::server::SubProtocol {
 
     int flyingPings = 0;
 
-    const std::string name;
-
     TikTakToeGameModel& gameModel;
 
     net::timer::Timer& timer;
 };
 
-#endif // TIKTAKTOESUBPROTOCOL_H
+#endif