Bankiru\Api\Doctrine\Test\TestApi

Complexity

Total Complexity

13

Size/Duplication

Total Lines	119
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes

0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	createApi()	0	4	1
A	count()	0	6	1
A	create()	0	6	1
A	find()	0	14	2
A	patch()	0	6	1
A	search()	0	14	1
A	remove()	0	6	1
A	getClient()	0	4	1
A	getMetadata()	0	4	1
A	setEntityCache()	0	4	1
A	getMethod()	0	4	1

<?php

namespace Bankiru\Api\Doctrine\Test;

use Bankiru\Api\Doctrine\ApiFactory\StaticApiFactoryInterface;
use Bankiru\Api\Doctrine\Cache\EntityCacheAwareInterface;
use Bankiru\Api\Doctrine\Cache\VoidEntityCache;
use Bankiru\Api\Doctrine\EntityDataCacheInterface;
use Bankiru\Api\Doctrine\Mapping\ApiMetadata;
use Bankiru\Api\Doctrine\Rpc\CrudsApiInterface;
use Bankiru\Api\Doctrine\Rpc\RpcRequest;
use ScayTrase\Api\Rpc\RpcClientInterface;

final class TestApi implements CrudsApiInterface, StaticApiFactoryInterface, EntityCacheAwareInterface
{
    /** @var RpcClientInterface */
    private $client;
    /** @var ApiMetadata */
    private $metadata;
    /** @var EntityDataCacheInterface */
    private $cache;

    /**
     * TestApi constructor.
     *
     * @param RpcClientInterface $client
     * @param ApiMetadata        $metadata
     */
    public function __construct(RpcClientInterface $client, ApiMetadata $metadata)
    {
        $this->client   = $client;
        $this->metadata = $metadata;
        $this->cache    = new VoidEntityCache($metadata);
    }

    public static function createApi(RpcClientInterface $client, ApiMetadata $metadata)
    {
        return new static($client, $metadata);
    }

    /** {@inheritdoc} */
    public function count(array $criteria)
    {
        $request = new RpcRequest($this->getMethod('count'), ['criteria' => $criteria]);

        return (int)$this->client->invoke($request)->getResponse($request)->getBody();
    }

    /** {@inheritdoc} */
    public function create(array $data)
    {
        $request = new RpcRequest($this->getMethod('create'), $data);

        return $this->client->invoke($request)->getResponse($request)->getBody();
    }

    /** {@inheritdoc} */
    public function find(array $identifier)
    {
        $body = $this->cache->get($identifier);

        if (null !== $body) {
            return $body;
        }

        $request = new RpcRequest($this->getMethod('find'), $identifier);
        $body    = $this->client->invoke($request)->getResponse($request)->getBody();
        $this->cache->set($identifier, $body);

        return $body;
    }

    /** {@inheritdoc} */
    public function patch(array $identifier, array $data, array $fields)
    {
        $request = new RpcRequest($this->getMethod('patch'), array_intersect_key($data, array_flip($fields)));

        return $this->client->invoke($request)->getResponse($request)->isSuccessful();
    }

    /** {@inheritdoc} */
    public function search(array $criteria = [], array $orderBy = null, $limit = null, $offset = null)
    {
        $request = new RpcRequest(
            $this->getMethod('search'),
            [
                'criteria' => $criteria,
                'order'    => $orderBy,
                'limit'    => $limit,
                'offset'   => $offset,
            ]
        );

        return new \ArrayIterator($this->client->invoke($request)->getResponse($request)->getBody());
    }

    /** {@inheritdoc} */
    public function remove(array $identifier)
    {
        $request = new RpcRequest($this->getMethod('remove'), $identifier);

        return $this->client->invoke($request)->getResponse($request)->isSuccessful();
    }

    /** @return RpcClientInterface */
    public function getClient()
    {
        return $this->client;
    }

    /** @return ApiMetadata */
    public function getMetadata()
    {
        return $this->metadata;
    }

    /** {@inheritdoc} */
    public function setEntityCache(EntityDataCacheInterface $cache)
    {
        $this->cache = $cache;
    }

    /**
     * @param string $method
     *
     * @return string
     */
    private function getMethod($method)
    {
        return $this->metadata->getMethodContainer()->getMethod($method);
    }
}