bankiru / doctrine-api-client

Test/TestApi.php

<?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 ScayTrase\Api\Rpc\RpcClientInterface;

final class TestApi implements CrudsApiInterface, EntityCacheAwareInterface, StaticApiFactoryInterface
{
    /** @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);
    }

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

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

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

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

        $id = $this->client->invoke($request)->getResponse($request)->getBody();

        if ($this->getMetadata()->isIdentifierNatural()) {
            return null;
        }

        return is_scalar($id) ? $id : (object)$id;
    }

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

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

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

        return $body;
    }

    /** {@inheritdoc} */
    public function patch(array $identifier, array $patch, array $data)
    {
        $request = new RpcRequestMock($this->getMethod('patch'), ['identifier' => $identifier, 'patch' => $patch]);

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

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

        $data = $this->client->invoke($request)->getResponse($request)->getBody();
        foreach ((array)$data as &$item) {

The expression (array) $data cannot be used as a reference.

            $item = (object)$item;
        }

        return new \ArrayIterator($data);
    }

    /** {@inheritdoc} */
    public function remove(array $identifier)
    {
        $request = new RpcRequestMock($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);
    }
}