WyriHaximus\React\ChildProcess\PSR3\ChildProcessLogger

Complexity

Total Complexity

3

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

0%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	log()	0	11	1
A	__construct()	0	10	1
A	create()	0	9	1

<?php declare(strict_types=1);

namespace WyriHaximus\React\ChildProcess\PSR3;

use Psr\Log\LoggerInterface;
use Psr\Log\LoggerTrait;
use React\EventLoop\LoopInterface;
use React\Promise\PromiseInterface;
use WyriHaximus\React\ChildProcess\Messenger\Factory;
use WyriHaximus\React\ChildProcess\Messenger\Messages\Factory as MessageFactory;
use WyriHaximus\React\ChildProcess\Messenger\Messenger;

final class ChildProcessLogger implements LoggerInterface
{
    use LoggerTrait;

    /**
     * @var Messenger
     */
    private $messenger;

    /**
     * @param Messenger $messenger
     * @param string    $factory
     */
    private function __construct(Messenger $messenger, string $factory)
    {
        $this->messenger = $messenger;
        $this->messenger->rpc(MessageFactory::rpc(
            'logger.setup',
            [
                'factory' => $factory,
            ]
        ))->done();
    }

    public static function create(LoopInterface $loop, string $factory): PromiseInterface
    {
        return Factory::parentFromClass(
            ChildProcess::class,
            $loop
        )->then(function (Messenger $messenger) use ($factory) {
            return new self($messenger, $factory);
        });
    }

    /**
     * @param mixed  $level
     * @param string $message
     * @param array  $context
     */
    public function log($level, $message, array $context = []): void
    {
        $this->messenger->rpc(MessageFactory::rpc(
            'logger.log',
            [
                'level'   => $level,
                'message' => $message,
                'context' => $context,
            ]
        ))->done();
    }
}