TalvBansal\ThrottledFailedJobMonitor\FailedJobNotifier

Complexity

Total Complexity

8

Size/Duplication

Total Lines	43
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	0

Test Coverage

Coverage

85%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	register()	0	16	3
A	isValidNotificationClass()	0	12	3
A	shouldSendNotification()	0	10	2

<?php

namespace TalvBansal\ThrottledFailedJobMonitor;

use Illuminate\Queue\Events\JobFailed;
use Illuminate\Queue\QueueManager;
use TalvBansal\ThrottledFailedJobMonitor\Exceptions\InvalidConfiguration;

class FailedJobNotifier
{
    public function register()
    {
        app(QueueManager::class)->failing(function (JobFailed $event) {
            $notifiable = app(config('throttled-failed-jobs.notifiable'));

            $notification = app(config('throttled-failed-jobs.notification'))->setEvent($event);

            if (! $this->isValidNotificationClass($notification)) {
                throw InvalidConfiguration::notificationClassInvalid(get_class($notification));
            }

            if ($this->shouldSendNotification($notification)) {
                $notifiable->notify($notification);
            }
        });
    }

    public function isValidNotificationClass($notification): bool
    {
        if (get_class($notification) === Notification::class) {
            return true;
        }

        if (is_subclass_of($notification, Notification::class)) {
            return true;
        }

        return false;
    }

    public function shouldSendNotification($notification)
    {
        $callable = config('throttled-failed-jobs.notificationFilter');

        if (! is_callable($callable)) {
            return true;
        }

        return $callable($notification);
    }
}