Canvas\Cli\Jobs\PushNotifications

Complexity

Total Complexity

10

Size/Duplication

Total Lines	121
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
B	handle()	0	55	8
A	oneSignal()	0	14	1

<?php

namespace Canvas\Cli\Jobs;

use Canvas\Contracts\Queue\QueueableJobInterface;
use Canvas\Jobs\Job;
use Phalcon\Di;
use GuzzleHttp\Client as GuzzleClient;

The type GuzzleHttp\Client was not found. Maybe you did not declare it correctly or list all dependencies?

use Http\Adapter\Guzzle6\Client as GuzzleAdapter;

The type Http\Adapter\Guzzle6\Client was not found. Maybe you did not declare it correctly or list all dependencies?

use Http\Client\Common\HttpMethodsClient as HttpClient;

The type Http\Client\Common\HttpMethodsClient was not found. Maybe you did not declare it correctly or list all dependencies?

use Http\Message\MessageFactory\GuzzleMessageFactory;

The type Http\Message\MessageFactory\GuzzleMessageFactory was not found. Maybe you did not declare it correctly or list all dependencies?

use OneSignal\Config;

The type OneSignal\Config was not found. Maybe you did not declare it correctly or list all dependencies?

use OneSignal\OneSignal;

The type OneSignal\OneSignal was not found. Maybe you did not declare it correctly or list all dependencies?

use Canvas\Models\UserLinkedSources;
use Canvas\Notifications\PushNotification;
use Exception;

class PushNotifications extends Job implements QueueableJobInterface
{
    /**
     * Realtime channel.
     *
     * @var string
     */
    protected $users;

    /**
     * Realtime event.
     *
     * @var string
     */
    protected $message;

    /**
     * Realtime params.
     *
     * @var array
     */
    protected $params;

    /**
     * Constructor setup info for Pusher.
     *
     * @param string $channel
     * @param string $event
     * @param array $params
     */
    public function __construct(PushNotification $pushNotification)
    {
        $this->users = $pushNotification->to;
        $this->message = $pushNotification->message;
        $this->params = $pushNotification->params;
    }

    /**
     * Handle the pusher request.
     *
     * @return void
     */
    public function handle()
    {
        $config = Di::getDefault()->getConfig();

        if (empty($this->users)) {
            return false;

The expression return false returns the type false which is incompatible with the documented return type void.

        }

        $userDevicesArray = UserLinkedSources::getMobileUserLinkedSources($this->users->getId());

        if (empty($userDevicesArray[2]) && empty($userDevicesArray[3])) {
            return false;

The expression return false returns the type false which is incompatible with the documented return type void.

        }

        /**
         * One signal array params.
         */
        $pushBody = [
            'contents' => [
                'en' => $this->message
            ],
            'data' => $this->params
        ];

        /**
         * @todo change to use some constante , ID dont tell you what device it is
         */
        //send push android
        if (!empty($userDevicesArray[2])) {
            $pushBody['include_player_ids'][] = $userDevicesArray[2][0];
        }

        //ios
        if (!empty($userDevicesArray[3])) {
            $pushBody['include_player_ids'][] = $userDevicesArray[3][0];
        }

        try {
            $this->oneSignal(
                $config->pushNotifications->appId,
                $config->pushNotifications->authKey,
                $config->pushNotifications->userAuthKey
            )->notifications->add(
                $pushBody
            );
        } catch (Exception $e) {
            if (Di::getDefault()->has('log')) {
                Di::getDefault()->get('log')->error(
                    'Error sending push notification via OneSignal - ' . $e->getMessage(),
                    [$e->getTraceAsString()]
                );
            }
        }

        return true;

The expression return true returns the type true which is incompatible with the documented return type void.

    }

    /**
     * Give back a one signal object to send push notifications.
     *
     * @param string $appId
     * @param string $appAuthKey
     * @param string $appUserKey
     * @return OneSignal
     */
    private function oneSignal(string $appId, string $appAuthKey, string $appUserKey): OneSignal
    {
        $config = new Config();
        $config->setApplicationId($appId);
        $config->setApplicationAuthKey($appAuthKey);
        $config->setUserAuthKey($appUserKey);

        $guzzle = new GuzzleClient([
            'timeout' => 2.0,
        ]);

        $client = new HttpClient(new GuzzleAdapter($guzzle), new GuzzleMessageFactory());

        return  new OneSignal($config, $client);
    }
}