Cushon\HealthBundle\Message\QueryFactory\ServiceContainerHealthCheck

Complexity

Total Complexity

5

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	createQuery()	0	12	2
A	assertHealthCheck()	0	6	2

<?php

declare(strict_types=1);

namespace Cushon\HealthBundle\Message\QueryFactory;

use Cushon\HealthBundle\Message\Query\HealthCheck;
use Cushon\HealthBundle\Message\QueryFactory\ServiceContainerHealthCheck\Exception\IncorrectQueryType;
use Cushon\HealthBundle\Message\QueryFactory\ServiceContainerHealthCheck\Exception\QueryServiceDefinitionNotFound;
use Symfony\Component\DependencyInjection\ContainerInterface;

final class ServiceContainerHealthCheck implements QueryFactory
{
    private ContainerInterface $container;
    private string $definitionName;

    /**
     * @param ContainerInterface $container
     * @param string $definitionName
     */
    public function __construct(
        ContainerInterface $container,
        string $definitionName = HealthCheck::class
    ) {
        $this->container = $container;
        $this->definitionName = $definitionName;
    }


    /**
     * @inheritDoc
     */
    public function createQuery(): HealthCheck
    {
        if (!$this->container->has($this->definitionName)) {
            throw QueryServiceDefinitionNotFound::create($this->container, $this->definitionName);
        }

        /** @var object $query */
        $query =  $this->container->get(HealthCheck::class);
        $this->assertHealthCheck($query);

        /** @var HealthCheck $query */
        return $query;
    }

    /**
     * @param object $query
     * @return void
     * @psalm-assert HealthCheck $query
     */
    private function assertHealthCheck(object $query): void
    {
        if (!$query instanceof HealthCheck) {
            throw IncorrectQueryType::create(
                HealthCheck::class,
                $query
            );
        }
    }
}