WyriHaximus\React\ChildProcess\PSR3\ChildProcess

Complexity

Total Complexity

7

Size/Duplication

Total Lines	55
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
A	setup()	0	15	3
A	create()	0	4	1
A	log()	0	16	2

<?php declare(strict_types=1);

namespace WyriHaximus\React\ChildProcess\PSR3;

use InvalidArgumentException;
use Psr\Log\LoggerInterface;
use React\EventLoop\LoopInterface;
use React\Promise\PromiseInterface;
use function React\Promise\reject;
use function React\Promise\resolve;
use Throwable;
use WyriHaximus\React\ChildProcess\Messenger\ChildInterface;
use WyriHaximus\React\ChildProcess\Messenger\Messages\Payload;
use WyriHaximus\React\ChildProcess\Messenger\Messenger;

final class ChildProcess implements ChildInterface
{
    /**
     * @var LoggerInterface
     */
    private $logger;

    private function __construct(Messenger $messenger, LoopInterface $loop)

The parameter $loop is not used and could be removed.

    {
        $messenger->registerRpc('logger.setup', function (Payload $payload) {
            return $this->setup($payload);
        });
        $messenger->registerRpc('logger.log', function (Payload $payload) {
            return $this->log($payload);
        });
    }

    private function setup(Payload $payload): PromiseInterface
    {
        try {
            $this->logger = $payload['factory']();
            if (!($this->logger instanceof LoggerInterface)) {
                throw new InvalidArgumentException('Passed logger isn\'t a PSR-3 logger');
            }

            return resolve([
                'success' => true,
            ]);
        } catch (Throwable $throwable) {
            return reject($throwable);
        }
    }

    public static function create(Messenger $messenger, LoopInterface $loop): void
    {
        new static($messenger, $loop);
    }

    private function log(Payload $payload): PromiseInterface
    {
        try {
            $this->logger->log(
                $payload['level'],
                $payload['message'],
                $payload['context']
            );

            return resolve([
                'success' => true,
            ]);
        } catch (Throwable $throwable) {
            return reject($throwable);
        }
    }
}