BlitzPHP\Tasks\Commands\Work

Complexity

Total Complexity

7

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
B	execute()	0	35	7

<?php

/**
 * This file is part of BlitzPHP Tasks.
 *
 * (c) 2025 Dimitri Sitchet Tomkeu <devcode.dst@gmail.com>
 *
 * For the full copyright and license information, please view
 * the LICENSE file that was distributed with this source code.
 */

namespace BlitzPHP\Tasks\Commands;

use BlitzPHP\Utilities\Date;
use Symfony\Component\Process\Process;

class Work extends TaskCommand
{
    /**
     * {@inheritDoc}
     */
    protected $name = 'tasks:work';

    /**
     * {@inheritDoc}
     */
    protected $options = [
        '--run-output-file' => 'Le fichier vers lequel diriger la sortie de `tasks:run`.',
    ];

    /**
     * {@inheritDoc}
     */
    protected $description = 'Démarre le planificateur de tâche et l\'exécute localement.';

    /**
     * @var list<string>
     */
    protected $required = [
        'symfony/process:^7.2',
    ];

    /**
     * {@inheritDoc}
     *
     * @return void
     */
    public function execute(array $params)
    {
        $this->info('Exéctutions des tâches programmées.');

        [$lastExecutionStartedAt, $executions] = [Date::now()->subMinutes(10), []];

        $command = sprintf(
            '%s %s %s',
            escapeshellarg(PHP_BINARY),
            escapeshellarg(base_path('klinge')),
            'tasks:run'
        );

        if ($this->option('run-output-file')) {
            $command .= ' >> ' . escapeshellarg($this->option('run-output-file')) . ' 2>&1';
        }

        while (true) {
            usleep(100 * 1000);

            if ((int) (Date::now()->getSecond()) === 0 && ! Date::now()->startOfMinute()->equalTo($lastExecutionStartedAt)) {
                $executions[] = $execution = Process::fromShellCommandline($command);

                $execution->start();

                $lastExecutionStartedAt = Date::now()->startOfMinute();
            }

            foreach ($executions as $key => $execution) {
                $output = $execution->getIncrementalOutput() . $execution->getIncrementalErrorOutput();

                $this->write(ltrim($output, "\n"))->eol();

                if (! $execution->isRunning()) {
                    unset($executions[$key]);
                }
            }
        }
    }
}