NotificationChannels\WebPush\WebPushChannel

Complexity

Total Complexity

18

Size/Duplication

Total Lines	85
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

73.68%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	send()	0	25	3
A	deleteInvalidSubscriptions()	0	12	5
B	logErrorsInDebug()	0	19	9

<?php

namespace NotificationChannels\WebPush;

use Illuminate\Support\Facades\Log;
use Minishlink\WebPush\WebPush;
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;
        }

        $payload = json_encode($notification->toWebPush($notifiable, $notification)->toArray());

The method toWebPush() does not seem to exist on object<Illuminate\Notifications\Notification>.

        $subscriptions->each(function ($sub) use ($payload) {
            $this->webPush->sendNotification(
                $sub->endpoint,
                $payload,
                $sub->public_key,
                $sub->auth_token
            );
        });

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

        $this->logErrorsInDebug($response, $subscriptions, $payload);

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

    /**
     * @param  array|bool $response
     * @param  \Illuminate\Database\Eloquent\Collection $subscriptions
     * @return void
     */
    protected function deleteInvalidSubscriptions($response, $subscriptions)
    {
        if (! is_array($response)) {
            return;
        }

        foreach ($response as $index => $value) {
            if (! $value['success'] && isset($subscriptions[$index])) {
                $subscriptions[$index]->delete();
            }
        }
    }

    protected function logErrorsInDebug($response, $subscriptions, $payload)
    {
		if(config('webpush.enable_logging')){
			if(is_array($response)){
				foreach($response as $index => $push){
					if(!$push['success']){
						Log::error("[WebPush] Error pushing: {$push['message']}\nEndpoint: {$push['endpoint']}\nPayload: {$payload}");
					}else{
						Log::info("[WebPush] Push successful\nEndpoint: {$subscriptions[$index]->endpoint}");
					}
				}
			}elseif(is_bool($response) && $response === true){
				Log::info('[WebPush] All messages successfully pushed');
			}elseif(is_bool($response) && $response === false){
				Log::info('[WebPush] No notifications in the queue');
			}

		}
    }
}