Reallyli\LaravelUnicomponent\Components\Pusher\Pusher

Complexity

Total Complexity

5

Size/Duplication

Total Lines	73
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	0

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	trigger()	0	8	2
A	sendRequest()	0	25	2
A	getPusherUrl()	0	8	1

<?php
/**
 * Created by PhpStorm.
 * User: uniqueway
 * Date: 2018/11/20
 * Time: 上午11:39.
 */

namespace Reallyli\LaravelUnicomponent\Components\Pusher;

class Pusher
{
    /**
     * trigger.
     *
     * @author reallyli <zlisreallyli@outlook.com>
     * @since 2018/11/20
     * @param mixed $channels
     * @param string $eventName
     * @param array $data
     * @param array $params
     * @return mixed
     */
    public function trigger($channels, string $eventName, array $data, array $params = [])
    {
        $params['channel'] = is_string($channels) ? [$channels] : (array) $channels;
        $params['data'] = $data;
        $params['name'] = $eventName;

        $this->sendRequest($this->getPusherUrl(), $params);
    }

    /**
     * Send Request.
     *
     * @author reallyli <zlisreallyli@outlook.com>
     * @since 2018/11/20
     * @param string $url
     * @param array $data
     * @return mixed
     */
    protected function sendRequest(string $url, array $data)
    {
        $ch = curl_init($url);
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST');
        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt(
            $ch,
            CURLOPT_HTTPHEADER,
            [
                'Content-Type: application/json',
                'Content-Length: '.strlen($data),
            ]
        );

        $response = curl_exec($ch);

        if ($response === false) {
            logger()->error('[LaravelUnicomponent] Pusher Send Request Error, data:'.json_encode($data));

            return false;
        }

        return $response;
    }

    /**
     * Get Pusher Url.
     *
     * @author reallyli <zlisreallyli@outlook.com>
     * @since 2018/11/20
     * @return string
     */
    protected function getPusherUrl()
    {
        $pusherUrl = config('unicomponent.pusher.configs.pusher_url');

        throw_unless(filter_var($pusherUrl, FILTER_VALIDATE_URL), '\Exception', 'pusher url illegal');

        return $pusherUrl;
    }
}