elkarte / Elkarte

sources/subs/Messages.subs.php

<?php

/**
 * This file contains functions for dealing with messages.
 * Low-level functions, i.e. database operations needed to perform.
 * These functions (probably) do NOT make permissions checks. (they assume
 * those were already made).
 *
 * @package   ElkArte Forum
 * @copyright ElkArte Forum contributors
 * @license   BSD http://opensource.org/licenses/BSD-3-Clause (see accompanying LICENSE.txt file)
 *
 * This file contains code covered by:
 * copyright: 2011 Simple Machines (http://www.simplemachines.org)
 *
 * @version 2.0 dev
 *
 */

use ElkArte\MessagesDelete;
use ElkArte\User;

/**
 * Get message and attachments data, for a message ID. The function returns the data in an array.
 *
 * What it does:
 * - 'message' => array with all message data, body, subject, etc
 * - 'attachment_stuff' => array with attachments ordered by attachment id as keys
 *
 * @param int $id_msg
 * @param int $id_topic = 0
 * @param int $attachment_type = 0
 *
 * @return array|bool
 */
function messageDetails($id_msg, $id_topic = 0, $attachment_type = 0)
{
	global $modSettings;

	$db = database();

	if (empty($id_msg))
	{
		return false;
	}

	$message_data = $db->fetchQuery('
		SELECT
			m.id_member, m.modified_time, m.modified_name, m.smileys_enabled, m.body,
			m.poster_name, m.poster_email, m.subject, m.icon, m.approved,
			COALESCE(a.size, -1) AS filesize, a.filename, a.id_attach,
			a.approved AS attachment_approved, t.id_member_started AS id_member_poster,
			m.poster_time, log.id_action
		FROM {db_prefix}messages AS m
			INNER JOIN {db_prefix}topics AS t ON (t.id_topic = {int:current_topic})
			LEFT JOIN {db_prefix}attachments AS a ON (a.id_msg = m.id_msg AND a.attachment_type = {int:attachment_type})
			LEFT JOIN {db_prefix}log_actions AS log ON (m.id_topic = log.id_topic AND log.action = {string:announce_action})
		WHERE m.id_msg = {int:id_msg}
			AND m.id_topic = {int:current_topic}',
		array(
			'current_topic' => $id_topic,
			'attachment_type' => $attachment_type,
			'id_msg' => $id_msg,
			'announce_action' => 'announce_topic',
		)
	)->fetch_all();

	// The message they were trying to edit was most likely deleted.
	if (empty($message_data))
	{
		return false;
	}

	$temp = [];

	// Attachments enabled, then return the details for each
	if (!empty($modSettings['attachmentEnable']))
	{
		foreach ($message_data as $attachment)
		{
			if ($attachment['filesize'] >= 0)
			{
				$temp[$attachment['id_attach']] = $attachment;
			}
		}

		ksort($temp);
	}

	return array('message' => $message_data[0], 'attachment_stuff' => $temp);
}

/**
 * Get some basic info of a certain message
 * Will use query_see_board unless $override_permissions is set to true
 * Will return additional topic information if $detailed is set to true
 * Returns an associative array of the results or false on error
 *
 * @param int $id_msg
 * @param bool $override_permissions
 * @param bool $detailed
 * @param bool $approved only return approved messages
 *
 * @return mixed[]|false array of message details or false if no message found.
 */
function basicMessageInfo($id_msg, $override_permissions = false, $detailed = false, $approved = true)
{
	global $modSettings;

	$db = database();

	if (empty($id_msg))
	{
		return false;
	}

	$request = $db->fetchQuery('
		SELECT
			m.id_member, m.id_topic, m.id_board, m.id_msg, m.body, m.subject,
			m.poster_name, m.poster_email, m.poster_time, m.approved' . ($detailed === false ? '' : ',
			t.id_first_msg, t.num_replies, t.unapproved_posts, t.id_last_msg, t.id_member_started, t.locked, t.approved AS topic_approved') . '
		FROM {db_prefix}messages AS m' . ($override_permissions === true ? '' : '
			INNER JOIN {db_prefix}boards AS b ON (b.id_board = m.id_board AND {query_see_board})') . ($detailed === false ? '' : '
			LEFT JOIN {db_prefix}topics AS t ON (t.id_topic = m.id_topic)') . '
		WHERE id_msg = {int:message}' . (empty($modSettings['postmod_active']) || allowedTo('approve_posts') || $approved === false ? '' : '
			AND m.approved = 1') . '
		LIMIT 1',
		array(
			'message' => $id_msg,
		)
	);
	$messageInfo = $request->fetch_assoc();

	return empty($messageInfo) ? false : $messageInfo;
}

/**
 * Get some basic info of a certain message, good to create a quote.
 * Very similar to many other queries, though slightly different.
 * Uses {query_see_board} and the 'moderate_board' permission
 *
 * @param int $id_msg
 * @param bool $modify
 *
 * @return array
 * @todo why it doesn't take into account post moderation?
 */
function quoteMessageInfo($id_msg, $modify)
{
	if (empty($id_msg))
	{
		return [];
	}

	$db = database();

	require_once(SUBSDIR . '/Post.subs.php');

	$moderate_boards = boardsAllowedTo('moderate_board');

	$request = $db->fetchQuery('
		SELECT 
			COALESCE(mem.real_name, m.poster_name) AS poster_name, m.poster_time, m.body, m.id_topic, m.subject,
			m.id_board, m.id_member, m.approved
		FROM {db_prefix}messages AS m
			INNER JOIN {db_prefix}topics AS t ON (t.id_topic = m.id_topic)
			INNER JOIN {db_prefix}boards AS b ON (b.id_board = m.id_board AND {query_see_board})
			LEFT JOIN {db_prefix}members AS mem ON (mem.id_member = m.id_member)
		WHERE m.id_msg = {int:id_msg}' . ($modify || (!empty($moderate_boards) && $moderate_boards[0] == 0) ? '' : '
			AND (t.locked = {int:not_locked}' . (empty($moderate_boards) ? '' : ' OR b.id_board IN ({array_int:moderation_board_list})') . ')') . '
		LIMIT 1',
		array(
			'current_member' => User::$info->id,

The property id does not exist on ElkArte\Helper\ValuesContainer. Since you implemented __get, consider adding a @property annotation.

			'moderation_board_list' => $moderate_boards,
			'id_msg' => $id_msg,
			'not_locked' => 0,
		)
	);

	return $request->fetch_assoc();
}

/**
 * Checks permissions to modify a message.
 * This function will give a fatal error if the current user
 * doesn't have permissions to modify the message.
 *
 * @param int $message
 *
 * @return array|bool
 * @throws \ElkArte\Exceptions\Exception modify_post_time_passed
 */
function checkMessagePermissions($message)
{
	global $modSettings, $context;

	if ($message['id_member'] == User::$info->id && !allowedTo('modify_any'))

The property id does not exist on ElkArte\Helper\ValuesContainer. Since you implemented __get, consider adding a @property annotation.

	{
		// Give an extra five minutes over the disable time threshold, so they can type - assuming the post is public.
		if ($message['approved'] && !empty($modSettings['edit_disable_time']) && $message['poster_time'] + ($modSettings['edit_disable_time'] + 5) * 60 < time())
		{
			throw new \ElkArte\Exceptions\Exception('modify_post_time_passed', false);
		}
		elseif ($message['id_member_poster'] == User::$info->id && !allowedTo('modify_own'))
		{
			isAllowedTo('modify_replies');
		}
		else
		{
			isAllowedTo('modify_own');
		}
	}
	elseif ($message['id_member_poster'] == User::$info->id && !allowedTo('modify_any'))
	{
		isAllowedTo('modify_replies');
	}
	else
	{
		isAllowedTo('modify_any');
	}

	if ($context['can_announce'] && !empty($message['id_action']))
	{
		return array('topic_already_announced');
	}

	return false;
}

/**
 * Prepare context for a message.
 *
 * What it does:
 * - Loads data from messageDetails into $context array
 *
 * @param mixed[] $message the message array
 */
function prepareMessageContext($message)
{
	global $context, $txt;

	// Load up 'em attachments!
	foreach ($message['attachment_stuff'] as $attachment)
	{
		$context['attachments']['current'][] = array(
			'name' => htmlspecialchars($attachment['filename'], ENT_COMPAT, 'UTF-8'),
			'size' => $attachment['filesize'],
			'id' => $attachment['id_attach'],
			'approved' => $attachment['attachment_approved'],
		);
	}

	// Allow moderators to change names....
	if (allowedTo('moderate_forum') && empty($message['message']['id_member']))
	{
		$context['name'] = htmlspecialchars($message['message']['poster_name'], ENT_COMPAT, 'UTF-8');
		$context['email'] = htmlspecialchars($message['message']['poster_email'], ENT_COMPAT, 'UTF-8');
	}

	// When was it last modified?
	if (!empty($message['message']['modified_time']))
	{
		$context['last_modified'] = standardTime($message['message']['modified_time']);
		$context['last_modified_text'] = sprintf($txt['last_edit_by'], $context['last_modified'], $message['message']['modified_name']);
	}

	// Show an "approve" box if the user can approve it, and the message isn't approved.
	if (!$message['message']['approved'] && !$context['show_approval'])
	{
		$context['show_approval'] = allowedTo('approve_posts');
	}
}

/**
 * This function removes all the messages of a certain user that are *not*
 * first messages of a topic
 *
 * @param int $memID The member id
 */
function removeNonTopicMessages($memID)
{
	$db = database();

	$db->fetchQuery('
		SELECT 
			m.id_msg
		FROM {db_prefix}messages AS m
			INNER JOIN {db_prefix}topics AS t ON (t.id_topic = m.id_topic
				AND t.id_first_msg != m.id_msg)
		WHERE m.id_member = {int:selected_member}',
		array(
			'selected_member' => $memID,
		)
	)->fetch_callback(
		function ($row) {
			// This could take a while... but ya know it's gonna be worth it in the end.
			detectServer()->setTimeLimit(300);
			removeMessage($row['id_msg']);
		}
	);
}

/**
 * Remove a specific message.
 * !! This includes permission checks.
 *
 * - normally, local and global should be the localCookies and globalCookies settings, respectively.
 * - uses boardurl to determine these two things.
 *
 * @param int $message The message id
 * @param bool $decreasePostCount if true users' post count will be reduced
 */
function removeMessage($message, $decreasePostCount = true)
{
	global $modSettings;

	$remover = new MessagesDelete($modSettings['recycle_enable'], $modSettings['recycle_board']);
	$remover->removeMessage($message, $decreasePostCount, true);
}

/**
 * This function deals with the topic associated to a message.
 * It allows retrieving or updating the topic to which the message belongs.
 *
 * If $topicID is not passed, the current topic ID of the message is returned.
 * If $topicID is passed, the message is updated to point to the new topic.
 *
 * @param int $msg_id message ID
 * @param int|null $topicID = null topic ID, if null is passed the ID of the topic is retrieved and returned
 * @return int|false int topic ID if any, or false
 */
function associatedTopic($msg_id, $topicID = null)
{
	$db = database();

	if ($topicID === null)
	{
		$request = $db->query('', '
			SELECT 
				id_topic
			FROM {db_prefix}messages
			WHERE id_msg = {int:msg}',
			array(
				'msg' => $msg_id,
			)
		);
		if ($request->num_rows() !== 1)
		{
			$topic = false;
		}
		else
		{
			list ($topic) = $request->fetch_row();
		}
		$request->free_result();

		return $topic;
	}
	else
	{
		$db->query('', '
			UPDATE {db_prefix}messages
			SET 
				id_topic = {int:topic}
			WHERE id_msg = {int:msg}',
			array(
				'msg' => $msg_id,
				'topic' => $topicID,
			)
		);
	}
}

/**
 * Small function that simply verifies if the current
 * user can access a specific message
 *
 * @param int $id_msg a message id
 * @param bool $check_approval if true messages are checked for approval (default true)
 * @return bool
 */
function canAccessMessage($id_msg, $check_approval = true)
{
	$message_info = basicMessageInfo($id_msg);

	// Do we even have a message to speak of?
	if (empty($message_info))
	{
		return false;
	}

	// Check for approval status?
	if ($check_approval)
	{
		// The user can access this message if it's approved or they're owner
		return (!empty($message_info['approved']) || $message_info['id_member'] == User::$info->id);

The property id does not exist on ElkArte\Helper\ValuesContainer. Since you implemented __get, consider adding a @property annotation.

	}

	// Otherwise, nope.
	return false;
}

/**
 * Advance message pointer in a topic.
 * (in either direction)
 * This function is used by previousMessage() and nextMessage().
 * The boolean parameter $next determines the direction.
 *
 * @param int $id_msg origin message id
 * @param int $id_topic topic
 * @param bool $next = true if true, it increases the pointer, otherwise it decreases it
 *
 * @return int
 */
function messagePointer($id_msg, $id_topic, $next = true)
{
	$db = database();

	$result = $db->query('', '
		SELECT ' . ($next ? 'MIN(id_msg)' : 'MAX(id_msg)') . '
		FROM {db_prefix}messages
		WHERE id_topic = {int:current_topic}
			AND id_msg {raw:strictly} {int:topic_msg_id}',
		array(
			'current_topic' => $id_topic,
			'topic_msg_id' => $id_msg,
			'strictly' => $next ? '>' : '<'
		)
	);
	list ($msg) = $result->fetch_row();
	$result->free_result();

	return $msg;
}

/**
 * Get previous message from where we were in the topic.
 *
 * @param int $id_msg
 * @param int $id_topic
 *
 * @return int
 */
function previousMessage($id_msg, $id_topic)
{
	return messagePointer($id_msg, $id_topic, false);
}

/**
 * Get next message from where we were in the topic.
 *
 * @param int $id_msg
 * @param int $id_topic
 *
 * @return int
 */
function nextMessage($id_msg, $id_topic)
{
	return messagePointer($id_msg, $id_topic);
}

/**
 * Retrieve the message id/s at a certain position in a topic
 *
 * @param int $start the offset of the message/s
 * @param int $id_topic the id of the topic
 * @param mixed[] $params an (optional) array of params, includes:
 *      - 'not_in' => array - of messages to exclude
 *      - 'include' => array - of messages to explicitly include
 *      - 'only_approved' => true/false - include or exclude the unapproved messages
 *      - 'limit' => mixed - the number of values to return (if false, no limits applied)
 *
 * @return array
 * @todo very similar to selectMessages in Topics.subs.php
 */
function messageAt($start, $id_topic, $params = array())
{
	$db = database();

	$params = array_merge(
	// Defaults
		array(
			'not_in' => false,
			'include' => false,
			'only_approved' => false,
			'limit' => 1,
		),
		// Passed arguments
		$params,
		// Others
		array(
			'current_topic' => $id_topic,
			'start' => $start,
			'is_approved' => 1,
		)
	);

	$msg = array();
	$db->fetchQuery('
		SELECT 
			id_msg
		FROM {db_prefix}messages
		WHERE id_topic = {int:current_topic}' . (!$params['include'] ? '' : '
			AND id_msg IN ({array_int:include})') . (!$params['not_in'] ? '' : '
			AND id_msg NOT IN ({array_int:not_in})') . (!$params['only_approved'] ? '' : '
			AND approved = {int:is_approved}') . '
		ORDER BY id_msg DESC' . ($params['limit'] === false ? '' : '
		LIMIT {int:limit} OFFSET {int:start} '),
		$params
	)->fetch_callback(
		function ($row) use (&$msg) {
			$msg[] = $row['id_msg'];
		}
	);

	return $msg;
}

/**
 * Finds an open report for a certain message if it exists and increase the
 * number of reports for that message, otherwise it creates one
 *
 * @param mixed[] $message array of several message details (id_msg, id_topic, etc.)
 * @param string $poster_comment the comment made by the reporter
 *
 * @return bool
 */
function recordReport($message, $poster_comment)
{
	$db = database();

	$request = $db->query('', '
		SELECT 
			id_report, ignore_all
		FROM {db_prefix}log_reported
		WHERE id_msg = {int:id_msg}
			AND type = {string:type}
			AND (closed = {int:not_closed} OR ignore_all = {int:ignored})
		ORDER BY ignore_all DESC',
		array(
			'id_msg' => $message['id_msg'],
			'type' => $message['type'] ?? 'msg',
			'not_closed' => 0,
			'ignored' => 1,
		)
	);
	if ($request->num_rows() !== 0)
	{
		list ($id_report, $ignore_all) = $request->fetch_row();
	}
	$request->free_result();

	if (!empty($ignore_all))
	{
		return false;
	}

	// Already reported? My god, we could be dealing with a real rogue here...
	if (!empty($id_report))
	{
		$db->query('', '
			UPDATE {db_prefix}log_reported
			SET 
				num_reports = num_reports + 1, time_updated = {int:current_time}
			WHERE id_report = {int:id_report}',
			array(
				'current_time' => time(),
				'id_report' => $id_report,
			)
		);
	}
	// Otherwise, we shall make one!
	else
	{
		if (empty($message['real_name']))
		{
			$message['real_name'] = $message['poster_name'];
		}

		$db->insert('',
			'{db_prefix}log_reported',
			array(
				'id_msg' => 'int', 'id_topic' => 'int', 'id_board' => 'int', 'id_member' => 'int', 'membername' => 'string',
				'subject' => 'string', 'body' => 'string', 'time_started' => 'int', 'time_updated' => 'int',
				'num_reports' => 'int', 'closed' => 'int',
				'type' => 'string-5', 'time_message' => 'int'
			),
			array(
				$message['id_msg'], $message['id_topic'], $message['id_board'], $message['id_poster'], $message['real_name'],
				$message['subject'], $message['body'], time(), time(), 1, 0,
				$message['type'], $message['time_message'] ?? 0
			),
			array('id_report')
		);
		$id_report = $db->insert_id('{db_prefix}log_reported');
	}

	// Now just add our report...
	if (!empty($id_report))
	{
		$db->insert('',
			'{db_prefix}log_reported_comments',
			array(
				'id_report' => 'int', 'id_member' => 'int', 'membername' => 'string', 'email_address' => 'string',
				'member_ip' => 'string', 'comment' => 'string', 'time_sent' => 'int',
			),
			array(
				$id_report, User::$info->id, User::$info->name, User::$info->email,

The property email does not exist on ElkArte\Helper\ValuesContainer. Since you implemented __get, consider adding a @property annotation.

The property name does not exist on ElkArte\Helper\ValuesContainer. Since you implemented __get, consider adding a @property annotation.

The property id does not exist on ElkArte\Helper\ValuesContainer. Since you implemented __get, consider adding a @property annotation.

				User::$info->ip, $poster_comment, time(),

The property ip does not exist on ElkArte\Helper\ValuesContainer. Since you implemented __get, consider adding a @property annotation.

			),
			array('id_comment')
		);
	}

	return $id_report;

The variable $id_report does not seem to be defined for all execution paths leading up to this point.

}

/**
 * Count the new posts for a specific topic
 *
 * @param int $topic
 * @param array $topicinfo
 * @param int $timestamp
 * @return int
 */
function countNewPosts($topic, $topicinfo, $timestamp)
{
	global $modSettings;

	$db = database();

	// Find the number of messages posted before said time...
	$request = $db->query('', '
		SELECT 
			COUNT(*)
		FROM {db_prefix}messages
		WHERE poster_time < {int:timestamp}
			AND id_topic = {int:current_topic}' . ($modSettings['postmod_active'] && $topicinfo['unapproved_posts'] && !allowedTo('approve_posts') ? '
			AND (approved = {int:is_approved}' . (User::$info->is_guest ? '' : ' OR id_member = {int:current_member}') . ')' : ''),

The property is_guest does not exist on ElkArte\Helper\ValuesContainer. Since you implemented __get, consider adding a @property annotation.

		array(
			'current_topic' => $topic,
			'current_member' => User::$info->id,

The property id does not exist on ElkArte\Helper\ValuesContainer. Since you implemented __get, consider adding a @property annotation.

			'is_approved' => 1,
			'timestamp' => $timestamp,
		)
	);
	list ($start) = $request->fetch_row();
	$request->free_result();

	return $start;
}

/**
 * Loads the details from a message
 *
 * @param string[] $msg_selects
 * @param string[] $msg_tables
 * @param mixed[] $msg_parameters
 * @param mixed[] $optional
 *
 * @return resource A request object
 */
function loadMessageRequest($msg_selects, $msg_tables, $msg_parameters, $optional = array())
{
	$db = database();

	return $db->query('', '

The expression return $db->query('', ' SELECT m.id_msg, m.icon, m.subject, m.poster_time, m.poster_ip, m.id_member, m.modified_time, m.modified_name, m.body, m.smileys_enabled, m.poster_name, m.poster_email, m.approved' . IssetNode ? ', m.id_msg_modified < {int:new_from} AS is_read' : '' . ' ' . ! empty($msg_selects) ? ',' . implode(',', $msg_selects) : '' . ' FROM {db_prefix}messages AS m ' . ! empty($msg_tables) ? implode(' ', $msg_tables) : '' . ' WHERE m.id_msg IN ({array_int:message_list}) ' . ! empty($optional['additional_conditions']) ? $optional['additional_conditions'] : '' . ' ORDER BY m.id_msg', $msg_parameters) returns the type ElkArte\Database\AbstractResult|boolean which is incompatible with the documented return type resource.

		SELECT
			m.id_msg, m.icon, m.subject, m.poster_time, m.poster_ip, m.id_member,
			m.modified_time, m.modified_name, m.body, m.smileys_enabled,
			m.poster_name, m.poster_email, m.approved' . (isset($msg_parameters['new_from']) ? ',
			m.id_msg_modified < {int:new_from} AS is_read' : '') . '
			' . (!empty($msg_selects) ? ',' . implode(',', $msg_selects) : '') . '
		FROM {db_prefix}messages AS m
			' . (!empty($msg_tables) ? implode("\n\t\t\t", $msg_tables) : '') . '
		WHERE m.id_msg IN ({array_int:message_list})
			' . (!empty($optional['additional_conditions']) ? $optional['additional_conditions'] : '') . '
		ORDER BY m.id_msg',
		$msg_parameters
	);
}

/**
 * Returns the details from a message or several messages
 * Uses loadMessageRequest to query the database
 *
 * @param string[] $msg_selects
 * @param string[] $msg_tables
 * @param mixed[] $msg_parameters
 * @param mixed[] $optional
 * @return array
 */
function loadMessageDetails($msg_selects, $msg_tables, $msg_parameters, $optional = array())
{
	if (!is_array($msg_parameters['message_list']))
	{
		$single = true;
		$msg_parameters['message_list'] = array($msg_parameters['message_list']);
	}
	else
	{
		$single = false;
	}

	$request = loadMessageRequest($msg_selects, $msg_tables, $msg_parameters, $optional);

	$return = array();
	while (($row = $request->fetch_assoc()))
	{
		$return[] = $row;
	}
	$request->free_result();

	if ($single)
	{
		return $return[0];
	}
	else
	{
		return $return;
	}
}

/**
 * Checks, which messages can be removed from a certain member.
 *
 * @param int $topic
 * @param int[] $messages
 * @param bool $allowed_all
 * @return array
 */
function determineRemovableMessages($topic, $messages, $allowed_all)
{
	$db = database();

	// Allowed to remove which messages?
	$messages_list = array();
	$db->fetchQuery('
		SELECT 
			id_msg, subject, id_member, poster_time
		FROM {db_prefix}messages
		WHERE id_msg IN ({array_int:message_list})
			AND id_topic = {int:current_topic}' . (!$allowed_all ? '
			AND id_member = {int:current_member}' : '') . '
		LIMIT ' . count($messages),
		array(
			'current_member' => User::$info->id,

The property id does not exist on ElkArte\Helper\ValuesContainer. Since you implemented __get, consider adding a @property annotation.

			'current_topic' => $topic,
			'message_list' => $messages,
		)
	)->fetch_callback(
		function ($row) use (&$messages_list, $allowed_all) {
			global $modSettings;

			if (!$allowed_all && !empty($modSettings['edit_disable_time']) && $row['poster_time'] + $modSettings['edit_disable_time'] * 60 < time())
			{
				return;
			}

			$messages_list[$row['id_msg']] = array($row['subject'], $row['id_member']);
		}
	);

	return $messages_list;
}

/**
 * Returns the number of messages that are being split to a new topic
 *
 * @param int $topic
 * @param bool $include_unapproved
 * @param int[] $selection
 *
 * @return array
 */
function countSplitMessages($topic, $include_unapproved, $selection = array())
{
	$db = database();

	$return = array('not_selected' => 0, 'selected' => 0);
	$db->fetchQuery('
		SELECT ' . (empty($selection) ? '0' : 'm.id_msg IN ({array_int:split_msgs})') . ' AS is_selected, COUNT(*) AS num_messages
		FROM {db_prefix}messages AS m
		WHERE m.id_topic = {int:current_topic}' . ($include_unapproved ? '' : '
			AND approved = {int:is_approved}') . (empty($selection) ? '' : '
		GROUP BY is_selected'),
		array(
			'current_topic' => $topic,
			'split_msgs' => $selection,
			'is_approved' => 1,
		)
	)->fetch_callback(
		function ($row) use (&$return) {
			$return[empty($row['is_selected']) || $row['is_selected'] == 'f' ? 'not_selected' : 'selected'] = $row['num_messages'];
		}
	);

	return $return;
}

/**
 * Returns an email (and few other things) associated with a message,
 * either the member's email or the poster_email (for example in case of guests)
 *
 * @param int $id_msg the id of a message
 * @return array
 * @todo very similar to posterDetails
 *
 */
function mailFromMessage($id_msg)
{
	$db = database();

	$request = $db->query('', '
		SELECT 
			COALESCE(mem.email_address, m.poster_email) AS email_address, COALESCE(mem.real_name, m.poster_name) AS real_name, COALESCE(mem.id_member, 0) AS id_member
		FROM {db_prefix}messages AS m
			LEFT JOIN {db_prefix}members AS mem ON (mem.id_member = m.id_member)
		WHERE m.id_msg = {int:id_msg}',
		array(
			'id_msg' => $id_msg,
		)
	);
	$row = $request->fetch_assoc();
	$request->free_result();

	return $row;
}

/**
 * This function changes the total number of messages,
 * and the highest message id by id_msg - which can be
 * parameters 1 and 2, respectively.
 *
 * @param bool|null $increment = null If true and $max_msg_id != null, then increment the total messages by one, otherwise recount all messages and get the max message id
 * @param int|null $max_msg_id = null, Only used if $increment === true
 */
function updateMessageStats($increment = null, $max_msg_id = null)
{
	global $modSettings;

	$db = database();

	if ($increment === true && $max_msg_id !== null)
	{
		updateSettings(array('totalMessages' => true, 'maxMsgID' => $max_msg_id), true);
	}
	else
	{
		// SUM and MAX on a smaller table is better for InnoDB tables.
		$request = $db->query('', '
			SELECT 
				SUM(num_posts + unapproved_posts) AS total_messages, MAX(id_last_msg) AS max_msg_id
			FROM {db_prefix}boards
			WHERE redirect = {string:blank_redirect}' . (!empty($modSettings['recycle_enable']) && $modSettings['recycle_board'] > 0 ? '
				AND id_board != {int:recycle_board}' : ''),
			array(
				'recycle_board' => $modSettings['recycle_board'] ?? 0,
				'blank_redirect' => '',
			)
		);
		$row = $request->fetch_assoc();
		$request->free_result();

		updateSettings(array(
			'totalMessages' => $row['total_messages'] ?? 0,
			'maxMsgID' => $row['max_msg_id'] ?? 0
		));
	}
}

/**
 * This function updates the log_search_subjects in the event of a topic being
 * moved, removed or split. It is being sent the topic id, and optionally
 * the new subject.
 *
 * @param int $id_topic
 * @param string|null $subject
 */
function updateSubjectStats($id_topic, $subject = null)
{
	$db = database();

	// Remove the previous subject (if any).
	$db->query('', '
		DELETE FROM {db_prefix}log_search_subjects
		WHERE id_topic = {int:id_topic}',
		array(
			'id_topic' => (int) $id_topic,
		)
	);

	// Insert the new subject.
	if ($subject !== null)
	{
		$id_topic = (int) $id_topic;
		$subject_words = text2words($subject);

		$inserts = array();
		foreach ($subject_words as $word)
		{
			$inserts[] = array($word, $id_topic);
		}

		if (!empty($inserts))
		{
			$db->insert('ignore',
				'{db_prefix}log_search_subjects',
				array('word' => 'string', 'id_topic' => 'int'),
				$inserts,
				array('word', 'id_topic')
			);
		}
	}
}