Tleckie\Async\TaskFactory

Complexity

Total Complexity

5

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Importance

Changes	4
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	createTask()	0	13	1
A	id()	0	3	1
A	find()	0	11	1
A	__construct()	0	4	1
A	pid()	0	5	1

<?php

namespace Tleckie\Async;

use Opis\Closure\SerializableClosure;
use Symfony\Component\Process\Process;

/**
 * Class TaskFactory
 *
 * @package Tleckie\Async
 * @author  Teodoro Leckie Westberg <teodoroleckie@gmail.com>
 */
class TaskFactory implements TaskFactoryInterface
{
    /** @var int */
    private int $pid = 0;

    /** @var int */
    private int $index = 0;

    /** @var string|null */
    private string|null $script = null;

The type Tleckie\Async\null was not found. Maybe you did not declare it correctly or list all dependencies?

    /** @var string|null */
    private string|null $autoloader = null;

    /**
     * TaskFactory constructor.
     */
    public function __construct()
    {
        $this->autoloader = $this->find('vendor/autoload.php');
        $this->script = $this->find('bin/child');
    }

    /**
     * @param string $file
     * @return string|null
     */
    protected function find(string $file): ?string
    {
        $paths = array_filter([
            __DIR__ . '/../../../../'.$file,
            __DIR__ . '/../../../'.$file,
            __DIR__ . '/../../'.$file,
            __DIR__ . '/../'.$file,
        ], static function (string $path) {
            return file_exists($path);
        });
        return reset($paths);
    }

    /**
     * @inheritdoc
     */
    public function createTask(
        $process,
        Encoder $encoder,
        $binary = PHP_BINARY
    ): TaskInterface {
        $process = new Process([
            $binary,
            $this->script,
            $this->autoloader,
            $encoder->encode(new SerializableClosure($process))
        ]);

        return new Task($process, $encoder, $this->id());

$this->id() of type string is incompatible with the type integer expected by parameter $id of Tleckie\Async\Task::__construct().

    }

    /**
     * @return string
     */
    protected function id(): string
    {
        return (++$this->index) . $this->pid();
    }

    /**
     * @return string
     */
    protected function pid(): string
    {
        $this->pid = $this->pid ?? getmypid();

        return (string)$this->pid;
    }
}