spryker / spryker-core

Bundles/StateMachine/src/Spryker/Zed/StateMachine/Communication/Console/CheckTimeoutConsole.php

<?php

/**
 * Copyright © 2016-present Spryker Systems GmbH. All rights reserved.
 * Use of this software requires acceptance of the Evaluation License Agreement. See LICENSE file.
 */

namespace Spryker\Zed\StateMachine\Communication\Console;

use Spryker\Zed\Kernel\Communication\Console\Console;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;

/**
 * @method \Spryker\Zed\StateMachine\Business\StateMachineFacadeInterface getFacade()
 * @method \Spryker\Zed\StateMachine\Persistence\StateMachineQueryContainerInterface getQueryContainer()
 * @method \Spryker\Zed\StateMachine\Communication\StateMachineCommunicationFactory getFactory()
 * @method \Spryker\Zed\StateMachine\Persistence\StateMachineRepositoryInterface getRepository()
 */
class CheckTimeoutConsole extends Console
{
    /**
     * @var string
     */
    public const COMMAND_NAME = 'state-machine:check-timeout';

    /**
     * @var string
     */
    public const COMMAND_DESCRIPTION = 'Check timeouts';

    /**
     * @var string
     */
    public const ARGUMENT_STATE_MACHINE_NAME = 'state machine name';

    /**
     * @var string
     */
    public const OPTION_STATE_MACHINE_NAME = 'state-machine-name';

    /**
     * @return void
     */
    protected function configure(): void
    {
        $this->setName(static::COMMAND_NAME);
        $this->setDescription(static::COMMAND_DESCRIPTION);

        $this->addArgument(
            static::ARGUMENT_STATE_MACHINE_NAME,
            InputArgument::OPTIONAL,
            'Name of state machine to trigger timeout expired items',
        );

        $this->addOption(
            static::OPTION_STATE_MACHINE_NAME,
            's',
            InputOption::VALUE_REQUIRED,
            '(deprecated) Name of state machine to trigger timeout expired items',
        );

        parent::configure();
    }

    /**
     * @param \Symfony\Component\Console\Input\InputInterface $input
     * @param \Symfony\Component\Console\Output\OutputInterface $output
     *
     * @return int
     */
    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        /** @var string|null $optionStateMachineName */
        $optionStateMachineName = $this->input->getOption(static::OPTION_STATE_MACHINE_NAME);
        /** @var string|null $argumentStateMachineName */
        $argumentStateMachineName = $this->input->getArgument(static::ARGUMENT_STATE_MACHINE_NAME);

        $isValidArgument = $this->validateStateMachineNameArgument($argumentStateMachineName);
        if ($isValidArgument === null) {
            $this->validateStateMachineNameOption($optionStateMachineName);
        }
        if ($isValidArgument === false) {
            return static::CODE_SUCCESS;
        }

        $affected = $this->getFacade()->checkTimeouts($isValidArgument === null ? $optionStateMachineName : $argumentStateMachineName);

The condition $isValidArgument === null is always false.

        if ($output->isVerbose()) {
            $output->writeln('Affected: ' . $affected);
        }

        return static::CODE_SUCCESS;
    }

    /**
     * @param string|null $stateMachineName
     *
     * @return void
     */
    protected function validateStateMachineNameOption($stateMachineName)
    {
        if ($stateMachineName === null) {
            $this->info('No state machine name was provided.');

            return;
        }

        if (!$this->getFacade()->stateMachineExists($stateMachineName)) {
            $this->info(sprintf('State machine "%s" was not found. ', $stateMachineName));
        }
    }

    /**
     * @param string|null $stateMachineName
     *
     * @return bool|null
     */
    protected function validateStateMachineNameArgument($stateMachineName)
    {
        if ($stateMachineName === null) {
            return null;
        }

        if ($this->getFacade()->stateMachineExists($stateMachineName)) {
            return true;
        }

        $this->error(sprintf('State machine "%s" was not found.', $stateMachineName));

        return false;
    }
}