hiapi\middlewares\LegacyResponderMiddleware

Complexity

Total Complexity

9

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	execute()	0	8	1
A	extract()	0	14	3
A	extractOne()	0	4	2
A	createResponseFor()	0	14	2

<?php

namespace hiapi\middlewares;

use hiapi\commands\error\CommandError;
use League\Tactician\Middleware;
use Psr\Http\Message\ResponseInterface;
use Zend\Hydrator\HydratorInterface;

class LegacyResponderMiddleware implements Middleware
{
    /**
     * @var ResponseInterface
     */
    private $response;
    /**
     * @var HydratorInterface
     */
    private $extractor;

    public function __construct(
        ResponseInterface $response,
        HydratorInterface $extractor
    ) {
        $this->response = $response;
        $this->extractor = $extractor;
    }

    /**
     * @param object $command
     * @param callable $next
     *
     * @return mixed
     */
    public function execute($command, callable $next)
    {
        $result = $next($command);

        $data = $this->extract($result);

        return $this->createResponseFor($data);
    }

    private function extract($result)
    {
        if ($result instanceof CommandError) {
            return ['_error' => $result->getException()->getMessage()];
        }

        if (is_array($result)) {
            return array_map(function ($item) {
                return $this->extractOne($item);
            }, $result);
        }

        return $this->extractOne($result);
    }

    private function extractOne($result)
    {
        return is_object($result) ? $this->extractor->extract($result) : $result;
    }

    private function createResponseFor($data)
    {
        $response = $this->response
            ->withStatus(200)
            ->withHeader("Content-Type", "application/json");

        if ($response->getBody()->isSeekable()) {
            $response->getBody()->rewind();
        }

        $response->getBody()->write(json_encode($data));

        return $response;
    }
}