, Christian Binder * @version $Id$ */ use EGroupware\Api; /** * Ajax methods for notifications */ class notifications_ajax { /** * Appname */ const _appname = 'notifications'; /** * Mailappname */ const _mailappname = 'mail'; /** * Notification table in SQL database */ const _notification_table = 'egw_notificationpopup'; /** * Notification type */ const _type = 'base'; /** * holds account object for user to notify * * @var object */ private $recipient; /** * holds config object (sitewide application config) * * @var object */ private $config; /** * holds preferences array of user to notify * * @var array */ private $preferences; /** * reference to global db object * * @var Api\Db */ private $db; /** * holds the users session data * * @var array */ var $session_data; /** * holds the users session data defaults * * @var array */ var $session_data_defaults = array( 'notified_mail_uids' => array(), ); /** * the xml response object * * @var Api\Json\Response */ private $response; /** * constructor * */ public function __construct() { $this->response = Api\Json\Response::get(); $this->recipient = (object)$GLOBALS['egw']->accounts->read($GLOBALS['egw_info']['user']['account_id']); $this->config = (object)Api\Config::read(self::_appname); $prefs = new Api\Preferences($this->recipient->account_id); $this->preferences = $prefs->read(); $this->db = $GLOBALS['egw']->db; } /** * public AJAX trigger function to be called by the JavaScript client * * this function calls all other recurring AJAX notifications methods * to have ONE single recurring AJAX call per user * * @return xajax response */ public function get_notifications($browserNotify = false) { // close session now, to not block other user actions, as specially mail checks can be time consuming $GLOBALS['egw']->session->commit_session(); // call a hook for notifications on new mail //if ($GLOBALS['egw_info']['user']['apps']['mail']) $this->check_mailbox(); Api\Hooks::process('check_notify'); // update currentusers if ($GLOBALS['egw_info']['user']['apps']['admin'] && $GLOBALS['egw_info']['user']['preferences']['common']['show_currentusers']) { $this->response->jquery('#currentusers', 'text', array((string)$GLOBALS['egw']->session->session_count())); } $this->get_egwpopup($browserNotify); } /** * Remove given notification id(s) from the table * * @param array|int $notify_ids one or multiple notify_id(s) */ public function delete_message($notify_ids) { if ($notify_ids) { $this->db->delete(self::_notification_table,array( 'notify_id' => $notify_ids, 'account_id' => $this->recipient->account_id, 'notify_type' => self::_type ),__LINE__,__FILE__,self::_appname); } } /** * Method to update message(s) status * * @param int|array $notify_ids one or more notify_id(s) * @param string $status = SEEN, status of message: * - SEEN: message has been seen * - UNSEEN: message has not been seen * - DISPLAYED: message has been shown but no further status applied yet * this status has been used more specifically for browser type * of notifications. */ public function update_status($notify_ids,$status = "SEEN") { if ($notify_ids) { $this->db->update(self::_notification_table,array('notify_status' => $status),array( 'notify_id' => $notify_ids, 'account_id' => $this->recipient->account_id, 'notify_type' => self::_type ),__LINE__,__FILE__,self::_appname); } } /** * gets all egwpopup notifications for calling user * * @return boolean true or false */ private function get_egwpopup($browserNotify = false) { $message = ''; $rs = $this->db->select(self::_notification_table, '*', array( 'account_id' => $this->recipient->account_id, 'notify_type' => self::_type ), __LINE__,__FILE__,false,'',self::_appname); if ($rs->NumRows() > 0) { foreach ($rs as $notification) { $message = null; if($browserNotify) { $message = $notification['notify_message']; // Check for a link - doesn't work in notification if(strpos($message, lang('Linked entries:'))) { $message = substr_replace($message, '', strpos($message, lang('Linked entries:'))); } $message2 = preg_replace('#]*>#is','',$message); $message3 = 'data:text/html;charset=' . Api\Translation::charset() .';base64,'.base64_encode($message2); } $this->response->apply('app.notifications.append',array( $notification['notify_id'], $notification['notify_message'], $message3, $notification['notify_status'], $notification['notify_created'], new DateTime()) ); } switch($this->preferences[self::_appname]['egwpopup_verbosity']) { case 'low': $this->response->apply('app.notifications.bell', array('active')); break; case 'high': $this->response->alert(lang('EGroupware has notifications for you')); $this->response->apply('app.notifications.display'); break; case 'medium': default: $this->response->apply('app.notifications.display'); break; } } return true; } /** * restores the users session data for notifications * * @return boolean true */ private function restore_session_data() { $session_data = Api\Cache::getSession(self::_appname, 'session_data'); if(is_array($session_data)) { $this->session_data = $session_data; } else { $this->session_data = $this->session_data_defaults; } return true; } /** * saves the users session data for notifications * * @return boolean true */ private function save_session_data() { Api\Cache::setSession(self::_appname, 'session_data', $this->session_data); return true; } }