tyler.durden
/
icinga2
mirror of https://github.com/Icinga/icinga2.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Added IcingaConnection PHP class.

This commit is contained in:
Gunnar Beutner 2012-07-13 14:28:52 +02:00
parent c0d7241eaf
commit abb5780f4a
1 changed files with 116 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

116
contrib/IcingaConnection.class.php Normal file
View File

@ -0,0 +1,116 @@
<?php
class IcingaConnection
{
private $_streamContext;
private $_stream;
private $_subscriptions;
private $_publications;
public function __construct()
{
$this->_subscriptions = array();
$this->_publications = array();
}
public function Connect($host, $port, $cafile, $cert)
{
$this->_streamContext = stream_context_create();
stream_context_set_option($this->_streamContext, 'ssl', 'cafile', $cafile);
stream_context_set_option($this->_streamContext, 'ssl', 'local_cert', $cert);
$this->_stream = stream_socket_client('ssl://' . $host . ':' . $port, $error, $errorString, 60, STREAM_CLIENT_CONNECT, $this->_streamContext);
if ($this->_stream === false)
return false;
$this->Publish('discovery::RegisterComponent');
$this->Publish('discovery::Welcome');
$this->Subscribe('discovery::NewComponent');
$this->Subscribe('discovery::RegisterComponent');
$this->Subscribe('discovery::Welcome');
$params = array(
'publications' => $this->_publications,
'subscriptions' => $this->_subscriptions
);
$this->SendMessage('discovery::RegisterComponent', $params);
$this->SendMessage('discovery::Welcome');
}
public function Subscribe($topic)
{
$this->_subscriptions[] = $topic;
}
public function Publish($topic)
{
$this->_publications[] = $topic;
}
public function SendMessage($topic, $params = array())
{
$message = array('jsonrpc' => '2.0', 'method' => $topic, 'params' => $params);
$messageStr = json_encode($message, JSON_FORCE_OBJECT);
fprintf($this->_stream, '%d:%s,', strlen($messageStr), $messageStr);
fflush($this->_stream);
}
public function ReadMessage()
{
$lenStr = '';
/* read netstring length (up until the first :) */
while (($chr = fread($this->_stream, 1)) != ':') {
if ($chr === false)
return false;
$lenStr .= $chr;
}
/* read data */
$messageStr = fread($this->_stream, (int)$lenStr);
if ($messageStr === false)
return false;
/* read trailing comma */
$comma = fread($this->_stream, 1);
if ($comma != ',')
return false;
return json_decode($messageStr, true);
}
}
$icinga = new IcingaConnection();
$icinga->Subscribe('delegation::ServiceStatus');
if ($icinga->Connect('localhost', 7777, 'ca.crt', 'icinga-c3.pem') === false)
return;
while (($message = $icinga->ReadMessage()) !== false) {
if ($message['method'] != 'delegation::ServiceStatus')
continue;
$params = $message['params'];
$now = time();
$next = $params['next_check'] - $now;
$states = array('ok', 'warning', 'critical', 'uncheckable', 'unknown');
$types = array('hard', 'soft');
echo 'Service: ' . $params['service'] .
', State: ' . $states[$params['state']] .
', State Type: ' . $types[$params['state_type']] .
', Attempt: ' . $params['current_attempt'] .
' (took ' . ($params['result']['schedule_end'] - $params['result']['schedule_start']) . ' seconds' .
', next check in ' . $next . ' seconds)' .
"\n";
}
?>