ValidateAssetActivity

Complexity

Total Complexity

5

Size/Duplication

Total Lines	72
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
B	do_activity()	0	59	4

<?php

/**
 * This class validate input assets and get metadata about them
 * It makes sure the input files to be transcoded exists and is valid.
 * Based on the input file type we lunch the proper transcoder
 */

require_once __DIR__.'/BasicActivity.php';

use SA\CpeSdk;

class ValidateAssetActivity extends BasicActivity
{
    /** @var \finfo */
    private $finfo;

    public function __construct($params, $debug, $cpeLogger = null)
    {
        parent::__construct($params, $debug, $cpeLogger);
        $this->finfo = new \finfo(FILEINFO_MIME_TYPE);
    }

    // Perform the activity
    public function do_activity($task)
    {
        $this->cpeLogger->log_out(
            "INFO",
            basename(__FILE__),
            "Preparing Asset validation ...",
            $this->activityLogKey
        );

        // Call parent do_activity:
        // It download the input file we will process.
        parent::do_activity($task);

        // Fetch first 1 KiB of file
        $this->send_heartbeat($task);
        $obj = $this->s3->getObject([
            'Bucket' => $this->input->{'input_asset'}->{'bucket'},
            'Key' => $this->input->{'input_asset'}->{'file'},
            'Range' => '0-10240'
        ]);
        $this->send_heartbeat($task);

        // Determine file type
        $tmpFile = tempnam(sys_get_temp_dir(), 'ct');
        file_put_contents($tmpFile, $obj['Body']);
        $mime = trim((new CommandExecuter($this->cpeLogger))->execute(
            'file -b --mime-type ' . escapeshellarg($tmpFile))['out']);
        $type = substr($mime, 0, strpos($mime, '/'));

        $this->cpeLogger->log_out(
            "DEBUG",
            basename(__FILE__),
            "File meta information gathered. Mime: $mime | Type: $type",
            $this->activityLogKey
        );

        // Load the right transcoder base on input_type
        // Get asset detailed info
        switch ($type)
        {
        case 'audio':
        case 'video':
        case 'image':
        default:
            require_once __DIR__.'/transcoders/VideoTranscoder.php';

            // Initiate transcoder obj
            $videoTranscoder = new VideoTranscoder($this, $task);
            // Get input video information
            $assetInfo = $videoTranscoder->get_asset_info($this->pathToInputFile);
            $assetInfo->mime = $mime;
            $assetInfo->type = $type;

            // Liberate memory
            unset($videoTranscoder);

            return $assetInfo;
        }
    }
}