|
<?php |
|
|
|
namespace Kanboard\Console; |
|
|
|
use Kanboard\Core\Queue\JobHandler; |
|
use SimpleQueue\Job; |
|
use Symfony\Component\Console\Input\InputInterface; |
|
use Symfony\Component\Console\Output\OutputInterface; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
class JobCommand extends BaseCommand |
|
{ |
|
protected function configure() |
|
{ |
|
$this |
|
->setName('job') |
|
->setDescription('Execute individual job (read payload from stdin)') |
|
; |
|
} |
|
|
|
protected function execute(InputInterface $input, OutputInterface $output): int |
|
{ |
|
$payload = fgets(STDIN); |
|
|
|
$job = new Job(); |
|
$job->unserialize($payload); |
|
|
|
JobHandler::getInstance($this->container)->executeJob($job); |
|
return 0; |
|
} |
|
} |
|
|