Bouncer\Logger\LogstashLogger

Complexity

Total Complexity

6

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
A	log()	0	11	2
A	getLogger()	0	23	3

<?php

/*
 * This file is part of the Bouncer package.
 *
 * (c) François Hodierne <francois@hodierne.net>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Bouncer\Logger;

use Monolog\Formatter\LogstashFormatter;
use Monolog\Handler\StreamHandler;
use Monolog\Logger;

class LogstashLogger extends BaseLogger
{

    /**
     * @var string
     */
    protected $host;

    /**
     * @var int
     */
    protected $port;

    /**
     * @var string
     */
    protected $protocol;

    /**
     * @var string
     */
    protected $channel;

    /**
     * @var string
     */
    protected $type;

    /**
     * @var object|bool
     */
    protected $logger;

    /**
     * @var int
     */
    protected $timeout;

    public function __construct($host, $port, $protocol = 'udp', $channel = 'bouncer', $type = 'access_log', $timeout = 2)
    {
        $this->host     = $host;
        $this->port     = $port;
        $this->protocol = $protocol;
        $this->channel  = $channel;
        $this->type     = $type;
        $this->timeout  = $timeout;
    }

    /**
     * {@inheritDoc}
     */
    public function log(array $logEntry)
    {
        $message = (string)$logEntry['request'];

        $entry = $this->format($logEntry);

        $logger = $this->getLogger();
        if ($logger) {
            $logger->info($message, $entry);
        }
    }

    /**
     * @return object|null
     */
    public function getLogger()
    {
        if (isset($this->logger)) {
            return $this->logger;
        }

        $logger = new Logger($this->channel);

        $formatter = new LogstashFormatter(
            $this->type, $systemName = null, $extraPrefix = null, $contextPrefix = '', LogstashFormatter::V1);

        $stream = stream_socket_client("{$this->protocol}://{$this->host}:{$this->port}", $errno, $errstr, $this->timeout);
        if (!$stream) {
            error_log("Unable to connect to '{$this->protocol}://{$this->host}': {$errstr} ({$errno})");
            return $this->logger = false;
        }

        $streamHandler = new StreamHandler($stream);
        $streamHandler->setFormatter($formatter);
        $logger->pushHandler($streamHandler);

        return $this->logger = $logger;
    }

}