TaskFactory::createTask() - Code Metrics - Inspection of "Async" - teodoroleckie/async - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed

Push — main ( b17b64...c3c525 )

by Teodoro

created 2021-04-23 17:39 UTC

TaskFactory::createTask() A

↳ Parent: TaskFactory

Complexity

Conditions	1
Paths	1

Size

Total Lines	13
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes	4
Bugs	0	Features	0

Metric	Value
cc	1
eloc	6
c	4
b	0
f	0
nc	1
nop	3
dl	0
loc	13
rs	10

<?php

namespace Tleckie\Async;

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

/**
 * Class TaskFactory
 *
 * @package Tleckie\Async
 * @author  Teodoro Leckie Westberg <[email protected]>
 */
class TaskFactory implements TaskFactoryInterface
{
    /** @var int */
    private int $pid = 0;

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

    /** @var string|null */
    private string|null $script = null;
filter:
    dependency_paths: ["lib/*"]

    /** @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());
        return new Task($process, $encoder, /** @scrutinizer ignore-type */ $this->id());
    }

    /**
     * @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;
    }
}


teodoroleckie / async

Push — main ( b17b64...c3c525 )

TaskFactory::createTask() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like