Chapi\Commands\ListCommand

Complexity

Total Complexity

28

Size/Duplication

Total Lines	191
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	9

Test Coverage

Coverage

96.05%

Importance

Changes	2
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
B	getOutputFormat()	0	25	6
A	configure()	0	8	1
B	process()	0	35	3
D	hasJobToPrint()	0	32	9
A	printJobTableRow()	0	18	1
C	getOutputLabel()	0	38	8

<?php
/**
 * @package: chapi
 *
 * @author:  msiebeneicher
 * @since:   2015-07-28
 *
 */

namespace Chapi\Commands;

use Chapi\Entity\Chronos\ChronosJobEntity;
use Chapi\Entity\JobEntityInterface;
use Chapi\Entity\Marathon\MarathonAppEntity;
use Chapi\Service\JobRepository\JobRepositoryInterface;
use Symfony\Component\Console\Helper\Table;
use Symfony\Component\Console\Input\InputOption;

class ListCommand extends AbstractCommand
{
    const DEFAULT_VALUE_JOB_NAME = 'all';

    /**
     * Configures the current command.
     */
    protected function configure()
    {
        $this->setName('list')
            ->setDescription('Display your jobs and filter them by status')
            ->addOption('onlyFailed', 'f', InputOption::VALUE_NONE, 'Display only failed jobs')
            ->addOption('onlyDisabled', 'd', InputOption::VALUE_NONE, 'Display only disabled jobs')
        ;
    }

    /**
     * @return int
     * @throws \LogicException
     */
    protected function process()
    {
        /** @var JobRepositoryInterface  $_oJobRepositoryChronos */
        $_oJobRepositoryChronos = $this->getContainer()->get(JobRepositoryInterface::DIC_NAME_CHRONOS);
        /** @var  JobRepositoryInterface $_oJobRepositoryMarathon */
        $_oJobRepositoryMarathon = $this->getContainer()->get(JobRepositoryInterface::DIC_NAME_MARATHON);

        $_bOnlyFailed = (bool) $this->oInput->getOption('onlyFailed');
        $_bOnlyDisabled = (bool) $this->oInput->getOption('onlyDisabled');

        $_oTable = new Table($this->oOutput);
        $_oTable->setHeaders(array(
            'Job',
            'Info',
            'Type'
        ));

        $_aAllEntities = array_merge(
            $_oJobRepositoryChronos->getJobs()->getArrayCopy(),
            $_oJobRepositoryMarathon->getJobs()->getArrayCopy()
        );

        /** @var ChronosJobEntity $_oJobEntity */
        foreach ($_aAllEntities as $_oJobEntity)
        {
            if ($this->hasJobToPrint($_oJobEntity, $_bOnlyFailed, $_bOnlyDisabled))
            {
                $this->printJobTableRow($_oTable, $_oJobEntity);
            }
        }

        $_oTable->render();

        return 0;
    }

    /**
     * @param JobEntityInterface $oJobEntity
     * @param bool $bOnlyFailed
     * @param bool $bOnlyDisabled
     * @return bool
     */
    private function hasJobToPrint(JobEntityInterface $oJobEntity, $bOnlyFailed, $bOnlyDisabled)
    {
        if ($oJobEntity->getEntityType() == JobEntityInterface::MARATHON_TYPE)
        {
            return true;
        }

        if (!$oJobEntity instanceof ChronosJobEntity)
        {
            throw new \RuntimeException('Entity not of type ChronosJobEntity');
        }

        $_bPrintAllJobs = (false === $bOnlyFailed && false === $bOnlyDisabled);
        if ($_bPrintAllJobs)
        {
            return true;
        }

        $_bHasToPrint = false;

        if (true === $bOnlyFailed && $oJobEntity->errorsSinceLastSuccess > 0)
        {
            $_bHasToPrint = true;
        }

        if (true === $bOnlyDisabled && true === $oJobEntity->disabled)
        {
            $_bHasToPrint = true;
        }

        return $_bHasToPrint;
    }

    /**
     * @param Table $oTable
     * @param JobEntityInterface $oJobEntity
     */
    private function printJobTableRow(Table $oTable, JobEntityInterface $oJobEntity)
    {
        $oTable->addRow([
            sprintf(
                $this->getOutputFormat($oJobEntity),
                $oJobEntity->getKey()
            ),

            sprintf(
                $this->getOutputFormat($oJobEntity),
                $this->getOutputLabel($oJobEntity)
            ),
            sprintf(
                $this->getOutputFormat($oJobEntity),
                $oJobEntity->getEntityType()
            )
        ]);
    }

    /**
     * @param JobEntityInterface $oJobEntity
     * @return string
     */
    private function getOutputLabel(JobEntityInterface $oJobEntity)
    {

        if ($oJobEntity->getEntityType() == JobEntityInterface::MARATHON_TYPE)
        {
            return 'ok';
        }

        if (!$oJobEntity instanceof ChronosJobEntity)
        {
            throw new \RuntimeException('Entity not of type ChronosJobEntity');
        }

        $_aJobInfoText = [];

        if ($oJobEntity->disabled)
        {
            $_aJobInfoText[] = 'disabled';
        }

        if ($oJobEntity->errorCount > 0)
        {
            $_fErrorRate = ($oJobEntity->successCount > 0)
                ? 100 / $oJobEntity->successCount * $oJobEntity->errorCount
                : 100;

            $_aJobInfoText[] = 'errors rate: ' . round($_fErrorRate, 2) . '%';
        }

        if ($oJobEntity->errorsSinceLastSuccess > 0)
        {
            $_aJobInfoText[] = 'errors since last success:' . $oJobEntity->errorsSinceLastSuccess;
        }

        return (!empty($_aJobInfoText))
            ? implode(' | ', $_aJobInfoText)
            : 'ok';
    }

    /**
     * @param JobEntityInterface $oJobEntity
     * @return string
     */
    private function getOutputFormat(JobEntityInterface $oJobEntity)
    {
        if ($oJobEntity->getEntityType() == JobEntityInterface::MARATHON_TYPE)
        {
            return '<info>%s</info>';
        }

        if (!$oJobEntity instanceof ChronosJobEntity)
        {
            throw new \RuntimeException('Entity not of type ChronosJobEntity');
        }

        if ($oJobEntity->errorsSinceLastSuccess > 0)
        {
            return '<fg=red>%s</>';
        }

        if ($oJobEntity->errorCount > 0 || true === $oJobEntity->disabled)
        {
            return '<comment>%s</comment>';
        }

        // else
        return '<info>%s</info>';
    }
}