adespresso / MonologFluentdBundle

Monolog/Handler/FluentdHandler.php

<?php

namespace Ae\MonologFluentdBundle\Monolog\Handler;

use Fluent\Logger\FluentLogger;
use Monolog\Formatter\JsonFormatter;
use Monolog\Handler\AbstractProcessingHandler;
use Monolog\Logger;

class FluentdHandler extends AbstractProcessingHandler
{
    /**
     * @var FluentLogger
     */
    protected $fluentLogger;

    /**
     * Initialize Handler.
     *
     * @param string $host
     * @param int    $port
     * @param array  $options FluentLogger options
     * @param int    $level   The minimum logging level at which this handler will be triggered
     * @param bool   $bubble  Whether the messages that are handled can bubble up the stack or not
     */
    public function __construct(
        $host = FluentLogger::DEFAULT_ADDRESS,
        $port = FluentLogger::DEFAULT_LISTEN_PORT,
        $options = array(),
        $level = Logger::DEBUG,
        $bubble = true)
    {
        parent::__construct($level, $bubble);
        $this->fluentLogger = $this->makeFluentLogger($host, $port, $options);

        // By default FluentLogger would write to stderr for every message gone wrong.
        // We find it a bad default (you would probably start to log miriad of data as error).
        // You can reset the same or a different error handler by accessing the logger with getFluentLogger();
        $this->fluentLogger->registerErrorHandler(function ($logger, $entity, $error) {});

The parameter $entity is not used and could be removed.

The parameter $logger is not used and could be removed.

The parameter $error is not used and could be removed.

    }

    /**
     * Get the internal FluentLogger instance.
     *
     * @return FluentLogger
     */
    public function getFluentLogger()
    {
        return $this->fluentLogger;
    }

    /**
     * Create a new instande of FluentLogger.
     *
     * @param string $host
     * @param int    $port
     * @param array  $options FluentLogger options
     */
    protected function makeFluentLogger($host, $port, $options = array())
    {
        return new FluentLogger($host, $port, $options);
    }

    /**
     * {@inheritdoc}
     */
    protected function write(array $record)
    {
        $this->fluentLogger->post($this->formatTag($record), $record['context']);
    }

    /**
     * Format a fluentd tag using the record data.
     *
     * @param array $record
     *
     * @return string the tag
     */
    protected function formatTag($record)
    {
        return sprintf('%s.%s', $record['channel'], $record['message']);
    }

    /**
     * {@inheritdoc}
     */
    public function close()
    {
        $this->fluentLogger->close();
    }

    /**
     * @return \Monolog\Formatter\FormatterInterface
     */
    protected function getDefaultFormatter()
    {
        return new JsonFormatter();
    }
}