UnitOfWork::addIdentifiers() - Code Metrics - Inspection of "Merge pull request #74 from mapado/jd-feat-prettie..." - mapado/rest-client-sdk - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 685595...680e76 )

by Julien

created 2018-04-10 14:58 UTC

UnitOfWork::addIdentifiers() B

↳ Parent: UnitOfWork

Complexity

Conditions	6
Paths	4

Size

Total Lines	14
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	6
CRAP Score	6

Importance

Changes

Metric	Value
cc	6
eloc	6
nc	4
nop	3
dl	0
loc	14
ccs	6
cts	6
cp	1
crap	6
rs	8.8571
c	0
b	0
f	0

<?php

namespace Mapado\RestClientSdk;

use Mapado\RestClientSdk\Helper\ArrayHelper;
use Mapado\RestClientSdk\Mapping\ClassMetadata;
use Mapado\RestClientSdk\Mapping\Relation;

/**
 * UnitOfWork
 */
class UnitOfWork
{
    /**
     * mapping
     *
     * @var Mapping
     */
    private $mapping;

    /**
     * storage for every entity retrieved
     *
     * @var array
     */
    private $storage;

    /**
     * Constructor.
     */
    public function __construct(Mapping $mapping)
    {
        $this->mapping = $mapping;
        $this->storage = [];
    }

    /**
     * getDirtyData
     *
     * return the new serialized model with only needed fields to update
     *
     * @param array $newSerializedModel
     * @param array $oldSerializedModel
     * @param ClassMetadata $classMetadata
     *
     * @return array
     */
    public function getDirtyData(
        array $newSerializedModel,
        array $oldSerializedModel,
        ClassMetadata $classMetadata
    ) {
        return $this->getDirtyFields(
            $newSerializedModel,
            $oldSerializedModel,
            $classMetadata
        );
    }

    /**
     * registerClean
     *
     * @param string $id
     * @param object $entity
     *
     * @return UnitOfWork
     */
    public function registerClean($id, $entity)
    {
        if (is_object($entity)) {
            $entityStored = clone $entity;
            $this->storage[$id] = $entityStored;
        }

        return $this;
    }

    /**
     * getDirtyEntity
     *
     * @param string $id
     *
     * @return mixed
     */
    public function getDirtyEntity($id)
    {
        if (isset($this->storage[$id])) {
            return $this->storage[$id];
        }

        return;
    }

    /**
     * clear
     *
     * @param string $id
     *
     * @return UnitOfWork
     */
    public function clear($id)
    {
        unset($this->storage[$id]);

        return $this;
    }

    /**
     * getDirtyFields
     *
     * compares serialize object and returns only modified fields
     *
     * @param array $newSerializedModel
     * @param array $oldSerializedModel
     * @param ClassMetadata $classMetadata
     *
     * @return array
     */
    private function getDirtyFields(
        array $newSerializedModel,
        array $oldSerializedModel,
        ClassMetadata $classMetadata
    ) {
        $dirtyFields = [];

        foreach ($newSerializedModel as $key => $value) {
            if (!array_key_exists($key, $oldSerializedModel)) {
                // a new key has been found, add it to the dirtyFields
                $dirtyFields[$key] = $value;
                continue;
            }

            $oldValue = $oldSerializedModel[$key];

            $currentRelation = $classMetadata
                ? $classMetadata->getRelation($key)
                : null;

            if (!$currentRelation) {
                if (
                    is_array($value) &&

                    !ArrayHelper::arraySame($value, $oldValue ?: []) ||
                    $value !== $oldValue
                ) {
                    $dirtyFields[$key] = $value;
                }
                continue;
            }

            $currentClassMetadata = $this->mapping->getClassMetadata(
                $currentRelation->getTargetEntity()
            );

            $idSerializedKey = $currentClassMetadata
                ? $currentClassMetadata->getIdSerializeKey()
                : null;

            if (Relation::MANY_TO_ONE === $currentRelation->getType()) {
                if ($value !== $oldValue) {
                    if (is_string($value) || is_string($oldValue)) {
                        $dirtyFields[$key] = $value;
                    } else {
                        $recursiveDiff = $this->getDirtyFields(
                            $value,
                            $oldValue,
                            $currentClassMetadata
                        );

                        if (!empty($recursiveDiff)) {
                            $recursiveDiff[
                                $idSerializedKey
                            ] = self::getEntityId($value, $idSerializedKey);
                            $dirtyFields[$key] = $recursiveDiff;
                        }
                    }
                }

                continue;
            }

            // ONE_TO_MANY relation
            if (count($value ?? []) !== count($oldValue ?? [])) {
                // get all objects ids of new array
                $dirtyFields[$key] = $this->addIdentifiers(
                    $value,
                    [],
                    $idSerializedKey
                );
            }

            if (!empty($value)) {
                foreach ($value as $relationKey => $relationValue) {
                    $oldRelationValue = $this->findOldRelation(
                        $relationValue,
                        $oldValue,
                        $currentClassMetadata
                    );

                    if ($relationValue !== $oldRelationValue) {
                        if (
                            is_string($relationValue) ||
                            is_string($oldRelationValue)
                        ) {
                            $dirtyFields[$key][$relationKey] = $relationValue;
                        } else {
                            $recursiveDiff = $this->getDirtyFields(
                                $relationValue,
                                $oldRelationValue,
                                $currentClassMetadata
                            );

                            if (!empty($recursiveDiff)) {
                                $idSerializedKey = $currentClassMetadata->getIdSerializeKey();

                                $entityId = self::getEntityId(
                                    $relationValue,
                                    $idSerializedKey
                                );
                                if (null !== $entityId) {
                                    $recursiveDiff[
                                        $idSerializedKey
                                    ] = $entityId;
                                }
                                $dirtyFields[$key][
                                    $relationKey
                                ] = $recursiveDiff;
                            }
                        }
                    }
                }
            }
        }

        return $dirtyFields;
    }

    /**
     * addIdentifiers
     *
     * add defined identifiers to given model
     *
     * @param array $newSerializedModel
     * @param array $dirtyFields
     *
     * @return array
     */
    private function addIdentifiers(
        $newSerializedModel,
        $dirtyFields,
        $idSerializedKey = null
    ) {
        foreach ($newSerializedModel as $key => $value) {
            if ($idSerializedKey && isset($value[$idSerializedKey])) {
                $dirtyFields[$key][$idSerializedKey] = $value[$idSerializedKey];
            } elseif (is_string($value) && is_int($key)) {
                $dirtyFields[$key] = $value;
            }
        }

        return $dirtyFields;
    }

    private function findOldRelation(
        $relationValue,
        array $oldValue,
        ClassMetadata $classMetadata
    ) {
        $idSerializedKey = $classMetadata->getIdSerializeKey();

        $relationValueId = self::getEntityId($relationValue, $idSerializedKey);

        foreach ($oldValue as $oldRelationValue) {
            $oldRelationValueId = self::getEntityId(
                $oldRelationValue,
                $idSerializedKey
            );

            if ($relationValueId === $oldRelationValueId) {
                return $oldRelationValue;
            }
        }

        return $classMetadata->getDefaultSerializedModel();
    }

    /**
     * get entity id from string or array
     *
     * @param mixed $stringOrEntity
     * @param string $idSerializedKey
     */
    private static function getEntityId($stringOrEntity, $idSerializedKey)
    {
        if (!is_array($stringOrEntity)) {
            return $stringOrEntity;
        }

        return $stringOrEntity[$idSerializedKey] ?? null;
    }
}


1		<?php
2
3		namespace Mapado\RestClientSdk;
4
5		use Mapado\RestClientSdk\Helper\ArrayHelper;
6		use Mapado\RestClientSdk\Mapping\ClassMetadata;
7		use Mapado\RestClientSdk\Mapping\Relation;
8
9		/**
10		* UnitOfWork
11		*/
12		class UnitOfWork
13		{
14		/**
15		* mapping
16		*
17		* @var Mapping
18		*/
19		private $mapping;
20
21		/**
22		* storage for every entity retrieved
23		*
24		* @var array
25		*/
26		private $storage;
27
28		/**
29		* Constructor.
30		*/
31		public function __construct(Mapping $mapping)
32		{
33	1	$this->mapping = $mapping;
34	1	$this->storage = [];
35	1	}
36
37		/**
38		* getDirtyData
39		*
40		* return the new serialized model with only needed fields to update
41		*
42		* @param array $newSerializedModel
43		* @param array $oldSerializedModel
44		* @param ClassMetadata $classMetadata
45		*
46		* @return array
47		*/
48		public function getDirtyData(
49		array $newSerializedModel,
50		array $oldSerializedModel,
51		ClassMetadata $classMetadata
52		) {
53	1	return $this->getDirtyFields(
54	1	$newSerializedModel,
55	1	$oldSerializedModel,
56	1	$classMetadata
57		);
58		}
59
60		/**
61		* registerClean
62		*
63		* @param string $id
64		* @param object $entity
65		*
66		* @return UnitOfWork
67		*/
68		public function registerClean($id, $entity)
69		{
70	1	if (is_object($entity)) {
71	1	$entityStored = clone $entity;
72	1	$this->storage[$id] = $entityStored;
73		}
74
75	1	return $this;
76		}
77
78		/**
79		* getDirtyEntity
80		*
81		* @param string $id
82		*
83		* @return mixed
84		*/
85		public function getDirtyEntity($id)
86		{
87	1	if (isset($this->storage[$id])) {
88	1	return $this->storage[$id];
89		}
90
91		return;
92		}
93
94		/**
95		* clear
96		*
97		* @param string $id
98		*
99		* @return UnitOfWork
100		*/
101		public function clear($id)
102		{
103		unset($this->storage[$id]);
104
105		return $this;
106		}
107
108		/**
109		* getDirtyFields
110		*
111		* compares serialize object and returns only modified fields
112		*
113		* @param array $newSerializedModel
114		* @param array $oldSerializedModel
115		* @param ClassMetadata $classMetadata
116		*
117		* @return array
118		*/
119		private function getDirtyFields(
120		array $newSerializedModel,
121		array $oldSerializedModel,
122		ClassMetadata $classMetadata
123		) {
124	1	$dirtyFields = [];
125
126	1	foreach ($newSerializedModel as $key => $value) {
127	1	if (!array_key_exists($key, $oldSerializedModel)) {
128		// a new key has been found, add it to the dirtyFields
129	1	$dirtyFields[$key] = $value;
130	1	continue;
131		}
132
133	1	$oldValue = $oldSerializedModel[$key];
134
135	1	$currentRelation = $classMetadata
136	1	? $classMetadata->getRelation($key)
137	1	: null;
138
139	1	if (!$currentRelation) {
140		if (
141	1	is_array($value) &&
		0 ignored issues – show introduced 2018-04-10 14:11 UTC by Report Bug Copy Issue Report Consider adding parentheses for clarity. Current Interpretation: `{currentAssign}`, Probably Intended Meaning: `{alternativeAssign}` Loading history...
142	1	!ArrayHelper::arraySame($value, $oldValue ?: []) \|\|
143	1	$value !== $oldValue
144		) {
145	1	$dirtyFields[$key] = $value;
146		}
147	1	continue;
148		}
149
150	1	$currentClassMetadata = $this->mapping->getClassMetadata(
151	1	$currentRelation->getTargetEntity()
152		);
153
154	1	$idSerializedKey = $currentClassMetadata
155	1	? $currentClassMetadata->getIdSerializeKey()
156	1	: null;
157
158	1	if (Relation::MANY_TO_ONE === $currentRelation->getType()) {
159	1	if ($value !== $oldValue) {
160	1	if (is_string($value) \|\| is_string($oldValue)) {
161	1	$dirtyFields[$key] = $value;
162		} else {
163	1	$recursiveDiff = $this->getDirtyFields(
164	1	$value,
165	1	$oldValue,
166	1	$currentClassMetadata
167		);
168
169	1	if (!empty($recursiveDiff)) {
170		$recursiveDiff[
171	1	$idSerializedKey
172	1	] = self::getEntityId($value, $idSerializedKey);
173	1	$dirtyFields[$key] = $recursiveDiff;
174		}
175		}
176		}
177
178	1	continue;
179		}
180
181		// ONE_TO_MANY relation
182	1	if (count($value ?? []) !== count($oldValue ?? [])) {
183		// get all objects ids of new array
184	1	$dirtyFields[$key] = $this->addIdentifiers(
185	1	$value,
186	1	[],
187	1	$idSerializedKey
188		);
189		}
190
191	1	if (!empty($value)) {
192	1	foreach ($value as $relationKey => $relationValue) {
193	1	$oldRelationValue = $this->findOldRelation(
194	1	$relationValue,
195	1	$oldValue,
196	1	$currentClassMetadata
197		);
198
199	1	if ($relationValue !== $oldRelationValue) {
200		if (
201	1	is_string($relationValue) \|\|
202	1	is_string($oldRelationValue)
203		) {
204	1	$dirtyFields[$key][$relationKey] = $relationValue;
205		} else {
206	1	$recursiveDiff = $this->getDirtyFields(
207	1	$relationValue,
208	1	$oldRelationValue,
209	1	$currentClassMetadata
210		);
211
212	1	if (!empty($recursiveDiff)) {
213	1	$idSerializedKey = $currentClassMetadata->getIdSerializeKey();
214
215	1	$entityId = self::getEntityId(
216	1	$relationValue,
217	1	$idSerializedKey
218		);
219	1	if (null !== $entityId) {
220		$recursiveDiff[
221	1	$idSerializedKey
222		] = $entityId;
223		}
224	1	$dirtyFields[$key][
225	1	$relationKey
226	1	] = $recursiveDiff;
227		}
228		}
229		}
230		}
231		}
232		}
233
234	1	return $dirtyFields;
235		}
236
237		/**
238		* addIdentifiers
239		*
240		* add defined identifiers to given model
241		*
242		* @param array $newSerializedModel
243		* @param array $dirtyFields
244		*
245		* @return array
246		*/
247		private function addIdentifiers(
248		$newSerializedModel,
249		$dirtyFields,
250		$idSerializedKey = null
251		) {
252	1	foreach ($newSerializedModel as $key => $value) {
253	1	if ($idSerializedKey && isset($value[$idSerializedKey])) {
254	1	$dirtyFields[$key][$idSerializedKey] = $value[$idSerializedKey];
255	1	} elseif (is_string($value) && is_int($key)) {
256	1	$dirtyFields[$key] = $value;
257		}
258		}
259
260	1	return $dirtyFields;
261		}
262
263		private function findOldRelation(
264		$relationValue,
265		array $oldValue,
266		ClassMetadata $classMetadata
267		) {
268	1	$idSerializedKey = $classMetadata->getIdSerializeKey();
269
270	1	$relationValueId = self::getEntityId($relationValue, $idSerializedKey);
271
272	1	foreach ($oldValue as $oldRelationValue) {
273	1	$oldRelationValueId = self::getEntityId(
274	1	$oldRelationValue,
275	1	$idSerializedKey
276		);
277
278	1	if ($relationValueId === $oldRelationValueId) {
279	1	return $oldRelationValue;
280		}
281		}
282
283	1	return $classMetadata->getDefaultSerializedModel();
284		}
285
286		/**
287		* get entity id from string or array
288		*
289		* @param mixed $stringOrEntity
290		* @param string $idSerializedKey
291		*/
292		private static function getEntityId($stringOrEntity, $idSerializedKey)
293		{
294	1	if (!is_array($stringOrEntity)) {
295	1	return $stringOrEntity;
296		}
297
298	1	return $stringOrEntity[$idSerializedKey] ?? null;
299		}
300		}
301

mapado / rest-client-sdk

Push — master ( 685595...680e76 )

UnitOfWork::addIdentifiers() B

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like