Borobudur\Bus\Message\MessageMapperBuilder

Complexity

Total Complexity

27

Size/Duplication

Total Lines	154
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	create()	0	7	1
A	call()	0	18	2
A	normalizeParameters()	0	19	3
B	buildValue()	0	14	6
B	buildArrayData()	0	20	5
C	buildObjectValue()	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 MessageMapperBuilder
{
    /**
     * Factory create object.
     *
     * @param string $class
     * @param mixed  $data
     *
     * @return object
     */
    public static function create($class, $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 mixed  $data
     *
     * @return object
     */
    public static function call($class, $method, $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 mixed                 $data
     *
     * @return array
     */
    public static function normalizeParameters(array $parameters, $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();
            $arguments[$name] = self::buildValue($param, $data);
        }

        return $arguments;
    }

    /**
     * @param ReflectionParameter $param
     * @param mixed               $data
     *
     * @return mixed
     */
    public static function buildValue(ReflectionParameter $param, $data)
    {
        $name = $param->getName();
        if (($class = $param->getClass()) && is_object($data) && property_exists($data, $name)) {
            if ($class->isInstance($data->{$name})) {
                return $data->{$name};
            }
        }

        $data = self::buildArrayData($data);
        $value = isset($data[$name]) ? $data[$name] : null;

        return self::buildObjectValue($param, $value);
    }

    /**
     * Normalize data.
     *
     * @param mixed $data
     *
     * @return array
     */
    public static function buildArrayData($data)
    {
        if (is_object($data)) {
            if (method_exists($data, 'serialize')) {
                return $data->{'serialize'}();
            }

            if (method_exists($data, 'toArray')) {
                return $data->{'toArray'}();
            }

            if (method_exists($data, 'all')) {
                return $data->{'all'}();
            }

            return (array) get_object_vars($data);
        }

        return (array) $data;
    }

    /**
     * Normalize value.
     *
     * @param ReflectionParameter $param
     * @param mixed               $value
     *
     * @return mixed
     */
    private static function buildObjectValue(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;
    }
}