Spaces:
Sleeping
Sleeping
processmaker-community / processmaker-files /vendor /mtdowling /cron-expression /src /Cron /CronExpression.php
| namespace Cron; | |
| use DateTime; | |
| use DateTimeImmutable; | |
| use DateTimeZone; | |
| use Exception; | |
| use InvalidArgumentException; | |
| use RuntimeException; | |
| /** | |
| * CRON expression parser that can determine whether or not a CRON expression is | |
| * due to run, the next run date and previous run date of a CRON expression. | |
| * The determinations made by this class are accurate if checked run once per | |
| * minute (seconds are dropped from date time comparisons). | |
| * | |
| * Schedule parts must map to: | |
| * minute [0-59], hour [0-23], day of month, month [1-12|JAN-DEC], day of week | |
| * [1-7|MON-SUN], and an optional year. | |
| * | |
| * @link http://en.wikipedia.org/wiki/Cron | |
| */ | |
| class CronExpression | |
| { | |
| const MINUTE = 0; | |
| const HOUR = 1; | |
| const DAY = 2; | |
| const MONTH = 3; | |
| const WEEKDAY = 4; | |
| const YEAR = 5; | |
| /** | |
| * @var array CRON expression parts | |
| */ | |
| private $cronParts; | |
| /** | |
| * @var FieldFactory CRON field factory | |
| */ | |
| private $fieldFactory; | |
| /** | |
| * @var int Max iteration count when searching for next run date | |
| */ | |
| private $maxIterationCount = 1000; | |
| /** | |
| * @var array Order in which to test of cron parts | |
| */ | |
| private static $order = array(self::YEAR, self::MONTH, self::DAY, self::WEEKDAY, self::HOUR, self::MINUTE); | |
| /** | |
| * Factory method to create a new CronExpression. | |
| * | |
| * @param string $expression The CRON expression to create. There are | |
| * several special predefined values which can be used to substitute the | |
| * CRON expression: | |
| * | |
| * `@yearly`, `@annually` - Run once a year, midnight, Jan. 1 - 0 0 1 1 * | |
| * `@monthly` - Run once a month, midnight, first of month - 0 0 1 * * | |
| * `@weekly` - Run once a week, midnight on Sun - 0 0 * * 0 | |
| * `@daily` - Run once a day, midnight - 0 0 * * * | |
| * `@hourly` - Run once an hour, first minute - 0 * * * * | |
| * @param FieldFactory $fieldFactory Field factory to use | |
| * | |
| * @return CronExpression | |
| */ | |
| public static function factory($expression, FieldFactory $fieldFactory = null) | |
| { | |
| $mappings = array( | |
| '@yearly' => '0 0 1 1 *', | |
| '@annually' => '0 0 1 1 *', | |
| '@monthly' => '0 0 1 * *', | |
| '@weekly' => '0 0 * * 0', | |
| '@daily' => '0 0 * * *', | |
| '@hourly' => '0 * * * *' | |
| ); | |
| if (isset($mappings[$expression])) { | |
| $expression = $mappings[$expression]; | |
| } | |
| return new static($expression, $fieldFactory ?: new FieldFactory()); | |
| } | |
| /** | |
| * Validate a CronExpression. | |
| * | |
| * @param string $expression The CRON expression to validate. | |
| * | |
| * @return bool True if a valid CRON expression was passed. False if not. | |
| * @see \Cron\CronExpression::factory | |
| */ | |
| public static function isValidExpression($expression) | |
| { | |
| try { | |
| self::factory($expression); | |
| } catch (InvalidArgumentException $e) { | |
| return false; | |
| } | |
| return true; | |
| } | |
| /** | |
| * Parse a CRON expression | |
| * | |
| * @param string $expression CRON expression (e.g. '8 * * * *') | |
| * @param FieldFactory $fieldFactory Factory to create cron fields | |
| */ | |
| public function __construct($expression, FieldFactory $fieldFactory) | |
| { | |
| $this->fieldFactory = $fieldFactory; | |
| $this->setExpression($expression); | |
| } | |
| /** | |
| * Set or change the CRON expression | |
| * | |
| * @param string $value CRON expression (e.g. 8 * * * *) | |
| * | |
| * @return CronExpression | |
| * @throws \InvalidArgumentException if not a valid CRON expression | |
| */ | |
| public function setExpression($value) | |
| { | |
| $this->cronParts = preg_split('/\s/', $value, -1, PREG_SPLIT_NO_EMPTY); | |
| if (count($this->cronParts) < 5) { | |
| throw new InvalidArgumentException( | |
| $value . ' is not a valid CRON expression' | |
| ); | |
| } | |
| foreach ($this->cronParts as $position => $part) { | |
| $this->setPart($position, $part); | |
| } | |
| return $this; | |
| } | |
| /** | |
| * Set part of the CRON expression | |
| * | |
| * @param int $position The position of the CRON expression to set | |
| * @param string $value The value to set | |
| * | |
| * @return CronExpression | |
| * @throws \InvalidArgumentException if the value is not valid for the part | |
| */ | |
| public function setPart($position, $value) | |
| { | |
| if (!$this->fieldFactory->getField($position)->validate($value)) { | |
| throw new InvalidArgumentException( | |
| 'Invalid CRON field value ' . $value . ' at position ' . $position | |
| ); | |
| } | |
| $this->cronParts[$position] = $value; | |
| return $this; | |
| } | |
| /** | |
| * Set max iteration count for searching next run dates | |
| * | |
| * @param int $maxIterationCount Max iteration count when searching for next run date | |
| * | |
| * @return CronExpression | |
| */ | |
| public function setMaxIterationCount($maxIterationCount) | |
| { | |
| $this->maxIterationCount = $maxIterationCount; | |
| return $this; | |
| } | |
| /** | |
| * Get a next run date relative to the current date or a specific date | |
| * | |
| * @param string|\DateTime $currentTime Relative calculation date | |
| * @param int $nth Number of matches to skip before returning a | |
| * matching next run date. 0, the default, will return the current | |
| * date and time if the next run date falls on the current date and | |
| * time. Setting this value to 1 will skip the first match and go to | |
| * the second match. Setting this value to 2 will skip the first 2 | |
| * matches and so on. | |
| * @param bool $allowCurrentDate Set to TRUE to return the current date if | |
| * it matches the cron expression. | |
| * | |
| * @return \DateTime | |
| * @throws \RuntimeException on too many iterations | |
| */ | |
| public function getNextRunDate($currentTime = 'now', $nth = 0, $allowCurrentDate = false) | |
| { | |
| return $this->getRunDate($currentTime, $nth, false, $allowCurrentDate); | |
| } | |
| /** | |
| * Get a previous run date relative to the current date or a specific date | |
| * | |
| * @param string|\DateTime $currentTime Relative calculation date | |
| * @param int $nth Number of matches to skip before returning | |
| * @param bool $allowCurrentDate Set to TRUE to return the | |
| * current date if it matches the cron expression | |
| * | |
| * @return \DateTime | |
| * @throws \RuntimeException on too many iterations | |
| * @see \Cron\CronExpression::getNextRunDate | |
| */ | |
| public function getPreviousRunDate($currentTime = 'now', $nth = 0, $allowCurrentDate = false) | |
| { | |
| return $this->getRunDate($currentTime, $nth, true, $allowCurrentDate); | |
| } | |
| /** | |
| * Get multiple run dates starting at the current date or a specific date | |
| * | |
| * @param int $total Set the total number of dates to calculate | |
| * @param string|\DateTime $currentTime Relative calculation date | |
| * @param bool $invert Set to TRUE to retrieve previous dates | |
| * @param bool $allowCurrentDate Set to TRUE to return the | |
| * current date if it matches the cron expression | |
| * | |
| * @return array Returns an array of run dates | |
| */ | |
| public function getMultipleRunDates($total, $currentTime = 'now', $invert = false, $allowCurrentDate = false) | |
| { | |
| $matches = array(); | |
| for ($i = 0; $i < max(0, $total); $i++) { | |
| try { | |
| $matches[] = $this->getRunDate($currentTime, $i, $invert, $allowCurrentDate); | |
| } catch (RuntimeException $e) { | |
| break; | |
| } | |
| } | |
| return $matches; | |
| } | |
| /** | |
| * Get all or part of the CRON expression | |
| * | |
| * @param string $part Specify the part to retrieve or NULL to get the full | |
| * cron schedule string. | |
| * | |
| * @return string|null Returns the CRON expression, a part of the | |
| * CRON expression, or NULL if the part was specified but not found | |
| */ | |
| public function getExpression($part = null) | |
| { | |
| if (null === $part) { | |
| return implode(' ', $this->cronParts); | |
| } elseif (array_key_exists($part, $this->cronParts)) { | |
| return $this->cronParts[$part]; | |
| } | |
| return null; | |
| } | |
| /** | |
| * Helper method to output the full expression. | |
| * | |
| * @return string Full CRON expression | |
| */ | |
| public function __toString() | |
| { | |
| return $this->getExpression(); | |
| } | |
| /** | |
| * Determine if the cron is due to run based on the current date or a | |
| * specific date. This method assumes that the current number of | |
| * seconds are irrelevant, and should be called once per minute. | |
| * | |
| * @param string|\DateTime $currentTime Relative calculation date | |
| * | |
| * @return bool Returns TRUE if the cron is due to run or FALSE if not | |
| */ | |
| public function isDue($currentTime = 'now') | |
| { | |
| if ('now' === $currentTime) { | |
| $currentDate = date('Y-m-d H:i'); | |
| $currentTime = strtotime($currentDate); | |
| } elseif ($currentTime instanceof DateTime) { | |
| $currentDate = clone $currentTime; | |
| // Ensure time in 'current' timezone is used | |
| $currentDate->setTimezone(new DateTimeZone(date_default_timezone_get())); | |
| $currentDate = $currentDate->format('Y-m-d H:i'); | |
| $currentTime = strtotime($currentDate); | |
| } elseif ($currentTime instanceof DateTimeImmutable) { | |
| $currentDate = DateTime::createFromFormat('U', $currentTime->format('U')); | |
| $currentDate->setTimezone(new DateTimeZone(date_default_timezone_get())); | |
| $currentDate = $currentDate->format('Y-m-d H:i'); | |
| $currentTime = strtotime($currentDate); | |
| } else { | |
| $currentTime = new DateTime($currentTime); | |
| $currentTime->setTime($currentTime->format('H'), $currentTime->format('i'), 0); | |
| $currentDate = $currentTime->format('Y-m-d H:i'); | |
| $currentTime = $currentTime->getTimeStamp(); | |
| } | |
| try { | |
| return $this->getNextRunDate($currentDate, 0, true)->getTimestamp() == $currentTime; | |
| } catch (Exception $e) { | |
| return false; | |
| } | |
| } | |
| /** | |
| * Get the next or previous run date of the expression relative to a date | |
| * | |
| * @param string|\DateTime $currentTime Relative calculation date | |
| * @param int $nth Number of matches to skip before returning | |
| * @param bool $invert Set to TRUE to go backwards in time | |
| * @param bool $allowCurrentDate Set to TRUE to return the | |
| * current date if it matches the cron expression | |
| * | |
| * @return \DateTime | |
| * @throws \RuntimeException on too many iterations | |
| */ | |
| protected function getRunDate($currentTime = null, $nth = 0, $invert = false, $allowCurrentDate = false) | |
| { | |
| if ($currentTime instanceof DateTime) { | |
| $currentDate = clone $currentTime; | |
| } elseif ($currentTime instanceof DateTimeImmutable) { | |
| $currentDate = DateTime::createFromFormat('U', $currentTime->format('U')); | |
| $currentDate->setTimezone($currentTime->getTimezone()); | |
| } else { | |
| $currentDate = new DateTime($currentTime ?: 'now'); | |
| $currentDate->setTimezone(new DateTimeZone(date_default_timezone_get())); | |
| } | |
| $currentDate->setTime($currentDate->format('H'), $currentDate->format('i'), 0); | |
| $nextRun = clone $currentDate; | |
| $nth = (int) $nth; | |
| // We don't have to satisfy * or null fields | |
| $parts = array(); | |
| $fields = array(); | |
| foreach (self::$order as $position) { | |
| $part = $this->getExpression($position); | |
| if (null === $part || '*' === $part) { | |
| continue; | |
| } | |
| $parts[$position] = $part; | |
| $fields[$position] = $this->fieldFactory->getField($position); | |
| } | |
| // Set a hard limit to bail on an impossible date | |
| for ($i = 0; $i < $this->maxIterationCount; $i++) { | |
| foreach ($parts as $position => $part) { | |
| $satisfied = false; | |
| // Get the field object used to validate this part | |
| $field = $fields[$position]; | |
| // Check if this is singular or a list | |
| if (strpos($part, ',') === false) { | |
| $satisfied = $field->isSatisfiedBy($nextRun, $part); | |
| } else { | |
| foreach (array_map('trim', explode(',', $part)) as $listPart) { | |
| if ($field->isSatisfiedBy($nextRun, $listPart)) { | |
| $satisfied = true; | |
| break; | |
| } | |
| } | |
| } | |
| // If the field is not satisfied, then start over | |
| if (!$satisfied) { | |
| $field->increment($nextRun, $invert, $part); | |
| continue 2; | |
| } | |
| } | |
| // Skip this match if needed | |
| if ((!$allowCurrentDate && $nextRun == $currentDate) || --$nth > -1) { | |
| $this->fieldFactory->getField(0)->increment($nextRun, $invert, isset($parts[0]) ? $parts[0] : null); | |
| continue; | |
| } | |
| return $nextRun; | |
| } | |
| // @codeCoverageIgnoreStart | |
| throw new RuntimeException('Impossible CRON expression'); | |
| // @codeCoverageIgnoreEnd | |
| } | |
| } | |