Blame view

sources/apps/files_external/3rdparty/aws-sdk-php/Monolog/Handler/CouchDBHandler.php 1.87 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
  <?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\Formatter\JsonFormatter;
  use Monolog\Logger;
  
  /**
   * CouchDB handler
   *
   * @author Markus Bachmann <markus.bachmann@bachi.biz>
   */
  class CouchDBHandler extends AbstractProcessingHandler
  {
      private $options;
  
      public function __construct(array $options = array(), $level = Logger::DEBUG, $bubble = true)
      {
          $this->options = array_merge(array(
              'host'     => 'localhost',
              'port'     => 5984,
              'dbname'   => 'logger',
              'username' => null,
              'password' => null,
          ), $options);
  
          parent::__construct($level, $bubble);
      }
  
      /**
       * {@inheritDoc}
       */
      protected function write(array $record)
      {
          $basicAuth = null;
          if ($this->options['username']) {
              $basicAuth = sprintf('%s:%s@', $this->options['username'], $this->options['password']);
          }
  
          $url = 'http://'.$basicAuth.$this->options['host'].':'.$this->options['port'].'/'.$this->options['dbname'];
          $context = stream_context_create(array(
              'http' => array(
                  'method'        => 'POST',
                  'content'       => $record['formatted'],
                  'ignore_errors' => true,
                  'max_redirects' => 0,
                  'header'        => 'Content-type: application/json',
              )
          ));
  
          if (false === @file_get_contents($url, null, $context)) {
              throw new \RuntimeException(sprintf('Could not connect to %s', $url));
          }
      }
  
      /**
       * {@inheritDoc}
       */
      protected function getDefaultFormatter()
      {
          return new JsonFormatter();
      }
  }