Compare commits
18 Commits
f5aabafcc5
...
env-settin
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
641573842c | ||
| abc3712d97 | |||
|
|
66cb356955 | ||
|
|
ffd20f5535 | ||
| 1b52f80448 | |||
|
|
b965f0f085 | ||
|
|
c4c989db4c | ||
| 37507bd169 | |||
|
|
732148a533 | ||
|
|
50d7ce745c | ||
| a475c1a268 | |||
|
|
1ae0f651d8 | ||
|
|
8e933631b2 | ||
| f8746207e6 | |||
|
|
e42966e618 | ||
|
|
e4976e51fa | ||
|
|
65070688ec | ||
|
|
e54c870f05 |
16
.env
16
.env
@@ -25,7 +25,15 @@ APP_SECRET=
|
||||
#
|
||||
# DATABASE_URL="sqlite:///%kernel.project_dir%/var/data_%kernel.environment%.db"
|
||||
# DATABASE_URL="mysql://app:!ChangeMe!@127.0.0.1:3306/app?serverVersion=8.0.32&charset=utf8mb4"
|
||||
DATABASE_URL="mysql://escapepage:b.0nqrxJ%%2FD%%2ALuf9N@localhost:3306/escapepage?serverVersion=8.0.32&charset=utf8mb4"
|
||||
DB_DRIVER=pdo_mysql
|
||||
DB_SERVER_VERSION=8.0.32
|
||||
DB_CHARSET=utf8mb4
|
||||
DB_USER=escapepage
|
||||
DB_PASSWORD="b.0nqrxJ/D*Luf9N"
|
||||
DB_HOST=localhost
|
||||
DB_PORT=3306
|
||||
DB_NAME=escapepage
|
||||
DATABASE_URL="${DB_DRIVER}://${DB_USER}:${DB_PASSWORD}@${DB_HOST}:${DB_PORT}/${DB_NAME}?serverVersion=${DB_SERVER_VERSION}&charset=${DB_CHARSET}"
|
||||
###< doctrine/doctrine-bundle ###
|
||||
|
||||
###> symfony/messenger ###
|
||||
@@ -57,7 +65,9 @@ MERCURE_URL=http://mercure/.well-known/mercure
|
||||
# Public hub URL used by browsers
|
||||
MERCURE_PUBLIC_URL=http://localhost:8090/.well-known/mercure
|
||||
# Shared secret for signing JWTs (dev only). In prod, set via real env/secrets.
|
||||
MERCURE_JWT_SECRET=!ChangeThisMercureJWT!
|
||||
# Base URL for Mercure topics. Use .dev in development; override to .com in prod via .env.prod or real env.
|
||||
MERCURE_JWT_SECRET=!ChangeThisMercureJWTSignedBySymfonySecretKey!
|
||||
# CORS allowed origins (default)
|
||||
MERCURE_CORS_ALLOWED_ORIGINS=http://localhost:8080
|
||||
# Base URL for Mercure topics.
|
||||
MERCURE_TOPIC_BASE=https://escapepage.dev
|
||||
###< mercure ###
|
||||
|
||||
4
.env.dev
4
.env.dev
@@ -1,4 +0,0 @@
|
||||
|
||||
###> symfony/framework-bundle ###
|
||||
APP_SECRET=620e9ce5f88a714b636179eb39d5be4f
|
||||
###< symfony/framework-bundle ###
|
||||
@@ -1,9 +0,0 @@
|
||||
### Compiled or real environment variables should be used in production.
|
||||
### Configure MAILER_DSN to use SendGrid API transport.
|
||||
### Prefer storing SENDGRID_API_KEY using Symfony Secrets or real env vars.
|
||||
|
||||
###> symfony/mailer ###
|
||||
# Example using SendGrid API key (replace with real secret via vault/secrets):
|
||||
# SENDGRID_API_KEY=SG.xxxxx
|
||||
MAILER_DSN=sendgrid+api://%env(resolve:SENDGRID_API_KEY)%@default
|
||||
###< symfony/mailer ###
|
||||
@@ -1,3 +0,0 @@
|
||||
# define your env variables for the test env here
|
||||
KERNEL_CLASS='App\Kernel'
|
||||
APP_SECRET='$ecretf0rt3st'
|
||||
@@ -4,7 +4,7 @@ import './styles/game1.css';
|
||||
let sequenceFinished = false;
|
||||
let stillPlayingSound = true;
|
||||
|
||||
function subscribeToMercure(mercurePublicUrl, topic) {
|
||||
function subscribeToMercure(mercurePublicUrl, topic, myScreen) {
|
||||
try {
|
||||
const url = mercurePublicUrl + '?topic=' + encodeURIComponent(topic);
|
||||
const es = new EventSource(url);
|
||||
@@ -16,6 +16,13 @@ function subscribeToMercure(mercurePublicUrl, topic) {
|
||||
|
||||
// data is [sendTo, message]
|
||||
if (Array.isArray(data) && data.length >= 2) {
|
||||
const sendTo = parseInt(data[0]);
|
||||
// Filter: 0 means everyone, otherwise must match myScreen
|
||||
if (sendTo !== 0 && sendTo !== parseInt(myScreen)) {
|
||||
console.log('[Mercure][game1] Message not for this player, skipping.');
|
||||
return;
|
||||
}
|
||||
|
||||
const messageContainer = document.getElementById('message-container');
|
||||
if (messageContainer) {
|
||||
const msgEl = document.createElement('div');
|
||||
@@ -24,6 +31,7 @@ function subscribeToMercure(mercurePublicUrl, topic) {
|
||||
msgEl.style.color = '#0F0'; // Green for incoming messages
|
||||
msgEl.style.marginBottom = '10px';
|
||||
messageContainer.appendChild(msgEl);
|
||||
window.scrollTo(0, document.body.scrollHeight);
|
||||
if(stillPlayingSound)
|
||||
playSound();
|
||||
console.log('[Mercure][game1] sequenceFinished status:', sequenceFinished);
|
||||
@@ -120,15 +128,64 @@ document.addEventListener('DOMContentLoaded', async () => {
|
||||
|
||||
const mercurePublicUrl = cfgEl.dataset.mercurePublicUrl;
|
||||
const topic = cfgEl.dataset.topic;
|
||||
const screen = cfgEl.dataset.screen;
|
||||
const apiPingUrl = cfgEl.dataset.apiPingUrl;
|
||||
const apiEchoUrl = cfgEl.dataset.apiEchoUrl;
|
||||
const apiCheckFinishedUrl = cfgEl.dataset.apiCheckFinishedUrl;
|
||||
const lostUrl = cfgEl.dataset.lostUrl;
|
||||
|
||||
if (mercurePublicUrl && topic) {
|
||||
subscribeToMercure(mercurePublicUrl, topic);
|
||||
subscribeToMercure(mercurePublicUrl, topic, screen);
|
||||
} else {
|
||||
console.warn('[Mercure][game1] Missing data attributes on #mercure-config');
|
||||
}
|
||||
|
||||
// Timer logic
|
||||
const timerEl = document.getElementById('game-timer');
|
||||
if (timerEl && timerEl.dataset.endTime) {
|
||||
const endTime = parseInt(timerEl.dataset.endTime) * 1000;
|
||||
|
||||
const updateTimer = async () => {
|
||||
const now = Date.now();
|
||||
const diff = endTime - now;
|
||||
|
||||
if (diff <= 0) {
|
||||
timerEl.textContent = '00:00:00';
|
||||
|
||||
// Timer reached zero, check with server
|
||||
if (apiCheckFinishedUrl && lostUrl) {
|
||||
try {
|
||||
const response = await fetchJson(apiCheckFinishedUrl, { method: 'POST' });
|
||||
if (response && response.finished) {
|
||||
window.location.href = lostUrl;
|
||||
return; // Stop the timer loop
|
||||
}
|
||||
} catch (e) {
|
||||
console.error('[API][game1] Failed to check finished status:', e);
|
||||
}
|
||||
}
|
||||
|
||||
// Even if check failed or not finished, stop the loop if diff <= 0
|
||||
// (though technically if the server says not finished, we might want to keep checking,
|
||||
// but 00:00:00 usually means it's over).
|
||||
return;
|
||||
}
|
||||
|
||||
const hours = Math.floor(diff / (1000 * 60 * 60));
|
||||
const minutes = Math.floor((diff % (1000 * 60 * 60)) / (1000 * 60));
|
||||
const seconds = Math.floor((diff % (1000 * 60)) / 1000);
|
||||
|
||||
const hDisplay = hours.toString().padStart(2, '0');
|
||||
const mDisplay = minutes.toString().padStart(2, '0');
|
||||
const sDisplay = seconds.toString().padStart(2, '0');
|
||||
|
||||
timerEl.textContent = `${hDisplay}:${mDisplay}:${sDisplay}`;
|
||||
setTimeout(updateTimer, 1000);
|
||||
};
|
||||
|
||||
updateTimer();
|
||||
}
|
||||
|
||||
// Demo API calls
|
||||
try {
|
||||
if (apiPingUrl) {
|
||||
@@ -181,6 +238,7 @@ document.addEventListener('DOMContentLoaded', async () => {
|
||||
msgEl.textContent = msg[0];
|
||||
msgEl.style.marginBottom = '10px';
|
||||
messageContainer.appendChild(msgEl);
|
||||
window.scrollTo(0, document.body.scrollHeight);
|
||||
|
||||
playSound();
|
||||
|
||||
@@ -203,6 +261,13 @@ document.addEventListener('DOMContentLoaded', async () => {
|
||||
stillPlayingSound = false;
|
||||
sequenceFinished = false;
|
||||
const message = inputField.value.trim();
|
||||
|
||||
const msgEl = document.createElement('div');
|
||||
msgEl.className = 'message';
|
||||
msgEl.textContent = message;
|
||||
msgEl.style.marginBottom = '10px';
|
||||
messageContainer.appendChild(msgEl);
|
||||
|
||||
if (message && apiEchoUrl) {
|
||||
inputField.value = '';
|
||||
try {
|
||||
@@ -211,6 +276,16 @@ document.addEventListener('DOMContentLoaded', async () => {
|
||||
body: { message, ts: new Date().toISOString() },
|
||||
});
|
||||
console.log('[API][game1] message sent →', response);
|
||||
if (response && response.result && Array.isArray(response.result.result)) {
|
||||
response.result.result.forEach(text => {
|
||||
const msgEl = document.createElement('div');
|
||||
msgEl.className = 'message';
|
||||
msgEl.textContent = text;
|
||||
msgEl.style.marginBottom = '10px';
|
||||
messageContainer.appendChild(msgEl);
|
||||
});
|
||||
window.scrollTo(0, document.body.scrollHeight);
|
||||
}
|
||||
} catch (err) {
|
||||
console.error('[API][game1] Failed to send message:', err);
|
||||
}
|
||||
|
||||
@@ -29,8 +29,11 @@ body {
|
||||
|
||||
div#game-timer {
|
||||
position: fixed;
|
||||
top: 20px;
|
||||
left: 20px;
|
||||
top: 0;
|
||||
left: 0;
|
||||
width: 100%;
|
||||
padding: 20px;
|
||||
background-color: #000;
|
||||
color: #F00;
|
||||
font-size: 28px;
|
||||
z-index: 100;
|
||||
@@ -38,7 +41,7 @@ div#game-timer {
|
||||
|
||||
div#message-container {
|
||||
padding: 20px;
|
||||
padding-top: 60px; /* Space for fixed timer */
|
||||
padding-top: 80px; /* Space for fixed timer */
|
||||
display: flex;
|
||||
flex-direction: column;
|
||||
justify-content: flex-end;
|
||||
@@ -49,6 +52,7 @@ div#message-container {
|
||||
|
||||
div.message {
|
||||
color: #C0C0C0;
|
||||
white-space: pre-wrap;
|
||||
}
|
||||
|
||||
div#input {
|
||||
|
||||
@@ -7,11 +7,11 @@ services:
|
||||
environment:
|
||||
# Uncomment the following line to disable HTTPS,
|
||||
#SERVER_NAME: ':80'
|
||||
MERCURE_PUBLISHER_JWT_KEY: '!ChangeThisMercureHubJWTSecretKey!'
|
||||
MERCURE_SUBSCRIBER_JWT_KEY: '!ChangeThisMercureHubJWTSecretKey!'
|
||||
MERCURE_PUBLISHER_JWT_KEY: ${MERCURE_JWT_SECRET}
|
||||
MERCURE_SUBSCRIBER_JWT_KEY: ${MERCURE_JWT_SECRET}
|
||||
# Set the URL of your Symfony project (without trailing slash!) as value of the cors_origins directive
|
||||
MERCURE_EXTRA_DIRECTIVES: |
|
||||
cors_origins http://127.0.0.1:8000
|
||||
cors_origins ${MERCURE_CORS_ALLOWED_ORIGINS:-http://localhost:8080}
|
||||
# Comment the following line to disable the development mode
|
||||
command: /usr/bin/caddy run --config /etc/caddy/dev.Caddyfile
|
||||
healthcheck:
|
||||
|
||||
@@ -1,6 +1,14 @@
|
||||
doctrine:
|
||||
dbal:
|
||||
url: '%env(resolve:DATABASE_URL)%'
|
||||
# url: '%env(resolve:DATABASE_URL)%'
|
||||
driver: '%env(DB_DRIVER)%'
|
||||
server_version: '%env(DB_SERVER_VERSION)%'
|
||||
host: '%env(DB_HOST)%'
|
||||
port: '%env(DB_PORT)%'
|
||||
user: '%env(DB_USER)%'
|
||||
password: '%env(DB_PASSWORD)%'
|
||||
dbname: '%env(DB_NAME)%'
|
||||
charset: '%env(DB_CHARSET)%'
|
||||
|
||||
# IMPORTANT: You MUST configure your server version,
|
||||
# either here or in the DATABASE_URL env var (see .env file)
|
||||
|
||||
@@ -3,4 +3,6 @@ mercure:
|
||||
default:
|
||||
url: '%env(MERCURE_URL)%'
|
||||
public_url: '%env(MERCURE_PUBLIC_URL)%'
|
||||
jwt: '%env(MERCURE_JWT_SECRET)%'
|
||||
jwt:
|
||||
secret: '%env(MERCURE_JWT_SECRET)%'
|
||||
publish: ['*']
|
||||
|
||||
@@ -16,5 +16,9 @@ services:
|
||||
App\:
|
||||
resource: '../src/'
|
||||
|
||||
App\Game\Service\GameResponseService:
|
||||
arguments:
|
||||
$projectDir: '%kernel.project_dir%'
|
||||
|
||||
# add more service definitions when explicit configuration is needed
|
||||
# please note that last definitions always *replace* previous ones
|
||||
|
||||
@@ -63,12 +63,12 @@ services:
|
||||
container_name: escapepage-mercure
|
||||
environment:
|
||||
SERVER_NAME: ":80"
|
||||
MERCURE_PUBLISHER_JWT_KEY: ${MERCURE_JWT_SECRET:-!ChangeThisMercureJWT!}
|
||||
MERCURE_SUBSCRIBER_JWT_KEY: ${MERCURE_JWT_SECRET:-!ChangeThisMercureJWT!}
|
||||
MERCURE_CORS_ALLOWED_ORIGINS: http://localhost:8080
|
||||
MERCURE_PUBLISH_ALLOWED_ORIGINS: http://localhost:8080
|
||||
MERCURE_PUBLISHER_JWT_KEY: ${MERCURE_JWT_SECRET}
|
||||
MERCURE_SUBSCRIBER_JWT_KEY: ${MERCURE_JWT_SECRET}
|
||||
MERCURE_CORS_ALLOWED_ORIGINS: ${MERCURE_CORS_ALLOWED_ORIGINS:-http://localhost:8080}
|
||||
MERCURE_PUBLISH_ALLOWED_ORIGINS: ${MERCURE_CORS_ALLOWED_ORIGINS:-http://localhost:8080}
|
||||
MERCURE_EXTRA_DIRECTIVES: |
|
||||
cors_origins http://localhost:8080
|
||||
cors_origins ${MERCURE_CORS_ALLOWED_ORIGINS:-http://localhost:8080}
|
||||
# Allow anonymous subscribers in dev only
|
||||
anonymous
|
||||
ports:
|
||||
@@ -82,9 +82,9 @@ services:
|
||||
image: mysql:8.0
|
||||
container_name: escapepage-db
|
||||
environment:
|
||||
MYSQL_DATABASE: ${MYSQL_DATABASE:-app}
|
||||
MYSQL_USER: ${MYSQL_USER:-app}
|
||||
MYSQL_PASSWORD: ${MYSQL_PASSWORD:-!ChangeMe!}
|
||||
MYSQL_DATABASE: ${DB_NAME:-app}
|
||||
MYSQL_USER: ${DB_USER:-app}
|
||||
MYSQL_PASSWORD: ${DB_PASSWORD:-!ChangeMe!}
|
||||
MYSQL_ROOT_PASSWORD: ${MYSQL_ROOT_PASSWORD:-root}
|
||||
healthcheck:
|
||||
test: ["CMD", "mysqladmin", "ping", "-h", "127.0.0.1", "-uroot", "-p${MYSQL_ROOT_PASSWORD:-root}"]
|
||||
|
||||
63
src/Game/Controller/GameAdminController.php
Normal file
63
src/Game/Controller/GameAdminController.php
Normal file
@@ -0,0 +1,63 @@
|
||||
<?php
|
||||
declare(strict_types=1);
|
||||
|
||||
namespace App\Game\Controller;
|
||||
|
||||
use App\Game\Entity\Session;
|
||||
use App\Game\Repository\SessionRepository;
|
||||
use App\Tech\Repository\UserRepository;
|
||||
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
|
||||
use Symfony\Component\HttpFoundation\Response;
|
||||
use Symfony\Component\Routing\Annotation\Route;
|
||||
use Symfony\Component\Security\Http\Attribute\IsGranted;
|
||||
use Symfony\Component\DependencyInjection\Attribute\Autowire;
|
||||
|
||||
#[Route('/admin')]
|
||||
#[IsGranted('ROLE_ADMIN')]
|
||||
final class GameAdminController extends AbstractController
|
||||
{
|
||||
public function __construct(
|
||||
#[Autowire('%kernel.project_dir%')]
|
||||
private string $projectDir
|
||||
) {
|
||||
}
|
||||
|
||||
#[Route('', name: 'game_admin_dashboard', methods: ['GET'])]
|
||||
public function index(
|
||||
UserRepository $userRepository,
|
||||
SessionRepository $sessionRepository
|
||||
): Response {
|
||||
$players = $userRepository->findByRole('ROLE_PLAYER');
|
||||
$sessions = $sessionRepository->findAll();
|
||||
|
||||
return $this->render('game/admin/index.html.twig', [
|
||||
'players' => $players,
|
||||
'sessions' => $sessions,
|
||||
]);
|
||||
}
|
||||
|
||||
#[Route('/session/{session}', name: 'game_admin_view_session', methods: ['GET'])]
|
||||
public function viewSession(Session $session): Response
|
||||
{
|
||||
$playersLogs = [];
|
||||
foreach ($session->getPlayers() as $player) {
|
||||
$username = $player->getUser()->getUsername();
|
||||
$logFile = $this->projectDir . '/var/log/sessions/' . $session->getId() . '/' . $username . '.txt';
|
||||
|
||||
$logs = '';
|
||||
if (file_exists($logFile)) {
|
||||
$logs = file_get_contents($logFile);
|
||||
}
|
||||
|
||||
$playersLogs[] = [
|
||||
'username' => $username,
|
||||
'logs' => $logs,
|
||||
];
|
||||
}
|
||||
|
||||
return $this->render('game/admin/session.html.twig', [
|
||||
'session' => $session,
|
||||
'playersLogs' => $playersLogs,
|
||||
]);
|
||||
}
|
||||
}
|
||||
@@ -3,7 +3,10 @@ declare(strict_types=1);
|
||||
|
||||
namespace App\Game\Controller;
|
||||
|
||||
use App\Game\Entity\Session;
|
||||
use App\Game\Enum\SessionStatus;
|
||||
use App\Game\Service\GameResponseService;
|
||||
use Doctrine\ORM\EntityManagerInterface;
|
||||
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
|
||||
use Symfony\Component\HttpFoundation\JsonResponse;
|
||||
use Symfony\Component\HttpFoundation\Request;
|
||||
@@ -15,7 +18,9 @@ final class GameApiController extends AbstractController
|
||||
{
|
||||
|
||||
public function __construct(
|
||||
protected GameResponseService $gameResponseService) {
|
||||
protected GameResponseService $gameResponseService,
|
||||
private EntityManagerInterface $entityManager
|
||||
) {
|
||||
|
||||
}
|
||||
|
||||
@@ -29,6 +34,30 @@ final class GameApiController extends AbstractController
|
||||
]);
|
||||
}
|
||||
|
||||
#[Route('/check-finished/{session}', name: 'check_finished', methods: ['POST'])]
|
||||
public function checkFinished(Session $session): JsonResponse
|
||||
{
|
||||
$now = (new \DateTime())->getTimestamp();
|
||||
$isFinished = false;
|
||||
|
||||
if ($session->getStatus() === SessionStatus::PLAYING) {
|
||||
if ($session->getTimer() !== null && $now >= $session->getTimer()) {
|
||||
$session->setStatus(SessionStatus::LOST);
|
||||
$this->entityManager->persist($session);
|
||||
$this->entityManager->flush();
|
||||
$isFinished = true;
|
||||
}
|
||||
} elseif ($session->getStatus() === SessionStatus::LOST || $session->getStatus() === SessionStatus::WON) {
|
||||
$isFinished = true;
|
||||
}
|
||||
|
||||
return $this->json([
|
||||
'ok' => true,
|
||||
'finished' => $isFinished,
|
||||
'status' => $session->getStatus()->value,
|
||||
]);
|
||||
}
|
||||
|
||||
#[Route('/message', name: 'message', methods: ['POST'])]
|
||||
public function message(Request $request): JsonResponse
|
||||
{
|
||||
|
||||
@@ -3,10 +3,17 @@ declare(strict_types=1);
|
||||
|
||||
namespace App\Game\Controller;
|
||||
|
||||
use App\Game\Entity\Player;
|
||||
use App\Game\Entity\Session;
|
||||
use App\Game\Entity\SessionSetting;
|
||||
use App\Game\Enum\SessionSettingType;
|
||||
use App\Game\Enum\SessionStatus;
|
||||
use App\Game\Repository\GameRepository;
|
||||
use App\Game\Repository\PlayerRepository;
|
||||
use App\Game\Repository\SessionRepository;
|
||||
use App\Game\Service\GameDashboardService;
|
||||
use App\Tech\Entity\User;
|
||||
use App\Game\Service\PlayerService;
|
||||
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
|
||||
use Symfony\Bundle\SecurityBundle\Security;
|
||||
use Symfony\Component\HttpFoundation\Request;
|
||||
@@ -14,9 +21,17 @@ use Symfony\Component\HttpFoundation\Response;
|
||||
use Symfony\Component\Routing\Annotation\Route;
|
||||
use Symfony\Component\Security\Http\Attribute\IsGranted;
|
||||
use Symfony\Component\ExpressionLanguage\Expression;
|
||||
use Symfony\Component\DependencyInjection\Attribute\Autowire;
|
||||
|
||||
final class GameController extends AbstractController
|
||||
{
|
||||
public function __construct(
|
||||
#[Autowire('%env(MERCURE_PUBLIC_URL)%')]
|
||||
private string $mercurePublicUrl,
|
||||
private \Doctrine\ORM\EntityManagerInterface $entityManager
|
||||
) {
|
||||
}
|
||||
|
||||
#[Route(path: '', name: 'game_dashboard', methods: ['GET', 'POST'])]
|
||||
#[IsGranted(new Expression("is_granted('ROLE_PLAYER') or is_granted('ROLE_ADMIN')"))]
|
||||
public function dashboard(
|
||||
@@ -70,6 +85,17 @@ final class GameController extends AbstractController
|
||||
$this->addFlash('error', 'Could not leave session (game might have started).');
|
||||
}
|
||||
}
|
||||
} elseif ($request->request->has('start_session')) {
|
||||
$sessionId = $request->request->get('session_id');
|
||||
$session = $sessionRepository->find($sessionId);
|
||||
|
||||
if ($session) {
|
||||
if ($dashboardService->startSession($session)) {
|
||||
$this->addFlash('success', 'Session started! Screens have been assigned.');
|
||||
} else {
|
||||
$this->addFlash('error', 'Could not start session. Make sure all players have joined.');
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return $this->redirectToRoute('game_dashboard');
|
||||
@@ -81,12 +107,125 @@ final class GameController extends AbstractController
|
||||
]);
|
||||
}
|
||||
|
||||
#[Route(path: '/{session}', name: 'game')]
|
||||
#[Route(path: '/{session}', name: 'game', methods: ['GET', 'POST'])]
|
||||
#[IsGranted(new Expression("is_granted('ROLE_PLAYER') or is_granted('ROLE_ADMIN')"))]
|
||||
#[IsGranted('SESSION_VIEW', subject: 'session')]
|
||||
public function index(
|
||||
Session $session): Response
|
||||
Session $session,
|
||||
Request $request,
|
||||
Security $security,
|
||||
PlayerRepository $playerRepository,
|
||||
GameDashboardService $dashboardService
|
||||
): Response
|
||||
{
|
||||
return $this->render('game/index.html.twig', ['session' => $session]);
|
||||
$user = $security->getUser();
|
||||
if (!$user instanceof User) {
|
||||
throw $this->createAccessDeniedException();
|
||||
}
|
||||
|
||||
$player = $playerRepository->findOneBy(['session' => $session, 'user' => $user]);
|
||||
|
||||
if ($request->isMethod('POST') && $request->request->has('toggle_ready')) {
|
||||
$dashboardService->toggleReady($session, $user);
|
||||
return $this->redirectToRoute('game', ['session' => $session->getId()]);
|
||||
}
|
||||
|
||||
// Periodically check readiness timeout
|
||||
$dashboardService->checkAllPlayersReady($session);
|
||||
|
||||
if ($session->getStatus() === SessionStatus::READY) {
|
||||
$isReady = false;
|
||||
$readyAt = null;
|
||||
if ($player) {
|
||||
$settingName = SessionSettingType::tryFrom('ReadyAtForPlayer' . $player->getScreen());
|
||||
if ($settingName) {
|
||||
$setting = $session->getSettings()->filter(fn(SessionSetting $s) => $s->getName() === $settingName && $s->getPlayer() === $player)->first();
|
||||
if ($setting) {
|
||||
$isReady = true;
|
||||
$readyAt = (int)$setting->getValue();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return $this->render('game/waiting.html.twig', [
|
||||
'session' => $session,
|
||||
'isReady' => $isReady,
|
||||
'readyAt' => $readyAt,
|
||||
'mercure_public_url' => $this->mercurePublicUrl,
|
||||
]);
|
||||
}
|
||||
|
||||
$screen = $player ? $player->getScreen() : 0;
|
||||
$session_id = $session->getId();
|
||||
|
||||
return $this->render('game/index.html.twig', [
|
||||
'session' => $session,
|
||||
'screen' => $screen,
|
||||
'session_id' => $session_id,
|
||||
]);
|
||||
}
|
||||
|
||||
#[Route(path: '/lost/{session}', name: 'game_lost', methods: ['GET', 'POST'])]
|
||||
#[IsGranted(new Expression("is_granted('ROLE_PLAYER') or is_granted('ROLE_ADMIN')"))]
|
||||
#[IsGranted('SESSION_VIEW', subject: 'session')]
|
||||
public function lost(
|
||||
Session $session,
|
||||
Request $request,
|
||||
Security $security,
|
||||
PlayerService $playerService,
|
||||
GameDashboardService $dashboardService
|
||||
): Response {
|
||||
/** @var User $user */
|
||||
$user = $security->getUser();
|
||||
$player = $playerService->GetCurrentlyActiveAsPlayer($user);
|
||||
|
||||
if ($request->isMethod('POST')) {
|
||||
$difficulty = $request->request->get('difficulty');
|
||||
$entertaining = $request->request->get('entertaining');
|
||||
$theme = $request->request->get('theme');
|
||||
$feedback = $request->request->get('feedback');
|
||||
|
||||
// Save feedback
|
||||
if ($player) {
|
||||
$this->saveFeedback($session, $player, $difficulty, $entertaining, $theme, $feedback);
|
||||
$this->addFlash('success', 'Thank you for your feedback!');
|
||||
return $this->redirectToRoute('game_dashboard');
|
||||
}
|
||||
}
|
||||
|
||||
return $this->render('game/lost.html.twig', [
|
||||
'session' => $session,
|
||||
]);
|
||||
}
|
||||
|
||||
private function saveFeedback(Session $session, Player $player, $difficulty, $entertaining, $theme, $feedback): void
|
||||
{
|
||||
$settings = [
|
||||
SessionSettingType::FEEDBACK_DIFFICULTY,
|
||||
SessionSettingType::FEEDBACK_ENTERTAINING,
|
||||
SessionSettingType::FEEDBACK_THEME,
|
||||
SessionSettingType::FEEDBACK_TEXT,
|
||||
];
|
||||
|
||||
$values = [
|
||||
$difficulty,
|
||||
$entertaining,
|
||||
$theme,
|
||||
$feedback,
|
||||
];
|
||||
|
||||
foreach ($settings as $index => $type) {
|
||||
$value = $values[$index];
|
||||
if ($value === null || $value === '') continue;
|
||||
|
||||
$setting = new SessionSetting();
|
||||
$setting->setSession($session);
|
||||
$setting->setPlayer($player);
|
||||
$setting->setName($type);
|
||||
$setting->setValue((string)$value);
|
||||
$this->entityManager->persist($setting);
|
||||
}
|
||||
|
||||
$this->entityManager->flush();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -23,7 +23,7 @@ class Player
|
||||
#[ORM\JoinColumn(nullable: false)]
|
||||
private ?User $user = null;
|
||||
|
||||
#[ORM\Column]
|
||||
#[ORM\Column(nullable: true)]
|
||||
private ?int $screen = null;
|
||||
|
||||
public function getId(): ?int
|
||||
@@ -60,7 +60,7 @@ class Player
|
||||
return $this->screen;
|
||||
}
|
||||
|
||||
public function setScreen(int $screen): static
|
||||
public function setScreen(?int $screen): static
|
||||
{
|
||||
$this->screen = $screen;
|
||||
|
||||
|
||||
@@ -7,18 +7,71 @@ enum SessionSettingType: string
|
||||
case PWD_FOR_PLAYER1 = 'PwdForPlayer1';
|
||||
case PWD_FOR_PLAYER2 = 'PwdForPlayer2';
|
||||
case PWD_FOR_PLAYER3 = 'PwdForPlayer3';
|
||||
case PWD_FOR_PLAYER4 = 'PwdForPlayer4';
|
||||
case PWD_FOR_PLAYER5 = 'PwdForPlayer5';
|
||||
case PWD_FOR_PLAYER6 = 'PwdForPlayer6';
|
||||
case PWD_FOR_PLAYER7 = 'PwdForPlayer7';
|
||||
case PWD_FOR_PLAYER8 = 'PwdForPlayer8';
|
||||
case PWD_FOR_PLAYER9 = 'PwdForPlayer9';
|
||||
case PWD_FOR_PLAYER10 = 'PwdForPlayer10';
|
||||
case RIGHTS_FOR_PLAYER1 = 'RightsForPlayer1';
|
||||
case RIGHTS_FOR_PLAYER2 = 'RightsForPlayer2';
|
||||
case RIGHTS_FOR_PLAYER3 = 'RightsForPlayer3';
|
||||
case RIGHTS_FOR_PLAYER4 = 'RightsForPlayer4';
|
||||
case RIGHTS_FOR_PLAYER5 = 'RightsForPlayer5';
|
||||
case RIGHTS_FOR_PLAYER6 = 'RightsForPlayer6';
|
||||
case RIGHTS_FOR_PLAYER7 = 'RightsForPlayer7';
|
||||
case RIGHTS_FOR_PLAYER8 = 'RightsForPlayer8';
|
||||
case RIGHTS_FOR_PLAYER9 = 'RightsForPlayer9';
|
||||
case RIGHTS_FOR_PLAYER10 = 'RightsForPlayer10';
|
||||
case INVITE_CODE = 'InviteCode';
|
||||
case SET_OF_DELETED_FILES = 'SetOfDeletedFiles';
|
||||
case CHAT_TRACKING_FOR_PLAYER1 = 'ChatTrackingForPlayer1';
|
||||
case CHAT_TRACKING_FOR_PLAYER2 = 'ChatTrackingForPlayer2';
|
||||
case CHAT_TRACKING_FOR_PLAYER3 = 'ChatTrackingForPlayer3';
|
||||
case CHAT_TRACKING_FOR_PLAYER4 = 'ChatTrackingForPlayer4';
|
||||
case CHAT_TRACKING_FOR_PLAYER5 = 'ChatTrackingForPlayer5';
|
||||
case CHAT_TRACKING_FOR_PLAYER6 = 'ChatTrackingForPlayer6';
|
||||
case CHAT_TRACKING_FOR_PLAYER7 = 'ChatTrackingForPlayer7';
|
||||
case CHAT_TRACKING_FOR_PLAYER8 = 'ChatTrackingForPlayer8';
|
||||
case CHAT_TRACKING_FOR_PLAYER9 = 'ChatTrackingForPlayer9';
|
||||
case CHAT_TRACKING_FOR_PLAYER10 = 'ChatTrackingForPlayer10';
|
||||
case VERIFY_CODES_FOR_PLAYER1 = 'VerifyCodesForPlayer1';
|
||||
case VERIFY_CODES_FOR_PLAYER2 = 'VerifyCodesForPlayer2';
|
||||
case VERIFY_CODES_FOR_PLAYER3 = 'VerifyCodesForPlayer3';
|
||||
case VERIFY_CODES_FOR_PLAYER4 = 'VerifyCodesForPlayer4';
|
||||
case VERIFY_CODES_FOR_PLAYER5 = 'VerifyCodesForPlayer5';
|
||||
case VERIFY_CODES_FOR_PLAYER6 = 'VerifyCodesForPlayer6';
|
||||
case VERIFY_CODES_FOR_PLAYER7 = 'VerifyCodesForPlayer7';
|
||||
case VERIFY_CODES_FOR_PLAYER8 = 'VerifyCodesForPlayer8';
|
||||
case VERIFY_CODES_FOR_PLAYER9 = 'VerifyCodesForPlayer9';
|
||||
case VERIFY_CODES_FOR_PLAYER10 = 'VerifyCodesForPlayer10';
|
||||
case VERIFICATION_PROGRESS_FOR_PLAYER1 = 'VerificationProgressForPlayer1';
|
||||
case VERIFICATION_PROGRESS_FOR_PLAYER2 = 'VerificationProgressForPlayer2';
|
||||
case VERIFICATION_PROGRESS_FOR_PLAYER3 = 'VerificationProgressForPlayer3';
|
||||
case VERIFICATION_PROGRESS_FOR_PLAYER4 = 'VerificationProgressForPlayer4';
|
||||
case VERIFICATION_PROGRESS_FOR_PLAYER5 = 'VerificationProgressForPlayer5';
|
||||
case VERIFICATION_PROGRESS_FOR_PLAYER6 = 'VerificationProgressForPlayer6';
|
||||
case VERIFICATION_PROGRESS_FOR_PLAYER7 = 'VerificationProgressForPlayer7';
|
||||
case VERIFICATION_PROGRESS_FOR_PLAYER8 = 'VerificationProgressForPlayer8';
|
||||
case VERIFICATION_PROGRESS_FOR_PLAYER9 = 'VerificationProgressForPlayer9';
|
||||
case VERIFICATION_PROGRESS_FOR_PLAYER10 = 'VerificationProgressForPlayer10';
|
||||
case EVERYONE_VERIFIED = 'EveryoneVerified';
|
||||
case SPECIAL_REPORT_CODE_DOYLE = 'SpecialReportCodeDoyle';
|
||||
case SPECIAL_REPORT_CODE_VEGA = 'SpecialReportCodeVega';
|
||||
case SPECIAL_REPORT_CODE_LENNOX = 'SpecialReportCodeLennox';
|
||||
case READY_AT_FOR_PLAYER1 = 'ReadyAtForPlayer1';
|
||||
case READY_AT_FOR_PLAYER2 = 'ReadyAtForPlayer2';
|
||||
case READY_AT_FOR_PLAYER3 = 'ReadyAtForPlayer3';
|
||||
case READY_AT_FOR_PLAYER4 = 'ReadyAtForPlayer4';
|
||||
case READY_AT_FOR_PLAYER5 = 'ReadyAtForPlayer5';
|
||||
case READY_AT_FOR_PLAYER6 = 'ReadyAtForPlayer6';
|
||||
case READY_AT_FOR_PLAYER7 = 'ReadyAtForPlayer7';
|
||||
case READY_AT_FOR_PLAYER8 = 'ReadyAtForPlayer8';
|
||||
case READY_AT_FOR_PLAYER9 = 'ReadyAtForPlayer9';
|
||||
case READY_AT_FOR_PLAYER10 = 'ReadyAtForPlayer10';
|
||||
case FEEDBACK_DIFFICULTY = 'FeedbackDifficulty';
|
||||
case FEEDBACK_ENTERTAINING = 'FeedbackEntertaining';
|
||||
case FEEDBACK_THEME = 'FeedbackTheme';
|
||||
case FEEDBACK_TEXT = 'FeedbackText';
|
||||
}
|
||||
|
||||
@@ -15,6 +15,9 @@ use App\Game\Repository\SessionRepository;
|
||||
use App\Tech\Entity\User;
|
||||
use Doctrine\ORM\EntityManagerInterface;
|
||||
use Symfony\Component\Security\Core\User\UserInterface;
|
||||
use Symfony\Component\Mercure\HubInterface;
|
||||
use Symfony\Component\Mercure\Update;
|
||||
use Symfony\Component\DependencyInjection\Attribute\Autowire;
|
||||
|
||||
final class GameDashboardService
|
||||
{
|
||||
@@ -22,6 +25,9 @@ final class GameDashboardService
|
||||
private readonly GameRepository $gameRepository,
|
||||
private readonly SessionRepository $sessionRepository,
|
||||
private readonly EntityManagerInterface $entityManager,
|
||||
private readonly HubInterface $hub,
|
||||
#[Autowire('%env(MERCURE_TOPIC_BASE)%')]
|
||||
private readonly string $mercureTopicBase,
|
||||
) {
|
||||
}
|
||||
|
||||
@@ -66,16 +72,17 @@ final class GameDashboardService
|
||||
|
||||
$player = new Player();
|
||||
$player->setUser($user);
|
||||
$player->setSession($session);
|
||||
$player->setScreen(1);
|
||||
$session->addPlayer($player);
|
||||
|
||||
$this->entityManager->persist($session);
|
||||
$this->entityManager->persist($player);
|
||||
|
||||
$this->initializePlayerSettings($player);
|
||||
|
||||
$this->entityManager->flush();
|
||||
|
||||
if (count($session->getPlayers()) === $session->getGame()->getNumberOfPlayers()) {
|
||||
$this->startSession($session);
|
||||
}
|
||||
|
||||
return $session;
|
||||
}
|
||||
|
||||
@@ -104,20 +111,22 @@ final class GameDashboardService
|
||||
}
|
||||
|
||||
$playerCount = count($session->getPlayers());
|
||||
if ($playerCount >= 3) {
|
||||
if ($playerCount >= $session->getGame()->getNumberOfPlayers()) {
|
||||
return false; // Session full
|
||||
}
|
||||
|
||||
$player = new Player();
|
||||
$player->setUser($user);
|
||||
$player->setSession($session);
|
||||
$player->setScreen($playerCount + 1);
|
||||
$session->addPlayer($player);
|
||||
|
||||
$this->entityManager->persist($player);
|
||||
$this->initializePlayerSettings($player);
|
||||
|
||||
$this->entityManager->flush();
|
||||
|
||||
if (count($session->getPlayers()) === $session->getGame()->getNumberOfPlayers()) {
|
||||
$this->startSession($session);
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
@@ -127,7 +136,7 @@ final class GameDashboardService
|
||||
return false;
|
||||
}
|
||||
|
||||
if ($session->getStatus() !== SessionStatus::CREATED || $session->getTimer() > 0) {
|
||||
if (!in_array($session->getStatus(), [SessionStatus::CREATED, SessionStatus::READY]) || $session->getTimer() > 0) {
|
||||
return false;
|
||||
}
|
||||
|
||||
@@ -143,6 +152,14 @@ final class GameDashboardService
|
||||
return false;
|
||||
}
|
||||
|
||||
if ($session->getStatus() === SessionStatus::READY) {
|
||||
$session->setStatus(SessionStatus::CREATED);
|
||||
// Clear assignments for all remaining players since the game needs to be "started" again
|
||||
foreach ($session->getPlayers() as $player) {
|
||||
$player->setScreen(null);
|
||||
}
|
||||
}
|
||||
|
||||
// Remove player specific settings (like rights)
|
||||
foreach ($session->getSettings() as $setting) {
|
||||
if ($setting->getPlayer() === $playerToDelete) {
|
||||
@@ -170,12 +187,7 @@ final class GameDashboardService
|
||||
private function initializePlayerSettings(Player $player): void
|
||||
{
|
||||
$screen = $player->getScreen();
|
||||
$rightsSettingName = match ($screen) {
|
||||
1 => SessionSettingType::RIGHTS_FOR_PLAYER1,
|
||||
2 => SessionSettingType::RIGHTS_FOR_PLAYER2,
|
||||
3 => SessionSettingType::RIGHTS_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
$rightsSettingName = SessionSettingType::tryFrom('RightsForPlayer' . $screen);
|
||||
|
||||
if ($rightsSettingName) {
|
||||
$setting = new SessionSetting();
|
||||
@@ -186,28 +198,18 @@ final class GameDashboardService
|
||||
$this->entityManager->persist($setting);
|
||||
}
|
||||
|
||||
$pwdSettingName = match ($screen) {
|
||||
1 => SessionSettingType::PWD_FOR_PLAYER1,
|
||||
2 => SessionSettingType::PWD_FOR_PLAYER2,
|
||||
3 => SessionSettingType::PWD_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
$pwdSettingName = SessionSettingType::tryFrom('PwdForPlayer' . $screen);
|
||||
|
||||
if ($pwdSettingName) {
|
||||
$setting = new SessionSetting();
|
||||
$setting->setSession($player->getSession());
|
||||
$setting->setPlayer($player);
|
||||
$setting->setName($pwdSettingName);
|
||||
$setting->setValue('home/' . $player->getUser()->getUserIdentifier());
|
||||
$setting->setValue('var/home/' . $player->getUser()->getUsername());
|
||||
$this->entityManager->persist($setting);
|
||||
}
|
||||
|
||||
$chatTrackingSettingName = match ($screen) {
|
||||
1 => SessionSettingType::CHAT_TRACKING_FOR_PLAYER1,
|
||||
2 => SessionSettingType::CHAT_TRACKING_FOR_PLAYER2,
|
||||
3 => SessionSettingType::CHAT_TRACKING_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
$chatTrackingSettingName = SessionSettingType::tryFrom('ChatTrackingForPlayer' . $screen);
|
||||
|
||||
if ($chatTrackingSettingName) {
|
||||
$setting = new SessionSetting();
|
||||
@@ -218,16 +220,12 @@ final class GameDashboardService
|
||||
$this->entityManager->persist($setting);
|
||||
}
|
||||
|
||||
$verifyCodesSettingName = match ($screen) {
|
||||
1 => SessionSettingType::VERIFY_CODES_FOR_PLAYER1,
|
||||
2 => SessionSettingType::VERIFY_CODES_FOR_PLAYER2,
|
||||
3 => SessionSettingType::VERIFY_CODES_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
$verifyCodesSettingName = SessionSettingType::tryFrom('VerifyCodesForPlayer' . $screen);
|
||||
|
||||
if ($verifyCodesSettingName) {
|
||||
$codes = [];
|
||||
for ($i = 1; $i <= 3; $i++) {
|
||||
$numPlayers = $player->getSession()->getGame()->getNumberOfPlayers();
|
||||
for ($i = 1; $i <= $numPlayers; $i++) {
|
||||
if ($i !== $screen) {
|
||||
$codes[$i] = bin2hex(random_bytes(3)); // 6 characters code
|
||||
}
|
||||
@@ -241,12 +239,7 @@ final class GameDashboardService
|
||||
$this->entityManager->persist($setting);
|
||||
}
|
||||
|
||||
$verificationProgressSettingName = match ($screen) {
|
||||
1 => SessionSettingType::VERIFICATION_PROGRESS_FOR_PLAYER1,
|
||||
2 => SessionSettingType::VERIFICATION_PROGRESS_FOR_PLAYER2,
|
||||
3 => SessionSettingType::VERIFICATION_PROGRESS_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
$verificationProgressSettingName = SessionSettingType::tryFrom('VerificationProgressForPlayer' . $screen);
|
||||
|
||||
if ($verificationProgressSettingName) {
|
||||
$setting = new SessionSetting();
|
||||
@@ -258,6 +251,179 @@ final class GameDashboardService
|
||||
}
|
||||
}
|
||||
|
||||
public function startSession(Session $session): bool
|
||||
{
|
||||
if ($session->getStatus() !== SessionStatus::CREATED) {
|
||||
return false;
|
||||
}
|
||||
|
||||
$players = $session->getPlayers()->toArray();
|
||||
if (count($players) < $session->getGame()->getNumberOfPlayers()) {
|
||||
return false;
|
||||
}
|
||||
|
||||
// Clean up any existing assignments (e.g. if we reverted from READY to CREATED)
|
||||
foreach ($session->getSettings() as $setting) {
|
||||
if ($setting->getPlayer() !== null) {
|
||||
$session->removeSetting($setting);
|
||||
$this->entityManager->remove($setting);
|
||||
}
|
||||
}
|
||||
|
||||
// Shuffle players to assign random screens
|
||||
shuffle($players);
|
||||
|
||||
foreach ($players as $index => $player) {
|
||||
$screen = $index + 1;
|
||||
$player->setScreen($screen);
|
||||
$this->initializePlayerSettings($player);
|
||||
$this->entityManager->persist($player);
|
||||
}
|
||||
|
||||
$session->setStatus(SessionStatus::READY);
|
||||
$this->entityManager->persist($session);
|
||||
$this->entityManager->flush();
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
public function toggleReady(Session $session, User $user): bool
|
||||
{
|
||||
if ($session->getStatus() !== SessionStatus::READY) {
|
||||
return false;
|
||||
}
|
||||
|
||||
$player = null;
|
||||
foreach ($session->getPlayers() as $p) {
|
||||
if ($p->getUser() === $user) {
|
||||
$player = $p;
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
if (!$player) {
|
||||
return false;
|
||||
}
|
||||
|
||||
$settingName = SessionSettingType::tryFrom('ReadyAtForPlayer' . $player->getScreen());
|
||||
if (!$settingName) {
|
||||
return false;
|
||||
}
|
||||
|
||||
/** @var \App\Game\Repository\SessionSettingRepository $settingRepo */
|
||||
$settingRepo = $this->entityManager->getRepository(SessionSetting::class);
|
||||
$setting = $settingRepo->getSetting($session, $settingName, $player);
|
||||
|
||||
if ($setting) {
|
||||
$session->removeSetting($setting);
|
||||
$this->entityManager->remove($setting);
|
||||
} else {
|
||||
$setting = new SessionSetting();
|
||||
$setting->setSession($session);
|
||||
$setting->setPlayer($player);
|
||||
$setting->setName($settingName);
|
||||
$setting->setValue((string)(new \DateTime())->getTimestamp());
|
||||
$this->entityManager->persist($setting);
|
||||
}
|
||||
|
||||
$this->checkAllPlayersReady($session);
|
||||
$this->entityManager->flush();
|
||||
|
||||
try {
|
||||
$topic = $this->mercureTopicBase . '/game/hub-' . $session->getId();
|
||||
$this->hub->publish(new Update($topic, json_encode(['type' => 'player_ready', 'player' => $player->getScreen(), 'ready' => !$setting])));
|
||||
} catch (\Exception $e) {
|
||||
// Mercure might be down, but we don't want to crash the game
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
public function checkAllPlayersReady(Session $session): void
|
||||
{
|
||||
if ($session->getStatus() !== SessionStatus::READY) {
|
||||
return;
|
||||
}
|
||||
|
||||
$players = $session->getPlayers();
|
||||
$numPlayers = $session->getGame()->getNumberOfPlayers();
|
||||
|
||||
if (count($players) < $numPlayers) {
|
||||
return;
|
||||
}
|
||||
|
||||
$readyPlayersCount = 0;
|
||||
$now = new \DateTime();
|
||||
$anyReset = false;
|
||||
|
||||
/** @var \App\Game\Repository\SessionSettingRepository $settingRepo */
|
||||
$settingRepo = $this->entityManager->getRepository(SessionSetting::class);
|
||||
|
||||
foreach ($players as $player) {
|
||||
$settingName = SessionSettingType::tryFrom('ReadyAtForPlayer' . $player->getScreen());
|
||||
if (!$settingName) {
|
||||
continue;
|
||||
}
|
||||
|
||||
$setting = $settingRepo->getSetting($session, $settingName, $player);
|
||||
if ($setting) {
|
||||
$readyAtTimestamp = (int)$setting->getValue();
|
||||
// Check timeout: 1 minute = 60 seconds
|
||||
if (($now->getTimestamp() - $readyAtTimestamp) > 60) {
|
||||
$session->removeSetting($setting);
|
||||
$this->entityManager->remove($setting);
|
||||
$anyReset = true;
|
||||
} else {
|
||||
$readyPlayersCount++;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if ($anyReset) {
|
||||
$this->entityManager->flush();
|
||||
try {
|
||||
$topic = $this->mercureTopicBase . '/game/hub-' . $session->getId();
|
||||
$this->hub->publish(new Update($topic, json_encode(['type' => 'player_ready'])));
|
||||
} catch (\Exception $e) {
|
||||
// Mercure might be down
|
||||
}
|
||||
}
|
||||
|
||||
if ($readyPlayersCount === $numPlayers) {
|
||||
$session->setStatus(SessionStatus::PLAYING);
|
||||
|
||||
// Set the end timer
|
||||
$game = $session->getGame();
|
||||
/** @var \App\Game\Repository\GameSettingRepository $gameSettingRepo */
|
||||
$gameSettingRepo = $this->entityManager->getRepository(\App\Game\Entity\GameSetting::class);
|
||||
$totalTimeSetting = $gameSettingRepo->getSetting($game, \App\Game\Enum\GameSettingType::TOTAL_TIME);
|
||||
$totalTime = $totalTimeSetting ? (int)$totalTimeSetting->getValue() : 3600; // Default to 60 minutes if not set
|
||||
|
||||
$session->setTimer((new \DateTime())->getTimestamp() + $totalTime);
|
||||
|
||||
$this->entityManager->persist($session);
|
||||
|
||||
// Clean up ready settings
|
||||
foreach ($players as $player) {
|
||||
$settingName = SessionSettingType::tryFrom('ReadyAtForPlayer' . $player->getScreen());
|
||||
if ($settingName) {
|
||||
$setting = $settingRepo->getSetting($session, $settingName, $player);
|
||||
if ($setting) {
|
||||
$session->removeSetting($setting);
|
||||
$this->entityManager->remove($setting);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
try {
|
||||
$topic = $this->mercureTopicBase . '/game/hub-' . $session->getId();
|
||||
$this->hub->publish(new Update($topic, json_encode(['type' => 'all_ready'])));
|
||||
} catch (\Exception $e) {
|
||||
// Mercure might be down, but we don't want to crash the game
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
public function generateInviteCode(Session $session, UserInterface $user, bool $isAdmin): ?string
|
||||
{
|
||||
// Security check: is user part of this session?
|
||||
|
||||
@@ -12,6 +12,7 @@ use Doctrine\ORM\EntityManagerInterface;
|
||||
use Symfony\Bundle\SecurityBundle\Security;
|
||||
use Symfony\Component\Mercure\HubInterface;
|
||||
use Symfony\Component\Mercure\Update;
|
||||
use Symfony\Component\DependencyInjection\Attribute\Autowire;
|
||||
|
||||
class GameResponseService
|
||||
{
|
||||
@@ -21,6 +22,9 @@ class GameResponseService
|
||||
private SessionSettingRepository $sessionSettingRepository,
|
||||
private HubInterface $hub,
|
||||
private EntityManagerInterface $entityManager,
|
||||
private string $projectDir,
|
||||
#[Autowire('%env(MERCURE_TOPIC_BASE)%')]
|
||||
private string $mercureTopicBase,
|
||||
) {
|
||||
}
|
||||
|
||||
@@ -44,7 +48,7 @@ class GameResponseService
|
||||
if(!$player)
|
||||
return ['error' => 'You are not in a game.'];
|
||||
|
||||
// TODO: Here i need to add a message handler to save the message in a big log.
|
||||
$this->logSessionActivity($player, 'PLAYER: ' . $message);
|
||||
|
||||
$data = [];
|
||||
|
||||
@@ -54,17 +58,46 @@ class GameResponseService
|
||||
$data = $this->checkConsoleCommando($message, $player);
|
||||
}
|
||||
|
||||
$responseLog = '';
|
||||
if (isset($data['result']) && is_array($data['result'])) {
|
||||
foreach ($data['result'] as $line) {
|
||||
if (is_array($line)) {
|
||||
$responseLog .= json_encode($line) . "\n";
|
||||
} elseif (is_string($line) || is_numeric($line)) {
|
||||
$responseLog .= (string)$line . "\n";
|
||||
}
|
||||
}
|
||||
} elseif (isset($data['error'])) {
|
||||
$responseLog = 'ERROR: ' . $data['error'];
|
||||
}
|
||||
|
||||
if ($responseLog !== '') {
|
||||
$this->logSessionActivity($player, 'SERVER: ' . trim($responseLog));
|
||||
}
|
||||
|
||||
return $data;
|
||||
}
|
||||
|
||||
private function logSessionActivity(Player $player, string $content): void
|
||||
{
|
||||
$sessionId = $player->getSession()->getId();
|
||||
$username = $player->getUser()->getUsername();
|
||||
$logDir = $this->projectDir . '/var/log/sessions/' . $sessionId;
|
||||
|
||||
if (!is_dir($logDir)) {
|
||||
mkdir($logDir, 0777, true);
|
||||
}
|
||||
|
||||
$logFile = $logDir . '/' . $username . '.txt';
|
||||
$timestamp = date('Y-m-d H:i:s');
|
||||
$logMessage = sprintf("[%s] %s\n", $timestamp, $content);
|
||||
|
||||
file_put_contents($logFile, $logMessage, FILE_APPEND);
|
||||
}
|
||||
|
||||
private function getRechten(Player $player): array
|
||||
{
|
||||
$settingName = match($player->getScreen()) {
|
||||
1 => SessionSettingType::RIGHTS_FOR_PLAYER1,
|
||||
2 => SessionSettingType::RIGHTS_FOR_PLAYER2,
|
||||
3 => SessionSettingType::RIGHTS_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
$settingName = SessionSettingType::tryFrom('RightsForPlayer' . $player->getScreen());
|
||||
|
||||
if (!$settingName) {
|
||||
return [];
|
||||
@@ -138,6 +171,15 @@ class GameResponseService
|
||||
|
||||
$this->playerService->saveCurrentPwdOfPlayer($player, $newLocation);
|
||||
return ['result' => ['Path: ' . $newLocation]];
|
||||
case 'cat':
|
||||
if(!in_array('cat', $rechten))
|
||||
return ['result' => ['Unknown command']];
|
||||
|
||||
$pwd = $this->playerService->getCurrentPwdOfPlayer($player);
|
||||
|
||||
$fileContent = $this->getFileContent($player, $pwd.'/'.$messagePart[1]);
|
||||
|
||||
return ['result' => $fileContent];
|
||||
case 'pwd':
|
||||
if(!in_array('pwd', $rechten))
|
||||
return ['result' => ['Unknown command']];
|
||||
@@ -189,6 +231,7 @@ class GameResponseService
|
||||
$messages[] = ' If you want to send a message specifically to one other agent, use the id of the agent after /chat, like /chat 6 {message}';
|
||||
$messages[] = ' This will send the message only to agent with id 6.';
|
||||
$messages[] = ' USAGE: /chat {message}';
|
||||
$messages[] = ' USAGE: /chat 6 {message}';
|
||||
$messages[] = '';
|
||||
break;
|
||||
case 'help':
|
||||
@@ -268,7 +311,7 @@ class GameResponseService
|
||||
if (isset($messageParts[1]) &&
|
||||
is_numeric($messageParts[1]) &&
|
||||
$messageParts[1] >= 1 &&
|
||||
$messageParts[1] <= 3) {
|
||||
$messageParts[1] <= $player->getSession()->getGame()->getNumberOfPlayers()) {
|
||||
|
||||
$toSingle = true;
|
||||
}
|
||||
@@ -293,8 +336,12 @@ class GameResponseService
|
||||
if(is_null($activeGame))
|
||||
return false;
|
||||
|
||||
$topic = $_ENV['MERCURE_TOPIC_BASE'] . '/game/hub-' . $activeGame;
|
||||
$this->hub->publish(new Update($topic, json_encode([$sendTo, $message])));
|
||||
$topic = $this->mercureTopicBase . '/game/hub-' . $activeGame;
|
||||
try {
|
||||
$this->hub->publish(new Update($topic, json_encode([$sendTo, $message])));
|
||||
} catch (\Exception $e) {
|
||||
// Mercure might be down
|
||||
}
|
||||
|
||||
$this->updateChatTracking($player, (int)$sendTo);
|
||||
|
||||
@@ -308,12 +355,7 @@ class GameResponseService
|
||||
$screen = $player->getScreen();
|
||||
$session = $player->getSession();
|
||||
|
||||
$verifyCodesSettingName = match ($screen) {
|
||||
1 => SessionSettingType::VERIFY_CODES_FOR_PLAYER1,
|
||||
2 => SessionSettingType::VERIFY_CODES_FOR_PLAYER2,
|
||||
3 => SessionSettingType::VERIFY_CODES_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
$verifyCodesSettingName = SessionSettingType::tryFrom('VerifyCodesForPlayer' . $screen);
|
||||
|
||||
if (!$verifyCodesSettingName) {
|
||||
return;
|
||||
@@ -340,10 +382,14 @@ class GameResponseService
|
||||
$this->entityManager->flush();
|
||||
|
||||
// Notify the player that their codes have changed
|
||||
$topic = $_ENV['MERCURE_TOPIC_BASE'] . '/game/hub-' . $session->getId();
|
||||
$topic = $this->mercureTopicBase . '/game/hub-' . $session->getId();
|
||||
$notification = "Security Alert: One of your verify codes was shared and has been regenerated.";
|
||||
// We send it only to this player (screen)
|
||||
$this->hub->publish(new Update($topic, json_encode([$screen, $notification])));
|
||||
try {
|
||||
$this->hub->publish(new Update($topic, json_encode([$screen, $notification])));
|
||||
} catch (\Exception $e) {
|
||||
// Mercure might be down
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -353,12 +399,7 @@ class GameResponseService
|
||||
if(in_array('verify', $rights))
|
||||
return;
|
||||
|
||||
$trackingSettingName = match ($player->getScreen()) {
|
||||
1 => SessionSettingType::CHAT_TRACKING_FOR_PLAYER1,
|
||||
2 => SessionSettingType::CHAT_TRACKING_FOR_PLAYER2,
|
||||
3 => SessionSettingType::CHAT_TRACKING_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
$trackingSettingName = SessionSettingType::tryFrom('ChatTrackingForPlayer' . $player->getScreen());
|
||||
|
||||
if (!$trackingSettingName) {
|
||||
return;
|
||||
@@ -388,7 +429,8 @@ class GameResponseService
|
||||
{
|
||||
$screen = $player->getScreen();
|
||||
$requiredTargets = [0]; // Everyone
|
||||
for ($i = 1; $i <= 3; $i++) {
|
||||
$numPlayers = $player->getSession()->getGame()->getNumberOfPlayers();
|
||||
for ($i = 1; $i <= $numPlayers; $i++) {
|
||||
if ($i !== $screen) {
|
||||
$requiredTargets[] = $i;
|
||||
}
|
||||
@@ -402,12 +444,7 @@ class GameResponseService
|
||||
}
|
||||
|
||||
// Grant verify right
|
||||
$rightsSettingName = match ($screen) {
|
||||
1 => SessionSettingType::RIGHTS_FOR_PLAYER1,
|
||||
2 => SessionSettingType::RIGHTS_FOR_PLAYER2,
|
||||
3 => SessionSettingType::RIGHTS_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
$rightsSettingName = SessionSettingType::tryFrom('RightsForPlayer' . $screen);
|
||||
|
||||
if (!$rightsSettingName) {
|
||||
return;
|
||||
@@ -468,6 +505,30 @@ class GameResponseService
|
||||
return $randomString;
|
||||
}
|
||||
|
||||
private function generateSpecialCode(int $firstDigit, int $min, int $max): string
|
||||
{
|
||||
$code = $this->generateRandomString($min, $max);
|
||||
|
||||
// Ensure the first numeric digit is the specified $firstDigit
|
||||
$found = false;
|
||||
$codeArray = str_split($code);
|
||||
for ($i = 0; $i < count($codeArray); $i++) {
|
||||
if (ctype_digit($codeArray[$i])) {
|
||||
$codeArray[$i] = (string)$firstDigit;
|
||||
$found = true;
|
||||
break;
|
||||
}
|
||||
}
|
||||
$code = implode('', $codeArray);
|
||||
|
||||
// If no digit was found (highly unlikely given the character set), prepend it
|
||||
if (!$found) {
|
||||
$code = (string)$firstDigit . substr($code, 1);
|
||||
}
|
||||
|
||||
return $code;
|
||||
}
|
||||
|
||||
private function handleVerifyMessage(string $message, Player $player) : string
|
||||
{
|
||||
$messageParts = explode(' ', $message);
|
||||
@@ -479,12 +540,7 @@ class GameResponseService
|
||||
$screen = $player->getScreen();
|
||||
$session = $player->getSession();
|
||||
|
||||
$progressSettingName = match ($screen) {
|
||||
1 => SessionSettingType::VERIFICATION_PROGRESS_FOR_PLAYER1,
|
||||
2 => SessionSettingType::VERIFICATION_PROGRESS_FOR_PLAYER2,
|
||||
3 => SessionSettingType::VERIFICATION_PROGRESS_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
$progressSettingName = SessionSettingType::tryFrom('VerificationProgressForPlayer' . $screen);
|
||||
|
||||
if (!$progressSettingName) {
|
||||
return 'Error: Invalid player screen.';
|
||||
@@ -504,12 +560,7 @@ class GameResponseService
|
||||
}
|
||||
|
||||
$otherScreen = $otherPlayer->getScreen();
|
||||
$codesSettingName = match ($otherScreen) {
|
||||
1 => SessionSettingType::VERIFY_CODES_FOR_PLAYER1,
|
||||
2 => SessionSettingType::VERIFY_CODES_FOR_PLAYER2,
|
||||
3 => SessionSettingType::VERIFY_CODES_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
$codesSettingName = SessionSettingType::tryFrom('VerifyCodesForPlayer' . $otherScreen);
|
||||
|
||||
if (!$codesSettingName) {
|
||||
continue;
|
||||
@@ -553,12 +604,7 @@ class GameResponseService
|
||||
private function grantVerificationRights(Player $player): void
|
||||
{
|
||||
$screen = $player->getScreen();
|
||||
$rightsSettingName = match ($screen) {
|
||||
1 => SessionSettingType::RIGHTS_FOR_PLAYER1,
|
||||
2 => SessionSettingType::RIGHTS_FOR_PLAYER2,
|
||||
3 => SessionSettingType::RIGHTS_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
$rightsSettingName = SessionSettingType::tryFrom('RightsForPlayer' . $screen);
|
||||
|
||||
if (!$rightsSettingName) {
|
||||
return;
|
||||
@@ -584,6 +630,56 @@ class GameResponseService
|
||||
$setting->setValue(json_encode($rights));
|
||||
$this->entityManager->persist($setting);
|
||||
$this->entityManager->flush();
|
||||
|
||||
$this->checkIfAllPlayersVerified($player);
|
||||
}
|
||||
}
|
||||
|
||||
private function checkIfAllPlayersVerified(Player $player): void
|
||||
{
|
||||
$session = $player->getSession();
|
||||
$everyoneVerifiedSetting = $this->sessionSettingRepository->getSetting($session, SessionSettingType::EVERYONE_VERIFIED, $player);
|
||||
|
||||
if ($everyoneVerifiedSetting && $everyoneVerifiedSetting->getValue() === 'true') {
|
||||
return;
|
||||
}
|
||||
|
||||
$allVerified = true;
|
||||
foreach ($session->getPlayers() as $otherPlayer) {
|
||||
$otherScreen = $otherPlayer->getScreen();
|
||||
$progressSettingName = SessionSettingType::tryFrom('VerificationProgressForPlayer' . $otherScreen);
|
||||
|
||||
if (!$progressSettingName) {
|
||||
continue;
|
||||
}
|
||||
|
||||
$progressSetting = $this->sessionSettingRepository->getSetting($session, $progressSettingName, $otherPlayer);
|
||||
$progress = json_decode($progressSetting?->getValue() ?? '[]', true) ?? [];
|
||||
|
||||
if (count($progress) < $session->getGame()->getNumberOfPlayers() - 1) {
|
||||
$allVerified = false;
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
if ($allVerified) {
|
||||
if (!$everyoneVerifiedSetting) {
|
||||
$everyoneVerifiedSetting = new SessionSetting();
|
||||
$everyoneVerifiedSetting->setSession($session);
|
||||
$everyoneVerifiedSetting->setPlayer($player);
|
||||
$everyoneVerifiedSetting->setName(SessionSettingType::EVERYONE_VERIFIED);
|
||||
}
|
||||
$everyoneVerifiedSetting->setValue('true');
|
||||
$this->entityManager->persist($everyoneVerifiedSetting);
|
||||
$this->entityManager->flush();
|
||||
|
||||
$topic = $this->mercureTopicBase . '/game/hub-' . $session->getId();
|
||||
$message = "Mainframe Help Modus: Agents Doyle, Vega and Lennox rapports have been updated with coded messages.";
|
||||
try {
|
||||
$this->hub->publish(new Update($topic, json_encode([0, $message])));
|
||||
} catch (\Exception $e) {
|
||||
// Mercure might be down
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -646,20 +742,20 @@ class GameResponseService
|
||||
$paths[] = '/etc/freak';
|
||||
$paths[] = '/etc/host';
|
||||
|
||||
$paths[] = '/home';
|
||||
$paths[] = '/var/home';
|
||||
|
||||
$playerNames = ['root', 'Luke', 'Charles', 'William', 'Peter'];
|
||||
|
||||
$players = $player->getSession()->getPlayers();
|
||||
|
||||
foreach($players as $player) {
|
||||
$playerNames[] = $player->getUser()->getUsername();
|
||||
foreach($players as $p) {
|
||||
$playerNames[] = $p->getUser()->getUsername();
|
||||
}
|
||||
|
||||
$playerNames = array_unique($playerNames);
|
||||
|
||||
foreach($playerNames as $name) {
|
||||
$paths[] = '/home/' . $name;
|
||||
$paths[] = '/var/home/' . $name;
|
||||
}
|
||||
|
||||
return $paths;
|
||||
@@ -725,12 +821,17 @@ class GameResponseService
|
||||
$files[] = '/var/rapports/017_123-88.txt';
|
||||
$files[] = '/var/rapports/093_138-24.txt';
|
||||
$files[] = '/var/rapports/001_145-93.txt';
|
||||
$files[] = '/var/rapports/011_130-62.txt';
|
||||
$files[] = '/var/rapports/index.txt';
|
||||
|
||||
if ($player === null) {
|
||||
return $files;
|
||||
}
|
||||
|
||||
$players = $player->getSession()->getPlayers();
|
||||
|
||||
foreach($players as $player) {
|
||||
$files[] = '/var/home/' . $player->getUser()->getUsername() . '/verifyCodes.txt';
|
||||
foreach($players as $p) {
|
||||
$files[] = '/var/home/' . $p->getUser()->getUsername() . '/verifyCodes.txt';
|
||||
}
|
||||
|
||||
return $files;
|
||||
@@ -744,7 +845,7 @@ class GameResponseService
|
||||
}
|
||||
|
||||
$allPaths = $this->getAllPossiblePaths($player);
|
||||
$allFiles = $this->getAllPossibleFiles();
|
||||
$allFiles = $this->getAllPossibleFiles($player);
|
||||
$deletedFiles = $this->playerService->getDeletedFilesOfSession($player);
|
||||
|
||||
$entries = [];
|
||||
@@ -779,4 +880,144 @@ class GameResponseService
|
||||
sort($entries);
|
||||
return $entries;
|
||||
}
|
||||
|
||||
public function getFileContent(Player $player, string $file) : array
|
||||
{
|
||||
$allPossibleFiles = $this->getAllPossibleFiles($player);
|
||||
if (!in_array($file, $allPossibleFiles)) {
|
||||
return ['File does not exist'];
|
||||
}
|
||||
|
||||
if (str_ends_with($file, '.sh')) {
|
||||
return ['It is not possible to read this file'];
|
||||
}
|
||||
|
||||
if (str_ends_with($file, 'verifyCodes.txt')) {
|
||||
return $this->readVerificationFile($player, $file);
|
||||
}
|
||||
|
||||
$physicalPath = 'assets/game1/filesystem' . $file;
|
||||
if (!file_exists($physicalPath)) {
|
||||
return ['File does not exist'];
|
||||
}
|
||||
|
||||
$content = file($physicalPath);
|
||||
if ($content === false) {
|
||||
return ['Error reading file'];
|
||||
}
|
||||
|
||||
$specialFiles = [
|
||||
'/var/rapports/083_25-39.txt' => [
|
||||
'setting' => SessionSettingType::SPECIAL_REPORT_CODE_DOYLE,
|
||||
'digit' => 1
|
||||
],
|
||||
'/var/rapports/019_31-11.txt' => [
|
||||
'setting' => SessionSettingType::SPECIAL_REPORT_CODE_VEGA,
|
||||
'digit' => 2
|
||||
],
|
||||
'/var/rapports/011_130-62.txt' => [
|
||||
'setting' => SessionSettingType::SPECIAL_REPORT_CODE_LENNOX,
|
||||
'digit' => 3
|
||||
],
|
||||
];
|
||||
|
||||
if (isset($specialFiles[$file])) {
|
||||
$everyoneVerifiedSetting = $this->sessionSettingRepository->getSetting($player->getSession(), SessionSettingType::EVERYONE_VERIFIED);
|
||||
if ($everyoneVerifiedSetting && $everyoneVerifiedSetting->getValue() === 'true') {
|
||||
$settingInfo = $specialFiles[$file];
|
||||
$codeSetting = $this->sessionSettingRepository->getSetting($player->getSession(), $settingInfo['setting']);
|
||||
|
||||
if (!$codeSetting) {
|
||||
$codeSetting = new SessionSetting();
|
||||
$codeSetting->setSession($player->getSession());
|
||||
$codeSetting->setName($settingInfo['setting']);
|
||||
$codeSetting->setValue($this->generateSpecialCode($settingInfo['digit'], 75, 100));
|
||||
|
||||
$this->entityManager->persist($codeSetting);
|
||||
$this->entityManager->flush();
|
||||
}
|
||||
|
||||
$specialCode = $codeSetting->getValue();
|
||||
|
||||
$newContent = [];
|
||||
foreach ($content as $line) {
|
||||
$newContent[] = $line;
|
||||
if (str_starts_with(trim($line), 'Date:')) {
|
||||
$newContent[] = $specialCode . "\n";
|
||||
}
|
||||
}
|
||||
$content = $newContent;
|
||||
}
|
||||
}
|
||||
|
||||
return $content;
|
||||
}
|
||||
|
||||
private function readVerificationFile(Player $player, string $file)
|
||||
{
|
||||
$parts = explode('/', $file);
|
||||
$ownerUsername = $parts[3] ?? null;
|
||||
|
||||
$ownerPlayer = null;
|
||||
foreach ($player->getSession()->getPlayers() as $p) {
|
||||
if ($p->getUser()->getUsername() === $ownerUsername) {
|
||||
$ownerPlayer = $p;
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
if (!$ownerPlayer) {
|
||||
return 'File does not exist';
|
||||
}
|
||||
|
||||
$screen = $ownerPlayer->getScreen();
|
||||
$settingName = SessionSettingType::tryFrom('VerifyCodesForPlayer' . $screen);
|
||||
|
||||
if (!$settingName) {
|
||||
return 'Error: Invalid player screen.';
|
||||
}
|
||||
|
||||
$setting = $this->sessionSettingRepository->getSetting($player->getSession(), $settingName, $ownerPlayer);
|
||||
if (!$setting) {
|
||||
$setting = new SessionSetting();
|
||||
$setting->setSession($player->getSession());
|
||||
$setting->setPlayer($ownerPlayer);
|
||||
$setting->setName($settingName);
|
||||
}
|
||||
|
||||
$codes = json_decode($setting->getValue() ?? '[]', true) ?? [];
|
||||
|
||||
$playerNames = ['Luke', 'Charles', 'William', 'Peter'];
|
||||
foreach ($player->getSession()->getPlayers() as $p) {
|
||||
$playerNames[] = $p->getUser()->getUsername();
|
||||
}
|
||||
$playerNames = array_unique($playerNames);
|
||||
sort($playerNames);
|
||||
|
||||
$content = [];
|
||||
|
||||
$content[] = "Verification codes:";
|
||||
$content[] = "";
|
||||
|
||||
foreach ($playerNames as $name) {
|
||||
$key = null;
|
||||
foreach ($player->getSession()->getPlayers() as $p) {
|
||||
if ($p->getUser()->getUsername() === $name) {
|
||||
$key = (string)$p->getScreen();
|
||||
break;
|
||||
}
|
||||
}
|
||||
if ($key === null) {
|
||||
$key = $name;
|
||||
}
|
||||
|
||||
if (!isset($codes[$key])) {
|
||||
$codes[$key] = bin2hex(random_bytes(3));
|
||||
}
|
||||
|
||||
$content[] = $name . ": " . $codes[$key] . "\n";
|
||||
}
|
||||
|
||||
return $content;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -40,12 +40,7 @@ class PlayerService
|
||||
}
|
||||
|
||||
public function getCurrentPwdOfPlayer(Player $player) : ?string {
|
||||
$settingName = match($player->getScreen()) {
|
||||
1 => SessionSettingType::PWD_FOR_PLAYER1,
|
||||
2 => SessionSettingType::PWD_FOR_PLAYER2,
|
||||
3 => SessionSettingType::PWD_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
$settingName = SessionSettingType::tryFrom('PwdForPlayer' . $player->getScreen());
|
||||
|
||||
if (!$settingName) {
|
||||
return null;
|
||||
@@ -57,12 +52,7 @@ class PlayerService
|
||||
|
||||
public function saveCurrentPwdOfPlayer(Player $player, string $newLocation)
|
||||
{
|
||||
$settingName = match($player->getScreen()) {
|
||||
1 => SessionSettingType::PWD_FOR_PLAYER1,
|
||||
2 => SessionSettingType::PWD_FOR_PLAYER2,
|
||||
3 => SessionSettingType::PWD_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
$settingName = SessionSettingType::tryFrom('PwdForPlayer' . $player->getScreen());
|
||||
|
||||
if (!$settingName) {
|
||||
return;
|
||||
|
||||
@@ -32,4 +32,16 @@ class UserRepository extends ServiceEntityRepository implements PasswordUpgrader
|
||||
$this->getEntityManager()->persist($user);
|
||||
$this->getEntityManager()->flush();
|
||||
}
|
||||
|
||||
/**
|
||||
* @return User[]
|
||||
*/
|
||||
public function findByRole(string $role): array
|
||||
{
|
||||
return $this->createQueryBuilder('u')
|
||||
->andWhere('u.roles LIKE :role')
|
||||
->setParameter('role', '%"' . $role . '"%')
|
||||
->getQuery()
|
||||
->getResult();
|
||||
}
|
||||
}
|
||||
|
||||
82
templates/game/admin/index.html.twig
Normal file
82
templates/game/admin/index.html.twig
Normal file
@@ -0,0 +1,82 @@
|
||||
{% extends 'base.html.twig' %}
|
||||
|
||||
{% block title %}Game Admin Dashboard{% endblock %}
|
||||
|
||||
{% block body %}
|
||||
<h1>Game Admin Dashboard</h1>
|
||||
|
||||
<div style="display: flex; gap: 2rem;">
|
||||
<div style="flex: 1;">
|
||||
<h2>All Players ({{ players|length }})</h2>
|
||||
<table style="width: 100%; border-collapse: collapse;">
|
||||
<thead>
|
||||
<tr style="background-color: #f2f2f2;">
|
||||
<th>ID</th>
|
||||
<th>Username</th>
|
||||
<th>Email</th>
|
||||
<th>Roles</th>
|
||||
<th>Verified</th>
|
||||
</tr>
|
||||
</thead>
|
||||
<tbody>
|
||||
{% for player in players %}
|
||||
<tr>
|
||||
<td>{{ player.id }}</td>
|
||||
<td>{{ player.username }}</td>
|
||||
<td>{{ player.email }}</td>
|
||||
<td>{{ player.roles|join(', ') }}</td>
|
||||
<td>{{ player.isVerified ? 'Yes' : 'No' }}</td>
|
||||
</tr>
|
||||
{% else %}
|
||||
<tr>
|
||||
<td colspan="5">No players found.</td>
|
||||
</tr>
|
||||
{% endfor %}
|
||||
</tbody>
|
||||
</table>
|
||||
</div>
|
||||
|
||||
<div style="flex: 2;">
|
||||
<h2>All Sessions ({{ sessions|length }})</h2>
|
||||
<table style="width: 100%; border-collapse: collapse;">
|
||||
<thead>
|
||||
<tr style="background-color: #f2f2f2;">
|
||||
<th>ID</th>
|
||||
<th>Game</th>
|
||||
<th>Status</th>
|
||||
<th>Players Joined</th>
|
||||
<th>Created At</th>
|
||||
<th>Actions</th>
|
||||
</tr>
|
||||
</thead>
|
||||
<tbody>
|
||||
{% for session in sessions %}
|
||||
<tr>
|
||||
<td>{{ session.id }}</td>
|
||||
<td>{{ session.game.name }}</td>
|
||||
<td>{{ session.status.value }}</td>
|
||||
<td>
|
||||
<ul>
|
||||
{% for p in session.players %}
|
||||
<li>{{ p.user.username }} (Screen: {{ p.screen ?? 'N/A' }})</li>
|
||||
{% else %}
|
||||
<li>No players</li>
|
||||
{% endfor %}
|
||||
</ul>
|
||||
({{ session.players|length }} / {{ session.game.numberOfPlayers }})
|
||||
</td>
|
||||
<td>{{ session.created|date('Y-m-d H:i') }}</td>
|
||||
<td>
|
||||
<a href="{{ path('game_admin_view_session', {session: session.id}) }}">View Game Logs</a>
|
||||
</td>
|
||||
</tr>
|
||||
{% else %}
|
||||
<tr>
|
||||
<td colspan="6">No sessions found.</td>
|
||||
</tr>
|
||||
{% endfor %}
|
||||
</tbody>
|
||||
</table>
|
||||
</div>
|
||||
</div>
|
||||
{% endblock %}
|
||||
49
templates/game/admin/session.html.twig
Normal file
49
templates/game/admin/session.html.twig
Normal file
@@ -0,0 +1,49 @@
|
||||
{% extends 'base.html.twig' %}
|
||||
|
||||
{% block title %}View Session Logs - {{ session.id }}{% endblock %}
|
||||
|
||||
{% block body %}
|
||||
<h1>Session: {{ session.game.name }} (#{{ session.id }})</h1>
|
||||
<p><a href="{{ path('game_admin_dashboard') }}">Back to Dashboard</a></p>
|
||||
|
||||
<div class="tabs">
|
||||
<ul style="display: flex; list-style: none; padding: 0; border-bottom: 1px solid #ccc;">
|
||||
{% for playerLog in playersLogs %}
|
||||
<li style="margin-right: 10px;">
|
||||
<button
|
||||
onclick="openTab(event, 'player-{{ loop.index }}')"
|
||||
class="tablinks {{ loop.first ? 'active' : '' }}"
|
||||
style="padding: 10px; cursor: pointer; border: 1px solid #ccc; border-bottom: none; background: {{ loop.first ? '#eee' : '#fff' }};"
|
||||
>
|
||||
{{ playerLog.username }}
|
||||
</button>
|
||||
</li>
|
||||
{% endfor %}
|
||||
</ul>
|
||||
</div>
|
||||
|
||||
{% for playerLog in playersLogs %}
|
||||
<div id="player-{{ loop.index }}" class="tabcontent" style="display: {{ loop.first ? 'block' : 'none' }}; border: 1px solid #ccc; border-top: none; padding: 20px;">
|
||||
<h3>Logs for {{ playerLog.username }}</h3>
|
||||
<pre style="background: #f4f4f4; padding: 15px; overflow-x: auto; white-space: pre-wrap; word-wrap: break-word;">{{ playerLog.logs ?: 'No logs found for this player.' }}</pre>
|
||||
</div>
|
||||
{% endfor %}
|
||||
|
||||
<script>
|
||||
function openTab(evt, playerName) {
|
||||
var i, tabcontent, tablinks;
|
||||
tabcontent = document.getElementsByClassName("tabcontent");
|
||||
for (i = 0; i < tabcontent.length; i++) {
|
||||
tabcontent[i].style.display = "none";
|
||||
}
|
||||
tablinks = document.getElementsByClassName("tablinks");
|
||||
for (i = 0; i < tablinks.length; i++) {
|
||||
tablinks[i].className = tablinks[i].className.replace(" active", "");
|
||||
tablinks[i].style.background = "#fff";
|
||||
}
|
||||
document.getElementById(playerName).style.display = "block";
|
||||
evt.currentTarget.className += " active";
|
||||
evt.currentTarget.style.background = "#eee";
|
||||
}
|
||||
</script>
|
||||
{% endblock %}
|
||||
@@ -5,6 +5,10 @@
|
||||
{% block body %}
|
||||
<h1>Game Dashboard</h1>
|
||||
|
||||
{% if is_granted('ROLE_ADMIN') %}
|
||||
<p><a href="{{ path('game_admin_dashboard') }}">Go to Game Admin Dashboard</a></p>
|
||||
{% endif %}
|
||||
|
||||
<h2>Create New Session</h2>
|
||||
{% if availableGames is not empty %}
|
||||
<form method="post">
|
||||
@@ -69,11 +73,19 @@
|
||||
</td>
|
||||
<td>
|
||||
<a href="{{ path('game', {session: session.id}) }}">Enter Game</a>
|
||||
{% if session.status.value == 'created' and session.timer == 0 %}
|
||||
<form method="post" style="display:inline;">
|
||||
<input type="hidden" name="session_id" value="{{ session.id }}">
|
||||
<button type="submit" name="leave_session" onclick="return confirm('Are you sure you want to leave this session?')">Leave Session</button>
|
||||
</form>
|
||||
{% if session.status.value == 'created' %}
|
||||
{% if session.players|length >= session.game.numberOfPlayers %}
|
||||
<form method="post" style="display:inline;">
|
||||
<input type="hidden" name="session_id" value="{{ session.id }}">
|
||||
<button type="submit" name="start_session">Start Session</button>
|
||||
</form>
|
||||
{% endif %}
|
||||
{% if session.timer == 0 %}
|
||||
<form method="post" style="display:inline;">
|
||||
<input type="hidden" name="session_id" value="{{ session.id }}">
|
||||
<button type="submit" name="leave_session" onclick="return confirm('Are you sure you want to leave this session?')">Leave Session</button>
|
||||
</form>
|
||||
{% endif %}
|
||||
{% endif %}
|
||||
</td>
|
||||
</tr>
|
||||
|
||||
@@ -18,11 +18,14 @@
|
||||
data-topic="{{ (mercure_topic_base ~ '/game/hub-' ~ session.id)|e('html_attr') }}"
|
||||
data-api-ping-url="{{ path('game_api_ping')|e('html_attr') }}"
|
||||
data-api-echo-url="{{ path('game_api_message')|e('html_attr') }}"
|
||||
data-api-check-finished-url="{{ path('game_api_check_finished', {session: session.id})|e('html_attr') }}"
|
||||
data-lost-url="{{ path('game_lost', {session: session.id})|e('html_attr') }}"
|
||||
data-screen="{{ screen|e('html_attr') }}"
|
||||
style="display:none">
|
||||
</div>
|
||||
|
||||
<div id="game-timer">
|
||||
00:30:00
|
||||
<div id="game-timer" data-end-time="{{ session.timer }}">
|
||||
--:--:--
|
||||
</div>
|
||||
<div id="message-container">
|
||||
|
||||
|
||||
127
templates/game/lost.html.twig
Normal file
127
templates/game/lost.html.twig
Normal file
@@ -0,0 +1,127 @@
|
||||
{% extends 'base.html.twig' %}
|
||||
|
||||
{% block title %}Game Lost - {{ session.game.name }}{% endblock %}
|
||||
|
||||
{% block stylesheets %}
|
||||
{{ parent() }}
|
||||
<style>
|
||||
body {
|
||||
background-color: #1a1a1a;
|
||||
color: #e0e0e0;
|
||||
}
|
||||
.card {
|
||||
background-color: #2d2d2d;
|
||||
border-color: #444;
|
||||
color: #e0e0e0;
|
||||
}
|
||||
.form-label {
|
||||
font-weight: bold;
|
||||
}
|
||||
.story-container {
|
||||
font-style: italic;
|
||||
border-left: 4px solid #dc3545;
|
||||
padding-left: 20px;
|
||||
margin-bottom: 30px;
|
||||
}
|
||||
.donation-section {
|
||||
background-color: #333;
|
||||
padding: 20px;
|
||||
border-radius: 8px;
|
||||
margin-bottom: 30px;
|
||||
text-align: center;
|
||||
}
|
||||
.form-range::-webkit-slider-runnable-track {
|
||||
background-color: #444;
|
||||
}
|
||||
.form-range::-moz-range-track {
|
||||
background-color: #444;
|
||||
}
|
||||
.form-range::-webkit-slider-thumb {
|
||||
background-color: #dc3545;
|
||||
}
|
||||
.form-range::-moz-range-thumb {
|
||||
background-color: #dc3545;
|
||||
}
|
||||
</style>
|
||||
{% endblock %}
|
||||
|
||||
{% block body %}
|
||||
<div class="container mt-5 mb-5">
|
||||
<div class="row justify-content-center">
|
||||
<div class="col-md-8">
|
||||
<div class="card shadow-lg">
|
||||
<div class="card-header bg-danger text-white">
|
||||
<h3 class="card-title mb-0">Game Over - Time's Up!</h3>
|
||||
</div>
|
||||
<div class="card-body">
|
||||
<h4>{{ session.game.name }}</h4>
|
||||
<hr>
|
||||
|
||||
<div class="story-container">
|
||||
<p>
|
||||
The screens flickered one last time before going completely dark. The hum of the servers ceased, replaced by an eerie silence.
|
||||
The server seems to have shut itself down before the AI virus could complete its task in decoding the undercover agents.
|
||||
</p>
|
||||
<p>
|
||||
In the days after some people are arrested for sabotaging the agency, but in the end nobody is convicted for the actions.
|
||||
Lets hope the agents which were undercover are safe and the information needed is still saved to put the other criminals behind bars.
|
||||
</p>
|
||||
</div>
|
||||
|
||||
<div class="donation-section">
|
||||
<h5>Support the Developer</h5>
|
||||
<p>If you enjoyed the experience (even if you lost!), please consider a small donation to help me create more games.</p>
|
||||
<a href="https://www.paypal.com/donate?hosted_button_id=X9X8KB6R6GMRU" target="_blank" class="btn btn-primary">
|
||||
<i class="bi bi-paypal"></i> Donate via PayPal
|
||||
</a>
|
||||
</div>
|
||||
|
||||
<div class="feedback-form mt-4">
|
||||
<h5>Feedback</h5>
|
||||
<form method="post">
|
||||
<div class="mb-3">
|
||||
<label for="difficulty" class="form-label">How would you rate the difficulty? (<span id="difficulty-val">5</span>/10)</label>
|
||||
<input type="range" class="form-range" min="1" max="10" step="1" id="difficulty" name="difficulty" value="5" oninput="document.getElementById('difficulty-val').innerText = this.value">
|
||||
<div class="d-flex justify-content-between mt-1">
|
||||
<small class="text-muted">Absolutely not</small>
|
||||
-
|
||||
<small class="text-muted">Absolutely</small>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div class="mb-3">
|
||||
<label for="entertaining" class="form-label">How entertaining was it? (<span id="entertaining-val">5</span>/10)</label>
|
||||
<input type="range" class="form-range" min="1" max="10" step="1" id="entertaining" name="entertaining" value="5" oninput="document.getElementById('entertaining-val').innerText = this.value">
|
||||
<div class="d-flex justify-content-between mt-1">
|
||||
<small class="text-muted">Absolutely not</small>
|
||||
-
|
||||
<small class="text-muted">Absolutely</small>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div class="mb-3">
|
||||
<label for="theme" class="form-label">How was the theme? (<span id="theme-val">5</span>/10)</label>
|
||||
<input type="range" class="form-range" min="1" max="10" step="1" id="theme" name="theme" value="5" oninput="document.getElementById('theme-val').innerText = this.value">
|
||||
<div class="d-flex justify-content-between mt-1">
|
||||
<small class="text-muted">Absolutely not</small>
|
||||
-
|
||||
<small class="text-muted">Absolutely</small>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div class="mb-3">
|
||||
<label for="feedback" class="form-label">Additional Feedback</label>
|
||||
<textarea class="form-control" id="feedback" name="feedback" rows="4" placeholder="Tell us more about your experience..."></textarea>
|
||||
</div>
|
||||
|
||||
<div class="d-grid gap-2">
|
||||
<button type="submit" class="btn btn-success">Submit Feedback & Return to Dashboard</button>
|
||||
</div>
|
||||
</form>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
{% endblock %}
|
||||
125
templates/game/waiting.html.twig
Normal file
125
templates/game/waiting.html.twig
Normal file
@@ -0,0 +1,125 @@
|
||||
{% extends 'base.html.twig' %}
|
||||
|
||||
{% block title %}Waiting for players - {{ session.game.name }}{% endblock %}
|
||||
|
||||
{% block body %}
|
||||
<div class="container mt-5">
|
||||
<div class="row justify-content-center">
|
||||
<div class="col-md-8">
|
||||
<div class="card shadow-sm">
|
||||
<div class="card-header bg-primary text-white">
|
||||
<h3 class="card-title mb-0">Waiting for all players to be ready</h3>
|
||||
</div>
|
||||
<div class="card-body">
|
||||
<h4>{{ session.game.name }}</h4>
|
||||
<p>Welcome to the game! Please wait for all players to join and signal they are ready to start.</p>
|
||||
|
||||
<div class="game-info">
|
||||
Please keep the following things in mind:
|
||||
<ul>
|
||||
<li>This game is best played in full screen mode. For windows, press F11. For Mac, press Cmd+Ctrl+F.</li>
|
||||
<li>There is no need to reload the page. There is even a chance this could break the game.</li>
|
||||
<li>If your internet connection is lost, you can get back in the game after internet has been fixed.</li>
|
||||
</ul>
|
||||
</div>
|
||||
|
||||
<div class="alert alert-info">
|
||||
<strong>Game Information:</strong>
|
||||
<ul class="mb-0">
|
||||
<li>Number of players: {{ session.game.numberOfPlayers }}</li>
|
||||
<li>Current players: {{ session.players|length }} / {{ session.game.numberOfPlayers }}</li>
|
||||
</ul>
|
||||
</div>
|
||||
|
||||
<div class="mt-4">
|
||||
<h5>Players status:</h5>
|
||||
<ul class="list-group">
|
||||
{% for player in session.players %}
|
||||
<li class="list-group-item d-flex justify-content-between align-items-center">
|
||||
{{ player.user.username }}
|
||||
{% set playerReady = false %}
|
||||
{% set settingName = 'ReadyAtForPlayer' ~ player.screen %}
|
||||
{% for setting in session.settings %}
|
||||
{% if setting.name.value == settingName and setting.player == player %}
|
||||
{% set playerReady = true %}
|
||||
{% endif %}
|
||||
{% endfor %}
|
||||
|
||||
{% if playerReady %}
|
||||
<span class="badge bg-success">Ready</span>
|
||||
{% else %}
|
||||
<span class="badge bg-secondary">Not ready</span>
|
||||
{% endif %}
|
||||
</li>
|
||||
{% endfor %}
|
||||
</ul>
|
||||
</div>
|
||||
|
||||
<hr>
|
||||
|
||||
<form method="post" class="mt-4">
|
||||
<div class="form-check form-switch mb-3">
|
||||
<input class="form-check-input" type="checkbox" id="toggle_ready" name="toggle_ready" onchange="this.form.submit()" {{ isReady ? 'checked' : '' }}>
|
||||
<label class="form-check-label" for="toggle_ready">
|
||||
<strong>I am ready to start!</strong>
|
||||
</label>
|
||||
</div>
|
||||
<p class="text-muted small">
|
||||
Note: If all players are not ready within 1 minute of you checking this, your status will be reset automatically.
|
||||
</p>
|
||||
</form>
|
||||
|
||||
<div class="mt-3">
|
||||
<a href="{{ path('game_dashboard') }}" class="btn btn-outline-secondary">Back to Dashboard</a>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<div id="mercure-config"
|
||||
data-mercure-public-url="{{ mercure_public_url|e('html_attr') }}"
|
||||
data-topic="{{ (mercure_topic_base ~ '/game/hub-' ~ session.id)|e('html_attr') }}"
|
||||
data-ready-at="{{ readyAt|e('html_attr') }}"
|
||||
style="display:none">
|
||||
</div>
|
||||
|
||||
<script>
|
||||
const config = document.getElementById('mercure-config');
|
||||
const publicUrl = config.dataset.mercurePublicUrl;
|
||||
const topic = config.dataset.topic;
|
||||
const readyAt = config.dataset.readyAt;
|
||||
|
||||
if (publicUrl && topic) {
|
||||
const url = new URL(publicUrl);
|
||||
url.searchParams.append('topic', topic);
|
||||
|
||||
const eventSource = new EventSource(url);
|
||||
eventSource.onmessage = event => {
|
||||
const data = JSON.parse(event.data);
|
||||
if (data.type === 'all_ready' || data.type === 'player_ready') {
|
||||
window.location.reload();
|
||||
}
|
||||
};
|
||||
}
|
||||
|
||||
// Client-side timeout for ready status
|
||||
if (readyAt) {
|
||||
const timeoutMs = 61000; // 61 seconds (slightly more than server-side 60s)
|
||||
const now = Date.now();
|
||||
const readyAtMs = readyAt * 1000;
|
||||
const timeElapsed = now - readyAtMs;
|
||||
const timeLeft = timeoutMs - timeElapsed;
|
||||
|
||||
if (timeLeft > 0) {
|
||||
setTimeout(() => {
|
||||
window.location.reload();
|
||||
}, timeLeft);
|
||||
} else {
|
||||
// Already timed out, reload to sync with server
|
||||
window.location.reload();
|
||||
}
|
||||
}
|
||||
</script>
|
||||
{% endblock %}
|
||||
@@ -8,12 +8,14 @@ use App\Game\Entity\Player;
|
||||
use App\Game\Entity\Session;
|
||||
use App\Game\Entity\SessionSetting;
|
||||
use App\Game\Enum\GameStatus;
|
||||
use App\Game\Enum\SessionStatus;
|
||||
use App\Game\Enum\SessionSettingType;
|
||||
use App\Game\Service\GameDashboardService;
|
||||
use App\Tech\Entity\User;
|
||||
use Doctrine\ORM\EntityManagerInterface;
|
||||
use App\Game\Repository\GameRepository;
|
||||
use App\Game\Repository\SessionRepository;
|
||||
use Symfony\Component\Mercure\HubInterface;
|
||||
use PHPUnit\Framework\TestCase;
|
||||
|
||||
class GameDashboardServiceTest extends TestCase
|
||||
@@ -21,6 +23,7 @@ class GameDashboardServiceTest extends TestCase
|
||||
private $entityManager;
|
||||
private $gameRepository;
|
||||
private $sessionRepository;
|
||||
private $hub;
|
||||
private $service;
|
||||
|
||||
protected function setUp(): void
|
||||
@@ -28,15 +31,18 @@ class GameDashboardServiceTest extends TestCase
|
||||
$this->entityManager = $this->createMock(EntityManagerInterface::class);
|
||||
$this->gameRepository = $this->createMock(GameRepository::class);
|
||||
$this->sessionRepository = $this->createMock(SessionRepository::class);
|
||||
$this->hub = $this->createMock(HubInterface::class);
|
||||
|
||||
$this->service = new GameDashboardService(
|
||||
$this->gameRepository,
|
||||
$this->sessionRepository,
|
||||
$this->entityManager
|
||||
$this->entityManager,
|
||||
$this->hub,
|
||||
'http://localhost/topic'
|
||||
);
|
||||
}
|
||||
|
||||
public function testCreateSessionInitializesRightsAndPwd(): void
|
||||
public function testCreateSessionDoesNotInitializeSettings(): void
|
||||
{
|
||||
$game = new Game();
|
||||
$game->setStatus(GameStatus::OPEN);
|
||||
@@ -44,20 +50,23 @@ class GameDashboardServiceTest extends TestCase
|
||||
$user = new User();
|
||||
$user->setUsername('testuser');
|
||||
|
||||
$this->entityManager->expects($this->exactly(7))
|
||||
$this->entityManager->expects($this->exactly(2))
|
||||
->method('persist');
|
||||
// 1. Session, 2. Player, 3. SessionSetting (rights), 4. SessionSetting (pwd), 5. SessionSetting (chat tracking), 6. SessionSetting (verify codes), 7. SessionSetting (verification progress)
|
||||
// 1. Session, 2. Player
|
||||
|
||||
$session = $this->service->createSession($game, $user, false);
|
||||
|
||||
$this->assertInstanceOf(Session::class, $session);
|
||||
}
|
||||
|
||||
public function testJoinSessionInitializesRightsAndPwd(): void
|
||||
public function testJoinSessionDoesNotInitializeSettings(): void
|
||||
{
|
||||
$user = new User();
|
||||
$user->setUsername('testuser');
|
||||
$game = new Game();
|
||||
$game->setNumberOfPlayers(3);
|
||||
$session = new Session();
|
||||
$session->setGame($game);
|
||||
|
||||
$setting = new SessionSetting();
|
||||
$setting->setSession($session);
|
||||
@@ -71,15 +80,93 @@ class GameDashboardServiceTest extends TestCase
|
||||
$repo->method('findOneBy')
|
||||
->willReturn($setting);
|
||||
|
||||
$this->entityManager->expects($this->exactly(6))
|
||||
$this->entityManager->expects($this->exactly(1))
|
||||
->method('persist');
|
||||
// 1. Player, 2. SessionSetting (rights), 3. SessionSetting (pwd), 4. SessionSetting (chat tracking), 5. SessionSetting (verify codes), 6. SessionSetting (verification progress)
|
||||
// 1. Player
|
||||
|
||||
$result = $this->service->joinSession('abc-123', $user);
|
||||
|
||||
$this->assertTrue($result);
|
||||
}
|
||||
|
||||
public function testStartSessionAssignsScreensAndInitializesSettings(): void
|
||||
{
|
||||
$game = new Game();
|
||||
$game->setNumberOfPlayers(2);
|
||||
$session = new Session();
|
||||
$session->setGame($game);
|
||||
$session->setStatus(\App\Game\Enum\SessionStatus::CREATED);
|
||||
|
||||
$user1 = new User();
|
||||
$user1->setUsername('user1');
|
||||
$player1 = new Player();
|
||||
$player1->setUser($user1);
|
||||
$session->addPlayer($player1);
|
||||
|
||||
$user2 = new User();
|
||||
$user2->setUsername('user2');
|
||||
$player2 = new Player();
|
||||
$player2->setUser($user2);
|
||||
$session->addPlayer($player2);
|
||||
|
||||
// For each player (2):
|
||||
// Player (persist)
|
||||
// SessionSetting (rights)
|
||||
// SessionSetting (pwd)
|
||||
// SessionSetting (chat tracking)
|
||||
// SessionSetting (verify codes)
|
||||
// SessionSetting (verification progress)
|
||||
// Total = 2 * 6 = 12
|
||||
// PLUS Session (persist)
|
||||
// Total = 13
|
||||
|
||||
$this->entityManager->expects($this->exactly(13))
|
||||
->method('persist');
|
||||
|
||||
$result = $this->service->startSession($session);
|
||||
|
||||
$this->assertTrue($result);
|
||||
$this->assertEquals(\App\Game\Enum\SessionStatus::READY, $session->getStatus());
|
||||
$this->assertNotNull($player1->getScreen());
|
||||
$this->assertNotNull($player2->getScreen());
|
||||
$this->assertNotEquals($player1->getScreen(), $player2->getScreen());
|
||||
}
|
||||
|
||||
public function testStartSessionWithFourPlayers(): void
|
||||
{
|
||||
$game = new Game();
|
||||
$game->setNumberOfPlayers(4);
|
||||
$session = new Session();
|
||||
$session->setGame($game);
|
||||
$session->setStatus(\App\Game\Enum\SessionStatus::CREATED);
|
||||
|
||||
for ($i = 1; $i <= 4; $i++) {
|
||||
$user = new User();
|
||||
$user->setUsername('user' . $i);
|
||||
$player = new Player();
|
||||
$player->setUser($user);
|
||||
$session->addPlayer($player);
|
||||
}
|
||||
|
||||
// For each player (4):
|
||||
// Player (persist) + 5 Settings = 6 persists
|
||||
// Total = 4 * 6 = 24
|
||||
// PLUS Session (persist)
|
||||
// Total = 25
|
||||
|
||||
$this->entityManager->expects($this->exactly(25))
|
||||
->method('persist');
|
||||
|
||||
$result = $this->service->startSession($session);
|
||||
|
||||
$this->assertTrue($result);
|
||||
foreach ($session->getPlayers() as $player) {
|
||||
$this->assertNotNull($player->getScreen());
|
||||
$this->assertGreaterThanOrEqual(1, $player->getScreen());
|
||||
$this->assertLessThanOrEqual(4, $player->getScreen());
|
||||
}
|
||||
}
|
||||
|
||||
public function testLeaveSession(): void
|
||||
{
|
||||
$user = new User();
|
||||
@@ -112,24 +199,225 @@ class GameDashboardServiceTest extends TestCase
|
||||
$this->assertCount(1, $session->getPlayers());
|
||||
}
|
||||
|
||||
public function testLeaveSessionDeletesSessionIfLastPlayer(): void
|
||||
public function testToggleReady(): void
|
||||
{
|
||||
$user = new User();
|
||||
$game = new Game();
|
||||
$game->setNumberOfPlayers(1);
|
||||
$session = new Session();
|
||||
$session->setStatus(\App\Game\Enum\SessionStatus::CREATED);
|
||||
$session->setTimer(0);
|
||||
$session->setGame($game);
|
||||
$session->setStatus(SessionStatus::READY);
|
||||
|
||||
$player = new Player();
|
||||
$player->setUser($user);
|
||||
$player->setSession($session);
|
||||
$player->setScreen(1);
|
||||
$session->addPlayer($player);
|
||||
|
||||
$this->entityManager->expects($this->exactly(2))
|
||||
$repo = $this->createMock(\App\Game\Repository\SessionSettingRepository::class);
|
||||
$this->entityManager->method('getRepository')
|
||||
->willReturn($repo);
|
||||
|
||||
// First call: toggle ON
|
||||
$repo->expects($this->atLeastOnce())
|
||||
->method('getSetting')
|
||||
->willReturn(null); // No setting initially
|
||||
|
||||
$this->entityManager->expects($this->atLeastOnce())
|
||||
->method('persist')
|
||||
->with($this->callback(function($entity) {
|
||||
return $entity instanceof SessionSetting && $entity->getName() === SessionSettingType::READY_AT_FOR_PLAYER1;
|
||||
}));
|
||||
|
||||
$result = $this->service->toggleReady($session, $user);
|
||||
$this->assertTrue($result);
|
||||
}
|
||||
|
||||
public function testCheckAllPlayersReadyTransitionsStatus(): void
|
||||
{
|
||||
$game = new Game();
|
||||
$game->setNumberOfPlayers(2);
|
||||
$session = new Session();
|
||||
$session->setGame($game);
|
||||
$session->setStatus(SessionStatus::READY);
|
||||
|
||||
$player1 = new Player();
|
||||
$player1->setScreen(1);
|
||||
$session->addPlayer($player1);
|
||||
|
||||
$player2 = new Player();
|
||||
$player2->setScreen(2);
|
||||
$session->addPlayer($player2);
|
||||
|
||||
$repo = $this->createMock(\App\Game\Repository\SessionSettingRepository::class);
|
||||
$this->entityManager->method('getRepository')
|
||||
->willReturn($repo);
|
||||
|
||||
$setting1 = new SessionSetting();
|
||||
$setting1->setName(SessionSettingType::READY_AT_FOR_PLAYER1);
|
||||
$setting1->setValue((string)time());
|
||||
$setting1->setPlayer($player1);
|
||||
|
||||
$setting2 = new SessionSetting();
|
||||
$setting2->setName(SessionSettingType::READY_AT_FOR_PLAYER2);
|
||||
$setting2->setValue((string)time());
|
||||
$setting2->setPlayer($player2);
|
||||
|
||||
$repo->method('getSetting')
|
||||
->willReturnCallback(function($s, $name, $p) use ($setting1, $setting2) {
|
||||
if ($name === SessionSettingType::READY_AT_FOR_PLAYER1) return $setting1;
|
||||
if ($name === SessionSettingType::READY_AT_FOR_PLAYER2) return $setting2;
|
||||
return null;
|
||||
});
|
||||
|
||||
$this->service->checkAllPlayersReady($session);
|
||||
|
||||
$this->assertEquals(SessionStatus::PLAYING, $session->getStatus());
|
||||
}
|
||||
|
||||
public function testCheckAllPlayersReadyTimeouts(): void
|
||||
{
|
||||
$game = new Game();
|
||||
$game->setNumberOfPlayers(2);
|
||||
$session = new Session();
|
||||
$session->setGame($game);
|
||||
$session->setStatus(SessionStatus::READY);
|
||||
|
||||
$player1 = new Player();
|
||||
$player1->setScreen(1);
|
||||
$session->addPlayer($player1);
|
||||
|
||||
$player2 = new Player();
|
||||
$player2->setScreen(2);
|
||||
$session->addPlayer($player2);
|
||||
|
||||
$repo = $this->createMock(\App\Game\Repository\SessionSettingRepository::class);
|
||||
$this->entityManager->method('getRepository')
|
||||
->willReturn($repo);
|
||||
|
||||
$setting1 = new SessionSetting();
|
||||
$setting1->setName(SessionSettingType::READY_AT_FOR_PLAYER1);
|
||||
$setting1->setValue((string)(time() - 70)); // Timed out
|
||||
$setting1->setPlayer($player1);
|
||||
$session->addSetting($setting1);
|
||||
|
||||
$repo->method('getSetting')
|
||||
->willReturnCallback(function($s, $name, $p) use ($setting1) {
|
||||
if ($name === SessionSettingType::READY_AT_FOR_PLAYER1) return $setting1;
|
||||
return null;
|
||||
});
|
||||
|
||||
$this->entityManager->expects($this->once())
|
||||
->method('remove')
|
||||
->with($setting1);
|
||||
|
||||
$this->entityManager->expects($this->atLeastOnce())
|
||||
->method('flush');
|
||||
|
||||
$this->hub->expects($this->once())
|
||||
->method('publish');
|
||||
|
||||
$this->service->checkAllPlayersReady($session);
|
||||
|
||||
$this->assertEquals(SessionStatus::READY, $session->getStatus());
|
||||
}
|
||||
|
||||
public function testJoinSessionTriggersStartSessionWhenFull(): void
|
||||
{
|
||||
$user = new User();
|
||||
$user->setUsername('testuser');
|
||||
$game = new Game();
|
||||
$game->setNumberOfPlayers(2);
|
||||
$session = new Session();
|
||||
$session->setGame($game);
|
||||
$session->setStatus(\App\Game\Enum\SessionStatus::CREATED);
|
||||
|
||||
$existingUser = new User();
|
||||
$existingUser->setUsername('existing');
|
||||
$existingPlayer = new Player();
|
||||
$existingPlayer->setUser($existingUser);
|
||||
$session->addPlayer($existingPlayer);
|
||||
|
||||
$setting = new SessionSetting();
|
||||
$setting->setSession($session);
|
||||
$setting->setName(SessionSettingType::INVITE_CODE);
|
||||
$setting->setValue('abc-123');
|
||||
|
||||
$repo = $this->createMock(\Doctrine\ORM\EntityRepository::class);
|
||||
$this->entityManager->method('getRepository')
|
||||
->willReturn($repo);
|
||||
|
||||
$repo->method('findOneBy')
|
||||
->willReturn($setting);
|
||||
|
||||
// Expectation:
|
||||
// 1. Persist new Player
|
||||
// 2. Persist Player 1 (existing) screen update
|
||||
// 3. Persist Player 2 (new) screen update
|
||||
// 4. Persist Session status update
|
||||
// 5. 5 Settings for Player 1
|
||||
// 6. 5 Settings for Player 2
|
||||
// Total = 1 + 1 + 1 + 1 + 5 + 5 = 14 persists
|
||||
$this->entityManager->expects($this->exactly(14))
|
||||
->method('persist');
|
||||
|
||||
$result = $this->service->joinSession('abc-123', $user);
|
||||
|
||||
$this->assertTrue($result);
|
||||
$this->assertEquals(\App\Game\Enum\SessionStatus::READY, $session->getStatus());
|
||||
}
|
||||
|
||||
public function testLeaveSessionRevertsFromReady(): void
|
||||
{
|
||||
$user = new User();
|
||||
$user->setUsername('testuser');
|
||||
$session = new Session();
|
||||
$session->setStatus(\App\Game\Enum\SessionStatus::READY);
|
||||
$session->setTimer(0);
|
||||
|
||||
$player1 = new Player();
|
||||
$player1->setUser($user);
|
||||
$player1->setScreen(1);
|
||||
$player1->setSession($session);
|
||||
$session->addPlayer($player1);
|
||||
|
||||
$player2 = new Player();
|
||||
$player2->setUser(new User());
|
||||
$player2->setScreen(2);
|
||||
$player2->setSession($session);
|
||||
$session->addPlayer($player2);
|
||||
|
||||
$this->entityManager->expects($this->exactly(1))
|
||||
->method('remove');
|
||||
// 1. Player, 2. Session
|
||||
// 1. Player1, any settings (none in this test setup)
|
||||
|
||||
$result = $this->service->leaveSession($session, $user);
|
||||
|
||||
$this->assertTrue($result);
|
||||
$this->assertEquals(\App\Game\Enum\SessionStatus::CREATED, $session->getStatus());
|
||||
$this->assertNull($player2->getScreen());
|
||||
}
|
||||
|
||||
public function testCreateSessionForOnePlayerGame(): void
|
||||
{
|
||||
$game = new Game();
|
||||
$game->setStatus(GameStatus::OPEN);
|
||||
$game->setNumberOfPlayers(1);
|
||||
|
||||
$user = new User();
|
||||
$user->setUsername('testuser');
|
||||
|
||||
// 1. Session persist
|
||||
// 2. Player persist
|
||||
// 3. Player screen persist (during startSession)
|
||||
// 4. Session status persist (during startSession)
|
||||
// 5. 5 Settings for Player (during startSession)
|
||||
// Total = 1 + 1 + 1 + 1 + 5 = 9 persists
|
||||
$this->entityManager->expects($this->exactly(9))
|
||||
->method('persist');
|
||||
|
||||
$session = $this->service->createSession($game, $user, false);
|
||||
|
||||
$this->assertInstanceOf(Session::class, $session);
|
||||
$this->assertEquals(\App\Game\Enum\SessionStatus::READY, $session->getStatus());
|
||||
}
|
||||
}
|
||||
|
||||
@@ -3,6 +3,7 @@ declare(strict_types=1);
|
||||
|
||||
namespace App\Tests\Game;
|
||||
|
||||
use App\Game\Entity\Game;
|
||||
use App\Game\Entity\Player;
|
||||
use App\Game\Entity\Session;
|
||||
use App\Game\Entity\SessionSetting;
|
||||
@@ -39,7 +40,8 @@ class GameResponseServiceChatVerifyCodeTest extends TestCase
|
||||
$this->playerService,
|
||||
$this->sessionSettingRepository,
|
||||
$this->hub,
|
||||
$this->entityManager
|
||||
$this->entityManager,
|
||||
'H:\escapepage'
|
||||
);
|
||||
|
||||
$_ENV['MERCURE_TOPIC_BASE'] = 'http://test';
|
||||
@@ -50,8 +52,12 @@ class GameResponseServiceChatVerifyCodeTest extends TestCase
|
||||
$user = new User();
|
||||
$user->setUsername('testuser');
|
||||
|
||||
$game = $this->createMock(Game::class);
|
||||
$game->method('getNumberOfPlayers')->willReturn(4);
|
||||
|
||||
$session = $this->createMock(Session::class);
|
||||
$session->method('getId')->willReturn(123);
|
||||
$session->method('getGame')->willReturn($game);
|
||||
|
||||
$player = $this->createMock(Player::class);
|
||||
$player->method('getUser')->willReturn($user);
|
||||
|
||||
102
tests/Game/SessionLoggingTest.php
Normal file
102
tests/Game/SessionLoggingTest.php
Normal file
@@ -0,0 +1,102 @@
|
||||
<?php
|
||||
declare(strict_types=1);
|
||||
|
||||
namespace App\Tests\Game;
|
||||
|
||||
use App\Game\Entity\Player;
|
||||
use App\Game\Entity\Session;
|
||||
use App\Game\Entity\SessionSetting;
|
||||
use App\Game\Enum\SessionSettingType;
|
||||
use App\Game\Repository\SessionSettingRepository;
|
||||
use App\Game\Service\GameResponseService;
|
||||
use App\Game\Service\PlayerService;
|
||||
use App\Tech\Entity\User;
|
||||
use Doctrine\ORM\EntityManagerInterface;
|
||||
use PHPUnit\Framework\TestCase;
|
||||
use Symfony\Bundle\SecurityBundle\Security;
|
||||
use Symfony\Component\Mercure\HubInterface;
|
||||
|
||||
class SessionLoggingTest extends TestCase
|
||||
{
|
||||
private string $tempDir;
|
||||
private $security;
|
||||
private $playerService;
|
||||
private $sessionSettingRepository;
|
||||
private $hub;
|
||||
private $entityManager;
|
||||
private $service;
|
||||
|
||||
protected function setUp(): void
|
||||
{
|
||||
$this->tempDir = sys_get_temp_dir() . '/escapepage_test_' . uniqid();
|
||||
mkdir($this->tempDir, 0777, true);
|
||||
|
||||
$this->security = $this->createMock(Security::class);
|
||||
$this->playerService = $this->createMock(PlayerService::class);
|
||||
$this->sessionSettingRepository = $this->createMock(SessionSettingRepository::class);
|
||||
$this->hub = $this->createMock(HubInterface::class);
|
||||
$this->entityManager = $this->createMock(EntityManagerInterface::class);
|
||||
|
||||
$this->service = new GameResponseService(
|
||||
$this->security,
|
||||
$this->playerService,
|
||||
$this->sessionSettingRepository,
|
||||
$this->hub,
|
||||
$this->entityManager,
|
||||
$this->tempDir
|
||||
);
|
||||
}
|
||||
|
||||
protected function tearDown(): void
|
||||
{
|
||||
$this->removeDir($this->tempDir);
|
||||
}
|
||||
|
||||
private function removeDir(string $dir): void
|
||||
{
|
||||
if (!is_dir($dir)) return;
|
||||
$files = array_diff(scandir($dir), ['.', '..']);
|
||||
foreach ($files as $file) {
|
||||
(is_dir("$dir/$file")) ? $this->removeDir("$dir/$file") : unlink("$dir/$file");
|
||||
}
|
||||
rmdir($dir);
|
||||
}
|
||||
|
||||
public function testLogging(): void
|
||||
{
|
||||
$user = new User();
|
||||
$user->setUsername('player1');
|
||||
|
||||
$session = $this->createMock(Session::class);
|
||||
$session->method('getId')->willReturn(456);
|
||||
|
||||
$player = $this->createMock(Player::class);
|
||||
$player->method('getUser')->willReturn($user);
|
||||
$player->method('getSession')->willReturn($session);
|
||||
$player->method('getScreen')->willReturn(1);
|
||||
|
||||
$this->security->method('getUser')->willReturn($user);
|
||||
$this->playerService->method('GetCurrentlyActiveAsPlayer')->willReturn($player);
|
||||
|
||||
// Mock rights
|
||||
$rightsSetting = new SessionSetting();
|
||||
$rightsSetting->setValue(json_encode(['chat']));
|
||||
$this->sessionSettingRepository->method('getSetting')
|
||||
->willReturnMap([
|
||||
[$session, SessionSettingType::RIGHTS_FOR_PLAYER1, $player, $rightsSetting],
|
||||
]);
|
||||
|
||||
// Simulate 'help' command (always returns something)
|
||||
$raw = json_encode(['message' => 'help', 'ts' => '123']);
|
||||
$result = $this->service->getGameResponse($raw);
|
||||
|
||||
$this->assertNotEmpty($result);
|
||||
|
||||
$logFilePath = $this->tempDir . '/var/log/sessions/456/player1.txt';
|
||||
$this->assertFileExists($logFilePath);
|
||||
|
||||
$logContent = file_get_contents($logFilePath);
|
||||
$this->assertStringContainsString('PLAYER: help', $logContent);
|
||||
$this->assertStringContainsString('SERVER:', $logContent);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user