src/Controller/Api/ConversationsController.php line 694

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;
  16. use App\Services\Core\AccesPremium;
  18. class ConversationsController extends AbstractController
  19. {
  20. /* Le verrou premium. Voir `App\Services\Core\AccesPremium`.
  22. ⚠️ IL NE S'APPLIQUE QU'AUX RECRUTEURS.
  24. `sendMessage` sert AUSSI aux candidats, et un candidat n'est
  25. jamais premium. Verrouiller sur `isPremium()` seul aurait coupé
  26. la parole à tous les candidats du site — et aucun test fait avec
  27. un compte entreprise ne l'aurait montré. */
  28. use AccesPremium;
  31. private $em;
  32. private $paginator;
  33. private $notificationService;
  35. public function __construct(EntityManagerInterface $em,
  36. PaginatorInterface $paginator,
  37. NotificationService $notificationService
  38. ) {
  39. $this->em = $em;
  40. $this->paginator = $paginator;
  41. $this->notificationService = $notificationService;
  42. }
  44. /* ══════════════════════════════════════════════════════════════════
  45. MASQUAGE D'IDENTITÉ — profil anonyme
  47. Une conversation peut porter `anonymousUserId` : l'utilisateur ainsi
  48. désigné est masqué pour SON INTERLOCUTEUR. C'est posé quand un
  49. recruteur écrit depuis /cv/{anonRef}, la porte anonyme du profil.
  51. ⚠️ UN SEUL ENDROIT DÉCIDE, ET TOUT LE MONDE L'APPELLE.
  53. L'identité fuyait par QUATRE canaux : la liste des conversations,
  54. chaque message, la notification in-app, et le payload poussé au
  55. WebSocket. Quatre masquages écrits séparément, c'est trois
  56. masquages corrects et un oubli — et l'oubli révèle quelqu'un qui
  57. avait demandé à ne pas l'être.
  59. ⚠️ L'E-MAIL AUSSI. Ce n'est pas qu'une question de nom : la liste
  60. des conversations renvoyait `userEmail`. Un nom masqué à côté
  61. d'une adresse `prenom.nom@societe.fr` ne masque rien.
  62. ══════════════════════════════════════════════════════════════════ */
  64. /**
  65. * L'identité à afficher pour `$autre` dans `$conversation`, vue par
  66. * `$lecteur`.
  67. *
  68. * @return array{fullname: string, avatar: string, email: string, masked: bool, reference?: ?string}
  69. */
  70. private function identite(Groups $conversation, ?Users $autre, ?Users $lecteur): array
  71. {
  72. $nomReel = $autre ? trim($autre->getName() . ' ' . $autre->getLastname()) : '';
  74. $avatarReel = $this->getDefaultAvatar();
  75. if ($autre && $autre->getImage()) {
  76. $avatarReel = $autre->getImageBase64();
  77. }
  79. /* On ne masque JAMAIS quelqu'un pour lui-même : le candidat doit se
  80. reconnaître dans son propre fil. Le masque protège de l'autre,
  81. pas de soi. */
  82. $memePersonne = $autre && $lecteur && $autre->getId() === $lecteur->getId();
  84. if ($memePersonne || !$autre || !$conversation->masque($autre->getId())) {
  85. return [
  86. 'fullname' => $nomReel,
  87. 'avatar' => $avatarReel,
  88. 'email' => $autre ? (string) $autre->getEmail() : '',
  89. 'masked' => false,
  90. ];
  91. }
  93. /* ══════════════════════════════════════════════════════════════
  94. LA RÉFÉRENCE DU CANDIDAT ANONYME, À LA PLACE DU NOM
  96. « Candidat anonyme » ne distingue rien : un recruteur qui a
  97. contacté trois CV anonymes voyait trois fils du même nom. La
  98. référence de la porte anonyme (`anon_ref`, celle de /cv/{ref})
  99. est ce qu'il a sous les yeux depuis le début — elle identifie le
  100. fil sans identifier la personne. Elle est publique par
  101. construction : c'est l'adresse qu'il a ouverte.
  102. ══════════════════════════════════════════════════════════════ */
  103. $reference = null;
  105. if ($autre && $autre->getCandidate() && $autre->getCandidate()->getAnonRef()) {
  106. $reference = $autre->getCandidate()->getAnonRef();
  107. }
  109. return [
  110. 'fullname' => $reference ? 'Candidat anonyme · ' . $reference : 'Candidat anonyme',
  111. 'avatar' => $this->getDefaultAvatar(),
  112. 'email' => '',
  113. 'masked' => true,
  114. 'reference' => $reference,
  115. ];
  116. }
  118. /**
  119. * Liste des conversations récentes de l'utilisateur connecté
  120. */
  121. public function recents(Request $request): JsonResponse
  122. {
  123. $user = $this->getUser();
  124. $limit = $request->query->get('limit', 20);
  126. $conversations = $this->em->getRepository(Groups::class)->recents($user, $limit);
  128. $array = [];
  129. foreach ($conversations as $conversation) {
  131. $otherUser = $conversation->getOtherUser($user);
  133. if (!$otherUser) {
  134. continue;
  135. }
  137. $countMessages = $this->em->getRepository(Messages::class)->countByConversation($conversation);
  139. /* Identité masquée si la conversation le prévoit — voir identite(). */
  140. $ident = $this->identite($conversation, $otherUser, $user);
  141. $fullname = $ident['fullname'];
  142. $avatar = $ident['avatar'];
  144. $array[] = [
  145. "id" => (string)$conversation->getId(),
  146. "conversationHash" => $conversation->getConversationHash(),
  147. "title" => $conversation->getTitle() ?: 'Conversation avec ' . $fullname,
  148. "fullname" => $fullname,
  149. "userId" => $otherUser->getId(),
  150. "userEmail" => $ident['email'],
  151. "anonymous" => $ident['masked'],
  152. "avatar" => $avatar,
  153. "count_messages" => $countMessages,
  154. "open" => false,
  155. "lastmessage" => $conversation->getLastMessageContent() ?? '',
  156. "lastMessageAt" => $conversation->getLastMessageAt() ? $conversation->getLastMessageAt()->format('c') : null,
  157. "createdAt" => $conversation->getCreatedAt() ? $conversation->getCreatedAt()->format('c') : null,
  158. ];
  159. }
  161. return new JsonResponse($array);
  162. }
  165. /**
  166. * Afficher les messages d'une conversation
  167. */
  168. public function show(Request $request, int $id): JsonResponse
  169. {
  170. $user = $this->getUser();
  172. $conversation = $this->em->getRepository(Groups::class)->find($id);
  174. if (!$conversation) {
  175. return new JsonResponse(['error' => 'Conversation non trouvée'], Response::HTTP_NOT_FOUND);
  176. }
  178. if (!$conversation->hasUser($user)) {
  179. return new JsonResponse(['error' => 'Accès interdit'], Response::HTTP_FORBIDDEN);
  180. }
  182. $limit = $request->query->get('limit', 100);
  183. $offset = $request->query->get('offset', 0);
  185. $messages = $this->em->getRepository(Messages::class)->findByConversation($conversation, $limit, $offset);
  187. $array = [];
  188. foreach ($messages as $message) {
  190. $isOwn = $message->getUser()->getId() === $user->getId();
  192. /* Chaque bulle porte le nom de son auteur : masquer la liste
  193. sans masquer les bulles laisserait le nom réel s'afficher au
  194. premier message reçu. */
  195. $ident = $this->identite($conversation, $message->getUser(), $user);
  196. $fullname = $ident['fullname'];
  197. $avatar = $ident['avatar'];
  199. $array[] = [
  200. "id" => (string)$message->getId(),
  201. "message" => (string)$message->getMessage(),
  202. "isOwn" => $isOwn,
  203. "userId" => $message->getUser()->getId(),
  204. "userName" => $fullname,
  205. "avatar" => $avatar,
  206. "anonymous" => $ident['masked'],
  207. "createdAt" => $message->getCreatedAt() ? $message->getCreatedAt()->format('c') : null,
  208. ];
  209. }
  211. return new JsonResponse($array);
  212. }
  214. /**
  215. * Envoyer un message
  216. */
  217. public function sendMessage(Request $request, int $id): JsonResponse
  218. {
  219. $user = $this->getUser();
  221. $conversation = $this->em->getRepository(Groups::class)->find($id);
  223. if (!$conversation) {
  224. return new JsonResponse(['error' => 'Conversation non trouvée'], Response::HTTP_NOT_FOUND);
  225. }
  227. if (!$conversation->hasUser($user)) {
  228. return new JsonResponse(['error' => 'Accès interdit'], Response::HTTP_FORBIDDEN);
  229. }
  231. /* ⚠️ « TOUT CONTACT » INCLUT LA RÉPONSE À UN FIL EXISTANT.
  233. Sans cette ligne, le verrou se contournerait tout seul : il
  234. suffirait d'avoir ouvert une conversation du temps de son
  235. abonnement, ou qu'un candidat écrive le premier, pour
  236. continuer d'écrire indéfiniment sans payer.
  238. Conséquence à connaître : un recruteur dont l'abonnement
  239. expire ne peut plus répondre, même à un candidat qui lui
  240. écrit. C'est le choix demandé — il se relâche en retirant
  241. ces quatre lignes. */
  242. if ($refus = $this->refuserSansPremium($user, 'contact')) {
  243. return $refus;
  244. }
  246. $data = json_decode($request->getContent(), true);
  247. $messageText = $data['message'] ?? null;
  249. if (empty($messageText)) {
  250. return new JsonResponse(['error' => 'Message vide'], Response::HTTP_BAD_REQUEST);
  251. }
  253. $emetteur = $user;
  254. $destinataire = null;
  256. if($conversation->getUserOne() !== $user) {
  257. $destinataire = $conversation->getUserOne();
  258. }
  260. if($conversation->getUserTwo() !== $user) {
  261. $destinataire = $conversation->getUserTwo();
  262. }
  264. // Créer le message
  265. $message = new Messages();
  266. $message->setMessage($messageText);
  267. $message->setUser($user);
  268. $message->setGroup($conversation);
  269. $message->setCreatedAt(new \DateTime());
  270. $this->em->persist($message);
  271. $this->em->flush();
  273. // Mettre à jour la conversation (avec le nouveau champ lastMessageSenderId)
  274. $conversation->setLastMessageContent(substr($messageText, 0, 100));
  275. $conversation->setLastMessageId($message->getId());
  276. $conversation->setLastMessageAt(new \DateTime());
  277. $conversation->setLastMessageSenderId($user->getId()); // ← NOUVEAU
  278. $this->em->persist($conversation);
  279. $this->em->flush();
  281. // Vers le destinataire
  282. $notification = new Notifications();
  283. $notification->setViewed(false);
  284. $notification->setOnlyAdmin(false);
  285. $notification->setTitle("message");
  286. if($conversation->getUserOne()->getLanguage() == "fr") {
  287. /* La notification nomme l'émetteur : sans masquage, elle
  288. annulerait tout le reste en une ligne. */
  289. $notification->setDescription("Message reçu par ".$this->identite($conversation, $emetteur, $destinataire)['fullname']);
  290. $this->notificationService->sendToUser(
  291. $destinataire,
  292. 'Nouveau message',
  293. $this->cleanMessageNotification($message->getMessage()),
  294. ['type' => 'message', 'conversationId' => $conversation->getId()],
  295. );
  296. } else {
  297. $this->notificationService->sendToUser(
  298. $destinataire,
  299. 'New message',
  300. $this->cleanMessageNotification($message->getMessage()),
  301. ['type' => 'message', 'conversationId' => $conversation->getId()],
  302. );
  303. $notification->setDescription("Message received by ".$this->identite($conversation, $emetteur, $destinataire)['fullname']);
  304. }
  305. $notification->setType("default");
  306. $notification->setUser($conversation->getUserTwo());
  307. $this->em->persist($notification);
  308. $this->em->flush();
  310. /* ⚠️ LE POINT LE PLUS FACILE À OUBLIER.
  312. Ce payload part vers le serveur WebSocket, qui le REDIFFUSE TEL
  313. QUEL au navigateur de l'interlocuteur. Masquer les endpoints REST
  314. en laissant celui-ci intact reviendrait à masquer la porte en
  315. laissant la fenêtre ouverte : le nom réel s'afficherait en direct,
  316. à la seconde où le message part.
  318. Le serveur WebSocket n'a rien à savoir de tout ça — c'est un
  319. relais. On lui donne déjà le texte masqué. */
  320. $identEmetteur = $this->identite($conversation, $user, $conversation->getOtherUser($user));
  321. $fullname = $identEmetteur['fullname'];
  322. $avatar = $identEmetteur['avatar'];
  324. try {
  325. $client = new \GuzzleHttp\Client([
  326. 'timeout' => 5.0,
  327. 'verify' => false,
  328. ]);
  330. $websocketUrl = rtrim((string) ($_ENV["WEBSOCKET_HTTP_URL"] ?? ''), '/').'/broadcast';
  332. /* ⚠️ LE SECRET PARTAGÉ AVEC LE SERVEUR WEBSOCKET.
  334. Le serveur WS protège `/broadcast` par `BROADCAST_SECRET`
  335. (en-tête `X-Internal-Secret`). Tant qu'on ne l'envoyait pas,
  336. poser ce secret côté WS coupait TOUTES les notifications
  337. temps réel — 403 à chaque message, visible seulement dans les
  338. journaux. La même valeur, dans `WEBSOCKET_BROADCAST_SECRET`
  339. ici : l'en-tête n'est envoyé que si elle est renseignée, donc
  340. un serveur WS sans secret continue de fonctionner. */
  341. $secretBroadcast = trim((string) ($_ENV["WEBSOCKET_BROADCAST_SECRET"] ?? ''));
  342. $entetesBroadcast = ['Content-Type' => 'application/json'];
  343. if ($secretBroadcast !== '') {
  344. $entetesBroadcast['X-Internal-Secret'] = $secretBroadcast;
  345. }
  347. error_log("╔═══════════════════════════════════════════════════════╗");
  348. error_log("║ 📡 BROADCAST WEBSOCKET - ENVOI MESSAGE ║");
  349. error_log("╚═══════════════════════════════════════════════════════╝");
  350. error_log("🔡 [WebSocket] URL cible : " . $websocketUrl);
  351. error_log("🔡 [WebSocket] Group ID : " . $conversation->getId());
  352. error_log("🔡 [WebSocket] Message ID: " . $message->getId());
  353. error_log("🔡 [WebSocket] User ID : " . $user->getId());
  354. error_log("🔡 [WebSocket] Fullname : " . $fullname);
  356. $broadcastData = [
  357. 'groupId' => (int) $conversation->getId(),
  358. 'message' => [
  359. 'id' => (int) $message->getId(),
  360. 'message' => $message->getMessage(),
  361. 'isOwn' => false,
  362. 'userId' => $user->getId(),
  363. 'userName' => $fullname,
  364. 'avatar' => $avatar,
  365. 'anonymous' => $identEmetteur['masked'],
  366. 'reference' => $identEmetteur['reference'] ?? null,
  367. 'createdAt' => $message->getCreatedAt()->format('c'),
  368. ]
  369. ];
  371. error_log("📤 [WebSocket] Données envoyées: " . json_encode($broadcastData));
  373. $response = $client->post($websocketUrl, [
  374. 'json' => $broadcastData,
  375. 'headers' => $entetesBroadcast,
  376. ]);
  378. $statusCode = $response->getStatusCode();
  379. $body = $response->getBody()->getContents();
  380. $bodyData = json_decode($body, true);
  382. error_log("✅ [WebSocket] Notification envoyée - Status: " . $statusCode);
  383. error_log("✅ [WebSocket] Réponse: " . $body);
  385. if (isset($bodyData['clientsNotified'])) {
  386. $clientsNotified = $bodyData['clientsNotified'];
  387. error_log("📊 [WebSocket] Clients notifiés: " . $clientsNotified);
  389. if ($clientsNotified === 0) {
  390. error_log("⚠️ [WebSocket] ATTENTION: Aucun client n'a reçu le message !");
  391. error_log(" Raisons possibles:");
  392. error_log(" 1. Aucun navigateur connecté à cette conversation");
  393. error_log(" 2. Les clients ne sont pas dans la bonne room");
  394. error_log(" 3. Les clients n'ont pas appelé joinGroup()");
  395. }
  396. }
  398. error_log("═══════════════════════════════════════════════════════");
  400. } catch (\GuzzleHttp\Exception\ConnectException $e) {
  401. error_log("╔═══════════════════════════════════════════════════════╗");
  402. error_log("║ ❌ ERREUR DE CONNEXION WEBSOCKET ║");
  403. error_log("╚═══════════════════════════════════════════════════════╝");
  404. error_log("❌ [WebSocket] Impossible de se connecter au serveur");
  405. error_log(" URL tentée: " . ($websocketUrl ?? 'undefined'));
  406. error_log(" Message: " . $e->getMessage());
  407. error_log(" ⚠️ Le serveur WebSocket est-il démarré ?");
  408. error_log(" Commande: pm2 status");
  409. error_log("═══════════════════════════════════════════════════════");
  411. } catch (\GuzzleHttp\Exception\RequestException $e) {
  412. error_log("╔═══════════════════════════════════════════════════════╗");
  413. error_log("║ ❌ ERREUR REQUÊTE WEBSOCKET ║");
  414. error_log("╚═══════════════════════════════════════════════════════╝");
  415. error_log("❌ [WebSocket] Erreur lors de la requête");
  416. error_log(" Message: " . $e->getMessage());
  417. if ($e->hasResponse()) {
  418. error_log(" Status: " . $e->getResponse()->getStatusCode());
  419. error_log(" Body: " . $e->getResponse()->getBody()->getContents());
  420. }
  421. error_log("═══════════════════════════════════════════════════════");
  423. } catch (\Exception $e) {
  424. error_log("╔═══════════════════════════════════════════════════════╗");
  425. error_log("║ ❌ ERREUR GÉNÉRALE WEBSOCKET ║");
  426. error_log("╚═══════════════════════════════════════════════════════╝");
  427. error_log("❌ [WebSocket] Erreur: " . $e->getMessage());
  428. error_log(" Type: " . get_class($e));
  429. error_log(" File: " . $e->getFile() . ":" . $e->getLine());
  430. error_log("⚠️ Le message a été enregistré mais la notification temps réel n'a pas pu être envoyée");
  431. error_log("═══════════════════════════════════════════════════════");
  432. }
  434. return new JsonResponse([
  435. 'id' => (string)$message->getId(),
  436. 'message' => $message->getMessage(),
  437. 'isOwn' => true,
  438. 'userId' => $user->getId(),
  439. 'userName' => $fullname,
  440. 'avatar' => $avatar,
  441. 'createdAt' => $message->getCreatedAt() ? $message->getCreatedAt()->format('c') : null,
  442. ], Response::HTTP_CREATED);
  443. }
  445. /**
  446. * Récupérer les nouveaux messages depuis un certain ID (polling)
  447. */
  448. public function getNewMessages(Request $request, int $id): JsonResponse
  449. {
  450. $user = $this->getUser();
  452. $conversation = $this->em->getRepository(Groups::class)->find($id);
  454. if (!$conversation) {
  455. return new JsonResponse(['error' => 'Conversation non trouvée'], Response::HTTP_NOT_FOUND);
  456. }
  458. if (!$conversation->hasUser($user)) {
  459. return new JsonResponse(['error' => 'Accès interdit'], Response::HTTP_FORBIDDEN);
  460. }
  462. $lastMessageId = $request->query->get('lastMessageId', 0);
  464. $messages = $this->em->getRepository(Messages::class)->findAfterMessage($conversation, $lastMessageId);
  466. $array = [];
  467. foreach ($messages as $message) {
  468. $isOwn = $message->getUser()->getId() === $user->getId();
  469. /* Masquage : voir identite(). */
  470. $ident = $this->identite($conversation, $message->getUser(), $user);
  471. $fullname = $ident['fullname'];
  472. $avatar = $ident['avatar'];
  474. $array[] = [
  475. "id" => (string)$message->getId(),
  476. "message" => (string)$message->getMessage(),
  477. "isOwn" => $isOwn,
  478. "userId" => $message->getUser()->getId(),
  479. "userName" => $fullname,
  480. "avatar" => $avatar,
  481. "createdAt" => $message->getCreatedAt() ? $message->getCreatedAt()->format('c') : null,
  482. ];
  483. }
  485. return new JsonResponse($array);
  486. }
  488. /**
  489. * Rechercher dans les conversations
  490. */
  491. public function search(Request $request): JsonResponse
  492. {
  493. $user = $this->getUser();
  494. $searchTerm = $request->query->get('q', '');
  496. if (empty(trim($searchTerm))) {
  497. return new JsonResponse(['error' => 'Terme de recherche requis'], Response::HTTP_BAD_REQUEST);
  498. }
  500. $conversations = $this->em->getRepository(Groups::class)->searchConversations($user, $searchTerm);
  502. $array = [];
  503. foreach ($conversations as $conversation) {
  504. $otherUser = $conversation->getOtherUser($user);
  506. if (!$otherUser) {
  507. continue;
  508. }
  510. $countMessages = $this->em->getRepository(Messages::class)->countByConversation($conversation);
  511. /* Masquage : voir identite(). */
  512. $ident = $this->identite($conversation, $otherUser, $user);
  513. $fullname = $ident['fullname'];
  514. $avatar = $ident['avatar'];
  516. $array[] = [
  517. "id" => (string)$conversation->getId(),
  518. "conversationHash" => $conversation->getConversationHash(),
  519. "title" => $conversation->getTitle() ?: 'Conversation avec ' . $fullname,
  520. "fullname" => $fullname,
  521. "userId" => $otherUser->getId(),
  522. "avatar" => $avatar,
  523. "count_messages" => $countMessages,
  524. "lastmessage" => $conversation->getLastMessageContent() ?? '',
  525. "lastMessageAt" => $conversation->getLastMessageAt() ? $conversation->getLastMessageAt()->format('c') : null,
  526. ];
  527. }
  529. return new JsonResponse($array);
  530. }
  532. /**
  533. * Supprimer une conversation (soft delete ou hard delete selon votre besoin)
  534. */
  535. public function deleteConversation(int $id): JsonResponse
  536. {
  537. $user = $this->getUser();
  539. $conversation = $this->em->getRepository(Groups::class)->find($id);
  541. if (!$conversation) {
  542. return new JsonResponse(['error' => 'Conversation non trouvée'], Response::HTTP_NOT_FOUND);
  543. }
  545. if (!$conversation->hasUser($user)) {
  546. return new JsonResponse(['error' => 'Accès interdit'], Response::HTTP_FORBIDDEN);
  547. }
  549. return new JsonResponse(['message' => 'Conversation supprimée avec succès']);
  550. }
  552. /**
  553. * Démarrer une conversation
  554. */
  555. public function startConversation(Request $request, int $userId): JsonResponse
  556. {
  557. $user = $this->getUser();
  559. if (!$user) {
  560. return new JsonResponse(['error' => 'Non authentifié'], Response::HTTP_UNAUTHORIZED);
  561. }
  563. /* ⚠️ AVANT DE CHERCHER L'AUTRE UTILISATEUR.
  565. Sinon un compte non premium pourrait, par la différence entre
  566. « utilisateur non trouvé » et « accès refusé », tester des
  567. identifiants au hasard pour savoir lesquels existent. */
  568. if ($refus = $this->refuserSansPremium($user, 'contact')) {
  569. return $refus;
  570. }
  572. $otherUser = $this->em->getRepository(Users::class)->find($userId);
  574. if (!$otherUser) {
  575. return new JsonResponse(['error' => 'Utilisateur non trouvé'], Response::HTTP_NOT_FOUND);
  576. }
  578. if ($user->getId() === $otherUser->getId()) {
  579. return new JsonResponse(['error' => 'Impossible de démarrer une conversation avec soi-même'], Response::HTTP_BAD_REQUEST);
  580. }
  582. $conversation = $this->em->getRepository(Groups::class)->findOrCreateConversation($user, $otherUser);
  584. /* Masquage : voir identite(). Cet endpoint renvoie le nom au moment
  585. d'ouvrir un fil — c'est exactement là qu'un anonyme se ferait
  586. démasquer sans que rien ne le signale. */
  587. $ident = $this->identite($conversation, $otherUser, $user);
  589. return new JsonResponse([
  590. 'id' => (string)$conversation->getId(),
  591. 'conversationHash' => $conversation->getConversationHash(),
  592. 'fullname' => $ident['fullname'],
  593. 'anonymous' => $ident['masked'],
  594. 'reference' => $ident['reference'] ?? null,
  595. 'userId' => $otherUser->getId(),
  596. ], Response::HTTP_CREATED);
  597. }
  599. // ========================================
  600. // NOUVELLES MÉTHODES — V2 avec lu/non lu
  601. // ========================================
  603. /**
  604. * Liste des conversations récentes V2 — avec lastMessageSenderId et unread_count
  605. * Utilise le vrai compteur de messages non lus (basé sur readAt)
  606. */
  607. public function recentsV2(Request $request): JsonResponse
  608. {
  609. $user = $this->getUser();
  611. if (!$user) {
  612. return new JsonResponse(['error' => 'Non authentifié'], Response::HTTP_UNAUTHORIZED);
  613. }
  615. $limit = $request->query->get('limit', 20);
  617. $conversations = $this->em->getRepository(Groups::class)->recents($user, $limit);
  618. $messagesRepo = $this->em->getRepository(Messages::class);
  620. $array = [];
  621. foreach ($conversations as $conversation) {
  623. $otherUser = $conversation->getOtherUser($user);
  625. if (!$otherUser) {
  626. continue;
  627. }
  629. // Compteur de messages NON LUS (messages de l'autre que je n'ai pas lus)
  630. $unreadCount = $messagesRepo->countUnreadByConversation($conversation, $user);
  632. /* Masquage : voir identite(). */
  633. $ident = $this->identite($conversation, $otherUser, $user);
  634. $fullname = $ident['fullname'];
  635. $avatar = $ident['avatar'];
  637. $array[] = [
  638. "id" => (string)$conversation->getId(),
  639. "conversationHash" => $conversation->getConversationHash(),
  640. "title" => $conversation->getTitle() ?: 'Conversation avec ' . $fullname,
  641. "fullname" => $fullname,
  642. "userId" => $otherUser->getId(),
  643. "userEmail" => $otherUser->getEmail(),
  644. "avatar" => $avatar,
  645. "count_messages" => $unreadCount, // ← maintenant = non lus uniquement
  646. "lastMessageSenderId" => $conversation->getLastMessageSenderId(), // ← NOUVEAU
  647. "open" => false,
  648. "lastmessage" => $conversation->getLastMessageContent() ?? '',
  649. "lastMessageAt" => $conversation->getLastMessageAt() ? $conversation->getLastMessageAt()->format('c') : null,
  650. "createdAt" => $conversation->getCreatedAt() ? $conversation->getCreatedAt()->format('c') : null,
  651. ];
  652. }
  654. return new JsonResponse($array);
  655. }
  657. /**
  658. * Marquer tous les messages d'une conversation comme lus
  659. * Appelé quand l'utilisateur ouvre une conversation
  660. */
  661. public function markAsRead(int $id): JsonResponse
  662. {
  663. $user = $this->getUser();
  665. if (!$user) {
  666. return new JsonResponse(['error' => 'Non authentifié'], Response::HTTP_UNAUTHORIZED);
  667. }
  669. $conversation = $this->em->getRepository(Groups::class)->find($id);
  671. if (!$conversation) {
  672. return new JsonResponse(['error' => 'Conversation non trouvée'], Response::HTTP_NOT_FOUND);
  673. }
  675. if (!$conversation->hasUser($user)) {
  676. return new JsonResponse(['error' => 'Accès interdit'], Response::HTTP_FORBIDDEN);
  677. }
  679. // Marquer comme lus tous les messages de l'autre utilisateur
  680. $markedCount = $this->em->getRepository(Messages::class)
  681. ->markAsReadByConversation($conversation, $user);
  683. error_log("✅ [MarkAsRead] Conv {$id} — {$markedCount} messages marqués comme lus pour user {$user->getId()}");
  685. return new JsonResponse([
  686. 'success' => true,
  687. 'markedCount' => $markedCount,
  688. ]);
  689. }
  691. /**
  692. * Obtenir le nombre total de messages non lus (pour le badge de l'onglet Messages)
  693. */
  694. public function totalUnread(): JsonResponse
  695. {
  696. $user = $this->getUser();
  698. if (!$user) {
  699. return new JsonResponse(['error' => 'Non authentifié'], Response::HTTP_UNAUTHORIZED);
  700. }
  702. $totalUnread = $this->em->getRepository(Messages::class)
  703. ->countTotalUnreadForUser($user);
  705. return new JsonResponse([
  706. 'totalUnread' => $totalUnread,
  707. ]);
  708. }
  710. // ========================================
  711. // HELPERS PRIVÉS
  712. // ========================================
  714. private function cleanMessageNotification($texte, $longueur = 20) {
  715. if (mb_strlen($texte) <= $longueur) {
  716. return $texte;
  717. }
  718. return mb_substr($texte, 0, $longueur) . '...';
  719. }
  721. /**
  722. * Avatar SVG par défaut
  723. */
  724. private function getDefaultAvatar(): string
  725. {
  726. return "data:image/svg+xml;base64,PHN2ZyB3aWR0aD0iMjAwIiBoZWlnaHQ9IjIwMCIgdmlld0JveD0iMCAwIDIwMCAyMDAiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyI+CiAgPGRlZnM+CiAgICA8bGluZWFyR3JhZGllbnQgaWQ9ImdyYWQiIHgxPSIwJSIgeTE9IjAlIiB4Mj0iMTAwJSIgeTI9IjEwMCUiPgogICAgICA8c3RvcCBvZmZzZXQ9IjAlIiBzdHlsZT0ic3RvcC1jb2xvcjojNjY3ZWVhO3N0b3Atb3BhY2l0eToxIiAvPgogICAgICA8c3RvcCBvZmZzZXQ9IjEwMCUiIHN0eWxlPSJzdG9wLWNvbG9yOiM3NjRiYTI7c3RvcC1vcGFjaXR5OjEiIC8+CiAgICA8L2xpbmVhckdyYWRpZW50PgogIDwvZGVmcz4KICA8Y2lyY2xlIGN4PSIxMDAiIGN5PSIxMDAiIHI9IjEwMCIgZmlsbD0idXJsKCNncmFkKSIvPgogIDxnIHRyYW5zZm9ybT0idHJhbnNsYXRlKDEwMCwgMTAwKSI+CiAgICA8Y2lyY2xlIGN4PSIwIiBjeT0iLTE1IiByPSIzNSIgZmlsbD0iI2ZmZmZmZiIgb3BhY2l0eT0iMC45Ii8+CiAgICA8cGF0aCBkPSJNIC01MCA2NSBRIC01MCAyNSAtMzUgMTAgUSAtMTUgLTUgMCAtNSBRIDE1IC01IDM1IDEwIFEgNTAgMjUgNTAgNjUgWiIgZmlsbD0iI2ZmZmZmZiIgb3BhY2l0eT0iMC45Ii8+CiAgPC9nPgo8L3N2Zz4K";
  727. }
  729. }