NotificationChannels\WebPush\WebPushChannel

Complexity

Total Complexity

9

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

96.77%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	send()	0	26	3
A	deleteInvalidSubscriptions()	0	16	5

<?php

namespace NotificationChannels\WebPush;

use Minishlink\WebPush\WebPush;
use Minishlink\WebPush\Subscription;
use Illuminate\Notifications\Notification;

class WebPushChannel
{
    /** @var \Minishlink\WebPush\WebPush */
    protected $webPush;

    /**
     * @param  \Minishlink\WebPush\WebPush $webPush
     * @return void

Adding a @return annotation to constructors is generally not recommended as a constructor does not have a meaningful return value.

     */
    public function __construct(WebPush $webPush)
    {
        $this->webPush = $webPush;
    }

    /**
     * Send the given notification.
     *
     * @param  mixed $notifiable
     * @param  \Illuminate\Notifications\Notification $notification
     * @return void
     */
    public function send($notifiable, Notification $notification)
    {
        $subscriptions = $notifiable->routeNotificationFor('WebPush');

        if (! $subscriptions || $subscriptions->isEmpty()) {
            return;
        }

        /** @var \NotificationChannels\WebPush\WebPushMessage $webPushMessage */
        $webPushMessage = $notification->toWebPush($notifiable, $notification);
        $options = $webPushMessage->getOptions();
        $payload = json_encode($webPushMessage->toArray());

        $subscriptions->each(function (PushSubscription $pushSubscription) use ($payload, $options) {
            $this->webPush->sendNotification(new Subscription(
                $pushSubscription->endpoint,
                $pushSubscription->public_key,
                $pushSubscription->auth_token,
                $pushSubscription->content_encoding
            ), $payload, false, $options);
        });

        $reports = $this->webPush->flush();

        $this->deleteInvalidSubscriptions($reports, $subscriptions);
    }

    /**
     * @param  \Minishlink\WebPush\MessageSentReport[] $reports
     * @param  \Illuminate\Database\Eloquent\Collection $subscriptions
     * @return void
     */
    protected function deleteInvalidSubscriptions($reports, $subscriptions)
    {
        foreach ($reports as $report) {
            if (is_null($report) || $report->isSuccess()) {
                continue;
            }

            /* @var \Minishlink\WebPush\MessageSentReport $report */
            $subscriptions->each(function ($subscription) use ($report) {
                if ($subscription->endpoint === $report->getEndpoint()) {
                    logger()->warning('deleting subscription cause of '.$report->getReason());
                    $subscription->delete();
                }
            });
        }
    }
}