WyriHaximus\React\Stream\Hash\WritableStreamHash

Complexity

Total Complexity

10

Size/Duplication

Total Lines	69
Duplicated Lines	27.54 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

81.25%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
B	__construct()	19	25	5
A	isWritable()	0	4	1
A	write()	0	6	1
A	end()	0	7	2
A	close()	0	4	1

<?php declare(strict_types=1);

namespace WyriHaximus\React\Stream\Hash;

use Evenement\EventEmitter;
use React\Stream\WritableStreamInterface;

final class WritableStreamHash extends EventEmitter implements WritableStreamInterface
{
    /**
     * @var WritableStreamInterface
     */
    private $stream;

    /**
     * @var resource
     */
    private $context;

    /**
     * WritableStreamHash constructor.
     * @param WritableStreamInterface $stream
     * @param string                  $algo
     * @param string|null             $key
     */
    public function __construct(WritableStreamInterface $stream, string $algo, string $key = null)
    {
        $this->stream = $stream;
        $options = [$algo];
        if ($key !== null && strlen($key) > 0) {

This code seems to be duplicated across your project.

            $options[] = HASH_HMAC;
            $options[] = $key;
        }
        $this->context = hash_init(...$options);
        $this->stream->once('close', function () use ($algo) {

This code seems to be duplicated across your project.

            $hash = hash_final($this->context, true);
            if (count($this->listeners('hash')) > 0) {
                $this->emit('hash', [
                    bin2hex($hash),
                    $algo,
                ]);
            }
            if (count($this->listeners('hash_raw')) > 0) {
                $this->emit('hash_raw', [
                    $hash,
                    $algo,
                ]);
            }
        });
    }

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

    public function write($data)
    {
        hash_update($this->context, $data);

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

    public function end($data = null)
    {
        if ($data !== null) {
            hash_update($this->context, $data);
        }
        $this->stream->end($data);
    }

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