Compare commits
25
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
c6adb00219 | ||
|
|
5f6ea89179 | ||
|
|
c384fc3dd5 | ||
|
|
78b570bd75 | ||
|
|
74f52db002 | ||
|
|
56590a901f | ||
|
|
49045bc696 | ||
|
|
28ee969c29 | ||
|
|
7230520551 | ||
|
|
59c1d97d84 | ||
|
|
3de1e907f2 | ||
|
|
91c0c3e6d1 | ||
|
|
8e3807e079 | ||
|
|
10c3dbc066 | ||
|
|
af13be2196 | ||
|
|
c0aa2ad44e | ||
|
|
d3cff2ef58 | ||
|
|
24b76f9700 | ||
|
|
03994dd54e | ||
|
|
499e699dbd | ||
|
|
c8b0a6e966 | ||
|
|
5b6bfaf5ad | ||
|
|
af61a3b920 | ||
|
|
0d6628e7c9 | ||
|
|
534175efb3 |
@@ -0,0 +1,63 @@
|
||||
# In all environments, the following files are loaded if they exist,
|
||||
# the latter taking precedence over the former:
|
||||
#
|
||||
# * .env contains default values for the environment variables needed by the app
|
||||
# * .env.local uncommitted file with local overrides
|
||||
# * .env.$APP_ENV committed environment-specific defaults
|
||||
# * .env.$APP_ENV.local uncommitted environment-specific overrides
|
||||
#
|
||||
# Real environment variables win over .env files.
|
||||
#
|
||||
# DO NOT DEFINE PRODUCTION SECRETS IN THIS FILE NOR IN ANY OTHER COMMITTED FILES.
|
||||
# https://symfony.com/doc/current/configuration/secrets.html
|
||||
#
|
||||
# Run "composer dump-env prod" to compile .env files for production use (requires symfony/flex >=1.2).
|
||||
# https://symfony.com/doc/current/best_practices.html#use-environment-variables-for-infrastructure-configuration
|
||||
|
||||
###> symfony/framework-bundle ###
|
||||
APP_ENV=dev
|
||||
APP_SECRET=
|
||||
###< symfony/framework-bundle ###
|
||||
|
||||
###> doctrine/doctrine-bundle ###
|
||||
# Format described at https://www.doctrine-project.org/projects/doctrine-dbal/en/latest/reference/configuration.html#connecting-using-a-url
|
||||
# IMPORTANT: You MUST configure your server version, either here or in config/packages/doctrine.yaml
|
||||
#
|
||||
# DATABASE_URL="sqlite:///%kernel.project_dir%/var/data_%kernel.environment%.db"
|
||||
# DATABASE_URL="mysql://app:!ChangeMe!@127.0.0.1:3306/app?serverVersion=8.0.32&charset=utf8mb4"
|
||||
DATABASE_URL="mysql://escapepage:b.0nqrxJ%%2FD%%2ALuf9N@localhost:3306/escapepage?serverVersion=8.0.32&charset=utf8mb4"
|
||||
###< doctrine/doctrine-bundle ###
|
||||
|
||||
###> symfony/messenger ###
|
||||
# Choose one of the transports below
|
||||
# MESSENGER_TRANSPORT_DSN=amqp://guest:guest@localhost:5672/%2f/messages
|
||||
# MESSENGER_TRANSPORT_DSN=redis://localhost:6379/messages
|
||||
MESSENGER_TRANSPORT_DSN=doctrine://default?auto_setup=0
|
||||
###< symfony/messenger ###
|
||||
|
||||
###> symfony/mailer ###
|
||||
# Development: use Mailpit (docker compose override provides service `mailer` on port 1025)
|
||||
MAILER_DSN=smtp://mailer:1025
|
||||
# Production/Stage (uncomment and set SENDGRID_API_KEY in real env or secrets):
|
||||
# MAILER_DSN=sendgrid+api://%env(SENDGRID_API_KEY)%
|
||||
# Alternatively, via SMTP (no extra package needed):
|
||||
# MAILER_DSN="smtp://apikey:%env(SENDGRID_API_KEY)%@smtp.sendgrid.net:587?encryption=tls"
|
||||
# Optional default sender (used by test command if --from not passed):
|
||||
# MAILER_FROM=no-reply@your-domain.tld
|
||||
# SENDGRID_API_KEY=your_real_key_goes_here # Do NOT commit this; set in .env.local or deployment env
|
||||
###< symfony/mailer ###
|
||||
|
||||
###> symfony/sendgrid-mailer ###
|
||||
# MAILER_DSN=sendgrid://KEY@default
|
||||
###< symfony/sendgrid-mailer ###
|
||||
|
||||
###> mercure ###
|
||||
# Internal hub URL used by the PHP app (reachable from the php container)
|
||||
MERCURE_URL=http://mercure/.well-known/mercure
|
||||
# Public hub URL used by browsers
|
||||
MERCURE_PUBLIC_URL=http://localhost:8090/.well-known/mercure
|
||||
# Shared secret for signing JWTs (dev only). In prod, set via real env/secrets.
|
||||
MERCURE_JWT_SECRET=!ChangeThisMercureJWT!
|
||||
# Base URL for Mercure topics. Use .dev in development; override to .com in prod via .env.prod or real env.
|
||||
MERCURE_TOPIC_BASE=https://escapepage.dev
|
||||
###< mercure ###
|
||||
@@ -0,0 +1,4 @@
|
||||
|
||||
###> symfony/framework-bundle ###
|
||||
APP_SECRET=620e9ce5f88a714b636179eb39d5be4f
|
||||
###< symfony/framework-bundle ###
|
||||
@@ -0,0 +1,9 @@
|
||||
### Compiled or real environment variables should be used in production.
|
||||
### Configure MAILER_DSN to use SendGrid API transport.
|
||||
### Prefer storing SENDGRID_API_KEY using Symfony Secrets or real env vars.
|
||||
|
||||
###> symfony/mailer ###
|
||||
# Example using SendGrid API key (replace with real secret via vault/secrets):
|
||||
# SENDGRID_API_KEY=SG.xxxxx
|
||||
MAILER_DSN=sendgrid+api://%env(resolve:SENDGRID_API_KEY)%@default
|
||||
###< symfony/mailer ###
|
||||
@@ -0,0 +1,3 @@
|
||||
# define your env variables for the test env here
|
||||
KERNEL_CLASS='App\Kernel'
|
||||
APP_SECRET='$ecretf0rt3st'
|
||||
@@ -39,13 +39,6 @@ final class GameController extends AbstractController
|
||||
$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')) {
|
||||
$sessionId = $request->request->get('session_id');
|
||||
$session = $sessionRepository->find($sessionId);
|
||||
@@ -59,17 +52,6 @@ final class GameController extends AbstractController
|
||||
if ($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).');
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return $this->redirectToRoute('game_dashboard');
|
||||
|
||||
@@ -12,13 +12,4 @@ enum SessionSettingType: string
|
||||
case RIGHTS_FOR_PLAYER3 = 'RightsForPlayer3';
|
||||
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 VERIFY_CODES_FOR_PLAYER1 = 'VerifyCodesForPlayer1';
|
||||
case VERIFY_CODES_FOR_PLAYER2 = 'VerifyCodesForPlayer2';
|
||||
case VERIFY_CODES_FOR_PLAYER3 = 'VerifyCodesForPlayer3';
|
||||
case VERIFICATION_PROGRESS_FOR_PLAYER1 = 'VerificationProgressForPlayer1';
|
||||
case VERIFICATION_PROGRESS_FOR_PLAYER2 = 'VerificationProgressForPlayer2';
|
||||
case VERIFICATION_PROGRESS_FOR_PLAYER3 = 'VerificationProgressForPlayer3';
|
||||
}
|
||||
|
||||
@@ -71,193 +71,11 @@ final class GameDashboardService
|
||||
|
||||
$this->entityManager->persist($session);
|
||||
$this->entityManager->persist($player);
|
||||
|
||||
$this->initializePlayerSettings($player);
|
||||
|
||||
$this->entityManager->flush();
|
||||
|
||||
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 >= 3) {
|
||||
return false; // Session full
|
||||
}
|
||||
|
||||
$player = new Player();
|
||||
$player->setUser($user);
|
||||
$player->setSession($session);
|
||||
$player->setScreen($playerCount + 1);
|
||||
|
||||
$this->entityManager->persist($player);
|
||||
$this->initializePlayerSettings($player);
|
||||
|
||||
$this->entityManager->flush();
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
public function leaveSession(Session $session, UserInterface $user): bool
|
||||
{
|
||||
if (!$user instanceof User) {
|
||||
return false;
|
||||
}
|
||||
|
||||
if ($session->getStatus() !== SessionStatus::CREATED || $session->getTimer() > 0) {
|
||||
return false;
|
||||
}
|
||||
|
||||
$playerToDelete = null;
|
||||
foreach ($session->getPlayers() as $player) {
|
||||
if ($player->getUser() === $user) {
|
||||
$playerToDelete = $player;
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
if (!$playerToDelete) {
|
||||
return false;
|
||||
}
|
||||
|
||||
// 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 = match ($screen) {
|
||||
1 => SessionSettingType::RIGHTS_FOR_PLAYER1,
|
||||
2 => SessionSettingType::RIGHTS_FOR_PLAYER2,
|
||||
3 => SessionSettingType::RIGHTS_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
|
||||
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 = match ($screen) {
|
||||
1 => SessionSettingType::PWD_FOR_PLAYER1,
|
||||
2 => SessionSettingType::PWD_FOR_PLAYER2,
|
||||
3 => SessionSettingType::PWD_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
|
||||
if ($pwdSettingName) {
|
||||
$setting = new SessionSetting();
|
||||
$setting->setSession($player->getSession());
|
||||
$setting->setPlayer($player);
|
||||
$setting->setName($pwdSettingName);
|
||||
$setting->setValue('home/' . $player->getUser()->getUserIdentifier());
|
||||
$this->entityManager->persist($setting);
|
||||
}
|
||||
|
||||
$chatTrackingSettingName = match ($screen) {
|
||||
1 => SessionSettingType::CHAT_TRACKING_FOR_PLAYER1,
|
||||
2 => SessionSettingType::CHAT_TRACKING_FOR_PLAYER2,
|
||||
3 => SessionSettingType::CHAT_TRACKING_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
|
||||
if ($chatTrackingSettingName) {
|
||||
$setting = new SessionSetting();
|
||||
$setting->setSession($player->getSession());
|
||||
$setting->setPlayer($player);
|
||||
$setting->setName($chatTrackingSettingName);
|
||||
$setting->setValue(json_encode([]));
|
||||
$this->entityManager->persist($setting);
|
||||
}
|
||||
|
||||
$verifyCodesSettingName = match ($screen) {
|
||||
1 => SessionSettingType::VERIFY_CODES_FOR_PLAYER1,
|
||||
2 => SessionSettingType::VERIFY_CODES_FOR_PLAYER2,
|
||||
3 => SessionSettingType::VERIFY_CODES_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
|
||||
if ($verifyCodesSettingName) {
|
||||
$codes = [];
|
||||
for ($i = 1; $i <= 3; $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 = match ($screen) {
|
||||
1 => SessionSettingType::VERIFICATION_PROGRESS_FOR_PLAYER1,
|
||||
2 => SessionSettingType::VERIFICATION_PROGRESS_FOR_PLAYER2,
|
||||
3 => SessionSettingType::VERIFICATION_PROGRESS_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
|
||||
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 generateInviteCode(Session $session, UserInterface $user, bool $isAdmin): ?string
|
||||
{
|
||||
// Security check: is user part of this session?
|
||||
|
||||
@@ -5,10 +5,8 @@ namespace App\Game\Service;
|
||||
use App\Game\Enum\DecodeMessage;
|
||||
use App\Game\Enum\SessionSettingType;
|
||||
use App\Game\Entity\Player;
|
||||
use App\Game\Entity\SessionSetting;
|
||||
use App\Game\Repository\SessionSettingRepository;
|
||||
use App\Tech\Entity\User;
|
||||
use Doctrine\ORM\EntityManagerInterface;
|
||||
use Symfony\Bundle\SecurityBundle\Security;
|
||||
use Symfony\Component\Mercure\HubInterface;
|
||||
use Symfony\Component\Mercure\Update;
|
||||
@@ -20,7 +18,6 @@ class GameResponseService
|
||||
private PlayerService $playerService,
|
||||
private SessionSettingRepository $sessionSettingRepository,
|
||||
private HubInterface $hub,
|
||||
private EntityManagerInterface $entityManager,
|
||||
) {
|
||||
}
|
||||
|
||||
@@ -104,7 +101,7 @@ class GameResponseService
|
||||
if(!in_array('verify', $rechten))
|
||||
return ['result' => ['Unknown command']];
|
||||
|
||||
$result = $this->handleVerifyMessage($message, $player);
|
||||
$result = $this->handleVerifyMessage($message);
|
||||
return ['result' => [$result]];
|
||||
default:
|
||||
return ['result' => ['Unknown command']];
|
||||
@@ -278,10 +275,9 @@ class GameResponseService
|
||||
|
||||
if ($toSingle) {
|
||||
$sendTo = array_shift($messageParts);
|
||||
$chatMessage = array_shift($messageParts);
|
||||
}
|
||||
|
||||
$message = $player->getUser()->getUsername() . ': ' . $chatMessage . ' ';
|
||||
$message = $player->getUser()->getUsername() . ': ' . $chatMessage;
|
||||
foreach($messageParts as $messagePart) {
|
||||
$message .= $messagePart . ' ';
|
||||
}
|
||||
@@ -296,146 +292,9 @@ class GameResponseService
|
||||
$topic = $_ENV['MERCURE_TOPIC_BASE'] . '/game/hub-' . $activeGame;
|
||||
$this->hub->publish(new Update($topic, json_encode([$sendTo, $message])));
|
||||
|
||||
$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 = match ($screen) {
|
||||
1 => SessionSettingType::VERIFY_CODES_FOR_PLAYER1,
|
||||
2 => SessionSettingType::VERIFY_CODES_FOR_PLAYER2,
|
||||
3 => SessionSettingType::VERIFY_CODES_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
|
||||
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 = $_ENV['MERCURE_TOPIC_BASE'] . '/game/hub-' . $session->getId();
|
||||
$notification = "Security Alert: One of your verify codes was shared and has been regenerated.";
|
||||
// We send it only to this player (screen)
|
||||
$this->hub->publish(new Update($topic, json_encode([$screen, $notification])));
|
||||
}
|
||||
}
|
||||
|
||||
private function updateChatTracking(Player $player, int $sendTo): void
|
||||
{
|
||||
$rights = $this->getRechten($player);
|
||||
if(in_array('verify', $rights))
|
||||
return;
|
||||
|
||||
$trackingSettingName = match ($player->getScreen()) {
|
||||
1 => SessionSettingType::CHAT_TRACKING_FOR_PLAYER1,
|
||||
2 => SessionSettingType::CHAT_TRACKING_FOR_PLAYER2,
|
||||
3 => SessionSettingType::CHAT_TRACKING_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
|
||||
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
|
||||
for ($i = 1; $i <= 3; $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 = match ($screen) {
|
||||
1 => SessionSettingType::RIGHTS_FOR_PLAYER1,
|
||||
2 => SessionSettingType::RIGHTS_FOR_PLAYER2,
|
||||
3 => SessionSettingType::RIGHTS_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
|
||||
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)
|
||||
{
|
||||
$userNumber = $player->getScreen();
|
||||
@@ -468,123 +327,9 @@ class GameResponseService
|
||||
return $randomString;
|
||||
}
|
||||
|
||||
private function handleVerifyMessage(string $message, Player $player) : string
|
||||
private function handleVerifyMessage(string $message) : string
|
||||
{
|
||||
$messageParts = explode(' ', $message);
|
||||
if (count($messageParts) < 2) {
|
||||
return 'Usage: /verify {code}';
|
||||
}
|
||||
|
||||
$code = $messageParts[1];
|
||||
$screen = $player->getScreen();
|
||||
$session = $player->getSession();
|
||||
|
||||
$progressSettingName = match ($screen) {
|
||||
1 => SessionSettingType::VERIFICATION_PROGRESS_FOR_PLAYER1,
|
||||
2 => SessionSettingType::VERIFICATION_PROGRESS_FOR_PLAYER2,
|
||||
3 => SessionSettingType::VERIFICATION_PROGRESS_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
|
||||
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 = match ($otherScreen) {
|
||||
1 => SessionSettingType::VERIFY_CODES_FOR_PLAYER1,
|
||||
2 => SessionSettingType::VERIFY_CODES_FOR_PLAYER2,
|
||||
3 => SessionSettingType::VERIFY_CODES_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
|
||||
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 = match ($screen) {
|
||||
1 => SessionSettingType::RIGHTS_FOR_PLAYER1,
|
||||
2 => SessionSettingType::RIGHTS_FOR_PLAYER2,
|
||||
3 => SessionSettingType::RIGHTS_FOR_PLAYER3,
|
||||
default => null,
|
||||
};
|
||||
|
||||
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();
|
||||
}
|
||||
return '';
|
||||
}
|
||||
|
||||
private function goToNewDir(string $pwd, string $newPwd, Player $player) : string|bool
|
||||
@@ -667,7 +412,7 @@ class GameResponseService
|
||||
|
||||
private function isAllowedToRemove(string $file, Player $player, bool $sudo) : bool
|
||||
{
|
||||
if(!$this->fileExists($file, $player))
|
||||
if(!$this->fileExists($file))
|
||||
return false;
|
||||
|
||||
if(str_starts_with($file, '/var/rapports/'))
|
||||
@@ -687,9 +432,9 @@ class GameResponseService
|
||||
return !in_array($file, $sudoFiles);
|
||||
}
|
||||
|
||||
private function fileExists(string $file, Player $player) : bool
|
||||
private function fileExists(string $file)
|
||||
{
|
||||
$files = $this->getAllPossibleFiles($player);
|
||||
$files = $this->getAllPossibleFiles();
|
||||
|
||||
if(in_array($file, $files))
|
||||
return true;
|
||||
@@ -697,7 +442,7 @@ class GameResponseService
|
||||
return false;
|
||||
}
|
||||
|
||||
private function getAllPossibleFiles(Player $player = null) : array
|
||||
private function getAllPossibleFiles()
|
||||
{
|
||||
$files = [];
|
||||
|
||||
@@ -727,12 +472,6 @@ class GameResponseService
|
||||
$files[] = '/var/rapports/001_145-93.txt';
|
||||
$files[] = '/var/rapports/index.txt';
|
||||
|
||||
$players = $player->getSession()->getPlayers();
|
||||
|
||||
foreach($players as $player) {
|
||||
$files[] = '/var/home/' . $player->getUser()->getUsername() . '/verifyCodes.txt';
|
||||
}
|
||||
|
||||
return $files;
|
||||
}
|
||||
|
||||
|
||||
@@ -24,12 +24,6 @@
|
||||
<p>No games available to start.</p>
|
||||
{% 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>
|
||||
{% if sessions is not empty %}
|
||||
<table>
|
||||
@@ -69,12 +63,6 @@
|
||||
</td>
|
||||
<td>
|
||||
<a href="{{ path('game', {session: session.id}) }}">Enter Game</a>
|
||||
{% if session.status.value == 'created' and session.timer == 0 %}
|
||||
<form method="post" style="display:inline;">
|
||||
<input type="hidden" name="session_id" value="{{ session.id }}">
|
||||
<button type="submit" name="leave_session" onclick="return confirm('Are you sure you want to leave this session?')">Leave Session</button>
|
||||
</form>
|
||||
{% endif %}
|
||||
</td>
|
||||
</tr>
|
||||
{% endfor %}
|
||||
|
||||
@@ -1,135 +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\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 PHPUnit\Framework\TestCase;
|
||||
|
||||
class GameDashboardServiceTest extends TestCase
|
||||
{
|
||||
private $entityManager;
|
||||
private $gameRepository;
|
||||
private $sessionRepository;
|
||||
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->service = new GameDashboardService(
|
||||
$this->gameRepository,
|
||||
$this->sessionRepository,
|
||||
$this->entityManager
|
||||
);
|
||||
}
|
||||
|
||||
public function testCreateSessionInitializesRightsAndPwd(): void
|
||||
{
|
||||
$game = new Game();
|
||||
$game->setStatus(GameStatus::OPEN);
|
||||
|
||||
$user = new User();
|
||||
$user->setUsername('testuser');
|
||||
|
||||
$this->entityManager->expects($this->exactly(7))
|
||||
->method('persist');
|
||||
// 1. Session, 2. Player, 3. SessionSetting (rights), 4. SessionSetting (pwd), 5. SessionSetting (chat tracking), 6. SessionSetting (verify codes), 7. SessionSetting (verification progress)
|
||||
|
||||
$session = $this->service->createSession($game, $user, false);
|
||||
|
||||
$this->assertInstanceOf(Session::class, $session);
|
||||
}
|
||||
|
||||
public function testJoinSessionInitializesRightsAndPwd(): void
|
||||
{
|
||||
$user = new User();
|
||||
$user->setUsername('testuser');
|
||||
$session = new Session();
|
||||
|
||||
$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(6))
|
||||
->method('persist');
|
||||
// 1. Player, 2. SessionSetting (rights), 3. SessionSetting (pwd), 4. SessionSetting (chat tracking), 5. SessionSetting (verify codes), 6. SessionSetting (verification progress)
|
||||
|
||||
$result = $this->service->joinSession('abc-123', $user);
|
||||
|
||||
$this->assertTrue($result);
|
||||
}
|
||||
|
||||
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 testLeaveSessionDeletesSessionIfLastPlayer(): void
|
||||
{
|
||||
$user = new User();
|
||||
$session = new Session();
|
||||
$session->setStatus(\App\Game\Enum\SessionStatus::CREATED);
|
||||
$session->setTimer(0);
|
||||
|
||||
$player = new Player();
|
||||
$player->setUser($user);
|
||||
$player->setSession($session);
|
||||
$session->addPlayer($player);
|
||||
|
||||
$this->entityManager->expects($this->exactly(2))
|
||||
->method('remove');
|
||||
// 1. Player, 2. Session
|
||||
|
||||
$result = $this->service->leaveSession($session, $user);
|
||||
|
||||
$this->assertTrue($result);
|
||||
}
|
||||
}
|
||||
@@ -1,101 +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;
|
||||
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
|
||||
);
|
||||
|
||||
$_ENV['MERCURE_TOPIC_BASE'] = 'http://test';
|
||||
}
|
||||
|
||||
public function testChatRegeneratesVerifyCodesIfShared(): void
|
||||
{
|
||||
$user = new User();
|
||||
$user->setUsername('testuser');
|
||||
|
||||
$session = $this->createMock(Session::class);
|
||||
$session->method('getId')->willReturn(123);
|
||||
|
||||
$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']);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user