RpcMockClient::getQueue() - Code Metrics - scaytrase/rpc-common - Measure and Improve Code Quality continuously with Scrutinizer

RpcMockClient::getQueue() A
last analyzed 2017-06-27 08:43 UTC

↳ Parent: RpcMockClient

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	2
CRAP Score	1

Importance

Changes

Metric	Value
dl	0
loc	4
ccs	2
cts	2
cp	1
rs	10
c	0
b	0
f	0
cc	1
eloc	2
nc	1
nop	0
crap	1

<?php

namespace ScayTrase\Api\Rpc\Test;

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

final class RpcMockClient implements RpcClientInterface, \Countable
{
    private $queue = [];

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

        $tuples = [];
        foreach ((array)$calls as $call) {
            $tuples[] = [
                'request'  => $call,
                'response' => $this->call($call),
            ];
        }

        return new TupleCollection($tuples);
    }

    public function push(RpcResponseInterface $response, callable $filter = null)
    {
        $this->queue[] = [$response, $filter];
    }

    /**
     * @return array
     */
    public function getQueue()
    {
        return $this->queue;
    }

    /** {@inheritdoc} */
    public function count()
    {
        return count($this->queue);
    }

    private function call(RpcRequestInterface $request)
    {
        $tip = array_shift($this->queue);

        if (null === $tip) {
            throw MockClientException::emptyQueue($request);
        }

        list($response, $filter) = $tip;

        if (is_callable($filter) && !$filter($request)) {
            throw MockClientException::filterFailed($request, $response);
        }

        return $response;
    }
}


1		<?php
2
3		namespace ScayTrase\Api\Rpc\Test;
4
5		use ScayTrase\Api\Rpc\RpcClientInterface;
6		use ScayTrase\Api\Rpc\RpcRequestInterface;
7		use ScayTrase\Api\Rpc\RpcResponseInterface;
8
9		final class RpcMockClient implements RpcClientInterface, \Countable
10		{
11		private $queue = [];
12
13		/** {@inheritdoc} */
14	13	public function invoke($calls)
15		{
16	13	if (!is_array($calls)) {
17	8	$calls = [$calls];
18	8	}
19
20	13	$tuples = [];
21	13	foreach ((array)$calls as $call) {
22	11	$tuples[] = [
23	13	'request' => $call,
24	13	'response' => $this->call($call),
25		];
26	11	}
27
28	11	return new TupleCollection($tuples);
29		}
30
31	14	public function push(RpcResponseInterface $response, callable $filter = null)
32		{
33	14	$this->queue[] = [$response, $filter];
34	14	}
35
36		/**
37		* @return array
38		*/
39	1	public function getQueue()
40		{
41	1	return $this->queue;
42		}
43
44		/** {@inheritdoc} */
45	3	public function count()
46		{
47	3	return count($this->queue);
48		}
49
50	13	private function call(RpcRequestInterface $request)
51		{
52	13	$tip = array_shift($this->queue);
53
54	13	if (null === $tip) {
55	2	throw MockClientException::emptyQueue($request);
56		}
57
58	13	list($response, $filter) = $tip;
59
60	13	if (is_callable($filter) && !$filter($request)) {
61	2	throw MockClientException::filterFailed($request, $response);
62		}
63
64	11	return $response;
65		}
66		}
67

scaytrase / rpc-common

RpcMockClient::getQueue() A last analyzed 2017-06-27 08:43 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

RpcMockClient::getQueue() A
last analyzed 2017-06-27 08:43 UTC