ElkArte\MessagesDelete::removeMessage()

Complexity

Conditions	42
Paths	> 20000

Size

Total Lines	415
Code Lines	178

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	1806

Importance

Changes

0

<?php
	public function removeMessage($message, $decreasePostCount = true, $check_permissions = true)
	{
		global $board, $modSettings;

		$db = database();

		$message = (int) $message;

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

		$row = $db->fetchQuery('
			SELECT
				m.id_msg, m.id_member, m.icon, m.poster_time, m.subject,' . (empty($modSettings['search_custom_index_config']) ? '' : ' m.body,') . '
				m.approved, t.id_topic, t.id_first_msg, t.id_last_msg, t.num_replies, t.id_board,
				t.id_member_started AS id_member_poster,
				b.count_posts
			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 = t.id_board)
			WHERE m.id_msg = {int:id_msg}
			LIMIT 1',
			array(
				'id_msg' => $message,
			)
		)->fetch_assoc();

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

		if ($check_permissions)
		{
			$check = $this->_checkDeletePermissions($row, $board);
			if ($check === 'topic')
			{
				// This needs to be included for topic functions
				require_once(SUBSDIR . '/Topic.subs.php');
				removeTopics($row['id_topic']);

				return true;
			}

			if ($check === 'exit')
			{
				return false;
			}
		}

		// Deleting a recycled message can not lower anyone's post count.
		if ($row['icon'] === 'recycled')
		{
			$decreasePostCount = false;
		}

		// This is the last post, update the last post on the board.
		if ((int) $row['id_last_msg'] === $message)
		{
			// Find the last message, set it, and decrease the post count.
			$row2 = $db->fetchQuery('
				SELECT 
					id_msg, id_member
				FROM {db_prefix}messages
				WHERE id_topic = {int:id_topic}
					AND id_msg != {int:id_msg}
				ORDER BY ' . ($modSettings['postmod_active'] ? 'approved DESC, ' : '') . 'id_msg DESC
				LIMIT 1',
				array(
					'id_topic' => $row['id_topic'],
					'id_msg' => $message,
				)
			)->fetch_assoc();

			$db->query('', '
				UPDATE {db_prefix}topics
				SET
					id_last_msg = {int:id_last_msg},
					id_member_updated = {int:id_member_updated}' . (!$modSettings['postmod_active'] || $row['approved'] ? ',
					num_replies = CASE WHEN num_replies = {int:no_replies} THEN 0 ELSE num_replies - 1 END' : ',
					unapproved_posts = CASE WHEN unapproved_posts = {int:no_unapproved} THEN 0 ELSE unapproved_posts - 1 END') . '
				WHERE id_topic = {int:id_topic}',
				array(
					'id_last_msg' => (int) $row2['id_msg'],
					'id_member_updated' => (int) $row2['id_member'],
					'no_replies' => 0,
					'no_unapproved' => 0,
					'id_topic' => (int) $row['id_topic'],
				)
			);
		}
		// Only decrease post counts.
		else
		{
			$db->query('', '
				UPDATE {db_prefix}topics
				SET ' . ($row['approved'] ? '
					num_replies = CASE WHEN num_replies = {int:no_replies} THEN 0 ELSE num_replies - 1 END' : '
					unapproved_posts = CASE WHEN unapproved_posts = {int:no_unapproved} THEN 0 ELSE unapproved_posts - 1 END') . '
				WHERE id_topic = {int:id_topic}',
				array(
					'no_replies' => 0,
					'no_unapproved' => 0,
					'id_topic' => (int) $row['id_topic'],
				)
			);
		}

		// Default recycle to false.
		$recycle = false;

		// If recycle topics has been set, make a copy of this message in the recycle board.
		// Make sure we're not recycling messages that are already on the recycle board.
		if (!empty($this->_recycle_board) && $row['id_board'] != $this->_recycle_board && $row['icon'] !== 'recycled')
		{
			// Check if the recycle board exists and if so get the read status.
			$request = $db->query('', '
				SELECT 
					(COALESCE(lb.id_msg, 0) >= b.id_msg_updated) AS is_seen, id_last_msg
				FROM {db_prefix}boards AS b
					LEFT JOIN {db_prefix}log_boards AS lb ON (lb.id_board = b.id_board AND lb.id_member = {int:current_member})
				WHERE b.id_board = {int:recycle_board}',
				array(
					'current_member' => $this->user->id,

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

					'recycle_board' => $this->_recycle_board,
				)
			);

			if ($request->num_rows() === 0)
			{
				throw new Exceptions\Exception('recycle_no_valid_board');
			}

			[$isRead, $last_board_msg] = $request->fetch_row();
			$request->free_result();

			// Is there an existing topic in the recycle board to group this post with?
			$request = $db->query('', '
				SELECT 
					id_topic, id_first_msg, id_last_msg
				FROM {db_prefix}topics
				WHERE id_previous_topic = {int:id_previous_topic}
					AND id_board = {int:recycle_board}',
				array(
					'id_previous_topic' => $row['id_topic'],
					'recycle_board' => $this->_recycle_board,
				)
			);
			[$id_recycle_topic, $first_topic_msg, $last_topic_msg] = $request->fetch_row();
			$request->free_result();

			// Insert a new topic in the recycle board if $id_recycle_topic is empty.
			if (empty($id_recycle_topic))
			{
				$insert_res = $db->insert('',
					'{db_prefix}topics',
					array(
						'id_board' => 'int', 'id_member_started' => 'int', 'id_member_updated' => 'int', 'id_first_msg' => 'int',
						'id_last_msg' => 'int', 'unapproved_posts' => 'int', 'approved' => 'int', 'id_previous_topic' => 'int',
					),
					array(
						$this->_recycle_board, $row['id_member'], $row['id_member'], $message,
						$message, 0, 1, $row['id_topic'],
					),
					array('id_topic')
				);
				$topicID = $insert_res->insert_id();
			}
			else
			{
				// Capture the ID of the new topic...
				$topicID = $id_recycle_topic;
			}

			// If the topic creation went successful, move the message.
			if ($topicID > 0)
			{
				$db->query('', '
					UPDATE {db_prefix}messages
					SET
						id_topic = {int:id_topic},
						id_board = {int:recycle_board},
						icon = {string:recycled},
						approved = {int:is_approved}
					WHERE id_msg = {int:id_msg}',
					array(
						'id_topic' => $topicID,
						'recycle_board' => $this->_recycle_board,
						'id_msg' => $message,
						'recycled' => 'recycled',
						'is_approved' => 1,
					)
				);

				// Take any reported posts with us...
				$db->query('', '
					UPDATE {db_prefix}log_reported
					SET
						id_topic = {int:id_topic},
						id_board = {int:recycle_board}
					WHERE id_msg = {int:id_msg}
						AND type = {string:msg}',
					array(
						'id_topic' => $topicID,
						'recycle_board' => $this->_recycle_board,
						'id_msg' => $message,
						'msg' => 'msg',
					)
				);

				// Mark recycled topic as read.
				if ($this->user->is_guest === false)

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

				{
					require_once(SUBSDIR . '/Topic.subs.php');
					markTopicsRead(array($this->user->id, $topicID, $modSettings['maxMsgID'], 0), true);
				}

				// Mark recycle board as seen, if it was marked as seen before.
				if (!empty($isRead) && $this->user->is_guest === false)
				{
					require_once(SUBSDIR . '/Boards.subs.php');
					markBoardsRead($this->_recycle_board);
				}

				// Add one topic and post to the recycle bin board.
				$db->query('', '
					UPDATE {db_prefix}boards
					SET
						num_topics = num_topics + {int:num_topics_inc},
						num_posts = num_posts + 1' .
					($message > $last_board_msg ? ', id_last_msg = {int:id_merged_msg}' : '') . '
					WHERE id_board = {int:recycle_board}',
					array(
						'num_topics_inc' => empty($id_recycle_topic) ? 1 : 0,
						'recycle_board' => $this->_recycle_board,
						'id_merged_msg' => $message,
					)
				);

				// Lets increase the num_replies, and the first/last message ID as appropriate.
				if (!empty($id_recycle_topic))
				{
					$db->query('', '
						UPDATE {db_prefix}topics
						SET num_replies = num_replies + 1' .
						($message > $last_topic_msg ? ', id_last_msg = {int:id_merged_msg}' : '') .
						($message < $first_topic_msg ? ', id_first_msg = {int:id_merged_msg}' : '') . '
						WHERE id_topic = {int:id_recycle_topic}',
						array(
							'id_recycle_topic' => $id_recycle_topic,
							'id_merged_msg' => $message,
						)
					);
				}

				// Update mentions accessibility
				$this->deleteMessageMentions(messagesInTopics($topicID), true);

				// Make sure this message isn't getting deleted later on.
				$recycle = true;

				// Make sure we update the search subject index.
				require_once(SUBSDIR . '/Messages.subs.php');
				updateSubjectStats($topicID, $row['subject']);
			}

			// If it wasn't approved don't keep it in the queue.
			if (!$row['approved'])
			{
				$db->query('', '
					DELETE FROM {db_prefix}approval_queue
					WHERE id_msg = {int:id_msg}
						AND id_attach = {int:id_attach}',
					array(
						'id_msg' => $message,
						'id_attach' => 0,
					)
				);
			}
		}

		$db->query('', '
			UPDATE {db_prefix}boards
			SET ' . ($row['approved'] ? '
				num_posts = CASE WHEN num_posts = {int:no_posts} THEN 0 ELSE num_posts - 1 END' : '
				unapproved_posts = CASE WHEN unapproved_posts = {int:no_unapproved} THEN 0 ELSE unapproved_posts - 1 END') . '
			WHERE id_board = {int:id_board}',
			array(
				'no_posts' => 0,
				'no_unapproved' => 0,
				'id_board' => $row['id_board'],
			)
		);

		// If the poster was registered and the board this message was on incremented
		// the member's posts when it was posted, decrease his or her post count.
		if (!empty($row['id_member']) && $decreasePostCount && empty($row['count_posts']) && $row['approved'])
		{
			require_once(SUBSDIR . '/Members.subs.php');
			updateMemberData($row['id_member'], array('posts' => '-'));
		}

		// Only remove posts if they're not recycled.
		if (!$recycle)
		{
			// Update the like counts
			require_once(SUBSDIR . '/Likes.subs.php');
			decreaseLikeCounts($message);

			// Remove the likes!
			$db->query('', '
				DELETE FROM {db_prefix}message_likes
				WHERE id_msg = {int:id_msg}',
				array(
					'id_msg' => $message,
				)
			);

			// Remove the mentions!
			$this->deleteMessageMentions($message);

			// Remove the message!
			$db->query('', '
				DELETE FROM {db_prefix}messages
				WHERE id_msg = {int:id_msg}',
				array(
					'id_msg' => $message,
				)
			);

			if (!empty($modSettings['search_custom_index_config']))
			{
				$words = text2words($row['body'], true);
				if (!empty($words))
				{
					$db->query('', '
						DELETE FROM {db_prefix}log_search_words
						WHERE id_word IN ({array_int:word_list})
							AND id_msg = {int:id_msg}',
						array(
							'word_list' => $words,
							'id_msg' => $message,
						)
					);
				}
			}

			// Delete attachment(s) if they exist.
			require_once(SUBSDIR . '/ManageAttachments.subs.php');
			$attachmentQuery = array(
				'attachment_type' => 0,
				'id_msg' => $message,
			);
			removeAttachments($attachmentQuery);

			// Delete follow-ups too
			require_once(SUBSDIR . '/FollowUps.subs.php');

			// If it is an entire topic
			if ((int) $row['id_first_msg'] === (int) $message)
			{
				$db->query('', '
					DELETE FROM {db_prefix}follow_ups
					WHERE follow_ups IN ({array_int:topics})',
					array(
						'topics' => $row['id_topic'],
					)
				);
			}

			// Allow mods to remove message related data of their own (likes, maybe?)
			call_integration_hook('integrate_remove_message', array($message));
		}

		// Update the pesky statistics.
		updateMessageStats();
		require_once(SUBSDIR . '/Topic.subs.php');
		updateTopicStats();
		updateSettings(['calendar_updated' => time(),]);

		// And now to update the last message of each board we messed with.
		require_once(SUBSDIR . '/Post.subs.php');
		if ($recycle)
		{
			updateLastMessages([$row['id_board'], $this->_recycle_board]);
		}
		else
		{
			updateLastMessages($row['id_board']);
		}

		// Close any moderation reports for this message.
		require_once(SUBSDIR . '/Moderation.subs.php');
		$updated_reports = updateReportsStatus($message, 'close', 1);
		if ($updated_reports != 0)
		{
			updateSettings(array('last_mod_report_action' => time()));
			recountOpenReports(true);
		}

		// Add it to the mod log.
		if (!allowedTo('delete_any'))
		{
			return false;
		}

		if (allowedTo('delete_own') && $row['id_member'] == $this->user->id)
		{
			return false;
		}

		logAction('delete', array('topic' => $row['id_topic'], 'subject' => $row['subject'], 'member' => $row['id_member'], 'board' => $row['id_board']));
		return false;
	}