eXpansion\Framework\Core\Plugins\DatabaseConnectionPersist

Complexity

Total Complexity

5

Size/Duplication

Total Lines	53
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

0%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	onPreLoop()	0	4	1
A	onPostLoop()	0	4	1
A	onEverySecond()	0	9	2

<?php

namespace eXpansion\Framework\Core\Plugins;

use eXpansion\Framework\Core\DataProviders\Listener\ListenerInterfaceExpTimer;
use Propel\Runtime\Propel;
use Psr\Log\LoggerInterface;

/**
 * Class DatabaseConnectionPersist
 *
 * @author    de Cramer Oliver<oldec@smile.fr>
 * @copyright 2018 Smile
 * @package eXpansion\Framework\Core\Plugins
 */
class DatabaseConnectionPersist implements ListenerInterfaceExpTimer
{
    /** @var int */
    protected $lastPing = 0;

    /** @var int */
    protected $pingInterval;

    /** @var LoggerInterface */
    protected $logger;

    /**
     * DatabaseConnectionPersist constructor.
     *
     * @param int $pingInterval
     * @param LoggerInterface $logger
     */
    public function __construct(int $pingInterval, LoggerInterface $logger)
    {
        $this->pingInterval = $pingInterval;
        $this->logger = $logger;
    }


    /**
     * @inheritdoc
     */
    public function onPreLoop()
    {
        // Nothing.
    }

    /**
     * @inheritdoc
     */
    public function onPostLoop()
    {
        // Nothing.
    }

    /**
     * @inheritdoc
     */
    public function onEverySecond()
    {
        if ((time() - $this->lastPing) > $this->pingInterval) {
            Propel::getConnection()->inTransaction();

            $this->logger->debug('Pinged database to persist connection!');
            $this->lastPing = time();
        }
    }
}