+ notifications:

+ class: phpbb_notifications_service

+ arguments:

+ - @container

+

+ $schema_data['phpbb_notifications'] = array(

+ 'COLUMNS' => array(

+ 'notification_id' => array('UINT', NULL, 'auto_increment'),

+ 'item_type' => array('VCHAR:25', ''),

+ 'item_id' => array('UINT', 0),

+ 'item_parent_id' => array('UINT', 0),

+ 'user_id' => array('UINT', 0),

+ 'unread' => array('BOOL', 1),

+ 'time' => array('TIMESTAMP', 1),

+ 'data' => array('TEXT_UNI', ''),

+ ),

+ 'PRIMARY_KEY' => 'notification_id',

+ 'KEYS' => array(

+ 'item_type' => array('INDEX', 'item_type'),

+ 'item_id' => array('INDEX', 'item_id'),

+ 'item_pid' => array('INDEX', 'item_parent_id'),

+ 'user_id' => array('INDEX', 'user_id'),

+ 'time' => array('INDEX', 'time'),

+ 'unread' => array('INDEX', 'unread'),

+ ),

+ );

+

+ $schema_data['phpbb_user_notifications'] = array(

+ 'COLUMNS' => array(

+ 'item_type' => array('VCHAR:25', ''),

+ 'item_id' => array('UINT', 0),

+ 'user_id' => array('UINT', 0),

+ 'method' => array('VCHAR:25', ''),

+ ),

+ 'PRIMARY_KEY' => array(

+ 'item_type',

+ 'item_id',

+ 'user_id',

+ 'method',

+ ),

+ 'KEYS' => array(

+ 'it' => array('INDEX', 'item_type'),

+ 'uid' => array('INDEX', 'user_id'),

+ ),

+ );

+

+define('NOTIFICATIONS_TABLE', $table_prefix . 'notifications');

+define('USER_NOTIFICATIONS_TABLE', $table_prefix . 'user_notifications');

+ global $request, $phpbb_container;

+ // Mark all forums read (index page)

+

+ // Mark all topic notifications read for this user

+ $phpbb_notifications = $phpbb_container->get('notifications');

+ $phpbb_notifications->mark_notifications_read(array('topic', 'quote', 'bookmark', 'post', 'approve_topic', 'approve_post'), false, $user->data['user_id'], $post_time);

+

+ // Mark topic notifications read for this user in this forum

+ $phpbb_notifications = $phpbb_container->get('notifications');

+ $phpbb_notifications->mark_notifications_read_by_parent(array('topic', 'approve_topic'), $forum_id, $user->data['user_id'], $post_time);

+

+ // Mark all post/quote notifications read for this user in this forum

+ $topic_ids = array();

+ $sql = 'SELECT topic_id

+ FROM ' . TOPICS_TABLE . '

+ WHERE ' . $db->sql_in_set('forum_id', $forum_id);

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

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

+ {

+ $topic_ids[] = $row['topic_id'];

+ }

+ $db->sql_freeresult($result);

+

+ $phpbb_notifications->mark_notifications_read_by_parent(array('quote', 'bookmark', 'post', 'approve_post'), $topic_ids, $user->data['user_id'], $post_time);

+

+ // Mark post notifications read for this user in this topic

+ $phpbb_notifications = $phpbb_container->get('notifications');

+ $phpbb_notifications->mark_notifications_read(array('topic', 'approve_topic'), $topic_id, $user->data['user_id'], $post_time);

+ $phpbb_notifications->mark_notifications_read_by_parent(array('quote', 'bookmark', 'post', 'approve_post'), $topic_id, $user->data['user_id'], $post_time);

+

+ global $phpbb_dispatcher, $phpbb_container;

+ // Output the notifications

+ $phpbb_notifications = $phpbb_container->get('notifications');

+ $notifications = $phpbb_notifications->load_notifications(array(

+ 'all_unread' => true,

+ 'limit' => 5,

+ ));

+ foreach ($notifications['notifications'] as $notification)

+ {

+ $template->assign_block_vars('notifications', $notification->prepare_for_display());

+ }

+

+ 'NUM_UNREAD_NOTIFICATIONS' => $notifications['unread_count'],

+ 'NOTIFICATIONS_CNT' => $user->lang('NOTIFICATIONS_CNT', $notifications['unread_count']),

+ global $phpbb_container;

+ // Delete notifications

+ $phpbb_notifications = $phpbb_container->get('notifications');

+ $phpbb_notifications->delete_notifications(array('topic', 'approve_topic', 'topic_in_queue'), $topic_ids);

+

+ global $phpbb_container;

+ // Delete notifications

+ $phpbb_notifications = $phpbb_container->get('notifications');

+ $phpbb_notifications->delete_notifications(array('quote', 'bookmark', 'post', 'approve_post', 'post_in_queue'), $post_ids);

+

+ generate_pagination(append_sid("{$phpbb_root_path}posting.$phpEx", 'mode=smilies&f=' . $forum_id), $smiley_count, $config['smilies_per_page'], $start);

+ global $phpbb_container;

+ $phpbb_notifications = $phpbb_container->get('notifications');

+ $notification_data = array_merge($data, array(

+ 'topic_title' => (isset($data['topic_title'])) ? $data['topic_title'] : $subject,

+ 'post_username' => $username,

+ 'poster_id' => $poster_id,

+ 'post_text' => $data['message'],

+ 'post_time' => $current_time,

+ 'post_subject' => $subject,

+ ));

+ if ($post_approval)

+ switch ($mode)

+ {

+ case 'post' :

+ $phpbb_notifications->add_notifications(array('quote', 'topic'), $notification_data);

+ break;

+

+ case 'reply' :

+ case 'quote' :

+ $phpbb_notifications->add_notifications(array('quote', 'bookmark', 'post'), $notification_data);

+ break;

+

+ case 'edit_topic' :

+ case 'edit_first_post' :

+ case 'edit' :

+ case 'edit_last_post' :

+ $phpbb_notifications->update_notifications(array('quote', 'bookmark', 'topic', 'post'), $notification_data);

+ break;

+ }

+ }

+ else

+ {

+ switch ($mode)

+ {

+ case 'post' :

+ $phpbb_notifications->add_notifications(array('topic_in_queue'), $notification_data);

+ break;

+

+ case 'reply' :

+ case 'quote' :

+ $phpbb_notifications->add_notifications(array('post_in_queue'), $notification_data);

+ break;

+

+ case 'edit_topic' :

+ case 'edit_first_post' :

+ case 'edit' :

+ case 'edit_last_post' :

+ $phpbb_notifications->delete_notifications('topic', $data['topic_id']);

+ $phpbb_notifications->delete_notifications(array('quote', 'bookmark', 'post'), $data['post_id']);

+ break;

+ }

+ global $db, $user, $phpbb_container;

+

+ // Mark the PM as read

+ $phpbb_notifications = $phpbb_container->get('notifications');

+ $phpbb_notifications->mark_notifications_read('pm', $msg_id, $user_id);

+ global $phpbb_container;

+ // Delete Notifications

+ $phpbb_notifications = $phpbb_container->get('notifications');

+ $phpbb_notifications->delete_notifications('pm', array_keys($delete_rows));

+

+ global $phpbb_container;

+

+ // Delete Notifications

+ $phpbb_notifications = $phpbb_container->get('notifications');

+ $phpbb_notifications->delete_notifications('pm', $delivered_msg);

+

+ // Delete Notifications

+ $phpbb_notifications = $phpbb_container->get('notifications');

+ $phpbb_notifications->delete_notifications('pm', $undelivered_msg);

+

+ // Delete Notifications

+ $phpbb_notifications = $phpbb_container->get('notifications');

+ $phpbb_notifications->delete_notifications('pm', $delete_ids);

+ global $phpbb_container;

+ $phpbb_notifications = $phpbb_container->get('notifications');

+ $pm_data = array_merge($data, array(

+ 'message_subject' => $subject,

+ 'recipients' => $recipients,

+ ));

+ if ($mode == 'edit')

+ $phpbb_notifications->update_notifications('pm', $pm_data);

+ else

+ $phpbb_notifications->add_notifications('pm', $pm_data);

+ return $data['msg_id'];

+

+ global $request, $phpbb_container;

+ // Handle notifications

+ $phpbb_notifications = $phpbb_container->get('notifications');

+ // Delete topic in queue notifications

+ $phpbb_notifications->delete_notifications(array('topic_in_queue'), $post_data['topic_id']);

+

+ $phpbb_notifications->add_notifications('topic', $post_data);

+

+ // Notify poster?

+ if ($notify_poster)

+ {

+ $phpbb_notifications->add_notifications('approve_topic', $post_data);

+ }

+ // Delete post in queue notification

+ $phpbb_notifications->delete_notifications(array('post_in_queue'), $post_id);

+

+ $phpbb_notifications->add_notifications(array('quote', 'bookmark', 'post'), $post_data);

+

+ // Notify poster?

+ if ($notify_poster)

+ {

+ $phpbb_notifications->add_notifications('approve_post', $post_data);

+ }

+ global $request, $phpbb_container;

+ // Handle notifications (topic/post in queue)

+ $phpbb_notifications = $phpbb_container->get('notifications');

+ foreach ($post_info as $post_id => $post_data)

+ {

+ if ($post_id == $post_data['topic_first_post_id'] && $post_id == $post_data['topic_last_post_id'])

+ {

+ $phpbb_notifications->delete_notifications(array('topic_in_queue'), $post_data['topic_id']);

+ }

+ else

+ {

+ $phpbb_notifications->delete_notifications(array('post_in_queue'), $post_id);

+ }

+ }

+ // Handle notifications

+ $post_data['disapprove_reason'] = '';

+ $post_data['disapprove_reason'] = $lang_reasons[$post_data['user_lang']];

+ $post_data['disapprove_reason'] .= ($reason) ? "\n\n" . $reason : '';

+ if ($post_id == $post_data['topic_first_post_id'] && $post_id == $post_data['topic_last_post_id'])

+ {

+ // Notify poster?

+ if ($notify_poster)

+ {

+ $phpbb_notifications->add_notifications('disapprove_topic', $post_data);

+ }

+ }

+ else

+ {

+ // Notify poster?

+ if ($notify_poster)

+ {

+ $phpbb_notifications->add_notifications('disapprove_post', $post_data);

+ }

+ }

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+use Symfony\Component\DependencyInjection\ContainerBuilder;

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Base notifications method class

+* @package notifications

+*/

+abstract class phpbb_notifications_method_base implements phpbb_notifications_method_interface

+{

+ protected $phpbb_container;

+ protected $service;

+ protected $db;

+ protected $user;

+ protected $phpbb_root_path;

+ protected $php_ext;

+

+ /**

+ * Desired notifications

+ * unique by (type, type_id, user_id, method)

+ * if multiple methods are desired, multiple rows will exist.

+ *

+ * method of "none" will over-ride any other options

+ *

+ * item_type

+ * item_id

+ * user_id

+ * method

+ * none (will never receive notifications)

+ * standard (listed in notifications window

+ * popup?

+ * email

+ * jabber

+ * sms?

+ */

+

+ /**

+ * Queue of messages to be sent

+ *

+ * @var array

+ */

+ protected $queue = array();

+

+ public function __construct(ContainerBuilder $phpbb_container)

+ {

+ // phpBB Container

+ $this->phpbb_container = $phpbb_container;

+

+ // Service

+ $this->service = $phpbb_container->get('notifications');

+

+ // Some common things we're going to use

+ $this->db = $phpbb_container->get('dbal.conn');

+ $this->user = $phpbb_container->get('user');

+

+ $this->phpbb_root_path = $phpbb_container->getParameter('core.root_path');

+ $this->php_ext = $phpbb_container->getParameter('core.php_ext');

+ }

+

+ /**

+ * Add a notification to the queue

+ *

+ * @param phpbb_notifications_type_interface $notification

+ */

+ public function add_to_queue(phpbb_notifications_type_interface $notification)

+ {

+ $this->queue[] = $notification;

+ }

+

+ /**

+ * Empty the queue

+ */

+ protected function empty_queue()

+ {

+ $this->queue = array();

+ }

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Email notification method class

+* This class handles sending emails for notifications

+*

+* @package notifications

+*/

+class phpbb_notifications_method_email extends phpbb_notifications_method_base

+{

+ /**

+ * Notify method (since jabber gets sent through the same messenger, we let the jabber class inherit from this to reduce code duplication)

+ *

+ * @var mixed

+ */

+ protected $notify_method = NOTIFY_EMAIL;

+

+ /**

+ * Is this method available for the user?

+ * This is checked on the notifications options

+ */

+ public function is_available()

+ {

+ // Email is always available

+ return true;

+ }

+

+ public function notify()

+ {

+ if (!sizeof($this->queue))

+ {

+ return;

+ }

+

+ // Load all users we want to notify (we need their email address)

+ $user_ids = $users = array();

+ foreach ($this->queue as $notification)

+ {

+ $user_ids[] = $notification->user_id;

+ }

+

+ // We do not send emails to banned users

+ if (!function_exists('phpbb_get_banned_user_ids'))

+ {

+ include($this->phpbb_container->getParameter('core.root_path') . 'includes/functions_user.' . $this->phpbb_container->getParameter('core.php_ext'));

+ }

+ $banned_users = phpbb_get_banned_user_ids($user_ids);

+

+ // Load all the users we need

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

+

+ // Load the messenger

+ if (!class_exists('messenger'))

+ {

+ include($this->phpbb_root_path . 'includes/functions_messenger.' . $this->php_ext);

+ }

+ $messenger = new messenger();

+ $board_url = generate_board_url();

+

+ // Time to go through the queue and send emails

+ foreach ($this->queue as $notification)

+ {

+ $user = $this->service->get_user($notification->user_id);

+

+ if ($user['user_type'] == USER_IGNORE || in_array($notification->user_id, $banned_users))

+ {

+ continue;

+ }

+

+ $messenger->template($notification->email_template, $user['user_lang']);

+

+ $messenger->to($user['user_email'], $user['username']);

+

+ $messenger->assign_vars(array_merge(array(

+ 'USERNAME' => $user['username'],

+

+ 'U_NOTIFICATION_SETTINGS' => generate_board_url() . '/ucp.' . $this->php_ext . '?i=ucp_notifications',

+ ), $notification->get_email_template_variables()));

+

+ $messenger->send($this->notify_method);

+ }

+

+ // Save the queue in the messenger class (has to be called or these emails could be lost?)

+ $messenger->save_queue();

+

+ // We're done, empty the queue

+ $this->empty_queue();

+ }

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Base notifications method interface

+* @package notifications

+*/

+interface phpbb_notifications_method_interface

+{

+ public function is_available();

+

+ public function notify();

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Jabber notification method class

+* This class handles sending Jabber messages for notifications

+*

+* @package notifications

+*/

+class phpbb_notifications_method_jabber extends phpbb_notifications_method_email

+{

+ /**

+ * Notify method (since jabber gets sent through the same messenger, we let the jabber class inherit from this to reduce code duplication)

+ *

+ * @var mixed

+ */

+ protected $notify_method = NOTIFY_IM;

+

+ /**

+ * Is this method available for the user?

+ * This is checked on the notifications options

+ */

+ public function is_available()

+ {

+ return ($this->global_available() && $this->phpbb_container->get('user')->data['jabber']);

+ }

+

+ /**

+ * Is this method available at all?

+ * This is checked before notifications are sent

+ */

+ public function global_available()

+ {

+ $config = $this->phpbb_container->get('config');

+

+ return ($config['jab_enable'] && @extension_loaded('xml'));

+ }

+

+ public function notify()

+ {

+ if (!$this->global_available())

+ {

+ return;

+ }

+

+ return parent::notify();

+ }

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+use Symfony\Component\DependencyInjection\ContainerBuilder;

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Notifications service class

+* @package notifications

+*/

+class phpbb_notifications_service

+{

+ protected $phpbb_container;

+ protected $db;

+

+ /**

+ * Users loaded from the DB

+ *

+ * @var array Array of user data that we've loaded from the DB

+ */

+ protected $users = array();

+

+ public function __construct(ContainerBuilder $phpbb_container)

+ {

+ $this->phpbb_container = $phpbb_container;

+

+ // Some common things we're going to use

+ $this->db = $phpbb_container->get('dbal.conn');

+ }

+

+ /**

+ * Load the user's notifications

+ *

+ * @param array $options Optional options to control what notifications are loaded

+ * notification_id Notification id to load (or array of notification ids)

+ * user_id User id to load notifications for (Default: $user->data['user_id'])

+ * order_by Order by (Default: time)

+ * order_dir Order direction (Default: DESC)

+ * limit Number of notifications to load (Default: 5)

+ * start Notifications offset (Default: 0)

+ * all_unread Load all unread messages? If set to true, count_unread is set to true (Default: false)

+ * count_unread Count all unread messages? (Default: false)

+ */

+ public function load_notifications($options = array())

+ {

+ $user = $this->phpbb_container->get('user');

+

+ // Merge default options

+ $options = array_merge(array(

+ 'notification_id' => false,

+ 'user_id' => $user->data['user_id'],

+ 'order_by' => 'time',

+ 'order_dir' => 'DESC',

+ 'limit' => 0,

+ 'start' => 0,

+ 'all_unread' => false,

+ 'count_unread' => false,

+ ), $options);

+

+ // If all_unread, count_unread mus be true

+ $options['count_unread'] = ($options['all_unread']) ? true : $options['count_unread'];

+

+ // Anonymous users and bots never receive notifications

+ if ($options['user_id'] == $user->data['user_id'] && ($user->data['user_id'] == ANONYMOUS || $user->data['user_type'] == USER_IGNORE))

+ {

+ return array(

+ 'notifications' => array(),

+ 'unread_count' => 0,

+ );

+ }

+

+ $notifications = $user_ids = array();

+ $load_special = array();

+ $count = 0;

+

+ if ($options['count_unread'])

+ {

+ // Get the total number of unread notifications

+ $sql = 'SELECT COUNT(*) AS count

+ FROM ' . NOTIFICATIONS_TABLE . '

+ WHERE user_id = ' . (int) $options['user_id'] . '

+ AND unread = 1';

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

+ $count = (int) $this->db->sql_fetchfield('count', $result);

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

+ }

+

+ $rowset = array();

+

+ // Get the main notifications

+ $sql = 'SELECT *

+ FROM ' . NOTIFICATIONS_TABLE . '

+ WHERE user_id = ' . (int) $options['user_id'] .

+ (($options['notification_id']) ? ((is_array($options['notification_id'])) ? ' AND ' . $this->db->sql_in_set('notification_id', $options['notification_id']) : ' AND notification_id = ' . (int) $options['notification_id']) : '') . '

+ ORDER BY ' . $this->db->sql_escape($options['order_by']) . ' ' . $this->db->sql_escape($options['order_dir']);

+ $result = $this->db->sql_query_limit($sql, $options['limit'], $options['start']);

+

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

+ {

+ $rowset[$row['notification_id']] = $row;

+ }

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

+

+ // Get all unread notifications

+ if ($count && $options['all_unread'] && !empty($rowset))

+ {

+ $sql = 'SELECT *

+ FROM ' . NOTIFICATIONS_TABLE . '

+ WHERE user_id = ' . (int) $options['user_id'] . '

+ AND unread = 1

+ AND ' . $this->db->sql_in_set('notification_id', array_keys($rowset), true) . '

+ ORDER BY ' . $this->db->sql_escape($options['order_by']) . ' ' . $this->db->sql_escape($options['order_dir']);

+ $result = $this->db->sql_query_limit($sql, $options['limit'], $options['start']);

+

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

+ {

+ $rowset[$row['notification_id']] = $row;

+ }

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

+ }

+

+ foreach ($rowset as $row)

+ {

+ $item_type_class_name = $this->get_item_type_class_name($row['item_type'], true);

+

+ $notification = new $item_type_class_name($this->phpbb_container, $row);

+

+ // Array of user_ids to query all at once

+ $user_ids = array_merge($user_ids, $notification->users_to_query());

+

+ // Some notification types also require querying additional tables themselves

+ if (!isset($load_special[$row['item_type']]))

+ {

+ $load_special[$row['item_type']] = array();

+ }

+ $load_special[$row['item_type']] = array_merge($load_special[$row['item_type']], $notification->get_load_special());

+

+ $notifications[] = $notification;

+ }

+

+ $this->load_users($user_ids);

+

+ // Allow each type to load it's own special items

+ foreach ($load_special as $item_type => $data)

+ {

+ $item_type_class_name = $this->get_item_type_class_name($item_type, true);

+

+ $item_type_class_name::load_special($this->phpbb_container, $data, $notifications);

+ }

+

+ return array(

+ 'notifications' => $notifications,

+ 'unread_count' => $count,

+ );

+ }

+

+ /**

+ * Mark notifications read

+ *

+ * @param string|array $item_type Type identifier or array of item types (only acceptable if the $data is identical for the specified types)

+ * @param bool|int|array $item_id Item id or array of item ids. False to mark read for all item ids

+ * @param bool|int|array $user_id User id or array of user ids. False to mark read for all user ids

+ * @param bool|int $time Time at which to mark all notifications prior to as read. False to mark all as read. (Default: False)

+ */

+ public function mark_notifications_read($item_type, $item_id, $user_id, $time = false)

+ {

+ if (is_array($item_type))

+ {

+ foreach ($item_type as $type)

+ {

+ $this->mark_notifications_read($type, $item_id, $user_id, $time);

+ }

+

+ return;

+ }

+

+ $time = ($time) ?: time();

+

+ $this->get_item_type_class_name($item_type);

+

+ $sql = 'UPDATE ' . NOTIFICATIONS_TABLE . "

+ SET unread = 0

+ WHERE item_type = '" . $this->db->sql_escape($item_type) . "'

+ AND time <= " . $time .

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

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

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

+ }

+

+ /**

+ * Mark notifications read from a parent identifier

+ *

+ * @param string|array $item_type Type identifier or array of item types (only acceptable if the $data is identical for the specified types)

+ * @param bool|int|array $item_parent_id Item parent id or array of item parent ids. False to mark read for all item parent ids

+ * @param bool|int|array $user_id User id or array of user ids. False to mark read for all user ids

+ * @param bool|int $time Time at which to mark all notifications prior to as read. False to mark all as read. (Default: False)

+ */

+ public function mark_notifications_read_by_parent($item_type, $item_parent_id, $user_id, $time = false)

+ {

+ if (is_array($item_type))

+ {

+ foreach ($item_type as $type)

+ {

+ $this->mark_notifications_read_by_parent($type, $item_parent_id, $user_id, $time);

+ }

+

+ return;

+ }

+

+ $time = ($time) ?: time();

+

+ $item_type_class_name = $this->get_item_type_class_name($item_type);

+

+ $sql = 'UPDATE ' . NOTIFICATIONS_TABLE . "

+ SET unread = 0

+ WHERE item_type = '" . $this->db->sql_escape($item_type) . "'

+ AND time <= " . $time .

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

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

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

+ }

+

+ /**

+ * Mark notifications read

+ *

+ * @param int|array $notification_id Notification id or array of notification ids.

+ * @param bool|int $time Time at which to mark all notifications prior to as read. False to mark all as read. (Default: False)

+ */

+ public function mark_notifications_read_by_id($notification_id, $time = false)

+ {

+ $time = ($time) ?: time();

+

+ $sql = 'UPDATE ' . NOTIFICATIONS_TABLE . "

+ SET unread = 0

+ WHERE time <= " . $time . '

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

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

+ }

+

+ /**

+ * Add a notification

+ *

+ * @param string|array $item_type Type identifier or array of item types (only acceptable if the $data is identical for the specified types)

+ * Note: If you send an array of types, any user who could receive multiple notifications from this single item will only receive

+ * a single notification. If they MUST receive multiple notifications, call this function multiple times instead of sending an array

+ * @param array $data Data specific for this type that will be inserted

+ */

+ public function add_notifications($item_type, $data, $options = array())

+ {

+ $options = array_merge(array(

+ 'ignore_users' => array(),

+ ), $options);

+

+ if (is_array($item_type))

+ {

+ $notified_users = array();

+ $temp_options = $options;

+

+ foreach ($item_type as $type)

+ {

+ $temp_options['ignore_users'] = $options['ignore_users'] + $notified_users;

+ $notified_users += $this->add_notifications($type, $data, $temp_options);

+ }

+

+ return $notified_users;

+ }

+

+ $item_type_class_name = $this->get_item_type_class_name($item_type);

+

+ $item_id = $item_type_class_name::get_item_id($data);

+

+ // find out which users want to receive this type of notification

+ $notify_users = $item_type_class_name::find_users_for_notification($this->phpbb_container, $data, $options);

+

+ $this->add_notifications_for_users($item_type, $data, $notify_users);

+

+ return $notify_users;

+ }

+

+ /**

+ * Add a notification for specific users

+ *

+ * @param string|array $item_type Type identifier or array of item types (only acceptable if the $data is identical for the specified types)

+ * @param array $data Data specific for this type that will be inserted

+ * @param array $notify_users User list to notify

+ */

+ public function add_notifications_for_users($item_type, $data, $notify_users)

+ {

+ if (is_array($item_type))

+ {

+ foreach ($item_type as $type)

+ {

+ $this->add_notifications_for_users($type, $data, $notify_users);

+ }

+

+ return;

+ }

+

+ $item_type_class_name = $this->get_item_type_class_name($item_type);

+

+ $item_id = $item_type_class_name::get_item_id($data);

+

+ $user_ids = array();

+ $notification_objects = $notification_methods = array();

+ $new_rows = array();

+

+ // Never send notifications to the anonymous user!

+ unset($notify_users[ANONYMOUS]);

+

+ // Make sure not to send new notifications to users who've already been notified about this item

+ // This may happen when an item was added, but now new users are able to see the item

+ // todo Users should not receive notifications from multiple events from the same item (ex: for a topic reply with a quote including your username)

+ // Probably should be handled within each type?

+ $sql = 'SELECT user_id

+ FROM ' . NOTIFICATIONS_TABLE . "

+ WHERE item_type = '" . $this->db->sql_escape($item_type) . "'

+ AND item_id = " . (int) $item_id;

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

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

+ {

+ unset($notify_users[$row['user_id']]);

+ }

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

+

+ if (!sizeof($notify_users))

+ {

+ return;

+ }

+

+ // Go through each user so we can insert a row in the DB and then notify them by their desired means

+ foreach ($notify_users as $user => $methods)

+ {

+ $notification = new $item_type_class_name($this->phpbb_container);

+

+ $notification->user_id = (int) $user;

+

+ // Store the creation array in our new rows that will be inserted later

+ $new_rows[] = $notification->create_insert_array($data);

+

+ // Users are needed to send notifications

+ $user_ids = array_merge($user_ids, $notification->users_to_query());

+

+ foreach ($methods as $method)

+ {

+ // setup the notification methods and add the notification to the queue

+ if ($method) // blank means we just insert it as a notification, but do not notify them by any other means

+ {

+ if (!isset($notification_methods[$method]))

+ {

+ $method_class_name = 'phpbb_notifications_method_' . $method;

+ $notification_methods[$method] = new $method_class_name($this->phpbb_container);

+ }

+

+ $notification_methods[$method]->add_to_queue($notification);

+ }

+ }

+ }

+

+ // insert into the db

+ $this->db->sql_multi_insert(NOTIFICATIONS_TABLE, $new_rows);

+

+ // We need to load all of the users to send notifications

+ $this->load_users($user_ids);

+

+ // run the queue for each method to send notifications

+ foreach ($notification_methods as $method)

+ {

+ $method->notify();

+ }

+ }

+

+ /**

+ * Update a notification

+ *

+ * @param string|array $item_type Type identifier or array of item types (only acceptable if the $data is identical for the specified types)

+ * @param array $data Data specific for this type that will be updated

+ */

+ public function update_notifications($item_type, $data)

+ {

+ if (is_array($item_type))

+ {

+ foreach ($item_type as $type)

+ {

+ $this->update_notifications($type, $data);

+ }

+

+ return;

+ }

+

+ $item_type_class_name = $this->get_item_type_class_name($item_type);

+

+ // Allow the notifications class to over-ride the update_notifications functionality

+ if (method_exists($item_type_class_name, 'update_notifications'))

+ {

+ // Return False to over-ride the rest of the update

+ if ($item_type_class_name::update_notifications($this->phpbb_container, $data) === false)

+ {

+ return;

+ }

+ }

+

+ $item_id = $item_type_class_name::get_item_id($data);

+

+ $notification = new $item_type_class_name($this->phpbb_container);

+ $update_array = $notification->create_update_array($data);

+

+ $sql = 'UPDATE ' . NOTIFICATIONS_TABLE . '

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

+ WHERE item_type = '" . $this->db->sql_escape($item_type) . "'

+ AND item_id = " . (int) $item_id;

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

+ }

+

+ /**

+ * Delete a notification

+ *

+ * @param string|array $item_type Type identifier or array of item types (only acceptable if the $item_id is identical for the specified types)

+ * @param int|array $item_id Identifier within the type (or array of ids)

+ * @param array $data Data specific for this type that will be updated

+ */

+ public function delete_notifications($item_type, $item_id)

+ {

+ if (is_array($item_type))

+ {

+ foreach ($item_type as $type)

+ {

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

+ }

+

+ return;

+ }

+

+ $this->get_item_type_class_name($item_type);

+

+ $sql = 'DELETE FROM ' . NOTIFICATIONS_TABLE . "

+ WHERE item_type = '" . $this->db->sql_escape($item_type) . "'

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

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

+ }

+

+ /**

+ * Get all of the subscription types

+ *

+ * @return array Array of item types

+ */

+ public function get_subscription_types()

+ {

+ $subscription_types = array();

+

+ foreach ($this->get_subscription_files('notifications/type/') as $class => $file)

+ {

+ $class = $this->get_item_type_class_name($class);

+

+ if (!class_exists($class))

+ {

+ include($file);

+ }

+

+ if ($class::is_available($this->phpbb_container) && method_exists($class, 'get_item_type'))

+ {

+ if ($class::$notification_option === false)

+ {

+ $subscription_types[$class::get_item_type()] = $class::get_item_type();

+ }

+ else

+ {

+ $subscription_types[$class::$notification_option['id']] = $class::$notification_option;

+ }

+ }

+ }

+

+ return $subscription_types;

+ }

+

+ /**

+ * Get all of the subscription methods

+ *

+ * @return array Array of methods

+ */

+ public function get_subscription_methods()

+ {

+ $subscription_methods = array();

+

+ foreach ($this->get_subscription_files('notifications/method/') as $method_name => $file)

+ {

+ $class_name = 'phpbb_notifications_method_' . $method_name;

+

+ if (!class_exists($class_name))

+ {

+ include($file);

+ }

+

+ $method = new $class_name($this->phpbb_container);

+

+ if ($method->is_available())

+ {

+ $subscription_methods[] = $method_name;

+ }

+ }

+

+ return $subscription_methods;

+ }

+

+ /**

+ * Get subscriptions

+ *

+ * @param bool|int $user_id The user_id to add the subscription for (bool false for current user)

+ * @param bool $only_global True to select only global subscription options (item_id = 0)

+ *

+ * @return array Subscriptions

+ */

+ public function get_subscriptions($user_id = false, $only_global = false)

+ {

+ $user_id = ($user_id === false) ? $this->phpbb_container->get('user')->data['user_id'] : $user_id;

+

+ $subscriptions = array();

+

+ $sql = 'SELECT *

+ FROM ' . USER_NOTIFICATIONS_TABLE . '

+ WHERE user_id = ' . (int) $user_id .

+ (($only_global) ? ' AND item_id = 0' : '');

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

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

+ {

+ if ($only_global)

+ {

+ if (!isset($subscriptions[$row['item_type']]))

+ {

+ $subscriptions[$row['item_type']] = array();

+ }

+

+ $subscriptions[$row['item_type']][] = $row['method'];

+ }

+ else

+ {

+ $subscriptions[] = $row;

+ }

+ }

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

+

+ return $subscriptions;

+ }

+

+ /**

+ * Add a subscription

+ *

+ * @param string $item_type Type identifier of the subscription

+ * @param int $item_id The id of the item

+ * @param string $method The method of the notification e.g. '', 'email', or 'jabber'

+ * @param bool|int $user_id The user_id to add the subscription for (bool false for current user)

+ */

+ public function add_subscription($item_type, $item_id = 0, $method = '', $user_id = false)

+ {

+ $this->get_item_type_class_name($item_type);

+

+ $user_id = ($user_id === false) ? $this->phpbb_container->get('user')->data['user_id'] : $user_id;

+

+ $sql = 'INSERT INTO ' . USER_NOTIFICATIONS_TABLE . ' ' .

+ $this->db->sql_build_array('INSERT', array(

+ 'item_type' => $item_type,

+ 'item_id' => (int) $item_id,

+ 'user_id' => (int) $user_id,

+ 'method' => $method,

+ ));

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

+ }

+

+ /**

+ * Delete a subscription

+ *

+ * @param string $item_type Type identifier of the subscription

+ * @param int $item_id The id of the item

+ * @param string $method The method of the notification e.g. '', 'email', or 'jabber'

+ * @param bool|int $user_id The user_id to add the subscription for (bool false for current user)

+ */

+ public function delete_subscription($item_type, $item_id = 0, $method = '', $user_id = false)

+ {

+ $this->get_item_type_class_name($item_type);

+

+ $user_id = ($user_id === false) ? $this->phpbb_container->get('user')->data['user_id'] : $user_id;

+

+ $sql = 'DELETE FROM ' . USER_NOTIFICATIONS_TABLE . "

+ WHERE item_type = '" . $this->db->sql_escape($item_type) . "'

+ AND item_id = " . (int) $item_id . '

+ AND user_id = ' .(int) $user_id . "

+ AND method = '" . $this->db->sql_escape($method) . "'";

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

+ }

+

+ /**

+ * Load user helper

+ *

+ * @param array $user_ids

+ */

+ public function load_users($user_ids)

+ {

+ $user_ids[] = ANONYMOUS;

+

+ // Load the users

+ $user_ids = array_unique($user_ids);

+

+ // Do not load users we already have in $this->users

+ $user_ids = array_diff($user_ids, array_keys($this->users));

+

+ if (sizeof($user_ids))

+ {

+ $sql = 'SELECT *

+ FROM ' . USERS_TABLE . '

+ WHERE ' . $this->db->sql_in_set('user_id', $user_ids);

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

+

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

+ {

+ $this->users[$row['user_id']] = $row;

+ }

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

+ }

+ }

+

+ /**

+ * Get a user row from our users cache

+ *

+ * @param int $user_id

+ * @return array

+ */

+ public function get_user($user_id)

+ {

+ return (isset($this->users[$user_id])) ? $this->users[$user_id] : $this->users[ANONYMOUS];

+ }

+

+ /**

+ * Helper to get the notifications item type class name and clean it if unsafe

+ */

+ private function get_item_type_class_name(&$item_type, $safe = false)

+ {

+ if (!$safe)

+ {

+ $item_type = preg_replace('#[^a-z_]#', '', $item_type);

+ }

+

+ return 'phpbb_notifications_type_' . $item_type;

+ }

+

+ /**

+ * Helper to get subscription related files with the finder

+ */

+ private function get_subscription_files($path)

+ {

+ $ext_manager = $this->phpbb_container->get('ext.manager');

+ $php_ext = $this->phpbb_container->getParameter('core.php_ext');

+

+ $finder = $ext_manager->get_finder();

+

+ $subscription_files = array();

+

+ $files = $finder

+ ->core_path('includes/' . $path)

+ ->extension_directory($path)

+ ->get_files();

+ foreach ($files as $file)

+ {

+ $class = substr($file, strrpos($file, '/'));

+ $class = substr($class, 1, (strpos($class, '.' . $php_ext) - 1));

+

+ if ($class == 'interface' || $class == 'base')

+ {

+ continue;

+ }

+

+ $subscription_files[$class] = $file;

+ }

+

+ return $subscription_files;

+ }

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+use Symfony\Component\DependencyInjection\ContainerBuilder;

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Post notifications class

+* This class handles notifications for replies to a topic

+*

+* @package notifications

+*/

+class phpbb_notifications_type_approve_post extends phpbb_notifications_type_post

+{

+ /**

+ * Email template to use to send notifications

+ *

+ * @var string

+ */

+ public $email_template = 'post_approved';

+

+ /**

+ * Language key used to output the text

+ *

+ * @var string

+ */

+ protected $language_key = 'NOTIFICATION_POST_APPROVED';

+

+ /**

+ * Notification option data (for outputting to the user)

+ *

+ * @var bool|array False if the service should use it's default data

+ * Array of data (including keys 'id' and 'lang')

+ */

+ public static $notification_option = array(

+ 'id' => 'moderation_queue',

+ 'lang' => 'NOTIFICATION_TYPE_MODERATION_QUEUE',

+ );

+

+ /**

+ * Get the type of notification this is

+ * phpbb_notifications_type_

+ */

+ public static function get_item_type()

+ {

+ return 'approve_post';

+ }

+

+ /**

+ * Find the users who want to receive notifications

+ *

+ * @param ContainerBuilder $phpbb_container

+ * @param array $post Data from

+ *

+ * @return array

+ */

+ public static function find_users_for_notification(ContainerBuilder $phpbb_container, $post, $options = array())

+ {

+ $options = array_merge(array(

+ 'ignore_users' => array(),

+ ), $options);

+

+ $db = $phpbb_container->get('dbal.conn');

+

+ $users = array();

+ $users[$post['poster_id']] = array('');

+

+ $auth_read = $phpbb_container->get('auth')->acl_get_list(array_keys($users), 'f_read', $post['forum_id']);

+

+ if (empty($auth_read))

+ {

+ return array();

+ }

+

+ $notify_users = array();

+

+ $sql = 'SELECT *

+ FROM ' . USER_NOTIFICATIONS_TABLE . "

+ WHERE item_type = '" . self::$notification_option['id'] . "'

+ AND " . $db->sql_in_set('user_id', $auth_read[$post['forum_id']]['f_read']);

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

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

+ {

+ if (isset($options['ignore_users'][$row['user_id']]) && in_array($row['method'], $options['ignore_users'][$row['user_id']]))

+ {

+ continue;

+ }

+

+ if (!isset($rowset[$row['user_id']]))

+ {

+ $notify_users[$row['user_id']] = array();

+ }

+

+ $notify_users[$row['user_id']][] = $row['method'];

+ }

+ $db->sql_freeresult($result);

+

+ return $notify_users;

+ }

+

+ /**

+ * Function for preparing the data for insertion in an SQL query

+ * (The service handles insertion)

+ *

+ * @param array $post Data from submit_post

+ *

+ * @return array Array of data ready to be inserted into the database

+ */

+ public function create_insert_array($post)

+ {

+ $this->set_data('post_subject', $post['post_subject']);

+

+ $data = parent::create_insert_array($post);

+

+ $this->time = $data['time'] = time();

+

+ return $data;

+ }

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+use Symfony\Component\DependencyInjection\ContainerBuilder;

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Post notifications class

+* This class handles notifications for replies to a topic

+*

+* @package notifications

+*/

+class phpbb_notifications_type_approve_topic extends phpbb_notifications_type_topic

+{

+ /**

+ * Email template to use to send notifications

+ *

+ * @var string

+ */

+ public $email_template = 'topic_approved';

+

+ /**

+ * Language key used to output the text

+ *

+ * @var string

+ */

+ protected $language_key = 'NOTIFICATION_TOPIC_APPROVED';

+

+ /**

+ * Notification option data (for outputting to the user)

+ *

+ * @var bool|array False if the service should use it's default data

+ * Array of data (including keys 'id' and 'lang')

+ */

+ public static $notification_option = array(

+ 'id' => 'moderation_queue',

+ 'lang' => 'NOTIFICATION_TYPE_MODERATION_QUEUE',

+ );

+

+ /**

+ * Get the type of notification this is

+ * phpbb_notifications_type_

+ */

+ public static function get_item_type()

+ {

+ return 'approve_topic';

+ }

+

+ /**

+ * Find the users who want to receive notifications

+ *

+ * @param ContainerBuilder $phpbb_container

+ * @param array $post Data from

+ *

+ * @return array

+ */

+ public static function find_users_for_notification(ContainerBuilder $phpbb_container, $post, $options = array())

+ {

+ $options = array_merge(array(

+ 'ignore_users' => array(),

+ ), $options);

+

+ $db = $phpbb_container->get('dbal.conn');

+

+ $users = array();

+ $users[$post['poster_id']] = array('');

+

+ $auth_read = $phpbb_container->get('auth')->acl_get_list(array_keys($users), 'f_read', $post['forum_id']);

+

+ if (empty($auth_read))

+ {

+ return array();

+ }

+

+ $notify_users = array();

+

+ $sql = 'SELECT *

+ FROM ' . USER_NOTIFICATIONS_TABLE . "

+ WHERE item_type = '" . self::$notification_option['id'] . "'

+ AND " . $db->sql_in_set('user_id', $auth_read[$post['forum_id']]['f_read']);

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

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

+ {

+ if (isset($options['ignore_users'][$row['user_id']]) && in_array($row['method'], $options['ignore_users'][$row['user_id']]))

+ {

+ continue;

+ }

+

+ if (!isset($rowset[$row['user_id']]))

+ {

+ $notify_users[$row['user_id']] = array();

+ }

+

+ $notify_users[$row['user_id']][] = $row['method'];

+ }

+ $db->sql_freeresult($result);

+

+ return $notify_users;

+ }

+

+ /**

+ * Function for preparing the data for insertion in an SQL query

+ * (The service handles insertion)

+ *

+ * @param array $post Data from submit_post

+ *

+ * @return array Array of data ready to be inserted into the database

+ */

+ public function create_insert_array($post)

+ {

+ $data = parent::create_insert_array($post);

+

+ $this->time = $data['time'] = time();

+

+ return $data;

+ }

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+use Symfony\Component\DependencyInjection\ContainerBuilder;

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Base notifications class

+* @package notifications

+*/

+abstract class phpbb_notifications_type_base implements phpbb_notifications_type_interface

+{

+ protected $phpbb_container;

+ protected $service;

+ protected $db;

+ protected $phpbb_root_path;

+ protected $php_ext;

+

+ /**

+ * Array of user data containing information needed to output the notifications to the template

+ *

+ * @var array

+ */

+ protected $users = array();

+

+ /**

+ * Notification option data (for outputting to the user)

+ *

+ * @var bool|array False if the service should use it's default data

+ * Array of data (including keys 'id' and 'lang')

+ */

+ public static $notification_option = false;

+

+ /**

+ * Indentification data

+ * item_type

+ * item_id

+ * item_parent_id // Parent item id (ex: for topic => forum_id, for post => topic_id, etc)

+ * user_id

+ * unread

+ *

+ * time

+ * data (special serialized field that each notification type can use to store stuff)

+ *

+ * @var array $data Notification row from the database

+ * This must be private, all interaction should use __get(), __set(), get_data(), set_data()

+ */

+ private $data = array();

+

+ public function __construct(ContainerBuilder $phpbb_container, $data = array())

+ {

+ // phpBB Container

+ $this->phpbb_container = $phpbb_container;

+

+ // Service

+ $this->service = $phpbb_container->get('notifications');

+

+ // Some common things we're going to use

+ $this->db = $phpbb_container->get('dbal.conn');

+

+ $this->phpbb_root_path = $phpbb_container->getParameter('core.root_path');

+ $this->php_ext = $phpbb_container->getParameter('core.php_ext');

+

+ // The row from the database (unless this is a new notification we're going to add)

+ $this->data = $data;

+ $this->data['data'] = (isset($this->data['data'])) ? unserialize($this->data['data']) : array();

+ }

+

+ public function __get($name)

+ {

+ return $this->data[$name];

+ }

+

+ public function __set($name, $value)

+ {

+ $this->data[$name] = $value;

+ }

+

+ /**

+ * Get special data (only important for the classes that extend this)

+ *

+ * @param string $name Name of the variable to get

+ *

+ * @return mixed

+ */

+ protected function get_data($name)

+ {

+ return (isset($this->data['data'][$name])) ? $this->data['data'][$name] : null;

+ }

+

+ /**

+ * Set special data (only important for the classes that extend this)

+ *

+ * @param string $name Name of the variable to set

+ * @param mixed $value Value to set to the variable

+ */

+ protected function set_data($name, $value)

+ {

+ $this->data['data'][$name] = $value;

+ }

+

+ /**

+ * Prepare to output the notification to the template

+ */

+ public function prepare_for_display()

+ {

+ $user = $this->phpbb_container->get('user');

+

+ return array(

+ 'AVATAR' => $this->get_avatar(),

+

+ 'FORMATTED_TITLE' => $this->get_title(),

+

+ 'URL' => $this->get_url(),

+ 'TIME' => $user->format_date($this->time),

+

+ 'UNREAD' => $this->unread,

+

+ 'U_MARK_READ' => append_sid($this->phpbb_root_path . 'index.' . $this->php_ext, 'mark_notification[]=' . $this->notification_id),

+ );

+ }

+

+ /**

+ * Mark this item read

+ *

+ * @param bool $return True to return a string containing the SQL code to update this item, False to execute it (Default: False)

+ * @return string

+ */

+ public function mark_read($return = true)

+ {

+ return $this->mark(false, $return);

+ }

+

+ /**

+ * Mark this item unread

+ *

+ * @param bool $return True to return a string containing the SQL code to update this item, False to execute it (Default: False)

+ * @return string

+ */

+ public function mark_unread($return = true)

+ {

+ return $this->mark(true, $return);

+ }

+

+ /**

+ * Function for preparing the data for insertion in an SQL query

+ * (The service handles insertion)

+ *

+ * @param array $type_data Data unique to this notification type

+ *

+ * @return array Array of data ready to be inserted into the database

+ */

+ public function create_insert_array($type_data)

+ {

+ // Defaults

+ $this->data = array_merge(array(

+ 'item_id' => static::get_item_id($type_data),

+ 'item_type' => $this->get_item_type(),

+ 'item_parent_id' => static::get_item_parent_id($type_data),

+

+ 'time' => time(),

+ 'unread' => true,

+

+ 'data' => array(),

+ ), $this->data);

+

+ $data = $this->data;

+

+ $data['data'] = serialize($data['data']);

+

+ return $data;

+ }

+

+ /**

+ * Function for preparing the data for update in an SQL query

+ * (The service handles insertion)

+ *

+ * @param array $type_data Data unique to this notification type

+ *

+ * @return array Array of data ready to be updated in the database

+ */

+ public function create_update_array($type_data)

+ {

+ $data = $this->create_insert_array($type_data);

+

+ // Unset data unique to each row

+ unset(

+ $data['notification_id'],

+ $data['unread'],

+ $data['user_id']

+ );

+

+ return $data;

+ }

+

+ /**

+ * -------------- Fall back functions -------------------

+ */

+

+ /**

+ * URL to unsubscribe to this notification (fall-back)

+ *

+ * @param string|bool $method Method name to unsubscribe from (email|jabber|etc), False to unsubscribe from all notifications for this item

+ */

+ public function get_unsubscribe_url($method = false)

+ {

+ return false;

+ }

+

+ /**

+ * Get the user's avatar (fall-back)

+ */

+ public function get_avatar()

+ {

+ return '';

+ }

+

+ /**

+ * Get the special items to load (fall-back)

+ */

+ public function get_load_special()

+ {

+ return array();

+ }

+

+ /**

+ * Load the special items (fall-back)

+ */

+ public static function load_special(ContainerBuilder $phpbb_container, $data, $notifications)

+ {

+ return;

+ }

+

+ /**

+ * Is available (fall-back)

+ */

+ public static function is_available(ContainerBuilder $phpbb_container)

+ {

+ return true;

+ }

+

+ /**

+ * -------------- Helper functions -------------------

+ */

+

+ /**

+ * Find the users who want to receive notifications (helper)

+ *

+ * @param ContainerBuilder $phpbb_container

+ * @param array $item_id The item_id to search for

+ *

+ * @return array

+ */

+ protected static function _find_users_for_notification(ContainerBuilder $phpbb_container, $item_id, $options)

+ {

+ $options = array_merge(array(

+ 'ignore_users' => array(),

+ ), $options);

+

+ $db = $phpbb_container->get('dbal.conn');

+

+ $rowset = array();

+

+ $sql = 'SELECT *

+ FROM ' . USER_NOTIFICATIONS_TABLE . "

+ WHERE item_type = '" . static::get_item_type() . "'

+ AND item_id = " . (int) $item_id;

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

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

+ {

+ if (isset($options['ignore_users'][$row['user_id']]) && in_array($row['method'], $options['ignore_users'][$row['user_id']]))

+ {

+ continue;

+ }

+

+ if (!isset($rowset[$row['user_id']]))

+ {

+ $rowset[$row['user_id']] = array();

+ }

+

+ $rowset[$row['user_id']][] = $row['method'];

+ }

+ $db->sql_freeresult($result);

+

+ return $rowset;

+ }

+

+ /**

+ * Get avatar helper

+ *

+ * @param int $user_id

+ * @return string

+ */

+ protected function _get_avatar($user_id)

+ {

+ $user = $this->service->get_user($user_id);

+

+ if (!function_exists('get_user_avatar'))

+ {

+ include($this->phpbb_root_path . 'includes/functions_display.' . $this->php_ext);

+ }

+

+ return get_user_avatar($user['user_avatar'], $user['user_avatar_type'], $user['user_avatar_width'], $user['user_avatar_height'], $user['username'], false, 'notifications-avatar');

+ }

+

+ /**

+ * Mark this item read/unread helper

+ *

+ * @param bool $unread Unread (True/False) (Default: False)

+ * @param bool $return True to return a string containing the SQL code to update this item, False to execute it (Default: False)

+ * @return string

+ */

+ protected function mark($unread = true, $return = false)

+ {

+ $where = array(

+ 'item_type = ' . $this->db->sql_escape($this->item_type),

+ 'item_id = ' . (int) $this->item_id,

+ 'user_id = ' . (int) $this->user_id,

+ );

+ $where = implode(' AND ' . $where);

+

+ if ($return)

+ {

+ return $where;

+ }

+

+ $sql = 'UPDATE ' . NOTIFICATIONS_TABLE . '

+ SET unread = ' . (bool) $unread . '

+ WHERE ' . $where;

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

+ }

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+use Symfony\Component\DependencyInjection\ContainerBuilder;

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Bookmark updating notifications class

+* This class handles notifications for replies to a bookmarked topic

+*

+* @package notifications

+*/

+class phpbb_notifications_type_bookmark extends phpbb_notifications_type_post

+{

+ /**

+ * Email template to use to send notifications

+ *

+ * @var string

+ */

+ public $email_template = 'notifications/bookmark';

+

+ /**

+ * Language key used to output the text

+ *

+ * @var string

+ */

+ protected $language_key = 'NOTIFICATION_BOOKMARK';

+

+ /**

+ * Get the type of notification this is

+ * phpbb_notifications_type_

+ */

+ public static function get_item_type()

+ {

+ return 'bookmark';

+ }

+

+ /**

+ * Find the users who want to receive notifications

+ *

+ * @param ContainerBuilder $phpbb_container

+ * @param array $post Data from

+ *

+ * @return array

+ */

+ public static function find_users_for_notification(ContainerBuilder $phpbb_container, $post, $options = array())

+ {

+ $options = array_merge(array(

+ 'ignore_users' => array(),

+ ), $options);

+

+ $db = $phpbb_container->get('dbal.conn');

+

+ $users = array();

+

+ $sql = 'SELECT user_id

+ FROM ' . BOOKMARKS_TABLE . '

+ WHERE ' . $db->sql_in_set('topic_id', $post['topic_id']) . '

+ AND user_id <> ' . (int) $post['poster_id'];

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

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

+ {

+ $users[] = $row['user_id'];

+ }

+ $db->sql_freeresult($result);

+

+ if (empty($users))

+ {

+ return array();

+ }

+

+ $auth_read = $phpbb_container->get('auth')->acl_get_list($users, 'f_read', $post['forum_id']);

+

+ if (empty($auth_read))

+ {

+ return array();

+ }

+

+ $notify_users = array();

+

+ $sql = 'SELECT *

+ FROM ' . USER_NOTIFICATIONS_TABLE . "

+ WHERE item_type = '" . self::get_item_type() . "'

+ AND " . $db->sql_in_set('user_id', $auth_read[$post['forum_id']]['f_read']);

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

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

+ {

+ if (isset($options['ignore_users'][$row['user_id']]) && in_array($row['method'], $options['ignore_users'][$row['user_id']]))

+ {

+ continue;

+ }

+

+ if (!isset($rowset[$row['user_id']]))

+ {

+ $notify_users[$row['user_id']] = array();

+ }

+

+ $notify_users[$row['user_id']][] = $row['method'];

+ }

+ $db->sql_freeresult($result);

+

+ return $notify_users;

+ }

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+use Symfony\Component\DependencyInjection\ContainerBuilder;

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Post notifications class

+* This class handles notifications for replies to a topic

+*

+* @package notifications

+*/

+class phpbb_notifications_type_disapprove_post extends phpbb_notifications_type_approve_post

+{

+ /**

+ * Email template to use to send notifications

+ *

+ * @var string

+ */

+ public $email_template = 'post_disapproved';

+

+ /**

+ * Language key used to output the text

+ *

+ * @var string

+ */

+ protected $language_key = 'NOTIFICATION_POST_DISAPPROVED';

+

+ /**

+ * Notification option data (for outputting to the user)

+ *

+ * @var bool|array False if the service should use it's default data

+ * Array of data (including keys 'id' and 'lang')

+ */

+ public static $notification_option = array(

+ 'id' => 'moderation_queue',

+ 'lang' => 'NOTIFICATION_TYPE_MODERATION_QUEUE',

+ );

+

+ /**

+ * Get the type of notification this is

+ * phpbb_notifications_type_

+ */

+ public static function get_item_type()

+ {

+ return 'disapprove_post';

+ }

+

+ /**

+ * Get the HTML formatted title of this notification

+ *

+ * @return string

+ */

+ public function get_title()

+ {

+ return $this->phpbb_container->get('user')->lang(

+ $this->language_key,

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

+ $this->get_data('disapprove_reason')

+ );

+ }

+

+ /**

+ * Get the url to this item

+ *

+ * @return string URL

+ */

+ public function get_url()

+ {

+ return '';

+ }

+

+ /**

+ * Get email template variables

+ *

+ * @return array

+ */

+ public function get_email_template_variables()

+ {

+ return array_merge(parent::get_email_template_variables(), array(

+ 'REASON' => htmlspecialchars_decode($this->get_data('disapprove_reason')),

+ ));

+ }

+

+ /**

+ * Function for preparing the data for insertion in an SQL query

+ * (The service handles insertion)

+ *

+ * @param array $post Data from submit_post

+ *

+ * @return array Array of data ready to be inserted into the database

+ */

+ public function create_insert_array($post)

+ {

+ $this->set_data('disapprove_reason', $post['disapprove_reason']);

+

+ $data = parent::create_insert_array($post);

+

+ $this->time = $data['time'] = time();

+

+ return $data;

+ }

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+use Symfony\Component\DependencyInjection\ContainerBuilder;

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Post notifications class

+* This class handles notifications for replies to a topic

+*

+* @package notifications

+*/

+class phpbb_notifications_type_disapprove_topic extends phpbb_notifications_type_approve_topic

+{

+ /**

+ * Email template to use to send notifications

+ *

+ * @var string

+ */

+ public $email_template = 'topic_disapproved';

+

+ /**

+ * Language key used to output the text

+ *

+ * @var string

+ */

+ protected $language_key = 'NOTIFICATION_TOPIC_DISAPPROVED';

+

+ /**

+ * Notification option data (for outputting to the user)

+ *

+ * @var bool|array False if the service should use it's default data

+ * Array of data (including keys 'id' and 'lang')

+ */

+ public static $notification_option = array(

+ 'id' => 'moderation_queue',

+ 'lang' => 'NOTIFICATION_TYPE_MODERATION_QUEUE',

+ );

+

+ /**

+ * Get the type of notification this is

+ * phpbb_notifications_type_

+ */

+ public static function get_item_type()

+ {

+ return 'disapprove_topic';

+ }

+

+ /**

+ * Get the HTML formatted title of this notification

+ *

+ * @return string

+ */

+ public function get_title()

+ {

+ return $this->phpbb_container->get('user')->lang(

+ $this->language_key,

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

+ $this->get_data('disapprove_reason')

+ );

+ }

+

+ /**

+ * Get the url to this item

+ *

+ * @return string URL

+ */

+ public function get_url()

+ {

+ return '';

+ }

+

+ /**

+ * Get email template variables

+ *

+ * @return array

+ */

+ public function get_email_template_variables()

+ {

+ return array_merge(parent::get_email_template_variables(), array(

+ 'REASON' => htmlspecialchars_decode($this->get_data('disapprove_reason')),

+ ));

+ }

+

+ /**

+ * Function for preparing the data for insertion in an SQL query

+ * (The service handles insertion)

+ *

+ * @param array $post Data from submit_post

+ *

+ * @return array Array of data ready to be inserted into the database

+ */

+ public function create_insert_array($post)

+ {

+ $this->set_data('disapprove_reason', $post['disapprove_reason']);

+

+ $data = parent::create_insert_array($post);

+

+ $this->time = $data['time'] = time();

+

+ return $data;

+ }

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Base notifications interface

+* @package notifications

+*/

+interface phpbb_notifications_type_interface

+{

+ public static function get_item_type();

+

+ public static function get_item_id($type_data);

+

+ public static function is_available(ContainerBuilder $phpbb_container);

+

+ public static function find_users_for_notification(ContainerBuilder $phpbb_container, $type_data, $options);

+

+ public function get_title();

+

+ public function get_email_template_variables();

+

+ public function get_url();

+

+ public function get_unsubscribe_url($method);

+

+ public function mark_read($return);

+

+ public function mark_unread($return);

+

+ public function create_insert_array($type_data);

+

+ public function get_load_special();

+

+ public static function load_special(ContainerBuilder $phpbb_container, $data, $notifications);

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+use Symfony\Component\DependencyInjection\ContainerBuilder;

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Private message notifications class

+* This class handles notifications for private messages

+*

+* @package notifications

+*/

+class phpbb_notifications_type_pm extends phpbb_notifications_type_base

+{

+ /**

+ * Email template to use to send notifications

+ *

+ * @var string

+ */

+ public $email_template = 'privmsg_notify';

+

+ /**

+ * Get the type of notification this is

+ * phpbb_notifications_type_

+ */

+ public static function get_item_type()

+ {

+ return 'pm';

+ }

+

+ /**

+ * Get the id of the

+ *

+ * @param array $pm The data from the private message

+ */

+ public static function get_item_id($pm)

+ {

+ return (int) $pm['msg_id'];

+ }

+

+ /**

+ * Get the id of the parent

+ *

+ * @param array $pm The data from the pm

+ */

+ public static function get_item_parent_id($pm)

+ {

+ // No parent

+ return 0;

+ }

+

+ /**

+ * Find the users who want to receive notifications

+ *

+ * @param ContainerBuilder $phpbb_container

+ * @param array $pm Data from

+ *

+ * @return array

+ */

+ public static function find_users_for_notification(ContainerBuilder $phpbb_container, $pm, $options = array())

+ {

+ $options = array_merge(array(

+ 'ignore_users' => array(),

+ ), $options);

+

+ $service = $phpbb_container->get('notifications');

+ $db = $phpbb_container->get('dbal.conn');

+ $user = $phpbb_container->get('user');

+

+ if (!sizeof($pm['recipients']))

+ {

+ return array();

+ }

+

+ $service->load_users(array_keys($pm['recipients']));

+

+ $notify_users = array();

+

+ $sql = 'SELECT *

+ FROM ' . USER_NOTIFICATIONS_TABLE . "

+ WHERE item_type = '" . self::get_item_type() . "'

+ AND " . $db->sql_in_set('user_id', array_keys($pm['recipients']));

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

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

+ {

+ if (isset($options['ignore_users'][$row['user_id']]) && in_array($row['method'], $options['ignore_users'][$row['user_id']]))

+ {

+ continue;

+ }

+

+ if (!isset($rowset[$row['user_id']]))

+ {

+ $notify_users[$row['user_id']] = array();

+ }

+

+ $notify_users[$row['user_id']][] = $row['method'];

+ }

+ $db->sql_freeresult($result);

+

+ return $notify_users;

+ }

+

+ /**

+ * Get the user's avatar

+ */

+ public function get_avatar()

+ {

+ return $this->_get_avatar($this->get_data('from_user_id'));

+ }

+

+ /**

+ * Get the HTML formatted title of this notification

+ *

+ * @return string

+ */

+ public function get_title()

+ {

+ $user_data = $this->service->get_user($this->get_data('from_user_id'));

+

+ $username = get_username_string('no_profile', $user_data['user_id'], $user_data['username'], $user_data['user_colour']);

+

+ return $this->phpbb_container->get('user')->lang('NOTIFICATION_PM', $username, $this->get_data('message_subject'));

+ }

+

+ /**

+ * Get email template variables

+ *

+ * @return array

+ */

+ public function get_email_template_variables()

+ {

+ $user_data = $this->service->get_user($this->get_data('from_user_id'));

+

+ return array(

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

+ 'SUBJECT' => htmlspecialchars_decode(censor_text($this->get_data('message_subject'))),

+

+ 'U_VIEW_MESSAGE' => generate_board_url() . '/ucp.' . $this->php_ext . "?i=pm&mode=view&p={$this->item_id}",

+ );

+ }

+

+ /**

+ * Get the url to this item

+ *

+ * @return string URL

+ */

+ public function get_url()

+ {

+ return append_sid($this->phpbb_root_path . 'ucp.' . $this->php_ext, "i=pm&amp;mode=view&amp;p={$this->item_id}");

+ }

+

+ /**

+ * Users needed to query before this notification can be displayed

+ *

+ * @return array Array of user_ids

+ */

+ public function users_to_query()

+ {

+ return array($this->data['from_user_id']);

+ }

+

+ /**

+ * Function for preparing the data for insertion in an SQL query

+ * (The service handles insertion)

+ *

+ * @param array $post Data from submit_post

+ *

+ * @return array Array of data ready to be inserted into the database

+ */

+ public function create_insert_array($pm)

+ {

+ $this->set_data('from_user_id', $pm['from_user_id']);

+

+ $this->set_data('message_subject', $pm['message_subject']);

+

+ return parent::create_insert_array($pm);

+ }

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+use Symfony\Component\DependencyInjection\ContainerBuilder;

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Post notifications class

+* This class handles notifications for replies to a topic

+*

+* @package notifications

+*/

+class phpbb_notifications_type_post extends phpbb_notifications_type_base

+{

+ /**

+ * Email template to use to send notifications

+ *

+ * @var string

+ */

+ public $email_template = 'topic_notify';

+

+ /**

+ * Language key used to output the text

+ *

+ * @var string

+ */

+ protected $language_key = 'NOTIFICATION_POST';

+

+ /**

+ * Get the type of notification this is

+ * phpbb_notifications_type_

+ */

+ public static function get_item_type()

+ {

+ return 'post';

+ }

+

+ /**

+ * Get the id of the item

+ *

+ * @param array $post The data from the post

+ */

+ public static function get_item_id($post)

+ {

+ return (int) $post['post_id'];

+ }

+

+ /**

+ * Get the id of the parent

+ *

+ * @param array $post The data from the post

+ */

+ public static function get_item_parent_id($post)

+ {

+ return (int) $post['topic_id'];

+ }

+

+ /**

+ * Find the users who want to receive notifications

+ *

+ * @param ContainerBuilder $phpbb_container

+ * @param array $post Data from

+ *

+ * @return array

+ */

+ public static function find_users_for_notification(ContainerBuilder $phpbb_container, $post, $options = array())

+ {

+ $options = array_merge(array(

+ 'ignore_users' => array(),

+ ), $options);

+

+ // Let's continue to use the phpBB subscriptions system, at least for now.

+ // It may not be the nicest thing, but it is already working and it would be significant work to replace it

+ //$users = parent::_find_users_for_notification($phpbb_container, $post['topic_id']);

+

+ $db = $phpbb_container->get('dbal.conn');

+

+ $users = array();

+

+ $sql = 'SELECT user_id

+ FROM ' . TOPICS_WATCH_TABLE . '

+ WHERE topic_id = ' . (int) $post['topic_id'] . '

+ AND notify_status = ' . NOTIFY_YES . '

+ AND user_id <> ' . (int) $post['poster_id'];

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

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

+ {

+ $users[] = $row['user_id'];

+ }

+ $db->sql_freeresult($result);

+

+ if (empty($users))

+ {

+ return array();

+ }

+

+ $auth_read = $phpbb_container->get('auth')->acl_get_list($users, 'f_read', $post['forum_id']);

+

+ if (empty($auth_read))

+ {

+ return array();

+ }

+

+ $notify_users = array();

+

+ $sql = 'SELECT *

+ FROM ' . USER_NOTIFICATIONS_TABLE . "

+ WHERE item_type = '" . self::get_item_type() . "'

+ AND " . $db->sql_in_set('user_id', $auth_read[$post['forum_id']]['f_read']);

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

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

+ {

+ if (isset($options['ignore_users'][$row['user_id']]) && in_array($row['method'], $options['ignore_users'][$row['user_id']]))

+ {

+ continue;

+ }

+

+ if (!isset($rowset[$row['user_id']]))

+ {

+ $notify_users[$row['user_id']] = array();

+ }

+

+ $notify_users[$row['user_id']][] = $row['method'];

+ }

+ $db->sql_freeresult($result);

+

+ return $notify_users;

+ }

+

+ /**

+ * Get the user's avatar

+ */

+ public function get_avatar()

+ {

+ return $this->_get_avatar($this->get_data('poster_id'));

+ }

+

+ /**

+ * Get the HTML formatted title of this notification

+ *

+ * @return string

+ */

+ public function get_title()

+ {

+ if ($this->get_data('post_username'))

+ {

+ $username = $this->get_data('post_username');

+ }

+ else

+ {

+ $user_data = $this->service->get_user($this->get_data('poster_id'));

+

+ $username = get_username_string('no_profile', $user_data['user_id'], $user_data['username'], $user_data['user_colour']);

+ }

+

+ return $this->phpbb_container->get('user')->lang(

+ $this->language_key,

+ $username,

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

+ );

+ }

+

+ /**

+ * Get email template variables

+ *

+ * @return array

+ */

+ public function get_email_template_variables()

+ {

+ return array(

+ 'POST_SUBJECT' => htmlspecialchars_decode(censor_text($this->get_data('post_subject'))),

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

+

+ 'U_VIEW_POST' => generate_board_url() . "/viewtopic.{$this->php_ext}?p={$this->item_id}#p{$this->item_id}",

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

+ 'U_TOPIC' => generate_board_url() . "/viewtopic.{$this->php_ext}?f={$this->get_data('forum_id')}&t={$this->item_parent_id}",

+ 'U_VIEW_TOPIC' => generate_board_url() . "/viewtopic.{$this->php_ext}?f={$this->get_data('forum_id')}&t={$this->item_parent_id}",

+ 'U_FORUM' => generate_board_url() . "/viewforum.{$this->php_ext}?f={$this->get_data('forum_id')}",

+ 'U_STOP_WATCHING_TOPIC' => generate_board_url() . "/viewtopic.{$this->php_ext}?uid={$this->user_id}&f={$this->get_data('forum_id')}&t={$this->item_parent_id}&unwatch=topic",

+ );

+ }

+

+ /**

+ * Get the url to this item

+ *

+ * @return string URL

+ */

+ public function get_url()

+ {

+ return append_sid($this->phpbb_root_path . 'viewtopic.' . $this->php_ext, "p={$this->item_id}#p{$this->item_id}");

+ }

+

+ /**

+ * Users needed to query before this notification can be displayed

+ *

+ * @return array Array of user_ids

+ */

+ public function users_to_query()

+ {

+ return array($this->data['poster_id']);

+ }

+

+ /**

+ * Function for preparing the data for insertion in an SQL query

+ * (The service handles insertion)

+ *

+ * @param array $post Data from submit_post

+ *

+ * @return array Array of data ready to be inserted into the database

+ */

+ public function create_insert_array($post)

+ {

+ $this->set_data('poster_id', $post['poster_id']);

+

+ $this->set_data('topic_title', $post['topic_title']);

+

+ $this->set_data('post_subject', $post['post_subject']);

+

+ $this->set_data('post_username', (($post['poster_id'] == ANONYMOUS) ? $post['post_username'] : ''));

+

+ $this->set_data('forum_id', $post['forum_id']);

+

+ $this->set_data('forum_name', $post['forum_name']);

+

+ $this->time = $post['post_time'];

+

+ return parent::create_insert_array($post);

+ }

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+use Symfony\Component\DependencyInjection\ContainerBuilder;

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Topic notifications class

+* This class handles notifications for new topics

+*

+* @package notifications

+*/

+class phpbb_notifications_type_post_in_queue extends phpbb_notifications_type_post

+{

+ /**

+ * Email template to use to send notifications

+ *

+ * @var string

+ */

+ public $email_template = 'notifications/post_in_queue';

+

+ /**

+ * Language key used to output the text

+ *

+ * @var string

+ */

+ protected $language_key = 'NOTIFICATION_POST_IN_QUEUE';

+

+ /**

+ * Notification option data (for outputting to the user)

+ *

+ * @var bool|array False if the service should use it's default data

+ * Array of data (including keys 'id' and 'lang')

+ */

+ public static $notification_option = array(

+ 'id' => 'needs_approval',

+ 'lang' => 'NOTIFICATION_TYPE_IN_MODERATION_QUEUE',

+ );

+

+ /**

+ * Get the type of notification this is

+ * phpbb_notifications_type_

+ */

+ public static function get_item_type()

+ {

+ return 'post_in_queue';

+ }

+

+ /**

+ * Is available

+ */

+ public static function is_available(ContainerBuilder $phpbb_container)

+ {

+ $m_approve = $phpbb_container->get('auth')->acl_getf('m_approve', true);

+

+ return (!empty($m_approve));

+ }

+

+ /**

+ * Find the users who want to receive notifications

+ *

+ * @param ContainerBuilder $phpbb_container

+ * @param array $post Data from the post

+ *

+ * @return array

+ */

+ public static function find_users_for_notification(ContainerBuilder $phpbb_container, $post, $options = array())

+ {

+ $options = array_merge(array(

+ 'ignore_users' => array(),

+ ), $options);

+

+ $db = $phpbb_container->get('dbal.conn');

+

+ $auth_approve = $phpbb_container->get('auth')->acl_get_list(false, 'm_approve', $post['forum_id']);

+

+ if (empty($auth_approve))

+ {

+ return array();

+ }

+

+ $notify_users = array();

+

+ $sql = 'SELECT *

+ FROM ' . USER_NOTIFICATIONS_TABLE . "

+ WHERE item_type = '" . self::$notification_option['id'] . "'

+ AND " . $db->sql_in_set('user_id', $auth_approve[$post['forum_id']]['m_approve']);

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

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

+ {

+ if (isset($options['ignore_users'][$row['user_id']]) && in_array($row['method'], $options['ignore_users'][$row['user_id']]))

+ {

+ continue;

+ }

+

+ if (!isset($rowset[$row['user_id']]))

+ {

+ $notify_users[$row['user_id']] = array();

+ }

+

+ $notify_users[$row['user_id']][] = $row['method'];

+ }

+ $db->sql_freeresult($result);

+

+ return $notify_users;

+ }

+

+ /**

+ * Function for preparing the data for insertion in an SQL query

+ * (The service handles insertion)

+ *

+ * @param array $post Data from submit_post

+ *

+ * @return array Array of data ready to be inserted into the database

+ */

+ public function create_insert_array($post)

+ {

+ $data = parent::create_insert_array($post);

+

+ $this->time = $data['time'] = time();

+

+ return $data;

+ }

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+use Symfony\Component\DependencyInjection\ContainerBuilder;

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Post quoting notifications class

+* This class handles notifications for quoting users in a post

+*

+* @package notifications

+*/

+class phpbb_notifications_type_quote extends phpbb_notifications_type_post

+{

+ /**

+ * Email template to use to send notifications

+ *

+ * @var string

+ */

+ public $email_template = 'notifications/quote';

+

+ /**

+ * regular expression to match to find usernames

+ *

+ * @var string

+ */

+ protected static $regular_expression_match = '#\[quote=&quot;(.+?)&quot;#';

+

+ /**

+ * Language key used to output the text

+ *

+ * @var string

+ */

+ protected $language_key = 'NOTIFICATION_QUOTE';

+

+ /**

+ * Get the type of notification this is

+ * phpbb_notifications_type_

+ */

+ public static function get_item_type()

+ {

+ return 'quote';

+ }

+

+ /**

+ * Find the users who want to receive notifications

+ *

+ * @param ContainerBuilder $phpbb_container

+ * @param array $post Data from

+ *

+ * @return array

+ */

+ public static function find_users_for_notification(ContainerBuilder $phpbb_container, $post, $options = array())

+ {

+ $options = array_merge(array(

+ 'ignore_users' => array(),

+ ), $options);

+

+ $db = $phpbb_container->get('dbal.conn');

+

+ $usernames = false;

+ preg_match_all(self::$regular_expression_match, $post['post_text'], $usernames);

+

+ if (empty($usernames[1]))

+ {

+ return array();

+ }

+

+ $usernames[1] = array_unique($usernames[1]);

+

+ $usernames = array_map('utf8_clean_string', $usernames[1]);

+

+ $users = array();

+

+ $sql = 'SELECT user_id

+ FROM ' . USERS_TABLE . '

+ WHERE ' . $db->sql_in_set('username_clean', $usernames) . '

+ AND user_id <> ' . (int) $post['poster_id'];

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

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

+ {

+ $users[] = $row['user_id'];

+ }

+ $db->sql_freeresult($result);

+

+ if (empty($users))

+ {

+ return array();

+ }

+

+ $auth_read = $phpbb_container->get('auth')->acl_get_list($users, 'f_read', $post['forum_id']);

+

+ if (empty($auth_read))

+ {

+ return array();

+ }

+

+ $notify_users = array();

+

+ $sql = 'SELECT *

+ FROM ' . USER_NOTIFICATIONS_TABLE . "

+ WHERE item_type = '" . self::get_item_type() . "'

+ AND " . $db->sql_in_set('user_id', $auth_read[$post['forum_id']]['f_read']);

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

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

+ {

+ if (isset($options['ignore_users'][$row['user_id']]) && in_array($row['method'], $options['ignore_users'][$row['user_id']]))

+ {

+ continue;

+ }

+

+ if (!isset($rowset[$row['user_id']]))

+ {

+ $notify_users[$row['user_id']] = array();

+ }

+

+ $notify_users[$row['user_id']][] = $row['method'];

+ }

+ $db->sql_freeresult($result);

+

+ return $notify_users;

+ }

+

+ /**

+ * Update a notification

+ *

+ * @param ContainerBuilder $phpbb_container

+ * @param array $data Data specific for this type that will be updated

+ */

+ public static function update_notifications(ContainerBuilder $phpbb_container, $post)

+ {

+ $service = $phpbb_container->get('notifications');

+ $db = $phpbb_container->get('dbal.conn');

+

+ $old_notifications = array();

+ $sql = 'SELECT user_id

+ FROM ' . NOTIFICATIONS_TABLE . "

+ WHERE item_type = '" . self::get_item_type() . "'

+ AND item_id = " . self::get_item_id($post);

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

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

+ {

+ $old_notifications[] = $row['user_id'];

+ }

+ $db->sql_freeresult($result);

+

+ // Find the new users to notify

+ $notifications = self::find_users_for_notification($phpbb_container, $post);

+

+ // Find the notifications we must delete

+ $remove_notifications = array_diff($old_notifications, array_keys($notifications));

+

+ // Find the notifications we must add

+ $add_notifications = array();

+ foreach (array_diff(array_keys($notifications), $old_notifications) as $user_id)

+ {

+ $add_notifications[$user_id] = $notifications[$user_id];

+ }

+

+ // todo Adding notifications while editing a post can be funky.

+ // If the user has read the topic/post already, and the user is newly quoted it an edit,

+ // The notification will be stuck as unread until another post is made and the user visits

+ // the topic again because the posts will not be marked as read since the topic is already

+ // marked as read

+

+ // Add the necessary notifications

+ $service->add_notifications_for_users(self::get_item_type(), $post, $add_notifications);

+

+ // Remove the necessary notifications

+ if (!empty($remove_notifications))

+ {

+ $sql = 'DELETE FROM ' . NOTIFICATIONS_TABLE . "

+ WHERE item_type = '" . self::get_item_type() . "'

+ AND item_id = " . self::get_item_id($post) . '

+ AND ' . $db->sql_in_set('user_id', $remove_notifications);

+ $db->sql_query($sql);

+ }

+

+ // return true to continue with the update code in the notifications service (this will update the rest of the notifications)

+ return true;

+ }

+

+ /**

+ * Get email template variables

+ *

+ * @return array

+ */

+ public function get_email_template_variables()

+ {

+ $user_data = $this->service->get_user($this->get_data('poster_id'));

+

+ return array_merge(parent::get_email_template_variables(), array(

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

+ ));

+ }

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+use Symfony\Component\DependencyInjection\ContainerBuilder;

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Topic notifications class

+* This class handles notifications for new topics

+*

+* @package notifications

+*/

+class phpbb_notifications_type_topic extends phpbb_notifications_type_base

+{

+ /**

+ * Email template to use to send notifications

+ *

+ * @var string

+ */

+ public $email_template = 'newtopic_notify';

+

+ /**

+ * Language key used to output the text

+ *

+ * @var string

+ */

+ protected $language_key = 'NOTIFICATION_TOPIC';

+

+ /**

+ * Get the type of notification this is

+ * phpbb_notifications_type_

+ */

+ public static function get_item_type()

+ {

+ return 'topic';

+ }

+

+ /**

+ * Get the id of the item

+ *

+ * @param array $post The data from the post

+ */

+ public static function get_item_id($post)

+ {

+ return (int) $post['topic_id'];

+ }

+

+ /**

+ * Get the id of the parent

+ *

+ * @param array $post The data from the post

+ */

+ public static function get_item_parent_id($post)

+ {

+ return (int) $post['forum_id'];

+ }

+

+ /**

+ * Find the users who want to receive notifications

+ *

+ * @param ContainerBuilder $phpbb_container

+ * @param array $topic Data from the topic

+ *

+ * @return array

+ */

+ public static function find_users_for_notification(ContainerBuilder $phpbb_container, $topic, $options = array())

+ {

+ $options = array_merge(array(

+ 'ignore_users' => array(),

+ ), $options);

+

+ // Let's continue to use the phpBB subscriptions system, at least for now.

+ // It may not be the nicest thing, but it is already working and it would be significant work to replace it

+ //$users = parent::_find_users_for_notification($phpbb_container, $topic['forum_id']);

+

+ $db = $phpbb_container->get('dbal.conn');

+

+ $users = array();

+

+ $sql = 'SELECT user_id

+ FROM ' . FORUMS_WATCH_TABLE . '

+ WHERE forum_id = ' . (int) $topic['forum_id'] . '

+ AND notify_status = ' . NOTIFY_YES . '

+ AND user_id <> ' . (int) $topic['poster_id'];

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

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

+ {

+ $users[] = $row['user_id'];

+ }

+ $db->sql_freeresult($result);

+

+ if (empty($users))

+ {

+ return array();

+ }

+

+ $auth_read = $phpbb_container->get('auth')->acl_get_list($users, 'f_read', $topic['forum_id']);

+

+ if (empty($auth_read))

+ {

+ return array();

+ }

+

+ $notify_users = array();

+

+ $sql = 'SELECT *

+ FROM ' . USER_NOTIFICATIONS_TABLE . "

+ WHERE item_type = '" . self::get_item_type() . "'

+ AND " . $db->sql_in_set('user_id', $auth_read[$topic['forum_id']]['f_read']);

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

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

+ {

+ if (isset($options['ignore_users'][$row['user_id']]) && in_array($row['method'], $options['ignore_users'][$row['user_id']]))

+ {

+ continue;

+ }

+

+ if (!isset($rowset[$row['user_id']]))

+ {

+ $notify_users[$row['user_id']] = array();

+ }

+

+ $notify_users[$row['user_id']][] = $row['method'];

+ }

+ $db->sql_freeresult($result);

+

+ return $notify_users;

+ }

+

+ /**

+ * Get the user's avatar

+ */

+ public function get_avatar()

+ {

+ return $this->_get_avatar($this->get_data('poster_id'));

+ }

+

+ /**

+ * Get the HTML formatted title of this notification

+ *

+ * @return string

+ */

+ public function get_title()

+ {

+ if ($this->get_data('post_username'))

+ {

+ $username = $this->get_data('post_username');

+ }

+ else

+ {

+ $user_data = $this->service->get_user($this->get_data('poster_id'));

+

+ $username = get_username_string('no_profile', $user_data['user_id'], $user_data['username'], $user_data['user_colour']);

+ }

+

+ return $this->phpbb_container->get('user')->lang(

+ $this->language_key,

+ $username,

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

+ $this->get_data('forum_name')

+ );

+ }

+

+ /**

+ * Get email template variables

+ *

+ * @return array

+ */

+ public function get_email_template_variables()

+ {

+ return array(

+ 'FORUM_NAME' => htmlspecialchars_decode($this->get_data('forum_name')),

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

+

+ 'U_TOPIC' => generate_board_url() . "/viewtopic.{$this->php_ext}?f={$this->item_parent_id}&t={$this->item_id}",

+ 'U_VIEW_TOPIC' => generate_board_url() . "/viewtopic.{$this->php_ext}?f={$this->item_parent_id}&t={$this->item_id}",

+ 'U_FORUM' => generate_board_url() . "/viewforum.{$this->php_ext}?f={$this->item_parent_id}",

+ 'U_STOP_WATCHING_FORUM' => generate_board_url() . "/viewforum.{$this->php_ext}?uid={$this->user_id}&f={$this->item_parent_id}&unwatch=forum",

+ );

+ }

+

+ /**

+ * Get the url to this item

+ *

+ * @return string URL

+ */

+ public function get_url()

+ {

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

+ }

+

+ /**

+ * Users needed to query before this notification can be displayed

+ *

+ * @return array Array of user_ids

+ */

+ public function users_to_query()

+ {

+ return array($this->data['poster_id']);

+ }

+

+ /**

+ * Function for preparing the data for insertion in an SQL query

+ * (The service handles insertion)

+ *

+ * @param array $post Data from submit_post

+ *

+ * @return array Array of data ready to be inserted into the database

+ */

+ public function create_insert_array($post)

+ {

+ $this->set_data('poster_id', $post['poster_id']);

+

+ $this->set_data('topic_title', $post['topic_title']);

+

+ $this->set_data('post_username', (($post['poster_id'] == ANONYMOUS) ? $post['post_username'] : ''));

+

+ $this->set_data('forum_name', $post['forum_name']);

+

+ $this->time = $post['post_time'];

+

+ return parent::create_insert_array($post);

+ }

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+use Symfony\Component\DependencyInjection\ContainerBuilder;

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+/**

+* Topic notifications class

+* This class handles notifications for new topics

+*

+* @package notifications

+*/

+class phpbb_notifications_type_topic_in_queue extends phpbb_notifications_type_topic

+{

+ /**

+ * Email template to use to send notifications

+ *

+ * @var string

+ */

+ public $email_template = 'notifications/topic_in_queue';

+

+ /**

+ * Language key used to output the text

+ *

+ * @var string

+ */

+ protected $language_key = 'NOTIFICATION_TOPIC_IN_QUEUE';

+

+ /**

+ * Notification option data (for outputting to the user)

+ *

+ * @var bool|array False if the service should use it's default data

+ * Array of data (including keys 'id' and 'lang')

+ */

+ public static $notification_option = array(

+ 'id' => 'needs_approval',

+ 'lang' => 'NOTIFICATION_TYPE_IN_MODERATION_QUEUE',

+ );

+

+ /**

+ * Is available

+ */

+ public static function is_available(ContainerBuilder $phpbb_container)

+ {

+ $m_approve = $phpbb_container->get('auth')->acl_getf('m_approve', true);

+

+ return (!empty($m_approve));

+ }

+

+ /**

+ * Get the type of notification this is

+ * phpbb_notifications_type_

+ */

+ public static function get_item_type()

+ {

+ return 'topic_in_queue';

+ }

+

+ /**

+ * Find the users who want to receive notifications

+ *

+ * @param ContainerBuilder $phpbb_container

+ * @param array $topic Data from the topic

+ *

+ * @return array

+ */

+ public static function find_users_for_notification(ContainerBuilder $phpbb_container, $topic, $options = array())

+ {

+ $options = array_merge(array(

+ 'ignore_users' => array(),

+ ), $options);

+

+ $db = $phpbb_container->get('dbal.conn');

+

+ $auth_approve = $phpbb_container->get('auth')->acl_get_list(false, 'm_approve', $topic['forum_id']);

+

+ if (empty($auth_approve))

+ {

+ return array();

+ }

+

+ $notify_users = array();

+

+ $sql = 'SELECT *

+ FROM ' . USER_NOTIFICATIONS_TABLE . "

+ WHERE item_type = '" . self::$notification_option['id'] . "'

+ AND " . $db->sql_in_set('user_id', $auth_approve[$topic['forum_id']]['m_approve']);

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

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

+ {

+ if (isset($options['ignore_users'][$row['user_id']]) && in_array($row['method'], $options['ignore_users'][$row['user_id']]))

+ {

+ continue;

+ }

+

+ if (!isset($rowset[$row['user_id']]))

+ {

+ $notify_users[$row['user_id']] = array();

+ }

+

+ $notify_users[$row['user_id']][] = $row['method'];

+ }

+ $db->sql_freeresult($result);

+

+ return $notify_users;

+ }

+

+ /**

+ * Function for preparing the data for insertion in an SQL query

+ * (The service handles insertion)

+ *

+ * @param array $topic Data from submit_post

+ *

+ * @return array Array of data ready to be inserted into the database

+ */

+ public function create_insert_array($topic)

+ {

+ $data = parent::create_insert_array($topic);

+

+ $this->time = $data['time'] = time();

+

+ return $data;

+ }

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+/**

+* @package module_install

+*/

+class ucp_notifications_info

+{

+ function module()

+ {

+ return array(

+ 'filename' => 'ucp_notifications',

+ 'title' => 'UCP_NOTIFICATION_OPTIONS',

+ 'version' => '1.0.0',

+ 'modes' => array(

+ 'notification_options' => array('title' => 'UCP_NOTIFICATION_OPTIONS', 'auth' => '', 'cat' => array('UCP_MAIN')),

+ ),

+ );

+ }

+

+ function install()

+ {

+ }

+

+ function uninstall()

+ {

+ }

+}

+<?php

+/**

+*

+* @package notifications

+* @copyright (c) 2012 phpBB Group

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

+*

+*/

+

+/**

+* @ignore

+*/

+if (!defined('IN_PHPBB'))

+{

+ exit;

+}

+

+class ucp_notifications

+{

+ public $u_action;

+

+ public function main($id, $mode)

+ {

+ global $phpbb_container;

+

+ add_form_key('ucp_notification_options');

+

+ $phpbb_notifications = $phpbb_container->get('notifications');

+ $template = $phpbb_container->get('template');

+ $user = $phpbb_container->get('user');

+ $request = $phpbb_container->get('request');

+

+ $subscriptions = $phpbb_notifications->get_subscriptions(false, true);

+

+ // Add/remove subscriptions

+ if ($request->is_set_post('submit'))

+ {

+ if (!check_form_key('ucp_notification_options'))

+ {

+ trigger_error('FORM_INVALID');

+ }

+

+ $notification_methods = $phpbb_notifications->get_subscription_methods();

+

+ foreach($phpbb_notifications->get_subscription_types() as $type => $data)

+ {

+ if ($request->is_set_post($type . '_notification') && !isset($subscriptions[$type]))

+ {

+ // add

+ $phpbb_notifications->add_subscription($type);

+ }

+ else if (!$request->is_set_post($type . '_notification') && isset($subscriptions[$type]))

+ {

+ // remove

+ $phpbb_notifications->delete_subscription($type);

+ }

+

+ foreach($notification_methods as $method)

+ {

+ if ($request->is_set_post($type . '_' . $method) && (!isset($subscriptions[$type]) || !in_array($method, $subscriptions[$type])))

+ {

+ // add

+ $phpbb_notifications->add_subscription($type, 0, $method);

+ }

+ else if (!$request->is_set_post($type . '_' . $method) && isset($subscriptions[$type]) && in_array($method, $subscriptions[$type]))

+ {

+ // remove

+ $phpbb_notifications->delete_subscription($type, 0, $method);

+ }

+ }

+ }

+ }

+

+ // todo include language files for extensions?

+

+ $this->output_notification_methods('notification_methods', $phpbb_notifications, $template, $user);

+

+ $this->output_notification_types('notification_types', $phpbb_notifications, $template, $user);

+

+ $this->tpl_name = 'ucp_notifications';

+ $this->page_title = 'UCP_NOTIFICATIONS';

+ }

+

+ /**

+ * Output all the notification types to the template

+ *

+ * @param string $block

+ * @param phpbb_notifications_service $phpbb_notifications

+ * @param phpbb_template $template

+ * @param phpbb_user $user

+ */

+ public function output_notification_types($block = 'notification_types', phpbb_notifications_service $phpbb_notifications, phpbb_template $template, phpbb_user $user)

+ {

+ $notification_methods = $phpbb_notifications->get_subscription_methods();

+ $subscriptions = $phpbb_notifications->get_subscriptions(false, true);

+

+ foreach($phpbb_notifications->get_subscription_types() as $type => $data)

+ {

+ $template->assign_block_vars($block, array(

+ 'TYPE' => $type,

+

+ 'NAME' => (is_array($data) && isset($data['lang'])) ? $user->lang($data['lang']) : $user->lang('NOTIFICATION_TYPE_' . strtoupper($type)),

+

+ 'SUBSCRIBED' => (isset($subscriptions[$type])) ? true : false,

+ ));

+

+ foreach($notification_methods as $method)

+ {

+ $template->assign_block_vars($block . '.notification_methods', array(

+ 'METHOD' => $method,

+

+ 'NAME' => $user->lang('NOTIFICATION_METHOD_' . strtoupper($method)),

+

+ 'SUBSCRIBED' => (isset($subscriptions[$type]) && in_array($method, $subscriptions[$type])) ? true : false,

+ ));

+ }

+ }

+ }

+

+ /**

+ * Output all the notification methods to the template

+ *

+ * @param string $block

+ * @param phpbb_notifications_service $phpbb_notifications

+ * @param phpbb_template $template

+ * @param phpbb_user $user

+ */

+ public function output_notification_methods($block = 'notification_methods', phpbb_notifications_service $phpbb_notifications, phpbb_template $template, phpbb_user $user)

+ {

+ $notification_methods = $phpbb_notifications->get_subscription_methods();

+

+ foreach($notification_methods as $method)

+ {

+ $template->assign_block_vars($block, array(

+ 'METHOD' => $method,

+

+ 'NAME' => $user->lang('NOTIFICATION_METHOD_' . strtoupper($method)),

+ ));

+ }

+ }

+}

+// Mark notifications read

+$mark_notifications = request_var('mark_notification', array(0));

+if (!empty($mark_notifications))

+{

+ $phpbb_notifications = $phpbb_container->get('notifications');

+ $phpbb_notifications->mark_notifications_read_by_id($mark_notifications);

+}

+

+if (!defined('NOTIFICATIONS_TABLE'))

+{

+ define('NOTIFICATIONS_TABLE', $table_prefix . 'notifications');

+}

+if (!defined('USER_NOTIFICATIONS_TABLE'))

+{

+ define('USER_NOTIFICATIONS_TABLE', $table_prefix . 'user_notifications');

+}

+ NOTIFICATIONS_TABLE => array(

+ 'COLUMNS' => array(

+ 'notification_id' => array('UINT', NULL, 'auto_increment'),

+ 'item_type' => array('VCHAR:25', ''),

+ 'item_id' => array('UINT', 0),

+ 'item_parent_id' => array('UINT', 0),

+ 'user_id' => array('UINT', 0),

+ 'unread' => array('BOOL', 1),

+ 'time' => array('TIMESTAMP', 1),

+ 'data' => array('TEXT_UNI', ''),

+ ),

+ 'PRIMARY_KEY' => 'notification_id',

+ 'KEYS' => array(

+ 'item_type' => array('INDEX', 'item_type'),

+ 'item_id' => array('INDEX', 'item_id'),

+ 'item_pid' => array('INDEX', 'item_parent_id'),

+ 'user_id' => array('INDEX', 'user_id'),

+ 'time' => array('INDEX', 'time'),

+ 'unread' => array('INDEX', 'unread'),

+ ),

+ ),

+ USER_NOTIFICATIONS_TABLE => array(

+ 'COLUMNS' => array(

+ 'item_type' => array('VCHAR:25', ''),

+ 'item_id' => array('UINT', 0),

+ 'user_id' => array('UINT', 0),

+ 'method' => array('VCHAR:25', ''),

+ ),

+ 'PRIMARY_KEY' => array(

+ 'item_type',

+ 'item_id',

+ 'user_id',

+ 'method',

+ ),

+ 'KEYS' => array(

+ 'it' => array('INDEX', 'item_type'),

+ 'uid' => array('INDEX', 'user_id'),

+ ),

+ ),

+ 'notifications' => array(

+ 'base' => 'ucp_notifications',

+ 'class' => 'ucp',

+ 'title' => 'UCP_NOTIFICATION_OPTIONS',

+ 'auth' => '',

+ 'cat' => 'UCP_MAIN',

+ ),

+ {

+

+

+ 'MARK_READ' => 'Mark read',

+ 'NOTIFICATIONS_CNT' => array(

+ 1 => '%d Notification',

+ 2 => '%d Notifications',

+ ),

+ 'NOTIFICATION_BOOKMARK' => '%1$s replied to the topic "%2$s" you have bookmarked.',

+ 'NOTIFICATION_PM' => '%1$s sent you a Private Message "%2$s".',

+ 'NOTIFICATION_POST' => '%1$s replied to the topic "%2$s".',

+ 'NOTIFICATION_POST_APPROVED' => 'Your post was approved "%2$s".',

+ 'NOTIFICATION_POST_DISAPPROVED' => 'Your post "%1$s" was disapproved because "%2$s".',

+ 'NOTIFICATION_POST_IN_QUEUE' => 'A new post titled "%2$s" was posted by "%1$s" and needs approval.',

+ 'NOTIFICATION_QUOTE' => '%1$s quoted you in the post "%2$s".',

+ 'NOTIFICATION_TOPIC' => '%1$s posted a new topic "%2$s" in the forum "%3$s".',

+ 'NOTIFICATION_TOPIC_APPROVED' => 'Your topic "%2$s" in the forum "%3$s" was approved.',

+ 'NOTIFICATION_TOPIC_DISAPPROVED' => 'Your topic "%1$s" was disapproved because "%2$s".',

+ 'NOTIFICATION_TOPIC_IN_QUEUE' => 'A new topic titled "%2$s" was posted by "%1$s" and needs approval.',

+Subject: Topic reply notification - "{TOPIC_TITLE}"

+

+Hello {USERNAME},

+

+You are receiving this notification because the topic you bookmarked, "{TOPIC_TITLE}" at "{SITENAME}" has received a reply since your last visit. You can use the following link to view the replies made, no more notifications will be sent until you visit the topic.

+

+If you want to view the newest post made since your last visit, click the following link:

+{U_NEWEST_POST}

+

+If you want to view the topic, click the following link:

+{U_TOPIC}

+

+If you want to view the forum, click the following link:

+{U_FORUM}

+

+If you no longer wish to receive updates about replies to bookmarks, please update your notification settings here:

+

+{U_NOTIFICATION_SETTINGS}

+

+{EMAIL_SIG} \ No newline at end of file

+Subject: Topic reply notification - "{TOPIC_TITLE}"

+

+Hello {USERNAME},

+

+You are receiving this notification because the post, "{POST_SUBJECT}" at "{SITENAME}" needs approval.

+

+If you want to view the post, click the following link:

+{U_VIEW_POST}

+

+If you want to view the topic, click the following link:

+{U_TOPIC}

+

+If you no longer wish to receive updates about replies to bookmarks, please update your notification settings here:

+

+{U_NOTIFICATION_SETTINGS}

+

+{EMAIL_SIG} \ No newline at end of file

+Subject: Topic reply notification - "{TOPIC_TITLE}"

+

+Hello {USERNAME},

+

+You are receiving this notification because "{AUTHOR_NAME}" quoted you in the topic, "{TOPIC_TITLE}" at "{SITENAME}". You can use the following link to view the reply made.

+

+If you want to view the quoted post, click the following link:

+{U_VIEW_POST}

+

+If you want to view the topic, click the following link:

+{U_TOPIC}

+

+If you want to view the forum, click the following link:

+{U_FORUM}

+

+If you no longer wish to receive updates about replies quoting you, please update your notification settings here:

+

+{U_NOTIFICATION_SETTINGS}

+

+{EMAIL_SIG} \ No newline at end of file

+Subject: Topic reply notification - "{TOPIC_TITLE}"

+

+Hello {USERNAME},

+

+You are receiving this notification because the topic, "{TOPIC_TITLE}" at "{SITENAME}" needs approval.

+

+If you want to view the topic, click the following link:

+{U_VIEW_TOPIC}

+

+If you want to view the forum, click the following link:

+{U_FORUM}

+

+If you no longer wish to receive updates about replies to bookmarks, please update your notification settings here:

+

+{U_NOTIFICATION_SETTINGS}

+

+{EMAIL_SIG} \ No newline at end of file

+

+ 'NOTIFICATIONS' => 'Notifications',

+ 'NOTIFICATION_METHOD_EMAIL' => 'Email',

+ 'NOTIFICATION_METHOD_JABBER' => 'Jabber',

+ 'NOTIFICATION_TYPE' => 'Notification type',

+ 'NOTIFICATION_TYPE_BOOKMARK' => 'Someone replies to a topic you have bookmarked',

+ 'NOTIFICATION_TYPE_IN_MODERATION_QUEUE' => 'A post or topic needs approval',

+ 'NOTIFICATION_TYPE_MODERATION_QUEUE' => 'Your topics/posts are approved or disapproved by a moderator',

+ 'NOTIFICATION_TYPE_PM' => 'Someone sends you a private message',

+ 'NOTIFICATION_TYPE_POST' => 'Someone replies to a topic you are subscribed to',

+ 'NOTIFICATION_TYPE_QUOTE' => 'Someone quotes you in a post',

+ 'NOTIFICATION_TYPE_TOPIC' => 'Someone creates a topic in a forum you are subscribed to',

+

+ 'UCP_NOTIFICATION_OPTIONS' => 'Notification options',

+ 'UCP_NOTIFICATION_OPTIONS_EXPLAIN' => 'Here you can set your preferred notification methods for the board.',

+

+/**

+ * Toggle notification list

+ */

+$('#notification_list_button').click(function() {

+ $('#notification_list').toggle();

+});

+

+<title><!-- IF NUM_UNREAD_NOTIFICATIONS -->({NUM_UNREAD_NOTIFICATIONS}) <!-- ENDIF --><!-- IF not S_VIEWTOPIC and not S_VIEWFORUM -->{SITENAME} - <!-- ENDIF --><!-- IF S_IN_MCP -->{L_MCP} - <!-- ELSEIF S_IN_UCP -->{L_UCP} - <!-- ENDIF -->{PAGE_TITLE}<!-- IF S_VIEWTOPIC or S_VIEWFORUM --> - {SITENAME}<!-- ENDIF --></title>

+ <li>

+ [ <a href="#" id="notification_list_button" title="{NOTIFICATIONS_CNT}">{NOTIFICATIONS_CNT}</a> ] &bull;

+ <div id="notification_list">

+ <ul class="topiclist forums">

+ <!-- BEGIN notifications -->

+ <li class="row<!-- IF notifications.UNREAD --> bg2<!-- ENDIF -->">

+ <!-- IF notifications.URL --><a href="{notifications.URL}"><!-- ENDIF -->

+ {notifications.AVATAR}

+ <div>

+ {notifications.FORMATTED_TITLE}<br />

+ {notifications.TIME}

+ </div>

+ <!-- IF notifications.URL --></a><!-- ENDIF -->

+ <!-- IF notifications.UNREAD --><a href="{notifications.U_MARK_READ}" title="{L_MARK_READ}">{L_MARK_READ}</a><!-- ENDIF -->

+ </li>

+ <!-- END notifications -->

+ </ul>

+ </div>

+ </li>

+<!-- INCLUDE ucp_header.html -->

+

+<form id="ucp" method="post" action="{S_UCP_ACTION}"{S_FORM_ENCTYPE}>

+

+<h2>{L_UCP_NOTIFICATION_OPTIONS}</h2>

+<div class="panel">

+ <div class="inner">

+

+ <p>{L_UCP_NOTIFICATION_OPTIONS_EXPLAIN}</p>

+

+ <ul class="topiclist">

+ <li class="header">

+ <dl>

+ <dt>{L_NOTIFICATION_TYPE}</dt>

+ <!-- BEGIN notification_methods -->

+ <dd class="mark">{notification_methods.NAME}</dd>

+ <!-- END notification_methods -->

+ <dd class="mark">{L_NOTIFICATIONS}</dd>

+ </dl>

+ </li>

+ </ul>

+ <ul class="topiclist cplist">

+

+ <!-- BEGIN notification_types -->

+ <li class="row<!-- IF notification_types.S_ROW_COUNT is odd --> bg1<!-- ELSE --> bg2<!-- ENDIF -->">

+ <dl>

+ <dt>

+ {notification_types.NAME}

+ </dt>

+ <!-- BEGIN notification_methods -->

+ <dd class="mark"><input type="checkbox" name="{notification_types.TYPE}_{notification_methods.METHOD}"<!-- IF notification_methods.SUBSCRIBED --> checked="checked"<!-- ENDIF --> /> <dfn>{notification_methods.NAME}</dfn></dd>

+ <!-- END notification_methods -->

+ <dd class="mark"><input type="checkbox" name="{notification_types.TYPE}_notification"<!-- IF notification_types.SUBSCRIBED --> checked="checked"<!-- ENDIF --> /> <dfn>{notification_methods.NAME}</dfn></dd>

+ </dl>

+ </li>

+ <!-- END notification_types -->

+

+ </ul>

+ </div>

+</div>

+

+

+<fieldset class="submit-buttons">

+ {S_HIDDEN_FIELDS}<input type="reset" value="{L_RESET}" name="reset" class="button2" />&nbsp;

+ <input type="submit" name="submit" value="{L_SUBMIT}" class="button1" />

+ {S_FORM_TOKEN}

+</fieldset>

+

+</form>

+

+<!-- INCLUDE ucp_footer.html -->

+

+#notification_list {

+ display: none;

+ position: absolute;

+ width: 330px;

+ max-height: 350px;

+ z-index: 1;

+ overflow-y: auto;

+ overflow-x: hidden;

+ background-color: #FFFFFF;

+}

+

+#notification_list ul li {

+ padding: 10px;

+ width: 310px;

+}

+

+#notification_list ul li a {

+ text-decoration: none;

+}

+

+#notification_list ul li img {

+ float: left;

+ padding: 0 10px 10px 0;

+ max-width: 50px;

+ max-height: 50px;

+}