JobSpecification.php

Go to the documentation of this file.

<?php
class JobSpecification implements IJobSpecification {
    protected $type;
 
    protected $params;
 
    protected $title;
 
    protected $opts;
 
    public function __construct(
        $type, array $params, array $opts = [], Title $title = null
    ) {
        $this->validateParams( $params );
        $this->validateParams( $opts );
 
        $this->type = $type;
        if ( $title instanceof Title ) {
            // Make sure JobQueue classes can pull the title from parameters alone
            if ( $title->getDBkey() !== '' ) {
                $params += [
                    'namespace' => $title->getNamespace(),
                    'title' => $title->getDBkey()
                ];
            }
        } else {
            $title = Title::makeTitle( NS_SPECIAL, '' );
        }
        $this->params = $params;
        $this->title = $title;
        $this->opts = $opts;
    }
 
    protected function validateParams( array $params ) {
        foreach ( $params as $p => $v ) {
            if ( is_array( $v ) ) {
                $this->validateParams( $v );
            } elseif ( !is_scalar( $v ) && $v !== null ) {
                throw new UnexpectedValueException( "Job parameter $p is not JSON serializable." );
            }
        }
    }
 
    public function getType() {
        return $this->type;
    }
 
    public function getTitle() {
        return $this->title;
    }
 
    public function getParams() {
        return $this->params;
    }
 
    public function getReleaseTimestamp() {
        return isset( $this->params['jobReleaseTimestamp'] )
            ? wfTimestampOrNull( TS_UNIX, $this->params['jobReleaseTimestamp'] )
            : null;
    }
 
    public function ignoreDuplicates() {
        return !empty( $this->opts['removeDuplicates'] );
    }
 
    public function getDeduplicationInfo() {
        $info = [
            'type' => $this->getType(),
            'namespace' => $this->getTitle()->getNamespace(),
            'title' => $this->getTitle()->getDBkey(),
            'params' => $this->getParams()
        ];
        if ( is_array( $info['params'] ) ) {
            // Identical jobs with different "root" jobs should count as duplicates
            unset( $info['params']['rootJobSignature'] );
            unset( $info['params']['rootJobTimestamp'] );
            // Likewise for jobs with different delay times
            unset( $info['params']['jobReleaseTimestamp'] );
        }
 
        return $info;
    }
 
    public function getRootJobParams() {
        return [
            'rootJobSignature' => $this->params['rootJobSignature'] ?? null,
            'rootJobTimestamp' => $this->params['rootJobTimestamp'] ?? null
        ];
    }
 
    public function hasRootJobParams() {
        return isset( $this->params['rootJobSignature'] )
            && isset( $this->params['rootJobTimestamp'] );
    }
 
    public function isRootJob() {
        return $this->hasRootJobParams() && !empty( $this->params['rootJobIsSelf'] );
    }
 
    public function toSerializableArray() {
        return [
            'type'   => $this->type,
            'params' => $this->params,
            'opts'   => $this->opts,
            'title'  => [
                'ns'  => $this->title->getNamespace(),
                'key' => $this->title->getDBkey()
            ]
        ];
    }
 
    public static function newFromArray( array $map ) {
        $title = Title::makeTitle( $map['title']['ns'], $map['title']['key'] );
 
        return new self( $map['type'], $map['params'], $map['opts'], $title );
    }
}