Code Coverage
 
Classes and Traits
Functions and Methods
Lines
Total
0.00% covered (danger)
0.00%
0 / 1
42.11% covered (danger)
42.11%
8 / 19
CRAP
78.10% covered (warning)
78.10%
107 / 137
post
0.00% covered (danger)
0.00%
0 / 1
42.11% covered (danger)
42.11%
8 / 19
68.22
78.10% covered (warning)
78.10%
107 / 137
 get_type
100.00% covered (success)
100.00%
1 / 1
1
100.00% covered (success)
100.00%
1 / 1
 set_config
100.00% covered (success)
100.00%
1 / 1
1
100.00% covered (success)
100.00%
2 / 2
 set_user_loader
100.00% covered (success)
100.00%
1 / 1
1
100.00% covered (success)
100.00%
2 / 2
 is_available
100.00% covered (success)
100.00%
1 / 1
1
100.00% covered (success)
100.00%
1 / 1
 get_item_id
100.00% covered (success)
100.00%
1 / 1
1
100.00% covered (success)
100.00%
1 / 1
 get_item_parent_id
100.00% covered (success)
100.00%
1 / 1
1
100.00% covered (success)
100.00%
1 / 1
 find_users_for_notification
100.00% covered (success)
100.00%
1 / 1
5
100.00% covered (success)
100.00%
28 / 28
 get_avatar
0.00% covered (danger)
0.00%
0 / 1
2.00
0.00% covered (danger)
0.00%
0 / 1
 get_title
0.00% covered (danger)
0.00%
0 / 1
6
95.65% covered (success)
95.65%
22 / 23
 get_reference
0.00% covered (danger)
0.00%
0 / 1
2.00
0.00% covered (danger)
0.00%
0 / 3
 get_email_template
0.00% covered (danger)
0.00%
0 / 1
2.00
0.00% covered (danger)
0.00%
0 / 1
 get_email_template_variables
0.00% covered (danger)
0.00%
0 / 1
6.00
0.00% covered (danger)
0.00%
0 / 12
 get_url
0.00% covered (danger)
0.00%
0 / 1
2.00
0.00% covered (danger)
0.00%
0 / 1
 get_redirect_url
0.00% covered (danger)
0.00%
0 / 1
2.00
0.00% covered (danger)
0.00%
0 / 1
 users_to_query
0.00% covered (danger)
0.00%
0 / 1
3.33
66.67% covered (warning)
66.67%
4 / 6
 trim_user_ary
100.00% covered (success)
100.00%
1 / 1
2
100.00% covered (success)
100.00%
3 / 3
 pre_create_insert_array
0.00% covered (danger)
0.00%
0 / 1
4.10
81.82% covered (warning)
81.82%
9 / 11
 create_insert_array
0.00% covered (danger)
0.00%
0 / 1
5.02
90.91% covered (success)
90.91%
10 / 11
 add_responders
0.00% covered (danger)
0.00%
0 / 1
8.36
82.14% covered (warning)
82.14%
23 / 28
<?php
/**
*
* This file is part of the phpBB Forum Software package.
*
* @copyright (c) phpBB Limited <https://www.phpbb.com>
* @license GNU General Public License, version 2 (GPL-2.0)
*
* For full copyright and license information, please see
* the docs/CREDITS.txt file.
*
*/
namespace phpbb\notification\type;
/**
* Post notifications class
* This class handles notifications for replies to a topic
*/
class post extends \phpbb\notification\type\base
{
    /**
    * Get notification type name
    *
    * @return string
    */
    public function get_type()
    {
        return 'notification.type.post';
    }
    /**
    * Language key used to output the text
    *
    * @var string
    */
    protected $language_key = 'NOTIFICATION_POST';
    /**
    * Inherit notification read status from post.
    *
    * @var bool
    */
    protected $inherit_read_status = true;
    /**
    * 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', 'lang', and 'group')
    */
    static public $notification_option = array(
        'lang'    => 'NOTIFICATION_TYPE_POST',
        'group'    => 'NOTIFICATION_GROUP_POSTING',
    );
    /** @var \phpbb\user_loader */
    protected $user_loader;
    /** @var \phpbb\config\config */
    protected $config;
    public function set_config(\phpbb\config\config $config)
    {
        $this->config = $config;
    }
    public function set_user_loader(\phpbb\user_loader $user_loader)
    {
        $this->user_loader = $user_loader;
    }
    /**
    * Is available
    */
    public function is_available()
    {
        return $this->config['allow_topic_notify'];
    }
    /**
    * Get the id of the item
    *
    * @param array $post The data from the post
    * @return int The post id
    */
    static public function get_item_id($post)
    {
        return (int) $post['post_id'];
    }
    /**
    * Get the id of the parent
    *
    * @param array $post The data from the post
    * @return int The topic id
    */
    static public function get_item_parent_id($post)
    {
        return (int) $post['topic_id'];
    }
    /**
    * Find the users who want to receive notifications
    *
    * @param array $post Data from submit_post
    * @param array $options Options for finding users for notification
    *
    * @return array
    */
    public function find_users_for_notification($post, $options = array())
    {
        $options = array_merge(array(
            'ignore_users'        => array(),
        ), $options);
        $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 = $this->db->sql_query($sql);
        while ($row = $this->db->sql_fetchrow($result))
        {
            $users[] = (int) $row['user_id'];
        }
        $this->db->sql_freeresult($result);
        $notify_users = $this->get_authorised_recipients($users, $post['forum_id'], $options, true);
        if (empty($notify_users))
        {
            return array();
        }
        // Try to find the users who already have been notified about replies and have not read the topic since and just update their notifications
        $notified_users = $this->notification_manager->get_notified_users($this->get_type(), array(
            'item_parent_id'    => static::get_item_parent_id($post),
            'read'                => 0,
        ));
        foreach ($notified_users as $user => $notification_data)
        {
            unset($notify_users[$user]);
            /** @var post $notification */
            $notification = $this->notification_manager->get_item_type_class($this->get_type(), $notification_data);
            $update_responders = $notification->add_responders($post);
            if (!empty($update_responders))
            {
                $this->notification_manager->update_notification($notification, $update_responders, array(
                    'item_parent_id'    => self::get_item_parent_id($post),
                    'read'                => 0,
                    'user_id'            => $user,
                ));
            }
        }
        return $notify_users;
    }
    /**
    * Get the user's avatar
    */
    public function get_avatar()
    {
        return $this->user_loader->get_avatar($this->get_data('poster_id'), false, true);
    }
    /**
    * Get the HTML formatted title of this notification
    *
    * @return string
    */
    public function get_title()
    {
        $responders = $this->get_data('responders');
        $usernames = array();
        if (!is_array($responders))
        {
            $responders = array();
        }
        $responders = array_merge(array(array(
            'poster_id'        => $this->get_data('poster_id'),
            'username'        => $this->get_data('post_username'),
        )), $responders);
        $responders_cnt = count($responders);
        $responders = $this->trim_user_ary($responders);
        $trimmed_responders_cnt = $responders_cnt - count($responders);
        foreach ($responders as $responder)
        {
            if ($responder['username'])
            {
                $usernames[] = $responder['username'];
            }
            else
            {
                $usernames[] = $this->user_loader->get_username($responder['poster_id'], 'no_profile');
            }
        }
        if ($trimmed_responders_cnt > 20)
        {
            $usernames[] = $this->language->lang('NOTIFICATION_MANY_OTHERS');
        }
        else if ($trimmed_responders_cnt)
        {
            $usernames[] = $this->language->lang('NOTIFICATION_X_OTHERS', $trimmed_responders_cnt);
        }
        return $this->language->lang(
            $this->language_key,
            phpbb_generate_string_list($usernames, $this->user),
            $responders_cnt
        );
    }
    /**
    * Get the HTML formatted reference of the notification
    *
    * @return string
    */
    public function get_reference()
    {
        return $this->language->lang(
            'NOTIFICATION_REFERENCE',
            censor_text($this->get_data('topic_title'))
        );
    }
    /**
    * Get email template
    *
    * @return string|bool
    */
    public function get_email_template()
    {
        return 'topic_notify';
    }
    /**
    * Get email template variables
    *
    * @return array
    */
    public function get_email_template_variables()
    {
        if ($this->get_data('post_username'))
        {
            $username = $this->get_data('post_username');
        }
        else
        {
            $username = $this->user_loader->get_username($this->get_data('poster_id'), 'username');
        }
        return array(
            'AUTHOR_NAME'                => html_entity_decode($username, ENT_COMPAT),
            'POST_SUBJECT'                => html_entity_decode(censor_text($this->get_data('post_subject')), ENT_COMPAT),
            'TOPIC_TITLE'                => html_entity_decode(censor_text($this->get_data('topic_title')), ENT_COMPAT),
            '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}?t={$this->item_parent_id}&e=1&view=unread#unread",
            'U_TOPIC'                    => generate_board_url() . "/viewtopic.{$this->php_ext}?t={$this->item_parent_id}",
            'U_VIEW_TOPIC'                => generate_board_url() . "/viewtopic.{$this->php_ext}?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}&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}");
    }
    /**
    * {inheritDoc}
    */
    public function get_redirect_url()
    {
        return append_sid($this->phpbb_root_path . 'viewtopic.' . $this->php_ext, "t={$this->item_parent_id}&amp;view=unread#unread");
    }
    /**
    * Users needed to query before this notification can be displayed
    *
    * @return array Array of user_ids
    */
    public function users_to_query()
    {
        $responders = $this->get_data('responders');
        $users = array(
            $this->get_data('poster_id'),
        );
        if (is_array($responders))
        {
            foreach ($responders as $responder)
            {
                $users[] = $responder['poster_id'];
            }
        }
        return $this->trim_user_ary($users);
    }
    /**
    * Trim the user array passed down to 3 users if the array contains
    * more than 4 users.
    *
    * @param array $users Array of users
    * @return array Trimmed array of user_ids
    */
    public function trim_user_ary($users)
    {
        if (count($users) > 4)
        {
            array_splice($users, 3);
        }
        return $users;
    }
    /**
    * Pre create insert array function
    * This allows you to perform certain actions, like run a query
    * and load data, before create_insert_array() is run. The data
    * returned from this function will be sent to create_insert_array().
    *
    * @param array $post Post data from submit_post
    * @param array $notify_users Notify users list
    *         Formatted from find_users_for_notification()
    * @return array Whatever you want to send to create_insert_array().
    */
    public function pre_create_insert_array($post, $notify_users)
    {
        if (!count($notify_users) || !$this->inherit_read_status)
        {
            return array();
        }
        $tracking_data = array();
        $sql = 'SELECT user_id, mark_time FROM ' . TOPICS_TRACK_TABLE . '
            WHERE topic_id = ' . (int) $post['topic_id'] . '
                AND ' . $this->db->sql_in_set('user_id', array_keys($notify_users));
        $result = $this->db->sql_query($sql);
        while ($row = $this->db->sql_fetchrow($result))
        {
            $tracking_data[$row['user_id']] = $row['mark_time'];
        }
        $this->db->sql_freeresult($result);
        return $tracking_data;
    }
    /**
    * {@inheritdoc}
    */
    public function create_insert_array($post, $pre_create_data = array())
    {
        $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->notification_time = $post['post_time'];
        // Topics can be "read" before they are public (while awaiting approval).
        // Make sure that if the user has read the topic, it's marked as read in the notification
        if ($this->inherit_read_status && isset($pre_create_data[$this->user_id]) && $pre_create_data[$this->user_id] >= $this->notification_time)
        {
            $this->notification_read = true;
        }
        parent::create_insert_array($post, $pre_create_data);
    }
    /**
    * Add responders to the notification
    *
    * @param mixed $post
    * @return array Array of responder data
    */
    public function add_responders($post)
    {
        // Do not add them as a responder if they were the original poster that created the notification
        if ($this->get_data('poster_id') == $post['poster_id'])
        {
            return array();
        }
        $responders = $this->get_data('responders');
        $responders = ($responders === null) ? array() : $responders;
        // Do not add more than 25 responders,
        // we trim the username list to "a, b, c and x others" anyway
        // so there is no use to add all of them anyway.
        if (count($responders) > 25)
        {
            return array();
        }
        foreach ($responders as $responder)
        {
            // Do not add them as a responder multiple times
            if ($responder['poster_id'] == $post['poster_id'])
            {
                return array();
            }
        }
        $responders[] = array(
            'poster_id'        => $post['poster_id'],
            'username'        => (($post['poster_id'] == ANONYMOUS) ? $post['post_username'] : ''),
        );
        $this->set_data('responders', $responders);
        $serialized_data = serialize($this->get_data(false));
        // If the data is longer then 4000 characters, it would cause a SQL error.
        // We don't add the username to the list if this is the case.
        if (utf8_strlen($serialized_data) >= 4000)
        {
            return array();
        }
        $data_array = array_merge(array(
            'poster_id'        => $post['poster_id'],
            'topic_title'    => $post['topic_title'],
            'post_subject'    => $post['post_subject'],
            'post_username'    => $post['post_username'],
            'forum_id'        => $post['forum_id'],
            'forum_name'    => $post['forum_name'],
            'post_time'        => $post['post_time'],
            'post_id'        => $post['post_id'],
            'topic_id'        => $post['topic_id']
        ), $this->get_data(false));
        return $data_array;
    }
}