PommProject\Foundation\Client\ClientHolder

Complexity

Total Complexity

12

Size/Duplication

Total Lines	114
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	add()	0	6	1
A	has()	0	4	1
A	get()	0	4	2
A	getAllFor()	0	8	2
A	clear()	0	9	2
A	shutdown()	0	18	4

<?php
/*
 * This file is part of the Pomm's Foundation package.
 *
 * (c) 2014 - 2017 Grégoire HUBERT <hubert.greg@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */
namespace PommProject\Foundation\Client;

use PommProject\Foundation\Exception\PommException;

/**
 * ClientHolder
 *
 * Session clients are stored in this holder.
 *
 * @package   Pomm
 * @copyright 2014 - 2017 Grégoire HUBERT
 * @author    Grégoire HUBERT
 * @license   X11 {@link http://opensource.org/licenses/mit-license.php}
 */
class ClientHolder
{
    protected $clients = [];

    /**
     * add
     *
     * Add a new client or replace existing one.
     *
     * @param  ClientInterface $client
     * @return ClientHolder    $this
     */
    public function add(ClientInterface $client)
    {
        $this->clients[$client->getClientType()][$client->getClientIdentifier()] = $client;

        return $this;
    }

    /**
     * has
     *
     * Tell if a client is in the pool or not.
     *
     * @param  string $type
     * @param  string $name
     * @return bool
     */
    public function has($type, $name)
    {
        return (bool) isset($this->clients[$type][$name]);
    }

    /**
     * get
     *
     * Return a client by its name or null if no client exist for that name.
     *
     * @param  string          $type
     * @param  string          $name
     * @return ClientInterface
     */
    public function get($type, $name)
    {
        return isset($this->clients[$type][$name]) ? $this->clients[$type][$name] : null;
    }

    /**
     * getAllFor
     *
     * Return all clients for a given type.
     *
     * @param  string $type
     * @return array
     */
    public function getAllFor($type)
    {
        if (!isset($this->clients[$type])) {
            return [];
        }

        return $this->clients[$type];
    }

    /**
     * clear
     *
     * Call shutdown and remove a client from the pool. If the client does not
     * exist, nothing is done.
     *
     * @param  string       $type
     * @param  string       $name
     * @return ClientHolder $this
     */
    public function clear($type, $name)
    {
        if (isset($this->clients[$type][$name])) {
            $this->clients[$type][$name]->shutdown();
            unset($this->clients[$type][$name]);
        }

        return $this;
    }

    /**
     * shutdown
     *
     * Call shutdown for all registered clients and unset the clients so they
     * can be cleaned by GC. It would have been better by far to use a
     * RecursiveArrayIterator to do this but it is not possible in PHP using
     * built'in iterators hence the double foreach recursion.
     * see http://fr2.php.net/manual/en/class.recursivearrayiterator.php#106519
     *
     * @return array exceptions caught during the shutdown
     */
    public function shutdown()
    {
        $exceptions = [];

        foreach ($this->clients as $type => $names) {
            foreach ($names as $name => $client) {
                try {
                    $client->shutdown();
                } catch (PommException $e) {
                    $exceptions[] = $e;
                }
            }
        }

        $this->clients = [];

        return $exceptions;
    }
}