vendor/mero/telegram-handler/src/Mero/Monolog/Handler/TelegramHandler.php line 18

Open in your IDE?
  1. <?php
  3. namespace Mero\Monolog\Handler;
  5. use Mero\Monolog\Formatter\HtmlFormatter;
  6. use Monolog\Handler\AbstractProcessingHandler;
  7. use Monolog\Handler\MissingExtensionException;
  8. use Monolog\Handler\Curl;
  9. use Monolog\Logger;
  11. /**
  12.  * Sends notifications through Telegram API.
  13.  *
  14.  * @author Rafael Mello <merorafael@gmail.com>
  15.  *
  16.  * @see    https://core.telegram.org/bots/api
  17.  */
  18. class TelegramHandler extends AbstractProcessingHandler
  19. {
  20.     /**
  21.      * @var string Telegram API token
  22.      */
  23.     private $token;
  25.     /**
  26.      * @var int Chat identifier
  27.      */
  28.     private $chatId;
  30.     /**
  31.      * @var int Request timeout
  32.      */
  33.     private $timeout;
  35.     /**
  36.      * @param string $token  Telegram API token
  37.      * @param int    $chatId Chat identifier
  38.      * @param int    $level  The minimum logging level at which this handler will be triggered
  39.      * @param bool   $bubble Whether the messages that are handled can bubble up the stack or not
  40.      *
  41.      * @throws MissingExtensionException If the PHP cURL extension is not loaded
  42.      */
  43.     public function __construct(
  44.         $token,
  45.         $chatId,
  46.         $level = Logger::CRITICAL,
  47.         $bubble = true
  48.     ) {
  49.         if (!extension_loaded('curl')) {
  50.             throw new MissingExtensionException('The cURL PHP extension is required to use the TelegramHandler');
  51.         }
  53.         $this->token = $token;
  54.         $this->chatId = $chatId;
  55.         $this->timeout = 0;
  57.         parent::__construct($level, $bubble);
  58.     }
  60.     /**
  61.      * Define a timeout to Telegram send message request.
  62.      *
  63.      * @param int $timeout Request timeout
  64.      *
  65.      * @return TelegramHandler
  66.      */
  67.     public function setTimeout($timeout)
  68.     {
  69.         $this->timeout = $timeout;
  70.         return $this;
  71.     }
  73.     /**
  74.      * Builds the header of the API Call.
  75.      *
  76.      * @param string $content
  77.      *
  78.      * @return array
  79.      */
  80.     protected function buildHeader($content)
  81.     {
  82.         return [
  83.             'Content-Type: application/json',
  84.             'Content-Length: '.strlen($content),
  85.         ];
  86.     }
  88.     /**
  89.      * Builds the body of API call.
  90.      *
  91.      * @param array $record
  92.      *
  93.      * @return string
  94.      */
  95.     protected function buildContent(array $record)
  96.     {
  97.         $content = [
  98.             'chat_id' => $this->chatId,
  99.             'text' => $record['formatted'],
  100.         ];
  102.         if ($this->formatter instanceof HtmlFormatter) {
  103.             $content['parse_mode'] = 'HTML';
  104.         }
  106.         return json_encode($content);
  107.     }
  109.     /**
  110.      * {@inheritdoc}
  111.      *
  112.      * @param array $record
  113.      */
  114.     protected function write(array $record)
  115.     {
  116.         $content = $this->buildContent($record);
  118.         $ch = curl_init();
  120.         curl_setopt($ch, CURLOPT_HTTPHEADER, $this->buildHeader($content));
  121.         curl_setopt($ch, CURLOPT_URL, sprintf('https://api.telegram.org/bot%s/sendMessage', $this->token));
  122.         curl_setopt($ch, CURLOPT_POST, true);
  123.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  124.         curl_setopt($ch, CURLOPT_POSTFIELDS, $content);
  125.         curl_setopt($ch, CURLOPT_TIMEOUT, $this->timeout);
  127.         Curl\Util::execute($ch);
  128.     }
  129. }