Tleckie\Async\Child

Complexity

Total Complexity

10

Size/Duplication

Total Lines	80
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	hasError()	0	3	1
A	handle()	0	10	2
A	exception()	0	3	1
A	__construct()	0	3	1
A	output()	0	3	1
A	write()	0	5	2
A	close()	0	6	2

<?php

namespace Tleckie\Async;

use Throwable;

/**
 * Class Child
 *
 * @package Tleckie\Async
 * @author  Teodoro Leckie Westberg <teodoroleckie@gmail.com>
 */
class Child
{
    /** @var Encoder */
    private Encoder $encoder;

    /** @var mixed */
    private mixed $output = null;

    /** @var mixed */
    private mixed $exception = null;

    /**
     * Child constructor.
     *
     * @param Encoder $encoder
     */
    public function __construct(Encoder $encoder)
    {
        $this->encoder = $encoder;
    }

    /**
     * @param string|null $encoded
     * @return $this
     */
    public function handle(?string $encoded): self
    {
        try {
            $task = $this->encoder->decode($encoded);
            $this->output = $this->encoder->encode($task());
        } catch (Throwable $exception) {
            $this->exception = $this->encoder->encode(new SerializeException($exception));
        }

        return $this;
    }

    /**
     * @return mixed
     */
    public function exception(): mixed
    {
        return $this->exception;
    }

    /**
     * @return mixed
     */
    public function output(): mixed
    {
        return $this->output;
    }

    /**
     * @return $this
     */
    public function write(): self
    {
        fwrite(($this->hasError()) ? STDERR : STDOUT, ($this->exception) ?? $this->output);

        return $this;
    }

    /**
     * @return bool
     */
    public function hasError(): bool
    {
        return isset($this->exception);
    }

    /**
     * @codeCoverageIgnore
     */
    public function close()
    {
        if ($this->exception) {
            exit(1);
        }
        exit(0);
    }
}