Hogosha\Monitor\Pusher\IncidentPusher

Complexity

Total Complexity

7

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes	4
Bugs	0	Features	1

1 Method

Rating	Name	Duplication	Size	Complexity
C	push()	0	41	7

<?php

/*
 * This file is part of the hogosha-monitor package
 *
 * Copyright (c) 2016 Guillaume Cavana
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 *
 * Feel free to edit as you please, and have fun.
 *
 * @author Guillaume Cavana <guillaume.cavana@gmail.com>
 */

namespace Hogosha\Monitor\Pusher;

use GuzzleHttp\Exception\BadResponseException;
use Hogosha\Monitor\Guesser\StatusGuesser;
use Hogosha\Monitor\Model\Result;
use Hogosha\Sdk\Resource\Factory\ResourceFactory;

/**
 * Class IncidentPusher.
 */
class IncidentPusher extends AbstractPusher
{
    /**
     * {@inheritdoc}
     */
    public function push(Result $result)
    {
        $statusGuesser = new StatusGuesser();

        $resourceFactory = new ResourceFactory($this->client);
        $incidentResource = $resourceFactory->get('incident');

        $serviceResource = $resourceFactory->get('service');
        $service = $serviceResource->getService($result->getUrl()->getServiceUuid());

        $alreadyInFailure = false;

        if ($service['status'] != StatusGuesser::RESOLVED) {
            $alreadyInFailure = true;
        }

        try {
            // If the service is not already in failure,
            // we check if there is a failure.
            if (false === $alreadyInFailure && $statusGuesser->isFailed($result)) {
                $incidentResource->createIncident([
                    'name' => str_replace('%service_name%', $service['name'], $this->getDefaultFailedIncidentMessage()),
                    'service' => $result->getUrl()->getServiceUuid(),
                    'status' => StatusGuesser::IDENTIFIED,
                    'error_log' => sprintf('%s %s', $result->getHandlerError(), $result->getValidatorError()),
                ]);
            }

            // If the service is already in failture,
            // we check if it's back to normal and create a incident resolver
            if ($alreadyInFailure && $statusGuesser->isOk($result)) {
                $incidentResource->createIncident([
                    'name' => str_replace('%service_name%', $service['name'], $this->getDefaultResolvedIncidentMessage()),
                    'service' => $result->getUrl()->getServiceUuid(),
                    'status' => StatusGuesser::RESOLVED,
                ]);
            }
        } catch (BadResponseException $e) {
            throw $e;
        }
    }
}