src/Controller/Api/ConversationsController.php line 659

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\Messenger\Groups;
  8. use App\Entity\Messenger\Messages;
  9. use App\Services\NotificationService;
  10. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  11. use Symfony\Component\HttpFoundation\Request;
  12. use Symfony\Component\HttpFoundation\Response;
  13. use Symfony\Component\HttpFoundation\JsonResponse;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Knp\Component\Pager\PaginatorInterface;
  17. class ConversationsController extends AbstractController
  18. {
  20. private $em;
  21. private $paginator;
  22. private $notificationService;
  24. public function __construct(EntityManagerInterface $em,
  25. PaginatorInterface $paginator,
  26. NotificationService $notificationService
  27. ) {
  28. $this->em = $em;
  29. $this->paginator = $paginator;
  30. $this->notificationService = $notificationService;
  31. }
  33. /* ══════════════════════════════════════════════════════════════════
  34. MASQUAGE D'IDENTITÉ — profil anonyme
  36. Une conversation peut porter `anonymousUserId` : l'utilisateur ainsi
  37. désigné est masqué pour SON INTERLOCUTEUR. C'est posé quand un
  38. recruteur écrit depuis /cv/{anonRef}, la porte anonyme du profil.
  40. ⚠️ UN SEUL ENDROIT DÉCIDE, ET TOUT LE MONDE L'APPELLE.
  42. L'identité fuyait par QUATRE canaux : la liste des conversations,
  43. chaque message, la notification in-app, et le payload poussé au
  44. WebSocket. Quatre masquages écrits séparément, c'est trois
  45. masquages corrects et un oubli — et l'oubli révèle quelqu'un qui
  46. avait demandé à ne pas l'être.
  48. ⚠️ L'E-MAIL AUSSI. Ce n'est pas qu'une question de nom : la liste
  49. des conversations renvoyait `userEmail`. Un nom masqué à côté
  50. d'une adresse `prenom.nom@societe.fr` ne masque rien.
  51. ══════════════════════════════════════════════════════════════════ */
  53. /**
  54. * L'identité à afficher pour `$autre` dans `$conversation`, vue par
  55. * `$lecteur`.
  56. *
  57. * @return array{fullname: string, avatar: string, email: string, masked: bool, reference?: ?string}
  58. */
  59. private function identite(Groups $conversation, ?Users $autre, ?Users $lecteur): array
  60. {
  61. $nomReel = $autre ? trim($autre->getName() . ' ' . $autre->getLastname()) : '';
  63. $avatarReel = $this->getDefaultAvatar();
  64. if ($autre && $autre->getImage()) {
  65. $avatarReel = $autre->getImageBase64();
  66. }
  68. /* On ne masque JAMAIS quelqu'un pour lui-même : le candidat doit se
  69. reconnaître dans son propre fil. Le masque protège de l'autre,
  70. pas de soi. */
  71. $memePersonne = $autre && $lecteur && $autre->getId() === $lecteur->getId();
  73. if ($memePersonne || !$autre || !$conversation->masque($autre->getId())) {
  74. return [
  75. 'fullname' => $nomReel,
  76. 'avatar' => $avatarReel,
  77. 'email' => $autre ? (string) $autre->getEmail() : '',
  78. 'masked' => false,
  79. ];
  80. }
  82. /* ══════════════════════════════════════════════════════════════
  83. LA RÉFÉRENCE DU CANDIDAT ANONYME, À LA PLACE DU NOM
  85. « Candidat anonyme » ne distingue rien : un recruteur qui a
  86. contacté trois CV anonymes voyait trois fils du même nom. La
  87. référence de la porte anonyme (`anon_ref`, celle de /cv/{ref})
  88. est ce qu'il a sous les yeux depuis le début — elle identifie le
  89. fil sans identifier la personne. Elle est publique par
  90. construction : c'est l'adresse qu'il a ouverte.
  91. ══════════════════════════════════════════════════════════════ */
  92. $reference = null;
  94. if ($autre && $autre->getCandidate() && $autre->getCandidate()->getAnonRef()) {
  95. $reference = $autre->getCandidate()->getAnonRef();
  96. }
  98. return [
  99. 'fullname' => $reference ? 'Candidat anonyme · ' . $reference : 'Candidat anonyme',
  100. 'avatar' => $this->getDefaultAvatar(),
  101. 'email' => '',
  102. 'masked' => true,
  103. 'reference' => $reference,
  104. ];
  105. }
  107. /**
  108. * Liste des conversations récentes de l'utilisateur connecté
  109. */
  110. public function recents(Request $request): JsonResponse
  111. {
  112. $user = $this->getUser();
  113. $limit = $request->query->get('limit', 20);
  115. $conversations = $this->em->getRepository(Groups::class)->recents($user, $limit);
  117. $array = [];
  118. foreach ($conversations as $conversation) {
  120. $otherUser = $conversation->getOtherUser($user);
  122. if (!$otherUser) {
  123. continue;
  124. }
  126. $countMessages = $this->em->getRepository(Messages::class)->countByConversation($conversation);
  128. /* Identité masquée si la conversation le prévoit — voir identite(). */
  129. $ident = $this->identite($conversation, $otherUser, $user);
  130. $fullname = $ident['fullname'];
  131. $avatar = $ident['avatar'];
  133. $array[] = [
  134. "id" => (string)$conversation->getId(),
  135. "conversationHash" => $conversation->getConversationHash(),
  136. "title" => $conversation->getTitle() ?: 'Conversation avec ' . $fullname,
  137. "fullname" => $fullname,
  138. "userId" => $otherUser->getId(),
  139. "userEmail" => $ident['email'],
  140. "anonymous" => $ident['masked'],
  141. "avatar" => $avatar,
  142. "count_messages" => $countMessages,
  143. "open" => false,
  144. "lastmessage" => $conversation->getLastMessageContent() ?? '',
  145. "lastMessageAt" => $conversation->getLastMessageAt() ? $conversation->getLastMessageAt()->format('c') : null,
  146. "createdAt" => $conversation->getCreatedAt() ? $conversation->getCreatedAt()->format('c') : null,
  147. ];
  148. }
  150. return new JsonResponse($array);
  151. }
  154. /**
  155. * Afficher les messages d'une conversation
  156. */
  157. public function show(Request $request, int $id): JsonResponse
  158. {
  159. $user = $this->getUser();
  161. $conversation = $this->em->getRepository(Groups::class)->find($id);
  163. if (!$conversation) {
  164. return new JsonResponse(['error' => 'Conversation non trouvée'], Response::HTTP_NOT_FOUND);
  165. }
  167. if (!$conversation->hasUser($user)) {
  168. return new JsonResponse(['error' => 'Accès interdit'], Response::HTTP_FORBIDDEN);
  169. }
  171. $limit = $request->query->get('limit', 100);
  172. $offset = $request->query->get('offset', 0);
  174. $messages = $this->em->getRepository(Messages::class)->findByConversation($conversation, $limit, $offset);
  176. $array = [];
  177. foreach ($messages as $message) {
  179. $isOwn = $message->getUser()->getId() === $user->getId();
  181. /* Chaque bulle porte le nom de son auteur : masquer la liste
  182. sans masquer les bulles laisserait le nom réel s'afficher au
  183. premier message reçu. */
  184. $ident = $this->identite($conversation, $message->getUser(), $user);
  185. $fullname = $ident['fullname'];
  186. $avatar = $ident['avatar'];
  188. $array[] = [
  189. "id" => (string)$message->getId(),
  190. "message" => (string)$message->getMessage(),
  191. "isOwn" => $isOwn,
  192. "userId" => $message->getUser()->getId(),
  193. "userName" => $fullname,
  194. "avatar" => $avatar,
  195. "anonymous" => $ident['masked'],
  196. "createdAt" => $message->getCreatedAt() ? $message->getCreatedAt()->format('c') : null,
  197. ];
  198. }
  200. return new JsonResponse($array);
  201. }
  203. /**
  204. * Envoyer un message
  205. */
  206. public function sendMessage(Request $request, int $id): JsonResponse
  207. {
  208. $user = $this->getUser();
  210. $conversation = $this->em->getRepository(Groups::class)->find($id);
  212. if (!$conversation) {
  213. return new JsonResponse(['error' => 'Conversation non trouvée'], Response::HTTP_NOT_FOUND);
  214. }
  216. if (!$conversation->hasUser($user)) {
  217. return new JsonResponse(['error' => 'Accès interdit'], Response::HTTP_FORBIDDEN);
  218. }
  220. $data = json_decode($request->getContent(), true);
  221. $messageText = $data['message'] ?? null;
  223. if (empty($messageText)) {
  224. return new JsonResponse(['error' => 'Message vide'], Response::HTTP_BAD_REQUEST);
  225. }
  227. $emetteur = $user;
  228. $destinataire = null;
  230. if($conversation->getUserOne() !== $user) {
  231. $destinataire = $conversation->getUserOne();
  232. }
  234. if($conversation->getUserTwo() !== $user) {
  235. $destinataire = $conversation->getUserTwo();
  236. }
  238. // Créer le message
  239. $message = new Messages();
  240. $message->setMessage($messageText);
  241. $message->setUser($user);
  242. $message->setGroup($conversation);
  243. $message->setCreatedAt(new \DateTime());
  244. $this->em->persist($message);
  245. $this->em->flush();
  247. // Mettre à jour la conversation (avec le nouveau champ lastMessageSenderId)
  248. $conversation->setLastMessageContent(substr($messageText, 0, 100));
  249. $conversation->setLastMessageId($message->getId());
  250. $conversation->setLastMessageAt(new \DateTime());
  251. $conversation->setLastMessageSenderId($user->getId()); // ← NOUVEAU
  252. $this->em->persist($conversation);
  253. $this->em->flush();
  255. // Vers le destinataire
  256. $notification = new Notifications();
  257. $notification->setViewed(false);
  258. $notification->setOnlyAdmin(false);
  259. $notification->setTitle("message");
  260. if($conversation->getUserOne()->getLanguage() == "fr") {
  261. /* La notification nomme l'émetteur : sans masquage, elle
  262. annulerait tout le reste en une ligne. */
  263. $notification->setDescription("Message reçu par ".$this->identite($conversation, $emetteur, $destinataire)['fullname']);
  264. $this->notificationService->sendToUser(
  265. $destinataire,
  266. 'Nouveau message',
  267. $this->cleanMessageNotification($message->getMessage()),
  268. ['type' => 'message', 'conversationId' => $conversation->getId()],
  269. );
  270. } else {
  271. $this->notificationService->sendToUser(
  272. $destinataire,
  273. 'New message',
  274. $this->cleanMessageNotification($message->getMessage()),
  275. ['type' => 'message', 'conversationId' => $conversation->getId()],
  276. );
  277. $notification->setDescription("Message received by ".$this->identite($conversation, $emetteur, $destinataire)['fullname']);
  278. }
  279. $notification->setType("default");
  280. $notification->setUser($conversation->getUserTwo());
  281. $this->em->persist($notification);
  282. $this->em->flush();
  284. /* ⚠️ LE POINT LE PLUS FACILE À OUBLIER.
  286. Ce payload part vers le serveur WebSocket, qui le REDIFFUSE TEL
  287. QUEL au navigateur de l'interlocuteur. Masquer les endpoints REST
  288. en laissant celui-ci intact reviendrait à masquer la porte en
  289. laissant la fenêtre ouverte : le nom réel s'afficherait en direct,
  290. à la seconde où le message part.
  292. Le serveur WebSocket n'a rien à savoir de tout ça — c'est un
  293. relais. On lui donne déjà le texte masqué. */
  294. $identEmetteur = $this->identite($conversation, $user, $conversation->getOtherUser($user));
  295. $fullname = $identEmetteur['fullname'];
  296. $avatar = $identEmetteur['avatar'];
  298. try {
  299. $client = new \GuzzleHttp\Client([
  300. 'timeout' => 5.0,
  301. 'verify' => false,
  302. ]);
  304. $websocketUrl = rtrim((string) ($_ENV["WEBSOCKET_HTTP_URL"] ?? ''), '/').'/broadcast';
  306. /* ⚠️ LE SECRET PARTAGÉ AVEC LE SERVEUR WEBSOCKET.
  308. Le serveur WS protège `/broadcast` par `BROADCAST_SECRET`
  309. (en-tête `X-Internal-Secret`). Tant qu'on ne l'envoyait pas,
  310. poser ce secret côté WS coupait TOUTES les notifications
  311. temps réel — 403 à chaque message, visible seulement dans les
  312. journaux. La même valeur, dans `WEBSOCKET_BROADCAST_SECRET`
  313. ici : l'en-tête n'est envoyé que si elle est renseignée, donc
  314. un serveur WS sans secret continue de fonctionner. */
  315. $secretBroadcast = trim((string) ($_ENV["WEBSOCKET_BROADCAST_SECRET"] ?? ''));
  316. $entetesBroadcast = ['Content-Type' => 'application/json'];
  317. if ($secretBroadcast !== '') {
  318. $entetesBroadcast['X-Internal-Secret'] = $secretBroadcast;
  319. }
  321. error_log("╔═══════════════════════════════════════════════════════╗");
  322. error_log("║ 📡 BROADCAST WEBSOCKET - ENVOI MESSAGE ║");
  323. error_log("╚═══════════════════════════════════════════════════════╝");
  324. error_log("🔡 [WebSocket] URL cible : " . $websocketUrl);
  325. error_log("🔡 [WebSocket] Group ID : " . $conversation->getId());
  326. error_log("🔡 [WebSocket] Message ID: " . $message->getId());
  327. error_log("🔡 [WebSocket] User ID : " . $user->getId());
  328. error_log("🔡 [WebSocket] Fullname : " . $fullname);
  330. $broadcastData = [
  331. 'groupId' => (int) $conversation->getId(),
  332. 'message' => [
  333. 'id' => (int) $message->getId(),
  334. 'message' => $message->getMessage(),
  335. 'isOwn' => false,
  336. 'userId' => $user->getId(),
  337. 'userName' => $fullname,
  338. 'avatar' => $avatar,
  339. 'anonymous' => $identEmetteur['masked'],
  340. 'reference' => $identEmetteur['reference'] ?? null,
  341. 'createdAt' => $message->getCreatedAt()->format('c'),
  342. ]
  343. ];
  345. error_log("📤 [WebSocket] Données envoyées: " . json_encode($broadcastData));
  347. $response = $client->post($websocketUrl, [
  348. 'json' => $broadcastData,
  349. 'headers' => $entetesBroadcast,
  350. ]);
  352. $statusCode = $response->getStatusCode();
  353. $body = $response->getBody()->getContents();
  354. $bodyData = json_decode($body, true);
  356. error_log("✅ [WebSocket] Notification envoyée - Status: " . $statusCode);
  357. error_log("✅ [WebSocket] Réponse: " . $body);
  359. if (isset($bodyData['clientsNotified'])) {
  360. $clientsNotified = $bodyData['clientsNotified'];
  361. error_log("📊 [WebSocket] Clients notifiés: " . $clientsNotified);
  363. if ($clientsNotified === 0) {
  364. error_log("⚠️ [WebSocket] ATTENTION: Aucun client n'a reçu le message !");
  365. error_log(" Raisons possibles:");
  366. error_log(" 1. Aucun navigateur connecté à cette conversation");
  367. error_log(" 2. Les clients ne sont pas dans la bonne room");
  368. error_log(" 3. Les clients n'ont pas appelé joinGroup()");
  369. }
  370. }
  372. error_log("═══════════════════════════════════════════════════════");
  374. } catch (\GuzzleHttp\Exception\ConnectException $e) {
  375. error_log("╔═══════════════════════════════════════════════════════╗");
  376. error_log("║ ❌ ERREUR DE CONNEXION WEBSOCKET ║");
  377. error_log("╚═══════════════════════════════════════════════════════╝");
  378. error_log("❌ [WebSocket] Impossible de se connecter au serveur");
  379. error_log(" URL tentée: " . ($websocketUrl ?? 'undefined'));
  380. error_log(" Message: " . $e->getMessage());
  381. error_log(" ⚠️ Le serveur WebSocket est-il démarré ?");
  382. error_log(" Commande: pm2 status");
  383. error_log("═══════════════════════════════════════════════════════");
  385. } catch (\GuzzleHttp\Exception\RequestException $e) {
  386. error_log("╔═══════════════════════════════════════════════════════╗");
  387. error_log("║ ❌ ERREUR REQUÊTE WEBSOCKET ║");
  388. error_log("╚═══════════════════════════════════════════════════════╝");
  389. error_log("❌ [WebSocket] Erreur lors de la requête");
  390. error_log(" Message: " . $e->getMessage());
  391. if ($e->hasResponse()) {
  392. error_log(" Status: " . $e->getResponse()->getStatusCode());
  393. error_log(" Body: " . $e->getResponse()->getBody()->getContents());
  394. }
  395. error_log("═══════════════════════════════════════════════════════");
  397. } catch (\Exception $e) {
  398. error_log("╔═══════════════════════════════════════════════════════╗");
  399. error_log("║ ❌ ERREUR GÉNÉRALE WEBSOCKET ║");
  400. error_log("╚═══════════════════════════════════════════════════════╝");
  401. error_log("❌ [WebSocket] Erreur: " . $e->getMessage());
  402. error_log(" Type: " . get_class($e));
  403. error_log(" File: " . $e->getFile() . ":" . $e->getLine());
  404. error_log("⚠️ Le message a été enregistré mais la notification temps réel n'a pas pu être envoyée");
  405. error_log("═══════════════════════════════════════════════════════");
  406. }
  408. return new JsonResponse([
  409. 'id' => (string)$message->getId(),
  410. 'message' => $message->getMessage(),
  411. 'isOwn' => true,
  412. 'userId' => $user->getId(),
  413. 'userName' => $fullname,
  414. 'avatar' => $avatar,
  415. 'createdAt' => $message->getCreatedAt() ? $message->getCreatedAt()->format('c') : null,
  416. ], Response::HTTP_CREATED);
  417. }
  419. /**
  420. * Récupérer les nouveaux messages depuis un certain ID (polling)
  421. */
  422. public function getNewMessages(Request $request, int $id): JsonResponse
  423. {
  424. $user = $this->getUser();
  426. $conversation = $this->em->getRepository(Groups::class)->find($id);
  428. if (!$conversation) {
  429. return new JsonResponse(['error' => 'Conversation non trouvée'], Response::HTTP_NOT_FOUND);
  430. }
  432. if (!$conversation->hasUser($user)) {
  433. return new JsonResponse(['error' => 'Accès interdit'], Response::HTTP_FORBIDDEN);
  434. }
  436. $lastMessageId = $request->query->get('lastMessageId', 0);
  438. $messages = $this->em->getRepository(Messages::class)->findAfterMessage($conversation, $lastMessageId);
  440. $array = [];
  441. foreach ($messages as $message) {
  442. $isOwn = $message->getUser()->getId() === $user->getId();
  443. /* Masquage : voir identite(). */
  444. $ident = $this->identite($conversation, $message->getUser(), $user);
  445. $fullname = $ident['fullname'];
  446. $avatar = $ident['avatar'];
  448. $array[] = [
  449. "id" => (string)$message->getId(),
  450. "message" => (string)$message->getMessage(),
  451. "isOwn" => $isOwn,
  452. "userId" => $message->getUser()->getId(),
  453. "userName" => $fullname,
  454. "avatar" => $avatar,
  455. "createdAt" => $message->getCreatedAt() ? $message->getCreatedAt()->format('c') : null,
  456. ];
  457. }
  459. return new JsonResponse($array);
  460. }
  462. /**
  463. * Rechercher dans les conversations
  464. */
  465. public function search(Request $request): JsonResponse
  466. {
  467. $user = $this->getUser();
  468. $searchTerm = $request->query->get('q', '');
  470. if (empty(trim($searchTerm))) {
  471. return new JsonResponse(['error' => 'Terme de recherche requis'], Response::HTTP_BAD_REQUEST);
  472. }
  474. $conversations = $this->em->getRepository(Groups::class)->searchConversations($user, $searchTerm);
  476. $array = [];
  477. foreach ($conversations as $conversation) {
  478. $otherUser = $conversation->getOtherUser($user);
  480. if (!$otherUser) {
  481. continue;
  482. }
  484. $countMessages = $this->em->getRepository(Messages::class)->countByConversation($conversation);
  485. /* Masquage : voir identite(). */
  486. $ident = $this->identite($conversation, $otherUser, $user);
  487. $fullname = $ident['fullname'];
  488. $avatar = $ident['avatar'];
  490. $array[] = [
  491. "id" => (string)$conversation->getId(),
  492. "conversationHash" => $conversation->getConversationHash(),
  493. "title" => $conversation->getTitle() ?: 'Conversation avec ' . $fullname,
  494. "fullname" => $fullname,
  495. "userId" => $otherUser->getId(),
  496. "avatar" => $avatar,
  497. "count_messages" => $countMessages,
  498. "lastmessage" => $conversation->getLastMessageContent() ?? '',
  499. "lastMessageAt" => $conversation->getLastMessageAt() ? $conversation->getLastMessageAt()->format('c') : null,
  500. ];
  501. }
  503. return new JsonResponse($array);
  504. }
  506. /**
  507. * Supprimer une conversation (soft delete ou hard delete selon votre besoin)
  508. */
  509. public function deleteConversation(int $id): JsonResponse
  510. {
  511. $user = $this->getUser();
  513. $conversation = $this->em->getRepository(Groups::class)->find($id);
  515. if (!$conversation) {
  516. return new JsonResponse(['error' => 'Conversation non trouvée'], Response::HTTP_NOT_FOUND);
  517. }
  519. if (!$conversation->hasUser($user)) {
  520. return new JsonResponse(['error' => 'Accès interdit'], Response::HTTP_FORBIDDEN);
  521. }
  523. return new JsonResponse(['message' => 'Conversation supprimée avec succès']);
  524. }
  526. /**
  527. * Démarrer une conversation
  528. */
  529. public function startConversation(Request $request, int $userId): JsonResponse
  530. {
  531. $user = $this->getUser();
  533. if (!$user) {
  534. return new JsonResponse(['error' => 'Non authentifié'], Response::HTTP_UNAUTHORIZED);
  535. }
  537. $otherUser = $this->em->getRepository(Users::class)->find($userId);
  539. if (!$otherUser) {
  540. return new JsonResponse(['error' => 'Utilisateur non trouvé'], Response::HTTP_NOT_FOUND);
  541. }
  543. if ($user->getId() === $otherUser->getId()) {
  544. return new JsonResponse(['error' => 'Impossible de démarrer une conversation avec soi-même'], Response::HTTP_BAD_REQUEST);
  545. }
  547. $conversation = $this->em->getRepository(Groups::class)->findOrCreateConversation($user, $otherUser);
  549. /* Masquage : voir identite(). Cet endpoint renvoie le nom au moment
  550. d'ouvrir un fil — c'est exactement là qu'un anonyme se ferait
  551. démasquer sans que rien ne le signale. */
  552. $ident = $this->identite($conversation, $otherUser, $user);
  554. return new JsonResponse([
  555. 'id' => (string)$conversation->getId(),
  556. 'conversationHash' => $conversation->getConversationHash(),
  557. 'fullname' => $ident['fullname'],
  558. 'anonymous' => $ident['masked'],
  559. 'reference' => $ident['reference'] ?? null,
  560. 'userId' => $otherUser->getId(),
  561. ], Response::HTTP_CREATED);
  562. }
  564. // ========================================
  565. // NOUVELLES MÉTHODES — V2 avec lu/non lu
  566. // ========================================
  568. /**
  569. * Liste des conversations récentes V2 — avec lastMessageSenderId et unread_count
  570. * Utilise le vrai compteur de messages non lus (basé sur readAt)
  571. */
  572. public function recentsV2(Request $request): JsonResponse
  573. {
  574. $user = $this->getUser();
  576. if (!$user) {
  577. return new JsonResponse(['error' => 'Non authentifié'], Response::HTTP_UNAUTHORIZED);
  578. }
  580. $limit = $request->query->get('limit', 20);
  582. $conversations = $this->em->getRepository(Groups::class)->recents($user, $limit);
  583. $messagesRepo = $this->em->getRepository(Messages::class);
  585. $array = [];
  586. foreach ($conversations as $conversation) {
  588. $otherUser = $conversation->getOtherUser($user);
  590. if (!$otherUser) {
  591. continue;
  592. }
  594. // Compteur de messages NON LUS (messages de l'autre que je n'ai pas lus)
  595. $unreadCount = $messagesRepo->countUnreadByConversation($conversation, $user);
  597. /* Masquage : voir identite(). */
  598. $ident = $this->identite($conversation, $otherUser, $user);
  599. $fullname = $ident['fullname'];
  600. $avatar = $ident['avatar'];
  602. $array[] = [
  603. "id" => (string)$conversation->getId(),
  604. "conversationHash" => $conversation->getConversationHash(),
  605. "title" => $conversation->getTitle() ?: 'Conversation avec ' . $fullname,
  606. "fullname" => $fullname,
  607. "userId" => $otherUser->getId(),
  608. "userEmail" => $otherUser->getEmail(),
  609. "avatar" => $avatar,
  610. "count_messages" => $unreadCount, // ← maintenant = non lus uniquement
  611. "lastMessageSenderId" => $conversation->getLastMessageSenderId(), // ← NOUVEAU
  612. "open" => false,
  613. "lastmessage" => $conversation->getLastMessageContent() ?? '',
  614. "lastMessageAt" => $conversation->getLastMessageAt() ? $conversation->getLastMessageAt()->format('c') : null,
  615. "createdAt" => $conversation->getCreatedAt() ? $conversation->getCreatedAt()->format('c') : null,
  616. ];
  617. }
  619. return new JsonResponse($array);
  620. }
  622. /**
  623. * Marquer tous les messages d'une conversation comme lus
  624. * Appelé quand l'utilisateur ouvre une conversation
  625. */
  626. public function markAsRead(int $id): JsonResponse
  627. {
  628. $user = $this->getUser();
  630. if (!$user) {
  631. return new JsonResponse(['error' => 'Non authentifié'], Response::HTTP_UNAUTHORIZED);
  632. }
  634. $conversation = $this->em->getRepository(Groups::class)->find($id);
  636. if (!$conversation) {
  637. return new JsonResponse(['error' => 'Conversation non trouvée'], Response::HTTP_NOT_FOUND);
  638. }
  640. if (!$conversation->hasUser($user)) {
  641. return new JsonResponse(['error' => 'Accès interdit'], Response::HTTP_FORBIDDEN);
  642. }
  644. // Marquer comme lus tous les messages de l'autre utilisateur
  645. $markedCount = $this->em->getRepository(Messages::class)
  646. ->markAsReadByConversation($conversation, $user);
  648. error_log("✅ [MarkAsRead] Conv {$id} — {$markedCount} messages marqués comme lus pour user {$user->getId()}");
  650. return new JsonResponse([
  651. 'success' => true,
  652. 'markedCount' => $markedCount,
  653. ]);
  654. }
  656. /**
  657. * Obtenir le nombre total de messages non lus (pour le badge de l'onglet Messages)
  658. */
  659. public function totalUnread(): JsonResponse
  660. {
  661. $user = $this->getUser();
  663. if (!$user) {
  664. return new JsonResponse(['error' => 'Non authentifié'], Response::HTTP_UNAUTHORIZED);
  665. }
  667. $totalUnread = $this->em->getRepository(Messages::class)
  668. ->countTotalUnreadForUser($user);
  670. return new JsonResponse([
  671. 'totalUnread' => $totalUnread,
  672. ]);
  673. }
  675. // ========================================
  676. // HELPERS PRIVÉS
  677. // ========================================
  679. private function cleanMessageNotification($texte, $longueur = 20) {
  680. if (mb_strlen($texte) <= $longueur) {
  681. return $texte;
  682. }
  683. return mb_substr($texte, 0, $longueur) . '...';
  684. }
  686. /**
  687. * Avatar SVG par défaut
  688. */
  689. private function getDefaultAvatar(): string
  690. {
  691. return "data:image/svg+xml;base64,PHN2ZyB3aWR0aD0iMjAwIiBoZWlnaHQ9IjIwMCIgdmlld0JveD0iMCAwIDIwMCAyMDAiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyI+CiAgPGRlZnM+CiAgICA8bGluZWFyR3JhZGllbnQgaWQ9ImdyYWQiIHgxPSIwJSIgeTE9IjAlIiB4Mj0iMTAwJSIgeTI9IjEwMCUiPgogICAgICA8c3RvcCBvZmZzZXQ9IjAlIiBzdHlsZT0ic3RvcC1jb2xvcjojNjY3ZWVhO3N0b3Atb3BhY2l0eToxIiAvPgogICAgICA8c3RvcCBvZmZzZXQ9IjEwMCUiIHN0eWxlPSJzdG9wLWNvbG9yOiM3NjRiYTI7c3RvcC1vcGFjaXR5OjEiIC8+CiAgICA8L2xpbmVhckdyYWRpZW50PgogIDwvZGVmcz4KICA8Y2lyY2xlIGN4PSIxMDAiIGN5PSIxMDAiIHI9IjEwMCIgZmlsbD0idXJsKCNncmFkKSIvPgogIDxnIHRyYW5zZm9ybT0idHJhbnNsYXRlKDEwMCwgMTAwKSI+CiAgICA8Y2lyY2xlIGN4PSIwIiBjeT0iLTE1IiByPSIzNSIgZmlsbD0iI2ZmZmZmZiIgb3BhY2l0eT0iMC45Ii8+CiAgICA8cGF0aCBkPSJNIC01MCA2NSBRIC01MCAyNSAtMzUgMTAgUSAtMTUgLTUgMCAtNSBRIDE1IC01IDM1IDEwIFEgNTAgMjUgNTAgNjUgWiIgZmlsbD0iI2ZmZmZmZiIgb3BhY2l0eT0iMC45Ii8+CiAgPC9nPgo8L3N2Zz4K";
  692. }
  694. }