TonicHealthCheck\Check\Email\SendReceiveCheck::check()

Complexity

Conditions	3
Paths	3

Size

Total Lines	15
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	9
CRAP Score	3

Importance

Changes	2
Bugs	1	Features	1

1 Method

Rating	Name	Duplication	Size	Complexity
A	SendReceiveCheck::getLabel()	0	4	1

<?php

namespace TonicHealthCheck\Check\Email;

use Exception;
use Psr\Log\LoggerInterface;
use TonicHealthCheck\Check\CheckInterface;
use TonicHealthCheck\Check\Email\Receive\EmailReceiveCheck;
use TonicHealthCheck\Check\Email\Send\EmailSendCheck;
use TonicHealthCheck\Check\ResultInterface;

/**
 * Class SendReceiveCheck.
 */
class SendReceiveCheck extends AbstractEmailCheck
{
    const EMAIL_SEND_CHECK_MSG = '%s:Email send check %s';
    const EMAIL_RECEIVE_CHECK_MSG = '%s:Email receive check %s';
    const CHECK_OK = 'OK';
    const CHECK_FAIL = 'FAIL';
    const ERROR_MSG = 'Error:%s';

    /**
     * @var LoggerInterface
     */
    private $healthCheckerLogger;

    /**
     * @var EmailSendCheck
     */
    private $emailSendCheck;

    /**
     * @var EmailReceiveCheck
     */
    private $emailReceiveCheck;

    /**
     * Init Dependency.
     *
     * @param LoggerInterface   $healthCheckerLogger
     * @param EmailSendCheck    $emailSendCheck
     * @param EmailReceiveCheck $emailReceiveCheck
     */
    public function __construct(
        LoggerInterface $healthCheckerLogger,
        EmailSendCheck $emailSendCheck,
        EmailReceiveCheck $emailReceiveCheck
    ) {
        $this->setHealthCheckerLogger($healthCheckerLogger);
        $this->setEmailSendCheck($emailSendCheck);
        $this->setEmailReceiveCheck($emailReceiveCheck);
    }

    /**
     * Check email send&receive.
     *
     * @return ResultInterface
     *
     * @throws Exception
     */
    public function performCheck()
    {
        $this->emailCheck($this->getEmailSendCheck(), self::EMAIL_SEND_CHECK_MSG);
        $this->emailCheck($this->getEmailReceiveCheck(), self::EMAIL_RECEIVE_CHECK_MSG);
    }

    /**
     * Return a label describing this test instance.
     *
     * @return string
     */
    public function getLabel()
    {
        return $this->getEmailSendCheck()->getIndent().' <-> '.$this->getEmailReceiveCheck()->getIndent();
    }

    /**
     * @return LoggerInterface
     */
    protected function getHealthCheckerLogger()
    {
        return $this->healthCheckerLogger;
    }

    /**
     * @return EmailReceiveCheck
     */
    protected function getEmailReceiveCheck()
    {
        return $this->emailReceiveCheck;
    }

    /**
     * @return EmailSendCheck
     */
    protected function getEmailSendCheck()
    {
        return $this->emailSendCheck;
    }

    /**
     * @param LoggerInterface $healthCheckerLogger
     */
    protected function setHealthCheckerLogger(LoggerInterface $healthCheckerLogger)
    {
        $this->healthCheckerLogger = $healthCheckerLogger;
    }

    /**
     * @param EmailReceiveCheck $emailReceiveCheck
     */
    protected function setEmailReceiveCheck(EmailReceiveCheck $emailReceiveCheck)
    {
        $this->emailReceiveCheck = $emailReceiveCheck;
    }

    /**
     * @param EmailSendCheck $emailSendCheck
     */
    protected function setEmailSendCheck(EmailSendCheck $emailSendCheck)
    {
        $this->emailSendCheck = $emailSendCheck;
    }

    /**
     * @param CheckInterface $emailCheck
     * @param string           $checkMsg
     *
     * @throws Exception
     */
    private function emailCheck(CheckInterface $emailCheck, $checkMsg)
    {
        try {
            $emailCheck->performCheck();
            $this->logSuccessCheck($checkMsg, $emailCheck->getIndent(), self::CHECK_OK);
        } catch (Exception $exception) {
            $this->logFailCheck($checkMsg, $emailCheck->getIndent(), $exception->getMessage(), self::CHECK_FAIL);
            throw $exception;
        }
    }

    /**
     * @param string $checkStatus
     * @param string $checkIndent
     *
     * @return array
     */
    private function getCheckTags($checkStatus, $checkIndent)
    {
        return [
            'check_status' => $checkStatus,
            'check_indent' => $checkIndent,
        ];
    }

    /**
     * @param string $checkMsg
     * @param string $checkIndent
     * @param string $checkStatus
     */
    private function logSuccessCheck($checkMsg, $checkIndent, $checkStatus = self::CHECK_OK)
    {
        $msg = sprintf(
            $checkMsg,
            $checkIndent,
            $checkStatus
        );

        $this->getHealthCheckerLogger()->info(
            $msg,
            $this->getCheckTags($checkStatus, $checkIndent)
        );
    }

    /**
     * @param string $checkMsg
     * @param string $checkIndent
     * @param string $errorMsg
     * @param string $checkStatus
     */
    private function logFailCheck($checkMsg, $checkIndent, $errorMsg, $checkStatus = self::CHECK_FAIL)
    {
        $msg = sprintf(
            $checkMsg,
            $checkIndent,
            $checkStatus
        );

        $msg .= ' '.sprintf(self::ERROR_MSG, $errorMsg);

        $this->getHealthCheckerLogger()->emergency(
            $msg,
            $this->getCheckTags($checkStatus, $checkIndent)
        );
    }
}