Strebl\Inetworx\InetworxClient

Complexity

Total Complexity

18

Size/Duplication

Total Lines	222
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	3
Bugs	0	Features	0

15 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	11	2
A	send()	0	9	1
A	credit()	0	4	1
B	sendRequest()	0	24	3
A	responseCodeFromBody()	0	4	1
A	responseBody()	0	4	1
A	getBaseUrl()	0	4	1
A	setBaseUrl()	0	4	1
A	getBroadcastUrl()	0	4	1
A	setBroadcastUrl()	0	4	1
A	getOptionsUrl()	0	4	1
A	setOptionsUrl()	0	4	1
A	getHttpClient()	0	4	1
A	setHttpClient()	0	4	1
A	createHttpClient()	0	10	1

<?php

namespace Strebl\Inetworx;

use GuzzleHttp\Client;
use Strebl\Inetworx\Exceptions\ApiErrorException;

class InetworxClient
{
    /**
     * @var string
     */
    protected $baseUrl = 'https://sms.inetworx.ch/';

    /**
     * @var string
     */
    protected $broadcastUrl = 'smsapp/sendsms.php';

    /**
     * @var string
     */
    protected $optionsUrl = 'smsapp/options.php';

    /**
     * @var Client
     */
    protected $httpClient;

    /**
     * @var string
     */
    protected $apiPassword;

    /**
     * @var string
     */
    protected $apiUsername;

    /**
     * Inetworx Client Constructor.
     *
     * @param string $authHeaderUsername
     * @param string $authHeaderPassword
     * @param string $apiUsername
     * @param string $apiPassword
     * @param $client
     */
    public function __construct($authHeaderUsername, $authHeaderPassword, $apiUsername, $apiPassword, $client = null)
    {
        if ($client) {
            $this->httpClient = $client;
        } else {
            $this->createHttpClient($authHeaderUsername, $authHeaderPassword);
        }

        $this->apiUsername = $apiUsername;
        $this->apiPassword = $apiPassword;
    }

    /**
     * Send the message.
     *
     * @param $phoneNumber
     * @param $message
     * @param $fromNumber
     *
     * @return array $response
     */
    public function send($phoneNumber, $message, $fromNumber)
    {
        return $this->sendRequest($this->getBroadcastUrl(), [
            'sender'  => $fromNumber,
            'rcpt'    => $phoneNumber,
            'msgbody' => $message,
            'coding'  => 2,
        ]);
    }

     /**
      * Get the remaining SMS credits.
      *
      * @throws ApiErrorException
      *
      * @return int $credit
      */
     public function credit()
     {
         return (int) $this->sendRequest($this->getOptionsUrl(), ['option'  => 'quota'])['body'];
     }

    /**
     * @param $url
     * @param $params
     *
     * @throws ApiErrorException
     *
     * @return array
     */
    protected function sendRequest($url, $params)
    {
        $response = $this
             ->getHttpClient()
             ->post($url, [
                 'form_params' => array_merge([
                     'user'    => $this->apiUsername,
                     'pass'    => $this->apiPassword,
                 ], $params),
             ]);

        if ($response->getStatusCode() !== 200 || $this->responseCodeFromBody($response) !== 200) {
            throw new ApiErrorException(
                 $this->responseBody($response)
             );
        }

        return [
             'body'      => $this->responseBody($response),
             'full_body' => (string) $response->getBody(),
             'status'    => $response->getStatusCode(),
             'message'   => $response->getReasonPhrase(),
         ];
    }

    /**
     * The Inetworx API doesn't respond with a useful HTTP Status Code if the request fails.
     * It puts the status code into the response body.
     * for example: 404: Invalid Option.
     *
     * @return int $code
     */
    protected function responseCodeFromBody($response)
    {
        return (int) explode(':', (string) $response->getBody())[0];
    }

    /**
     * Inetworx puts the status code in the response body too.
     * Because of that, we have to parse the answer.
     *
     * @param $response
     *
     * @return string $body
     */
    protected function responseBody($response)
    {
        return trim(explode(':', (string) $response->getBody())[1]);
    }

    /**
     * @return string
     */
    public function getBaseUrl()
    {
        return $this->baseUrl;
    }

    /**
     * @param string $baseUrl
     */
    public function setBaseUrl($baseUrl)
    {
        $this->baseUrl = $baseUrl;
    }

    /**
     * @return string
     */
    public function getBroadcastUrl()
    {
        return $this->broadcastUrl;
    }

    /**
     * @param string $broadcastUrl
     */
    public function setBroadcastUrl($broadcastUrl)
    {
        $this->broadcastUrl = $broadcastUrl;
    }

    /**
     * @return string
     */
    public function getOptionsUrl()
    {
        return $this->optionsUrl;
    }

    /**
     * @param string $optionsUrl
     */
    public function setOptionsUrl($optionsUrl)
    {
        $this->optionsUrl = $optionsUrl;
    }

    /**
     * @return Client
     */
    protected function getHttpClient()
    {
        return $this->httpClient;
    }

    /**
     * @param $client
     *
     * @return void
     */
    protected function setHttpClient($client)
    {
        $this->httpClient = $client;
    }

    /**
     * @return void
     */
    protected function createHttpClient($authHeaderUsername, $authHeaderPassword)
    {
        $this->httpClient = new Client([
            'base_uri' => $this->getBaseUrl(),
            'auth'     => [
                $authHeaderUsername,
                $authHeaderPassword,
            ],
        ]);
    }
}