=It's been a minute. I went through the Routes and associated Managers and ...

Jake Vanderwerf

2026-08-25 3d25ad7de4fdbb3eba2cde2a62422e6be5d79a0a

 inc/rest/routes/NotificationsRoutes.php

@@ -1,6 +1,7 @@
<?php
namespace JVBase\rest\routes;

use JVBase\Instance;
use JVBase\managers\Cache;
use JVBase\managers\CustomTable;
use JVBase\registrar\Registrar;
@@ -23,6 +24,7 @@
 */
class NotificationsRoutes extends Rest
{
   use Instance;
   protected int $user_id;
   protected array $notification_types = [];
   protected object $manager;
@@ -133,7 +135,7 @@
    */
   public function init(): void
   {
      $this->manager = JVB()->notification();
      $this->manager = NotificationManager::getInstance();
      $this->notification_types = $this->manager->getNotificationTypes(true);
   }

@@ -146,7 +148,6 @@
      Route::for('notifications')
         ->get([$this, 'getNotifications'])
         ->args([
            'user' => 'integer|required',
            'type' => 'string',
            'status' => 'string|enum:unread,read,actioned,dismissed',
            'limit' => 'integer|default:20|min:1|max:100',
@@ -160,7 +161,6 @@
      Route::for('notifications/read')
         ->post([$this, 'markRead'])
         ->args([
            'user' => 'integer|required',
            'notification_id' => 'integer|required',
         ])
         ->auth('user')
@@ -171,7 +171,6 @@
      Route::for('notifications/read-all')
         ->post([$this, 'markAllRead'])
         ->args([
            'user' => 'integer|required',
            'type' => 'string',
         ])
         ->auth('user')
@@ -182,7 +181,6 @@
      Route::for('notifications/action')
         ->post([$this, 'markActioned'])
         ->args([
            'user' => 'integer|required',
            'notification_id' => 'integer|required',
         ])
         ->auth('user')
@@ -193,7 +191,6 @@
      Route::for('notifications/dismiss')
         ->post([$this, 'markDismissed'])
         ->args([
            'user' => 'integer|required',
            'notification_id' => 'integer|required',
         ])
         ->auth('user')
@@ -204,7 +201,6 @@
      Route::for('notifications/count')
         ->get([$this, 'getUnreadCount'])
         ->args([
            'user' => 'integer|required',
            'type' => 'string',
         ])
         ->auth('user')
@@ -221,16 +217,15 @@
    */
   public function getNotifications(WP_REST_Request $request): WP_REST_Response
   {
      $user_id = absint($request->get_param('user'));
      $user_id = get_current_user_id();
      if (!$user_id) {
         return $this->unauthorized();
      }
      $type = sanitize_text_field($request->get_param('type') ?? '');
      $status = sanitize_text_field($request->get_param('status') ?? '');
      $limit = absint($request->get_param('limit'));
      $offset = absint($request->get_param('offset'));

      if (!$this->checkUser($user_id)) {
         return $this->unauthorized();
      }

      $cacheKey = compact('user_id', 'type', 'status', 'limit', 'offset');

      $result = $this->cache->remember($cacheKey, function() use ($user_id, $type, $status, $limit, $offset) {
@@ -265,12 +260,11 @@
    */
   public function getUnreadCount(WP_REST_Request $request): WP_REST_Response
   {
      $user_id = absint($request->get_param('user'));
      $type = sanitize_text_field($request->get_param('type') ?? '');

      if (!$this->checkUser($user_id)) {
      $user_id = get_current_user_id();
      if (!$user_id) {
         return $this->unauthorized();
      }
      $type = sanitize_text_field($request->get_param('type') ?? '');

      $cacheKey = compact('user_id', 'type');

@@ -555,7 +549,7 @@
            $statusCondition = $wpdb->prepare("a.status = %s", $status);
         }

         $approvals = Registrar::getFeatured('approve_new');
         $approvals = Registrar::withFeature('approve_new');
         foreach ($approvals as $type => $config) {
            $table = $wpdb->prefix . BASE . 'approval_' . $type . 'requests';
            $votes = $wpdb->prefix . BASE . 'approval_' . $type . 'votes';
@@ -647,12 +641,11 @@
    */
   public function markRead(WP_REST_Request $request): WP_REST_Response
   {
      $user_id = absint($request->get_param('user'));
      $notification_id = absint($request->get_param('notification_id'));

      if (!$this->checkUser($user_id)) {
      $user_id = get_current_user_id();
      if (!$user_id) {
         return $this->unauthorized();
      }
      $notification_id = absint($request->get_param('notification_id'));

      try {
         $result = $this->notifications->transaction(function($table) use ($notification_id, $user_id) {
@@ -695,12 +688,11 @@
    */
   public function markAllRead(WP_REST_Request $request): WP_REST_Response
   {
      $user_id = absint($request->get_param('user'));
      $type = sanitize_text_field($request->get_param('type') ?? '');

      if (!$this->checkUser($user_id)) {
      $user_id = get_current_user_id();
      if (!$user_id) {
         return $this->unauthorized();
      }
      $type = sanitize_text_field($request->get_param('type') ?? '');

      try {
         $where = ['owner_id' => $user_id, 'status' => 'unread'];
@@ -730,12 +722,11 @@
    */
   public function markActioned(WP_REST_Request $request): WP_REST_Response
   {
      $user_id = absint($request->get_param('user'));
      $notification_id = absint($request->get_param('notification_id'));

      if (!$this->checkUser($user_id)) {
      $user_id = get_current_user_id();
      if (!$user_id) {
         return $this->unauthorized();
      }
      $notification_id = absint($request->get_param('notification_id'));

      try {
         $result = $this->notifications->transaction(function($table) use ($notification_id, $user_id) {
@@ -779,12 +770,11 @@
    */
   public function markDismissed(WP_REST_Request $request): WP_REST_Response
   {
      $user_id = absint($request->get_param('user'));
      $notification_id = absint($request->get_param('notification_id'));

      if (!$this->checkUser($user_id)) {
      $user_id = get_current_user_id();
      if (!$user_id) {
         return $this->unauthorized();
      }
      $notification_id = absint($request->get_param('notification_id'));

      try {
         $result = $this->notifications->transaction(function($table) use ($notification_id, $user_id) {
@@ -979,7 +969,7 @@
      }

      if (!empty($queueData)) {
         JVB()->queue()->queueOperation(
         Queue::getInstance()->queueOperation(
            'notification_' . $action,
            $args['user_id'],
            $queueData
@@ -1318,7 +1308,7 @@
         'status' => in_array($params['status'] ?? '', ['all', 'unread', 'expired'])
            ? $params['status']
            : 'unread',
         'user_id' => absint($params['user'] ?? get_current_user_id()),
         'user_id' => get_current_user_id(),
         'page' => absint($params['page'] ?? 1),
         'type' => in_array($params['type'] ?? '', array_keys($this->manager->notification_types ?? []))
            ? $params['type']