T4web\Cron\Config

Complexity

Total Complexity

24

Size/Duplication

Total Lines	153
Duplicated Lines	0 %

Coupling/Cohesion

Components	3
Dependencies	2

Importance

Changes	2
Bugs	0	Features	1

9 Methods

Rating	Name	Duplication	Size	Complexity
C	__construct()	0	31	13
A	prepareLogDirectory()	0	14	3
A	getLogDirectory()	0	4	1
A	getJobs()	0	4	1
A	getJob()	0	4	1
A	hasJobs()	0	4	1
A	getPhpPath()	0	4	1
A	getScriptPath()	0	7	2
A	getTimeout()	0	4	1

<?php

namespace T4web\Cron;

use Zend\Stdlib;
use T4web\Cron\Exception\RuntimeException;
use T4web\Cron\Log\FileSystem;

class Config
{
    /**
     * Array of shell jobs.
     *
     * @var array
     */
    protected $jobs = [];

    /**
     * PHP executable path for using shell jobs. Defaults 'php'.
     *
     * @var string
     */
    protected $phpPath = 'php';

    /**
     * Base path for script. Defaults 'getcwd()/public/'.
     *
     * @var string
     */
    protected $scriptPath = null;

    /**
     * Timeout in seconds for the process. null for no timeout.
     *
     * @var int
     */
    protected $timeout = null;

    /**
     * @var string
     */
    protected $logDirectory;

    /**
     * @var FileSystem
     */
    protected $fileSystem;

    /**
     * Config constructor.
     *
     * @param array           $config
     * @param FileSystem|null $filesystem
     */
    public function __construct(array $config = [], FileSystem $filesystem = null)
    {
        if (!$filesystem) {
            $filesystem = new FileSystem();
        }

        $this->fileSystem = $filesystem;

        if (isset($config['phpPath']) && !empty($config['phpPath'])) {
            $this->phpPath = $config['phpPath'];
        }

        if (isset($config['scriptPath']) && !empty($config['scriptPath'])) {
            $this->scriptPath = $config['scriptPath'];
        }

        if (isset($config['jobs']) && !empty($config['jobs']) && is_array($config['jobs'])) {
            $this->jobs = $config['jobs'];
        }

        if (isset($config['timeout']) && !empty($config['timeout'])) {
            $this->timeout = $config['timeout'];
        }

        $logDirectory = null;
        if (isset($config['log-directory']) && !empty($config['log-directory'])) {
            $logDirectory = $config['log-directory'];
        }

        $this->logDirectory = $this->prepareLogDirectory($logDirectory);
    }

    private function prepareLogDirectory($logDirectory)
    {
        if (empty($logDirectory)) {
            $logDirectory = getcwd() . '/data';
        }

        $logDirectory = rtrim($logDirectory, '/');

        if (!$this->fileSystem->isWritable($logDirectory)) {
            throw new RuntimeException("Directory $logDirectory must be writable");
        }

        return $logDirectory;
    }

    /**
     * @return string
     */
    public function getLogDirectory()
    {
        return $this->logDirectory;
    }

    /**
     * @return array
     */
    public function getJobs()
    {
        return $this->jobs;
    }

    /**
     * @param $key
     * @return array
     */
    public function getJob($key)
    {
        return $this->jobs[$key];
    }

    /**
     * @return boolean
     */
    public function hasJobs()
    {
        return (bool) (count($this->jobs) > 0);
    }

    /**
     * @return string
     */
    public function getPhpPath()
    {
        return $this->phpPath;
    }

    /**
     * @return string
     */
    public function getScriptPath()
    {
        if (!$this->scriptPath) {
            $this->scriptPath = getcwd() . DIRECTORY_SEPARATOR  . 'public' . DIRECTORY_SEPARATOR;
        }
        return $this->scriptPath;
    }

    /**
     * @return int
     */
    public function getTimeout()
    {
        return $this->timeout;
    }
}