Junty\Stream\Stream

Complexity

Total Complexity

13

Size/Duplication

Total Lines	84
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	1

Importance

Changes	4
Bugs	0	Features	2

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	getResource()	0	4	1
A	setContents()	0	4	1
A	save()	0	6	1
A	getContents()	0	8	2
A	__toString()	0	8	2
B	pipe()	0	10	5

<?php
/**
 * Junty
 *
 * @author Gabriel Jacinto aka. GabrielJMJ <gamjj74@hotmail.com>
 * @license MIT License
 */
 
namespace Junty\Stream;

use GuzzleHttp\Psr7\Stream as GuzzleStream;
use Psr\Http\Message\StreamInterface;

class Stream extends GuzzleStream
{
    private $contents;

    private $resource;

    public function __construct($stream, $options = [])
    {
        parent::__construct($stream, $options);

        $this->resource = $stream;
    }

    /**
     * Returns the stream resource
     *
     * @return resource
     */
    public function getResource()
    {
        return $this->resource;
    }

    /**
     * Sets stream contents
     *
     * @param string $contents
     */
    public function setContents($contents)
    {
        $this->contents = $contents;
    }

    /**
     * Updates the stream contents
     */
    public function save()
    {
        $stream = new self(fopen($this->getMetaData('uri'), 'w'));
        $stream->write($this->contents);
        $stream->close();
    }

    /**
     * If the contents is setted, return it
     *
     * @return string
     */
    public function getContents()
    {
        if (null !== $this->contents) {
            return $this->contents;
        }

        return parent::getContents();
    }

    public function __toString()
    {
        if (null !== $this->contents) {
            return $this->contents;
        }

        return parent::__toString();
    }

    /**
     * Copies a stream to another
     *
     * @param self|resource $stream
     *
     * @return integer
     */
    public function pipe($stream)
    {
        if (!(is_resource($stream) && get_resource_type($stream) === 'stream') && !$stream instanceof StreamInterface) {
            throw new \Exception('Invalid stream type passed. You must pass an instance of \'Junty\Stream\Stream\' or a PHP stream resouce.');
        }

        $stream = $stream instanceof StreamInterface ? $stream->getResource() : $stream;

        return stream_copy_to_stream($this->getResource(), $stream);
    }
}