Meema\MediaConverter\Http\Controllers\IncomingWebhookController

Complexity

Total Complexity

13

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__invoke()	0	11	2
A	__construct()	0	3	1
B	fireEventFor()	0	26	8
A	ensureSubscriptionIsConfirmed()	0	9	2

<?php

namespace Meema\MediaConverter\Http\Controllers;

use Aws\Sns\Message;
use Illuminate\Routing\Controller;
use Illuminate\Support\Facades\Http;
use Meema\MediaConverter\Events\ConversionHasCompleted;
use Meema\MediaConverter\Events\ConversionHasError;
use Meema\MediaConverter\Events\ConversionHasInputInformation;
use Meema\MediaConverter\Events\ConversionHasNewWarning;
use Meema\MediaConverter\Events\ConversionHasStatusUpdate;
use Meema\MediaConverter\Events\ConversionIsProgressing;
use Meema\MediaConverter\Events\ConversionQueueHop;

class IncomingWebhookController extends Controller
{
    public function __construct()
    {
        $this->middleware('verify-signature');
    }

    /**
     * @throws \Exception
     */
    public function __invoke()
    {
        try {
            $message = $this->ensureSubscriptionIsConfirmed();

            $detail = $message['detail'];
            $status = $detail['status'];

            $this->fireEventFor($status, $message);
        } catch (\Exception $e) {
            throw new \Exception($e);
        }
    }

    /**
     * @param $status
     * @param $message
     * @throws \Exception
     */
    public function fireEventFor($status, $message)
    {
        switch ($status) {
            case 'PROGRESSING':
                event(new ConversionIsProgressing($message));
                break;
            case 'INPUT_INFORMATION':
                event(new ConversionHasInputInformation($message));
                break;
            case 'COMPLETE':
                event(new ConversionHasCompleted($message));
                break;
            case 'STATUS_UPDATE':
                event(new ConversionHasStatusUpdate($message));
                break;
            case 'NEW_WARNING':
                event(new ConversionHasNewWarning($message));
                break;
            case 'QUEUE_HOP':
                event(new ConversionQueueHop($message));
                break;
            case 'ERROR':
                event(new ConversionHasError($message));
                break;
            default:
                throw new \Exception();
        }
    }

    /**
     * @return array
     */
    public function ensureSubscriptionIsConfirmed(): array
    {
        $message = Message::fromRawPostData()->toArray();

        if (array_key_exists('SubscribeURL', $message)) {
            Http::get($message['SubscribeURL']);
        }

        return $message;
    }
}