1 Commits

Author SHA1 Message Date
Frank
314e16d4bf Created a dashboard and created an invite code for game sessions. 2026-01-06 20:20:55 +01:00
24 changed files with 88 additions and 2520 deletions

2
.env
View File

@@ -57,7 +57,7 @@ MERCURE_URL=http://mercure/.well-known/mercure
# Public hub URL used by browsers # Public hub URL used by browsers
MERCURE_PUBLIC_URL=http://localhost:8090/.well-known/mercure MERCURE_PUBLIC_URL=http://localhost:8090/.well-known/mercure
# Shared secret for signing JWTs (dev only). In prod, set via real env/secrets. # Shared secret for signing JWTs (dev only). In prod, set via real env/secrets.
MERCURE_JWT_SECRET=!ChangeThisMercureJWTSignedBySymfonySecretKey! MERCURE_JWT_SECRET=!ChangeThisMercureJWT!
# Base URL for Mercure topics. Use .dev in development; override to .com in prod via .env.prod or real env. # Base URL for Mercure topics. Use .dev in development; override to .com in prod via .env.prod or real env.
MERCURE_TOPIC_BASE=https://escapepage.dev MERCURE_TOPIC_BASE=https://escapepage.dev
###< mercure ### ###< mercure ###

View File

@@ -1,10 +1,7 @@
/* Game1 entry point built with Webpack Encore */ /* Game1 entry point built with Webpack Encore */
import './styles/game1.css'; import './styles/game1.css';
let sequenceFinished = false; function subscribeToMercure(mercurePublicUrl, topic) {
let stillPlayingSound = true;
function subscribeToMercure(mercurePublicUrl, topic, myScreen) {
try { try {
const url = mercurePublicUrl + '?topic=' + encodeURIComponent(topic); const url = mercurePublicUrl + '?topic=' + encodeURIComponent(topic);
const es = new EventSource(url); const es = new EventSource(url);
@@ -13,33 +10,6 @@ function subscribeToMercure(mercurePublicUrl, topic, myScreen) {
try { try {
const data = JSON.parse(event.data); const data = JSON.parse(event.data);
console.log('[Mercure][game1] Update:', data); console.log('[Mercure][game1] Update:', data);
// 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');
msgEl.className = 'message';
msgEl.textContent = data[1];
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);
if (sequenceFinished) {
flashRed();
}
}
}
} catch (e) { } catch (e) {
console.log('[Mercure][game1] Raw event:', event.data); console.log('[Mercure][game1] Raw event:', event.data);
} }
@@ -55,28 +25,6 @@ function subscribeToMercure(mercurePublicUrl, topic, myScreen) {
} }
} }
function playSound() {
const sound = document.getElementById('message-sound');
if (sound) {
sound.currentTime = 0;
sound.play().catch(e => console.warn('[Audio] Playback failed:', e));
}
}
function flashRed() {
console.log('[Game1] Triggering flashRed');
const body = document.body;
body.classList.remove('flash-red');
void body.offsetWidth; // Trigger reflow to restart animation
body.classList.add('flash-red');
// Also remove it after animation finishes so it's clean for inspection
setTimeout(() => {
body.classList.remove('flash-red');
console.log('[Game1] Removed flash-red class');
}, 150);
}
async function fetchJson(url, options = {}) { async function fetchJson(url, options = {}) {
const opts = { ...options }; const opts = { ...options };
const headers = new Headers(opts.headers || {}); const headers = new Headers(opts.headers || {});
@@ -112,15 +60,6 @@ document.addEventListener('DOMContentLoaded', async () => {
// Look for config injected by Twig in the page // Look for config injected by Twig in the page
const cfgEl = document.getElementById('mercure-config'); const cfgEl = document.getElementById('mercure-config');
// Prevent/warn on page reload
window.addEventListener('beforeunload', (event) => {
// Standard way to trigger the browser's confirmation dialog
event.preventDefault();
// Included for compatibility with older browsers
event.returnValue = '';
});
if (!cfgEl) { if (!cfgEl) {
console.warn('[Mercure][game1] #mercure-config element not found on page'); console.warn('[Mercure][game1] #mercure-config element not found on page');
return; return;
@@ -128,12 +67,12 @@ document.addEventListener('DOMContentLoaded', async () => {
const mercurePublicUrl = cfgEl.dataset.mercurePublicUrl; const mercurePublicUrl = cfgEl.dataset.mercurePublicUrl;
const topic = cfgEl.dataset.topic; const topic = cfgEl.dataset.topic;
const screen = cfgEl.dataset.screen;
const apiPingUrl = cfgEl.dataset.apiPingUrl; const apiPingUrl = cfgEl.dataset.apiPingUrl;
const apiEchoUrl = cfgEl.dataset.apiEchoUrl; const apiEchoUrl = cfgEl.dataset.apiEchoUrl;
const userId = cfgEl.dataset.userId;
if (mercurePublicUrl && topic) { if (mercurePublicUrl && topic) {
subscribeToMercure(mercurePublicUrl, topic, screen); subscribeToMercure(mercurePublicUrl, topic);
} else { } else {
console.warn('[Mercure][game1] Missing data attributes on #mercure-config'); console.warn('[Mercure][game1] Missing data attributes on #mercure-config');
} }
@@ -150,7 +89,7 @@ document.addEventListener('DOMContentLoaded', async () => {
if (apiEchoUrl) { if (apiEchoUrl) {
const echo = await fetchJson(apiEchoUrl, { const echo = await fetchJson(apiEchoUrl, {
method: 'POST', method: 'POST',
body: { message: 'from game1.js', ts: new Date().toISOString() }, body: { message: 'from game1.js', ts: new Date().toISOString(), user: userId },
}); });
console.log('[API][game1] echo →', echo); console.log('[API][game1] echo →', echo);
} else { } else {
@@ -159,99 +98,4 @@ document.addEventListener('DOMContentLoaded', async () => {
} catch (e) { } catch (e) {
console.error('[API][game1] Request failed:', e); console.error('[API][game1] Request failed:', e);
} }
// Add messages to message-container
const messageContainer = document.getElementById('message-container');
if (messageContainer) {
let messages = [
['System initializing...', 500],
['Connection established.', 200],
['Welcome agent to the mainframe.', 1000],
['Scanning...', 3000],
['Virus detected.', 500],
['Starting Mainframe help modus...', 2000],
['Help modus activated.', 500],
['Blocking virus activated', 0]
];
let currentMessageIndex = 0;
const printNextMessage = () => {
if (currentMessageIndex < messages.length) {
const msg = messages[currentMessageIndex];
const msgEl = document.createElement('div');
let extraClass = '';
if(msg[2])
extraClass = msg[2];
msgEl.className = 'message ' + extraClass;
msgEl.textContent = msg[0];
msgEl.style.marginBottom = '10px';
messageContainer.appendChild(msgEl);
window.scrollTo(0, document.body.scrollHeight);
playSound();
currentMessageIndex++;
setTimeout(printNextMessage, msg[1]);
if (sequenceFinished) {
flashRed();
}
} else {
// After it has printed a set of messages, it has to start a timer of 2 seconds
console.log('[Game1] All messages printed. Starting 2s timer to expand message-container height...');
setTimeout(() => {
messageContainer.style.height = '400vh';
const inputField = document.getElementById('input-message');
inputField.disabled = false;
// Add event listener for Enter key
inputField.addEventListener('keypress', async (e) => {
if (e.key === 'Enter') {
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 {
const response = await fetchJson(apiEchoUrl, {
method: 'POST',
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);
}
}
}
});
console.log('[Game1] message-container height changed to 400vh and input enabled');
sequenceFinished = true;
console.log('[Game1] sequenceFinished is now TRUE');
}, 2000);
}
};
printNextMessage();
}
}); });

View File

@@ -1,93 +1,17 @@
/* Styles specific to Game1 */ /* Styles specific to Game1 */
/* page-level indicator to confirm CSS is loaded */ /* page-level indicator to confirm CSS is loaded */
/* Custom scrollbar for WebKit browsers */ body.game1-page {
html::-webkit-scrollbar, /* subtle background tint so you can visually confirm on /game */
body::-webkit-scrollbar { background-color: #f9fbff;
width: 1px;
} }
html::-webkit-scrollbar-track, /* example component style */
body::-webkit-scrollbar-track { .game1-banner {
background: #000; padding: 1rem 1.25rem;
} border: 1px solid #cfe2ff;
background: #e9f2ff;
html::-webkit-scrollbar-thumb, color: #0b5ed7;
body::-webkit-scrollbar-thumb { border-radius: 8px;
background: #F00; margin: 1rem 0;
}
/* Standard properties for Firefox */
body {
background-color: #000;
min-height: 100vh;
font-family: monospace;
margin: 0;
scrollbar-width: thin;
scrollbar-color: #F00 #000;
}
div#game-timer {
position: fixed;
top: 0;
left: 0;
width: 100%;
padding: 20px;
background-color: #000;
color: #F00;
font-size: 28px;
z-index: 100;
}
div#message-container {
padding: 20px;
padding-top: 80px; /* Space for fixed timer */
display: flex;
flex-direction: column;
justify-content: flex-end;
min-height: calc(100vh - 100px); /* Fill most of the viewport initially */
box-sizing: border-box;
font-size: 20px;
}
div.message {
color: #C0C0C0;
white-space: pre-wrap;
}
div#input {
padding: 20px;
}
input#input-message {
width: 100%;
padding: 10px;
background: #111;
border: 1px solid #A00000;
color: #C0C0C0;
font-size: 18px;
box-sizing: border-box;
font-family: monospace;
}
.flash-red::after {
content: '';
position: fixed;
bottom: 0;
left: 0;
right: 0;
height: 100px;
pointer-events: none;
background: linear-gradient(to top, rgba(255, 0, 0, 0.8), transparent);
animation: flash-red-anim 0.1s linear forwards;
z-index: 9999;
}
@keyframes flash-red-anim {
0% {
opacity: 1;
}
100% {
opacity: 0;
}
} }

View File

@@ -7,11 +7,11 @@ services:
environment: environment:
# Uncomment the following line to disable HTTPS, # Uncomment the following line to disable HTTPS,
#SERVER_NAME: ':80' #SERVER_NAME: ':80'
MERCURE_PUBLISHER_JWT_KEY: '!ChangeThisMercureJWTSignedBySymfonySecretKey!' MERCURE_PUBLISHER_JWT_KEY: '!ChangeThisMercureHubJWTSecretKey!'
MERCURE_SUBSCRIBER_JWT_KEY: '!ChangeThisMercureJWTSignedBySymfonySecretKey!' MERCURE_SUBSCRIBER_JWT_KEY: '!ChangeThisMercureHubJWTSecretKey!'
# Set the URL of your Symfony project (without trailing slash!) as value of the cors_origins directive # Set the URL of your Symfony project (without trailing slash!) as value of the cors_origins directive
MERCURE_EXTRA_DIRECTIVES: | MERCURE_EXTRA_DIRECTIVES: |
cors_origins http://localhost:8080 cors_origins http://127.0.0.1:8000
# Comment the following line to disable the development mode # Comment the following line to disable the development mode
command: /usr/bin/caddy run --config /etc/caddy/dev.Caddyfile command: /usr/bin/caddy run --config /etc/caddy/dev.Caddyfile
healthcheck: healthcheck:

View File

@@ -3,6 +3,4 @@ mercure:
default: default:
url: '%env(MERCURE_URL)%' url: '%env(MERCURE_URL)%'
public_url: '%env(MERCURE_PUBLIC_URL)%' public_url: '%env(MERCURE_PUBLIC_URL)%'
jwt: jwt: '%env(MERCURE_JWT_SECRET)%'
secret: '%env(MERCURE_JWT_SECRET)%'
publish: ['*']

View File

@@ -16,9 +16,5 @@ services:
App\: App\:
resource: '../src/' resource: '../src/'
App\Game\Service\GameResponseService:
arguments:
$projectDir: '%kernel.project_dir%'
# add more service definitions when explicit configuration is needed # add more service definitions when explicit configuration is needed
# please note that last definitions always *replace* previous ones # please note that last definitions always *replace* previous ones

View File

@@ -63,8 +63,8 @@ services:
container_name: escapepage-mercure container_name: escapepage-mercure
environment: environment:
SERVER_NAME: ":80" SERVER_NAME: ":80"
MERCURE_PUBLISHER_JWT_KEY: '!ChangeThisMercureJWTSignedBySymfonySecretKey!' MERCURE_PUBLISHER_JWT_KEY: ${MERCURE_JWT_SECRET:-!ChangeThisMercureJWT!}
MERCURE_SUBSCRIBER_JWT_KEY: '!ChangeThisMercureJWTSignedBySymfonySecretKey!' MERCURE_SUBSCRIBER_JWT_KEY: ${MERCURE_JWT_SECRET:-!ChangeThisMercureJWT!}
MERCURE_CORS_ALLOWED_ORIGINS: http://localhost:8080 MERCURE_CORS_ALLOWED_ORIGINS: http://localhost:8080
MERCURE_PUBLISH_ALLOWED_ORIGINS: http://localhost:8080 MERCURE_PUBLISH_ALLOWED_ORIGINS: http://localhost:8080
MERCURE_EXTRA_DIRECTIVES: | MERCURE_EXTRA_DIRECTIVES: |

Binary file not shown.

View File

@@ -1,63 +0,0 @@
<?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,
]);
}
}

View File

@@ -4,14 +4,9 @@ declare(strict_types=1);
namespace App\Game\Controller; namespace App\Game\Controller;
use App\Game\Entity\Session; 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\GameRepository;
use App\Game\Repository\PlayerRepository;
use App\Game\Repository\SessionRepository; use App\Game\Repository\SessionRepository;
use App\Game\Service\GameDashboardService; use App\Game\Service\GameDashboardService;
use App\Tech\Entity\User;
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController; use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Bundle\SecurityBundle\Security; use Symfony\Bundle\SecurityBundle\Security;
use Symfony\Component\HttpFoundation\Request; use Symfony\Component\HttpFoundation\Request;
@@ -19,16 +14,9 @@ use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\Routing\Annotation\Route; use Symfony\Component\Routing\Annotation\Route;
use Symfony\Component\Security\Http\Attribute\IsGranted; use Symfony\Component\Security\Http\Attribute\IsGranted;
use Symfony\Component\ExpressionLanguage\Expression; use Symfony\Component\ExpressionLanguage\Expression;
use Symfony\Component\DependencyInjection\Attribute\Autowire;
final class GameController extends AbstractController final class GameController extends AbstractController
{ {
public function __construct(
#[Autowire('%env(MERCURE_PUBLIC_URL)%')]
private string $mercurePublicUrl
) {
}
#[Route(path: '', name: 'game_dashboard', methods: ['GET', 'POST'])] #[Route(path: '', name: 'game_dashboard', methods: ['GET', 'POST'])]
#[IsGranted(new Expression("is_granted('ROLE_PLAYER') or is_granted('ROLE_ADMIN')"))] #[IsGranted(new Expression("is_granted('ROLE_PLAYER') or is_granted('ROLE_ADMIN')"))]
public function dashboard( public function dashboard(
@@ -51,13 +39,6 @@ final class GameController extends AbstractController
$this->addFlash('success', 'New session created!'); $this->addFlash('success', 'New session created!');
} }
} }
} elseif ($request->request->has('join_session')) {
$inviteCode = $request->request->get('invite_code');
if ($dashboardService->joinSession($inviteCode, $user)) {
$this->addFlash('success', 'Joined session successfully!');
} else {
$this->addFlash('error', 'Invalid invite code or session full.');
}
} elseif ($request->request->has('create_invite')) { } elseif ($request->request->has('create_invite')) {
$sessionId = $request->request->get('session_id'); $sessionId = $request->request->get('session_id');
$session = $sessionRepository->find($sessionId); $session = $sessionRepository->find($sessionId);
@@ -71,28 +52,6 @@ final class GameController extends AbstractController
if ($inviteCode) { if ($inviteCode) {
$this->addFlash('success', 'Invite link created: ' . $inviteCode); $this->addFlash('success', 'Invite link created: ' . $inviteCode);
} }
} elseif ($request->request->has('leave_session')) {
$sessionId = $request->request->get('session_id');
$session = $sessionRepository->find($sessionId);
if ($session) {
if ($dashboardService->leaveSession($session, $user)) {
$this->addFlash('success', 'Left session successfully.');
} else {
$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'); return $this->redirectToRoute('game_dashboard');
@@ -104,59 +63,12 @@ final class GameController extends AbstractController
]); ]);
} }
#[Route(path: '/{session}', name: 'game', methods: ['GET', 'POST'])] #[Route(path: '/{session}', name: 'game')]
#[IsGranted(new Expression("is_granted('ROLE_PLAYER') or is_granted('ROLE_ADMIN')"))] #[IsGranted(new Expression("is_granted('ROLE_PLAYER') or is_granted('ROLE_ADMIN')"))]
#[IsGranted('SESSION_VIEW', subject: 'session')] #[IsGranted('SESSION_VIEW', subject: 'session')]
public function index( public function index(
Session $session, Session $session): Response
Request $request,
Security $security,
PlayerRepository $playerRepository,
GameDashboardService $dashboardService
): Response
{ {
$user = $security->getUser(); return $this->render('game/index.html.twig', ['session' => $session]);
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;
return $this->render('game/index.html.twig', [
'session' => $session,
'screen' => $screen,
]);
} }
} }

View File

@@ -23,7 +23,7 @@ class Player
#[ORM\JoinColumn(nullable: false)] #[ORM\JoinColumn(nullable: false)]
private ?User $user = null; private ?User $user = null;
#[ORM\Column(nullable: true)] #[ORM\Column]
private ?int $screen = null; private ?int $screen = null;
public function getId(): ?int public function getId(): ?int
@@ -60,7 +60,7 @@ class Player
return $this->screen; return $this->screen;
} }
public function setScreen(?int $screen): static public function setScreen(int $screen): static
{ {
$this->screen = $screen; $this->screen = $screen;

View File

@@ -7,67 +7,8 @@ enum SessionSettingType: string
case PWD_FOR_PLAYER1 = 'PwdForPlayer1'; case PWD_FOR_PLAYER1 = 'PwdForPlayer1';
case PWD_FOR_PLAYER2 = 'PwdForPlayer2'; case PWD_FOR_PLAYER2 = 'PwdForPlayer2';
case PWD_FOR_PLAYER3 = 'PwdForPlayer3'; 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_PLAYER1 = 'RightsForPlayer1';
case RIGHTS_FOR_PLAYER2 = 'RightsForPlayer2'; case RIGHTS_FOR_PLAYER2 = 'RightsForPlayer2';
case RIGHTS_FOR_PLAYER3 = 'RightsForPlayer3'; 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 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';
} }

View File

@@ -15,9 +15,6 @@ use App\Game\Repository\SessionRepository;
use App\Tech\Entity\User; use App\Tech\Entity\User;
use Doctrine\ORM\EntityManagerInterface; use Doctrine\ORM\EntityManagerInterface;
use Symfony\Component\Security\Core\User\UserInterface; 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 final class GameDashboardService
{ {
@@ -25,9 +22,6 @@ final class GameDashboardService
private readonly GameRepository $gameRepository, private readonly GameRepository $gameRepository,
private readonly SessionRepository $sessionRepository, private readonly SessionRepository $sessionRepository,
private readonly EntityManagerInterface $entityManager, private readonly EntityManagerInterface $entityManager,
private readonly HubInterface $hub,
#[Autowire('%env(MERCURE_TOPIC_BASE)%')]
private readonly string $mercureTopicBase,
) { ) {
} }
@@ -72,348 +66,16 @@ final class GameDashboardService
$player = new Player(); $player = new Player();
$player->setUser($user); $player->setUser($user);
$session->addPlayer($player); $player->setSession($session);
$player->setScreen(1);
$this->entityManager->persist($session); $this->entityManager->persist($session);
$this->entityManager->persist($player); $this->entityManager->persist($player);
$this->entityManager->flush(); $this->entityManager->flush();
if (count($session->getPlayers()) === $session->getGame()->getNumberOfPlayers()) {
$this->startSession($session);
}
return $session; return $session;
} }
public function joinSession(string $inviteCode, UserInterface $user): bool
{
if (!$user instanceof User) {
return false;
}
$setting = $this->entityManager->getRepository(SessionSetting::class)->findOneBy([
'name' => SessionSettingType::INVITE_CODE,
'value' => $inviteCode,
]);
if (!$setting) {
return false;
}
$session = $setting->getSession();
// Check if user is already in this session
foreach ($session->getPlayers() as $player) {
if ($player->getUser() === $user) {
return true; // Already joined
}
}
$playerCount = count($session->getPlayers());
if ($playerCount >= $session->getGame()->getNumberOfPlayers()) {
return false; // Session full
}
$player = new Player();
$player->setUser($user);
$session->addPlayer($player);
$this->entityManager->persist($player);
$this->entityManager->flush();
if (count($session->getPlayers()) === $session->getGame()->getNumberOfPlayers()) {
$this->startSession($session);
}
return true;
}
public function leaveSession(Session $session, UserInterface $user): bool
{
if (!$user instanceof User) {
return false;
}
if (!in_array($session->getStatus(), [SessionStatus::CREATED, SessionStatus::READY]) || $session->getTimer() > 0) {
return false;
}
$playerToDelete = null;
foreach ($session->getPlayers() as $player) {
if ($player->getUser() === $user) {
$playerToDelete = $player;
break;
}
}
if (!$playerToDelete) {
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) {
$session->removeSetting($setting);
$this->entityManager->remove($setting);
}
}
$session->removePlayer($playerToDelete);
$this->entityManager->remove($playerToDelete);
// If no players left, we might want to delete the session and its remaining settings
if ($session->getPlayers()->isEmpty()) {
foreach ($session->getSettings() as $setting) {
$this->entityManager->remove($setting);
}
$this->entityManager->remove($session);
}
$this->entityManager->flush();
return true;
}
private function initializePlayerSettings(Player $player): void
{
$screen = $player->getScreen();
$rightsSettingName = SessionSettingType::tryFrom('RightsForPlayer' . $screen);
if ($rightsSettingName) {
$setting = new SessionSetting();
$setting->setSession($player->getSession());
$setting->setPlayer($player);
$setting->setName($rightsSettingName);
$setting->setValue(json_encode(['chat', 'help', 'ls', 'pwd']));
$this->entityManager->persist($setting);
}
$pwdSettingName = SessionSettingType::tryFrom('PwdForPlayer' . $screen);
if ($pwdSettingName) {
$setting = new SessionSetting();
$setting->setSession($player->getSession());
$setting->setPlayer($player);
$setting->setName($pwdSettingName);
$setting->setValue('var/home/' . $player->getUser()->getUsername());
$this->entityManager->persist($setting);
}
$chatTrackingSettingName = SessionSettingType::tryFrom('ChatTrackingForPlayer' . $screen);
if ($chatTrackingSettingName) {
$setting = new SessionSetting();
$setting->setSession($player->getSession());
$setting->setPlayer($player);
$setting->setName($chatTrackingSettingName);
$setting->setValue(json_encode([]));
$this->entityManager->persist($setting);
}
$verifyCodesSettingName = SessionSettingType::tryFrom('VerifyCodesForPlayer' . $screen);
if ($verifyCodesSettingName) {
$codes = [];
$numPlayers = $player->getSession()->getGame()->getNumberOfPlayers();
for ($i = 1; $i <= $numPlayers; $i++) {
if ($i !== $screen) {
$codes[$i] = bin2hex(random_bytes(3)); // 6 characters code
}
}
$setting = new SessionSetting();
$setting->setSession($player->getSession());
$setting->setPlayer($player);
$setting->setName($verifyCodesSettingName);
$setting->setValue(json_encode($codes));
$this->entityManager->persist($setting);
}
$verificationProgressSettingName = SessionSettingType::tryFrom('VerificationProgressForPlayer' . $screen);
if ($verificationProgressSettingName) {
$setting = new SessionSetting();
$setting->setSession($player->getSession());
$setting->setPlayer($player);
$setting->setName($verificationProgressSettingName);
$setting->setValue(json_encode([]));
$this->entityManager->persist($setting);
}
}
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);
$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 public function generateInviteCode(Session $session, UserInterface $user, bool $isAdmin): ?string
{ {
// Security check: is user part of this session? // Security check: is user part of this session?

View File

@@ -5,14 +5,9 @@ namespace App\Game\Service;
use App\Game\Enum\DecodeMessage; use App\Game\Enum\DecodeMessage;
use App\Game\Enum\SessionSettingType; use App\Game\Enum\SessionSettingType;
use App\Game\Entity\Player; use App\Game\Entity\Player;
use App\Game\Entity\SessionSetting;
use App\Game\Repository\SessionSettingRepository; use App\Game\Repository\SessionSettingRepository;
use App\Tech\Entity\User; use App\Tech\Entity\User;
use Doctrine\ORM\EntityManagerInterface;
use Symfony\Bundle\SecurityBundle\Security; use Symfony\Bundle\SecurityBundle\Security;
use Symfony\Component\Mercure\HubInterface;
use Symfony\Component\Mercure\Update;
use Symfony\Component\DependencyInjection\Attribute\Autowire;
class GameResponseService class GameResponseService
{ {
@@ -20,15 +15,10 @@ class GameResponseService
private Security $security, private Security $security,
private PlayerService $playerService, private PlayerService $playerService,
private SessionSettingRepository $sessionSettingRepository, private SessionSettingRepository $sessionSettingRepository,
private HubInterface $hub,
private EntityManagerInterface $entityManager,
private string $projectDir,
#[Autowire('%env(MERCURE_TOPIC_BASE)%')]
private string $mercureTopicBase,
) { ) {
} }
public function getGameResponse(string $raw) : array public function getGameResponse(string $raw)
{ {
$info = json_decode($raw, true); $info = json_decode($raw, true);
@@ -48,7 +38,7 @@ class GameResponseService
if(!$player) if(!$player)
return ['error' => 'You are not in a game.']; return ['error' => 'You are not in a game.'];
$this->logSessionActivity($player, 'PLAYER: ' . $message); // TODO: Here i need to add a message handler to save the message in a big log.
$data = []; $data = [];
@@ -58,46 +48,17 @@ class GameResponseService
$data = $this->checkConsoleCommando($message, $player); $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; 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 private function getRechten(Player $player): array
{ {
$settingName = SessionSettingType::tryFrom('RightsForPlayer' . $player->getScreen()); $settingName = match($player->getScreen()) {
1 => SessionSettingType::RIGHTS_FOR_PLAYER1,
2 => SessionSettingType::RIGHTS_FOR_PLAYER2,
3 => SessionSettingType::RIGHTS_FOR_PLAYER3,
default => null,
};
if (!$settingName) { if (!$settingName) {
return []; return [];
@@ -122,10 +83,8 @@ class GameResponseService
if(!in_array('chat', $rechten)) if(!in_array('chat', $rechten))
return ['result' => ['Unknown command']]; return ['result' => ['Unknown command']];
if($this->handleChatMessage($message, $player)) $this->handleChatMessage($message);
return ['result' => ['succesfully send']]; break;
else
return ['result' => ['Error sending']];
case '/help': case '/help':
return ['result' => $this->getHelpCommand($rechten)]; return ['result' => $this->getHelpCommand($rechten)];
case '/decode': case '/decode':
@@ -137,11 +96,12 @@ class GameResponseService
if(!in_array('verify', $rechten)) if(!in_array('verify', $rechten))
return ['result' => ['Unknown command']]; return ['result' => ['Unknown command']];
$result = $this->handleVerifyMessage($message, $player); $result = $this->handleVerifyMessage($message);
return ['result' => [$result]]; return ['result' => [$result]];
default: default:
return ['result' => ['Unknown command']]; return ['result' => ['Unknown command']];
} }
return [];
} }
private function checkConsoleCommando(string $message, Player $player, bool $sudo = false) : array private function checkConsoleCommando(string $message, Player $player, bool $sudo = false) : array
@@ -152,15 +112,8 @@ class GameResponseService
case 'help': case 'help':
return ['result' => $this->getHelpCommand($rechten)]; return ['result' => $this->getHelpCommand($rechten)];
case 'ls': case 'ls':
if(!in_array('ls', $rechten)) break;
return ['result' => ['Unknown command']];
$files = $this->getAllCurrentFilesInDirectory($player);
return ['result' => $files];
case 'cd': case 'cd':
if(!in_array('cd', $rechten))
return ['result' => ['Unknown command']];
$pwd = $this->playerService->getCurrentPwdOfPlayer($player); $pwd = $this->playerService->getCurrentPwdOfPlayer($player);
if(!$pwd) if(!$pwd)
return ['result' => ['Unknown command']]; return ['result' => ['Unknown command']];
@@ -171,52 +124,14 @@ class GameResponseService
$this->playerService->saveCurrentPwdOfPlayer($player, $newLocation); $this->playerService->saveCurrentPwdOfPlayer($player, $newLocation);
return ['result' => ['Path: ' . $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']];
$pwd = $this->playerService->getCurrentPwdOfPlayer($player);
return ['result' => ['Path: ' . $pwd]];
case 'rm': case 'rm':
if(!in_array('rm', $rechten)) break;
return ['result' => ['Unknown command']];
$pwd = $this->playerService->getCurrentPwdOfPlayer($player);
if(!$pwd)
return ['result' => ['Unknown command']];
if (!isset($messagePart[1])) {
return ['result' => ['Usage: rm {filename}']];
}
$filename = $messagePart[1];
$fullPath = ($pwd === '/' ? '' : $pwd) . '/' . $filename;
if(!$this->isAllowedToRemove($fullPath, $player, $sudo))
return ['result' => ['You are not allowed to remove this file.']];
$this->playerService->addDeletedFileToSession($player, $fullPath);
return ['result' => ['File removed: ' . $filename]];
case 'sudo': case 'sudo':
if(!in_array('sudo', $rechten)) break;
return ['result' => ['Unknown command']];
$sudo = array_shift($messagePart);
$message = implode(' ', $messagePart);
return $this->checkConsoleCommando($message, $player, true);
default: default:
return ['result' => ['Unknown command']]; return ['result' => ['Unknown command']];
} }
return [];
} }
private function getHelpCommand(mixed $rechten) : array private function getHelpCommand(mixed $rechten) : array
@@ -231,7 +146,6 @@ 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[] = ' 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[] = ' This will send the message only to agent with id 6.';
$messages[] = ' USAGE: /chat {message}'; $messages[] = ' USAGE: /chat {message}';
$messages[] = ' USAGE: /chat 6 {message}';
$messages[] = ''; $messages[] = '';
break; break;
case 'help': case 'help':
@@ -247,13 +161,6 @@ class GameResponseService
$messages[] = ' USAGE: /decode {message}'; $messages[] = ' USAGE: /decode {message}';
$messages[] = ''; $messages[] = '';
break; break;
case 'pwd':
$messages[] = 'pwd';
$messages[] = ' This message will let you know what your current location is.';
$messages[] = ' It will show you the folder you are in so you can continue navigating the server.';
$messages[] = ' USAGE: pwd';
$messages[] = '';
break;
case 'cat': case 'cat':
$messages[] = 'cat'; $messages[] = 'cat';
$messages[] = ' To read a file, use cat {filename}.'; $messages[] = ' To read a file, use cat {filename}.';
@@ -303,174 +210,9 @@ class GameResponseService
return $messages; return $messages;
} }
private function handleChatMessage(string $message, Player $player) : bool private function handleChatMessage(string $message)
{ {
$messageParts = explode(' ', $message);
$toSingle = false;
if (isset($messageParts[1]) &&
is_numeric($messageParts[1]) &&
$messageParts[1] >= 1 &&
$messageParts[1] <= $player->getSession()->getGame()->getNumberOfPlayers()) {
$toSingle = true;
}
$chatMessage = array_shift($messageParts);
$sendTo = 0;
if ($toSingle) {
$sendTo = array_shift($messageParts);
$chatMessage = array_shift($messageParts);
}
$message = $player->getUser()->getUsername() . ': ' . $chatMessage . ' ';
foreach($messageParts as $messagePart) {
$message .= $messagePart . ' ';
}
$message = trim($message);
$activeGame = $player->getSession()?->getId();
if(is_null($activeGame))
return false;
$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);
$this->checkAndRegenerateVerifyCodes($player, $chatMessage . ' ' . implode(' ', $messageParts));
return true;
}
private function checkAndRegenerateVerifyCodes(Player $player, string $messageContent): void
{
$screen = $player->getScreen();
$session = $player->getSession();
$verifyCodesSettingName = SessionSettingType::tryFrom('VerifyCodesForPlayer' . $screen);
if (!$verifyCodesSettingName) {
return;
}
$setting = $this->sessionSettingRepository->getSetting($session, $verifyCodesSettingName, $player);
if (!$setting) {
return;
}
$codes = json_decode($setting->getValue() ?? '[]', true) ?? [];
$regenerated = false;
foreach ($codes as $targetPlayerScreen => $code) {
if (str_contains($messageContent, (string)$code)) {
$codes[$targetPlayerScreen] = bin2hex(random_bytes(3));
$regenerated = true;
}
}
if ($regenerated) {
$setting->setValue(json_encode($codes));
$this->entityManager->persist($setting);
$this->entityManager->flush();
// Notify the player that their codes have changed
$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)
try {
$this->hub->publish(new Update($topic, json_encode([$screen, $notification])));
} catch (\Exception $e) {
// Mercure might be down
}
}
}
private function updateChatTracking(Player $player, int $sendTo): void
{
$rights = $this->getRechten($player);
if(in_array('verify', $rights))
return;
$trackingSettingName = SessionSettingType::tryFrom('ChatTrackingForPlayer' . $player->getScreen());
if (!$trackingSettingName) {
return;
}
$setting = $this->sessionSettingRepository->getSetting($player->getSession(), $trackingSettingName, $player);
if (!$setting) {
$setting = new SessionSetting();
$setting->setSession($player->getSession());
$setting->setPlayer($player);
$setting->setName($trackingSettingName);
$setting->setValue(json_encode([]));
}
$tracking = json_decode($setting->getValue() ?? '[]', true) ?? [];
if (!in_array($sendTo, $tracking)) {
$tracking[] = $sendTo;
$setting->setValue(json_encode($tracking));
$this->entityManager->persist($setting);
$this->entityManager->flush();
$this->checkAndGrantVerifyRight($player, $tracking);
}
}
private function checkAndGrantVerifyRight(Player $player, array $tracking): void
{
$screen = $player->getScreen();
$requiredTargets = [0]; // Everyone
$numPlayers = $player->getSession()->getGame()->getNumberOfPlayers();
for ($i = 1; $i <= $numPlayers; $i++) {
if ($i !== $screen) {
$requiredTargets[] = $i;
}
}
// Check if all required targets are in tracking
foreach ($requiredTargets as $target) {
if (!in_array($target, $tracking)) {
return;
}
}
// Grant verify right
$rightsSettingName = SessionSettingType::tryFrom('RightsForPlayer' . $screen);
if (!$rightsSettingName) {
return;
}
$setting = $this->sessionSettingRepository->getSetting($player->getSession(), $rightsSettingName, $player);
if (!$setting) {
return; // Should have been initialized
}
$rights = json_decode($setting->getValue() ?? '[]', true) ?? [];
$newRights = ['verify', 'cat'];
$updated = false;
foreach ($newRights as $newRight) {
if (!in_array($newRight, $rights)) {
$rights[] = $newRight;
$updated = true;
}
}
if ($updated) {
$setting->setValue(json_encode($rights));
$this->entityManager->persist($setting);
$this->entityManager->flush();
}
} }
private function handleDecodeMessage(string $message, Player $player) private function handleDecodeMessage(string $message, Player $player)
@@ -505,182 +247,9 @@ class GameResponseService
return $randomString; return $randomString;
} }
private function generateSpecialCode(int $firstDigit, int $min, int $max): string private function handleVerifyMessage(string $message) : string
{ {
$code = $this->generateRandomString($min, $max); return '';
// 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);
if (count($messageParts) < 2) {
return 'Usage: /verify {code}';
}
$code = $messageParts[1];
$screen = $player->getScreen();
$session = $player->getSession();
$progressSettingName = SessionSettingType::tryFrom('VerificationProgressForPlayer' . $screen);
if (!$progressSettingName) {
return 'Error: Invalid player screen.';
}
$progressSetting = $this->sessionSettingRepository->getSetting($session, $progressSettingName, $player);
if (!$progressSetting) {
return 'Error: Verification progress setting not found.';
}
$progress = json_decode($progressSetting->getValue() ?? '[]', true) ?? [];
$verifiedBy = null;
foreach ($session->getPlayers() as $otherPlayer) {
if ($otherPlayer->getId() === $player->getId()) {
continue;
}
$otherScreen = $otherPlayer->getScreen();
$codesSettingName = SessionSettingType::tryFrom('VerifyCodesForPlayer' . $otherScreen);
if (!$codesSettingName) {
continue;
}
$codesSetting = $this->sessionSettingRepository->getSetting($session, $codesSettingName, $otherPlayer);
if (!$codesSetting) {
continue;
}
$codes = json_decode($codesSetting->getValue() ?? '[]', true) ?? [];
if (isset($codes[$screen]) && $codes[$screen] === $code) {
$verifiedBy = $otherScreen;
break;
}
}
if ($verifiedBy !== null) {
if (!in_array($verifiedBy, $progress)) {
$progress[] = $verifiedBy;
$progressSetting->setValue(json_encode($progress));
$this->entityManager->persist($progressSetting);
$this->entityManager->flush();
$response = 'You have been successfully verified by Agent ' . $verifiedBy . '.';
if (count($progress) >= 2) {
$this->grantVerificationRights($player);
$response .= ' You have received additional rights!';
}
return $response;
} else {
return 'You were already verified by Agent ' . $verifiedBy . '.';
}
}
return 'Invalid verification code.';
}
private function grantVerificationRights(Player $player): void
{
$screen = $player->getScreen();
$rightsSettingName = SessionSettingType::tryFrom('RightsForPlayer' . $screen);
if (!$rightsSettingName) {
return;
}
$setting = $this->sessionSettingRepository->getSetting($player->getSession(), $rightsSettingName, $player);
if (!$setting) {
return;
}
$rights = json_decode($setting->getValue() ?? '[]', true) ?? [];
$newRights = ['cd', 'decode'];
$updated = false;
foreach ($newRights as $newRight) {
if (!in_array($newRight, $rights)) {
$rights[] = $newRight;
$updated = true;
}
}
if ($updated) {
$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
}
}
} }
private function goToNewDir(string $pwd, string $newPwd, Player $player) : string|bool private function goToNewDir(string $pwd, string $newPwd, Player $player) : string|bool
@@ -742,282 +311,22 @@ class GameResponseService
$paths[] = '/etc/freak'; $paths[] = '/etc/freak';
$paths[] = '/etc/host'; $paths[] = '/etc/host';
$paths[] = '/var/home'; $paths[] = '/home';
$playerNames = ['root', 'Luke', 'Charles', 'William', 'Peter']; $playerNames = ['root', 'Luke', 'Charles', 'William', 'Peter'];
$players = $player->getSession()->getPlayers(); $players = $player->getSession()->getPlayers();
foreach($players as $p) { foreach($players as $player) {
$playerNames[] = $p->getUser()->getUsername(); $playerNames[] = $player->getUser()->getUsername();
} }
$playerNames = array_unique($playerNames); $playerNames = array_unique($playerNames);
foreach($playerNames as $name) { foreach($playerNames as $name) {
$paths[] = '/var/home/' . $name; $paths[] = '/home/' . $name;
} }
return $paths; return $paths;
} }
private function isAllowedToRemove(string $file, Player $player, bool $sudo) : bool
{
if(!$this->fileExists($file, $player))
return false;
if(str_starts_with($file, '/var/rapports/'))
return false;
$rights = $this->getRechten($player);
if(in_array('sudo', $rights) || $sudo)
return true;
$sudoFiles = [
'/var/arrest/handle.sh',
'/var/arrest/cell.sh',
'/var/marriage/divorce.sh',
];
return !in_array($file, $sudoFiles);
}
private function fileExists(string $file, Player $player) : bool
{
$files = $this->getAllPossibleFiles($player);
if(in_array($file, $files))
return true;
return false;
}
private function getAllPossibleFiles(Player $player = null) : array
{
$files = [];
$files[] = '/var/arrest/handle.sh';
$files[] = '/var/arrest/bars.sh';
$files[] = '/var/arrest/cell.sh';
$files[] = '/var/marriage/share.sh';
$files[] = '/var/marriage/divorce.sh';
$files[] = '/var/rapports/095_07-14.txt';
$files[] = '/var/rapports/007_19-52.txt';
$files[] = '/var/rapports/083_25-39.txt';
$files[] = '/var/rapports/019_31-11.txt';
$files[] = '/var/rapports/075_46-77.txt';
$files[] = '/var/rapports/031_53-28.txt';
$files[] = '/var/rapports/072_61-05.txt';
$files[] = '/var/rapports/064_72-90.txt';
$files[] = '/var/rapports/091_81-33.txt';
$files[] = '/var/rapports/079_89-47.txt';
$files[] = '/var/rapports/098_92-14.txt';
$files[] = '/var/rapports/012_94-31.txt';
$files[] = '/var/rapports/016_98-07.txt';
$files[] = '/var/rapports/087_102-45.txt';
$files[] = '/var/rapports/094_110-19.txt';
$files[] = '/var/rapports/063_117-56.txt';
$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 $p) {
$files[] = '/var/home/' . $p->getUser()->getUsername() . '/verifyCodes.txt';
}
return $files;
}
private function getAllCurrentFilesInDirectory(Player $player) : array
{
$pwd = $this->playerService->getCurrentPwdOfPlayer($player);
if (!$pwd) {
return [];
}
$allPaths = $this->getAllPossiblePaths($player);
$allFiles = $this->getAllPossibleFiles($player);
$deletedFiles = $this->playerService->getDeletedFilesOfSession($player);
$entries = [];
// Find directories in current pwd
foreach ($allPaths as $path) {
if ($path === $pwd) {
continue;
}
// Check if $path is a direct child of $pwd
$parent = $this->getPrevPath($path);
if ($parent === $pwd) {
$parts = explode('/', $path);
$entries[] = [end($parts) . '/', 'dir'];
}
}
// Find files in current pwd
foreach ($allFiles as $file) {
if (in_array($file, $deletedFiles)) {
continue;
}
$parent = $this->getPrevPath($file);
if ($parent === $pwd) {
$parts = explode('/', $file);
$entries[] = [end($parts), 'file'];
}
}
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;
}
} }

View File

@@ -4,7 +4,6 @@ namespace App\Game\Service;
use App\Game\Entity\Game; use App\Game\Entity\Game;
use App\Game\Entity\Player; use App\Game\Entity\Player;
use App\Game\Entity\SessionSetting;
use App\Game\Enum\SessionSettingType; use App\Game\Enum\SessionSettingType;
use App\Game\Enum\SessionStatus; use App\Game\Enum\SessionStatus;
use App\Game\Repository\PlayerRepository; use App\Game\Repository\PlayerRepository;
@@ -40,7 +39,12 @@ class PlayerService
} }
public function getCurrentPwdOfPlayer(Player $player) : ?string { public function getCurrentPwdOfPlayer(Player $player) : ?string {
$settingName = SessionSettingType::tryFrom('PwdForPlayer' . $player->getScreen()); $settingName = match($player->getScreen()) {
1 => SessionSettingType::PWD_FOR_PLAYER1,
2 => SessionSettingType::PWD_FOR_PLAYER2,
3 => SessionSettingType::PWD_FOR_PLAYER3,
default => null,
};
if (!$settingName) { if (!$settingName) {
return null; return null;
@@ -52,7 +56,12 @@ class PlayerService
public function saveCurrentPwdOfPlayer(Player $player, string $newLocation) public function saveCurrentPwdOfPlayer(Player $player, string $newLocation)
{ {
$settingName = SessionSettingType::tryFrom('PwdForPlayer' . $player->getScreen()); $settingName = match($player->getScreen()) {
1 => SessionSettingType::PWD_FOR_PLAYER1,
2 => SessionSettingType::PWD_FOR_PLAYER2,
3 => SessionSettingType::PWD_FOR_PLAYER3,
default => null,
};
if (!$settingName) { if (!$settingName) {
return; return;
@@ -64,33 +73,4 @@ class PlayerService
$this->entityManager->persist($setting); $this->entityManager->persist($setting);
$this->entityManager->flush(); $this->entityManager->flush();
} }
public function getDeletedFilesOfSession(Player $player): array
{
$setting = $this->sessionSettingRepository->getSetting($player->getSession(), SessionSettingType::SET_OF_DELETED_FILES);
if (!$setting || !$setting->getValue()) {
return [];
}
return json_decode($setting->getValue(), true) ?? [];
}
public function addDeletedFileToSession(Player $player, string $filename): void
{
$setting = $this->sessionSettingRepository->getSetting($player->getSession(), SessionSettingType::SET_OF_DELETED_FILES);
if (!$setting) {
$setting = new SessionSetting();
$setting->setSession($player->getSession());
$setting->setName(SessionSettingType::SET_OF_DELETED_FILES);
}
$deletedFiles = json_decode($setting->getValue() ?? '[]', true) ?? [];
if (!in_array($filename, $deletedFiles)) {
$deletedFiles[] = $filename;
$setting->setValue(json_encode($deletedFiles));
$this->entityManager->persist($setting);
$this->entityManager->flush();
}
}
} }

View File

@@ -32,16 +32,4 @@ class UserRepository extends ServiceEntityRepository implements PasswordUpgrader
$this->getEntityManager()->persist($user); $this->getEntityManager()->persist($user);
$this->getEntityManager()->flush(); $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();
}
} }

View File

@@ -1,82 +0,0 @@
{% 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 %}

View File

@@ -1,49 +0,0 @@
{% 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 %}

View File

@@ -5,10 +5,6 @@
{% block body %} {% block body %}
<h1>Game Dashboard</h1> <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> <h2>Create New Session</h2>
{% if availableGames is not empty %} {% if availableGames is not empty %}
<form method="post"> <form method="post">
@@ -28,12 +24,6 @@
<p>No games available to start.</p> <p>No games available to start.</p>
{% endif %} {% endif %}
<h2>Join Session</h2>
<form method="post">
<input type="text" name="invite_code" placeholder="Enter Invite Code" required>
<button type="submit" name="join_session">Join Session</button>
</form>
<h2>Your Sessions</h2> <h2>Your Sessions</h2>
{% if sessions is not empty %} {% if sessions is not empty %}
<table> <table>
@@ -73,20 +63,6 @@
</td> </td>
<td> <td>
<a href="{{ path('game', {session: session.id}) }}">Enter Game</a> <a href="{{ path('game', {session: session.id}) }}">Enter Game</a>
{% 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> </td>
</tr> </tr>
{% endfor %} {% endfor %}

View File

@@ -1,44 +1,33 @@
<!DOCTYPE html> {% extends 'base.html.twig' %}
<html lang="{{ app.request.locale|default(app.request.defaultLocale|default('en')) }}">
<head> {% block title %}{{ 'game.title'|trans({'%site%': ('site.name'|trans)}) }}{% endblock %}
<meta charset="UTF-8">
<meta name="viewport" content="width=device-width, initial-scale=1.0">
<title>{{ 'game.title'|trans({'%site%': ('site.name'|trans)}) }}</title>
{# Include Game1-specific CSS in addition to the base app assets #} {# Include Game1-specific CSS in addition to the base app assets #}
{% block stylesheets %} {% block stylesheets %}
{{ encore_entry_link_tags('app') }} {{ parent() }}
{{ encore_entry_link_tags('game1') }} {{ encore_entry_link_tags('game1') }}
{% endblock %} {% endblock %}
</head>
<body> {% block body %}
<div id="game-container"> <h1>{{ 'game.h1'|trans }}</h1>
<p>{{ 'game.description'|trans }}</p>
<div class="game1-banner">Game 1 assets are active. Enjoy the challenge!</div>
{# Hidden config element read by assets/game1.js #}
<div id="mercure-config" <div id="mercure-config"
data-mercure-public-url="{{ mercure_public_url|e('html_attr') }}" data-mercure-public-url="{{ mercure_public_url|e('html_attr') }}"
data-topic="{{ (mercure_topic_base ~ '/game/hub-' ~ session.id)|e('html_attr') }}" data-topic="{{ (mercure_topic_base ~ '/game/hub')|e('html_attr') }}"
data-api-ping-url="{{ path('game_api_ping')|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-echo-url="{{ path('game_api_message')|e('html_attr') }}"
data-screen="{{ screen|e('html_attr') }}" data-session-id="{{ session.id }}"
style="display:none"> style="display:none">
</div> </div>
<div id="game-timer"> <p><a href="{{ path('website_home') }}">{{ 'link.back_to_website'|trans }}</a></p>
00:30:00 {% endblock %}
</div>
<div id="message-container">
</div>
<audio id="message-sound" style="display:none">
<source src="{{ asset('audio/message.mp3') }}" type="audio/mpeg">
</audio>
<div id="input">
<input type="text" disabled id="input-message">
</div>
</div>
</body>
{# Include Game1-specific JS in addition to the base app assets #} {# Include Game1-specific JS in addition to the base app assets #}
{% block javascripts %} {% block javascripts %}
{{ encore_entry_script_tags('app') }} {{ parent() }}
{{ encore_entry_script_tags('game1') }} {{ encore_entry_script_tags('game1') }}
{% endblock %} {% endblock %}

View File

@@ -1,125 +0,0 @@
{% 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 %}

View File

@@ -1,423 +0,0 @@
<?php
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;
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
{
private $entityManager;
private $gameRepository;
private $sessionRepository;
private $hub;
private $service;
protected function setUp(): void
{
$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->hub,
'http://localhost/topic'
);
}
public function testCreateSessionDoesNotInitializeSettings(): void
{
$game = new Game();
$game->setStatus(GameStatus::OPEN);
$user = new User();
$user->setUsername('testuser');
$this->entityManager->expects($this->exactly(2))
->method('persist');
// 1. Session, 2. Player
$session = $this->service->createSession($game, $user, false);
$this->assertInstanceOf(Session::class, $session);
}
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);
$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);
$this->entityManager->expects($this->exactly(1))
->method('persist');
// 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();
$session = new Session();
$session->setStatus(\App\Game\Enum\SessionStatus::CREATED);
$session->setTimer(0);
$player1 = new Player();
$player1->setUser($user);
$player1->setSession($session);
$session->addPlayer($player1);
$player2 = new Player();
$player2->setUser(new User());
$player2->setSession($session);
$session->addPlayer($player2);
$setting = new SessionSetting();
$setting->setPlayer($player1);
$setting->setSession($session);
$session->addSetting($setting);
$this->entityManager->expects($this->exactly(2))
->method('remove');
// 1. SessionSetting, 2. Player
$result = $this->service->leaveSession($session, $user);
$this->assertTrue($result);
$this->assertCount(1, $session->getPlayers());
}
public function testToggleReady(): void
{
$user = new User();
$game = new Game();
$game->setNumberOfPlayers(1);
$session = new Session();
$session->setGame($game);
$session->setStatus(SessionStatus::READY);
$player = new Player();
$player->setUser($user);
$player->setScreen(1);
$session->addPlayer($player);
$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. 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());
}
}

View File

@@ -1,107 +0,0 @@
<?php
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;
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;
use Symfony\Component\Mercure\Update;
class GameResponseServiceChatVerifyCodeTest extends TestCase
{
private $security;
private $playerService;
private $sessionSettingRepository;
private $hub;
private $entityManager;
private $service;
protected function setUp(): void
{
$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,
'H:\escapepage'
);
$_ENV['MERCURE_TOPIC_BASE'] = 'http://test';
}
public function testChatRegeneratesVerifyCodesIfShared(): void
{
$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);
$player->method('getScreen')->willReturn(1);
$player->method('getSession')->willReturn($session);
$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],
]);
// Mock verify codes
$verifyCodesSetting = new SessionSetting();
$initialCodes = ['2' => 'secret123', '3' => 'secret456'];
$verifyCodesSetting->setValue(json_encode($initialCodes));
// Setting repository map for multiple calls
$this->sessionSettingRepository->method('getSetting')
->willReturnCallback(function($s, $t, $p = null) use ($rightsSetting, $verifyCodesSetting) {
if ($t === SessionSettingType::RIGHTS_FOR_PLAYER1) return $rightsSetting;
if ($t === SessionSettingType::VERIFY_CODES_FOR_PLAYER1) return $verifyCodesSetting;
return null;
});
// Expect Mercure updates: 1 for chat, 1 for notification
$this->hub->expects($this->exactly(2))
->method('publish');
$this->entityManager->expects($this->once())
->method('flush');
$raw = json_encode(['message' => '/chat Hello look at my code secret123', 'ts' => '123']);
$result = $this->service->getGameResponse($raw);
$this->assertEquals(['result' => ['succesfully send']], $result);
$newCodes = json_decode($verifyCodesSetting->getValue(), true);
$this->assertNotEquals('secret123', $newCodes['2']);
$this->assertEquals('secret456', $newCodes['3']);
}
}

View File

@@ -1,102 +0,0 @@
<?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);
}
}