121 lines
		
	
	
		
			3.7 KiB
		
	
	
	
		
			PHP
		
	
	
	
			
		
		
	
	
			121 lines
		
	
	
		
			3.7 KiB
		
	
	
	
		
			PHP
		
	
	
	
<?php
 | 
						|
 | 
						|
/*
 | 
						|
 * This file is part of the Monolog package.
 | 
						|
 *
 | 
						|
 * (c) Jordi Boggiano <j.boggiano@seld.be>
 | 
						|
 *
 | 
						|
 * For the full copyright and license information, please view the LICENSE
 | 
						|
 * file that was distributed with this source code.
 | 
						|
 */
 | 
						|
 | 
						|
namespace Monolog\Handler;
 | 
						|
 | 
						|
use Monolog\Formatter\FormatterInterface;
 | 
						|
use Monolog\Logger;
 | 
						|
use Monolog\Handler\Slack\SlackRecord;
 | 
						|
 | 
						|
/**
 | 
						|
 * Sends notifications through Slack Webhooks
 | 
						|
 *
 | 
						|
 * @author Haralan Dobrev <hkdobrev@gmail.com>
 | 
						|
 * @see    https://api.slack.com/incoming-webhooks
 | 
						|
 */
 | 
						|
class SlackWebhookHandler extends AbstractProcessingHandler
 | 
						|
{
 | 
						|
    /**
 | 
						|
     * Slack Webhook token
 | 
						|
     * @var string
 | 
						|
     */
 | 
						|
    private $webhookUrl;
 | 
						|
 | 
						|
    /**
 | 
						|
     * Instance of the SlackRecord util class preparing data for Slack API.
 | 
						|
     * @var SlackRecord
 | 
						|
     */
 | 
						|
    private $slackRecord;
 | 
						|
 | 
						|
    /**
 | 
						|
     * @param  string      $webhookUrl             Slack Webhook URL
 | 
						|
     * @param  string|null $channel                Slack channel (encoded ID or name)
 | 
						|
     * @param  string|null $username               Name of a bot
 | 
						|
     * @param  bool        $useAttachment          Whether the message should be added to Slack as attachment (plain text otherwise)
 | 
						|
     * @param  string|null $iconEmoji              The emoji name to use (or null)
 | 
						|
     * @param  bool        $useShortAttachment     Whether the the context/extra messages added to Slack as attachments are in a short style
 | 
						|
     * @param  bool        $includeContextAndExtra Whether the attachment should include context and extra data
 | 
						|
     * @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
 | 
						|
     * @param  array       $excludeFields          Dot separated list of fields to exclude from slack message. E.g. ['context.field1', 'extra.field2']
 | 
						|
     */
 | 
						|
    public function __construct($webhookUrl, $channel = null, $username = null, $useAttachment = true, $iconEmoji = null, $useShortAttachment = false, $includeContextAndExtra = false, $level = Logger::CRITICAL, $bubble = true, array $excludeFields = array())
 | 
						|
    {
 | 
						|
        parent::__construct($level, $bubble);
 | 
						|
 | 
						|
        $this->webhookUrl = $webhookUrl;
 | 
						|
 | 
						|
        $this->slackRecord = new SlackRecord(
 | 
						|
            $channel,
 | 
						|
            $username,
 | 
						|
            $useAttachment,
 | 
						|
            $iconEmoji,
 | 
						|
            $useShortAttachment,
 | 
						|
            $includeContextAndExtra,
 | 
						|
            $excludeFields,
 | 
						|
            $this->formatter
 | 
						|
        );
 | 
						|
    }
 | 
						|
 | 
						|
    public function getSlackRecord()
 | 
						|
    {
 | 
						|
        return $this->slackRecord;
 | 
						|
    }
 | 
						|
 | 
						|
    public function getWebhookUrl()
 | 
						|
    {
 | 
						|
        return $this->webhookUrl;
 | 
						|
    }
 | 
						|
 | 
						|
    /**
 | 
						|
     * {@inheritdoc}
 | 
						|
     *
 | 
						|
     * @param array $record
 | 
						|
     */
 | 
						|
    protected function write(array $record)
 | 
						|
    {
 | 
						|
        $postData = $this->slackRecord->getSlackData($record);
 | 
						|
        $postString = json_encode($postData);
 | 
						|
 | 
						|
        $ch = curl_init();
 | 
						|
        $options = array(
 | 
						|
            CURLOPT_URL => $this->webhookUrl,
 | 
						|
            CURLOPT_POST => true,
 | 
						|
            CURLOPT_RETURNTRANSFER => true,
 | 
						|
            CURLOPT_HTTPHEADER => array('Content-type: application/json'),
 | 
						|
            CURLOPT_POSTFIELDS => $postString
 | 
						|
        );
 | 
						|
        if (defined('CURLOPT_SAFE_UPLOAD')) {
 | 
						|
            $options[CURLOPT_SAFE_UPLOAD] = true;
 | 
						|
        }
 | 
						|
 | 
						|
        curl_setopt_array($ch, $options);
 | 
						|
 | 
						|
        Curl\Util::execute($ch);
 | 
						|
    }
 | 
						|
 | 
						|
    public function setFormatter(FormatterInterface $formatter)
 | 
						|
    {
 | 
						|
        parent::setFormatter($formatter);
 | 
						|
        $this->slackRecord->setFormatter($formatter);
 | 
						|
 | 
						|
        return $this;
 | 
						|
    }
 | 
						|
 | 
						|
    public function getFormatter()
 | 
						|
    {
 | 
						|
        $formatter = parent::getFormatter();
 | 
						|
        $this->slackRecord->setFormatter($formatter);
 | 
						|
 | 
						|
        return $formatter;
 | 
						|
    }
 | 
						|
}
 |