NotificationHandler.inc.php

<?php
 
import('classes.handler.Handler');
import('classes.notification.Notification');
 
class NotificationHandler extends Handler {
 
   function fetchNotification($args, $request) {
      $this->setupTemplate($request);
      $user = $request->getUser();
      $userId = $user?$user->getId():null;
      $context = $request->getContext();
      $notificationDao = DAORegistry::getDAO('NotificationDAO'); /* @var $notificationDao NotificationDAO */
      $notifications = array();
 
      // Get the notification options from request.
      $notificationOptions = $request->getUserVar('requestOptions');
 
      if (!$user) {
         $notifications = array();
      } elseif (is_array($notificationOptions)) {
         // Retrieve the notifications.
         $notifications = $this->_getNotificationsByOptions($notificationOptions, $context->getId(), $userId);
      } else {
         // No options, get only TRIVIAL notifications.
         $notifications = $notificationDao->getByUserId($userId, NOTIFICATION_LEVEL_TRIVIAL);
         $notifications = $notifications->toArray();
      }
 
      import('lib.pkp.classes.core.JSONMessage');
      $json = new JSONMessage();
 
      if (is_array($notifications) && !empty($notifications)) {
         $formattedNotificationsData = array();
         $notificationManager = new NotificationManager();
 
         // Format in place notifications.
         $formattedNotificationsData['inPlace'] = $notificationManager->formatToInPlaceNotification($request, $notifications);
 
         // Format general notifications.
         $formattedNotificationsData['general'] = $notificationManager->formatToGeneralNotification($request, $notifications);
 
         // Delete trivial notifications from database.
         $notificationManager->deleteTrivialNotifications($notifications);
 
         $json->setContent($formattedNotificationsData);
      }
 
      return $json;
   }
 
   function _getNotificationsByOptions($notificationOptions, $contextId, $userId = null) {
      $notificationDao = DAORegistry::getDAO('NotificationDAO'); /* @var $notificationDao NotificationDAO */
      $notificationsArray = array();
      $notificationMgr = new NotificationManager();
 
      foreach ($notificationOptions as $level => $levelOptions) {
         if ($levelOptions) {
            foreach ($levelOptions as $type => $typeOptions) {
               if ($typeOptions) {
                  $notificationMgr->isVisibleToAllUsers($type, $typeOptions['assocType'], $typeOptions['assocId']) ? $workingUserId = null : $workingUserId = $userId;
                  $notificationsResultFactory = $notificationDao->getByAssoc($typeOptions['assocType'], $typeOptions['assocId'], $workingUserId, $type, $contextId);
                  $notificationsArray = $this->_addNotificationsToArray($notificationsResultFactory, $notificationsArray);
               } else {
                  if ($userId) {
                     $notificationsResultFactory = $notificationDao->getByUserId($userId, $level, $type, $contextId);
                     $notificationsArray = $this->_addNotificationsToArray($notificationsResultFactory, $notificationsArray);
                  }
               }
            }
         } else {
            if ($userId) {
               $notificationsResultFactory = $notificationDao->getByUserId($userId, $level, null, $contextId);
               $notificationsArray = $this->_addNotificationsToArray($notificationsResultFactory, $notificationsArray);
            }
         }
         $notificationsResultFactory = null;
      }
 
      return $notificationsArray;
   }
 
   function _addNotificationsToArray($resultFactory, $notificationArray) {
      if (!$resultFactory->wasEmpty()) {
         $notificationArray = array_merge($notificationArray, $resultFactory->toArray());
      }
 
      return $notificationArray;
   }
 
   function setupTemplate($request) {
      AppLocale::requireComponents(LOCALE_COMPONENT_PKP_GRID, LOCALE_COMPONENT_PKP_SUBMISSION);
      parent::setupTemplate($request);
   }
}