Chrisyue\PhpM3u8\M3u8\AnnotationReadable\AbstractAnnotationReadable

Complexity

Total Complexity

26

Size/Duplication

Total Lines	117
Duplicated Lines	19.66 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
C	parse()	23	35	13
B	dump()	0	28	6
A	setReader()	0	6	1
A	createResult()	0	6	1
	couldTryNextLine()	0	1	?
	getClass()	0	1	?
A	getRefProperties()	0	9	2
A	moveToNextLine()	0	6	1
A	ensureResult()	0	10	2

<?php

namespace Chrisyue\PhpM3u8\M3u8\AnnotationReadable;

use Chrisyue\PhpM3u8\Stream\StreamInterface;
use Chrisyue\PhpM3u8\M3u8\AbstractM3u8;
use Chrisyue\PhpM3u8\M3u8\M3u8Interface;
use Chrisyue\PhpM3u8\M3u8\SequenceAwareInterface;
use Doctrine\Common\Annotations\Reader;
use Chrisyue\PhpM3u8\ReaderAwareInterface;

abstract class AbstractAnnotationReadable extends AbstractM3u8 implements ReaderAwareInterface
{
    private $refProperties;

    private $reader;

    public function parse()
    {
        do {
            $lineInfo = $this->getStream()->read();
            if (empty($lineInfo['tag']) && empty($lineInfo['value'])) {
                continue;
            }

            foreach ($this->getRefProperties() as $refProp) {

This code seems to be duplicated across your project.

                $m3u8 = $this->reader->getPropertyAnnotation($refProp, M3u8Interface::class);
                if (null === $m3u8) {
                    continue;
                }

                $value = null === $this->getResult() ? null : $refProp->getValue($this->getResult());
                if (null !== $value && !is_array($value)) {
                    continue;
                }

                if ($m3u8 instanceof ReaderAwareInterface) {
                    $m3u8->setReader($this->reader);
                }

                $parsed = $m3u8->setStream($this->getStream())->parse()->getResult();
                if (null !== $parsed) {
                    is_array($value) ? $value[] = $parsed : $value = $parsed;
                    $refProp->setValue($this->ensureResult(), $value);

                    break;
                }
            }
        } while ($this->couldTryNextLine() && $this->moveToNextLine());

        return $this;
    }

    public function dump()
    {
        $refProps = $this->getRefProperties();
        $dumpers = [];
        foreach ($refProps as $refProp) {
            $m3u8 = $this->reader->getPropertyAnnotation($refProp, M3u8Interface::class);
            if (null === $m3u8) {
                continue;
            }

            $dumpers[$m3u8->getSequence()] = compact('m3u8', 'refProp');
        }

        ksort($dumpers);

        foreach ($dumpers as $dumper) {
            $value = $dumper['refProp']->getValue($this->getResult());
            if (null === $value) {
                continue;
            }

            $dumper['m3u8']->setStream($this->getStream());

            !is_array($value) ? $dumper['m3u8']->setResult($value)->dump() : array_walk($value, function($val) use ($dumper) {
                $dumper['m3u8']->setResult($val)->dump();
            });
        }
    }

    public function setReader(Reader $reader)
    {
        $this->reader = $reader;

        return $this;
    }

    protected function createResult()
    {
        $class = $this->getClass();

        return new $class;
    }

    abstract protected function couldTryNextLine();

    abstract protected function getClass();

    private function getRefProperties()
    {
        if (null === $this->refProperties) {
            $refClass = new \ReflectionClass($this->getClass());
            $this->refProperties = $refClass->getProperties();
        }

        return $this->refProperties;
    }

    private function moveToNextLine()
    {
        $this->getStream()->next();

        return $this->getStream()->valid();
    }

    private function ensureResult()
    {
        $result = $this->getResult();
        if (null === $result) {
            $result = $this->createResult();
            $this->setResult($result);
        }

        return $result;
    }
}