Oliverde8\Component\PhpEtl\PerExecutionContextFactory

Complexity

Total Complexity

3

Size/Duplication

Total Lines	31
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	get()	0	12	2

<?php
declare(strict_types=1);

namespace Oliverde8\Component\PhpEtl;

use Oliverde8\Component\PhpEtl\Factory\FileSystemFactoryInterface;
use Oliverde8\Component\PhpEtl\Factory\LoggerFactoryInterface;
use Oliverde8\Component\PhpEtl\Model\ExecutionContext;
use Oliverde8\Component\PhpEtl\Model\ExecutionInterface;
use Oliverde8\Component\PhpEtl\Model\PerExecutionExecutionContext;

class PerExecutionContextFactory implements ExecutionContextFactoryInterface
{
    private ChainWorkDirManager $dirManager;

    private FileSystemFactoryInterface $fileSystemFactory;

    private LoggerFactoryInterface $loggerFactory;

    public function __construct(
        ChainWorkDirManager $dirManager,
        FileSystemFactoryInterface $fileSystemFactory,
        LoggerFactoryInterface $loggerFactory
    ) {
        $this->dirManager = $dirManager;
        $this->fileSystemFactory = $fileSystemFactory;
        $this->loggerFactory = $loggerFactory;
    }


    public function get(array $parameters): ExecutionContext
    {
        $execution = $parameters['etl']['execution'] ?? null;
        if (!$execution instanceof ExecutionInterface) {
            throw new \LogicException("Etl execution needs to have a unique execution object of type ExecutionInterface as per Execution Context is used");
        }

        $fileSystem = $this->fileSystemFactory->get($execution);
        $logger = $this->loggerFactory->get($execution);
        $workDir = $this->dirManager->getLocalTmpWorkDir($execution);

        return new PerExecutionExecutionContext($parameters, $fileSystem, $logger, $workDir);
    }
}