IPub\WebSocketsSession\Events\OnIncomingMessageHandler

Complexity

Total Complexity

4

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	2

Test Coverage

Coverage

50%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	__invoke()	0	10	3

<?php
/**
 * OnIncomingMessageHandler.php
 *
 * @copyright      More in license.md
 * @license        http://www.ipublikuj.eu
 * @author         Adam Kadlec http://www.ipublikuj.eu
 * @package        iPublikuj:WebSocketSession!
 * @subpackage     Events
 * @since          1.0.0
 *
 * @date           19.02.17
 */

declare(strict_types = 1);

namespace IPub\WebSocketsSession\Events;

use Nette;

use IPub;
use IPub\WebSocketsSession\Session;

use IPub\WebSockets\Entities as WebSocketsEntities;
use IPub\WebSockets\Http as WebSocketsHttp;

/**
 * This component will allow access to session data from your Nette Framework website for each user connected
 *
 * @package        iPublikuj:WebSocketSession!
 * @subpackage     Events
 *
 * @author         Adam Kadlec <adam.kadlec@ipublikuj.eu>
 */
final class OnIncomingMessageHandler
{
	/**
	 * Implement nette smart magic
	 */
	use Nette\SmartObject;

	/**
	 * @var Session\SwitchableSession
	 */
	private $session;

	/**
	 * @param Session\SwitchableSession $session
	 */
	public function __construct(
		Session\SwitchableSession $session
	) {
		$this->session = $session;
	}

	/**
	 * @param WebSocketsEntities\Clients\IClient $from
	 * @param WebSocketsHttp\IRequest $httpRequest
	 * @param string $message
	 *
	 * @return void
	 */
	public function __invoke(WebSocketsEntities\Clients\IClient $from, WebSocketsHttp\IRequest $httpRequest, string $message)
	{
		if ($this->session instanceof Session\SwitchableSession) {
			$this->session->attach($from, $httpRequest);

			if (!$this->session->isStarted()) {
				$this->session->start();
			}
		}
	}
}