NotificationChannels\Engage\EngageChannel

Complexity

Total Complexity

5

Size/Duplication

Total Lines	55
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

94.74%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	send()	0	30	4

<?php

namespace NotificationChannels\Engage;

use GuzzleHttp\Client;
use Illuminate\Notifications\Notification;
use NotificationChannels\Engage\Exceptions\CouldNotSendNotification;
use NotificationChannels\Engage\Exceptions\InvalidConfiguration;

class EngageChannel
{
    const API_ENDPOINT = 'https://pushcrew.com/api/v1/send/list';

    /** @var \GuzzleHttp\Client */
    protected $client;

    /**
     * @param \GuzzleHttp\Client $client
     */
    public function __construct(Client $client)
    {
        $this->client = $client;
    }

    /**
     * Send the given notification.
     *
     * @param mixed $notifiable
     * @param \Illuminate\Notifications\Notification $notification
     *
     * @throws \NotificationChannels\Engage\Exceptions\InvalidConfiguration
     * @throws \NotificationChannels\Engage\Exceptions\CouldNotSendNotification
     */
    public function send($notifiable, Notification $notification)
    {
        $subscribers = collect($notifiable->routeNotificationFor('Engage'));

        if (! $subscribers->count()) {
            return;
        }

        if (! $token = config('services.vwo-engage.token')) {
            throw InvalidConfiguration::configurationNotSet();
        }

        $message = $notification->toEngage($notifiable);

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

        $data = $message->toArray() + [
            'subscriber_list' => json_encode([
                'subscriber_list' => $subscribers,
            ]),
        ];

        $response = $this->client->post(self::API_ENDPOINT, [
            'headers' => ['Authorization' => $token],
            'http_errors' => false,
            'form_params' => $data,
        ]);

        if ($response->getStatusCode() !== 200) {
            throw CouldNotSendNotification::serviceRespondedWithAnError($response);
        }
    }
}