added check services and sen alert functions

Author: mbautista

README.md

@@ -7,13 +7,27 @@ cd /opt
 wget http://github.com/ircf/php-monitoring/archive/master.zip
 gunzip master.zip
 cd php-monitoring
-ln -s cron /etc/cron.d/php-monitoring
 ```
 
-# Configure
+# Configure services and alert
 ```
 cd /opt/php-monitoring
 cp config.inc.php-dist config.inc.php
 nano config.inc.php
 # Enter the service names, IP, alert method, and save file
 ```
+
+# Configure cron
+```
+ln -s cron /etc/cron.d/php-monitoring
+```
+
+# View services statuses
+Services statuses can be viewed from CLI :
+```
+php /opt/php-monitoring/index.php
+```
+Or if you have a web server installed, from a web browser :
+```
+http://example.tld/php-monitoring/index.php
+```

config.inc.php-dist

@@ -4,10 +4,14 @@
  */
 
 $config = array(
+  'timeout' => 2,
   'services' => array(
-    // TODO
+    // 'www.example.tld:80',
+    // 'pop.example.tld:110',
+    // 'smtp.example.tld:25',
   ),
   'alert' => array(
-    // TODO
+    // 'subject' => 'PHP monitoring alert',
+    // 'to' => 'admin@example.tld',
   ),
 );

cron

@@ -2,4 +2,4 @@
 # PHP monitoring cron script
 # To install this script please see README.md
 #
-* * * * * /bin/php /opt/php-monitoring/cron.php &> /var/log/php-monitoring.log
+* * * * * /bin/php /opt/php-monitoring/cron.php

cron.php

@@ -3,10 +3,13 @@
   * PHP monitoring cron script
   */
 
+require_once('functions.php');
+
 $p = new PHPMonitoring();
+
 try{
   $p->init();
   $p->run();
 }catch(Exception $e){
-  $p->log($e);
+  $p->error($e->getMessage());
 }

functions.php

@@ -5,19 +5,120 @@
 
 class PHPMonitoring {
 
+  const CONFIG_FILE = 'config.inc.php';
+  const ERROR_LOG = '/var/log/php-monitoring.log';
+  var $config;
+
+  /**
+   * Initialize PHP settings, load config file and reset results
+   */
   function init(){
-    // TODO load config file
+    ini_set('log_errors', 1);
+    ini_set('error_log', self::ERROR_LOG);
+    global $config;
+    if (!file_exists(self::CONFIG_FILE)){
+      throw new Exception('config file not found');
+    }
+    require_once self::CONFIG_FILE;
+    $this->config = $config;
+    $this->config['results'] = array();
   }
 
+  /**
+   * Check all services statuses
+   */
   function run(){
-    // TODO check services
+    if (
+      !isset($this->config['services'])
+      || !is_array($this->config['services'])
+      || empty($this->config['services'])
+    ){
+      throw new Exception('services not configured');
+    }
+    $alert = false;
+    foreach ($this->config['services'] as $service){
+      $alert = $alert || !$this->checkService($service);
+    }
+    if ($alert){
+      $this->alert();
+    }
+  }
+
+  /**
+   * Check a service status
+   */
+  function checkService($service){
+    list($ip, $port) = explode(':', $service);
+    $this->config['results'][$service] = array();
+    $this->config['results'][$service]['result'] = @fsockopen(
+      $ip,
+      $port,
+      $this->config['results'][$service]['errno'],
+      $this->config['results'][$service]['errstr'],
+      $this->config['timeout']
+    );
+    if (!$this->config['results'][$service]['result']){
+      $this->error("$service is down");
+    }
+    return $this->config['results'][$service]['result'];
+  }
+
+  /**
+   * Check and print a service status
+   */
+  function printService($service){
+    if (!isset($this->config['results'][$service])){
+      $this->checkService($service);
+    }
+    $result = "{$service} -> ";
+    if ($this->config['results'][$service]['result']){
+      $result .= "OK";
+    }else{
+      $result .= "ERROR {$this->config['results'][$service]['errno']} ({$this->config['results'][$service]['errstr']})";
+    }
+    $result .= "\r\n";
+    return $result;
   }
 
-  function log(){
-    // TODO log message
+  /**
+   * Message logging
+   */
+  function info($msg){
+    error_log(date('Y-m-d H:i:s') . ' [INFO] ' . $msg);
+  }
+  function error($msg){
+    error_log(date('Y-m-d H:i:s') . ' [ERROR] ' . $msg);
   }
 
+  /**
+   * Send a mail alert
+   */
   function alert(){
-    // TODO send alert
+    if (
+      !isset($this->config['alert'])
+      || !is_array($this->config['alert'])
+      || empty($this->config['alert'])
+    ){
+      throw new Exception('alert not configured');
+    }
+    foreach ($p->getServices() as $service){
+      $body .= $p->printService($service);
+    }
+    $result = mail(
+      $this->config['alert']['to'],
+      $this->config['alert']['subject'],
+      $body
+    );
+    if (!$result){
+      $this->error('could not send alert');
+    }
+    return $result;
+  }
+  
+  /**
+   * Get services from config
+   */
+  function getServices(){
+    return $this->config['services'];
   }
 }

index.php

@@ -0,0 +1,22 @@
+<?php
+/**
+ * PHP Monitoring index page : show services statuses
+ */
+
+require_once('functions.php');
+
+header('content-type:text/plain');
+
+$p = new PHPMonitoring();
+try{
+  $p->init();
+  ob_start();
+  foreach ($p->getServices() as $service){
+    echo $p->printService($service);
+    ob_flush();
+    flush();
+  }
+}catch(Exception $e){
+  $p->error($e->getMessage());
+  echo $e->getMessage();
+}