oficial/cli/src/Command/BaseLoop.php

<?php
namespace Incoviba\Command;

use Throwable;
use DateTimeInterface;
use DateTimeImmutable;
use Psr\Log\LoggerInterface;
use Symfony\Component\Console;
use Incoviba\Service\Schedule;

#[Console\Attribute\AsCommand(
    name: 'loop',
    description: 'Run base loop',
)]
class BaseLoop extends Console\Command\Command
{
    public function __construct(protected LoggerInterface $logger, protected Schedule $scheduleService, ?string $name = null)
    {
        parent::__construct($name);
    }

    public function execute(Console\Input\InputInterface $input, Console\Output\OutputInterface $output): int
    {
        $this->write($output, 'Running loop...');

        $this->waitNextMinute($output);

        $this->write($output, 'Starting loop...');
        while (true) {
            $commands = $this->scheduleService->getPending();
            foreach ($commands as $command) {
                $this->runCommand($input, $output, $command);
                sleep(10);
            }
        }
        return self::SUCCESS;
    }
    protected function waitNextMinute(Console\Output\OutputInterface $output): void
    {
        // wait for next minute
        $now = new DateTimeImmutable();
        $nextMinute = new DateTimeImmutable($now->format('Y-m-d H:i:00'));
        $nextMinute = $nextMinute->add(new \DateInterval('PT1M'));
        $this->logger->debug('Wait', [
            'now' => $now->format('Y-m-d H:i:s.u'),
            'nextMinute' => $nextMinute->format('Y-m-d H:i:s.u'),
        ]);
        $diff = $nextMinute->getTimestamp() - $now->getTimestamp();
        if ($diff > 0) {
            $output->writeln("Waiting {$diff} seconds...");
            sleep($diff);
        }
    }
    protected function runCommand(Console\Input\InputInterface $input, Console\Output\OutputInterface $output, string $commandName): int
    {
        try {
            $command = $this->getApplication()->find($commandName);
        } catch (Console\Exception\CommandNotFoundException $exception) {
            $this->logger->warning($exception);
        }

        $cmd = new Console\Input\ArrayInput([
            'command' => $commandName
        ]);
        try {
            return $this->getApplication()->doRun($cmd, $output);
        } catch (Throwable $exception) {
            $this->logger->warning($exception);
            return self::FAILURE;
        }
    }
    protected function write(Console\Output\OutputInterface $output, string $message): void
    {
        $now = new DateTimeImmutable();
        $output->writeln("[{$now->format('Y-m-d H:i:s e')}] {$message}");
    }
}