WyriHaximus\React\Stream\Base64\WritableStreamBase64Decode

Complexity

Total Complexity

6

Size/Duplication

Total Lines	59
Duplicated Lines	100 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

78.26%

Importance

Changes

0

6 Methods

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

<?php declare(strict_types=1);

namespace WyriHaximus\React\Stream\Base64;

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

final class WritableStreamBase64Decode implements WritableStreamInterface

This class seems to be duplicated in your project.

{
    use EventEmitterTrait;

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

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

    /**
     * WritableStreamHash constructor.
     * @param WritableStreamInterface $stream
     */
    public function __construct(WritableStreamInterface $stream)
    {
        $this->stream = $stream;
        Util::forwardEvents($stream, $this, ['error', 'drain', 'end', 'close']);
    }

    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): void
    {
        $this->buffer .= $data;
        $this->stream->end(
            $this->processBuffer() . \base64_decode($this->buffer, true)
        );
        $this->buffer = '';
    }

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

    private function processBuffer(): string
    {
        $length = \strlen($this->buffer);
        $buffer = \base64_decode(\substr($this->buffer, 0, $length - $length % 4), true);
        $this->buffer = \substr($this->buffer, $length - $length % 4);

        return $buffer;
    }
}