src/ApplicationBundle/Controller/Api/InternalNotificationApiController.php line 147

Open in your IDE?
  1. <?php
  3. namespace ApplicationBundle\Controller\Api;
  5. use ApplicationBundle\Modules\Authentication\Constants\UserConstants;
  6. use CompanyGroupBundle\Entity\NotificationLog;
  7. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  8. use Symfony\Component\HttpFoundation\JsonResponse;
  9. use Symfony\Component\HttpFoundation\Request;
  11. /**
  12.  * InternalNotificationApiController
  13.  *
  14.  * Internal API endpoints called by the Node socket server.
  15.  * All routes are protected by X-Api-Key header checked against
  16.  * the socket_shared_secret parameter.
  17.  */
  18. class InternalNotificationApiController extends AbstractController
  19. {
  20.     private function checkApiKey(Request $request): bool
  21.     {
  22.         $secret = $this->getParameter('socket_shared_secret');
  23.         if (!$secret) return true; // not configured yet — allow during migration
  25.         $key = $request->headers->get('X-Api-Key', '');
  26.         return hash_equals($secret, $key);
  27.     }
  29.     /**
  30.      * GET /api/internal/tokens?userIds=1,2,3
  31.      *
  32.      * Returns FCM device tokens for the requested user IDs,
  33.      * fetched from entity_token_storage.fire_base_token.
  34.      */
  35.     public function getTokensAction(Request $request): JsonResponse
  36.     {
  37.         if (!$this->checkApiKey($request)) {
  38.             return new JsonResponse(['error' => 'Unauthorized'], 401);
  39.         }
  41.         $rawIds = $request->query->get('userIds', '');
  42.         if (!$rawIds) {
  43.             return new JsonResponse(['tokens' => []]);
  44.         }
  46.         $userIds = array_filter(
  47.             array_map('intval', explode(',', $rawIds)),
  48.             fn($id) => $id > 0
  49.         );
  51.         if (empty($userIds)) {
  52.             return new JsonResponse(['tokens' => []]);
  53.         }
  55.         $cgEm = $this->getDoctrine()->getManager('company_group');
  57.         try {
  58.             $rows = $cgEm->getConnection()->fetchAllAssociative(
  59.                 'SELECT user_id, fire_base_token
  60.                  FROM entity_token_storage
  61.                  WHERE user_id IN (' . implode(',', $userIds) . ')
  62.                    AND fire_base_token IS NOT NULL
  63.                    AND fire_base_token != \'\'',
  64.                 []
  65.             );
  66.         } catch (\Exception $e) {
  67.             return new JsonResponse(['tokens' => [], 'error' => $e->getMessage()]);
  68.         }
  70.         // Group by userId: userId => [token1, token2, ...]
  71.         $result = [];
  72.         foreach ($rows as $row) {
  73.             $uid = (int) $row['user_id'];
  74.             if (!isset($result[$uid])) $result[$uid] = [];
  75.             $result[$uid][] = $row['fire_base_token'];
  76.         }
  78.         return new JsonResponse(['tokens' => $result]);
  79.     }
  81.     /**
  82.      * POST /api/internal/fcm_log
  83.      *
  84.      * Accepts FCM delivery results from Node and persists them to notification_log.
  85.      * Also purges invalidated tokens from entity_token_storage.
  86.      */
  87.     public function fcmLogAction(Request $request): JsonResponse
  88.     {
  89.         if (!$this->checkApiKey($request)) {
  90.             return new JsonResponse(['error' => 'Unauthorized'], 401);
  91.         }
  93.         $data      = json_decode($request->getContent(), true) ?: [];
  94.         $eventCode = $data['eventCode'] ?? '';
  95.         $userIds   = $data['userIds'] ?? [];
  96.         $responses = $data['responses'] ?? [];
  98.         $cgEm = $this->getDoctrine()->getManager('company_group');
  100.         // Write per-user log entries
  101.         foreach ($userIds as $i => $uid) {
  102.             $response = $responses[$i] ?? null;
  103.             $success  = $response && $response['success'];
  104.             $errCode  = $response['errorCode'] ?? null;
  106.             $log = new NotificationLog();
  107.             $log->setEventCode($eventCode);
  108.             $log->setChannel('fcm');
  109.             $log->setRecipientUserId((int) $uid);
  110.             $log->setStatus($success ? NotificationLog::STATUS_SENT : NotificationLog::STATUS_FAILED);
  111.             $log->setError($errCode);
  112.             $cgEm->persist($log);
  114.             // Remove stale token from DB if FCM said it's unregistered
  115.             if (
  116.                 !$success &&
  117.                 in_array($errCode, [
  118.                     'messaging/registration-token-not-registered',
  119.                     'messaging/invalid-registration-token',
  120.                 ])
  121.             ) {
  122.                 try {
  123.                     $cgEm->getConnection()->executeStatement(
  124.                         'UPDATE entity_token_storage SET fire_base_token = NULL WHERE user_id = :uid',
  125.                         ['uid' => (int) $uid]
  126.                     );
  127.                 } catch (\Exception $e) {}
  128.             }
  129.         }
  131.         try {
  132.             $cgEm->flush();
  133.         } catch (\Exception $e) {}
  135.         return new JsonResponse(['ok' => true]);
  136.     }
  138.     /**
  139.      * GET /api/notifications/unread_count
  140.      *
  141.      * Returns unread notification count for the currently logged-in user.
  142.      * Called by frontend JS after a socket push to refresh the badge.
  143.      */
  144.     public function unreadCountAction(Request $request): JsonResponse
  145.     {
  146.         $session = $request->getSession();
  147.         $userId  = (int) $session->get(UserConstants::USER_ID, 0);
  148.         $companyId = (int) $session->get(UserConstants::USER_COMPANY_ID, 0);
  150.         if ($userId <= 0) {
  151.             return new JsonResponse(['count' => 0]);
  152.         }
  154.         $cgEm = $this->getDoctrine()->getManager('company_group');
  155.         try {
  156.             $count = (int) $cgEm->getConnection()->fetchOne(
  157.                 'SELECT COUNT(*) FROM entity_notification
  158.                  WHERE user_id = :uid AND company_id = :cid AND seen_flag = 0
  159.                    AND (expire_ts = 0 OR expire_ts > :now)',
  160.                 ['uid' => $userId, 'cid' => $companyId, 'now' => time()]
  161.             );
  162.         } catch (\Exception $e) {
  163.             $count = 0;
  164.         }
  166.         return new JsonResponse(['count' => $count]);
  167.     }
  169.     /**
  170.      * GET /api/notifications/recent?limit=15
  171.      *
  172.      * Returns the most recent notifications for the logged-in user as JSON.
  173.      * Used to pre-populate the header dropdown on every page load.
  174.      */
  175.     public function recentListAction(Request $request): JsonResponse
  176.     {
  177.         $session = $request->getSession();
  178.         $userId  = (int) $session->get(UserConstants::USER_ID, 0);
  179.         if ($userId <= 0) {
  180.             return new JsonResponse(['items' => [], 'unreadCount' => 0]);
  181.         }
  183.         $limit = min(20, max(1, (int) $request->query->get('limit', 15)));
  184.         $cgEm  = $this->getDoctrine()->getManager('company_group');
  186.         try {
  187.             $rows = $cgEm->getConnection()->fetchAllAssociative(
  188.                 'SELECT id, title, body, target_route, target_url, notification_ts, seen_flag
  189.                  FROM entity_notification
  190.                  WHERE user_id = :uid
  191.                  ORDER BY notification_ts DESC, id DESC
  192.                  LIMIT ' . $limit,
  193.                 ['uid' => $userId]
  194.             );
  196.             $unreadCount = (int) $cgEm->getConnection()->fetchOne(
  197.                 'SELECT COUNT(*) FROM entity_notification WHERE user_id = :uid AND seen_flag = 0',
  198.                 ['uid' => $userId]
  199.             );
  200.         } catch (\Exception $e) {
  201.             return new JsonResponse(['items' => [], 'unreadCount' => 0]);
  202.         }
  204.         $items = [];
  205.         foreach ($rows as $row) {
  206.             $items[] = [
  207.                 'id'             => (int) $row['id'],
  208.                 'title'          => $row['title'] ?: 'Notification',
  209.                 'body'           => $row['body'] ?: '',
  210.                 'targetRoute'    => $row['target_route'] ?: '',
  211.                 'targetUrl'      => $row['target_url'] ?: '',
  212.                 'notificationTs' => (int) $row['notification_ts'],
  213.                 'seenFlag'       => (int) $row['seen_flag'],
  214.             ];
  215.         }
  217.         return new JsonResponse(['items' => $items, 'unreadCount' => $unreadCount]);
  218.     }
  220.     /**
  221.      * POST /api/notifications/mark_read
  222.      *
  223.      * Marks one or all notifications as read for the current user.
  224.      */
  225.     public function markReadAction(Request $request): JsonResponse
  226.     {
  227.         $session = $request->getSession();
  228.         $userId  = (int) $session->get(UserConstants::USER_ID, 0);
  229.         if ($userId <= 0) {
  230.             return new JsonResponse(['ok' => false, 'error' => 'Not logged in']);
  231.         }
  233.         $id  = (int) ($request->request->get('id') ?: $request->query->get('id', 0));
  234.         $all = (bool) ($request->request->get('all') ?: $request->query->get('all', 0));
  236.         $cgEm = $this->getDoctrine()->getManager('company_group');
  237.         try {
  238.             if ($all) {
  239.                 $cgEm->getConnection()->executeStatement(
  240.                     'UPDATE entity_notification SET seen_flag = 1, read_flag = 1
  241.                      WHERE user_id = :uid',
  242.                     ['uid' => $userId]
  243.                 );
  244.             } elseif ($id > 0) {
  245.                 $cgEm->getConnection()->executeStatement(
  246.                     'UPDATE entity_notification SET seen_flag = 1, read_flag = 1
  247.                      WHERE id = :id AND user_id = :uid',
  248.                     ['id' => $id, 'uid' => $userId]
  249.                 );
  250.             }
  251.         } catch (\Exception $e) {
  252.             return new JsonResponse(['ok' => false, 'error' => $e->getMessage()]);
  253.         }
  255.         return new JsonResponse(['ok' => true]);
  256.     }
  257. }