RemotelyLiving\PHPDNS\Observability\Subscribers\STDIOSubscriber

Complexity

Total Complexity

5

Size/Duplication

Total Lines	28
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	2	1
A	getSubscribedEvents()	0	6	1
A	onDNSQueried()	0	3	1
A	onDNSQueryFailed()	0	3	1
A	onDNSQueryProfiled()	0	3	1

<?php

namespace RemotelyLiving\PHPDNS\Observability\Subscribers;

use RemotelyLiving\PHPDNS\Observability\Events\DNSQueried;
use RemotelyLiving\PHPDNS\Observability\Events\DNSQueryFailed;
use RemotelyLiving\PHPDNS\Observability\Events\DNSQueryProfiled;
use RemotelyLiving\PHPDNS\Observability\Events\ObservableEventAbstract;
use SplFileObject;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;

use function json_encode;

final class STDIOSubscriber implements EventSubscriberInterface
{
    public function __construct(private SplFileObject $STDOUT, private SplFileObject $STDERR)
    {
    }

    public static function getSubscribedEvents()
    {
        return [
            DNSQueryFailed::getName() => 'onDNSQueryFailed',
            DNSQueried::getName() => 'onDNSQueried',
            DNSQueryProfiled::getName() => 'onDNSQueryProfiled',
        ];
    }

    public function onDNSQueryFailed(ObservableEventAbstract $event): void
    {
        $this->STDERR->fwrite(json_encode($event, JSON_PRETTY_PRINT) . PHP_EOL);
    }

    public function onDNSQueried(ObservableEventAbstract $event): void
    {
        $this->STDOUT->fwrite(json_encode($event, JSON_PRETTY_PRINT) . PHP_EOL);
    }

    public function onDNSQueryProfiled(ObservableEventAbstract $event): void
    {
        $this->STDOUT->fwrite(json_encode($event, JSON_PRETTY_PRINT) . PHP_EOL);
    }
}