class LagoonLogsLogger in Lagoon Logs 8

Hierarchy

• class \Drupal\lagoon_logs\Logger\LagoonLogsLogger implements \Psr\Log\LoggerInterface uses RfcLoggerTrait

1 string reference to 'LagoonLogsLogger'

lagoon_logs.services.yml in ./lagoon_logs.services.yml

lagoon_logs.services.yml

1 service uses LagoonLogsLogger

logger.lagoon_logs in ./lagoon_logs.services.yml

Drupal\lagoon_logs\Logger\LagoonLogsLogger

File

src/Logger/LagoonLogsLogger.php, line 18

Namespace

Drupal\lagoon_logs\Logger

class LagoonLogsLogger implements LoggerInterface {
  use RfcLoggerTrait;
  const LAGOON_LOGS_MONOLOG_CHANNEL_NAME = 'LagoonLogs';
  const LAGOON_LOGS_DEFAULT_CHUNK_SIZE_BYTES = 15000;

  //will be used when new release of monolog is available
  const LAGOON_LOGS_DEFAULT_IDENTIFIER = 'drupal';

  //The following is used to log Lagoon Logs issues if logging target

  //cannot be reached.
  const LAGOON_LOGGER_WATCHDOG_FALLBACK_IDENTIFIER = 'lagoon_logs_fallback_error';

  // protected static $logger;
  protected $hostName;
  protected $hostPort;
  protected $logFullIdentifier;
  protected $parser;

  /**
   * See
   * https://github.com/Seldaek/monolog/blob/master/doc/01-usage.md#log-levels
   *
   * @var array
   */
  protected $rfcMonologErrorMap = [
    RfcLogLevel::EMERGENCY => 600,
    RfcLogLevel::ALERT => 550,
    RfcLogLevel::CRITICAL => 500,
    RfcLogLevel::ERROR => 400,
    RfcLogLevel::WARNING => 300,
    RfcLogLevel::NOTICE => 250,
    RfcLogLevel::INFO => 200,
    RfcLogLevel::DEBUG => 100,
  ];
  public function __construct($host, $port, $logFullIdentifier, LogMessageParserInterface $parser) {
    $this->hostName = $host;
    $this->hostPort = $port;
    $this->logFullIdentifier = $logFullIdentifier;
    $this->parser = $parser;
  }
  protected function mapRFCtoMonologLevels(int $rfcErrorLevel) {
    return $this->rfcMonologErrorMap[$rfcErrorLevel];
  }

  /**
   * @param $level
   * @param $message
   * @param array $context
   * @param $base_url
   *
   * @return array
   */
  protected function transformDataForProcessor($level, $message, array $context, $base_url) {
    $processorData = [
      "extra" => [],
    ];
    $processorData['message'] = $message;
    $processorData['extra']['ip'] = $context['ip'];
    $processorData['extra']['request_uri'] = $context['request_uri'];
    $processorData['level'] = $this
      ->mapRFCtoMonologLevels($level);
    $processorData['extra']['uid'] = $context['uid'];
    $processorData['extra']['link'] = strip_tags($context['link']);
    $processorData['extra']['channel'] = $context['channel'];
    $processorData['extra']['application'] = self::LAGOON_LOGS_DEFAULT_IDENTIFIER;
    return $processorData;
  }
  protected function getRFCLevelName(int $rfcErrorLevel) {
    $levels = RfcLogLevel::getLevels();
    return $levels[$rfcErrorLevel];
  }

  /**
   * {@inheritdoc}
   */
  public function log($level, $message, array $context = []) {
    global $base_url;
    $logger = new Logger(self::LAGOON_LOGS_MONOLOG_CHANNEL_NAME);
    $formatter = new LogstashFormatter($this->logFullIdentifier, null, null, 'ctxt_', 1);
    $connectionString = sprintf("udp://%s:%s", $this->hostName, $this->hostPort);
    $udpHandler = new SocketHandler($connectionString);

    // Monolog has a change waiting for release that allows us to have large UDP packets.
    $udpHandler
      ->setChunkSize(self::LAGOON_LOGS_DEFAULT_CHUNK_SIZE_BYTES);
    $udpHandler
      ->setFormatter($formatter);
    $logger
      ->pushHandler($udpHandler);
    $message_placeholders = $this->parser
      ->parseMessagePlaceholders($message, $context);
    $message = strip_tags(empty($message_placeholders) ? $message : strtr($message, $message_placeholders));
    $processorData = $this
      ->transformDataForProcessor($level, $message, $context, $base_url);
    $logger
      ->pushProcessor(new LagoonLogsLogProcessor($processorData));
    try {
      $logger
        ->log($this
        ->mapRFCtoMonologLevels($level), $message);
    } catch (\Exception $exception) {
    }
  }

}

Members

Name	Modifiers	Type	Description	Overrides
LagoonLogsLogger::$hostName	protected	property
LagoonLogsLogger::$hostPort	protected	property
LagoonLogsLogger::$logFullIdentifier	protected	property
LagoonLogsLogger::$parser	protected	property
LagoonLogsLogger::$rfcMonologErrorMap	protected	property	See https://github.com/Seldaek/monolog/blob/master/doc/01-usage.md#log-levels
LagoonLogsLogger::getRFCLevelName	protected	function
LagoonLogsLogger::LAGOON_LOGGER_WATCHDOG_FALLBACK_IDENTIFIER		constant
LagoonLogsLogger::LAGOON_LOGS_DEFAULT_CHUNK_SIZE_BYTES		constant
LagoonLogsLogger::LAGOON_LOGS_DEFAULT_IDENTIFIER		constant
LagoonLogsLogger::LAGOON_LOGS_MONOLOG_CHANNEL_NAME		constant
LagoonLogsLogger::log	public	function	Logs with an arbitrary level. Overrides RfcLoggerTrait::log
LagoonLogsLogger::mapRFCtoMonologLevels	protected	function
LagoonLogsLogger::transformDataForProcessor	protected	function
LagoonLogsLogger::__construct	public	function
RfcLoggerTrait::alert	public	function
RfcLoggerTrait::critical	public	function
RfcLoggerTrait::debug	public	function
RfcLoggerTrait::emergency	public	function
RfcLoggerTrait::error	public	function
RfcLoggerTrait::info	public	function
RfcLoggerTrait::notice	public	function
RfcLoggerTrait::warning	public	function