BEAR\Streamer\StreamRenderer

Complexity

Total Complexity

12

Size/Duplication

Total Lines	81
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	render()	0	7	1
A	getView()	0	10	2
A	pushStream()	0	7	1
A	pushScalarBody()	0	8	3
A	pushArrayBody()	0	8	4

<?php
/**
 * This file is part of the BEAR.Streamer package.
 *
 * @license http://opensource.org/licenses/MIT MIT
 */
namespace BEAR\Streamer;

use BEAR\Resource\RenderInterface;
use BEAR\Resource\ResourceObject;

final class StreamRenderer implements RenderInterface
{
    /**
     * @var RenderInterface
     */
    private $renderer;

    /**
     * Pushed stream
     *
     * @var resource[]
     */
    private $streams = [];

    /**
     * @var StreamerInterface
     */
    private $streamer;

    public function __construct(RenderInterface $renderer, StreamerInterface $streamer)
    {
        $this->renderer = $renderer;
        $this->streamer = $streamer;
    }

    /**
     * {@inheritdoc}
     */
    public function render(ResourceObject $ro)
    {
        $view = $this->getView($ro);
        $this->streamer->addStreams($this->streams);

        return $view;
    }

    /**
     * {@inheritdoc}
     */
    public function getView(ResourceObject $ro)
    {
        if (is_array($ro->body)) {
            $this->pushArrayBody($ro);

            return $this->renderer->render($ro);
        }

        return $this->pushScalarBody($ro);
    }

    /**
     * @param resource $item
     *
     * @return string
     */
    private function pushStream($item) : string
    {
        $id = uniqid(__FUNCTION__ . mt_rand(), true) . '_';
        $this->streams[$id] = $item; // push

        return $id;
    }

    private function pushScalarBody(ResourceObject $ro) : string
    {
        if (is_resource($ro->body) && get_resource_type($ro->body) === 'stream') {
            return $this->pushStream($ro->body);
        }

        return $this->renderer->render($ro);
    }

    private function pushArrayBody(ResourceObject $ro)
    {
        foreach ($ro->body as &$item) {
            if (is_resource($item) && get_resource_type($item) === 'stream') {
                $item = $this->pushStream($item);
            }
        }
    }
}