Na}{

File Content: BackgroundTaskProcessCreator.php

<?php

use BackgroundTasks\BaseTaskInterface;
use BackgroundTasks\DatabaseStorage\BackgroundTaskBrokerInterface;
use BackgroundTasks\DatabaseStorage\BackgroundTaskParamsBrokerInterface;
use BackgroundTasks\DatabaseStorage\BackgroundTaskRowInterface;
use BackgroundTasks\DataStorage\SaasTaskDataStorage;
use Psr\Log\LoggerInterface;
use WPToolkitDependenciesIsolationPrefix\React\ChildProcess\Process;
use WPToolkitDependenciesIsolationPrefix\React\EventLoop\LoopInterface;
class BackgroundTaskProcessCreator
{
    /**
     * @var LoggerInterface
     */
    private $logger;
    /**
     * @var string[]
     */
    private $commandWithArgs;
    /**
     * @var BackgroundTaskParamsBrokerInterface
     */
    private $backgroundTaskParamsBroker;
    /**
     * @param BackgroundTaskParamsBrokerInterface $backgroundTaskParamsBroker
     * @param LoggerInterface $logger
     * @param string[] $commandWithArgs Command to execute. Task id will be automatically passed in arguments
     */
    public function __construct(BackgroundTaskParamsBrokerInterface $backgroundTaskParamsBroker, LoggerInterface $logger, array $commandWithArgs)
    {
        $this->backgroundTaskParamsBroker = $backgroundTaskParamsBroker;
        $this->logger = $logger;
        $this->commandWithArgs = $commandWithArgs;
    }
    public function createTaskProcess(LoopInterface $loop, BackgroundTaskRowInterface $backgroundTask) : void
    {
        $escapedCommand = \implode(' ', \array_map(function ($command) {
            return \escapeshellarg($command);
        }, $this->commandWithArgs));
        $taskId = (int) $backgroundTask->getId();
        $this->logger->debug("Starting process for task '{id}'", ['id' => $taskId]);
        $stdoutLogger = $this->createLogger($taskId);
        $stderrLogger = $this->createLogger($taskId);
        $escapedLongTaskId = \escapeshellarg($taskId);
        $process = new Process("{$escapedCommand} {$escapedLongTaskId}");
        $process->start($loop);
        $process->stdout->on('data', $stdoutLogger->onData());
        $process->stdout->on('end', $stdoutLogger->onEnd());
        $process->stderr->on('data', $stderrLogger->onData());
        $process->stderr->on('end', $stderrLogger->onEnd());
        $process->on('exit', function ($exitCode, $termSignal) use($backgroundTask, $taskId) {
            $this->logger->debug("Process for task '{id}' exited with code '{code}' and signal '{signal}'", ['id' => $taskId, 'code' => $exitCode, 'signal' => $termSignal]);
            if ((int) $exitCode === 0 && \is_null($termSignal)) {
                return;
            }
            $backgroundTask->setStatus(BaseTaskInterface::STATUS_ERROR);
            $taskDataStorage = new SaasTaskDataStorage($backgroundTask, $this->backgroundTaskParamsBroker);
            $taskDataStorage->addError("Task is not responding, error code '{$exitCode}'");
        });
        $backgroundTask->setPid($process->getPid());
    }
    private function createLogger(int $taskId) : \BackgroundTasks\Executor\ConsoleTasks\ChildProcessOutputLogger
    {
        return new \BackgroundTasks\Executor\ConsoleTasks\ChildProcessOutputLogger($this->logger, "[Task id: {$taskId}] ");
    }
}

Name	Size	Permission
Queue	---	0755
BackgroundTaskProcessCreator.php	3319 bytes	0644
BackgroundTasksExecutor.php	4362 bytes	0644
ChildProcessOutputLogger.php	1472 bytes	0644
SingleBackgroundTasksExecutor.php	2401 bytes	0644