Oliverde8\PhpEtlBundle\Services\ChainExecutionLogger

Complexity

Total Complexity

7

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	write()	0	8	3
A	__construct()	0	4	1
A	setCurrentExecution()	0	11	3

<?php


namespace Oliverde8\PhpEtlBundle\Services;

use Monolog\Handler\AbstractProcessingHandler;

The type Monolog\Handler\AbstractProcessingHandler was not found. Maybe you did not declare it correctly or list all dependencies?

use Monolog\Handler\StreamHandler;

The type Monolog\Handler\StreamHandler was not found. Maybe you did not declare it correctly or list all dependencies?

use Monolog\Logger;

The type Monolog\Logger was not found. Maybe you did not declare it correctly or list all dependencies?

use Oliverde8\PhpEtlBundle\Entity\EtlExecution;

class ChainExecutionLogger extends AbstractProcessingHandler
{
    /** @var ChainWorkDirManager */
    protected $chainWorkDirManager;

    protected $level;

    /** @var EtlExecution */
    protected $currentExecution;

    /** @var AbstractProcessingHandler */
    protected $currentStreamHandler;

    /**
     * ChainExecutionLogger constructor.
     *
     * @param ChainProcessorsManager $chainProcessorManager
     * @param ChainWorkDirManager $chainWorkDirManager
     * @param string $level
     */
    public function __construct(ChainWorkDirManager $chainWorkDirManager, string $level = Logger::DEBUG)
    {
        $this->chainWorkDirManager = $chainWorkDirManager;
        $this->level = $level;
    }


    protected function write(array $record)
    {
        // TODO Optimize this by moving it into isHandling.
        if (is_null($this->currentExecution) || is_null($this->currentStreamHandler)) {
            return;
        }

        $this->currentStreamHandler->write($record);
    }

    /**
     * @param EtlExecution|null $currentExecution
     */
    public function setCurrentExecution(?EtlExecution $currentExecution): void
    {
        if ($this->currentStreamHandler) {
            $this->currentStreamHandler->close();
            $this->currentStreamHandler = null;
        }

        $this->currentExecution = $currentExecution;
        if ($currentExecution) {
            $logFile = $this->chainWorkDirManager->getWorkDir($currentExecution) . "/execution.log";
            $this->currentStreamHandler = new StreamHandler($logFile, $this->level);
        }
    }
}