Clearcode\SimpleBusElkBundle\Logstash\Logstash

Complexity

Total Complexity

5

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	write()	0	11	3
A	handleError()	0	4	1

<?php

namespace Clearcode\SimpleBusElkBundle\Logstash;

use Clearcode\SimpleBusElkBundle\Converter\DataToConvertIsNotAnObject;
use Clearcode\SimpleBusElkBundle\Converter\ObjectToArrayConverterInterface;
use Psr\Log\LoggerInterface;

class Logstash
{
    /** @var LoggerInterface */
    private $logger;
    /** @var ObjectToArrayConverterInterface */
    private $converter;

    /**
     * @param LoggerInterface                 $logger
     * @param ObjectToArrayConverterInterface $converter
     */
    public function __construct(LoggerInterface $logger, ObjectToArrayConverterInterface $converter)
    {
        $this->logger = $logger;
        $this->converter = $converter;
    }

    /**
     * @param $object
     *
     * @throws CannotWriteToLogstash
     */
    public function write($object)
    {
        try {
            $this->logger->info('Event recorded', $this->converter->toArray($object));

        } catch (DataToConvertIsNotAnObject $e) {
            $this->handleError(sprintf('Data conversion problem during writing to logstash: %s', $e->getMessage()));
        } catch (\Exception $e) {
            $this->handleError(sprintf('Connection with logstash error: %s', $e->getMessage()));
        }
    }

    private function handleError($message)
    {
        throw new CannotWriteToLogstash($message);
    }
}