vendor/monolog/monolog/src/Monolog/Logger.php line 315

Open in your IDE?
  1. <?php declare(strict_types=1);
  2. /*
  3.  * This file is part of the Monolog package.
  4.  *
  5.  * (c) Jordi Boggiano <j.boggiano@seld.be>
  6.  *
  7.  * For the full copyright and license information, please view the LICENSE
  8.  * file that was distributed with this source code.
  9.  */
  10. namespace Monolog;
  11. use DateTimeZone;
  12. use Monolog\Handler\HandlerInterface;
  13. use Psr\Log\LoggerInterface;
  14. use Psr\Log\InvalidArgumentException;
  15. use Throwable;
  16. /**
  17.  * Monolog log channel
  18.  *
  19.  * It contains a stack of Handlers and a stack of Processors,
  20.  * and uses them to store records that are added to it.
  21.  *
  22.  * @author Jordi Boggiano <j.boggiano@seld.be>
  23.  */
  24. class Logger implements LoggerInterfaceResettableInterface
  25. {
  26.     /**
  27.      * Detailed debug information
  28.      */
  29.     public const DEBUG 100;
  30.     /**
  31.      * Interesting events
  32.      *
  33.      * Examples: User logs in, SQL logs.
  34.      */
  35.     public const INFO 200;
  36.     /**
  37.      * Uncommon events
  38.      */
  39.     public const NOTICE 250;
  40.     /**
  41.      * Exceptional occurrences that are not errors
  42.      *
  43.      * Examples: Use of deprecated APIs, poor use of an API,
  44.      * undesirable things that are not necessarily wrong.
  45.      */
  46.     public const WARNING 300;
  47.     /**
  48.      * Runtime errors
  49.      */
  50.     public const ERROR 400;
  51.     /**
  52.      * Critical conditions
  53.      *
  54.      * Example: Application component unavailable, unexpected exception.
  55.      */
  56.     public const CRITICAL 500;
  57.     /**
  58.      * Action must be taken immediately
  59.      *
  60.      * Example: Entire website down, database unavailable, etc.
  61.      * This should trigger the SMS alerts and wake you up.
  62.      */
  63.     public const ALERT 550;
  64.     /**
  65.      * Urgent alert.
  66.      */
  67.     public const EMERGENCY 600;
  68.     /**
  69.      * Monolog API version
  70.      *
  71.      * This is only bumped when API breaks are done and should
  72.      * follow the major version of the library
  73.      *
  74.      * @var int
  75.      */
  76.     public const API 2;
  77.     /**
  78.      * This is a static variable and not a constant to serve as an extension point for custom levels
  79.      *
  80.      * @var string[] $levels Logging levels with the levels as key
  81.      */
  82.     protected static $levels = [
  83.         self::DEBUG     => 'DEBUG',
  84.         self::INFO      => 'INFO',
  85.         self::NOTICE    => 'NOTICE',
  86.         self::WARNING   => 'WARNING',
  87.         self::ERROR     => 'ERROR',
  88.         self::CRITICAL  => 'CRITICAL',
  89.         self::ALERT     => 'ALERT',
  90.         self::EMERGENCY => 'EMERGENCY',
  91.     ];
  92.     /**
  93.      * @var string
  94.      */
  95.     protected $name;
  96.     /**
  97.      * The handler stack
  98.      *
  99.      * @var HandlerInterface[]
  100.      */
  101.     protected $handlers;
  102.     /**
  103.      * Processors that will process all log records
  104.      *
  105.      * To process records of a single handler instead, add the processor on that specific handler
  106.      *
  107.      * @var callable[]
  108.      */
  109.     protected $processors;
  110.     /**
  111.      * @var bool
  112.      */
  113.     protected $microsecondTimestamps true;
  114.     /**
  115.      * @var DateTimeZone
  116.      */
  117.     protected $timezone;
  118.     /**
  119.      * @var callable|null
  120.      */
  121.     protected $exceptionHandler;
  122.     /**
  123.      * @psalm-param array<callable(array): array> $processors
  124.      *
  125.      * @param string             $name       The logging channel, a simple descriptive name that is attached to all log records
  126.      * @param HandlerInterface[] $handlers   Optional stack of handlers, the first one in the array is called first, etc.
  127.      * @param callable[]         $processors Optional array of processors
  128.      * @param DateTimeZone|null  $timezone   Optional timezone, if not provided date_default_timezone_get() will be used
  129.      */
  130.     public function __construct(string $name, array $handlers = [], array $processors = [], ?DateTimeZone $timezone null)
  131.     {
  132.         $this->name $name;
  133.         $this->setHandlers($handlers);
  134.         $this->processors $processors;
  135.         $this->timezone $timezone ?: new DateTimeZone(date_default_timezone_get() ?: 'UTC');
  136.     }
  137.     public function getName(): string
  138.     {
  139.         return $this->name;
  140.     }
  141.     /**
  142.      * Return a new cloned instance with the name changed
  143.      */
  144.     public function withName(string $name): self
  145.     {
  146.         $new = clone $this;
  147.         $new->name $name;
  148.         return $new;
  149.     }
  150.     /**
  151.      * Pushes a handler on to the stack.
  152.      */
  153.     public function pushHandler(HandlerInterface $handler): self
  154.     {
  155.         array_unshift($this->handlers$handler);
  156.         return $this;
  157.     }
  158.     /**
  159.      * Pops a handler from the stack
  160.      *
  161.      * @throws \LogicException If empty handler stack
  162.      */
  163.     public function popHandler(): HandlerInterface
  164.     {
  165.         if (!$this->handlers) {
  166.             throw new \LogicException('You tried to pop from an empty handler stack.');
  167.         }
  168.         return array_shift($this->handlers);
  169.     }
  170.     /**
  171.      * Set handlers, replacing all existing ones.
  172.      *
  173.      * If a map is passed, keys will be ignored.
  174.      *
  175.      * @param HandlerInterface[] $handlers
  176.      */
  177.     public function setHandlers(array $handlers): self
  178.     {
  179.         $this->handlers = [];
  180.         foreach (array_reverse($handlers) as $handler) {
  181.             $this->pushHandler($handler);
  182.         }
  183.         return $this;
  184.     }
  185.     /**
  186.      * @return HandlerInterface[]
  187.      */
  188.     public function getHandlers(): array
  189.     {
  190.         return $this->handlers;
  191.     }
  192.     /**
  193.      * Adds a processor on to the stack.
  194.      */
  195.     public function pushProcessor(callable $callback): self
  196.     {
  197.         array_unshift($this->processors$callback);
  198.         return $this;
  199.     }
  200.     /**
  201.      * Removes the processor on top of the stack and returns it.
  202.      *
  203.      * @throws \LogicException If empty processor stack
  204.      * @return callable
  205.      */
  206.     public function popProcessor(): callable
  207.     {
  208.         if (!$this->processors) {
  209.             throw new \LogicException('You tried to pop from an empty processor stack.');
  210.         }
  211.         return array_shift($this->processors);
  212.     }
  213.     /**
  214.      * @return callable[]
  215.      */
  216.     public function getProcessors(): array
  217.     {
  218.         return $this->processors;
  219.     }
  220.     /**
  221.      * Control the use of microsecond resolution timestamps in the 'datetime'
  222.      * member of new records.
  223.      *
  224.      * On PHP7.0, generating microsecond resolution timestamps by calling
  225.      * microtime(true), formatting the result via sprintf() and then parsing
  226.      * the resulting string via \DateTime::createFromFormat() can incur
  227.      * a measurable runtime overhead vs simple usage of DateTime to capture
  228.      * a second resolution timestamp in systems which generate a large number
  229.      * of log events.
  230.      *
  231.      * On PHP7.1 however microseconds are always included by the engine, so
  232.      * this setting can be left alone unless you really want to suppress
  233.      * microseconds in the output.
  234.      *
  235.      * @param bool $micro True to use microtime() to create timestamps
  236.      */
  237.     public function useMicrosecondTimestamps(bool $micro)
  238.     {
  239.         $this->microsecondTimestamps $micro;
  240.     }
  241.     /**
  242.      * Adds a log record.
  243.      *
  244.      * @param  int    $level   The logging level
  245.      * @param  string $message The log message
  246.      * @param  array  $context The log context
  247.      * @return bool   Whether the record has been processed
  248.      */
  249.     public function addRecord(int $levelstring $message, array $context = []): bool
  250.     {
  251.         // check if any handler will handle this message so we can return early and save cycles
  252.         $handlerKey null;
  253.         foreach ($this->handlers as $key => $handler) {
  254.             if ($handler->isHandling(['level' => $level])) {
  255.                 $handlerKey $key;
  256.                 break;
  257.             }
  258.         }
  259.         if (null === $handlerKey) {
  260.             return false;
  261.         }
  262.         $levelName = static::getLevelName($level);
  263.         $record = [
  264.             'message' => $message,
  265.             'context' => $context,
  266.             'level' => $level,
  267.             'level_name' => $levelName,
  268.             'channel' => $this->name,
  269.             'datetime' => new DateTimeImmutable($this->microsecondTimestamps$this->timezone),
  270.             'extra' => [],
  271.         ];
  272.         try {
  273.             foreach ($this->processors as $processor) {
  274.                 $record $processor($record);
  275.             }
  276.             // advance the array pointer to the first handler that will handle this record
  277.             reset($this->handlers);
  278.             while ($handlerKey !== key($this->handlers)) {
  279.                 next($this->handlers);
  280.             }
  281.             while ($handler current($this->handlers)) {
  282.                 if (true === $handler->handle($record)) {
  283.                     break;
  284.                 }
  285.                 next($this->handlers);
  286.             }
  287.         } catch (Throwable $e) {
  288.             $this->handleException($e$record);
  289.         }
  290.         return true;
  291.     }
  292.     /**
  293.      * Ends a log cycle and frees all resources used by handlers.
  294.      *
  295.      * Closing a Handler means flushing all buffers and freeing any open resources/handles.
  296.      * Handlers that have been closed should be able to accept log records again and re-open
  297.      * themselves on demand, but this may not always be possible depending on implementation.
  298.      *
  299.      * This is useful at the end of a request and will be called automatically on every handler
  300.      * when they get destructed.
  301.      */
  302.     public function close(): void
  303.     {
  304.         foreach ($this->handlers as $handler) {
  305.             $handler->close();
  306.         }
  307.     }
  308.     /**
  309.      * Ends a log cycle and resets all handlers and processors to their initial state.
  310.      *
  311.      * Resetting a Handler or a Processor means flushing/cleaning all buffers, resetting internal
  312.      * state, and getting it back to a state in which it can receive log records again.
  313.      *
  314.      * This is useful in case you want to avoid logs leaking between two requests or jobs when you
  315.      * have a long running process like a worker or an application server serving multiple requests
  316.      * in one process.
  317.      */
  318.     public function reset(): void
  319.     {
  320.         foreach ($this->handlers as $handler) {
  321.             if ($handler instanceof ResettableInterface) {
  322.                 $handler->reset();
  323.             }
  324.         }
  325.         foreach ($this->processors as $processor) {
  326.             if ($processor instanceof ResettableInterface) {
  327.                 $processor->reset();
  328.             }
  329.         }
  330.     }
  331.     /**
  332.      * Gets all supported logging levels.
  333.      *
  334.      * @return array Assoc array with human-readable level names => level codes.
  335.      */
  336.     public static function getLevels(): array
  337.     {
  338.         return array_flip(static::$levels);
  339.     }
  340.     /**
  341.      * Gets the name of the logging level.
  342.      *
  343.      * @throws \Psr\Log\InvalidArgumentException If level is not defined
  344.      */
  345.     public static function getLevelName(int $level): string
  346.     {
  347.         if (!isset(static::$levels[$level])) {
  348.             throw new InvalidArgumentException('Level "'.$level.'" is not defined, use one of: '.implode(', 'array_keys(static::$levels)));
  349.         }
  350.         return static::$levels[$level];
  351.     }
  352.     /**
  353.      * Converts PSR-3 levels to Monolog ones if necessary
  354.      *
  355.      * @param  string|int                        $level Level number (monolog) or name (PSR-3)
  356.      * @throws \Psr\Log\InvalidArgumentException If level is not defined
  357.      */
  358.     public static function toMonologLevel($level): int
  359.     {
  360.         if (is_string($level)) {
  361.             // Contains chars of all log levels and avoids using strtoupper() which may have
  362.             // strange results depending on locale (for example, "i" will become "İ" in Turkish locale)
  363.             $upper strtr($level'abcdefgilmnortuwy''ABCDEFGILMNORTUWY');
  364.             if (defined(__CLASS__.'::'.$upper)) {
  365.                 return constant(__CLASS__ '::' $upper);
  366.             }
  367.             throw new InvalidArgumentException('Level "'.$level.'" is not defined, use one of: '.implode(', 'array_keys(static::$levels)));
  368.         }
  369.         if (!is_int($level)) {
  370.             throw new InvalidArgumentException('Level "'.var_export($leveltrue).'" is not defined, use one of: '.implode(', 'array_keys(static::$levels)));
  371.         }
  372.         return $level;
  373.     }
  374.     /**
  375.      * Checks whether the Logger has a handler that listens on the given level
  376.      */
  377.     public function isHandling(int $level): bool
  378.     {
  379.         $record = [
  380.             'level' => $level,
  381.         ];
  382.         foreach ($this->handlers as $handler) {
  383.             if ($handler->isHandling($record)) {
  384.                 return true;
  385.             }
  386.         }
  387.         return false;
  388.     }
  389.     /**
  390.      * Set a custom exception handler that will be called if adding a new record fails
  391.      *
  392.      * The callable will receive an exception object and the record that failed to be logged
  393.      */
  394.     public function setExceptionHandler(?callable $callback): self
  395.     {
  396.         $this->exceptionHandler $callback;
  397.         return $this;
  398.     }
  399.     public function getExceptionHandler(): ?callable
  400.     {
  401.         return $this->exceptionHandler;
  402.     }
  403.     /**
  404.      * Adds a log record at an arbitrary level.
  405.      *
  406.      * This method allows for compatibility with common interfaces.
  407.      *
  408.      * @param mixed  $level   The log level
  409.      * @param string $message The log message
  410.      * @param array  $context The log context
  411.      */
  412.     public function log($level$message, array $context = []): void
  413.     {
  414.         $level = static::toMonologLevel($level);
  415.         $this->addRecord($level, (string) $message$context);
  416.     }
  417.     /**
  418.      * Adds a log record at the DEBUG level.
  419.      *
  420.      * This method allows for compatibility with common interfaces.
  421.      *
  422.      * @param string $message The log message
  423.      * @param array  $context The log context
  424.      */
  425.     public function debug($message, array $context = []): void
  426.     {
  427.         $this->addRecord(static::DEBUG, (string) $message$context);
  428.     }
  429.     /**
  430.      * Adds a log record at the INFO level.
  431.      *
  432.      * This method allows for compatibility with common interfaces.
  433.      *
  434.      * @param string $message The log message
  435.      * @param array  $context The log context
  436.      */
  437.     public function info($message, array $context = []): void
  438.     {
  439.         $this->addRecord(static::INFO, (string) $message$context);
  440.     }
  441.     /**
  442.      * Adds a log record at the NOTICE level.
  443.      *
  444.      * This method allows for compatibility with common interfaces.
  445.      *
  446.      * @param string $message The log message
  447.      * @param array  $context The log context
  448.      */
  449.     public function notice($message, array $context = []): void
  450.     {
  451.         $this->addRecord(static::NOTICE, (string) $message$context);
  452.     }
  453.     /**
  454.      * Adds a log record at the WARNING level.
  455.      *
  456.      * This method allows for compatibility with common interfaces.
  457.      *
  458.      * @param string $message The log message
  459.      * @param array  $context The log context
  460.      */
  461.     public function warning($message, array $context = []): void
  462.     {
  463.         $this->addRecord(static::WARNING, (string) $message$context);
  464.     }
  465.     /**
  466.      * Adds a log record at the ERROR level.
  467.      *
  468.      * This method allows for compatibility with common interfaces.
  469.      *
  470.      * @param string $message The log message
  471.      * @param array  $context The log context
  472.      */
  473.     public function error($message, array $context = []): void
  474.     {
  475.         $this->addRecord(static::ERROR, (string) $message$context);
  476.     }
  477.     /**
  478.      * Adds a log record at the CRITICAL level.
  479.      *
  480.      * This method allows for compatibility with common interfaces.
  481.      *
  482.      * @param string $message The log message
  483.      * @param array  $context The log context
  484.      */
  485.     public function critical($message, array $context = []): void
  486.     {
  487.         $this->addRecord(static::CRITICAL, (string) $message$context);
  488.     }
  489.     /**
  490.      * Adds a log record at the ALERT level.
  491.      *
  492.      * This method allows for compatibility with common interfaces.
  493.      *
  494.      * @param string $message The log message
  495.      * @param array  $context The log context
  496.      */
  497.     public function alert($message, array $context = []): void
  498.     {
  499.         $this->addRecord(static::ALERT, (string) $message$context);
  500.     }
  501.     /**
  502.      * Adds a log record at the EMERGENCY level.
  503.      *
  504.      * This method allows for compatibility with common interfaces.
  505.      *
  506.      * @param string $message The log message
  507.      * @param array  $context The log context
  508.      */
  509.     public function emergency($message, array $context = []): void
  510.     {
  511.         $this->addRecord(static::EMERGENCY, (string) $message$context);
  512.     }
  513.     /**
  514.      * Sets the timezone to be used for the timestamp of log records.
  515.      */
  516.     public function setTimezone(DateTimeZone $tz): self
  517.     {
  518.         $this->timezone $tz;
  519.         return $this;
  520.     }
  521.     /**
  522.      * Returns the timezone to be used for the timestamp of log records.
  523.      */
  524.     public function getTimezone(): DateTimeZone
  525.     {
  526.         return $this->timezone;
  527.     }
  528.     /**
  529.      * Delegates exception management to the custom exception handler,
  530.      * or throws the exception if no custom handler is set.
  531.      */
  532.     protected function handleException(Throwable $e, array $record)
  533.     {
  534.         if (!$this->exceptionHandler) {
  535.             throw $e;
  536.         }
  537.         ($this->exceptionHandler)($e$record);
  538.     }
  539. }