ScayTrase\Api\Rpc\Decorators\LoggableRpcClient

Complexity

Total Complexity

5

Size/Duplication

Total Lines	38
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	2
A	invoke()	0	17	3

<?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;

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

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

        foreach ($loggedCalls as $call) {
            $this->logger->debug(
                sprintf('%s Invoking RPC method "%s"', spl_object_hash($call), $call->getMethod()),
                json_decode(json_encode($call->getParameters()), true)
            );
        }

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