<?php

namespace MediaWiki\CheckUser\IPContributions;

use JobQueueGroup;
use LogicException;
use MediaWiki\Cache\LinkBatchFactory;
use MediaWiki\CheckUser\Jobs\LogTemporaryAccountAccessJob;
use MediaWiki\CheckUser\Logging\TemporaryAccountLogger;
use MediaWiki\CheckUser\Services\CheckUserLookupUtils;
use MediaWiki\CommentFormatter\CommentFormatter;
use MediaWiki\Context\IContextSource;
use MediaWiki\HookContainer\HookContainer;
use MediaWiki\Linker\LinkRenderer;
use MediaWiki\Pager\ContributionsPager;
use MediaWiki\Revision\RevisionStore;
use MediaWiki\Title\NamespaceInfo;
use MediaWiki\User\TempUser\TempUserConfig;
use MediaWiki\User\UserFactory;
use MediaWiki\User\UserIdentity;
use Wikimedia\Rdbms\IExpression;

class IPContributionsPager extends ContributionsPager {
	private TempUserConfig $tempUserConfig;
	private CheckUserLookupUtils $checkUserLookupUtils;
	private JobQueueGroup $jobQueueGroup;

	/**
	 * @param LinkRenderer $linkRenderer
	 * @param LinkBatchFactory $linkBatchFactory
	 * @param HookContainer $hookContainer
	 * @param RevisionStore $revisionStore
	 * @param NamespaceInfo $namespaceInfo
	 * @param CommentFormatter $commentFormatter
	 * @param UserFactory $userFactory
	 * @param TempUserConfig $tempUserConfig
	 * @param CheckUserLookupUtils $checkUserLookupUtils
	 * @param JobQueueGroup $jobQueueGroup
	 * @param IContextSource $context
	 * @param array $options
	 * @param ?UserIdentity $target IP address for temporary user contributions lookup
	 */
	public function __construct(
		LinkRenderer $linkRenderer,
		LinkBatchFactory $linkBatchFactory,
		HookContainer $hookContainer,
		RevisionStore $revisionStore,
		NamespaceInfo $namespaceInfo,
		CommentFormatter $commentFormatter,
		UserFactory $userFactory,
		TempUserConfig $tempUserConfig,
		CheckUserLookupUtils $checkUserLookupUtils,
		JobQueueGroup $jobQueueGroup,
		IContextSource $context,
		array $options,
		?UserIdentity $target = null
	) {
		parent::__construct(
			$linkRenderer,
			$linkBatchFactory,
			$hookContainer,
			$revisionStore,
			$namespaceInfo,
			$commentFormatter,
			$userFactory,
			$context,
			$options,
			$target
		);
		$this->tempUserConfig = $tempUserConfig;
		$this->checkUserLookupUtils = $checkUserLookupUtils;
		$this->jobQueueGroup = $jobQueueGroup;

		if ( $this->isArchive ) {
			$this->revisionIdField = 'ar_rev_id';
			$this->revisionParentIdField = 'ar_parent_id';
			$this->revisionTimestampField = 'ar_timestamp';
			$this->revisionLengthField = 'ar_len';
			$this->revisionDeletedField = 'ar_deleted';
			$this->revisionMinorField = 'ar_minor_edit';
			$this->userNameField = 'ar_user_text';
			$this->pageNamespaceField = 'ar_namespace';
			$this->pageTitleField = 'ar_title';
		}
	}

	public function doQuery() {
		parent::doQuery();
		// Log that the user has viewed the temporary accounts editing on the target IP or IP range, as if we reach
		// here query has been made for a valid target and if there are rows to display they will be displayed.
		$this->jobQueueGroup->push(
			LogTemporaryAccountAccessJob::newSpec(
				$this->getAuthority()->getUser(),
				$this->target,
				TemporaryAccountLogger::ACTION_VIEW_TEMPORARY_ACCOUNTS_ON_IP,
			)
		);
	}

	/**
	 * @inheritDoc
	 */
	protected function getRevisionQuery() {
		$queryBuilder = $this->getDatabase()->newSelectQueryBuilder();

		if ( $this->isArchive ) {
			$queryBuilder
				->select( [
					// The fields prefixed with ar_ must be named that way so that
					// RevisionStore::isRevisionRow can recognize the row.
					'ar_id',
					'ar_page_id',
					'ar_namespace',
					'ar_title',
					'ar_rev_id',
					'ar_timestamp',
					'ar_minor_edit',
					'ar_deleted',
					'ar_len',
					'ar_parent_id',
					'ar_sha1',
					'ar_actor',
					'ar_user' => 'cu_changes_actor.actor_user',
					'ar_user_text' => 'cu_changes_actor.actor_name',
					'ar_comment_text' => 'cu_changes_comment.comment_text',
					'ar_comment_data' => 'cu_changes_comment.comment_data',
					'ar_comment_cid' => 'cu_changes_comment.comment_id',
				] )
				->from( 'cu_changes' )
				->join( 'actor', 'cu_changes_actor', 'actor_id=cuc_actor' )
				->join( 'archive', 'cu_changes_archive', 'ar_rev_id=cuc_this_oldid' )
				->join( 'comment', 'cu_changes_comment', 'comment_id=cuc_comment_id' );
		} else {
			$queryBuilder
				->select( [
					// The fields prefixed with rev_ must be named that way so that
					// RevisionStore::isRevisionRow can recognize the row.
					'rev_id',
					'rev_page',
					'rev_actor',
					'rev_user' => 'cu_changes_actor.actor_user',
					'rev_user_text' => 'cu_changes_actor.actor_name',
					'rev_timestamp',
					'rev_minor_edit',
					'rev_deleted',
					'rev_len',
					'rev_parent_id',
					'rev_sha1',
					'rev_comment_text' => 'cu_changes_comment.comment_text',
					'rev_comment_data' => 'cu_changes_comment.comment_data',
					'rev_comment_cid' => 'cu_changes_comment.comment_id',
					'page_latest',
					'page_is_new',
					'page_namespace',
					'page_title',
				] )
				->from( 'cu_changes' )
				->join( 'actor', 'cu_changes_actor', 'actor_id=cuc_actor' )
				->join( 'revision', 'cu_changes_revision', 'rev_id=cuc_this_oldid' )
				->join( 'page', 'cu_changes_page', 'page_id=cuc_page_id' )
				->join( 'comment', 'cu_changes_comment', 'comment_id=cuc_comment_id' );
		}

		$ipConditions = $this->checkUserLookupUtils->getIPTargetExpr(
			$this->target,
			false,
			'cu_changes'
		);
		if ( $ipConditions === null ) {
			throw new LogicException( "Attempted IP contributions lookup with non-IP target: $this->target" );
		}

		$tempUserConditions = $this->tempUserConfig->getMatchCondition(
			$this->getDatabase(),
			'actor_name',
			IExpression::LIKE
		);

		$queryBuilder->where( $ipConditions );
		$queryBuilder->where( $tempUserConditions );

		return $queryBuilder->getQueryInfo();
	}

	/**
	 * @inheritDoc
	 */
	public function getIndexField() {
		return 'cuc_timestamp';
		// TODO: parent needs fixing for multi-column pagination so we can do this:
		// return [ [ 'cuc_timestamp', 'cuc_id' ] ];
	}
}