RocketChatHandler\RocketChatHandler

Complexity

Total Complexity

5

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Importance

Changes	3
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	write()	0	23	4

<?php

namespace RocketChatHandler;

use GuzzleHttp\Client;
use Monolog\Handler\AbstractProcessingHandler;

The type Monolog\Handler\AbstractProcessingHandler was not found. Maybe you did not declare it correctly or list all dependencies?

use Monolog\Logger;

The type Monolog\Logger was not found. Maybe you did not declare it correctly or list all dependencies?

class RocketChatHandler extends AbstractProcessingHandler
{
    /**
     * @var \GuzzleHttp\Client;
     */
    private $client;

    /**
     * @var array
     */
    private $webhooks;

    /**
     * Colors for a given log level.
     *
     * @var array
     */
    protected $levelColors = [
        Logger::DEBUG => "#9E9E9E",
        Logger::INFO => "#4CAF50",
        Logger::NOTICE => "#607D8B",
        Logger::WARNING => "#FFEB3B",
        Logger::ERROR => "#F44336",
        Logger::CRITICAL => "#F44336",
        Logger::ALERT => "#F44336",
        Logger::EMERGENCY => "#F44336",
    ];

    /**
     * RocketChatHandler constructor.
     *
     * @param array $webhooks
     * @param int $level
     * @param bool $bubble
     */
    public function __construct(array $webhooks, $level = Logger::DEBUG, bool $bubble = true)
    {
        parent::__construct($level, $bubble);
        $this->client = new Client();
        $this->webhooks = $webhooks;
    }

    /**
     * @param array $record
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    protected function write(array $record): void
    {
        $level = $record['level'] ?? $this->level;
        $content = [
            "text" => "",
            "attachments" => [
                [
                    "title" => $record['level_name'] ?? '',
                    "text" => $record['message'] ?? '',
                    "color" => $this->levelColors[$level],
                ],
            ],
        ];

        foreach (['title_link', 'image_url'] as $field_name) {
            if(!empty($record[$field_name])) {
                $content['attachments'][$field_name] = $record[$field_name];
            }
        }

        foreach ($this->webhooks as $webhook) {
            $this->client->request('POST', $webhook, [
                'json' => $content,
            ]);
        }
    }
}