JobQueueEnqueueUpdate.php

Go to the documentation of this file.

<?php
namespace MediaWiki\Deferred;
 
use IJobSpecification;
use MediaWiki\JobQueue\JobQueueGroupFactory;
use MediaWiki\MediaWikiServices;
use MWExceptionHandler;
use Throwable;
use Wikimedia\Assert\Assert;
 
class JobQueueEnqueueUpdate implements DeferrableUpdate, MergeableUpdate {
    private $jobsByDomain;
 
    private $jobQueueGroupFactory;
 
    public function __construct( string $domain, array $jobs ) {
        $this->jobsByDomain[$domain] = $jobs;
        // TODO Inject services, when DeferredUpdates supports DI
        $this->jobQueueGroupFactory = MediaWikiServices::getInstance()->getJobQueueGroupFactory();
    }
 
    public function merge( MergeableUpdate $update ) {
        Assert::parameterType( __CLASS__, $update, '$update' );
        '@phan-var self $update';
 
        foreach ( $update->jobsByDomain as $domain => $jobs ) {
            $this->jobsByDomain[$domain] = array_merge(
                $this->jobsByDomain[$domain] ?? [],
                $jobs
            );
        }
    }
 
    public function doUpdate() {
        foreach ( $this->jobsByDomain as $domain => $jobs ) {
            $group = $this->jobQueueGroupFactory->makeJobQueueGroup( $domain );
            try {
                $group->push( $jobs );
            } catch ( Throwable $e ) {
                // Get in as many jobs as possible and let other post-send updates happen
                MWExceptionHandler::logException( $e );
            }
        }
    }
}
 
class_alias( JobQueueEnqueueUpdate::class, 'JobQueueEnqueueUpdate' );