Tarantool\JobQueue\Executor\ProcessExecutor

Complexity

Total Complexity

4

Size/Duplication

Total Lines	19
Duplicated Lines	0 %

Test Coverage

Coverage

80%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	execute()	0	4	1
A	createProcess()	0	11	3

<?php

namespace Tarantool\JobQueue\Executor;

use Symfony\Component\Process\Process;
use Tarantool\JobQueue\Exception\BadPayloadException;
use Tarantool\Queue\Queue;

class ProcessExecutor implements Executor
{
    public function execute($payload, Queue $queue): void
    {
        $process = $this->createProcess($payload);
        $process->mustRun();
    }

    private function createProcess($payload): Process
    {
        if ($payload instanceof Process) {
            return $payload;
        }

        if (is_string($payload)) {
            return new Process($payload);

$payload of type string is incompatible with the type array expected by parameter $command of Symfony\Component\Process\Process::__construct().

        }

        throw BadPayloadException::unexpectedType($payload, 'string or '.Process::class, __CLASS__);
    }
}