Bernard\EventListener\Doctrine\PingEventListener

Complexity

Total Complexity

7

Size/Duplication

Total Lines	38
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	getSubscribedEvents()	0	6	1
A	__construct()	0	8	2
A	onPing()	0	14	4

<?php

namespace Bernard\EventListener\Doctrine;

use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Doctrine\DBAL\DBALException;

/**
 * Inspired by Swarrots ConnectionProcessor (https://github.com/swarrot/swarrot/blob/master/src/Swarrot/Processor/Doctrine/ConnectionProcessor.php)
 *
 * @author Markus Bachmann <markus.bachmann@bachi.biz>
 * @package Bernard
 */
class PingEventListener implements EventSubscriberInterface
{
    /**
     * @var Connection[]
     */
    private $connections;

    public static function getSubscribedEvents()
    {
        return [
            'bernard.invoke' => 'onPing',
        ];
    }

    public function __construct($connections)
    {
        if (!is_array($connections)) {
            $connections = [$connections];
        }

        $this->connections = $connections;
    }

    public function onPing()
    {
        foreach ($this->connections as $connection) {
            if (!$connection->isConnected()) {
                continue;
            }

            try {
                $connection->query($connection->getDatabasePlatform()->getDummySelectSQL());
            } catch (DBALException $e) {
                $connection->close(); // close timed out connections so that using them connects again
            }
        }
    }
}