Scheduler::getTimestamp() - Code Metrics - Inspection of "[WIP] Introduce Namespaces" - resque/php-resque - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed
Pull Request — master (#56)

unknown
created 2021-12-30 16:49 UTC
Scheduler::getTimestamp() A

↳ Parent: Scheduler
Complexity

Conditions	3
Paths	4
Size

Total Lines	13
Code Lines	6
Duplication

Lines	0
Ratio	0 %
Importance

Changes
Metric	Value
cc	3
eloc	6
nc	4
nop	1
dl	0
loc	13
rs	10
c	0
b	0
f	0
<?php

namespace Resque;

use \Resque\Exceptions\Exception as ResqueException;
use \Resque\Exceptions\InvalidTimestampException;

/**
* Resque scheduler core class to handle scheduling of jobs in the future.
*
* @package		Resque/Scheduler
* @author		Chris Boulton <[email protected]>
* @copyright	(c) 2012 Chris Boulton
* @license		http://www.opensource.org/licenses/mit-license.php
*/
class Scheduler
{
	const VERSION = "0.1";

	/**
	 * Enqueue a job in a given number of seconds from now.
	 *
	 * Identical to Resque::enqueue, however the first argument is the number
	 * of seconds before the job should be executed.
	 *
	 * @param int $in Number of seconds from now when the job should be executed.
	 * @param string $queue The name of the queue to place the job in.
	 * @param string $class The name of the class that contains the code to execute the job.
	 * @param array $args Any optional arguments that should be passed when the job is executed.
	 */
	public static function enqueueIn($in, $queue, $class, array $args = array())
	{
		self::enqueueAt(time() + $in, $queue, $class, $args);
	}

	/**
	 * Enqueue a job for execution at a given timestamp.
	 *
	 * Identical to Resque::enqueue, however the first argument is a timestamp
	 * (either UNIX timestamp in integer format or an instance of the DateTime
	 * class in PHP).
	 *
	 * @param DateTime|int $at Instance of PHP DateTime object or int of UNIX timestamp.

	 * @param string $queue The name of the queue to place the job in.
	 * @param string $class The name of the class that contains the code to execute the job.
	 * @param array $args Any optional arguments that should be passed when the job is executed.
	 */
	public static function enqueueAt($at, $queue, $class, $args = array())
	{
		self::validateJob($class, $queue);

		$job = self::jobToHash($queue, $class, $args);
		self::delayedPush($at, $job);

		Event::trigger('afterSchedule', array(
			'at'    => $at,
			'queue' => $queue,
			'class' => $class,
			'args'  => $args,
		));
	}

	/**
	 * Directly append an item to the delayed queue schedule.
	 *
	 * @param DateTime|int $timestamp Timestamp job is scheduled to be run at.
	 * @param array $item Hash of item to be pushed to schedule.
	 */
	public static function delayedPush($timestamp, $item)
	{
		$timestamp = self::getTimestamp($timestamp);
		$redis = Resque::redis();
		$redis->rpush('delayed:' . $timestamp, json_encode($item));
          rpush('delayed:' . $timestamp, json_encode($item));

		$redis->zadd('delayed_queue_schedule', $timestamp, $timestamp);
          zadd('delayed_queue_schedule', $timestamp, $timestamp);
	}

	/**
	 * Get the total number of jobs in the delayed schedule.
	 *
	 * @return int Number of scheduled jobs.
	 */
	public static function getDelayedQueueScheduleSize()
	{
		return (int)Resque::redis()->zcard('delayed_queue_schedule');
		return (int)Resque::redis()->/** @scrutinizer ignore-call */ zcard('delayed_queue_schedule');
	}

	/**
	 * Get the number of jobs for a given timestamp in the delayed schedule.
	 *
	 * @param DateTime|int $timestamp Timestamp
	 * @return int Number of scheduled jobs.
	 */
	public static function getDelayedTimestampSize($timestamp)
	{
		$timestamp = self::getTimestamp($timestamp);
		return Resque::redis()->llen('delayed:' . $timestamp, $timestamp);
		return Resque::redis()->/** @scrutinizer ignore-call */ llen('delayed:' . $timestamp, $timestamp);
	}

	/**
	 * Remove a delayed job from the queue
	 *
	 * note: you must specify exactly the same
	 * queue, class and arguments that you used when you added
	 * to the delayed queue
	 *
	 * also, this is an expensive operation because all delayed keys have tobe
	 * searched
	 *
	 * @param $queue
	 * @param $class
	 * @param $args
	 * @return int number of jobs that were removed
	 */
	public static function removeDelayed($queue, $class, $args)
	{
		$destroyed = 0;
		$item = json_encode(self::jobToHash($queue, $class, $args));
		$redis = Resque::redis();

		foreach ($redis->keys('delayed:*') as $key) {
		foreach ($redis->/** @scrutinizer ignore-call */ keys('delayed:*') as $key) {
			$key = $redis->removePrefix($key);
			$destroyed += $redis->lrem($key, 0, $item);
			$destroyed += $redis->/** @scrutinizer ignore-call */ lrem($key, 0, $item);
		}

		return $destroyed;
	}

	/**
	 * removed a delayed job queued for a specific timestamp
	 *
	 * note: you must specify exactly the same
	 * queue, class and arguments that you used when you added
	 * to the delayed queue
	 *
	 * @param $timestamp
	 * @param $queue
	 * @param $class
	 * @param $args
	 * @return mixed
	 */
	public static function removeDelayedJobFromTimestamp($timestamp, $queue, $class, $args)
	{
		$key = 'delayed:' . self::getTimestamp($timestamp);
		$item = json_encode(self::jobToHash($queue, $class, $args));
		$redis = Resque::redis();
		$count = $redis->lrem($key, 0, $item);
		self::cleanupTimestamp($key, $timestamp);

		return $count;
	}

	/**
	 * Generate hash of all job properties to be saved in the scheduled queue.
	 *
	 * @param string $queue Name of the queue the job will be placed on.
	 * @param string $class Name of the job class.
	 * @param array $args Array of job arguments.
	 */

	private static function jobToHash($queue, $class, $args)
	{
		return array(
			'class' => $class,
			'args'  => array($args),
			'queue' => $queue,
		);
	}

	/**
	 * If there are no jobs for a given key/timestamp, delete references to it.
	 *
	 * Used internally to remove empty delayed: items in Redis when there are
	 * no more jobs left to run at that timestamp.
	 *
	 * @param string $key Key to count number of items at.
	 * @param int $timestamp Matching timestamp for $key.
	 */
	private static function cleanupTimestamp($key, $timestamp)
	{
		$timestamp = self::getTimestamp($timestamp);
		$redis = Resque::redis();

		if ($redis->llen($key) == 0) {
			$redis->del($key);
           del($key);
			$redis->zrem('delayed_queue_schedule', $timestamp);
           zrem('delayed_queue_schedule', $timestamp);
		}
	}

	/**
	 * Convert a timestamp in some format in to a unix timestamp as an integer.
	 *
	 * @param DateTime|int $timestamp Instance of DateTime or UNIX timestamp.
	 * @return int Timestamp
	 * @throws Scheduler_InvalidTimestampException
	 */
	private static function getTimestamp($timestamp)
	{
		if ($timestamp instanceof DateTime) {
			$timestamp = $timestamp->getTimestamp();
		}

		if ((int)$timestamp != $timestamp) {
			throw new InvalidTimestampException(
				'The supplied timestamp value could not be converted to an integer.'
			);
		}

		return (int)$timestamp;
	}

	/**
	 * Find the first timestamp in the delayed schedule before/including the timestamp.
	 *
	 * Will find and return the first timestamp upto and including the given
	 * timestamp. This is the heart of the Scheduler that will make sure
	 * that any jobs scheduled for the past when the worker wasn't running are
	 * also queued up.
	 *
	 * @param DateTime|int $timestamp Instance of DateTime or UNIX timestamp.
	 *                                Defaults to now.
	 * @return int|false UNIX timestamp, or false if nothing to run.
	 */
	public static function nextDelayedTimestamp($at = null)
	{
		if ($at === null) {
			$at = time();
		} else {
			$at = self::getTimestamp($at);
		}

		$items = Resque::redis()->zrangebyscore('delayed_queue_schedule', '-inf', $at, array('limit' => array(0, 1)));
		$items = Resque::redis()->/** @scrutinizer ignore-call */ zrangebyscore('delayed_queue_schedule', '-inf', $at, array('limit' => array(0, 1)));
		if (!empty($items)) {
			return $items[0];
		}

		return false;
	}

	/**
	 * Pop a job off the delayed queue for a given timestamp.
	 *
	 * @param DateTime|int $timestamp Instance of DateTime or UNIX timestamp.
	 * @return array Matching job at timestamp.
	 */
	public static function nextItemForTimestamp($timestamp)
	{
		$timestamp = self::getTimestamp($timestamp);
		$key = 'delayed:' . $timestamp;

		$item = json_decode(Resque::redis()->lpop($key), true);
		$item = json_decode(Resque::redis()->/** @scrutinizer ignore-call */ lpop($key), true);

		self::cleanupTimestamp($key, $timestamp);
		return $item;
	}

	/**
	 * Ensure that supplied job class/queue is valid.
	 *
	 * @param string $class Name of job class.
	 * @param string $queue Name of queue.
	 * @throws \Resque\Exceptions\Exception
	 */
	private static function validateJob($class, $queue)
	{
		if (empty($class)) {
			throw new ResqueException('Jobs must be given a class.');
		} elseif (empty($queue)) {
			throw new ResqueException('Jobs must be put in a queue.');
		}

		return true;
	}
}

resque / php-resque

Pull Request — master (#56)

Scheduler::getTimestamp() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like
