Mhor\MediaInfo\Runner\MediaInfoCommandRunner

Complexity

Total Complexity

6

Size/Duplication

Total Lines	68
Duplicated Lines	29.41 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	run()	9	9	2
A	start()	0	6	1
A	wait()	11	11	2

<?php

namespace Mhor\MediaInfo\Runner;

use Symfony\Component\Process\Process;

class MediaInfoCommandRunner
{
    const MEDIAINFO_COMMAND = 'mediainfo';
    const MEDIAINFO_OLDXML_OUTPUT_ARGUMENT = '--OUTPUT=OLDXML';
    const MEDIAINFO_XML_OUTPUT_ARGUMENT = '--OUTPUT=XML';
    const MEDIAINFO_FULL_DISPLAY_ARGUMENT = '-f';
    const MEDIAINFO_URLENCODE = '--urlencode';
    const MEDIAINFO_INCLUDE_COVER_DATA = '--Cover_Data=base64';

    /**
     * @var Process
     */
    protected $process;

    /**
     * @param Process $process
     */
    public function __construct(Process $process)
    {
        $this->process = $process;
    }

    /**
     * @throws \RuntimeException
     *
     * @return string
     */
    public function run(): string
    {
        $this->process->run();
        if (!$this->process->isSuccessful()) {
            throw new \RuntimeException($this->process->getErrorOutput());
        }

        return $this->process->getOutput();
    }

    /**
     * Asynchronously start mediainfo operation.
     * Make call to MediaInfoCommandRunner::wait() afterwards to receive output.
     */
    public function start(): void
    {
        // just takes advantage of symfony's underlying Process framework
        // process runs in background
        $this->process->start();
    }

    /**
     * Blocks until call is complete.
     *
     * @throws \Exception        If this function is called before start()
     * @throws \RuntimeException
     *
     * @return string
     */
    public function wait(): string
    {
        // blocks here until process completes
        $this->process->wait();

        if (!$this->process->isSuccessful()) {
            throw new \RuntimeException($this->process->getErrorOutput());
        }

        return $this->process->getOutput();
    }
}