Cushon\HealthBundle\Handler\CheckHealth\DefaultHealthCheck

Complexity

Total Complexity

4

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	handleApplicationHealthError()	0	6	1
A	__invoke()	0	13	2
A	__construct()	0	5	1

<?php

declare(strict_types=1);

namespace Cushon\HealthBundle\Handler\CheckHealth;

use Cushon\HealthBundle\ApplicationHealth\Dependencies;
use Cushon\HealthBundle\ApplicationHealth\Exception\ApplicationHealthError;
use Cushon\HealthBundle\Handler\CheckHealth;
use Cushon\HealthBundle\Handler\CheckHealth\Exception\ApplicationHealthCheckFailure;
use Cushon\HealthBundle\Message\Query\HealthCheck as HealthCheckQuery;
use Cushon\HealthBundle\Message\Result\HealthCheck as HealthCheckResult;

final class DefaultHealthCheck implements CheckHealth
{
    private Dependencies $dependencies;
    private Logger $logger;
    private ResultFactory $resultFactory;

    /**
     * @param Dependencies $dependencies
     * @param Logger $logger
     * @param ResultFactory $resultFactory
     */
    public function __construct(Dependencies $dependencies, Logger $logger, ResultFactory $resultFactory)
    {
        $this->dependencies = $dependencies;
        $this->logger = $logger;
        $this->resultFactory = $resultFactory;
    }

    /**
     * @inheritDoc
     */
    public function __invoke(HealthCheckQuery $healthCheck): HealthCheckResult
    {
        $this->logger->begin($healthCheck);
        try {
            $health = $this->dependencies->check();
        } catch (ApplicationHealthError $exc) {
            throw $this->handleApplicationHealthError($exc);
        }

        $result = $this->resultFactory->fromHealth($health);
        $this->logger->complete($result);

        return $result;
    }

    /**
     * @param ApplicationHealthError $exc
     * @return ApplicationHealthCheckFailure
     */
    private function handleApplicationHealthError(ApplicationHealthError $exc): ApplicationHealthCheckFailure
    {
        $failure = ApplicationHealthCheckFailure::fromApplicationHealthError($exc);
        $this->logger->error($failure);

        return $failure;
    }
}