Webparking\QueueEnsurer\Processes\ProcessManager

Complexity

Total Complexity

5

Size/Duplication

Total Lines	42
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	isStillRunning()	0	3	1
A	killProcess()	0	3	1
A	startProcess()	0	29	3

<?php

namespace Webparking\QueueEnsurer\Processes;

class ProcessManager
{
    public function isStillRunning(int $processId): bool
    {
        return posix_kill($processId, 0);
    }

    public function startProcess(
        string $phpPath,
        string $queueName,
        ?string $connection,
        bool $specifyQueue,
        int $timeout,
        int $sleep,
        int $tries
    ): int {
        $command = $phpPath;
        $command .= ' artisan queue:work';

        if (null !== $connection) {
            $command .= ' ' . $connection;
        }

        if ($specifyQueue) {
            $command .= ' --queue ' . $queueName;
        }

        $command .= ' --timeout ' . $timeout;
        $command .= ' --sleep ' . $sleep;
        $command .= ' --tries ' . $tries;

        // Suppress output and return PID
        $command .= ' > /dev/null & echo $!';

        return (int) exec(
            $command
        );
    }

    public function killProcess(int $processId): void
    {
        posix_kill($processId, 9);
    }
}