Resque\SignalHandler

Complexity

Total Complexity

9

Size/Duplication

Total Lines	48
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	setWorker()	0	3	1
A	register()	0	9	2
A	__construct()	0	8	4
A	setDispatcher()	0	3	1
A	unregister()	0	3	1

<?php

declare(strict_types=1);

namespace Resque;

use Resque\Dispatchers\Noop;
use Resque\Interfaces\Dispatcher;
use Resque\Tasks\BeforeSignalsRegister;

class SignalHandler
{
    private $worker = null;
    private $dispatcher;

    private $signals = [
        SIGTERM => 'shutdown',
        SIGINT => 'shutdown',
        SIGQUIT => 'shutdown',
        SIGUSR1 => 'pause',
        SIGCONT => 'continue',
        SIGUSR2 => 'forceShutdown',
    ];

    public function __construct(array $signals = [])
    {
        foreach ($signals as $type => $signalCallback) {
            if (in_array($type, array_keys($this->signals)) && is_callable($signalCallback)) {
                $this->signals[$type] = $signalCallback;
            }
        }
        $this->dispatcher = new Noop();
    }

    public function setDispatcher(Dispatcher $dispatcher): void
    {
        $this->dispatcher = $dispatcher;
    }

    public function setWorker(Worker $worker): void
    {
        $this->worker = $worker;
    }

    public function register(): void
    {
        $payload = $this->dispatcher->dispatch(BeforeSignalsRegister::class, ['signals' => $this->signals]);
        pcntl_async_signals(true);
        foreach ($payload['signals'] as $signalType => $signalHandler) {
            pcntl_signal($signalType, [$this->worker, $signalHandler]);
        }

        register_shutdown_function([$this, 'unregister']);
    }

    public function unregister(): void
    {
        pcntl_async_signals(false);
    }
}