Blame view

sources/apps/files_external/3rdparty/aws-sdk-php/Monolog/Handler/FingersCrossedHandler.php 4.13 KB
31b7f2792   Kload   Upgrade to ownclo...
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
  <?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\Handler\FingersCrossed\ErrorLevelActivationStrategy;
  use Monolog\Handler\FingersCrossed\ActivationStrategyInterface;
  use Monolog\Logger;
  
  /**
   * Buffers all records until a certain level is reached
   *
   * The advantage of this approach is that you don't get any clutter in your log files.
   * Only requests which actually trigger an error (or whatever your actionLevel is) will be
   * in the logs, but they will contain all records, not only those above the level threshold.
   *
   * @author Jordi Boggiano <j.boggiano@seld.be>
   */
  class FingersCrossedHandler extends AbstractHandler
  {
      protected $handler;
      protected $activationStrategy;
      protected $buffering = true;
      protected $bufferSize;
      protected $buffer = array();
      protected $stopBuffering;
  
      /**
       * @param callable|HandlerInterface       $handler            Handler or factory callable($record, $fingersCrossedHandler).
       * @param int|ActivationStrategyInterface $activationStrategy Strategy which determines when this handler takes action
       * @param int                             $bufferSize         How many entries should be buffered at most, beyond that the oldest items are removed from the buffer.
       * @param Boolean                         $bubble             Whether the messages that are handled can bubble up the stack or not
       * @param Boolean                         $stopBuffering      Whether the handler should stop buffering after being triggered (default true)
       */
      public function __construct($handler, $activationStrategy = null, $bufferSize = 0, $bubble = true, $stopBuffering = true)
      {
          if (null === $activationStrategy) {
              $activationStrategy = new ErrorLevelActivationStrategy(Logger::WARNING);
          }
          if (!$activationStrategy instanceof ActivationStrategyInterface) {
              $activationStrategy = new ErrorLevelActivationStrategy($activationStrategy);
          }
  
          $this->handler = $handler;
          $this->activationStrategy = $activationStrategy;
          $this->bufferSize = $bufferSize;
          $this->bubble = $bubble;
          $this->stopBuffering = $stopBuffering;
      }
  
      /**
       * {@inheritdoc}
       */
      public function isHandling(array $record)
      {
          return true;
      }
  
      /**
       * {@inheritdoc}
       */
      public function handle(array $record)
      {
          if ($this->processors) {
              foreach ($this->processors as $processor) {
                  $record = call_user_func($processor, $record);
              }
          }
  
          if ($this->buffering) {
              $this->buffer[] = $record;
              if ($this->bufferSize > 0 && count($this->buffer) > $this->bufferSize) {
                  array_shift($this->buffer);
              }
              if ($this->activationStrategy->isHandlerActivated($record)) {
                  if ($this->stopBuffering) {
                      $this->buffering = false;
                  }
                  if (!$this->handler instanceof HandlerInterface) {
                      if (!is_callable($this->handler)) {
                          throw new \RuntimeException("The given handler (".json_encode($this->handler).") is not a callable nor a Monolog\Handler\HandlerInterface object");
                      }
                      $this->handler = call_user_func($this->handler, $record, $this);
                      if (!$this->handler instanceof HandlerInterface) {
                          throw new \RuntimeException("The factory callable should return a HandlerInterface");
                      }
                  }
                  $this->handler->handleBatch($this->buffer);
                  $this->buffer = array();
              }
          } else {
              $this->handler->handle($record);
          }
  
          return false === $this->bubble;
      }
  
      /**
       * Resets the state of the handler. Stops forwarding records to the wrapped handler.
       */
      public function reset()
      {
          $this->buffering = true;
      }
  }