Merge pull request #148 from tegbessou/add-mongodb-check

Adding a check for mongodb connection

.travis.yml

@@ -1,5 +1,7 @@
 language: php
-
+sudo: required
+dist: trusty
+group: edge
 php:
   - 5.4
   - 5.5
@@ -8,8 +10,6 @@ php:
   - 7.1
   - hhvm
 
-sudo: false
-
 cache:
   directories:
     - $HOME/.composer/cache/files

Check/DoctrineMongoDb.php

@@ -0,0 +1,27 @@
+<?php
+
+namespace Liip\MonitorBundle\Check;
+
+use Doctrine\Bundle\MongoDBBundle\ManagerRegistry;
+use ZendDiagnostics\Check\AbstractCheck;
+use ZendDiagnostics\Result\Success;
+
+class DoctrineMongoDb extends AbstractCheck
+{
+    protected $manager;
+    protected $connectionName;
+
+    public function __construct(ManagerRegistry $registry, $connectionName = null)
+    {
+        $this->manager = $registry;
+        $this->connectionName = $connectionName;
+    }
+
+    public function check()
+    {
+        $connection = $this->manager->getConnection();
+        $connection->connect();
+
+        return new Success();
+    }
+}

Check/DoctrineMongoDbCollection.php

@@ -0,0 +1,36 @@
+<?php
+
+namespace Liip\MonitorBundle\Check;
+
+use Doctrine\Common\Persistence\ConnectionRegistry;
+use ZendDiagnostics\Check\CheckCollectionInterface;
+
+/**
+ * @author Hugues Gobet <[email protected]>
+ */
+class DoctrineMongoDbCollection implements CheckCollectionInterface
+{
+    private $checks = array();
+
+    public function __construct(ConnectionRegistry $manager, $connections)
+    {
+        if (!is_array($connections)) {
+            $connections = array($connections);
+        }
+
+        foreach ($connections as $connection) {
+            $check = new DoctrineMongoDb($manager, $connection);
+            $check->setLabel(sprintf('Doctrine Mongo Db "%s" connection', $connection));
+
+            $this->checks[sprintf('doctrine_dbal_%s_connection', $connection)] = $check;
+        }
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function getChecks()
+    {
+        return $this->checks;
+    }
+}

DependencyInjection/Configuration.php

@@ -158,6 +158,11 @@ private function createGroupsNode()
                         ->info('Connection name or an array of connection names')
                         ->example('[default, crm]')
                     ->end()
+                    ->variableNode('doctrine_mongodb')
+                        ->defaultNull()
+                        ->info('Connection name or an array of connection names')
+                        ->example('[default, crm]')
+                    ->end()
                     ->arrayNode('doctrine_migrations')
                         ->useAttributeAsKey('name')
                         ->info('Check if doctrine migrations are applied')

DependencyInjection/LiipMonitorExtension.php

@@ -98,6 +98,7 @@ private function setParameters(ContainerBuilder $container, $checkName, $group,
             case 'writable_directory':
             case 'process_running':
             case 'doctrine_dbal':
+            case 'doctrine_mongodb':
             case 'http_service':
             case 'guzzle_http_service':
             case 'memcache':

README.md

@@ -315,6 +315,9 @@ liip_monitor:
 
                 # Connection name or an array of connection names
                 doctrine_dbal:        null # Example: [default, crm]
+                
+                # Connection name or an array of connection names
+                doctrine_mongodb:        null # Example: [default, crm]
 
                 # Check if MemCache extension is loaded and given server is reachable
                 memcache:

Resources/config/checks/doctrine_mongodb.xml

@@ -0,0 +1,18 @@
+<?xml version="1.0" ?>
+
+<container xmlns="http://symfony.com/schema/dic/services"
+           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+           xsi:schemaLocation="http://symfony.com/schema/dic/services http://symfony.com/schema/dic/services/services-1.0.xsd">
+
+    <parameters>
+        <parameter key="liip_monitor.check.doctrine_mongodb.class">Liip\MonitorBundle\Check\DoctrineMongoDbCollection</parameter>
+    </parameters>
+
+    <services>
+        <service id="liip_monitor.check.doctrine_mongodb" public="false" class="%liip_monitor.check.doctrine_mongodb.class%">
+            <argument type="service" id="doctrine_mongodb" />
+            <argument>%%liip_monitor.check.doctrine_mongodb%%</argument>
+            <tag name="liip_monitor.check_collection" />
+        </service>
+    </services>
+</container>