<?php namespace Illuminate\Console\Scheduling; use Illuminate\Container\Container; use Symfony\Component\Process\ProcessUtils; use Symfony\Component\Process\PhpExecutableFinder; class Schedule { /** * All of the events on the schedule. * * @var array */ protected $events = []; /** * Add a new callback event to the schedule. * * @param string $callback * @param array $parameters * @return \Illuminate\Console\Scheduling\Event */ public function call($callback, array $parameters = []) { $this->events[] = $event = new CallbackEvent($callback, $parameters); return $event; } /** * Add a new Artisan command event to the schedule. * * @param string $command * @param array $parameters * @return \Illuminate\Console\Scheduling\Event */ public function command($command, array $parameters = []) { if (class_exists($command)) { $command = Container::getInstance()->make($command)->getName(); } $binary = ProcessUtils::escapeArgument((new PhpExecutableFinder)->find(false)); $artisan = defined('ARTISAN_BINARY') ? ProcessUtils::escapeArgument(ARTISAN_BINARY) : 'artisan'; return $this->exec("{$binary} {$artisan} {$command}", $parameters); } /** * Add a new command event to the schedule. * * @param string $command * @param array $parameters * @return \Illuminate\Console\Scheduling\Event */ public function exec($command, array $parameters = []) { if (count($parameters)) { $command .= ' '.$this->compileParameters($parameters); } $this->events[] = $event = new Event($command); return $event; } /** * Compile parameters for a command. * * @param array $parameters * @return string */ protected function compileParameters(array $parameters) { return collect($parameters)->map(function ($value, $key) { if (is_array($value)) { $value = collect($value)->map(function ($value) { return ProcessUtils::escapeArgument($value); })->implode(' '); } elseif (! is_numeric($value) && ! preg_match('/^(-.$|--.*)/i', $value)) { $value = ProcessUtils::escapeArgument($value); } return is_numeric($key) ? $value : "{$key}={$value}"; })->implode(' '); } /** * Get all of the events on the schedule. * * @return array */ public function events() { return $this->events; } /** * Get all of the events on the schedule that are due. * * @param \Illuminate\Contracts\Foundation\Application $app * @return array */ public function dueEvents($app) { return array_filter($this->events, function ($event) use ($app) { return $event->isDue($app); }); } }