gameRecord.dao.php

Aller à la documentation de ce fichier.

<?php
 
namespace ComusParty\Models;
 
use DateTime;
use Exception;
use PDO;

class GameRecordDAO
{
    private ?PDO $pdo;

    public function __construct(?PDO $pdo)
    {
        $this->pdo = $pdo;
    }

    public function findByGameId(int $gameId): ?array
    {
        $stmt = $this->pdo->prepare("SELECT * FROM " . DB_PREFIX . "game_record WHERE game_id = :gameId");
        $stmt->bindParam(":gameId", $gameId);
        $stmt->execute();
        $stmt->setFetchMode(PDO::FETCH_ASSOC);
        $gameRecords = $stmt->fetchAll();
        if (!$gameRecords) {
            return null;
        }
        return $this->hydrateMany($gameRecords);
    }

    private function hydrateMany(array $rows): array
    {
        $gameRecords = [];
        foreach ($rows as $row) {
            $gameRecords[] = $this->hydrate($row);
        }
        return $gameRecords;
    }

    private function hydrate(array $row): GameRecord
    {
        if (!is_null($row["hosted_by"])) {
            $hostedBy = (new PlayerDAO($this->getPdo()))->findByUuid($row["hosted_by"]);
        } else {
            $hostedBy = null;
        }
 
        $game = (new GameDAO($this->getPdo()))->findById($row["game_id"]);
        $gameRecordState = match ($row["state"]) {
            "waiting" => GameRecordState::WAITING,
            "started" => GameRecordState::STARTED,
            "finished" => GameRecordState::FINISHED,
            default => GameRecordState::UNKNOWN,
        };
        $finishedAt = $row["finished_at"] ? new DateTime($row["finished_at"]) : null;
        $players = $this->findPlayersByGameRecordCode($row["code"]);
        if (!is_null($players)) {
            $players = array_map(function ($player) {
                $playerObject = (new PlayerDAO($this->getPdo()))->findByUuid($player["player_uuid"]);
                return [
                    "player" => $playerObject,
                    "token" => $player["token"]
                ];
            }, $players);
        }
 
        return new GameRecord(
            $row["code"],
            $game,
            $hostedBy,
            $players,
            $gameRecordState,
            $row["private"] === 1,
            $row["token"],
            new DateTime($row["created_at"]),
            new DateTime($row["updated_at"]),
            $finishedAt
        );
    }

    public function getPdo(): ?PDO
    {
        return $this->pdo;
    }

    public function setPdo(?PDO $pdo): void
    {
        $this->pdo = $pdo;
    }

    private function findPlayersByGameRecordCode(string $code): ?array
    {
        $stmt = $this->pdo->prepare("SELECT player_uuid, token FROM " . DB_PREFIX . "played WHERE game_code = :code");
        $stmt->bindParam(":code", $code);
        $stmt->execute();
        $stmt->setFetchMode(PDO::FETCH_ASSOC);
        $players = $stmt->fetchAll();
        if (!$players) {
            return null;
        }
        return $players;
    }

    public function findByGameIdAndState(int $gameId, GameRecordState $state): ?array
    {
        $stmt = $this->pdo->prepare("SELECT * FROM " . DB_PREFIX . "game_record WHERE game_id = :gameId AND state = :gameState");
        $stmt->bindParam(":gameId", $gameId);
 
        $state = match ($state) {
            GameRecordState::WAITING => "waiting",
            GameRecordState::STARTED => "started",
            GameRecordState::FINISHED => "finished",
            GameRecordState::UNKNOWN => null,
        };
        $stmt->bindParam(":gameState", $state);
 
        $stmt->execute();
        $stmt->setFetchMode(PDO::FETCH_ASSOC);
        $gameRecords = $stmt->fetchAll();
        if (!$gameRecords) {
            return null;
        }
        return $this->hydrateMany($gameRecords);
    }

    public function findByCode(string $code): ?GameRecord
    {
        $stmt = $this->pdo->prepare("SELECT * FROM " . DB_PREFIX . "game_record WHERE code = :code");
        $stmt->bindParam(":code", $code);
        $stmt->execute();
        $stmt->setFetchMode(PDO::FETCH_ASSOC);
 
        $gameRecord = $stmt->fetch();
        if (!$gameRecord) {
            return null;
        }
        return $this->hydrate($gameRecord);
    }

    public function findByHostUuid(string $uuid): ?array
    {
        $stmt = $this->pdo->prepare("SELECT * FROM " . DB_PREFIX . "game_record WHERE hosted_by = :uuid");
        $stmt->bindParam(":uuid", $uuid);
        $stmt->execute();
        $stmt->setFetchMode(PDO::FETCH_ASSOC);
 
        $gameRecords = $stmt->fetchAll();
        if (!$gameRecords) {
            return null;
        }
        return $this->hydrateMany($gameRecords);
    }
 

    public function findByState(GameRecordState $state): ?array
    {
        $state = match ($state) {
            GameRecordState::WAITING => "waiting",
            GameRecordState::STARTED => "started",
            GameRecordState::FINISHED => "finished",
            GameRecordState::UNKNOWN => null,
        };
 
        $stmt = $this->pdo->prepare("SELECT * FROM " . DB_PREFIX . "game_record WHERE state = :state");
        $stmt->bindParam(":state", $state);
        $stmt->execute();
        $stmt->setFetchMode(PDO::FETCH_ASSOC);
 
        $gameRecords = $stmt->fetchAll();
        if (!$gameRecords) {
            return null;
        }
        return $this->hydrateMany($gameRecords);
    }

    public function insert(GameRecord $gameRecord): bool
    {
        $stmt = $this->pdo->prepare("INSERT INTO " . DB_PREFIX . "game_record (code, token, game_id, hosted_by, state, private, created_at, updated_at, finished_at) VALUES (:code, :token, :gameId, :hostedBy, :state, :isPrivate, :createdAt, :updatedAt, :finishedAt)");
 
        $code = $gameRecord->getCode();
        $token = $gameRecord->getToken();
        $gameId = $gameRecord->getGame()->getId();
        $hostUuid = $gameRecord->getHostedBy()->getUuid();
        $state = match ($gameRecord->getState()) {
            GameRecordState::WAITING => "waiting",
            GameRecordState::STARTED => "started",
            GameRecordState::FINISHED => "finished",
            GameRecordState::UNKNOWN => null,
        };
        $isPrivate = $gameRecord->isPrivate();
        $createdAt = $gameRecord->getCreatedAt()->format("Y-m-d H:i:s");
        $updatedAt = $gameRecord->getUpdatedAt()?->format("Y-m-d H:i:s");
        $finishedAt = $gameRecord->getFinishedAt()?->format("Y-m-d H:i:s");
 
        $stmt->bindParam(":code", $code);
        $stmt->bindParam(":token", $token);
        $stmt->bindParam(":gameId", $gameId);
        $stmt->bindParam(":hostedBy", $hostUuid);
        $stmt->bindParam(":state", $state);
        $stmt->bindParam(":isPrivate", $isPrivate, PDO::PARAM_BOOL);
        $stmt->bindParam(":createdAt", $createdAt);
        $stmt->bindParam(":updatedAt", $updatedAt);
        $stmt->bindParam(":finishedAt", $finishedAt);
 
        return $stmt->execute();
    }

    public function update(GameRecord $gameRecord): bool
    {
        $stmt = $this->pdo->prepare("UPDATE " . DB_PREFIX . "game_record SET token = :token, hosted_by = :hosted_by, state = :state, private = :private, finished_at = :finishedAt WHERE code = :code");
 
        $token = $gameRecord->getToken();
        $hostUuid = $gameRecord->getHostedBy()->getUuid();
        $state = match ($gameRecord->getState()) {
            GameRecordState::WAITING => "waiting",
            GameRecordState::STARTED => "started",
            GameRecordState::FINISHED => "finished",
            GameRecordState::UNKNOWN => null,
        };
        $private = $gameRecord->isPrivate();
        $finishedAt = $gameRecord->getFinishedAt()?->format("Y-m-d H:i:s");
        $code = $gameRecord->getCode();
 
        $stmt->bindParam(":token", $token);
        $stmt->bindParam(":hosted_by", $hostUuid);
        $stmt->bindParam(":state", $state);
        $stmt->bindParam(":private", $private, PDO::PARAM_BOOL);
        $stmt->bindParam(":finishedAt", $finishedAt);
        $stmt->bindParam(":code", $code);
 
        return $stmt->execute();
    }

    public function updatePlayers(string $gameCode, array $players): bool
    {
        $stmt = $this->pdo->prepare("UPDATE " . DB_PREFIX . "played SET token = :token WHERE game_code = :gameCode AND player_uuid = :playerUuid");
        foreach ($players as $player) {
            $stmt->bindParam(":token", $player["token"]);
            $stmt->bindParam(":gameCode", $gameCode);
            $uuid = $player["player"]->getUuid();
            $stmt->bindParam(":playerUuid", $uuid);
            if (!$stmt->execute()) {
                return false;
            }
        }
        return true;
    }

    public function delete(string $code): bool
    {
        $stmt = $this->pdo->prepare("DELETE FROM " . DB_PREFIX . "game_record WHERE code = :code");
        $stmt->bindParam(":code", $code);
        return $stmt->execute();
    }

    public function addPlayer(GameRecord $gameRecord, Player $player): bool
    {
        $stmt = $this->pdo->prepare("INSERT INTO " . DB_PREFIX . "played (game_code, player_uuid) VALUES (:gameCode, :playerUuid)");
        $gameRecord->addPlayer($player);
        $playerUuid = $player->getUuid();
        $gameCode = $gameRecord->getCode();
        $stmt->bindParam(":gameCode", $gameCode);
        $stmt->bindParam(":playerUuid", $playerUuid);
        return $stmt->execute();
    }

    public function removePlayer(string $gameCode, string $playerUuid): bool
    {
        $stmt = $this->pdo->prepare("DELETE FROM " . DB_PREFIX . "played WHERE game_code = :gameCode AND player_uuid = :playerUuid");
        $stmt->bindParam(":gameCode", $gameCode);
        $stmt->bindParam(":playerUuid", $playerUuid);
        return $stmt->execute();
    }

    public function addWinner(string $code, mixed $uuid): bool
    {
        $stmt = $this->pdo->prepare("INSERT INTO " . DB_PREFIX . "won (game_code, player_uuid) VALUES (:gameCode, :playerUuid)");
        $stmt->bindParam(":gameCode", $code);
        $stmt->bindParam(":playerUuid", $uuid);
        return $stmt->execute();
    }
}