vendor/monolog/monolog/src/Monolog/Handler/DynamoDbHandler.php

   1 <?php
   2
   3 /*
   4  * This file is part of the Monolog package.
   5  *
   6  * (c) Jordi Boggiano <j.boggiano@seld.be>
   7  *
   8  * For the full copyright and license information, please view the LICENSE
   9  * file that was distributed with this source code.
  10  */
  11
  12 namespace Monolog\Handler;
  13
  14 use Aws\Common\Aws;
  15 use Aws\DynamoDb\DynamoDbClient;
  16 use Aws\DynamoDb\Marshaler;
  17 use Monolog\Formatter\ScalarFormatter;
  18 use Monolog\Logger;
  19
  20 /**
  21  * Amazon DynamoDB handler (http://aws.amazon.com/dynamodb/)
  22  *
  23  * @link https://github.com/aws/aws-sdk-php/
  24  * @author Andrew Lawson <adlawson@gmail.com>
  25  */
  26 class DynamoDbHandler extends AbstractProcessingHandler
  27 {
  28     const DATE_FORMAT = 'Y-m-d\TH:i:s.uO';
  29
  30     /**
  31      * @var DynamoDbClient
  32      */
  33     protected $client;
  34
  35     /**
  36      * @var string
  37      */
  38     protected $table;
  39
  40     /**
  41      * @var int
  42      */
  43     protected $version;
  44
  45     /**
  46      * @var Marshaler
  47      */
  48     protected $marshaler;
  49
  50     /**
  51      * @param DynamoDbClient $client
  52      * @param string         $table
  53      * @param int            $level
  54      * @param bool           $bubble
  55      */
  56     public function __construct(DynamoDbClient $client, $table, $level = Logger::DEBUG, $bubble = true)
  57     {
  58         if (defined('Aws\Common\Aws::VERSION') && version_compare(Aws::VERSION, '3.0', '>=')) {
  59             $this->version = 3;
  60             $this->marshaler = new Marshaler;
  61         } else {
  62             $this->version = 2;
  63         }
  64
  65         $this->client = $client;
  66         $this->table = $table;
  67
  68         parent::__construct($level, $bubble);
  69     }
  70
  71     /**
  72      * {@inheritdoc}
  73      */
  74     protected function write(array $record)
  75     {
  76         $filtered = $this->filterEmptyFields($record['formatted']);
  77         if ($this->version === 3) {
  78             $formatted = $this->marshaler->marshalItem($filtered);
  79         } else {
  80             $formatted = $this->client->formatAttributes($filtered);
  81         }
  82
  83         $this->client->putItem(array(
  84             'TableName' => $this->table,
  85             'Item' => $formatted,
  86         ));
  87     }
  88
  89     /**
  90      * @param  array $record
  91      * @return array
  92      */
  93     protected function filterEmptyFields(array $record)
  94     {
  95         return array_filter($record, function ($value) {
  96             return !empty($value) || false === $value || 0 === $value;
  97         });
  98     }
  99
 100     /**
 101      * {@inheritdoc}
 102      */
 103     protected function getDefaultFormatter()
 104     {
 105         return new ScalarFormatter(self::DATE_FORMAT);
 106     }
 107 }