Wikibase\Client\ChangeModification\ChangeVisibilityNotificationJob

Complexity

Total Complexity

4

Size/Duplication

Total Lines	57
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	1
A	newFromGlobalState()	0	9	1
A	modifyChanges()	0	16	2

<?php

declare( strict_types = 1 );

namespace Wikibase\Client\ChangeModification;

use MediaWiki\MediaWikiServices;
use Title;
use Wikimedia\Assert\Assert;
use Wikimedia\Rdbms\LBFactory;

/**
 * Job for notifying a client wiki of a batch of revision visibility changes on the repository.
 *
 * @license GPL-2.0-or-later
 * @author Marius Hoch
 */
class ChangeVisibilityNotificationJob extends ChangeModificationNotificationJob {

	private $batchSize;
	private $lbFactory;

	/**
	 * Constructs a ChangeVisibilityNotificationJob for the repo revisions given.
	 *
	 * @param LBFactory $lbFactory
	 * @param int $batchSize
	 * @param array $params Contains the name of the repo, revisionIdentifiersJson to redact
	 *   and the visibilityBitFlag to set.
	 */
	public function __construct( LBFactory $lbFactory, int $batchSize, array $params = [] ) {
		parent::__construct( 'ChangeVisibilityNotification', $lbFactory->getMainLB(), $params );

		Assert::parameter(
			isset( $params['visibilityBitFlag'] ),
			'$params',
			'$params[\'visibilityBitFlag\'] not set.'
		);

		$this->lbFactory = $lbFactory;
		$this->batchSize = $batchSize;
	}

	public static function newFromGlobalState( Title $unused, array $params ) {
		$mwServices = MediaWikiServices::getInstance();

		return new self(
			$mwServices->getDBLoadBalancerFactory(),
			$mwServices->getMainConfig()->get( 'UpdateRowsPerQuery' ),
			$params
		);
	}

	/**
	 * @param int[] $relevantChanges
	 */
	protected function modifyChanges( array $relevantChanges ): void {
		$visibilityBitFlag = $this->params['visibilityBitFlag'];

		$dbw = $this->loadBalancer->getConnection( DB_MASTER );

		foreach ( array_chunk( $relevantChanges, $this->batchSize ) as $rcIdBatch ) {
			$dbw->update(
				'recentchanges',
				[ 'rc_deleted' => $visibilityBitFlag ],
				[ 'rc_id' => $rcIdBatch ],
				__METHOD__
			);

			$this->lbFactory->waitForReplication();
		}
	}

}