Jalle19\StatusManager\Instance\InstanceStatus

Complexity

Total Complexity

13

Size/Duplication

Total Lines	170
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	getAvailableNetworks()	0	3	1
A	getInstanceName()	0	3	1
A	getSubscriptionStateChanges()	0	3	1
A	__construct()	0	16	1
A	getSubscriptions()	0	3	1
A	getInputs()	0	3	1
A	getSubscriptionAggregates()	0	17	4
A	getConnections()	0	3	1
A	getAvailableMuxes()	0	3	1
A	jsonSerialize()	0	11	1

<?php

namespace Jalle19\StatusManager\Instance;

use Jalle19\StatusManager\Subscription\StateChange;
use Jalle19\tvheadend\model\ConnectionStatus;
use Jalle19\tvheadend\model\InputStatus;
use Jalle19\tvheadend\model\multiplex\Multiplex;
use Jalle19\tvheadend\model\network\Network;
use Jalle19\tvheadend\model\SubscriptionStatus;

/**
 * Class InstanceStatus
 * @package   Jalle19\StatusManager\Instance
 * @copyright Copyright &copy; Sam Stenvall 2015-
 * @license   https://www.gnu.org/licenses/gpl.html The GNU General Public License v2.0
 */
class InstanceStatus implements \JsonSerializable
{

	/**
	 * @var string the name of the instance
	 */
	private $_instanceName;

	/**
	 * @var Network[]
	 */
	private $_availableNetworks;

	/**
	 * @var Multiplex[]
	 */
	private $_availableMuxes;

	/**
	 * @var InputStatus[]
	 */
	private $_inputs;

	/**
	 * @var SubscriptionStatus[]
	 */
	private $_subscriptions;

	/**
	 * @var ConnectionStatus[]
	 */
	private $_connections;

	/**
	 * @var StateChange[]
	 */
	private $_subscriptionStateChanges;


	/**
	 * BroadcastMessage constructor.
	 *
	 * @param string               $instanceName
	 * @param Network[]            $availableNetworks
	 * @param Multiplex[]          $availableMuxes
	 * @param InputStatus[]        $inputs
	 * @param SubscriptionStatus[] $subscriptions
	 * @param ConnectionStatus[]   $connections
	 * @param StateChange[]        $subscriptionStateChanges
	 *
	 */
	public function __construct(
		$instanceName,
		array $availableNetworks,
		array $availableMuxes,
		array $inputs,
		array $subscriptions,
		array $connections,
		array $subscriptionStateChanges
	) {
		$this->_instanceName             = $instanceName;
		$this->_inputs                   = $inputs;
		$this->_subscriptions            = $subscriptions;
		$this->_connections              = $connections;
		$this->_subscriptionStateChanges = $subscriptionStateChanges;
		$this->_availableNetworks        = $availableNetworks;
		$this->_availableMuxes           = $availableMuxes;
	}


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


	/**
	 * @return Network[]
	 */
	public function getAvailableNetworks(): array
	{
		return $this->_availableNetworks;
	}


	/**
	 * @return Multiplex[]
	 */
	public function getAvailableMuxes(): array
	{
		return $this->_availableMuxes;
	}


	/**
	 * @return ConnectionStatus[]
	 */
	public function getConnections()
	{
		return $this->_connections;
	}


	/**
	 * @return InputStatus[]
	 */
	public function getInputs()
	{
		return $this->_inputs;
	}


	/**
	 * @return SubscriptionStatus[]
	 */
	public function getSubscriptions()
	{
		return $this->_subscriptions;
	}


	/**
	 * @return StateChange[]
	 */
	public function getSubscriptionStateChanges()
	{
		return $this->_subscriptionStateChanges;
	}


	/**
	 * @return array aggregate input/output bandwidth of all subscriptions
	 */
	public function getSubscriptionAggregates()
	{
		$aggregates = [
			'input'  => 0,
			'output' => 0,
		];

		foreach ($this->_subscriptions as $subscription)
		{
			// Bandwidth may be null from time to time
			if (is_numeric($subscription->in))
				$aggregates['input'] += $subscription->in;
			if (is_numeric($subscription->out))
				$aggregates['output'] += $subscription->out;
		}

		return $aggregates;
	}


	/**
	 * @inheritdoc
	 */
	public function jsonSerialize()
	{
		return [
			'instanceName'             => $this->_instanceName,
			'availableNetworks'        => $this->_availableNetworks,
			'availableMuxes'           => $this->_availableMuxes,
			'inputs'                   => $this->_inputs,
			'subscriptions'            => $this->_subscriptions,
			'connections'              => $this->_connections,
			'subscriptionStateChanges' => $this->_subscriptionStateChanges,
			'subscriptionAggregates'   => $this->getSubscriptionAggregates(),
		];
	}

}