Add support to log to redis

DependencyInjection/Configuration.php

@@ -85,6 +85,18 @@
  *   - [level]: level name or int value, defaults to DEBUG
  *   - [bubble]: bool, defaults to true
  *
+ * - redis:
+ *   - id: optional if host is given
+ *   - host: 127.0.0.1
+ *   - password: null
+ *   - port: 6379
+ *   - database: 0
+ *   - key_name: monolog_redis
+ *
+ * - predis:
+ *   - id: optional if host is given
+ *   - host: tcp://10.0.0.1:6379
+ *   - key_name: monolog_redis
  * - fingers_crossed:
  *   - handler: the wrapped handler's name
  *   - [action_level|activation_strategy]: minimum level or service id to activate the handler, defaults to WARNING
@@ -517,6 +529,44 @@ public function getConfigTreeBuilder()
                             ->scalarNode('index')->defaultValue('monolog')->end() // elasticsearch
                             ->scalarNode('document_type')->defaultValue('logs')->end() // elasticsearch
                             ->scalarNode('ignore_error')->defaultValue(false)->end() // elasticsearch
+                            ->arrayNode('redis')
+                                ->canBeUnset()
+                                ->beforeNormalization()
+                                    ->ifString()
+                                    ->then(function ($v) { return array('id' => $v); })
+                                ->end()
+                                ->children()
+                                    ->scalarNode('id')->end()
+                                    ->scalarNode('host')->end()
+                                    ->scalarNode('password')->defaultNull()->end()
+                                    ->scalarNode('port')->defaultValue(6379)->end()
+                                    ->scalarNode('database')->defaultValue(0)->end()
+                                    ->scalarNode('key_name')->defaultValue('monolog_redis')->end()
+                                ->end()
+                                ->validate()
+                                    ->ifTrue(function ($v) {
+                                        return !isset($v['id']) && !isset($v['host']);
+                                    })
+                                    ->thenInvalid('What must be set is either the host or the service id of the Redis client.')
+                                ->end()
+                            ->end() // redis
+                            ->arrayNode('predis')
+                                ->canBeUnset()
+                                ->beforeNormalization()
+                                    ->ifString()
+                                    ->then(function ($v) { return array('id' => $v); })
+                                ->end()
+                                ->children()
+                                    ->scalarNode('id')->end()
+                                    ->scalarNode('host')->end()
+                                ->end()
+                                ->validate()
+                                    ->ifTrue(function ($v) {
+                                        return !isset($v['id']) && !isset($v['host']);
+                                    })
+                                    ->thenInvalid('What must be set is either the host or the service id of the Predis client.')
+                                ->end()
+                            ->end() // predis
                             ->arrayNode('config')
                                 ->canBeUnset()
                                 ->prototype('scalar')->end()
@@ -833,6 +883,14 @@ public function getConfigTreeBuilder()
                             ->ifTrue(function ($v) { return 'server_log' === $v['type'] && empty($v['host']); })
                             ->thenInvalid('The host has to be specified to use a ServerLogHandler')
                         ->end()
+                        ->validate()
+                            ->ifTrue(function ($v) { return 'redis' === $v['type'] && empty($v['redis']); })
+                            ->thenInvalid('The host has to be specified to use a RedisLogHandler')
+                        ->end()
+                        ->validate()
+                            ->ifTrue(function ($v) { return 'predis' === $v['type'] && empty($v['redis']); })
+                            ->thenInvalid('The host has to be specified to use a RedisLogHandler')
+                        ->end()
                     ->end()
                     ->validate()
                         ->ifTrue(function ($v) { return isset($v['debug']); })

DependencyInjection/MonologExtension.php

@@ -291,6 +291,45 @@ private function buildHandler(ContainerBuilder $container, $name, array $handler
                 $handler['bubble'],
             ));
             break;
+        case 'redis':
+        case 'predis':
+            $type = $handler['type'];
+
+            if (isset($handler[$type]['id'])) {
+                $clientId = $handler[$type]['id'];
+            } elseif ('redis' === $type) {
+                if (!class_exists('\Redis')) {
+                    throw new \RuntimeException('The \Redis is not available.');
+                }
+
+                $client = new Definition('\Redis');
+                $client->addMethodCall('connect', array($handler['redis']['host'], $handler['redis']['port']));
+                $client->addMethodCall('auth', array($handler['redis']['password']));
+                $client->addMethodCall('select', array($handler['redis']['database']));
+                $client->setPublic(false);
+                $clientId = uniqid('monolog.redis.client.', true);
+                $container->setDefinition($clientId, $client);
+            } else {
+                if (!class_exists('\Predis\Client')) {
+                    throw new \RuntimeException('The \Predis\Client is not available.');
+                }
+
+                $client = new Definition('\Predis\Client');
+                $client->setArguments(array(
+                    $handler['predis']['host'],
+                ));
+                $client->setPublic(false);
+
+                $clientId = uniqid('monolog.predis.client.', true);
+                $container->setDefinition($clientId, $client);
+            }
+            $definition->setArguments(array(
+                new Reference($clientId),
+                $handler[$type]['key_name'],
+                $handler['level'],
+                $handler['bubble'],
+            ));
+            break;
 
         case 'chromephp':
             $definition->setArguments(array(
@@ -801,6 +840,8 @@ private function getHandlerClassByType($handlerType)
             'mongo' => 'Monolog\Handler\MongoDBHandler',
             'elasticsearch' => 'Monolog\Handler\ElasticSearchHandler',
             'server_log' => 'Symfony\Bridge\Monolog\Handler\ServerLogHandler',
+            'redis' => 'Monolog\Handler\RedisHandler',
+            'predis' => 'Monolog\Handler\RedisHandler',
         );
 
         if (!isset($typeToClassMapping[$handlerType])) {

Resources/config/schema/monolog-1.0.xsd

@@ -156,6 +156,20 @@
         <xsd:attribute name="collection" type="xsd:string" />
     </xsd:complexType>
 
+    <xsd:complexType name="redis">
+        <xsd:attribute name="id" type="xsd:string" />
+        <xsd:attribute name="host" type="xsd:string" />
+        <xsd:attribute name="password" type="xsd:string" />
+        <xsd:attribute name="port" type="xsd:integer" />
+        <xsd:attribute name="database" type="xsd:integer" />
+        <xsd:attribute name="key_name" type="xsd:string" />
+    </xsd:complexType>
+
+    <xsd:complexType name="predis">
+        <xsd:attribute name="id" type="xsd:string" />
+        <xsd:attribute name="host" type="xsd:string" />
+    </xsd:complexType>
+
     <xsd:complexType name="elasticsearch">
         <xsd:attribute name="id" type="xsd:string" />
         <xsd:attribute name="host" type="xsd:string" />

Tests/DependencyInjection/ConfigurationTest.php

@@ -337,6 +337,50 @@ public function testWithNestedHandler()
 
         $this->assertTrue($config['handlers']['foobar']['nested']);
     }
+    public function testWithRedisHandler()
+    {
+        $configs = array(
+            array(
+                'handlers' => array(
+                    'redis' => array(
+                        'type' => 'redis',
+                        'redis' => array(
+                            'host' => '127.0.1.1',
+                            'password' => 'pa$$w0rd',
+                            'port' => 1234,
+                            'database' => 1,
+                            'key_name' => 'monolog_redis_test'
+                        )
+                    )
+                )
+            )
+        );
+        $config = $this->process($configs);
+
+        $this->assertEquals('127.0.1.1', $config['handlers']['redis']['redis']['host']);
+        $this->assertEquals('pa$$w0rd', $config['handlers']['redis']['redis']['password']);
+        $this->assertEquals(1234, $config['handlers']['redis']['redis']['port']);
+        $this->assertEquals(1, $config['handlers']['redis']['redis']['database']);
+        $this->assertEquals('monolog_redis_test', $config['handlers']['redis']['redis']['key_name']);
+
+        $configs = array(
+            array(
+                'handlers' => array(
+                    'redis' => array(
+                        'type' => 'predis',
+                        'redis' => array(
+                            'host' => '127.0.1.1',
+                            'key_name' => 'monolog_redis_test'
+                        )
+                    )
+                )
+            )
+        );
+        $config = $this->process($configs);
+
+        $this->assertEquals('127.0.1.1', $config['handlers']['redis']['redis']['host']);
+        $this->assertEquals('monolog_redis_test', $config['handlers']['redis']['redis']['key_name']);
+    }
 
     /**
      * Processes an array of configurations and returns a compiled version.