ApiPersister::loadById() - Code Metrics - Inspection of "[WIP] Release 2.0" - bankiru/doctrine-api-client - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Pull Request — master (#14)

by Pavel

created 2017-04-28 10:11 UTC

ApiPersister::loadById() A

↳ Parent: ApiPersister

Complexity

Conditions	2
Paths	2

Size

Total Lines	10
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	4
CRAP Score	2.032

Importance

Changes

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

<?php

namespace Bankiru\Api\Doctrine\Persister;

use Bankiru\Api\Doctrine\ApiEntityManager;
use Bankiru\Api\Doctrine\Dehydration\PatchDehydrator;
use Bankiru\Api\Doctrine\Dehydration\SearchDehydrator;
use Bankiru\Api\Doctrine\Mapping\EntityMetadata;
use Bankiru\Api\Doctrine\Proxy\ApiCollection;
use Bankiru\Api\Doctrine\Rpc\CrudsApiInterface;
use Doctrine\Common\Collections\AbstractLazyCollection;

/** @internal */
final class ApiPersister implements EntityPersister
{
    /** @var  EntityMetadata */
    private $metadata;
    /** @var ApiEntityManager */
    private $manager;
    /** @var CrudsApiInterface */
    private $api;
    /** @var array */
    private $pendingInserts = [];
    /** @var SearchDehydrator */
    private $searchDehydrator;
    /** @var PatchDehydrator */
    private $patchDehydrator;

    /**
     * ApiPersister constructor.
     *
     * @param ApiEntityManager  $manager
     * @param CrudsApiInterface $api
     */
    public function __construct(ApiEntityManager $manager, CrudsApiInterface $api)
    {
        $this->manager          = $manager;
        $this->metadata         = $api->getMetadata();
        $this->api              = $api;
        $this->searchDehydrator = new SearchDehydrator($this->metadata, $this->manager);
        $this->patchDehydrator  = new PatchDehydrator($this, $this->metadata, $this->manager);
    }

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

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

    /** {@inheritdoc} */
    public function update($entity)
    {
        $patch = $this->patchDehydrator->prepareUpdateData($entity);
        $data  = $this->patchDehydrator->convertEntityToData($entity);

        $this->api->patch($this->searchDehydrator->transformIdentifier($entity), $patch, $data);
    }

    /** {@inheritdoc} */
    public function delete($entity)
    {
        return $this->api->remove($this->searchDehydrator->transformIdentifier($entity));
    }

    /** {@inheritdoc} */
    public function count($criteria = [])
    {
        return $this->api->count($this->searchDehydrator->transformCriteria($criteria));
    }

    /** {@inheritdoc} */
    public function loadAll(array $criteria = [], array $orderBy = null, $limit = null, $offset = null)
    {
        $objects = $this->api->search(
            $this->searchDehydrator->transformCriteria($criteria),
            $this->searchDehydrator->transformOrder($orderBy),
            $limit,
            $offset
        );

        $entities = [];
        foreach ($objects as $object) {
            $entities[] = $this->manager->getUnitOfWork()->getOrCreateEntity($this->metadata->getName(), $object);
        }

        return $entities;
    }

    /** {@inheritdoc} */
    public function loadOneToOneEntity(array $assoc, $sourceEntity, array $identifier = [])
    {
        if (false !== ($foundEntity = $this->manager->getUnitOfWork()->tryGetById($identifier, $assoc['target']))) {
            return $foundEntity;
        }

        // Get identifiers from entity if the entity is not the owning side
        if (!$assoc['isOwningSide']) {
            $identifier = $this->metadata->getIdentifierValues($sourceEntity);
        }

        return $this->loadById($identifier);
    }

    /** {@inheritdoc} */
    public function loadById(array $identifiers, $entity = null)
    {
        $body = $this->api->find($this->searchDehydrator->transformFields($identifiers));

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

        return $this->manager->getUnitOfWork()->getOrCreateEntity($this->metadata->getName(), $body);
    }

    /** {@inheritdoc} */
    public function refresh(array $id, $entity)
    {
        $this->loadById($id, $entity);
    }

    /** {@inheritdoc} */
    public function loadOneToManyCollection(array $assoc, $sourceEntity, AbstractLazyCollection $collection)
    {
        $criteria = [
            $assoc['mappedBy'] => $sourceEntity,
        ];

        $orderBy = isset($assoc['orderBy']) ? $assoc['orderBy'] : [];

        $source = $this->api->search(
            $this->searchDehydrator->transformCriteria($criteria),
            $this->searchDehydrator->transformOrder($orderBy)
        );

        $target = $this->manager->getClassMetadata($assoc['target']);

        foreach ($source as $object) {
            $entity = $this->manager->getUnitOfWork()->getOrCreateEntity($target->getName(), $object);
            if (isset($assoc['orderBy'])) {
                $index = $target->getReflectionProperty($assoc['orderBy'])->getValue($entity);
                $collection->set($index, $entity);
            } else {
                $collection->add($entity);
            }

            $target->getReflectionProperty($assoc['mappedBy'])->setValue($entity, $sourceEntity);
        }

        return $collection;
    }

    /** {@inheritdoc} */
    public function getOneToManyCollection(array $assoc, $sourceEntity, $limit = null, $offset = null)
    {
        $targetClass = $assoc['target'];
        /** @var EntityMetadata $targetMetadata */
        $targetMetadata = $this->manager->getClassMetadata($targetClass);

        if ($this->metadata->isIdentifierComposite) {
            throw new \BadMethodCallException(__METHOD__ . ' on composite reference is not supported');
        }

        $apiCollection = new ApiCollection($this->manager, $targetMetadata);
        $apiCollection->setOwner($sourceEntity, $assoc);
        $apiCollection->setInitialized(false);

        return $apiCollection;
    }

    /** {@inheritdoc} */
    public function getToOneEntity(array $mapping, $sourceEntity, array $identifiers)
    {
        $metadata = $this->manager->getClassMetadata(get_class($sourceEntity));

        if (!$mapping['isOwningSide']) {
            $identifiers = $metadata->getIdentifierValues($sourceEntity);
        }

        return $this->manager->getReference($mapping['target'], $identifiers);
    }

    public function pushNewEntity($entity)
    {
        $this->pendingInserts[spl_object_hash($entity)] = $entity;
    }

    public function flushNewEntities()
    {
        $result = [];
        foreach ($this->pendingInserts as $entity) {
            $result[] = [
                'generatedId' => $this->getCrudsApi()->create($this->patchDehydrator->convertEntityToData($entity)),
                'entity'      => $entity,
            ];
        }

        $this->pendingInserts = [];

        if ($this->metadata->isIdentifierNatural()) {
            return [];
        }

        return $result;
    }

    /** {@inheritdoc} */
    public function hasPendingUpdates($oid)
    {
        return isset($this->pendingInserts[$oid]);
    }
}


1		<?php
2
3		namespace Bankiru\Api\Doctrine\Persister;
4
5		use Bankiru\Api\Doctrine\ApiEntityManager;
6		use Bankiru\Api\Doctrine\Dehydration\PatchDehydrator;
7		use Bankiru\Api\Doctrine\Dehydration\SearchDehydrator;
8		use Bankiru\Api\Doctrine\Mapping\EntityMetadata;
9		use Bankiru\Api\Doctrine\Proxy\ApiCollection;
10		use Bankiru\Api\Doctrine\Rpc\CrudsApiInterface;
11		use Doctrine\Common\Collections\AbstractLazyCollection;
12
13		/** @internal */
14		final class ApiPersister implements EntityPersister
15		{
16		/** @var EntityMetadata */
17		private $metadata;
18		/** @var ApiEntityManager */
19		private $manager;
20		/** @var CrudsApiInterface */
21		private $api;
22		/** @var array */
23		private $pendingInserts = [];
24		/** @var SearchDehydrator */
25		private $searchDehydrator;
26		/** @var PatchDehydrator */
27		private $patchDehydrator;
28
29		/**
30		* ApiPersister constructor.
31		*
32		* @param ApiEntityManager $manager
33		* @param CrudsApiInterface $api
34		*/
35	22	public function __construct(ApiEntityManager $manager, CrudsApiInterface $api)
36		{
37	22	$this->manager = $manager;
38	22	$this->metadata = $api->getMetadata();
39	22	$this->api = $api;
40	22	$this->searchDehydrator = new SearchDehydrator($this->metadata, $this->manager);
41	22	$this->patchDehydrator = new PatchDehydrator($this, $this->metadata, $this->manager);
42	22	}
43
44		/** {@inheritdoc} */
45		public function getClassMetadata()
46		{
47		return $this->metadata;
48		}
49
50		/** {@inheritdoc} */
51	6	public function getCrudsApi()
52		{
53	6	return $this->api;
54		}
55
56		/** {@inheritdoc} */
57	2	public function update($entity)
58		{
59	2	$patch = $this->patchDehydrator->prepareUpdateData($entity);
60	2	$data = $this->patchDehydrator->convertEntityToData($entity);
61
62	2	$this->api->patch($this->searchDehydrator->transformIdentifier($entity), $patch, $data);
63	2	}
64
65		/** {@inheritdoc} */
66	1	public function delete($entity)
67		{
68	1	return $this->api->remove($this->searchDehydrator->transformIdentifier($entity));
69		}
70
71		/** {@inheritdoc} */
72	1	public function count($criteria = [])
73		{
74	1	return $this->api->count($this->searchDehydrator->transformCriteria($criteria));
75		}
76
77		/** {@inheritdoc} */
78	5	public function loadAll(array $criteria = [], array $orderBy = null, $limit = null, $offset = null)
79		{
80	5	$objects = $this->api->search(
81	5	$this->searchDehydrator->transformCriteria($criteria),
82	5	$this->searchDehydrator->transformOrder($orderBy),
83	5	$limit,
84		$offset
85	5	);
86
87	5	$entities = [];
88	5	foreach ($objects as $object) {
89	5	$entities[] = $this->manager->getUnitOfWork()->getOrCreateEntity($this->metadata->getName(), $object);
90	5	}
91
92	5	return $entities;
93		}
94
95		/** {@inheritdoc} */
96		public function loadOneToOneEntity(array $assoc, $sourceEntity, array $identifier = [])
97		{
98		if (false !== ($foundEntity = $this->manager->getUnitOfWork()->tryGetById($identifier, $assoc['target']))) {
99		return $foundEntity;
100		}
101
102		// Get identifiers from entity if the entity is not the owning side
103		if (!$assoc['isOwningSide']) {
104		$identifier = $this->metadata->getIdentifierValues($sourceEntity);
105		}
106
107		return $this->loadById($identifier);
108		}
109
110		/** {@inheritdoc} */
111	11	public function loadById(array $identifiers, $entity = null)
112		{
113	11	$body = $this->api->find($this->searchDehydrator->transformFields($identifiers));
114
115	11	if (null === $body) {
116		return null;
117		}
118
119	11	return $this->manager->getUnitOfWork()->getOrCreateEntity($this->metadata->getName(), $body);
120		}
121
122		/** {@inheritdoc} */
123		public function refresh(array $id, $entity)
124		{
125		$this->loadById($id, $entity);
126		}
127
128		/** {@inheritdoc} */
129	2	public function loadOneToManyCollection(array $assoc, $sourceEntity, AbstractLazyCollection $collection)
130		{
131		$criteria = [
132	2	$assoc['mappedBy'] => $sourceEntity,
133	2	];
134
135	2	$orderBy = isset($assoc['orderBy']) ? $assoc['orderBy'] : [];
136
137	2	$source = $this->api->search(
138	2	$this->searchDehydrator->transformCriteria($criteria),
139	2	$this->searchDehydrator->transformOrder($orderBy)
140	2	);
141
142	2	$target = $this->manager->getClassMetadata($assoc['target']);
143
144	2	foreach ($source as $object) {
145	2	$entity = $this->manager->getUnitOfWork()->getOrCreateEntity($target->getName(), $object);
146	2	if (isset($assoc['orderBy'])) {
147		$index = $target->getReflectionProperty($assoc['orderBy'])->getValue($entity);
148		$collection->set($index, $entity);
149		} else {
150	2	$collection->add($entity);
151		}
152
153	2	$target->getReflectionProperty($assoc['mappedBy'])->setValue($entity, $sourceEntity);
154	2	}
155
156	2	return $collection;
157		}
158
159		/** {@inheritdoc} */
160	10	public function getOneToManyCollection(array $assoc, $sourceEntity, $limit = null, $offset = null)
161		{
162	10	$targetClass = $assoc['target'];
163		/** @var EntityMetadata $targetMetadata */
164	10	$targetMetadata = $this->manager->getClassMetadata($targetClass);
165
166	10	if ($this->metadata->isIdentifierComposite) {
167		throw new \BadMethodCallException(__METHOD__ . ' on composite reference is not supported');
168		}
169
170	10	$apiCollection = new ApiCollection($this->manager, $targetMetadata);
171	10	$apiCollection->setOwner($sourceEntity, $assoc);
172	10	$apiCollection->setInitialized(false);
173
174	10	return $apiCollection;
175		}
176
177		/** {@inheritdoc} */
178	5	public function getToOneEntity(array $mapping, $sourceEntity, array $identifiers)
179		{
180	5	$metadata = $this->manager->getClassMetadata(get_class($sourceEntity));
181
182	5	if (!$mapping['isOwningSide']) {
183		$identifiers = $metadata->getIdentifierValues($sourceEntity);
184		}
185
186	5	return $this->manager->getReference($mapping['target'], $identifiers);
187		}
188
189	6	public function pushNewEntity($entity)
190		{
191	6	$this->pendingInserts[spl_object_hash($entity)] = $entity;
192	6	}
193
194	6	public function flushNewEntities()
195		{
196	6	$result = [];
197	6	foreach ($this->pendingInserts as $entity) {
198	6	$result[] = [
199	6	'generatedId' => $this->getCrudsApi()->create($this->patchDehydrator->convertEntityToData($entity)),
200	6	'entity' => $entity,
201		];
202	6	}
203
204	6	$this->pendingInserts = [];
205
206	6	if ($this->metadata->isIdentifierNatural()) {
207		return [];
208		}
209
210	6	return $result;
211		}
212
213		/** {@inheritdoc} */
214	1	public function hasPendingUpdates($oid)
215		{
216	1	return isset($this->pendingInserts[$oid]);
217		}
218		}
219

bankiru / doctrine-api-client

Pull Request — master (#14)

ApiPersister::loadById() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like