bilberrry\log\FluentdTarget

Complexity

Total Complexity

3

Size/Duplication

Total Lines	61
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	init()	0	6	1
A	export()	0	6	1
A	createTag()	0	6	1

<?php
/**
 * @link      https://github.com/bilberrry/yii2-fluentd
 * @copyright Copyright (c) 2016 Alex Mukho <alex@bilberrry.com>
 * @license   https://github.com/bilberrry/yii2-fluentd/blob/master/LICENSE
 */

namespace bilberrry\log;

use Fluent\Logger\FluentLogger;
use yii\log\Logger;


/**
 * FluentdTarget sends log messages to Fluentd
 */
class FluentdTarget extends \yii\log\Target
{

    /**
     * @var string Fluentd host
     */
    public $host = 'localhost';
    /**
     * @var int Fluentd port
     */
    public $port = 24224;
    /**
     * @var array Options for Fluentd client
     */
    public $options = [];

    /**
     * @var string Tag format, available placeholders: %date, %timestamp, %level
     */
    public $tagFormat = 'app.%level';

    /**
     * @var FluentLogger Fluentd client instance
     */
    private $_logger;


    /**
     * @inheritdoc
     */
    public function init()
    {
        parent::init();

        $this->_logger = FluentLogger::open($this->host, $this->port, $this->options);
    }

    /**
     * @inheritdoc
     */
    public function export()
    {
        $messages = array_map([$this, 'formatMessage'], $this->messages);

        $this->_logger->post($this->createTag($this->messages), $messages);
    }


    /**
     * Generating tag name based on $tagFormat
     *
     * @param $messages
     * @return string
     */
    private function createTag($messages)
    {
        return str_replace(['%date', '%timestamp', '%level'], [
            date('Y-m-d H:i:s'), time(), Logger::getLevelName($messages[0][1])
        ], $this->tagFormat);
    }
}