Innmind\AMQP\Client\SignalAware

Complexity

Total Complexity

6

Size/Duplication

Total Lines	48
Duplicated Lines	0 %

Test Coverage

Coverage

95.83%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	channel()	0	5	1
A	close()	0	3	1
A	__construct()	0	4	1
A	register()	0	19	2
A	closed()	0	3	1

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Client;

use Innmind\AMQP\Client as ClientInterface;
use Innmind\OperatingSystem\CurrentProcess\Signals;
use Innmind\Signals\Signal;

final class SignalAware implements ClientInterface
{
    private $client;
    private $signals;
    private $handlersRegistered = false;

    public function __construct(ClientInterface $client, Signals $signals)
    {
        $this->client = $client;
        $this->signals = $signals;
    }

    public function channel(): Channel
    {
        $this->register();

        return $this->client->channel();
    }

    public function closed(): bool
    {
        return $this->client->closed();
    }

    public function close(): void
    {
        $this->client->close();
    }

    private function register(): void
    {
        if ($this->handlersRegistered === true) {
            return;
        }

        $softClose = function(): void {
            $this->close();
        };

        $this->signals->listen(Signal::hangup(), static function() {
            //do nothing so it can run in background
        });
        $this->signals->listen(Signal::interrupt(), $softClose);
        $this->signals->listen(Signal::abort(), $softClose);
        $this->signals->listen(Signal::terminate(), $softClose);
        $this->signals->listen(Signal::terminalStop(), $softClose);
        $this->signals->listen(Signal::alarm(), $softClose);
        $this->handlersRegistered = true;
    }
}