+* @license http://opensource.org/licenses/gpl-2.0.php GNU General Public License v2

+namespace phpbb\notification;

+class exception extends \Exception

+namespace phpbb\notification;

+class manager

+ /** @var \phpbb\user_loader */

+ /** @var \phpbb\config\config */

+ protected $config;

+

+ /** @var \phpbb\db\driver\driver_interface */

+ /** @var \phpbb\cache\service */

+ /** @var \phpbb\user */

+ *

+ * @param \phpbb\user_loader $user_loader

+ * @param \phpbb\config\config $config

+ * @param \phpbb\db\driver\driver_interface $db

+ * @param \phpbb\user $user

+ * @return \phpbb\notification\manager

+ public function __construct($notification_types, $notification_methods, $phpbb_container, \phpbb\user_loader $user_loader, \phpbb\config\config $config, \phpbb\db\driver\driver_interface $db, \phpbb\cache\service $cache, $user, $phpbb_root_path, $php_ext, $notification_types_table, $notifications_table, $user_notifications_table)

+ $this->config = $config;

+ $unread_count = (int) $this->db->sql_fetchfield('unread_count');

+ $total_count = (int) $this->db->sql_fetchfield('total_count');

+ (is_array($notification_type_name) ? $this->db->sql_in_set('notification_type_id', $this->get_notification_type_ids($notification_type_name)) : 'notification_type_id = ' . $this->get_notification_type_id($notification_type_name)) : '') .

+ (is_array($notification_type_name) ? $this->db->sql_in_set('notification_type_id', $this->get_notification_type_ids($notification_type_name)) : 'notification_type_id = ' . $this->get_notification_type_id($notification_type_name)) : '') .

+ $insert_buffer = new \phpbb\db\sql_insert_buffer($this->db, $this->notifications_table);

+ * @param mixed $parent_id Parent identifier within the type (or array of ids), used in combination with item_id if specified (Default: false; not checked)

+ public function delete_notifications($notification_type_name, $item_id, $parent_id = false)

+ $this->delete_notifications($type, $item_id, $parent_id);

+ AND ' . (is_array($item_id) ? $this->db->sql_in_set('item_id', $item_id) : 'item_id = ' . (int) $item_id) .

+ (($parent_id !== false) ? ' AND ' . ((is_array($parent_id) ? $this->db->sql_in_set('item_parent_id', $parent_id) : 'item_parent_id = ' . (int) $parent_id)) : '');

+ if ($type instanceof \phpbb\notification\type\type_interface && $type->is_available())

+ if ($method instanceof \phpbb\notification\method\method_interface && $method->is_available())

+ * @param bool $only_unread True (default) to only prune read notifications

+ public function prune_notifications($timestamp, $only_read = true)

+ WHERE notification_time < ' . (int) $timestamp .

+ (($only_read) ? ' AND notification_read = 1' : '');

+

+ $this->config->set('read_notification_last_gc', time(), false);

+

+

+ throw new \phpbb\notification\exception($this->user->lang('NOTIFICATION_TYPE_NOT_EXIST', $notification_type_name));

+namespace phpbb\notification\method;

+abstract class base implements \phpbb\notification\method\method_interface

+ /** @var \phpbb\notification\manager */

+ /** @var \phpbb\user_loader */

+ /** @var \phpbb\db\driver\driver_interface */

+ /** @var \phpbb\cache\driver\driver_interface */

+ /** @var \phpbb\template\template */

+ /** @var \phpbb\extension\manager */

+ /** @var \phpbb\user */

+ /** @var \phpbb\auth\auth */

+ /** @var \phpbb\config\config */

+ * @param \phpbb\user_loader $user_loader

+ * @param \phpbb\db\driver\driver_interface $db

+ * @param \phpbb\cache\driver\driver_interface $cache

+ * @param \phpbb\user $user

+ * @param \phpbb\auth\auth $auth

+ * @param \phpbb\config\config $config

+ * @return \phpbb\notification\method\base

+ public function __construct(\phpbb\user_loader $user_loader, \phpbb\db\driver\driver_interface $db, \phpbb\cache\driver\driver_interface $cache, $user, \phpbb\auth\auth $auth, \phpbb\config\config $config, $phpbb_root_path, $php_ext)

+ * @param \phpbb\notification\manager $notification_manager

+ public function set_notification_manager(\phpbb\notification\manager $notification_manager)

+ * @param \phpbb\notification\type\type_interface $notification

+ public function add_to_queue(\phpbb\notification\type\type_interface $notification)

+namespace phpbb\notification\method;

+class email extends \phpbb\notification\method\messenger_base

+namespace phpbb\notification\method;

+class jabber extends \phpbb\notification\method\messenger_base

+namespace phpbb\notification\method;

+abstract class messenger_base extends \phpbb\notification\method\base

+ $messenger = new \messenger();

+namespace phpbb\notification\method;

+interface method_interface

+ * @param \phpbb\notification\type\type_interface $notification

+ public function add_to_queue(\phpbb\notification\type\type_interface $notification);

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2013 phpBB Group

+* @license http://opensource.org/licenses/gpl-2.0.php GNU General Public License v2

+*

+*/

+

+namespace phpbb\notification\type;

+

+/**

+* Admin activation notifications class

+* This class handles notifications for users requiring admin activation

+*

+* @package notifications

+*/

+class admin_activate_user extends \phpbb\notification\type\base

+{

+ /**

+ * {@inheritdoc}

+ */

+ public function get_type()

+ {

+ return 'admin_activate_user';

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ protected $language_key = 'NOTIFICATION_ADMIN_ACTIVATE_USER';

+

+ /**

+ * {@inheritdoc}

+ */

+ public static $notification_option = array(

+ 'lang' => 'NOTIFICATION_TYPE_ADMIN_ACTIVATE_USER',

+ 'group' => 'NOTIFICATION_GROUP_ADMINISTRATION',

+ );

+

+ /**

+ * {@inheritdoc}

+ */

+ public function is_available()

+ {

+ return ($this->auth->acl_get('a_user') && $this->config['require_activation'] == USER_ACTIVATION_ADMIN);

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public static function get_item_id($user)

+ {

+ return (int) $user['user_id'];

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public static function get_item_parent_id($post)

+ {

+ return 0;

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function find_users_for_notification($user, $options = array())

+ {

+ $options = array_merge(array(

+ 'ignore_users' => array(),

+ ), $options);

+

+ // Grab admins that have permission to administer users.

+ $admin_ary = $this->auth->acl_get_list(false, 'a_user', false);

+ $users = (!empty($admin_ary[0]['a_user'])) ? $admin_ary[0]['a_user'] : array();

+

+ // Grab founders

+ $sql = 'SELECT user_id

+ FROM ' . USERS_TABLE . '

+ WHERE user_type = ' . USER_FOUNDER;

+ $result = $this->db->sql_query($sql);

+

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $users[] = (int) $row['user_id'];

+ }

+ $this->db->sql_freeresult($result);

+

+ if (empty($users))

+ {

+ return array();

+ }

+ $users = array_unique($users);

+

+ return $this->check_user_notification_options($users, $options);

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function get_avatar()

+ {

+ return $this->user_loader->get_avatar($this->item_id);

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function get_title()

+ {

+ $username = $this->user_loader->get_username($this->item_id, 'no_profile');

+

+ return $this->user->lang($this->language_key, $username);

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function get_email_template()

+ {

+ return 'admin_activate';

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function get_email_template_variables()

+ {

+ $board_url = generate_board_url();

+ $username = $this->user_loader->get_username($this->item_id, 'no_profile');

+

+ return array(

+ 'USERNAME' => htmlspecialchars_decode($username),

+ 'U_USER_DETAILS' => "{$board_url}/memberlist.{$this->php_ext}?mode=viewprofile&u={$this->item_id}",

+ 'U_ACTIVATE' => "{$board_url}/ucp.{$this->php_ext}?mode=activate&u={$this->item_id}&k={$this->get_data('user_actkey')}",

+ );

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function get_url()

+ {

+ return $this->user_loader->get_username($this->item_id, 'profile');

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function users_to_query()

+ {

+ return array($this->item_id);

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function create_insert_array($user, $pre_create_data)

+ {

+ $this->set_data('user_actkey', $user['user_actkey']);

+ $this->notification_time = $user['user_regdate'];

+

+ return parent::create_insert_array($user, $pre_create_data);

+ }

+}

+namespace phpbb\notification\type;

+class approve_post extends \phpbb\notification\type\post

+ * Inherit notification read status from post.

+ *

+ * @var bool

+ */

+ protected $inherit_read_status = false;

+

+ /**

+

+ /**

+ * {inheritDoc}

+ */

+ public function get_redirect_url()

+ {

+ return $this->get_url();

+ }

+namespace phpbb\notification\type;

+class approve_topic extends \phpbb\notification\type\topic

+

+ * Inherit notification read status from topic.

+ *

+ * @var bool

+ */

+ protected $inherit_read_status = false;

+

+ /**

+namespace phpbb\notification\type;

+abstract class base implements \phpbb\notification\type\type_interface

+ /** @var \phpbb\notification\manager */

+ /** @var \phpbb\user_loader */

+ /** @var \phpbb\db\driver\driver_interface */

+ /** @var \phpbb\cache\driver\driver_interface */

+ /** @var \phpbb\template\template */

+ /** @var \phpbb\user */

+ /** @var \phpbb\auth\auth */

+ /** @var \phpbb\config\config */

+ *

+ * @param \phpbb\user_loader $user_loader

+ * @param \phpbb\db\driver\driver_interface $db

+ * @param \phpbb\cache\driver\driver_interface $cache

+ * @param \phpbb\user $user

+ * @param \phpbb\auth\auth $auth

+ * @param \phpbb\config\config $config

+ * @return \phpbb\notification\type\base

+ public function __construct(\phpbb\user_loader $user_loader, \phpbb\db\driver\driver_interface $db, \phpbb\cache\driver\driver_interface $cache, $user, \phpbb\auth\auth $auth, \phpbb\config\config $config, $phpbb_root_path, $php_ext, $notification_types_table, $notifications_table, $user_notifications_table)

+ *

+ * @param \phpbb\notification\manager $notification_manager

+ public function set_notification_manager(\phpbb\notification\manager $notification_manager)

+ *

+ *

+ *

+ *

+ * {inheritDoc}

+ */

+ public function get_redirect_url()

+ {

+ return $this->get_url();

+ }

+

+ /**

+ *

+ $mark_hash = generate_link_hash('mark_notification_read');

+

+ $u_mark_read = append_sid($this->phpbb_root_path . 'index.' . $this->php_ext, 'mark_notification=' . $this->notification_id . '&amp;hash=' . $mark_hash);

+ $u_mark_read = append_sid($this->phpbb_root_path . 'index.' . $this->php_ext, 'mark_notification=' . $this->notification_id . '&amp;hash=' . $mark_hash . '&amp;redirect=' . urlencode($redirect));

+ *

+ *

+ *

+ *

+namespace phpbb\notification\type;

+class bookmark extends \phpbb\notification\type\post

+ $users[] = (int) $row['user_id'];

+ $update_responders = $notification->add_responders($post);

+ if (!empty($update_responders))

+ {

+ $sql = 'UPDATE ' . $this->notifications_table . '

+ SET ' . $this->db->sql_build_array('UPDATE', $update_responders) . '

+ WHERE notification_id = ' . $row['notification_id'];

+ $this->db->sql_query($sql);

+ }

+namespace phpbb\notification\type;

+class disapprove_post extends \phpbb\notification\type\approve_post

+ * Inherit notification read status from post.

+ *

+ * @var bool

+ */

+ protected $inherit_read_status = false;

+

+ /**

+namespace phpbb\notification\type;

+class disapprove_topic extends \phpbb\notification\type\approve_topic

+ * Inherit notification read status from topic.

+ *

+ * @var bool

+ */

+ protected $inherit_read_status = false;

+

+ /**

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2013 phpBB Group

+* @license http://opensource.org/licenses/gpl-2.0.php GNU General Public License v2

+*

+*/

+

+namespace phpbb\notification\type;

+

+class group_request extends \phpbb\notification\type\base

+{

+ /**

+ * {@inheritdoc}

+ */

+ public function get_type()

+ {

+ return 'group_request';

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public static $notification_option = array(

+ 'lang' => 'NOTIFICATION_TYPE_GROUP_REQUEST',

+ );

+

+ /**

+ * {@inheritdoc}

+ */

+ public function is_available()

+ {

+ // Leader of any groups?

+ $sql = 'SELECT group_id

+ FROM ' . USER_GROUP_TABLE . '

+ WHERE user_id = ' . (int) $this->user->data['user_id'] . '

+ AND group_leader = 1';

+ $result = $this->db->sql_query_limit($sql, 1);

+ $row = $this->db->sql_fetchrow($result);

+ $this->db->sql_freeresult($result);

+

+ return (!empty($row)) ? true : false;

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public static function get_item_id($group)

+ {

+ return (int) $group['user_id'];

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public static function get_item_parent_id($group)

+ {

+ // Group id is the parent

+ return (int) $group['group_id'];

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function find_users_for_notification($group, $options = array())

+ {

+ $options = array_merge(array(

+ 'ignore_users' => array(),

+ ), $options);

+

+ $sql = 'SELECT user_id

+ FROM ' . USER_GROUP_TABLE . '

+ WHERE group_leader = 1

+ AND group_id = ' . (int) $group['group_id'];

+ $result = $this->db->sql_query($sql);

+

+ $user_ids = array();

+ while ($row = $this->db->sql_fetchrow($result))

+ {

+ $user_ids[] = (int) $row['user_id'];

+ }

+ $this->db->sql_freeresult($result);

+

+ $this->user_loader->load_users($user_ids);

+

+ return $this->check_user_notification_options($user_ids, $options);

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function get_avatar()

+ {

+ return $this->user_loader->get_avatar($this->item_id);

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function get_title()

+ {

+ $username = $this->user_loader->get_username($this->item_id, 'no_profile');

+

+ return $this->user->lang('NOTIFICATION_GROUP_REQUEST', $username, $this->get_data('group_name'));

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function get_email_template()

+ {

+ return 'group_request';

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function get_email_template_variables()

+ {

+ $user_data = $this->user_loader->get_user($this->item_id);

+

+ return array(

+ 'GROUP_NAME' => htmlspecialchars_decode($this->get_data('group_name')),

+ 'REQUEST_USERNAME' => htmlspecialchars_decode($user_data['username']),

+

+ 'U_PENDING' => generate_board_url() . "/ucp.{$this->php_ext}?i=groups&mode=manage&action=list&g={$this->item_parent_id}",

+ 'U_GROUP' => generate_board_url() . "/memberlist.{$this->php_ext}?mode=group&g={$this->item_parent_id}",

+ );

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function get_url()

+ {

+ return append_sid($this->phpbb_root_path . 'ucp.' . $this->php_ext, "i=groups&mode=manage&action=list&g={$this->item_parent_id}");

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function users_to_query()

+ {

+ return array($this->item_id);

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function create_insert_array($group, $pre_create_data = array())

+ {

+ $this->set_data('group_name', $group['group_name']);

+

+ return parent::create_insert_array($group, $pre_create_data);

+ }

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2013 phpBB Group

+* @license http://opensource.org/licenses/gpl-2.0.php GNU General Public License v2

+*

+*/

+

+namespace phpbb\notification\type;

+

+class group_request_approved extends \phpbb\notification\type\base

+{

+ /**

+ * {@inheritdoc}

+ */

+ public function get_type()

+ {

+ return 'group_request_approved';

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function is_available()

+ {

+ return false;

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public static function get_item_id($group)

+ {

+ return (int) $group['group_id'];

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public static function get_item_parent_id($group)

+ {

+ return 0;

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function find_users_for_notification($group, $options = array())

+ {

+ $users = array();

+

+ $group['user_ids'] = (!is_array($group['user_ids'])) ? array($group['user_ids']) : $group['user_ids'];

+

+ foreach ($group['user_ids'] as $user_id)

+ {

+ $users[$user_id] = array('');

+ }

+

+ return $users;

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function get_title()

+ {

+ return $this->user->lang('NOTIFICATION_GROUP_REQUEST_APPROVED', $this->get_data('group_name'));

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function get_url()

+ {

+ return append_sid($this->phpbb_root_path . 'memberlist.' . $this->php_ext, "mode=group&g={$this->item_id}");

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function create_insert_array($group, $pre_create_data = array())

+ {

+ $this->set_data('group_name', $group['group_name']);

+

+ return parent::create_insert_array($group, $pre_create_data);

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function users_to_query()

+ {

+ return array();

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function get_email_template()

+ {

+ return false;

+ }

+

+ /**

+ * {@inheritdoc}

+ */

+ public function get_email_template_variables()

+ {

+ return array();

+ }

+}

+namespace phpbb\notification\type;

+class pm extends \phpbb\notification\type\base

+namespace phpbb\notification\type;

+class post extends \phpbb\notification\type\base

+ * Inherit notification read status from post.

+ *

+ * @var bool

+ */

+ protected $inherit_read_status = true;

+

+ /**

+ $users[] = (int) $row['user_id'];

+ $users[] = (int) $row['user_id'];

+ $update_responders = $notification->add_responders($post);

+ if (!empty($update_responders))

+ {

+ $sql = 'UPDATE ' . $this->notifications_table . '

+ SET ' . $this->db->sql_build_array('UPDATE', $update_responders) . '

+ WHERE notification_id = ' . $row['notification_id'];

+ $this->db->sql_query($sql);

+ }

+ $responders_cnt = sizeof($responders);

+ $responders = $this->trim_user_ary($responders);

+ $trimmed_responders_cnt = $responders_cnt - sizeof($responders);

+

+ if ($trimmed_responders_cnt > 20)

+ {

+ $usernames[] = $this->user->lang('NOTIFICATION_MANY_OTHERS');

+ }

+ else if ($trimmed_responders_cnt)

+ {

+ $usernames[] = $this->user->lang('NOTIFICATION_X_OTHERS', $trimmed_responders_cnt);

+ }

+

+ phpbb_generate_string_list($usernames, $this->user),

+ censor_text($this->get_data('topic_title')),

+ $responders_cnt

+ 'U_NEWEST_POST' => generate_board_url() . "/viewtopic.{$this->php_ext}?f={$this->get_data('forum_id')}&t={$this->item_parent_id}&e=1&view=unread#unread",

+ * {inheritDoc}

+ */

+ public function get_redirect_url()

+ {

+ return append_sid($this->phpbb_root_path . 'viewtopic.' . $this->php_ext, "t={$this->item_parent_id}&amp;view=unread#unread");

+ }

+

+ /**

+ return $this->trim_user_ary($users);

+ }

+

+ /**

+ * Trim the user array passed down to 3 users if the array contains

+ * more than 4 users.

+ *

+ * @param array $users Array of users

+ * @return array Trimmed array of user_ids

+ */

+ public function trim_user_ary($users)

+ {

+ if (sizeof($users) > 4)

+ {

+ array_splice($users, 3);

+ }

+ if (!sizeof($notify_users) || !$this->inherit_read_status)

+ if ($this->inherit_read_status && isset($pre_create_data[$this->user_id]) && $pre_create_data[$this->user_id] >= $this->notification_time)

+ return array();

+ // Do not add more than 25 responders,

+ // we trim the username list to "a, b, c and x others" anyway

+ // so there is no use to add all of them anyway.

+ if (sizeof($responders) > 25)

+ {

+ return array();

+ }

+

+ return array();

+ $serialized_data = serialize($this->get_data(false));

+

+ // If the data is longer then 4000 characters, it would cause a SQL error.

+ // We don't add the username to the list if this is the case.

+ if (utf8_strlen($serialized_data) >= 4000)

+ {

+ return array();

+ }

+

+ return array('notification_data' => $serialized_data);

+namespace phpbb\notification\type;

+class post_in_queue extends \phpbb\notification\type\post

+ * {inheritDoc}

+ */

+ public function get_redirect_url()

+ {

+ return parent::get_url();

+ }

+

+ /**

+namespace phpbb\notification\type;

+* This class handles notifying users when they have been quoted in a post

+class quote extends \phpbb\notification\type\post

+ $users[] = (int) $row['user_id'];

+ * {inheritDoc}

+ */

+ public function get_redirect_url()

+ {

+ return $this->get_url();

+ }

+

+ /**

+namespace phpbb\notification\type;

+* Private message reported notifications class

+class report_pm extends \phpbb\notification\type\pm

+namespace phpbb\notification\type;

+class report_pm_closed extends \phpbb\notification\type\pm

+ return $this->user_loader->get_avatar($this->get_data('closer_id'));

+namespace phpbb\notification\type;

+class report_post extends \phpbb\notification\type\post_in_queue

+ * Inherit notification read status from post.

+ *

+ * @var bool

+ */

+ protected $inherit_read_status = false;

+

+ /**

+namespace phpbb\notification\type;

+class report_post_closed extends \phpbb\notification\type\post

+ /**

+ * Inherit notification read status from post.

+ *

+ * @var bool

+ */

+ protected $inherit_read_status = false;

+

+namespace phpbb\notification\type;

+class topic extends \phpbb\notification\type\base

+ * Inherit notification read status from topic.

+ *

+ * @var bool

+ */

+ protected $inherit_read_status = true;

+

+ /**

+ $users[] = (int) $row['user_id'];

+ if (!sizeof($notify_users) || !$this->inherit_read_status)

+ if ($this->inherit_read_status && isset($pre_create_data[$this->user_id]) && $pre_create_data[$this->user_id] >= $this->notification_time)

+namespace phpbb\notification\type;

+class topic_in_queue extends \phpbb\notification\type\topic

+namespace phpbb\notification\type;

+interface type_interface

+

+ * Get the url to redirect after the item has been marked as read

+ *

+ * @return string URL

+ */

+ public function get_redirect_url();

+

+ /**