Streaming\Export

Complexity

Total Complexity

16

Size/Duplication

Total Lines	150
Duplicated Lines	0 %

Importance

Changes	1
Bugs	1	Features	1

7 Methods

Rating	Name	Duplication	Size	Complexity
A	save()	0	22	3
A	__construct()	0	4	1
A	getPath()	0	25	6
A	saveToS3()	0	26	3
A	getMedia()	0	3	1
A	deleteOriginalFile()	0	4	1
A	getPathInfo()	0	3	1

<?php

/**
 * This file is part of the PHP-FFmpeg-video-streaming package.
 *
 * (c) Amin Yazdanpanah <contact@aminyazdanpanah.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Streaming;

use Streaming\Exception\Exception;
use Streaming\Filters\Filter;
use Streaming\Traits\Formats;

abstract class Export
{
    use Formats;

    /** @var object */
    protected $media;

    /** @var Filter */
    protected $filter;

    /** @var array */
    protected $path_info;

    /**
     * Export constructor.
     * @param Media $media
     */
    public function __construct(Media $media)
    {
        $this->media = $media;
        $this->path_info = pathinfo($media->getPath());
    }

    /**
     * @param string $path
     * @param bool $analyse
     * @return mixed
     * @throws Exception
     */
    public function save(string $path = null, $analyse = true)
    {
        $path = $this->getPath($path);

        $this->setFilter();

        $this->media->addFilter(
            $this->getFilter()
        );

        $this->media->save(
            $this->getFormat(),
            $path
        );

        $response = ($analyse) ? (new StreamingAnalytics($this))->analyse() : $path;

        if ($this->media->isTmp()) {
            $this->deleteOriginalFile();
        }

        return $response;
    }

    /**
     * @return Filter
     */
    abstract protected function getFilter(): Filter;

    /**
     * @return mixed
     */
    abstract protected function setFilter();

    /**
     * @param $path
     * @return string
     * @throws Exception
     */
    private function getPath($path): string
    {
        if (null !== $path) {
            $this->path_info = pathinfo($path);
        }

        if (null === $path && $this->media->isTmp()) {
            $this->deleteOriginalFile();
            throw new Exception("You need to specify a path. It is not possible to save to the tmp directory");
        }

        $dirname = str_replace("\\", "/", $this->path_info["dirname"]);
        $filename = substr($this->path_info["filename"], -50);

        Helper::makeDir($dirname);

        if ($this instanceof DASH) {
            $path = $dirname . "/" . $filename . ".mpd";
        } elseif ($this instanceof HLS) {
            $representations = $this->getRepresentations();
            $path = $dirname . "/" . $filename . "_" . end($representations)->getHeight() . "p.m3u8";
            ExportHLSPlaylist::savePlayList($dirname . "/" . $filename . ".m3u8", $this->getRepresentations(), $filename);
        }

        return $path;
    }

    /**
     * @param array $config
     * @param string $dest
     * @param string|null $path
     * @return mixed
     * @throws Exception
     */
    public function saveToS3(array $config, string $dest, string $path = null)
    {
        $basename = Helper::randomString();

        if (null !== $path){
            $basename = pathinfo($path)["basename"];
        }

        $tmp_dir = Helper::tmpDir();
        $tmp_file = $tmp_dir . $basename;

        $results = $this->save($tmp_file);
        sleep(1);

        $aws = new AWS($config);
        $aws->uploadAndDownloadDirectory($tmp_dir, $dest);

        if(null !== $path){
            $destination = pathinfo($path)["dirname"] . DIRECTORY_SEPARATOR;
            Helper::makeDir($destination);
            Helper::moveDir($tmp_dir, $destination);
        }else{
            Helper::deleteDirectory($tmp_dir);
        }

        return $results;
    }

    /**
     * @return array
     */
    public function getPathInfo(): array
    {
        return $this->path_info;
    }

    /**
     * @return object|Media
     */
    public function getMedia()
    {
        return $this->media;
    }

    private function deleteOriginalFile()
    {
        sleep(1);
        @unlink($this->media->getPath());

It seems like you do not handle an error condition for unlink(). This can introduce security issues, and is generally not recommended.

    }
}