kalanis\RemoteRequest\Protocols\Http\Answer\DecodeStreams\TDecoding

Complexity

Total Complexity

7

Size/Duplication

Total Lines	36
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	processStreamDecode()	0	9	4
A	getStreamHeader()	0	4	2
A	addStreamDecoder()	0	4	1

<?php

namespace kalanis\RemoteRequest\Protocols\Http\Answer\DecodeStreams;


/**
 * Trait TDecoding
 * @package kalanis\RemoteRequest\Protocols\Http\Answer\DecodeStreams
 */
trait TDecoding
{
    /** @var ADecoder[] */
    protected array $streamsDecoders = [];

    public function addStreamDecoder(ADecoder $decoder): self
    {
        $this->streamsDecoders[] = $decoder;
        return $this;
    }

    /**
     * @param resource $content stream handler
     * @return resource
     */
    public function processStreamDecode($content)
    {
        foreach ($this->streamsDecoders as $decoder) {
            $header = $this->getStreamHeader($decoder->getHeaderKey());
            if (!empty($header) && $decoder->canDecode(strval($header))) {
                $content = $decoder->processDecode($content);
            }
        }
        return $content;
    }

    protected function getStreamHeader(string $key, ?string $default = null): ?string
    {
        $headers = $this->getAllHeaders();
        return isset($headers[$key]) ? strval(reset($headers[$key])) : $default;
    }

    /**
     * @return array<string, array<string>>
     */
    abstract public function getAllHeaders(): array;
}