ElkArte\MessagesDelete::restoreMessages()

Complexity

Conditions	19
Paths	183

Size

Total Lines	151
Code Lines	63

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	380

Importance

Changes	1
Bugs	1	Features	0

<?php
	public function restoreMessages($msgs_id): ?array
	{
		$msgs = [];
		foreach ($msgs_id as $msg)
		{
			$msg = (int) $msg;
			if (!empty($msg))
			{
				$msgs[] = $msg;
			}
		}

		if (empty($msgs))
		{
			return null;
		}

		$db = database();

		// Get the id_previous_board and id_previous_topic.
		$actioned_messages = [];
		$previous_topics = [];
		$db->fetchQuery('
			SELECT 
				m.id_topic, m.id_msg, m.id_board, m.subject, m.id_member, t.id_previous_board, t.id_previous_topic,
				t.id_first_msg, b.count_posts, COALESCE(pt.id_board, 0) AS possible_prev_board
			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)
				LEFT JOIN {db_prefix}topics AS pt ON (pt.id_topic = t.id_previous_topic)
			WHERE m.id_msg IN ({array_int:messages})',
			[
				'messages' => $msgs,
			]
		)->fetch_callback(
			function ($row) use (&$actioned_messages, &$previous_topics) {
				// Restoring the first post means topic.
				if ((int) $row['id_msg'] === (int) $row['id_first_msg'] && (int) $row['id_previous_topic'] === (int) $row['id_topic'])
				{
					$this->_topics_to_restore[] = $row['id_topic'];
					return;
				}

				// Don't know where it's going?
				if (empty($row['id_previous_topic']))
				{
					$this->_unfound_messages[$row['id_msg']] = $row['subject'];
					return;
				}

				$previous_topics[] = $row['id_previous_topic'];
				if (empty($actioned_messages[$row['id_previous_topic']]))
				{
					$actioned_messages[$row['id_previous_topic']] = [
						'msgs' => [],
						'count_posts' => (int) $row['count_posts'],
						'subject' => $row['subject'],
						'previous_board' => $row['id_previous_board'],
						'possible_prev_board' => $row['possible_prev_board'],
						'current_topic' => (int) $row['id_topic'],
						'current_board' => (int) $row['id_board'],
						'members' => [],
					];
				}

				$actioned_messages[$row['id_previous_topic']]['msgs'][$row['id_msg']] = $row['subject'];
				if ($row['id_member'])
				{
					$actioned_messages[$row['id_previous_topic']]['members'][] = (int) $row['id_member'];
				}
			}
		);

		// Check for topics we are going to fully restore.
		foreach (array_keys($actioned_messages) as $topic)
		{
			if (in_array($topic, $this->_topics_to_restore))
			{
				unset($actioned_messages[$topic]);
			}
		}

		// Load any previous topics to check they exist.
		if (!empty($previous_topics))
		{
			$db->fetchQuery('
				SELECT 
					t.id_topic, t.id_board, m.subject
				FROM {db_prefix}topics AS t
					INNER JOIN {db_prefix}messages AS m ON (m.id_msg = t.id_first_msg)
				WHERE t.id_topic IN ({array_int:previous_topics})',
				[
					'previous_topics' => $previous_topics,
				]
			)->fetch_callback(
				static function ($row) use (&$previous_topics) {
					$previous_topics[$row['id_topic']] = [
						'board' => $row['id_board'],
						'subject' => $row['subject'],
					];
				}
			);
		}

		// Restore each topic.
		$messages = [];
		foreach ($actioned_messages as $topic => $data)
		{
			// If we have topics we are going to restore the whole lot ignore them.
			if (in_array($topic, $this->_topics_to_restore))
			{
				unset($actioned_messages[$topic]);
				continue;
			}

			// Move the posts back then!
			if (isset($previous_topics[$topic]))
			{
				$this->_mergePosts(array_keys($data['msgs']), $data['current_topic'], $topic);

				// Log em.
				logAction('restore_posts', ['topic' => $topic, 'subject' => $previous_topics[$topic]['subject'], 'board' => empty($data['previous_board']) ? $data['possible_prev_board'] : $data['previous_board']]);
				foreach (array_keys($data['msgs']) as $m)
				{
					$messages[] = $m;
				}
			}
			else
			{
				foreach ($data['msgs'] as $id => $subject)
				{
					$this->_unfound_messages[$id] = $subject;
				}
			}
		}

		// Put the icons back.
		if (!empty($messages))
		{
			$db->query('', '
				UPDATE {db_prefix}messages
				SET icon = {string:icon}
				WHERE id_msg IN ({array_int:messages})',
				[
					'icon' => 'xx',
					'messages' => $messages,
				]
			);
		}

		return $actioned_messages;
	}