Maslosoft\Mangan\Decorators\EmbeddedArrayDecorator

Complexity

Total Complexity

22

Size/Duplication

Total Lines	104
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	3

Test Coverage

Coverage

84.09%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	read()	0	24	3
A	write()	0	17	3
C	_getInstance()	0	49	16

<?php

/**
 * This software package is licensed under AGPL or Commercial license.
 *
 * @package maslosoft/mangan
 * @licence AGPL or Commercial
 * @copyright Copyright (c) Piotr Masełkowski <pmaselkowski@gmail.com>
 * @copyright Copyright (c) Maslosoft
 * @copyright Copyright (c) Others as mentioned in code
 * @link https://maslosoft.com/mangan/
 */

namespace Maslosoft\Mangan\Decorators;

use Maslosoft\Addendum\Interfaces\AnnotatedInterface;
use Maslosoft\Mangan\Helpers\DbRefManager;
use Maslosoft\Mangan\Helpers\UnknownDocumentTypePanicker;
use Maslosoft\Mangan\Interfaces\Decorators\Property\DecoratorInterface;
use Maslosoft\Mangan\Interfaces\Transformators\TransformatorInterface;

/**
 * EmbeddedArrayDecorator
 *
 * @author Piotr Maselkowski <pmaselkowski at gmail.com>
 */
class EmbeddedArrayDecorator extends EmbeddedDecorator implements DecoratorInterface
{

	public function read($model, $name, &$dbValue, $transformatorClass = TransformatorInterface::class)
	{
		if (is_array($dbValue))
		{
			$docs = [];
			foreach ($dbValue as $key => $data)
			{
				static::ensureClass($model, $name, $data);
				// Set ensured class to $dbValue
				$instance = $this->_getInstance($model->$name, $dbValue, $data, $model, $name);
				$embedded = $transformatorClass::toModel($data, $instance, $instance, $model, $name);

				// Field was transformed from DB Ref
				$embedded = DbRefManager::maybeCreateInstanceFrom($embedded);

				$docs[] = $embedded;
			}
			$model->$name = $docs;
		}
		else
		{
			$model->$name = $dbValue;
		}
	}

	public function write($model, $name, &$dbValue, $transformatorClass = TransformatorInterface::class)
	{
		if (is_array($model->$name))
		{
			$dbValue[$name] = [];
			$key = 0;
			foreach ($model->$name as $key => $document)
			{
				$data = $transformatorClass::fromModel($document);
				$dbValue[$name][] = $data;
			}
		}
		else
		{
			$dbValue[$name] = $model->$name;
		}
	}

	/**
	 * TODO: This relies on _id
	 * @param AnnotatedInterface[] $instances
	 * @param mixed[] $dbValue
	 * @param mixed[] $data
	 * @return AnnotatedInterface|null
	 */
	private function _getInstance($instances, $dbValue, $data, $parent = null, $parentField = '')
	{
		if (!count($instances))
		{
			return null;
		}
		$map = [];
		/**
		 * TODO Workaround for manganel not having _id
		 */
		if (!isset($data['_id']) && isset($data['id']))
		{
			$data['_id'] = $data['id'];
		}
		if(!isset($data['_id']) && isset($data['_mongo_id_']))
		{
			$data['_id'] = $data['_mongo_id_'];
		}
		foreach ($dbValue as $val)
		{
			/**
			 * TODO Workaround for manganel not having _id
			 */
			if (!isset($val['_id']) && isset($val['id']))
			{
				$val['_id'] = $val['id'];
			}
			if(!isset($val['_id']) && isset($val['_mongo_id_']))
			{
				$val['_id'] = $val['_mongo_id_'];
			}
			if(empty($val['_class']))
			{
				UnknownDocumentTypePanicker::tryHandle($val, $parent, $parentField);
			}
			assert(array_key_exists('_id', $val), sprintf('_id not defined for %s', $val['_class']));
			$id = (string) $val['_id'];
			$map[$id] = true;
		}
		foreach ($instances as $instance)
		{
			$id = (string) $instance->_id;
			if (isset($map[$id]) && $data['_id'] == $id && $instance instanceof $data['_class'])
			{
				return $instance;
			}
		}
		return null;
	}

}