craft-async-queue/src/QueueCommand.php at master · ClockworkNet/craft-async-queue · GitHub

History

75 lines (61 loc) · 1.99 KB

Raw

<?php namespace ostark\AsyncQueue;

use ostark\AsyncQueue\Events\QueueCommandEvent;

use ostark\AsyncQueue\Exceptions\PhpExecutableNotFound;

use Symfony\Component\Process\PhpExecutableFinder;

use yii\base\Component;

class QueueCommand extends Component

{

const DEFAULT_SCRIPT = "craft";

const DEFAULT_ARGS = "queue/run";

const EVENT_PREPARE_COMMAND = 'prepareCommand';

protected $scriptName;

protected $scriptArgs;

/**

* QueueCommand constructor.

* @param string|null $scriptName

* @param string|null $scriptArgs

* @param array $config

public function __construct(string $scriptName = null, string $scriptArgs = null, array $config = [])

{

parent::__construct($config);

$this->scriptName = $scriptName ?: self::DEFAULT_SCRIPT;

$this->scriptArgs = $scriptArgs ?: self::DEFAULT_ARGS;

}

/**

* @param callable|null $wrapper

* @return string

* @throws \ostark\AsyncQueue\Exceptions\PhpExecutableNotFound

public function getPreparedCommand(callable $wrapper = null): string

{

$finder = new PhpExecutableFinder();

$php = $finder->find(false);

if (false === $php) {

throw new PhpExecutableNotFound('Unable to find php executable.');

}

$commandLine = join(" ", [$php, $this->scriptName, $this->scriptArgs]);

return $this->decorate($commandLine);

}

/**

* Wrapper

* @param string $commandLine

* @return string

protected function decorate(string $commandLine): string

{

// Allow others to decorate the command

$event = new QueueCommandEvent(['commandLine' => $commandLine]);

$this->trigger(self::EVENT_PREPARE_COMMAND, $event);

$commandLine = $event->commandLine;

if ($event->useDefaultDecoration === false) {

return $commandLine;

}

// default decoration

return "nice $commandLine > /dev/null 2>&1 &";

}

craft-async-queue/src/QueueCommand.php at master · ClockworkNet/craft-async-queue · GitHub

Uh oh!

Expand file tree

Breadcrumbs

QueueCommand.php

Latest commit

History

Breadcrumbs

QueueCommand.php

File metadata and controls