tarantool-php / jobqueue

src/Console/Command/PutCommand.php

<?php

namespace Tarantool\JobQueue\Console\Command;

use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

class PutCommand extends Command
{
    protected function configure(): void
    {
        parent::configure();

        $this
            ->setName('put')
            ->setDescription('Puts a task into the queue')
            ->addArgument('json-data', InputArgument::REQUIRED)
        ;
    }

    protected function execute(InputInterface $input, OutputInterface $output): void
    {
        $json = $input->getArgument('json-data');
        $data = json_decode($json, true);

It seems like $json can also be of type string[]; however, parameter $json of json_decode() does only seem to accept string, maybe add an additional type check?

        if (!is_array($data)) {
            throw new \InvalidArgumentException('Invalid json data.');
        }

        $queue = $this->createConfigFactory($input, $output)->createQueue();
        $task = $queue->put($data);

        $output->writeln(sprintf(
            '<comment>%s</comment> was successfully put to <info>%s</info> (#<comment>%d</comment>).',
            json_encode($task->getData()),
            $queue->getName(),
            $task->getId()
        ));
    }
}