App\Factories\StreamerFactory

Complexity

Total Complexity

7

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	3
Bugs	2	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	10	1
A	createStreamer()	0	27	6

<?php

namespace App\Factories;

use App\Models\Song;
use App\Services\Streamers\DirectStreamerInterface;
use App\Services\Streamers\ObjectStorageStreamerInterface;
use App\Services\Streamers\StreamerInterface;
use App\Services\Streamers\TranscodingStreamerInterface;
use App\Services\TranscodingService;

class StreamerFactory
{
    private $directStreamer;
    private $transcodingStreamer;
    private $objectStorageStreamer;
    private $transcodingService;

    public function __construct(
        DirectStreamerInterface $directStreamer,
        TranscodingStreamerInterface $transcodingStreamer,
        ObjectStorageStreamerInterface $objectStorageStreamer,
        TranscodingService $transcodingService
    ) {
        $this->directStreamer = $directStreamer;
        $this->transcodingStreamer = $transcodingStreamer;
        $this->objectStorageStreamer = $objectStorageStreamer;
        $this->transcodingService = $transcodingService;
    }

    public function createStreamer(
        Song $song,
        ?bool $transcode = null,
        ?int $bitRate = null,
        float $startTime = 0.0
    ): StreamerInterface {
        if ($song->s3_params) {
            $this->objectStorageStreamer->setSong($song);

            return $this->objectStorageStreamer;
        }

        if ($transcode === null && $this->transcodingService->songShouldBeTranscoded($song)) {
            $transcode = true;
        }

        if ($transcode) {
            $this->transcodingStreamer->setSong($song);
            $this->transcodingStreamer->setBitRate($bitRate ?: config('koel.streaming.bitrate'));
            $this->transcodingStreamer->setStartTime($startTime);

            return $this->transcodingStreamer;
        }

        $this->directStreamer->setSong($song);

        return $this->directStreamer;
    }
}