ApiClients\Middleware\Json\JsonStream

Complexity

Total Complexity

17

Size/Duplication

Total Lines	109
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

31.58%

Importance

Changes

0

17 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	getContents()	0	4	1
A	close()	0	3	1
A	detach()	0	3	1
A	getSize()	0	4	1
A	isReadable()	0	4	1
A	isWritable()	0	4	1
A	isSeekable()	0	4	1
A	rewind()	0	4	1
A	seek()	0	4	1
A	eof()	0	4	1
A	tell()	0	4	1
A	__toString()	0	4	1
A	getParsedContents()	0	4	1
A	read()	0	4	1
A	write()	0	4	1
A	getMetadata()	0	4	1

<?php declare(strict_types=1);

namespace ApiClients\Middleware\Json;

use ApiClients\Foundation\Transport\ParsedContentsInterface;
use Psr\Http\Message\StreamInterface;
use RingCentral\Psr7\BufferStream;

class JsonStream implements StreamInterface, ParsedContentsInterface
{
    /**
     * @var array
     */
    private $json = [];

    /**
     * @var StreamInterface
     */
    private $bufferStream;

    public function __construct(array $json)
    {
        $this->json = $json;
        $jsonString = \json_encode($json);
        $this->bufferStream = new BufferStream(\strlen($jsonString));
        $this->bufferStream->write($jsonString);
    }

    public function __toString()
    {
        return $this->getContents();
    }

    /**
     * @return array
     */
    public function getParsedContents(): array
    {
        return $this->json;
    }

    public function getContents()
    {
        return $this->bufferStream->getContents();
    }

    public function close(): void
    {
    }

    public function detach(): void
    {
    }

    public function getSize()
    {
        return $this->bufferStream->getSize();
    }

    public function isReadable()
    {
        return $this->bufferStream->isReadable();
    }

    public function isWritable()
    {
        return $this->bufferStream->isWritable();
    }

    public function isSeekable()
    {
        return $this->bufferStream->isSeekable();
    }

    public function rewind()
    {
        return $this->bufferStream->rewind();
    }

    public function seek($offset, $whence = \SEEK_SET)
    {
        return $this->bufferStream->seek($offset, $whence);
    }

    public function eof()
    {
        return $this->bufferStream->eof();
    }

    public function tell()
    {
        return $this->bufferStream->tell();
    }

    /**
     * Reads data from the buffer.
     * @param mixed $length
     */
    public function read($length)
    {
        return $this->bufferStream->read($length);
    }

    /**
     * Writes data to the buffer.
     * @param mixed $string
     */
    public function write($string)
    {
        return $this->bufferStream->write($string);
    }

    public function getMetadata($key = null)
    {
        return $this->bufferStream->getMetadata($key);
    }
}