ScayTrase\Api\Rpc\Decorators\LoggableRpcClient

Complexity

Total Complexity

7

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	2
A	invoke()	0	17	3
A	getContext()	0	8	2

<?php

namespace ScayTrase\Api\Rpc\Decorators;

use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;
use ScayTrase\Api\Rpc\RpcClientInterface;
use ScayTrase\Api\Rpc\RpcRequestInterface;

final class LoggableRpcClient implements RpcClientInterface
{
    /** @var  LoggerInterface */
    private $logger;
    /** @var  RpcClientInterface */
    private $decoratedClient;
    /**
     * @var bool
     */
    private $debug;

    /**
     * LoggableRpcClient constructor.
     *
     * @param RpcClientInterface $decoratedClient
     * @param LoggerInterface    $logger
     * @param bool               $debug
     */
    public function __construct(RpcClientInterface $decoratedClient, LoggerInterface $logger = null, $debug = false)
    {
        $this->decoratedClient = $decoratedClient;
        $this->logger          = $logger ?: new NullLogger();
        $this->debug           = $debug;
    }

    /** {@inheritdoc} */
    public function invoke($calls)
    {
        /** @var RpcRequestInterface[] $loggedCalls */
        $loggedCalls = $calls;
        if (!is_array($loggedCalls)) {
            $loggedCalls = [$loggedCalls];
        }

        foreach ($loggedCalls as $call) {
            $this->logger->info(
                sprintf('%s Invoking RPC method "%s"', spl_object_hash($call), $call->getMethod()),
                $this->getContext($call)
            );
        }

        return new LoggableResponseCollection($this->decoratedClient->invoke($calls), $this->logger, $this->debug);
    }

    /**
     * @param $call
     *
     * @return array
     */
    private function getContext($call)
    {
        if (!$this->debug) {
            return [];
        }

        return json_decode(json_encode($call->getParameters()), true);
    }
}