Kadet\Xmpp\Component\TlsEnabler

Complexity

Total Complexity

7

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	setClient()	0	12	1
A	startTls()	0	16	4
A	handleTls()	0	13	2

<?php
/**
 * Nucleus - XMPP Library for PHP
 *
 * Copyright (C) 2016, Some rights reserved.
 *
 * @author Kacper "Kadet" Donat <kacper@kadet.net>
 *
 * Contact with author:
 * Xmpp: me@kadet.net
 * E-mail: contact@kadet.net
 *
 * From Kadet with love.
 */

namespace Kadet\Xmpp\Component;

use Kadet\Xmpp\Exception\Protocol\TlsException;
use Kadet\Xmpp\Network\SecureStream;
use Kadet\Xmpp\Stream\Features;
use Kadet\Xmpp\Utils\filter as with;
use Kadet\Xmpp\Xml\XmlElement;
use Kadet\Xmpp\XmppClient;

class TlsEnabler extends Component
{
    public function setClient(XmppClient $client)
    {
        parent::setClient($client);

        $client->on('features', function (Features $features) {
            return !$this->startTls($features);
        }, null, 10);

        $client->on('element', function (XmlElement $element) {
            return $this->handleTls($element);
        }, with\element\xmlns(Features\StartTls::XMLNS));
    }

    public function startTls(Features $features)
    {
        if ($features->startTls) {
            if ($this->_client->getDecorated() instanceof SecureStream) {
                $this->_client->write(new Features\StartTls());

                return true; // Stop processing
            } elseif ($features->startTls->required) {
                throw new TlsException('Encryption is not available, but server requires it.');
            }

            $this->_client->getLogger()->warning('Server offers TLS encryption, but stream is not capable of it.');
        }

        return false;
    }

    private function handleTls(XmlElement $response)
    {
        if ($response->localName !== 'proceed') {
            throw new TlsException('TLS negotiation failed.'); // XMPP does not provide any useful information why it happened
        }

        // this function is called only by event, which can be only fired after instanceof check
        /** @noinspection PhpUndefinedMethodInspection */
        $this->_client->getDecorated()->encrypt(STREAM_CRYPTO_METHOD_TLS_CLIENT);
        $this->_client->restart();

        $this->_client->state = 'secured';
    }
}