src/Controller/Api/ConversationsController.php line 56

Open in your IDE?
  1. <?php
  3. namespace App\Controller\Api;
  5. use App\Entity\Core\Notifications;
  6. use App\Entity\Core\Users;
  7. use App\Entity\Cvs\Candidates;
  8. use App\Entity\Messenger\Groups;
  9. use App\Entity\Messenger\Messages;
  10. use App\Services\Dossiers;
  11. use App\Services\NotificationService;
  12. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Cache;
  13. use Sensio\Bundle\FrameworkExtraBundle\Configuration\IsGranted;
  14. use Sensio\Bundle\FrameworkExtraBundle\Configuration\ParamConverter;
  15. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  16. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  17. use Symfony\Component\HttpFoundation\Request;
  18. use Symfony\Component\HttpFoundation\Response;
  19. use Symfony\Component\Routing\Annotation\Route;
  20. use Symfony\Component\HttpFoundation\JsonResponse;
  21. use Doctrine\ORM\EntityManagerInterface;
  22. use Knp\Component\Pager\PaginatorInterface;
  23. use Symfony\Component\Form\Extension\Core\Type\CheckboxType;
  24. use Symfony\Component\Form\Extension\Core\Type\ChoiceType;
  25. use Symfony\Component\Form\Extension\Core\Type\DateTimeType;
  26. use Symfony\Component\Form\Extension\Core\Type\EmailType;
  27. use Symfony\Component\Form\Extension\Core\Type\HiddenType;
  28. use Symfony\Component\Form\Extension\Core\Type\NumberType;
  29. use Symfony\Component\Form\Extension\Core\Type\SubmitType;
  30. use Symfony\Component\Form\Extension\Core\Type\TextareaType;
  31. use Symfony\Component\Form\Extension\Core\Type\TextType;
  32. use Symfony\Component\HttpFoundation\Session\Session;
  34. class ConversationsController extends AbstractController
  35. {
  37.     private $em;
  38.     private $paginator;
  39.     private $dossier;
  40.     private $notificationService;
  42.     public function __construct(EntityManagerInterface $em,
  43.                                 Dossiers $dossier,
  44.                                 PaginatorInterface $paginator,
  45.                                 NotificationService $notificationService
  46.     ) {
  47.         $this->em = $em;
  48.         $this->paginator = $paginator;
  49.         $this->dossier = $dossier;
  50.         $this->notificationService = $notificationService;
  51.     }
  53.     /**
  54.      * Liste des conversations récentes de l'utilisateur connecté
  55.      */
  56.     public function recents(Request $request): JsonResponse
  57.     {
  58.         $user = $this->getUser();
  59.         $limit = $request->query->get('limit', 20);
  61.         $conversations = $this->em->getRepository(Groups::class)->recents($user, $limit);
  63.         $array = [];
  64.         foreach ($conversations as $conversation) {
  66.             $otherUser = $conversation->getOtherUser($user);
  68.             if (!$otherUser) {
  69.                 continue;
  70.             }
  72.             $countMessages = $this->em->getRepository(Messages::class)->countByConversation($conversation);
  73.             $fullname =  $otherUser->getName()." ". $otherUser->getLastname();
  75.             $avatar = "data:image/svg+xml;base64,PHN2ZyB3aWR0aD0iMjAwIiBoZWlnaHQ9IjIwMCIgdmlld0JveD0iMCAwIDIwMCAyMDAiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyI+CiAgPGRlZnM+CiAgICA8bGluZWFyR3JhZGllbnQgaWQ9ImdyYWQiIHgxPSIwJSIgeTE9IjAlIiB4Mj0iMTAwJSIgeTI9IjEwMCUiPgogICAgICA8c3RvcCBvZmZzZXQ9IjAlIiBzdHlsZT0ic3RvcC1jb2xvcjojNjY3ZWVhO3N0b3Atb3BhY2l0eToxIiAvPgogICAgICA8c3RvcCBvZmZzZXQ9IjEwMCUiIHN0eWxlPSJzdG9wLWNvbG9yOiM3NjRiYTI7c3RvcC1vcGFjaXR5OjEiIC8+CiAgICA8L2xpbmVhckdyYWRpZW50PgogIDwvZGVmcz4KICA8Y2lyY2xlIGN4PSIxMDAiIGN5PSIxMDAiIHI9IjEwMCIgZmlsbD0idXJsKCNncmFkKSIvPgogIDxnIHRyYW5zZm9ybT0idHJhbnNsYXRlKDEwMCwgMTAwKSI+CiAgICA8Y2lyY2xlIGN4PSIwIiBjeT0iLTE1IiByPSIzNSIgZmlsbD0iI2ZmZmZmZiIgb3BhY2l0eT0iMC45Ii8+CiAgICA8cGF0aCBkPSJNIC01MCA2NSBRIC01MCAyNSAtMzUgMTAgUSAtMTUgLTUgMCAtNSBRIDE1IC01IDM1IDEwIFEgNTAgMjUgNTAgNjUgWiIgZmlsbD0iI2ZmZmZmZiIgb3BhY2l0eT0iMC45Ii8+CiAgPC9nPgo8L3N2Zz4K";
  76.             if ($otherUser->getImage()) {
  77.                 $avatar = $otherUser->getImageBase64();
  78.             }
  80.             $array[] = [
  81.                 "id" => (string)$conversation->getId(),
  82.                 "conversationHash" => $conversation->getConversationHash(),
  83.                 "title" => $conversation->getTitle() ?: 'Conversation avec ' . $fullname,
  84.                 "fullname" => $fullname,
  85.                 "userId" => $otherUser->getId(),
  86.                 "userEmail" => $otherUser->getEmail(),
  87.                 "avatar" => $avatar,
  88.                 "count_messages" => $countMessages,
  89.                 "open" => false,
  90.                 "lastmessage" => $conversation->getLastMessageContent() ?? '',
  91.                 "lastMessageAt" => $conversation->getLastMessageAt() ? $conversation->getLastMessageAt()->format('c') : null,
  92.                 "createdAt" => $conversation->getCreatedAt() ? $conversation->getCreatedAt()->format('c') : null,
  93.             ];
  94.         }
  96.         return new JsonResponse($array);
  97.     }
  99.     /**
  100.      * Obtenir la configuration pour une conversation
  101.      */
  102.     public function getConfig(int $id): JsonResponse
  103.     {
  104.         $user = $this->getUser();
  106.         if (!$user) {
  107.             return new JsonResponse(['error' => 'Non authentifié'], Response::HTTP_UNAUTHORIZED);
  108.         }
  110.         $conversation = $this->em->getRepository(Groups::class)->find($id);
  112.         if (!$conversation) {
  113.             return new JsonResponse(['error' => 'Conversation non trouvée'], Response::HTTP_NOT_FOUND);
  114.         }
  116.         if (!$conversation->hasUser($user)) {
  117.             return new JsonResponse(['error' => 'Accès interdit'], Response::HTTP_FORBIDDEN);
  118.         }
  120.         $otherUser = $conversation->getOtherUser($user);
  122.         if (!$otherUser) {
  123.             return new JsonResponse(['error' => 'Interlocuteur introuvable'], Response::HTTP_NOT_FOUND);
  124.         }
  126.         $fullname = $otherUser->getName()." ".$otherUser->getLastname();
  128.         $avatar = "data:image/svg+xml;base64,PHN2ZyB3aWR0aD0iMjAwIiBoZWlnaHQ9IjIwMCIgdmlld0JveD0iMCAwIDIwMCAyMDAiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyI+CiAgPGRlZnM+CiAgICA8bGluZWFyR3JhZGllbnQgaWQ9ImdyYWQiIHgxPSIwJSIgeTE9IjAlIiB4Mj0iMTAwJSIgeTI9IjEwMCUiPgogICAgICA8c3RvcCBvZmZzZXQ9IjAlIiBzdHlsZT0ic3RvcC1jb2xvcjojNjY3ZWVhO3N0b3Atb3BhY2l0eToxIiAvPgogICAgICA8c3RvcCBvZmZzZXQ9IjEwMCUiIHN0eWxlPSJzdG9wLWNvbG9yOiM3NjRiYTI7c3RvcC1vcGFjaXR5OjEiIC8+CiAgICA8L2xpbmVhckdyYWRpZW50PgogIDwvZGVmcz4KICA8Y2lyY2xlIGN4PSIxMDAiIGN5PSIxMDAiIHI9IjEwMCIgZmlsbD0idXJsKCNncmFkKSIvPgogIDxnIHRyYW5zZm9ybT0idHJhbnNsYXRlKDEwMCwgMTAwKSI+CiAgICA8Y2lyY2xlIGN4PSIwIiBjeT0iLTE1IiByPSIzNSIgZmlsbD0iI2ZmZmZmZiIgb3BhY2l0eT0iMC45Ii8+CiAgICA8cGF0aCBkPSJNIC01MCA2NSBRIC01MCAyNSAtMzUgMTAgUSAtMTUgLTUgMCAtNSBRIDE1IC01IDM1IDEwIFEgNTAgMjUgNTAgNjUgWiIgZmlsbD0iI2ZmZmZmZiIgb3BhY2l0eT0iMC45Ii8+CiAgPC9nPgo8L3N2Zz4K";
  129.         if ($otherUser->getImage()) {
  130.             $avatar = $otherUser->getImageBase64();
  131.         }
  133.         $config = [
  134.             'groupId' => (string) $conversation->getId(),
  135.             'userId' => $user->getId(),
  136.             'conversationHash' => $conversation->getConversationHash(),
  137.             'title' => $conversation->getTitle() ?: 'Conversation avec ' . $fullname,
  138.             'otherUser' => [
  139.                 'id' => $otherUser->getId(),
  140.                 'name' => $otherUser->getName(),
  141.                 'lastname' => $otherUser->getLastname(),
  142.                 'fullname' => $fullname,
  143.                 'email' => $otherUser->getEmail(),
  144.                 'avatar' => $avatar,
  145.             ],
  146.             'urls' => [
  147.                 'api' => $_ENV["WEBSOCKET_MESSENGER_WS"],
  148.                 'ws' => $_ENV["WEBSOCKET_MESSENGER_WS"],
  149.             ],
  150.             'createdAt' => $conversation->getCreatedAt() ? $conversation->getCreatedAt()->format('c') : null,
  151.             'lastMessageAt' => $conversation->getLastMessageAt() ? $conversation->getLastMessageAt()->format('c') : null,
  152.         ];
  154.         error_log('✅ [Config] Configuration envoyée pour conversation ' . $conversation->getId());
  155.         error_log('   User ID: ' . $user->getId());
  156.         error_log('   WS URL: ' . $config['urls']['ws']);
  158.         return new JsonResponse($config);
  159.     }
  161.     /**
  162.      * Afficher les messages d'une conversation
  163.      */
  164.     public function show(Request $request, int $id): JsonResponse
  165.     {
  166.         $user = $this->getUser();
  168.         $conversation = $this->em->getRepository(Groups::class)->find($id);
  170.         if (!$conversation) {
  171.             return new JsonResponse(['error' => 'Conversation non trouvée'], Response::HTTP_NOT_FOUND);
  172.         }
  174.         if (!$conversation->hasUser($user)) {
  175.             return new JsonResponse(['error' => 'Accès interdit'], Response::HTTP_FORBIDDEN);
  176.         }
  178.         $limit = $request->query->get('limit', 100);
  179.         $offset = $request->query->get('offset', 0);
  181.         $messages = $this->em->getRepository(Messages::class)->findByConversation($conversation, $limit, $offset);
  183.         $array = [];
  184.         foreach ($messages as $message) {
  186.             $isOwn = $message->getUser()->getId() === $user->getId();
  187.             $fullname =  $message->getUser()->getName()." ". $message->getUser()->getLastname();
  189.             $avatar = $this->getDefaultAvatar();
  190.             if ($message->getUser()->getImage()) {
  191.                 $avatar = $message->getUser()->getImageBase64();
  192.             }
  194.             $array[] = [
  195.                 "id" => (string)$message->getId(),
  196.                 "message" => (string)$message->getMessage(),
  197.                 "isOwn" => $isOwn,
  198.                 "userId" => $message->getUser()->getId(),
  199.                 "userName" => $fullname,
  200.                 "avatar" => $avatar,
  201.                 "createdAt" => $message->getCreatedAt() ? $message->getCreatedAt()->format('c') : null,
  202.             ];
  203.         }
  205.         return new JsonResponse($array);
  206.     }
  208.     /**
  209.      * Envoyer un message
  210.      */
  211.     public function sendMessage(Request $request, int $id): JsonResponse
  212.     {
  213.         $user = $this->getUser();
  215.         $conversation = $this->em->getRepository(Groups::class)->find($id);
  217.         if (!$conversation) {
  218.             return new JsonResponse(['error' => 'Conversation non trouvée'], Response::HTTP_NOT_FOUND);
  219.         }
  221.         if (!$conversation->hasUser($user)) {
  222.             return new JsonResponse(['error' => 'Accès interdit'], Response::HTTP_FORBIDDEN);
  223.         }
  225.         $data = json_decode($request->getContent(), true);
  226.         $messageText = $data['message'] ?? null;
  228.         if (empty($messageText)) {
  229.             return new JsonResponse(['error' => 'Message vide'], Response::HTTP_BAD_REQUEST);
  230.         }
  232.         $emetteur = $user;
  233.         $destinataire = null;
  235.         if($conversation->getUserOne() !== $user) {
  236.             $destinataire = $conversation->getUserOne();
  237.         }
  239.         if($conversation->getUserTwo() !== $user) {
  240.             $destinataire = $conversation->getUserTwo();
  241.         }
  243.         // Créer le message
  244.         $message = new Messages();
  245.         $message->setMessage($messageText);
  246.         $message->setUser($user);
  247.         $message->setGroup($conversation);
  248.         $message->setCreatedAt(new \DateTime());
  249.         $this->em->persist($message);
  250.         $this->em->flush();
  252.         // Mettre à jour la conversation (avec le nouveau champ lastMessageSenderId)
  253.         $conversation->setLastMessageContent(substr($messageText, 0, 100));
  254.         $conversation->setLastMessageId($message->getId());
  255.         $conversation->setLastMessageAt(new \DateTime());
  256.         $conversation->setLastMessageSenderId($user->getId());  // ← NOUVEAU
  257.         $this->em->persist($conversation);
  258.         $this->em->flush();
  260.         // Vers le destinataire
  261.         $notification = new Notifications();
  262.         $notification->setViewed(false);
  263.         $notification->setOnlyAdmin(false);
  264.         $notification->setTitle("message");
  265.         if($conversation->getUserOne()->getLanguage() == "fr") {
  266.             $notification->setDescription("Message reçu par ".$emetteur->getName()." ".$emetteur->getLastname());
  267.             $this->notificationService->sendToUser(
  268.                 $destinataire,
  269.                 'Nouveau message',
  270.                 $this->cleanMessageNotification($message->getMessage()),
  271.                 ['type' => 'message', 'conversationId' => $conversation->getId()],
  272.             );
  273.         } else {
  274.             $this->notificationService->sendToUser(
  275.                 $destinataire,
  276.                 'New message',
  277.                 $this->cleanMessageNotification($message->getMessage()),
  278.                 ['type' => 'message', 'conversationId' => $conversation->getId()],
  279.             );
  280.             $notification->setDescription("Message received by ".$emetteur->getName()." ".$emetteur->getLastname());
  281.         }
  282.         $notification->setType("default");
  283.         $notification->setUser($conversation->getUserTwo());
  284.         $this->em->persist($notification);
  285.         $this->em->flush();
  287.         $fullname = $user->getName()." ".$user->getLastname();
  289.         $avatar = $this->getDefaultAvatar();
  290.         if ($user->getImage()) {
  291.             $avatar = $user->getImageBase64();
  292.         }
  294.         try {
  295.             $client = new \GuzzleHttp\Client([
  296.                 'timeout' => 5.0,
  297.                 'verify' => false,
  298.             ]);
  300.             $websocketUrl = $_ENV["WEBSOCKET_HTTP_URL"].'/broadcast';
  302.             error_log("╔═══════════════════════════════════════════════════════╗");
  303.             error_log("║  📡 BROADCAST WEBSOCKET - ENVOI MESSAGE              ║");
  304.             error_log("╚═══════════════════════════════════════════════════════╝");
  305.             error_log("🔡 [WebSocket] URL cible : " . $websocketUrl);
  306.             error_log("🔡 [WebSocket] Group ID  : " . $conversation->getId());
  307.             error_log("🔡 [WebSocket] Message ID: " . $message->getId());
  308.             error_log("🔡 [WebSocket] User ID   : " . $user->getId());
  309.             error_log("🔡 [WebSocket] Fullname  : " . $fullname);
  311.             $broadcastData = [
  312.                 'groupId' => (int) $conversation->getId(),
  313.                 'message' => [
  314.                     'id' => (int) $message->getId(),
  315.                     'message' => $message->getMessage(),
  316.                     'isOwn' => false,
  317.                     'userId' => $user->getId(),
  318.                     'userName' => $fullname,
  319.                     'avatar' => $avatar,
  320.                     'createdAt' => $message->getCreatedAt()->format('c'),
  321.                 ]
  322.             ];
  324.             error_log("📤 [WebSocket] Données envoyées: " . json_encode($broadcastData));
  326.             $response = $client->post($websocketUrl, [
  327.                 'json' => $broadcastData,
  328.                 'headers' => [
  329.                     'Content-Type' => 'application/json',
  330.                 ]
  331.             ]);
  333.             $statusCode = $response->getStatusCode();
  334.             $body = $response->getBody()->getContents();
  335.             $bodyData = json_decode($body, true);
  337.             error_log("✅ [WebSocket] Notification envoyée - Status: " . $statusCode);
  338.             error_log("✅ [WebSocket] Réponse: " . $body);
  340.             if (isset($bodyData['clientsNotified'])) {
  341.                 $clientsNotified = $bodyData['clientsNotified'];
  342.                 error_log("📊 [WebSocket] Clients notifiés: " . $clientsNotified);
  344.                 if ($clientsNotified === 0) {
  345.                     error_log("⚠️  [WebSocket] ATTENTION: Aucun client n'a reçu le message !");
  346.                     error_log("   Raisons possibles:");
  347.                     error_log("   1. Aucun navigateur connecté à cette conversation");
  348.                     error_log("   2. Les clients ne sont pas dans la bonne room");
  349.                     error_log("   3. Les clients n'ont pas appelé joinGroup()");
  350.                 }
  351.             }
  353.             error_log("═══════════════════════════════════════════════════════");
  355.         } catch (\GuzzleHttp\Exception\ConnectException $e) {
  356.             error_log("╔═══════════════════════════════════════════════════════╗");
  357.             error_log("║  ❌ ERREUR DE CONNEXION WEBSOCKET                     ║");
  358.             error_log("╚═══════════════════════════════════════════════════════╝");
  359.             error_log("❌ [WebSocket] Impossible de se connecter au serveur");
  360.             error_log("   URL tentée: " . ($websocketUrl ?? 'undefined'));
  361.             error_log("   Message: " . $e->getMessage());
  362.             error_log("   ⚠️  Le serveur WebSocket est-il démarré ?");
  363.             error_log("   Commande: pm2 status");
  364.             error_log("═══════════════════════════════════════════════════════");
  366.         } catch (\GuzzleHttp\Exception\RequestException $e) {
  367.             error_log("╔═══════════════════════════════════════════════════════╗");
  368.             error_log("║  ❌ ERREUR REQUÊTE WEBSOCKET                          ║");
  369.             error_log("╚═══════════════════════════════════════════════════════╝");
  370.             error_log("❌ [WebSocket] Erreur lors de la requête");
  371.             error_log("   Message: " . $e->getMessage());
  372.             if ($e->hasResponse()) {
  373.                 error_log("   Status: " . $e->getResponse()->getStatusCode());
  374.                 error_log("   Body: " . $e->getResponse()->getBody()->getContents());
  375.             }
  376.             error_log("═══════════════════════════════════════════════════════");
  378.         } catch (\Exception $e) {
  379.             error_log("╔═══════════════════════════════════════════════════════╗");
  380.             error_log("║  ❌ ERREUR GÉNÉRALE WEBSOCKET                         ║");
  381.             error_log("╚═══════════════════════════════════════════════════════╝");
  382.             error_log("❌ [WebSocket] Erreur: " . $e->getMessage());
  383.             error_log("   Type: " . get_class($e));
  384.             error_log("   File: " . $e->getFile() . ":" . $e->getLine());
  385.             error_log("⚠️  Le message a été enregistré mais la notification temps réel n'a pas pu être envoyée");
  386.             error_log("═══════════════════════════════════════════════════════");
  387.         }
  389.         return new JsonResponse([
  390.             'id' => (string)$message->getId(),
  391.             'message' => $message->getMessage(),
  392.             'isOwn' => true,
  393.             'userId' => $user->getId(),
  394.             'userName' => $fullname,
  395.             'avatar' => $avatar,
  396.             'createdAt' => $message->getCreatedAt() ? $message->getCreatedAt()->format('c') : null,
  397.         ], Response::HTTP_CREATED);
  398.     }
  400.     /**
  401.      * Récupérer les nouveaux messages depuis un certain ID (polling)
  402.      */
  403.     public function getNewMessages(Request $request, int $id): JsonResponse
  404.     {
  405.         $user = $this->getUser();
  407.         $conversation = $this->em->getRepository(Groups::class)->find($id);
  409.         if (!$conversation) {
  410.             return new JsonResponse(['error' => 'Conversation non trouvée'], Response::HTTP_NOT_FOUND);
  411.         }
  413.         if (!$conversation->hasUser($user)) {
  414.             return new JsonResponse(['error' => 'Accès interdit'], Response::HTTP_FORBIDDEN);
  415.         }
  417.         $lastMessageId = $request->query->get('lastMessageId', 0);
  419.         $messages = $this->em->getRepository(Messages::class)->findAfterMessage($conversation, $lastMessageId);
  421.         $array = [];
  422.         foreach ($messages as $message) {
  423.             $isOwn = $message->getUser()->getId() === $user->getId();
  424.             $fullname = $message->getUser()->getName()." ".$message->getUser()->getLastname();
  426.             $avatar = $this->getDefaultAvatar();
  427.             if ($message->getUser()->getImage()) {
  428.                 $avatar = $message->getUser()->getImageBase64();
  429.             }
  431.             $array[] = [
  432.                 "id" => (string)$message->getId(),
  433.                 "message" => (string)$message->getMessage(),
  434.                 "isOwn" => $isOwn,
  435.                 "userId" => $message->getUser()->getId(),
  436.                 "userName" => $fullname,
  437.                 "avatar" => $avatar,
  438.                 "createdAt" => $message->getCreatedAt() ? $message->getCreatedAt()->format('c') : null,
  439.             ];
  440.         }
  442.         return new JsonResponse($array);
  443.     }
  445.     /**
  446.      * Rechercher dans les conversations
  447.      */
  448.     public function search(Request $request): JsonResponse
  449.     {
  450.         $user = $this->getUser();
  451.         $searchTerm = $request->query->get('q', '');
  453.         if (empty(trim($searchTerm))) {
  454.             return new JsonResponse(['error' => 'Terme de recherche requis'], Response::HTTP_BAD_REQUEST);
  455.         }
  457.         $conversations = $this->em->getRepository(Groups::class)->searchConversations($user, $searchTerm);
  459.         $array = [];
  460.         foreach ($conversations as $conversation) {
  461.             $otherUser = $conversation->getOtherUser($user);
  463.             if (!$otherUser) {
  464.                 continue;
  465.             }
  467.             $countMessages = $this->em->getRepository(Messages::class)->countByConversation($conversation);
  468.             $fullname = $otherUser->getName()." ".$otherUser->getLastname();
  470.             $avatar = $this->getDefaultAvatar();
  471.             if ($otherUser->getImage()) {
  472.                 $avatar = $otherUser->getImageBase64();
  473.             }
  475.             $array[] = [
  476.                 "id" => (string)$conversation->getId(),
  477.                 "conversationHash" => $conversation->getConversationHash(),
  478.                 "title" => $conversation->getTitle() ?: 'Conversation avec ' . $fullname,
  479.                 "fullname" => $fullname,
  480.                 "userId" => $otherUser->getId(),
  481.                 "avatar" => $avatar,
  482.                 "count_messages" => $countMessages,
  483.                 "lastmessage" => $conversation->getLastMessageContent() ?? '',
  484.                 "lastMessageAt" => $conversation->getLastMessageAt() ? $conversation->getLastMessageAt()->format('c') : null,
  485.             ];
  486.         }
  488.         return new JsonResponse($array);
  489.     }
  491.     /**
  492.      * Supprimer une conversation (soft delete ou hard delete selon votre besoin)
  493.      */
  494.     public function deleteConversation(int $id): JsonResponse
  495.     {
  496.         $user = $this->getUser();
  498.         $conversation = $this->em->getRepository(Groups::class)->find($id);
  500.         if (!$conversation) {
  501.             return new JsonResponse(['error' => 'Conversation non trouvée'], Response::HTTP_NOT_FOUND);
  502.         }
  504.         if (!$conversation->hasUser($user)) {
  505.             return new JsonResponse(['error' => 'Accès interdit'], Response::HTTP_FORBIDDEN);
  506.         }
  508.         return new JsonResponse(['message' => 'Conversation supprimée avec succès']);
  509.     }
  511.     /**
  512.      * Démarrer une conversation
  513.      */
  514.     public function startConversation(Request $request, int $userId): JsonResponse
  515.     {
  516.         $user = $this->getUser();
  518.         if (!$user) {
  519.             return new JsonResponse(['error' => 'Non authentifié'], Response::HTTP_UNAUTHORIZED);
  520.         }
  522.         $otherUser = $this->em->getRepository(Users::class)->find($userId);
  524.         if (!$otherUser) {
  525.             return new JsonResponse(['error' => 'Utilisateur non trouvé'], Response::HTTP_NOT_FOUND);
  526.         }
  528.         if ($user->getId() === $otherUser->getId()) {
  529.             return new JsonResponse(['error' => 'Impossible de démarrer une conversation avec soi-même'], Response::HTTP_BAD_REQUEST);
  530.         }
  532.         $conversation = $this->em->getRepository(Groups::class)->findOrCreateConversation($user, $otherUser);
  534.         $fullname = $otherUser->getName() . " " . $otherUser->getLastname();
  536.         return new JsonResponse([
  537.             'id' => (string)$conversation->getId(),
  538.             'conversationHash' => $conversation->getConversationHash(),
  539.             'fullname' => $fullname,
  540.             'userId' => $otherUser->getId(),
  541.         ], Response::HTTP_CREATED);
  542.     }
  544.     // ========================================
  545.     // NOUVELLES MÉTHODES — V2 avec lu/non lu
  546.     // ========================================
  548.     /**
  549.      * Liste des conversations récentes V2 — avec lastMessageSenderId et unread_count
  550.      * Utilise le vrai compteur de messages non lus (basé sur readAt)
  551.      */
  552.     public function recentsV2(Request $request): JsonResponse
  553.     {
  554.         $user = $this->getUser();
  556.         if (!$user) {
  557.             return new JsonResponse(['error' => 'Non authentifié'], Response::HTTP_UNAUTHORIZED);
  558.         }
  560.         $limit = $request->query->get('limit', 20);
  562.         $conversations = $this->em->getRepository(Groups::class)->recents($user, $limit);
  563.         $messagesRepo = $this->em->getRepository(Messages::class);
  565.         $array = [];
  566.         foreach ($conversations as $conversation) {
  568.             $otherUser = $conversation->getOtherUser($user);
  570.             if (!$otherUser) {
  571.                 continue;
  572.             }
  574.             // Compteur de messages NON LUS (messages de l'autre que je n'ai pas lus)
  575.             $unreadCount = $messagesRepo->countUnreadByConversation($conversation, $user);
  577.             $fullname = $otherUser->getName() . " " . $otherUser->getLastname();
  579.             $avatar = $this->getDefaultAvatar();
  580.             if ($otherUser->getImage()) {
  581.                 $avatar = $otherUser->getImageBase64();
  582.             }
  584.             $array[] = [
  585.                 "id"                    => (string)$conversation->getId(),
  586.                 "conversationHash"      => $conversation->getConversationHash(),
  587.                 "title"                 => $conversation->getTitle() ?: 'Conversation avec ' . $fullname,
  588.                 "fullname"              => $fullname,
  589.                 "userId"                => $otherUser->getId(),
  590.                 "userEmail"             => $otherUser->getEmail(),
  591.                 "avatar"                => $avatar,
  592.                 "count_messages"        => $unreadCount,                                    // ← maintenant = non lus uniquement
  593.                 "lastMessageSenderId"   => $conversation->getLastMessageSenderId(),         // ← NOUVEAU
  594.                 "open"                  => false,
  595.                 "lastmessage"           => $conversation->getLastMessageContent() ?? '',
  596.                 "lastMessageAt"         => $conversation->getLastMessageAt() ? $conversation->getLastMessageAt()->format('c') : null,
  597.                 "createdAt"             => $conversation->getCreatedAt() ? $conversation->getCreatedAt()->format('c') : null,
  598.             ];
  599.         }
  601.         return new JsonResponse($array);
  602.     }
  604.     /**
  605.      * Marquer tous les messages d'une conversation comme lus
  606.      * Appelé quand l'utilisateur ouvre une conversation
  607.      */
  608.     public function markAsRead(int $id): JsonResponse
  609.     {
  610.         $user = $this->getUser();
  612.         if (!$user) {
  613.             return new JsonResponse(['error' => 'Non authentifié'], Response::HTTP_UNAUTHORIZED);
  614.         }
  616.         $conversation = $this->em->getRepository(Groups::class)->find($id);
  618.         if (!$conversation) {
  619.             return new JsonResponse(['error' => 'Conversation non trouvée'], Response::HTTP_NOT_FOUND);
  620.         }
  622.         if (!$conversation->hasUser($user)) {
  623.             return new JsonResponse(['error' => 'Accès interdit'], Response::HTTP_FORBIDDEN);
  624.         }
  626.         // Marquer comme lus tous les messages de l'autre utilisateur
  627.         $markedCount = $this->em->getRepository(Messages::class)
  628.             ->markAsReadByConversation($conversation, $user);
  630.         error_log("✅ [MarkAsRead] Conv {$id} — {$markedCount} messages marqués comme lus pour user {$user->getId()}");
  632.         return new JsonResponse([
  633.             'success'     => true,
  634.             'markedCount' => $markedCount,
  635.         ]);
  636.     }
  638.     /**
  639.      * Obtenir le nombre total de messages non lus (pour le badge de l'onglet Messages)
  640.      */
  641.     public function totalUnread(): JsonResponse
  642.     {
  643.         $user = $this->getUser();
  645.         if (!$user) {
  646.             return new JsonResponse(['error' => 'Non authentifié'], Response::HTTP_UNAUTHORIZED);
  647.         }
  649.         $totalUnread = $this->em->getRepository(Messages::class)
  650.             ->countTotalUnreadForUser($user);
  652.         return new JsonResponse([
  653.             'totalUnread' => $totalUnread,
  654.         ]);
  655.     }
  657.     // ========================================
  658.     // HELPERS PRIVÉS
  659.     // ========================================
  661.     private function cleanMessageNotification($texte, $longueur = 20) {
  662.         if (mb_strlen($texte) <= $longueur) {
  663.             return $texte;
  664.         }
  665.         return mb_substr($texte, 0, $longueur) . '...';
  666.     }
  668.     /**
  669.      * Avatar SVG par défaut
  670.      */
  671.     private function getDefaultAvatar(): string
  672.     {
  673.         return "data:image/svg+xml;base64,PHN2ZyB3aWR0aD0iMjAwIiBoZWlnaHQ9IjIwMCIgdmlld0JveD0iMCAwIDIwMCAyMDAiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyI+CiAgPGRlZnM+CiAgICA8bGluZWFyR3JhZGllbnQgaWQ9ImdyYWQiIHgxPSIwJSIgeTE9IjAlIiB4Mj0iMTAwJSIgeTI9IjEwMCUiPgogICAgICA8c3RvcCBvZmZzZXQ9IjAlIiBzdHlsZT0ic3RvcC1jb2xvcjojNjY3ZWVhO3N0b3Atb3BhY2l0eToxIiAvPgogICAgICA8c3RvcCBvZmZzZXQ9IjEwMCUiIHN0eWxlPSJzdG9wLWNvbG9yOiM3NjRiYTI7c3RvcC1vcGFjaXR5OjEiIC8+CiAgICA8L2xpbmVhckdyYWRpZW50PgogIDwvZGVmcz4KICA8Y2lyY2xlIGN4PSIxMDAiIGN5PSIxMDAiIHI9IjEwMCIgZmlsbD0idXJsKCNncmFkKSIvPgogIDxnIHRyYW5zZm9ybT0idHJhbnNsYXRlKDEwMCwgMTAwKSI+CiAgICA8Y2lyY2xlIGN4PSIwIiBjeT0iLTE1IiByPSIzNSIgZmlsbD0iI2ZmZmZmZiIgb3BhY2l0eT0iMC45Ii8+CiAgICA8cGF0aCBkPSJNIC01MCA2NSBRIC01MCAyNSAtMzUgMTAgUSAtMTUgLTUgMCAtNSBRIDE1IC01IDM1IDEwIFEgNTAgMjUgNTAgNjUgWiIgZmlsbD0iI2ZmZmZmZiIgb3BhY2l0eT0iMC45Ii8+CiAgPC9nPgo8L3N2Zz4K";
  674.     }
  676. }