ScayTrase\Api\Rpc\Decorators\ProfiledClientStorage

Complexity

Total Complexity

10

Size/Duplication

Total Lines	92
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	registerCalls()	0	12	3
A	registerResponse()	0	13	2
A	getFullPairs()	0	9	1
A	getUnmatchedRequestPairs()	0	9	1
A	getUnmatchedResponsePairs()	0	4	1
A	getClientName()	0	4	1

<?php

namespace ScayTrase\Api\Rpc\Decorators;

use ScayTrase\Api\Rpc\RpcRequestInterface;
use ScayTrase\Api\Rpc\RpcResponseInterface;

final class ProfiledClientStorage
{
    /** @var array[] */
    private $pairs = [];
    /** @var array[] */
    private $unmatchedResponse = [];
    /** @var  string */
    private $clientName;

    /**
     * RpcProfiler constructor.
     *
     * @param string $clientName
     */
    public function __construct($clientName)
    {
        $this->clientName = (string)$clientName;
    }

    /**
     * @param RpcRequestInterface|RpcRequestInterface[] $calls
     */
    public function registerCalls($calls)
    {
        if (!is_array($calls)) {
            $calls = [$calls];
        }

        $time = microtime(true);
        foreach ($calls as $call) {
            $this->pairs[spl_object_hash($call)]['start']   = $time;
            $this->pairs[spl_object_hash($call)]['request'] = $call;
        }
    }

    /**
     * @param RpcResponseInterface $response
     * @param RpcRequestInterface  $request
     */
    public function registerResponse(RpcResponseInterface $response, RpcRequestInterface $request = null)
    {
        $time = microtime(true);

        if (null === $request) {
            $this->unmatchedResponse[]['response'] = $response;

            return;
        }

        $this->pairs[spl_object_hash($request)]['stop']     = $time;
        $this->pairs[spl_object_hash($request)]['response'] = $response;
    }

    /**
     * @return array[]
     */
    public function getFullPairs()
    {
        return array_filter(
            $this->pairs,
            function (array $row) {
                return isset($row['response']);
            }
        );
    }

    public function getUnmatchedRequestPairs()
    {
        return array_filter(
            $this->pairs,
            function (array $row) {
                return !isset($row['response']);
            }
        );
    }

    /**
     * @return array[]
     */
    public function getUnmatchedResponsePairs()
    {
        return $this->unmatchedResponse;
    }

    /**
     * @return string
     */
    public function getClientName()
    {
        return $this->clientName;
    }
}