wikimedia / mediawiki

	 * @param IJobSpecification $job

	 * @return array

	 */

	protected function getNewJobFields( IJobSpecification $job ) {

		return [

			// Fields that describe the nature of the job

			'type' => $job->getType(),

			'namespace' => $job->getTitle()->getNamespace(),

			'title' => $job->getTitle()->getDBkey(),

			'params' => $job->getParams(),

			// Some jobs cannot run until a "release timestamp"

			'rtimestamp' => $job->getReleaseTimestamp() ?: 0,

			// Additional job metadata

			'uuid' => UIDGenerator::newRawUUIDv4( UIDGenerator::QUICK_RAND ),

			'sha1' => $job->ignoreDuplicates()

				? Wikimedia\base_convert( sha1( serialize( $job->getDeduplicationInfo() ) ), 16, 36, 31 )

				: '',

			'timestamp' => time() // UNIX timestamp

		];

	}

	/**

	 * @param array $fields

	 * @param IJobSpecification $job

	 * @return array

	 */

	protected function insertFields( IJobSpecification $job ) {

		$dbw = $this->getMasterDB();

		return [

			// Fields that describe the nature of the job

			'job_cmd' => $job->getType(),

			'job_namespace' => $job->getTitle()->getNamespace(),

			'job_title' => $job->getTitle()->getDBkey(),

			'job_params' => self::makeBlob( $job->getParams() ),

			// Additional job metadata

			'job_id' => $dbw->nextSequenceValue( 'job_job_id_seq' ),

			'job_timestamp' => $dbw->timestamp(),

			'job_sha1' => Wikimedia\base_convert(

				sha1( serialize( $job->getDeduplicationInfo() ) ),

				16, 36, 31

			),

			'job_random' => mt_rand( 0, self::MAX_JOB_RANDOM )

		];

	}

	/**

	 * @throws JobQueueConnectionError