WatchlistExpiryJob.php

Go to the documentation of this file.

<?php
 
use MediaWiki\MediaWikiServices;
 
class WatchlistExpiryJob extends Job {
 
    public function __construct( string $command = 'watchlistExpiry', array $params = [] ) {
        parent::__construct( $command, $params );
    }
 
    public function run() {
        $watchedItemStore = MediaWikiServices::getInstance()->getWatchedItemStore();
        $watchedItemStore->removeExpired( 100 );
        if ( $watchedItemStore->countExpired() ) {
            // If there are still items, add a new job.
            JobQueueGroup::singleton()->push( new static() );
        }
        return true;
    }
 
}