Zbox\UnifiedPush\NotificationService\MPNS\ServiceClient

Complexity

Total Complexity

6

Size/Duplication

Total Lines	94
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	7

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	createClient()	0	18	2
B	sendRequest()	0	24	2
A	getMPNSHeaders()	0	13	1
A	getHeaders()	0	18	1

<?php

/*
 * (c) Alexander Zhukov <zbox82@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Zbox\UnifiedPush\NotificationService\MPNS;

use Zbox\UnifiedPush\NotificationService\ResponseInterface;
use Zbox\UnifiedPush\NotificationService\ServiceClientBase;
use Zbox\UnifiedPush\Utils\ClientCredentials\DTO\SSLCertificate;
use Zbox\UnifiedPush\Exception\ClientException;
use Buzz\Browser;
use Buzz\Client\MultiCurl;

/**
 * Class ServiceClient
 * @package Zbox\UnifiedPush\NotificationService\MPNS
 */
class ServiceClient extends ServiceClientBase
{
    /**
     * Initializing HTTP client
     *
     * @return $this
     */
    protected function createClient()
    {
        $client = new MultiCurl();

        $credentials     = $this->getCredentials();
        $isAuthenticated = $credentials instanceof SSLCertificate;

        $client->setVerifyPeer($isAuthenticated);

        if ($isAuthenticated) {
            $client->setOption(CURLOPT_SSLCERT, $credentials->getCertificatePassPhrase());
            $client->setOption(CURLOPT_SSLCERTPASSWD, $credentials->getCertificatePassPhrase());
        }

        $this->serviceClient = new Browser($client);

        return $this;
    }

    /**
     * @throws ClientException
     * @return ResponseInterface
     */
    public function sendRequest()
    {
        $notification = $this->getNotificationOrThrowException();

        try {
            $connection  = $this->getClientConnection();
            $serviceURL  = $this->getServiceURL();
            $url         = str_replace('[TOKEN]', $notification->getRecipients()->current(), $serviceURL['url']);

            $response =
                $connection->post(
                    $url,
                    $this->getHeaders(),
                    $notification->getPayload()
                );

            $connection->getClient()->flush();

        } catch (\Exception $e) {
            throw new ClientException($e->getMessage());
        }

        return new Response($response, $notification->getRecipients());
    }

    /**
     * @return array
     */
    protected function getMPNSHeaders()
    {
        $notification = $this->getNotificationOrThrowException();

        $customNotification = $notification->getCustomNotificationData();

        return
            array(
                'X-MessageID'           => $customNotification['message_id'],
                'X-NotificationClass'   => $customNotification['delay_interval'],
                'X-WindowsPhone-Target' => $customNotification['message_type']
            );
    }

    /**
     * @return array
     */
    protected function getHeaders()
    {
        $headers = array(
            'Accept'        => 'application/*',
            'Content-Type'  => 'text/xml'
        );

        $headers += $this->getMPNSHeaders();

        return
            array_map(
                function ($value, $key) {
                    return sprintf("%s: %s'", $key, $value);
                },
                $headers,
                array_keys($headers)
            );
    }
}