mirror of
https://github.com/kierankihn/uno-game.git
synced 2025-12-27 10:23:16 +08:00
feat(network): add MessageSerializer for message serialization/deserialization
- Implemented `MessageSerializer` class to handle JSON serialization and deserialization of game messages and payloads. - Added `MessageSerializer.cpp` and `MessageSerializer.h` to `CMakeLists.txt`. - Linked `nlohmann_json` library to the project.
This commit is contained in:
Kieran Kihn
278
src/network/MessageSerializer.cpp
Normal file
278
src/network/MessageSerializer.cpp
Normal file
@@ -0,0 +1,278 @@
|
||||
/**
|
||||
* @file
|
||||
*
|
||||
* @author Yuzhe Guo
|
||||
* @date 2025.11.20
|
||||
*/
|
||||
#include "MessageSerializer.h"
|
||||
|
||||
namespace UNO::NETWORK {
|
||||
nlohmann::json MessageSerializer::serializeCard(const GAME::Card &card)
|
||||
{
|
||||
return {{"card_color", card.colorToString()}, {"card_type", card.typeToString()}};
|
||||
}
|
||||
|
||||
nlohmann::json MessageSerializer::serializeDiscardPile(const GAME::DiscardPile &discardPile)
|
||||
{
|
||||
nlohmann::json res = nlohmann::json::array();
|
||||
for (const auto &i : discardPile.getCards()) {
|
||||
res.push_back(serializeCard(i));
|
||||
}
|
||||
return res;
|
||||
}
|
||||
|
||||
nlohmann::json MessageSerializer::serializeHandCard(const GAME::HandCard &handCard)
|
||||
{
|
||||
nlohmann::json res = nlohmann::json::array();
|
||||
for (const auto &i : handCard.getCards()) {
|
||||
res.push_back(serializeCard(i));
|
||||
}
|
||||
return res;
|
||||
}
|
||||
|
||||
nlohmann::json MessageSerializer::serializePayload(const std::monostate &payload)
|
||||
{
|
||||
return nullptr;
|
||||
}
|
||||
|
||||
nlohmann::json MessageSerializer::serializePayload(const JoinGamePayload &payload)
|
||||
{
|
||||
return {{"name", payload.playerName}};
|
||||
}
|
||||
|
||||
nlohmann::json MessageSerializer::serializePayload(const StartGamePayload &payload)
|
||||
{
|
||||
return nullptr;
|
||||
}
|
||||
|
||||
nlohmann::json MessageSerializer::serializePayload(const DrawCardPayload &payload)
|
||||
{
|
||||
return {{"draw_count", payload.drawCount}};
|
||||
}
|
||||
|
||||
nlohmann::json MessageSerializer::serializePayload(const PlayCardPayload &payload)
|
||||
{
|
||||
return {{"card", serializeCard(payload.card)}};
|
||||
}
|
||||
|
||||
nlohmann::json MessageSerializer::serializePayload(const InitGamePayload &payload)
|
||||
{
|
||||
return {{"discard_pile", serializeDiscardPile(payload.discardPile)},
|
||||
{"hand_card", serializeHandCard(payload.handCard)},
|
||||
{"current_player", payload.currentPlayerIndex}};
|
||||
}
|
||||
|
||||
nlohmann::json MessageSerializer::serializePayload(const EndGamePayload &payload)
|
||||
{
|
||||
return nullptr;
|
||||
}
|
||||
|
||||
std::string MessageSerializer::serializeMessagePayloadType(const MessagePayloadType &messagePayloadType)
|
||||
{
|
||||
switch (messagePayloadType) {
|
||||
case MessagePayloadType::JOIN_GAME: return "JOIN_GAME";
|
||||
case MessagePayloadType::START_GAME: return "START_GAME";
|
||||
case MessagePayloadType::DRAW_CARD: return "DRAW_CARD";
|
||||
case MessagePayloadType::PLAY_CARD: return "PLAY_CARD";
|
||||
case MessagePayloadType::INIT_GAME: return "INIT_GAME";
|
||||
case MessagePayloadType::END_GAME: return "END_GAME";
|
||||
}
|
||||
throw std::invalid_argument("invalid message payload type");
|
||||
}
|
||||
|
||||
nlohmann::json MessageSerializer::serializeMessage(const Message &message)
|
||||
{
|
||||
return {{"payload_type", serializeMessagePayloadType(message.getMessagePayloadType())},
|
||||
{"payload", std::visit([](auto &&value) { return serializePayload(value); }, message.getMessagePayload())}};
|
||||
}
|
||||
|
||||
std::string MessageSerializer::serialize(const Message &message)
|
||||
{
|
||||
return serializeMessage(message).dump();
|
||||
}
|
||||
|
||||
GAME::CardColor MessageSerializer::deserializeCardColor(const std::string &cardColor)
|
||||
{
|
||||
if (cardColor == "Red") return GAME::CardColor::RED;
|
||||
if (cardColor == "Blue") return GAME::CardColor::BLUE;
|
||||
if (cardColor == "Green") return GAME::CardColor::GREEN;
|
||||
if (cardColor == "Yellow") return GAME::CardColor::YELLOW;
|
||||
throw std::invalid_argument("Invalid card color: '" + cardColor + "'. Expected: Red, Blue, Green, or Yellow");
|
||||
}
|
||||
|
||||
GAME::CardType MessageSerializer::deserializeCardType(const std::string &cardType)
|
||||
{
|
||||
if (cardType == "0") return GAME::CardType::NUM0;
|
||||
if (cardType == "1") return GAME::CardType::NUM1;
|
||||
if (cardType == "2") return GAME::CardType::NUM2;
|
||||
if (cardType == "3") return GAME::CardType::NUM3;
|
||||
if (cardType == "4") return GAME::CardType::NUM4;
|
||||
if (cardType == "5") return GAME::CardType::NUM5;
|
||||
if (cardType == "6") return GAME::CardType::NUM6;
|
||||
if (cardType == "7") return GAME::CardType::NUM7;
|
||||
if (cardType == "8") return GAME::CardType::NUM8;
|
||||
if (cardType == "9") return GAME::CardType::NUM9;
|
||||
if (cardType == "Skip") return GAME::CardType::SKIP;
|
||||
if (cardType == "Reverse") return GAME::CardType::REVERSE;
|
||||
if (cardType == "Draw 2") return GAME::CardType::DRAW2;
|
||||
if (cardType == "Wild") return GAME::CardType::WILD;
|
||||
if (cardType == "Wild Draw 4") return GAME::CardType::WILDDRAWFOUR;
|
||||
throw std::invalid_argument("Invalid card type: '" + cardType + "'. Expected: 0-9, Skip, Reverse, Draw 2, Wild, or Wild Draw 4");
|
||||
}
|
||||
|
||||
GAME::Card MessageSerializer::deserializeCard(const nlohmann::json &card)
|
||||
{
|
||||
if (card.is_object() == false) throw std::invalid_argument("Invalid card format: expected JSON object");
|
||||
try {
|
||||
if (card.at("card_color").is_string() == false) throw std::invalid_argument("Invalid card_color field: expected string");
|
||||
if (card.at("card_type").is_string() == false) throw std::invalid_argument("Invalid card_type field: expected string");
|
||||
return {deserializeCardColor(card.at("card_color")), deserializeCardType(card.at("card_type"))};
|
||||
}
|
||||
catch (const nlohmann::json::out_of_range &) {
|
||||
throw std::invalid_argument("Missing required field in card: expected 'card_color' and 'card_type'");
|
||||
}
|
||||
}
|
||||
|
||||
GAME::DiscardPile MessageSerializer::deserializeDiscardPile(const nlohmann::json &discardPile)
|
||||
{
|
||||
if (discardPile.is_array() == false) throw std::invalid_argument("Invalid discard_pile format: expected JSON array");
|
||||
|
||||
GAME::DiscardPile res;
|
||||
for (const auto &i : std::views::reverse(discardPile)) {
|
||||
res.add(deserializeCard(i));
|
||||
}
|
||||
|
||||
return res;
|
||||
}
|
||||
|
||||
GAME::HandCard MessageSerializer::deserializeHandCard(const nlohmann::json &handCard)
|
||||
{
|
||||
if (handCard.is_array() == false) throw std::invalid_argument("Invalid hand_card format: expected JSON array");
|
||||
|
||||
GAME::HandCard res;
|
||||
for (const auto &i : std::views::reverse(handCard)) {
|
||||
res.draw(deserializeCard(i));
|
||||
}
|
||||
|
||||
return res;
|
||||
}
|
||||
|
||||
std::monostate MessageSerializer::deserializeMonostatePayload(const nlohmann::json &payload)
|
||||
{
|
||||
if (payload.is_null() == false) throw std::invalid_argument("Invalid payload: expected null for empty payload");
|
||||
return {};
|
||||
}
|
||||
|
||||
|
||||
JoinGamePayload MessageSerializer::deserializeJoinGamePayload(const nlohmann::json &payload)
|
||||
{
|
||||
try {
|
||||
if (payload.is_object() == false) throw std::invalid_argument("Invalid JOIN_GAME payload: expected JSON object");
|
||||
if (payload.at("name").is_string() == false)
|
||||
throw std::invalid_argument("Invalid 'name' field in JOIN_GAME payload: expected string");
|
||||
return {payload.at("name")};
|
||||
}
|
||||
catch (const nlohmann::json::out_of_range &) {
|
||||
throw std::invalid_argument("Missing required field 'name' in JOIN_GAME payload");
|
||||
}
|
||||
}
|
||||
|
||||
StartGamePayload MessageSerializer::deserializeStartGamePayload(const nlohmann::json &payload)
|
||||
{
|
||||
if (payload.is_null() == false) throw std::invalid_argument("Invalid START_GAME payload: expected null");
|
||||
return {};
|
||||
}
|
||||
|
||||
DrawCardPayload MessageSerializer::deserializeDrawCardPayload(const nlohmann::json &payload)
|
||||
{
|
||||
try {
|
||||
if (payload.is_object() == false) throw std::invalid_argument("Invalid DRAW_CARD payload: expected JSON object");
|
||||
if (payload.at("draw_count").is_number_unsigned() == false)
|
||||
throw std::invalid_argument("Invalid 'draw_count' field in DRAW_CARD payload: expected unsigned integer");
|
||||
return {payload.at("draw_count")};
|
||||
}
|
||||
catch (const nlohmann::json::out_of_range &) {
|
||||
throw std::invalid_argument("Missing required field 'draw_count' in DRAW_CARD payload");
|
||||
}
|
||||
}
|
||||
|
||||
PlayCardPayload MessageSerializer::deserializePlayCardPayload(const nlohmann::json &payload)
|
||||
{
|
||||
try {
|
||||
if (payload.is_object() == false) throw std::invalid_argument("Invalid PLAY_CARD payload: expected JSON object");
|
||||
return {deserializeCard(payload.at("card"))};
|
||||
}
|
||||
catch (const nlohmann::json::out_of_range &) {
|
||||
throw std::invalid_argument("Missing required field 'card' in PLAY_CARD payload");
|
||||
}
|
||||
}
|
||||
|
||||
InitGamePayload MessageSerializer::deserializeInitGamePayload(const nlohmann::json &payload)
|
||||
{
|
||||
try {
|
||||
if (payload.is_object() == false) throw std::invalid_argument("Invalid INIT_GAME payload: expected JSON object");
|
||||
if (payload.at("current_player").is_number_unsigned() == false)
|
||||
throw std::invalid_argument("Invalid 'current_player' field in INIT_GAME payload: expected unsigned integer");
|
||||
return {deserializeDiscardPile(payload.at("discard_pile")),
|
||||
deserializeHandCard(payload.at("hand_card")),
|
||||
payload.at("current_player")};
|
||||
}
|
||||
catch (const nlohmann::json::out_of_range &) {
|
||||
throw std::invalid_argument(
|
||||
"Missing required field in INIT_GAME payload: expected 'discard_pile', 'hand_card', and 'current_player'");
|
||||
}
|
||||
}
|
||||
|
||||
EndGamePayload MessageSerializer::deserializeEndGamePayload(const nlohmann::json &payload)
|
||||
{
|
||||
if (payload.is_null() == false) throw std::invalid_argument("Invalid END_GAME payload: expected null");
|
||||
return {};
|
||||
}
|
||||
|
||||
MessagePayloadType MessageSerializer::deserializeMessagePayloadType(const std::string &messagePayloadType)
|
||||
{
|
||||
if (messagePayloadType == "JOIN_GAME") return MessagePayloadType::JOIN_GAME;
|
||||
if (messagePayloadType == "START_GAME") return MessagePayloadType::START_GAME;
|
||||
if (messagePayloadType == "DRAW_CARD") return MessagePayloadType::DRAW_CARD;
|
||||
if (messagePayloadType == "PLAY_CARD") return MessagePayloadType::PLAY_CARD;
|
||||
if (messagePayloadType == "INIT_GAME") return MessagePayloadType::INIT_GAME;
|
||||
if (messagePayloadType == "END_GAME") return MessagePayloadType::END_GAME;
|
||||
throw std::invalid_argument("Invalid message payload type: '" + messagePayloadType
|
||||
+ "'. Expected: JOIN_GAME, START_GAME, DRAW_CARD, PLAY_CARD, INIT_GAME, or END_GAME");
|
||||
}
|
||||
|
||||
Message MessageSerializer::deserializeMessage(const nlohmann::json &message)
|
||||
{
|
||||
try {
|
||||
if (message.is_object() == false) throw std::invalid_argument("Invalid message format: expected JSON object");
|
||||
if (message.at("payload_type").is_string() == false)
|
||||
throw std::invalid_argument("Invalid 'payload_type' field: expected string");
|
||||
|
||||
auto payloadType = deserializeMessagePayloadType(message.at("payload_type"));
|
||||
switch (payloadType) {
|
||||
case MessagePayloadType::JOIN_GAME: return {payloadType, deserializeJoinGamePayload(message.at("payload"))};
|
||||
case MessagePayloadType::START_GAME: return {payloadType, deserializeStartGamePayload(message.at("payload"))};
|
||||
case MessagePayloadType::DRAW_CARD: return {payloadType, deserializeDrawCardPayload(message.at("payload"))};
|
||||
case MessagePayloadType::PLAY_CARD: return {payloadType, deserializePlayCardPayload(message.at("payload"))};
|
||||
case MessagePayloadType::INIT_GAME: return {payloadType, deserializeInitGamePayload(message.at("payload"))};
|
||||
case MessagePayloadType::END_GAME: return {payloadType, deserializeEndGamePayload(message.at("payload"))};
|
||||
}
|
||||
|
||||
std::unreachable();
|
||||
}
|
||||
catch (const nlohmann::json::out_of_range &) {
|
||||
throw std::invalid_argument("Missing required field in message: expected 'payload_type' and 'payload'");
|
||||
}
|
||||
}
|
||||
|
||||
Message MessageSerializer::deserialize(const std::string &data)
|
||||
{
|
||||
try {
|
||||
return deserializeMessage(nlohmann::json::parse(data));
|
||||
}
|
||||
catch (const nlohmann::json::parse_error &) {
|
||||
throw std::invalid_argument("Invalid JSON body");
|
||||
}
|
||||
}
|
||||
|
||||
} // namespace UNO::NETWORK
|
||||
Reference in New Issue
Block a user