vendor/symfony/monolog-bridge/Handler/ServerLogHandler.php line 22

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Symfony\Bridge\Monolog\Handler;
  14. use Monolog\Formatter\FormatterInterface;
  15. use Monolog\Handler\AbstractHandler;
  16. use Monolog\Logger;
  17. use Symfony\Bridge\Monolog\Formatter\VarDumperFormatter;
  19. /**
  20.  * @author Grégoire Pineau <lyrixx@lyrixx.info>
  21.  */
  22. class ServerLogHandler extends AbstractHandler
  23. {
  24.     private $host;
  25.     private $context;
  26.     private $socket;
  28.     /**
  29.      * @param string|int $level The minimum logging level at which this handler will be triggered
  30.      */
  31.     public function __construct(string $host, $level = Logger::DEBUG, bool $bubble = true, array $context = [])
  32.     {
  33.         parent::__construct($level, $bubble);
  35.         if (false === strpos($host, '://')) {
  36.             $host = 'tcp://'.$host;
  37.         }
  39.         $this->host = $host;
  40.         $this->context = stream_context_create($context);
  41.     }
  43.     /**
  44.      * {@inheritdoc}
  45.      *
  46.      * @return bool
  47.      */
  48.     public function handle(array $record)
  49.     {
  50.         if (!$this->isHandling($record)) {
  51.             return false;
  52.         }
  54.         set_error_handler(self::class.'::nullErrorHandler');
  56.         try {
  57.             if (!$this->socket = $this->socket ?: $this->createSocket()) {
  58.                 return false === $this->bubble;
  59.             }
  60.         } finally {
  61.             restore_error_handler();
  62.         }
  64.         $recordFormatted = $this->formatRecord($record);
  66.         set_error_handler(self::class.'::nullErrorHandler');
  68.         try {
  69.             if (-1 === stream_socket_sendto($this->socket, $recordFormatted)) {
  70.                 stream_socket_shutdown($this->socket, \STREAM_SHUT_RDWR);
  72.                 // Let's retry: the persistent connection might just be stale
  73.                 if ($this->socket = $this->createSocket()) {
  74.                     stream_socket_sendto($this->socket, $recordFormatted);
  75.                 }
  76.             }
  77.         } finally {
  78.             restore_error_handler();
  79.         }
  81.         return false === $this->bubble;
  82.     }
  84.     /**
  85.      * {@inheritdoc}
  86.      *
  87.      * @return FormatterInterface
  88.      */
  89.     protected function getDefaultFormatter()
  90.     {
  91.         return new VarDumperFormatter();
  92.     }
  94.     private static function nullErrorHandler()
  95.     {
  96.     }
  98.     private function createSocket()
  99.     {
  100.         $socket = stream_socket_client($this->host, $errno, $errstr, 0, \STREAM_CLIENT_CONNECT | \STREAM_CLIENT_ASYNC_CONNECT | \STREAM_CLIENT_PERSISTENT, $this->context);
  102.         if ($socket) {
  103.             stream_set_blocking($socket, false);
  104.         }
  106.         return $socket;
  107.     }
  109.     private function formatRecord(array $record): string
  110.     {
  111.         if ($this->processors) {
  112.             foreach ($this->processors as $processor) {
  113.                 $record = $processor($record);
  114.             }
  115.         }
  117.         $recordFormatted = $this->getFormatter()->format($record);
  119.         foreach (['log_uuid', 'uuid', 'uid'] as $key) {
  120.             if (isset($record['extra'][$key])) {
  121.                 $recordFormatted['log_id'] = $record['extra'][$key];
  122.                 break;
  123.             }
  124.         }
  126.         return base64_encode(serialize($recordFormatted))."\n";
  127.     }
  128. }