dark1\reducesearchindex\cron\auto_reduce_sync::run()

Complexity

Conditions	10
Paths	7

Size

Total Lines	97
Code Lines	66

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
	public function run()
	{
		if ($this->config['dark1_rsi_enable'] && ($this->config['dark1_rsi_time'] < (time() - $this->config['dark1_rsi_interval'])))
		{
			$this->config->set('dark1_rsi_time', (time() - $this->config['dark1_rsi_interval']), false);
			$post_ids = $poster_ids = $topic_ids = $forum_ids = array();

			$sql = 'SELECT t.topic_id, p.post_id, p.poster_id, p.forum_id' . PHP_EOL .
					'FROM ' . POSTS_TABLE . ' as p' . PHP_EOL .
					'LEFT JOIN ' . TOPICS_TABLE . ' as t' . PHP_EOL .
					'ON t.topic_id = p.topic_id' . PHP_EOL .
					'LEFT JOIN ' . FORUMS_TABLE . ' as f' . PHP_EOL .
					'ON f.forum_id = p.forum_id' . PHP_EOL .
					'WHERE f.dark1_rsi_f_enable = 3 AND t.topic_time <= ' . (int) $this->config['dark1_rsi_time'];
			$result = $this->db->sql_query($sql);

			while ($row = $this->db->sql_fetchrow($result))
			{
				$post_ids[] = (int) $row['post_id'];
				$poster_ids[] = (int) $row['poster_id'];
				$topic_ids[] = (int) $row['topic_id'];
				$forum_ids[] = (int) $row['forum_id'];
			}
			$this->db->sql_freeresult($result);

			$sql = 'SELECT p.post_id, p.poster_id, p.forum_id' . PHP_EOL .
					'FROM ' . POSTS_TABLE . ' as p' . PHP_EOL .
					'LEFT JOIN ' . TOPICS_TABLE . ' as t' . PHP_EOL .
					'ON t.topic_id = p.topic_id' . PHP_EOL .
					'LEFT JOIN ' . FORUMS_TABLE . ' as f' . PHP_EOL .
					'ON f.forum_id = p.forum_id' . PHP_EOL .
					'WHERE f.dark1_rsi_f_enable = 2 AND t.topic_time <= ' . (int) $this->config['dark1_rsi_time'];
			$result = $this->db->sql_query($sql);

			while ($row = $this->db->sql_fetchrow($result))
			{
				$post_ids[] = (int) $row['post_id'];
				$poster_ids[] = (int) $row['poster_id'];
				$forum_ids[] = (int) $row['forum_id'];
			}
			$this->db->sql_freeresult($result);

			$sql = 'SELECT p.post_id, p.poster_id, p.forum_id' . PHP_EOL .
					'FROM ' . POSTS_TABLE . ' as p' . PHP_EOL .
					'LEFT JOIN ' . FORUMS_TABLE . ' as f' . PHP_EOL .
					'ON f.forum_id = p.forum_id' . PHP_EOL .
					'WHERE f.dark1_rsi_f_enable = 1 AND p.post_time <= ' . (int) $this->config['dark1_rsi_time'];
			$result = $this->db->sql_query($sql);

			while ($row = $this->db->sql_fetchrow($result))
			{
				$post_ids[] = (int) $row['post_id'];
				$poster_ids[] = (int) $row['poster_id'];
				$forum_ids[] = (int) $row['forum_id'];
			}
			$this->db->sql_freeresult($result);

			$post_ids = $this->array_unique_sort($post_ids);
			$poster_ids = $this->array_unique_sort($poster_ids);
			$topic_ids = $this->array_unique_sort($topic_ids);
			$forum_ids = $this->array_unique_sort($forum_ids);

			// Lock Topics
			if (count($topic_ids) > 0)
			{
				$sql = 'UPDATE ' . TOPICS_TABLE . PHP_EOL .
						'SET topic_status = ' . ITEM_LOCKED  . PHP_EOL .
						'WHERE ' . $this->db->sql_in_set('topic_id', $topic_ids);
				$this->db->sql_query($sql);
			}

			// Remove the message from the search index
			$search_type = $this->config['search_type'];
			$identifier = substr($search_type, strrpos($search_type, '\\') + 1);
			if ($identifier == 'fulltext_native' && class_exists($search_type))
			{
				$error = false;
				$phpbb_root_path = $this->phpbb_container->getParameter('core.root_path');
				$phpEx = $this->phpbb_container->getParameter('core.php_ext');
				$auth = $this->phpbb_container->get('auth');
				$user = $this->phpbb_container->get('user');
				$phpbb_dispatcher = $this->phpbb_container->get('dispatcher');

				$search = new $search_type($error, $phpbb_root_path, $phpEx, $auth, $this->config, $this->db, $user, $phpbb_dispatcher);
				if ($error == false)

The condition $error == false is always true.

It seems like you are loosely comparing two booleans. Considering using the strict comparison === instead.

				{
					@$search->index_remove($post_ids, $poster_ids, $forum_ids);

It seems like you do not handle an error condition for index_remove(). This can introduce security issues, and is generally not recommended.

				}
			}

			$dark1_rsi_interval = $this->config['dark1_rsi_interval'] / 86400;
			$dark1_rsi_time = date('Y-m-d h:i:s A P', $this->config['dark1_rsi_time']);

$this->config['dark1_rsi_time'] of type string is incompatible with the type integer expected by parameter $timestamp of date().

			$this->phpbb_log->add('admin', '', '', 'RSI_AUTO_LOG', time(), array($dark1_rsi_interval, $dark1_rsi_time));
		}

		// Update the last backup time
		$this->config->set('dark1_rsi_auto_reduce_sync_last_gc', time(), false);
	}