Borobudur\Bus\Message\MessageMapperFactory

Complexity

Total Complexity

17

Size/Duplication

Total Lines	103
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	4
Bugs	0	Features	2

4 Methods

Rating	Name	Duplication	Size	Complexity
A	create()	0	7	1
A	call()	0	16	2
A	normalizeParameters()	0	19	4
C	normalizeValue()	0	22	10

<?php
/*
 * This file is part of the Borobudur-Bus package.
 *
 * (c) Hexacodelabs <http://hexacodelabs.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Borobudur\Bus\Message;

use Borobudur\Bus\Exception\InvalidArgumentException;
use ReflectionClass;
use ReflectionParameter;

/**
 * @author      Iqbal Maulana <iq.bluejack@gmail.com>
 * @created     10/12/15
 */
class MessageMapperFactory
{
    /**
     * Factory create object.
     *
     * @param string $class
     * @param array  $data
     *
     * @return object
     */
    public static function create($class, array $data)
    {
        $reflection = new ReflectionClass($class);
        $parameters = $reflection->getConstructor()->getParameters();

        return $reflection->newInstanceArgs(self::normalizeParameters($parameters, $data));
    }

    /**
     * Call factory method on class.
     *
     * @param string $class
     * @param string $method
     * @param array  $data
     *
     * @return object
     */
    public static function call($class, $method, array $data)
    {
        $reflection = new ReflectionClass($class);
        if (!$reflection->hasMethod($method)) {
            throw new InvalidArgumentException(sprintf(
                'Undefined method "%s" in class "%s".',
                $method,
                $class
            ));
        }

        $method = $reflection->getMethod($method);
        $parameters = $method->getParameters();

        return $method->invokeArgs(null, self::normalizeParameters($parameters, $data));
    }

    /**
     * Normalize parameters.
     *
     * @param ReflectionParameter[] $parameters
     * @param array                 $data
     *
     * @return array
     */
    public static function normalizeParameters(array $parameters, array $data)
    {
        $arguments = array();
        foreach ($parameters as $param) {
            if (!$param instanceof ReflectionParameter) {
                throw new InvalidArgumentException(sprintf(
                    'Param "%s" not instance of ReflectionParameter',
                    (string) $param
                ));
            }

            $name = $param->getName();
            $value = isset($data[$name]) ? $data[$name] : null;

            $arguments[$name] = self::normalizeValue($param, $value);
        }

        return $arguments;
    }

    /**
     * Normalize value.
     *
     * @param ReflectionParameter $param
     * @param mixed               $value
     *
     * @return mixed
     */
    private static function normalizeValue(ReflectionParameter $param, $value)
    {
        if (null === $value) {
            return $value;
        }
        
        if (null !== ($class = $param->getClass()) && false === is_object($value)) {
            if (is_scalar($value) && $class->hasMethod('fromString')) {
                return $class->getMethod('fromString')->invoke(null, $value);
            }

            if ((is_array($value) || is_object($value)) && $class->hasMethod('deserialize')) {
                return $class->getMethod('deserialize')->invoke(null, $value);
            }

            if ($class->isInstantiable()) {
                return $class->newInstance($value);
            }
        }

        return $value;
    }
}