Async\AsyncProcess

Complexity

Total Complexity

7

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	hasCallbackSet()	0	3	1
A	startJob()	0	23	5
A	hasOnErrorSet()	0	3	1

<?php
declare(strict_types=1);

namespace Async;

use RuntimeException;
use Symfony\Component\Process\Process;

class AsyncProcess extends Process
{
    /**
     * @var bool
     */
    private $hasCallbackSet;
    /**
     * @var bool
     */
    private $hasOnErrorSet;

    public function startJob(
        callable $callback = null,
        callable $onError = null
    ): void {
        $this->hasCallbackSet = null !== $callback;
        $this->hasOnErrorSet = null !== $callback;

        $this->start(
            static function (string $type, string $buffer) use ($callback, $onError) {
                // if we can't decode probably child failed to execute
                if ($decoded = base64_decode($buffer, true)) {
                    /** @var AsyncChildResponse $asyncChildResponse */
                    $asyncChildResponse = unserialize($decoded, [false]);
                } else {
                    throw new RuntimeException('Child process returned: ' . $buffer);
                }

                if (null !== $onError && $asyncChildResponse->getError()) {
                    $onError($asyncChildResponse->getError());
                }

                if (null !== $callback) {
                    $callback($asyncChildResponse->getJobResult(), $asyncChildResponse->getStdOut());
                }
            }
        );
    }

    public function hasCallbackSet(): bool
    {
        return $this->hasCallbackSet;
    }

    public function hasOnErrorSet(): bool
    {
        return $this->hasOnErrorSet;
    }
}