Meema\MediaConverter\Converters\MediaConvert

Complexity

Total Complexity

8

Size/Duplication

Total Lines	103
Duplicated Lines	0 %

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	listJobs()	0	3	1
A	cancelJob()	0	4	1
A	getStatusUpdateInterval()	0	10	2
A	createJob()	0	9	1
A	getClient()	0	3	1
A	getJob()	0	4	1
A	__construct()	0	9	1

<?php

namespace Meema\MediaConverter\Converters;

use Aws\Credentials\Credentials;
use Aws\MediaConvert\MediaConvertClient;
use Meema\MediaConverter\Contracts\Converter;

class MediaConvert implements Converter
{
    /**
     * Client instance of AWS MediaConvert.
     *
     * @var \Aws\MediaConvert\MediaConvertClient
     */
    protected MediaConvertClient $client;

    /**
     * Construct converter.
     *
     * @param \Aws\MediaConvert\MediaConvertClient $client
     */
    public function __construct(MediaConvertClient $client)

The parameter $client is not used and could be removed.

    {
        $config = config('media-converter');

        $this->client = new MediaConvertClient([
            'version' => $config['version'],
            'region' => $config['region'],
            'credentials' => new Credentials($config['credentials']['key'], $config['credentials']['secret']),
            'endpoint' => $config['url'],
        ]);
    }

    /**
     * Get the MediaConvert Client.
     *
     * @return \Aws\MediaConvert\MediaConvertClient
     */
    public function getClient(): MediaConvertClient
    {
        return $this->client;
    }

    /**
     * Cancels an active job.
     *
     * @param string $id
     * @return \Aws\Result
     */
    public function cancelJob(string $id)
    {
        return $this->client->cancelJob([
            'Id' => $id,
        ]);
    }

    /**
     * Creates a new job based on the settings passed.
     *
     * @param array $settings
     * @param array $metaData
     * @param int $priority
     * @return \Aws\Result
     */
    public function createJob(array $settings, $metaData = [], $priority = 0)
    {
        return $this->client->createJob([
            'Role' => config('media-converter.iam_arn'),
            'Settings' => $settings,
            'Queue' => config('media-converter.queue_arn'),
            'UserMetadata' => $metaData,
            'StatusUpdateInterval' => $this->getStatusUpdateInterval(),
            'Priority' => $priority,
        ]);
    }

    /**
     * Gets the job.
     *
     * @param string $id
     * @return \Aws\Result
     */
    public function getJob(string $id)
    {
        return $this->client->getJob([
            'Id' => $id,
        ]);
    }

    /**
     * Lists all of the jobs based on your options provided.
     *
     * @param array $options
     * @return \Aws\Result
     */
    public function listJobs(array $options)
    {
        return $this->client->listJobs($options);
    }

    protected function getStatusUpdateInterval(): string
    {
        $webhookInterval = config('media-converter.webhook_interval');
        $allowedValues = [10, 12, 15, 20, 30, 60, 120, 180, 240, 300, 360, 420, 480, 540, 600];

        if (in_array($webhookInterval, [$allowedValues])) {
            return 'SECONDS_'.$webhookInterval;
        }

        return 'SECONDS_60'; // gracefully default to this value, in case the config value is missing or incorrect
    }
}