LoggableRpcClient::invoke() - Code Metrics - Inspection of "Disable logging of request and response bodies by..." - scaytrase/rpc-common - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 98184f...a2057a )

by Pavel

created 2017-05-11 08:05 UTC

LoggableRpcClient::invoke() A

↳ Parent: LoggableRpcClient

Complexity

Conditions	3
Paths	4

Size

Total Lines	17
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	12
CRAP Score	3

Importance

Changes

Metric	Value
dl	0
loc	17
ccs	12
cts	12
cp	1
rs	9.4285
c	0
b	0
f	0
cc	3
eloc	9
nc	4
nop	1
crap	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;
    /**
     * @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);
    }
}


1		<?php
2
3		namespace ScayTrase\Api\Rpc\Decorators;
4
5		use Psr\Log\LoggerInterface;
6		use Psr\Log\NullLogger;
7		use ScayTrase\Api\Rpc\RpcClientInterface;
8		use ScayTrase\Api\Rpc\RpcRequestInterface;
9
10		final class LoggableRpcClient implements RpcClientInterface
11		{
12		/** @var LoggerInterface */
13		private $logger;
14		/** @var RpcClientInterface */
15		private $decoratedClient;
16		/**
17		* @var bool
18		*/
19		private $debug;
20
21		/**
22		* LoggableRpcClient constructor.
23		*
24		* @param RpcClientInterface $decoratedClient
25		* @param LoggerInterface $logger
26		* @param bool $debug
27		*/
28	5	public function __construct(RpcClientInterface $decoratedClient, LoggerInterface $logger = null, $debug = false)
29		{
30	5	$this->decoratedClient = $decoratedClient;
31	5	$this->logger = $logger ?: new NullLogger();
32	5	$this->debug = $debug;
33	5	}
34
35		/** {@inheritdoc} */
36	5	public function invoke($calls)
37		{
38		/** @var RpcRequestInterface[] $loggedCalls */
39	5	$loggedCalls = $calls;
40	5	if (!is_array($loggedCalls)) {
41	2	$loggedCalls = [$loggedCalls];
42	2	}
43
44	5	foreach ($loggedCalls as $call) {
45	5	$this->logger->info(
46	5	sprintf('%s Invoking RPC method "%s"', spl_object_hash($call), $call->getMethod()),
47	5	$this->getContext($call)
48	5	);
49	5	}
50
51	5	return new LoggableResponseCollection($this->decoratedClient->invoke($calls), $this->logger, $this->debug);
52		}
53
54		/**
55		* @param $call
56		*
57		* @return array
58		*/
59	5	private function getContext($call)
60		{
61	5	if (!$this->debug) {
62	4	return [];
63		}
64
65	1	return json_decode(json_encode($call->getParameters()), true);
66		}
67		}
68

scaytrase / rpc-common

Push — master ( 98184f...a2057a )

LoggableRpcClient::invoke() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like