Alpixel\Bundle\CronBundle\Command\CronPruneLogsCommand

Complexity

Total Complexity

5

Size/Duplication

Total Lines	41
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	0	6	1
B	execute()	0	31	4

<?php

namespace Alpixel\Bundle\CronBundle\Command;

use Alpixel\Bundle\CronBundle\Entity\CronJobResult;
use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

class CronPruneLogsCommand extends ContainerAwareCommand
{
    protected function configure()
    {
        $this->setName('cron:pruneLogs')
             ->setDescription('Prunes the logs for each cron job, leaving only recent failures and the most recent success')
             ->addArgument('job', InputArgument::OPTIONAL, 'Operate only on this job');
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $em = $this->getContainer()->get('doctrine.orm.entity_manager');
        $job = $input->getArgument('job');

        if ($job) {
            $output->writeln("Pruning logs for cron job $job");
        } else {
            $output->writeln('Pruning logs for all cron jobs');
        }

        if ($job) {
            $jobObj = $em->getRepository('CronBundle:CronJob')->findOneByCommand($job);
            if (!$jobObj) {
                $output->writeln("Couldn't find a job by the name of ".$job);

                return CronJobResult::FAILED;
            }

            $em->getRepository('CronBundle:CronJobResult')->deleteOldLogs($jobObj);
        } else {
            $em->getRepository('CronBundle:CronJobResult')->deleteOldLogs();
        }

        // Flush the EM
        $em->flush();

        $output->writeln('Logs pruned successfully');

        return CronJobResult::SUCCEEDED;
    }
}