statusJson.php

<?php
// statusJson.php
//
// Script to parse Nagios status.dat and present it as JSON, to allow inclusion
// of status info in a web page served from a separate machine.
//
// This code is just a modification of Jason Antman's statusXML.php available at
// https://github.com/jantman/php-nagios-xml
//
// +----------------------------------------------------------------------+
// | Copyright (c) 2013 Christian Lizell.                                 |
// |                                                                      |
// | This program is free software; you can redistribute it and/or modify |
// | it under the terms of the GNU General Public License as published by |
// | the Free Software Foundation; either version 3 of the License, or    |
// | (at your option) any later version.                                  |
// |                                                                      |
// | This program is distributed in the hope that it will be useful,      |
// | but WITHOUT ANY WARRANTY; without even the implied warranty of       |
// | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the        |
// | GNU General Public License for more details.                         |
// |                                                                      |
// +----------------------------------------------------------------------+

// Change this accordingly
$statusFile = "/opt/local/var/nagios/status.dat";

$nag_version = getFileVersion($statusFile);
$created_ts = 0;

$debug = false;

if ($nag_version == 4) {
    $data = getData4($statusFile);
} else if ($nag_version == 3) {
    $data = getData3($statusFile);
} else {
    $data = getData2($statusFile);
}

$hosts = $data['hosts'];
$services = $data['services'];
$program = "";
if (array_key_exists("program", $data)) {
    $program = $data['program'];
}

outputJson($hosts, $services, $program);

function outputJson($hosts, $services, $program)
{
    // begin outputting XML
    header("Content-type: application/json");
    echo "{" . "\n";

    // program status
    if ($program != "") {
        echo '  "programStatus": {' . "\n";
        foreach ($program as $key => $val) {
            echo '    "' . jsonString($key) . '": "' . jsonString($val) . '"' . (isLast($program, $key) ? '' : ',') . "\n";
        }
        unset($key, $val);
        echo '  },' . "\n";
    }

    // hosts
    echo '  "hosts": {' . "\n";
    foreach ($hosts as $hostName => $hostArray) {
        echo '   "' . jsonString($hostName) . '": {' . "\n";
        foreach ($hostArray as $key => $val) {
            echo '      "' . jsonString($key) . '": "' . jsonString($val) . '"' . (isLast($hostArray, $key) ? '' : ',') . "\n";
        }
        unset($key, $val);
        echo '   }' . (isLast($hosts, $hostName) ? '' : ',') . "\n";
    }
    unset($hostName, $hostArray);
    echo '  },' . "\n";

    // loop through the services
    echo '  "services": {' . "\n";
    foreach ($services as $hostName => $service) {
        echo '   "' . jsonString($hostName) . '": {' . "\n";
        foreach ($service as $serviceDesc => $serviceArray) {
            echo '   "' . jsonString($serviceDesc) . '": {' . "\n";
            foreach ($serviceArray as $key => $val) {
                echo '      "' . jsonString($key) . '": "' . jsonString($val) . '"' . (isLast($serviceArray, $key) ? '' : ',') . "\n";
            }
            unset($key, $val);
            echo '   }' . (isLast($service, $serviceDesc) ? '' : ',') . "\n";
        }
        echo '   }' . (isLast($services, $hostName) ? '' : ',') . "\n";
        unset($serviceDesc, $serviceArray);
    }
    unset($hostName, $service);
    echo '  }' . "\n";
    echo "}";
}


// Determines if the given key is last in the given array
function isLast($array, $key)
{
    end($array);
    return ($key === key($array));
}


// replace reserved characters in json
function jsonString($s)
{
    $s = str_replace('\\', '\\\\', $s);
    $s = str_replace('"', '\"', $s);
    $s = str_replace("\t", '\t', $s);
    $s = str_replace("\n", " ", $s);
    $s = str_replace("\r", " ", $s);
    return $s;
}


// figure out what version the file is
function getFileVersion($statusFile)
{
    global $created_ts;
    $version = 2;

    $fh = fopen($statusFile, 'r');
    $inInfo = false;
    while ($line = fgets($fh)) {
        if (trim($line) == "info {") {
            $inInfo = true;
        } elseif (trim($line) == "}") {
            $inInfo = false;
            break;
        } elseif ($inInfo) {
            $vals = explode("=", $line);
            if (trim($vals[0]) == "created") {
                $created = $vals[1];
            } elseif (trim($vals[0]) == "version") {
                $version = substr($vals[1], 0, 1);
            }
        }
    }
    return $version;
}


// parse nagios2 status.dat
function getData2($statusFile)
{
    // the keys to get from host status:
    $host_keys = array('host_name', 'has_been_checked', 'check_execution_time', 'check_latency', 'check_type', 'current_state', 'current_attempt', 'state_type', 'last_state_change', 'last_time_up', 'last_time_down', 'last_time_unreachable', 'last_notification', 'next_notification', 'no_more_notifications', 'current_notification_number', 'notifications_enabled', 'problem_has_been_acknowledged', 'acknowledgement_type', 'active_checks_enabled', 'passive_checks_enabled', 'last_update');

    // keys to get from service status:
    $service_keys = array('host_name', 'service_description', 'has_been_checked', 'check_execution_time', 'check_latency', 'current_state', 'state_type', 'last_state_change', 'last_time_ok', 'last_time_warning', 'last_time_unknown', 'last_time_critical', 'plugin_output', 'last_check', 'notifications_enabled', 'active_checks_enabled', 'passive_checks_enabled', 'problem_has_been_acknowledged', 'acknowledgement_type', 'last_update', 'is_flapping');

    # open the file
    $fh = fopen($statusFile, 'r');

    # variables to keep state
    $inSection = false;
    $sectionType = "";
    $lineNum = 0;
    $sectionData = array();

    $hostStatus = array();
    $serviceStatus = array();

    #variables for total hosts and services
    $typeTotals = array();

    # loop through the file
    while ($line = fgets($fh)) {
        $lineNum++; // increment counter of line number, mainly for debugging
        $line = trim($line); // strip whitespace
        if ($line == "") {
            continue;
        } // ignore blank line
        if (substr($line, 0, 1) == "#") {
            continue;
        } // ignore comment

        // ok, now we need to deal with the sections

        if (!$inSection) {
            // we're not currently in a section, but are looking to start one
            if (strstr($line, " ") && (substr($line, -1) == "{")) // space and ending with {, so it's a section header
            {
                $sectionType = substr($line, 0, strpos($line, " ")); // first word on line is type
                $inSection = true;
                // we're now in a section
                $sectionData = array();

                // increment the counter for this sectionType
                if (isset($typeTotals[$sectionType])) {
                    $typeTotals[$sectionType] = $typeTotals[$sectionType] + 1;
                } else {
                    $typeTotals[$sectionType] = 1;
                }

            }
        }

        if ($inSection && $line == "}") // closing a section
        {
            if ($sectionType == "service") {
                $serviceStatus[$sectionData['host_name']][$sectionData['service_description']] = $sectionData;
            }
            if ($sectionType == "host") {
                $hostStatus[$sectionData["host_name"]] = $sectionData;
            }
            $inSection = false;
            $sectionType = "";
            continue;
        } else {
            // we're currently in a section, and this line is part of it
            $lineKey = substr($line, 0, strpos($line, "="));
            $lineVal = substr($line, strpos($line, "=") + 1);

            // add to the array as appropriate
            if ($sectionType == "service") {
                if (in_array($lineKey, $service_keys)) {
                    $sectionData[$lineKey] = $lineVal;
                }
            } elseif ($sectionType == "host") {
                if (in_array($lineKey, $host_keys)) {
                    $sectionData[$lineKey] = $lineVal;
                }
            }
            // else continue on, ignore this section, don't save anything
        }

    }

    fclose($fh);

    $retArray = array("hosts" => $hostStatus, "services" => $serviceStatus);

    return $retArray;
}


// parse nagios3 status.dat
function getData3($statusFile)
{
    global $debug;

    # open the file
    $fh = fopen($statusFile, 'r');

    # variables to keep state
    $inSection = false;
    $sectionType = "";
    $lineNum = 0;
    $sectionData = array();

    $hostStatus = array();
    $serviceStatus = array();
    $programStatus = array();

    #variables for total hosts and services
    $typeTotals = array();

    # loop through the file
    while ($line = fgets($fh)) {
        $lineNum++; // increment counter of line number, mainly for debugging
        $line = trim($line); // strip whitespace
        if ($line == "") {
            continue;
        } // ignore blank line
        if (substr($line, 0, 1) == "#") {
            continue;
        } // ignore comment

        // ok, now we need to deal with the sections
        if (!$inSection) {
            // we're not currently in a section, but are looking to start one
            if (substr($line, strlen($line) - 1, 1) == "{") // space and ending with {, so it's a section header
            {
                $sectionType = substr($line, 0, strpos($line, " ")); // first word on line is type
                $inSection = true;
                // we're now in a section
                $sectionData = array();

                // increment the counter for this sectionType
                if (isset($typeTotals[$sectionType])) {
                    $typeTotals[$sectionType] = $typeTotals[$sectionType] + 1;
                } else {
                    $typeTotals[$sectionType] = 1;
                }

            }
        } elseif ($inSection && trim($line) == "}") // closing a section
        {
            if ($sectionType == "servicestatus") {
                $serviceStatus[$sectionData['host_name']][$sectionData['service_description']] = $sectionData;
            } elseif ($sectionType == "hoststatus") {
                $hostStatus[$sectionData["host_name"]] = $sectionData;
            } elseif ($sectionType == "programstatus") {
                $programStatus = $sectionData;
            }
            $inSection = false;
            $sectionType = "";
            continue;
        } else {
            // we're currently in a section, and this line is part of it
            $lineKey = substr($line, 0, strpos($line, "="));
            $lineVal = substr($line, strpos($line, "=") + 1);

            // add to the array as appropriate
            if ($sectionType == "servicestatus" || $sectionType == "hoststatus" || $sectionType == "programstatus") {
                if ($debug) {
                    echo "LINE " . $lineNum . ": lineKey=" . $lineKey . "= lineVal=" . $lineVal . "=\n";
                }
                $sectionData[$lineKey] = $lineVal;
            }
            // else continue on, ignore this section, don't save anything
        }

    }

    fclose($fh);

    $retArray = array("hosts" => $hostStatus, "services" => $serviceStatus, "program" => $programStatus);
    return $retArray;
}


// parse nagios4 status.dat
function getData4($statusFile)
{
    // For now just re-use the nagios3 parsing
    return getData3($statusFile);
}

// this formats the age of a check in seconds into a nice textual description
function ageString($seconds)
{
    $age = "";
    if ($seconds > 86400) {
        $days = (int)($seconds / 86400);
        $seconds = $seconds - ($days * 86400);
        $age .= $days . " days ";
    }
    if ($seconds > 3600) {
        $hours = (int)($seconds / 3600);
        $seconds = $seconds - ($hours * 3600);
        $age .= $hours . " hours ";
    }
    if ($seconds > 60) {
        $minutes = (int)($seconds / 60);
        $seconds = $seconds - ($minutes * 60);
        $age .= $minutes . " minutes ";
    }
    $age .= $seconds . " seconds ";
    return $age;
}
?>