RpcMockClient::push() - Code Metrics - Inspection of "Add PHP 7.1 to test matrix" - scaytrase/rpc-common - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( f61680...98184f )

by Pavel

created 2017-04-28 18:45 UTC

RpcMockClient::push() A

↳ Parent: RpcMockClient

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	3
CRAP Score	1

Importance

Changes

Metric	Value
dl	0
loc	4
ccs	3
cts	3
cp	1
rs	10
c	0
b	0
f	0
cc	1
eloc	2
nc	1
nop	2
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	6	public function invoke($calls)
15		{
16	6	if (!is_array($calls)) {
17	6	$calls = [$calls];
18	6	}
19
20	6	$tuples = [];
21	6	foreach ((array)$calls as $call) {
22	4	$tuples[] = [
23	6	'request' => $call,
24	6	'response' => $this->call($call),
25		];
26	4	}
27
28	4	return new TupleCollection($tuples);
29		}
30
31	6	public function push(RpcResponseInterface $response, callable $filter = null)
32		{
33	6	$this->queue[] = [$response, $filter];
34	6	}
35
36		/**
37		* @return array
38		*/
39	1	public function getQueue()
40		{
41	1	return $this->queue;
42		}
43
44		/** {@inheritdoc} */
45	1	public function count()
46		{
47	1	return count($this->queue);
48		}
49
50	6	private function call(RpcRequestInterface $request)
51		{
52	6	$tip = array_shift($this->queue);
53
54	6	if (null === $tip) {
55	2	throw MockClientException::emptyQueue($request);
56		}
57
58	6	list($response, $filter) = $tip;
59
60	6	if (is_callable($filter) && !$filter($request)) {
61	2	throw MockClientException::filterFailed($request, $response);
62		}
63
64	4	return $response;
65		}
66		}
67

scaytrase / rpc-common

Push — master ( f61680...98184f )

RpcMockClient::push() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like