Page MenuHomeWickedGov Phorge
Files F1432448

RebuildMessageGroupStatsJob.php
No OneTemporary
Actions

Size
2 KB
Referenced Files
None
Subscribers
None

RebuildMessageGroupStatsJob.php
View Options

<?php
declare( strict_types = 1 );
namespace MediaWiki\Extension\Translate\Statistics;
use GenericParameterJob;
use InvalidArgumentException;
use MediaWiki\Extension\Translate\Jobs\GenericTranslateJob;
use MediaWiki\Extension\Translate\MessageGroupProcessing\MessageGroups;
use MediaWiki\MediaWikiServices;
/**
* Job for rebuilding message group stats.
*
* @author Niklas Laxström
* @license GPL-2.0-or-later
* @ingroup JobQueue
*/
class RebuildMessageGroupStatsJob extends GenericTranslateJob implements GenericParameterJob {
public const GROUP_ID = 'groupid';
public const LANGUAGE_CODE = 'languagecode';
public const CLEAR_GROUPS = 'cleargroups';
public const REFRESH = 'purge';
/** @inheritdoc */
protected $removeDuplicates = true;
public static function newJob( array $params ): self {
return new self( $params );
}
/**
* Force updating of message group stats for given groups.
*
* This uses cache for groups not given. If given groups have dependencies such
* as an aggregate group and it's subgroup, this attempts to take care of it so
* that no duplicate work is done.
*
* @param string[] $messageGroupIds
*/
public static function newRefreshGroupsJob( array $messageGroupIds ): self {
return new self( [ self::CLEAR_GROUPS => $messageGroupIds ] );
}
public function __construct( array $params = [] ) {
parent::__construct( 'RebuildMessageGroupStatsJob', $params );
}
public function run(): bool {
$lb = MediaWikiServices::getInstance()->getDBLoadBalancerFactory();
if ( !$lb->waitForReplication() ) {
$this->logWarning( 'Continuing despite replication lag' );
}
$params = $this->params;
$flags = 0;
// Sanity check that this is run via JobQueue. Immediate writes are only safe when they
// are run in isolation, e.g. as a separate job in the JobQueue.
if ( defined( 'MEDIAWIKI_JOB_RUNNER' ) ) {
$flags |= MessageGroupStats::FLAG_IMMEDIATE_WRITES;
}
// This is to make sure the priority value is not read from the process cache.
// There is still a possibility that, due to replication lag, an old value is read.
MessageGroups::singleton()->clearProcessCache();
if ( isset( $params[self::REFRESH] ) && $params[self::REFRESH] ) {
$flags |= MessageGroupStats::FLAG_NO_CACHE;
}
if ( isset( $params[self::GROUP_ID] ) && isset( $params[self::LANGUAGE_CODE] ) ) {
MessageGroupStats::forItem( $params[self::GROUP_ID], $params[self::LANGUAGE_CODE], $flags );
} elseif ( isset( $params[self::GROUP_ID] ) ) {
MessageGroupStats::forGroup( $params[self::GROUP_ID], $flags );
} elseif ( isset( $params[self::CLEAR_GROUPS] ) ) {
MessageGroupStats::clearGroup( $params[self::CLEAR_GROUPS], $flags );
} elseif ( isset( $params[self::LANGUAGE_CODE] ) ) {
MessageGroupStats::forLanguage( $params[self::LANGUAGE_CODE], $flags );
} else {
throw new InvalidArgumentException( 'No groupid or languagecode or cleargroup provided' );
}
return true;
}
}

File Metadata

Mime Type
text/x-php
Expires
Sat, May 16, 21:45 (1 d, 5 h)
Storage Engine
local-disk
Storage Format
Raw Data
Storage Handle
e1/99/3a1f389a25f8b1a53e4d94457023
Default Alt Text
RebuildMessageGroupStatsJob.php (2 KB)

Event Timeline