ScayTrase\Api\Rpc\Test\RpcMockClient

Complexity

Total Complexity

10

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

92.31%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	invoke()	0	16	3
A	push()	0	4	1
A	getQueue()	0	4	1
A	count()	0	4	1
A	call()	0	16	4

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