src/Controller/Admin/PresenceController.php line 24

Open in your IDE?
  1. <?php
  3. namespace App\Controller\Admin;
  5. use App\Service\PresenceService;
  6. use Psr\Cache\InvalidArgumentException;
  7. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  8. use Symfony\Component\HttpFoundation\JsonResponse;
  9. use Symfony\Component\Mercure\HubInterface;
  10. use Symfony\Component\Mercure\Update;
  11. use Symfony\Component\HttpFoundation\Request;
  12. use Symfony\Component\Routing\Annotation\Route;
  14. class PresenceController extends AbstractController
  15. {
  16. public function __construct(private readonly PresenceService $presenceService)
  17. {
  18. }
  20. /**
  21. * @Route("/presence", name="api_presence_update", methods={"POST"})
  22. * @throws InvalidArgumentException
  23. */
  24. public function updatePresence(Request $request, HubInterface $hub): JsonResponse
  25. {
  26. $data = json_decode($request->getContent(), true);
  27. $userId = $data['userId'] ?? null;
  28. $status = $data['status'] ?? null;
  30. if (!$userId || $status === null) {
  31. return new JsonResponse(['error' => 'Missing userId or status'], 400);
  32. }
  34. if ($status) {
  35. $this->presenceService->markOnline($userId);
  36. } else {
  37. $this->presenceService->markOffline($userId);
  38. }
  40. $hub->publish(new Update(
  41. 'presence',
  42. json_encode(['userId' => $userId, 'status' => $status])
  43. ));
  45. return new JsonResponse([
  46. 'success' => true,
  47. 'userId' => $userId,
  48. 'status' => $status
  49. ]);
  50. }
  52. /**
  53. * @Route("/presence", name="api_presence_list", methods={"GET"})
  54. * @throws InvalidArgumentException
  55. */
  56. public function listOnlineUsers(): JsonResponse
  57. {
  58. $onlineUsers = $this->presenceService->getOnlineUsers();
  59. return new JsonResponse(array_keys($onlineUsers));
  60. }
  61. }