WyriHaximus\React\Stream\Base64\WritableStreamBase64Encode

Complexity

Total Complexity

6

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

77.27%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	isWritable()	0	4	1
A	write()	0	6	1
A	end()	0	8	1
A	close()	0	4	1
A	processBuffer()	0	8	1

<?php declare(strict_types=1);

namespace WyriHaximus\React\Stream\Base64;

use Evenement\EventEmitterTrait;
use React\Stream\WritableStreamInterface;

final class WritableStreamBase64Encode implements WritableStreamInterface
{
    use EventEmitterTrait;

    /**
     * @var WritableStreamInterface
     */
    private $stream;

    /**
     * @var string
     */
    private $buffer = '';

    /**
     * WritableStreamHash constructor.
     * @param WritableStreamInterface $stream
     */
    public function __construct(WritableStreamInterface $stream)
    {
        $this->stream = $stream;
    }

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

    public function write($data)
    {
        $this->buffer .= $data;

        return $this->stream->write($this->processBuffer());
    }

    public function end($data = null)
    {
        $this->buffer .= $data;
        $this->stream->end(
            $this->processBuffer() . base64_encode($this->buffer)
        );
        $this->buffer = '';
    }

    public function close()
    {
        $this->stream->close();
    }

    private function processBuffer(): string
    {
        $length = strlen($this->buffer);
        $buffer = base64_encode(substr($this->buffer, 0, $length - $length % 3));
        $this->buffer = substr($this->buffer, $length - $length % 3);

        return $buffer;
    }
}