BenatEspina\StackExchangeApiClient\Application\DataTransformer\ResponseToModelDataTransformer

Complexity

Total Complexity

8

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	1
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	10	2
A	write()	0	4	1
A	read()	0	17	4
A	build()	0	4	1

<?php

/*
 * This file is part of the Stack Exchange Api Client library.
 *
 * Copyright (c) 2014-2016 Beñat Espiña <benatespina@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace BenatEspina\StackExchangeApiClient\Application\DataTransformer;

use Psr\Http\Message\ResponseInterface as Response;

/**
 * Response to model data transformer.
 *
 * @author Beñat Espiña <benatespina@gmail.com>
 */
abstract class ResponseToModelDataTransformer implements ResponseDataTransformer
{
    /**
     * The response.
     *
     * @var Response
     */
    private $response;

    /**
     * The fully qualified class name.
     *
     * @var string
     */
    private $fqcn;

    /**
     * The model class.
     *
     * @var string
     */
    protected $class;

    /**
     * Constructor.
     *
     * @param string $fqcn The fully qualified class name
     *
     * @throws \LogicException when the given fqcn is invalid
     */
    public function __construct($fqcn)
    {
        $answerReflectionClass = new \ReflectionClass($fqcn);
        if (!$answerReflectionClass->implementsInterface($this->class)) {
            throw new \LogicException(
                sprintf('Given %s class must implement the %s', $fqcn, $this->class)
            );
        }
        $this->fqcn = $fqcn;
    }

    /**
     * {@inheritdoc}
     */
    public function write(Response $response)
    {
        $this->response = $response;
    }

    /**
     * {@inheritdoc}
     */
    public function read()
    {
        $data = json_decode($this->response->getBody()->getContents(), true);
        if (false === array_key_exists('items', $data)) {
            throw new \Exception('Given data is incorrect');
        }
        if (count($data['items']) > 1) {
            $objects = [];
            foreach ($data['items'] as $item) {
                $objects[] = $this->build($item);
            }

            return $objects;
        }

        return $this->build($data['items'][0]);
    }

    /**
     * Builds the object with the response data given.
     *
     * @param mixed $data The data
     *
     * @return mixed
     */
    private function build($data)
    {
        return forward_static_call_array([$this->fqcn, 'fromJson'], [$data]);
    }
}