X-Git-Url: https://git.heureux-cyclage.org/?a=blobdiff_plain;f=includes%2Fjobqueue%2Fjobs%2FEnqueueJob.php;h=f9735d53c1595b112463e43265fc336ebb5ff410;hb=e3c745fea0c5231cc425a0223c9d4567152171a0;hp=ea7a8d7801785fe3474b7e708b0491974d4bcf7b;hpb=925c20a9ca669c67cc44f4468d0e0f3b33b94213;p=lhc%2Fweb%2Fwiklou.git

diff --git a/includes/jobqueue/jobs/EnqueueJob.php b/includes/jobqueue/jobs/EnqueueJob.php
index ea7a8d7801..f9735d53c1 100644
--- a/includes/jobqueue/jobs/EnqueueJob.php
+++ b/includes/jobqueue/jobs/EnqueueJob.php
@@ -32,15 +32,14 @@
  * @ingroup JobQueue
  * @since 1.25
  */
-final class EnqueueJob extends Job {
+final class EnqueueJob extends Job implements GenericParameterJob {
 	/**
 	 * Callers should use the factory methods instead
 	 *
-	 * @param Title $title
 	 * @param array $params Job parameters
 	 */
-	function __construct( Title $title, array $params ) {
-		parent::__construct( 'enqueue', $title, $params );
+	public function __construct( array $params ) {
+		parent::__construct( 'enqueue', $params );
 	}
 
 	/**
@@ -50,22 +49,24 @@ final class EnqueueJob extends Job {
 	public static function newFromLocalJobs( $jobs ) {
 		$jobs = is_array( $jobs ) ? $jobs : [ $jobs ];
 
-		return self::newFromJobsByWiki( [ wfWikiID() => $jobs ] );
+		return self::newFromJobsByDomain( [
+			WikiMap::getCurrentWikiDbDomain()->getId() => $jobs
+		] );
 	}
 
 	/**
-	 * @param array $jobsByWiki Map of (wiki => JobSpecification list)
+	 * @param array $jobsByDomain Map of (wiki => JobSpecification list)
 	 * @return EnqueueJob
 	 */
-	public static function newFromJobsByWiki( array $jobsByWiki ) {
+	public static function newFromJobsByDomain( array $jobsByDomain ) {
 		$deduplicate = true;
 
-		$jobMapsByWiki = [];
-		foreach ( $jobsByWiki as $wiki => $jobs ) {
-			$jobMapsByWiki[$wiki] = [];
+		$jobMapsByDomain = [];
+		foreach ( $jobsByDomain as $domain => $jobs ) {
+			$jobMapsByDomain[$domain] = [];
 			foreach ( $jobs as $job ) {
 				if ( $job instanceof JobSpecification ) {
-					$jobMapsByWiki[$wiki][] = $job->toSerializableArray();
+					$jobMapsByDomain[$domain][] = $job->toSerializableArray();
 				} else {
 					throw new InvalidArgumentException( "Jobs must be of type JobSpecification." );
 				}
@@ -73,10 +74,7 @@ final class EnqueueJob extends Job {
 			}
 		}
 
-		$eJob = new self(
-			Title::makeTitle( NS_SPECIAL, 'Badtitle/' . __CLASS__ ),
-			[ 'jobsByWiki' => $jobMapsByWiki ]
-		);
+		$eJob = new self( [ 'jobsByDomain' => $jobMapsByDomain ] );
 		// If *all* jobs to be pushed are to be de-duplicated (a common case), then
 		// de-duplicate this whole job itself to avoid build up in high traffic cases
 		$eJob->removeDuplicates = $deduplicate;
@@ -84,13 +82,24 @@ final class EnqueueJob extends Job {
 		return $eJob;
 	}
 
+	/**
+	 * @param array $jobsByWiki
+	 * @return EnqueueJob
+	 * @deprecated Since 1.33; use newFromJobsByDomain()
+	 */
+	public static function newFromJobsByWiki( array $jobsByWiki ) {
+		return self::newFromJobsByDomain( $jobsByWiki );
+	}
+
 	public function run() {
-		foreach ( $this->params['jobsByWiki'] as $wiki => $jobMaps ) {
+		$jobsByDomain = $this->params['jobsByDomain'] ?? $this->params['jobsByWiki']; // b/c
+
+		foreach ( $jobsByDomain as $domain => $jobMaps ) {
 			$jobSpecs = [];
 			foreach ( $jobMaps as $jobMap ) {
 				$jobSpecs[] = JobSpecification::newFromArray( $jobMap );
 			}
-			JobQueueGroup::singleton( $wiki )->push( $jobSpecs );
+			JobQueueGroup::singleton( $domain )->push( $jobSpecs );
 		}
 
 		return true;