debmon
/
nagiosql
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
nagiosql/functions/NagConfigClass.php

2449 lines
114 KiB
PHP
Raw Permalink Blame History

<?php
///////////////////////////////////////////////////////////////////////////////
//
// NagiosQL
//
///////////////////////////////////////////////////////////////////////////////
//
// (c) 2005-2018 by Martin Willisegger
//
// Project : NagiosQL
// Component : Configuration Class
// Website : https://sourceforge.net/projects/nagiosql/
// Version : 3.4.0
// GIT Repo : https://gitlab.com/wizonet/NagiosQL
//
///////////////////////////////////////////////////////////////////////////////////////////////
//
///////////////////////////////////////////////////////////////////////////////////////////////
//
// Class: Configuration class
//
///////////////////////////////////////////////////////////////////////////////////////////////
//
// Includes all functions used for handling configuration files with NagiosQL
//
// Name: NagConfigClass
//
///////////////////////////////////////////////////////////////////////////////////////////////
namespace functions;
class NagConfigClass
{
// Define class variables
/** @var resource $resConnectId */
public $resConnectId; // Connection id for FTP and SSH connections
public $resSFTP; // SFTP ressource id
public $arrSession = array(); // Session content
public $strRelTable = ''; // Relation table name
public $strErrorMessage = ''; // String including error messages
public $strInfoMessage = ''; // String including information messages
public $strPicPath = 'none'; // Picture path string
public $intNagVersion = 0; // Nagios version id
public $intDomainId = 0; // Configuration domain ID
// PRIVATE
private $arrSettings = array(); // Array includes all global settings
private $resConnectServer = ''; // Connection server name for FTP and SSH connections
private $resConnectType = 'none'; // Connection type for FTP and SSH connections
private $arrRelData = ''; // Relation data
// Class includes
/** @var MysqliDbClass */
public $myDBClass; // Database class reference
/** @var NagDataClass */
public $myDataClass; // Data processing class reference
/**
* NagConfigClass constructor.
* @param array $arrSession PHP Session array
*/
public function __construct($arrSession)
{
if (isset($arrSession['SETS'])) {
// Read global settings
$this->arrSettings = $arrSession['SETS'];
}
if (isset($arrSession['domain'])) {
$this->intDomainId = $arrSession['domain'];
}
$this->arrSession = $arrSession;
}
/**
* Get domain configuration parameters.
* @param string $strConfigItem Configuration key
* @param string $strValue Configuration value (by reference)
* @return int 0 = successful / 1 = error
*/
public function getDomainData($strConfigItem, &$strValue)
{
// Variable definition
$intReturn = 0;
// Request domain data from database
$strSQL = 'SELECT `' .$strConfigItem. '` FROM `tbl_datadomain` WHERE `id` = ' .$this->intDomainId;
$strValue = $this->myDBClass->getFieldData($strSQL);
if ($strValue == '') {
$intReturn = 1;
}
return $intReturn;
}
/**
* Get last modification date of a database table and any configuration files inside a directory.
* @param string $strTableName Name of the database table
* @param string $strConfigName Name of the configuration file
* @param int $intDataId ID of the dataset for service table
* @param array $arrTimeData Array with the timestamps of the files and the DB table (by reference)
* @param int $intTimeInfo Time status value (by reference)
* 0 = all files are newer than the database item
* 1 = some file are older than the database item
* 2 = one file is missing
* 3 = any files are missing
* 4 = no configuration targets defined
* @return int 0 = successful / 1 = error
* Status messages are stored in class variables
*/
public function lastModifiedDir($strTableName, $strConfigName, $intDataId, &$arrTimeData, &$intTimeInfo)
{
// Variable definitions
$intReturn = 0;
// Create file name
$strFileName = $strConfigName. '.cfg';
// Get table times
$strActive = 0;
$arrTimeData = array();
$arrTimeData['table'] = 'unknown';
// Clear status cache
clearstatcache();
// Get last change on dataset
if ($strTableName == 'tbl_host') {
$strSQL1 = "SELECT DATE_FORMAT(`last_modified`,'%Y-%m-%d %H:%i:%s') FROM `tbl_host` ".
"WHERE `host_name`='$strConfigName' AND `config_id`=".$this->intDomainId;
$strSQL2 = "SELECT `active` FROM `tbl_host` WHERE `host_name`='$strConfigName' ".
'AND `config_id`=' .$this->intDomainId;
$arrTimeData['table'] = $this->myDBClass->getFieldData($strSQL1);
$strActive = $this->myDBClass->getFieldData($strSQL2);
} elseif ($strTableName == 'tbl_service') {
$strSQL1 = "SELECT DATE_FORMAT(`last_modified`,'%Y-%m-%d %H:%i:%s') FROM `tbl_service` ".
"WHERE `id`='$intDataId' AND `config_id`=".$this->intDomainId;
$strSQL2 = "SELECT * FROM `$strTableName` WHERE `config_name`='$strConfigName' ".
'AND `config_id`=' .$this->intDomainId." AND `active`='1'";
$arrTimeData['table'] = $this->myDBClass->getFieldData($strSQL1);
$intServiceCount = $this->myDBClass->countRows($strSQL2);
if ($intServiceCount != 0) {
$strActive = 1;
}
} else {
$intReturn = 1;
}
// Get config sets
$arrConfigId = array();
$strTarget = '';
$strBaseDir = '';
$intTimeInfo = -1;
$intRetVal2 = $this->getConfigTargets($arrConfigId);
if ($intRetVal2 == 0) {
foreach ($arrConfigId as $intConfigId) {
// Get configuration file data
$this->getConfigValues($intConfigId, 'target', $strTarget);
// Get last change on dataset
if ($strTableName == 'tbl_host') {
$this->getConfigValues($intConfigId, 'hostconfig', $strBaseDir);
} elseif ($strTableName == 'tbl_service') {
$this->getConfigValues($intConfigId, 'serviceconfig', $strBaseDir);
}
$arrTimeData[$strTarget] = 'unknown';
$intFileStampTemp = -1;
// Get time data
$intReturn = $this->getFileDate(
$intConfigId,
$strFileName,
$strBaseDir,
$intFileStampTemp,
$arrTimeData[$strTarget]
);
if (($intFileStampTemp == 0) && ($strActive == '1')) {
$intTimeInfo = 2;
}
if (($strActive == '1') && (strtotime($arrTimeData['table']) > $intFileStampTemp)) {
$intTimeInfo = 1;
}
}
$intItems = \count($arrTimeData) - 1;
$intUnknown = 0;
$intUpToDate = 0;
foreach ($arrTimeData as $key) {
if ($key == 'unknown') {
$intUnknown++;
}
if (strtotime($arrTimeData['table']) < strtotime($key)) {
$intUpToDate++;
}
}
if ($intUnknown == $intItems) {
$intTimeInfo = 3;
}
if ($intUpToDate == $intItems) {
$intTimeInfo = 0;
}
} else {
$intTimeInfo = 4;
}
return $intReturn;
}
/**
* Get configuration target IDs
* @param array $arrConfigId Configuration target IDs (by reference)
* @return int 0 = successful / 1 = error
*/
public function getConfigTargets(&$arrConfigId)
{
// Variable definition
$arrData = array();
$arrConfigId = array();
$intDataCount = 0;
$intReturn = 1;
// Request target ID
$strSQL = 'SELECT `targets` FROM `tbl_datadomain` WHERE `id`=' .$this->intDomainId;
$booReturn = $this->myDBClass->hasDataArray($strSQL, $arrData, $intDataCount);
if ($booReturn && ($intDataCount != 0)) {
foreach ($arrData as $elem) {
$arrConfigId[] = $elem['targets'];
}
$intReturn = 0;
}
return $intReturn;
}
/**
* Get configuration domain values
* @param int $intConfigId Configuration ID
* @param string $strConfigKey Configuration key
* @param string $strValue Configuration value (by reference)
* @return int 0 = successful / 1 = error
*/
public function getConfigValues($intConfigId, $strConfigKey, &$strValue)
{
// Define variables
$intReturn = 1;
// Read database
$strSQL = 'SELECT `' .$strConfigKey. '` FROM `tbl_configtarget` WHERE `id`=' .$intConfigId;
$strValue = $this->myDBClass->getFieldData($strSQL);
if ($strValue != '') {
$intReturn = 0;
}
return $intReturn;
}
/**
* Get last modification date of a configuration file.
* @param int $intConfigId Configuration ID
* @param string $strFile Configuration file name
* @param string $strBaseDir Base directory with configuration file
* @param int|bool $intFileStamp File timestamp (by reference)
* @param string $strTimeData Human readable string of file time stamp (by reference)
* @return int 0 = successful / 1 = error
*/
public function getFileDate($intConfigId, $strFile, $strBaseDir, &$intFileStamp, &$strTimeData)
{
$strMethod = 1;
$intReturn = 0;
// Get configuration file data
$this->getConfigValues($intConfigId, 'method', $strMethod);
$strTimeData = 'unknown';
$intFileStamp = -1;
// Lokal file system
if (($strMethod == 1) && file_exists($strBaseDir. '/' .$strFile)) {
$intFileStamp = filemtime($strBaseDir. '/' .$strFile);
$strTimeData = date('Y-m-d H:i:s', $intFileStamp);
} elseif ($strMethod == 2) { // FTP file system
// Check connection
$intReturn = $this->getFTPConnection($intConfigId);
if ($intReturn == 0) {
$intFileStamp = ftp_mdtm($this->resConnectId, $strBaseDir . '/' . $strFile);
if ($intFileStamp != -1) {
$strTimeData = date('Y-m-d H:i:s', $intFileStamp);
}
}
} elseif ($strMethod == 3) { // SSH file system
// Check connection
$intReturn = $this->getSSHConnection($intConfigId);
// Check file date
$strFilePath = str_replace('//', '/', $strBaseDir.'/'.$strFile);
$strCommand = 'ls '.$strFilePath;
$arrResult = array();
if (($intReturn == 0) && ($this->sendSSHCommand($strCommand, $arrResult) == 0) &&
isset($arrResult[0]) && ($arrResult[0] == $strFilePath)) {
$arrInfo = ssh2_sftp_stat($this->resSFTP, $strFilePath);
$intFileStamp = $arrInfo['mtime'];
if ($intFileStamp != -1) {
$strTimeData = date('Y-m-d H:i:s', $intFileStamp);
}
}
}
return $intReturn;
}
/**
* Open an FTP connection
* @param int $intConfigID Configuration ID
* @return int 0 = successful / 1 = error
* Status messages are stored in class variables
*/
public function getFTPConnection($intConfigID)
{
// Define variables
$intReturn = 0;
$arrError = array();
// Already connected?
if (empty($this->resConnectId) || !\is_resource($this->resConnectId) || ($this->resConnectType != 'FTP')) {
// Define variables
$booLogin = false;
$this->getConfigValues($intConfigID, 'server', $strServer);
$this->getConfigValues($intConfigID, 'ftp_secure', $intFtpSecure);
// Set up basic connection
$this->resConnectServer = $strServer;
$this->resConnectType = 'FTP';
// Secure FTP?
if ($intFtpSecure == 1) {
$this->resConnectId = ftp_ssl_connect($strServer);
} else {
$this->resConnectId = ftp_connect($strServer);
}
// Login with username and password
if ($this->resConnectId) {
$this->getConfigValues($intConfigID, 'user', $strUser);
$this->getConfigValues($intConfigID, 'password', $strPasswd);
$intErrorReporting = error_reporting();
error_reporting('0');
$booLogin = ftp_login($this->resConnectId, $strUser, $strPasswd);
$arrError = error_get_last();
error_reporting($intErrorReporting);
if ($booLogin == false) {
ftp_close($this->resConnectId);
$this->resConnectServer = '';
$this->resConnectType = 'none';
$this->resConnectId = null;
$intReturn = 1;
} else {
// Change to PASV mode
ftp_pasv($this->resConnectId, true);
}
}
// Check connection
if ((!$this->resConnectId) || (!$booLogin)) {
$this->myDataClass->writeLog(translate('Connection to remote system failed (FTP connection):') .
' ' . $strServer);
$this->processClassMessage(translate('Connection to remote system failed (FTP connection):') .
' <b>' . $strServer . '</b>::', $this->strErrorMessage);
if ($arrError !== null && ($arrError['message'] != '')) {
$this->processClassMessage($arrError['message'] . '::', $this->strErrorMessage);
}
}
}
return $intReturn;
}
/**
* Open an SSH connection
* @param int $intConfigID Configuration ID
* @return int 0 = successful / 1 = error
* Status messages are stored in class variables
*/
public function getSSHConnection($intConfigID)
{
// Define variables
$intReturn = 0;
$strPasswordNote = '';
// Already connected?
if (empty($this->resConnectId) || !\is_resource($this->resConnectId) || ($this->resConnectType != 'SSH')) {
// SSH Possible
if (!\function_exists('ssh2_connect')) {
$this->processClassMessage(translate('SSH module not loaded!'). '::', $this->strErrorMessage);
return 1;
}
// Define variables
$booLogin = false;
$this->getConfigValues($intConfigID, 'server', $strServer);
$this->resConnectServer = $strServer;
$this->resConnectType = 'SSH';
$intErrorReporting = error_reporting();
error_reporting(0);
$this->resConnectId = ssh2_connect($strServer);
$arrError = error_get_last();
error_reporting($intErrorReporting);
// Check connection
if ($this->resConnectId) {
// Login with username and password
$this->getConfigValues($intConfigID, 'user', $strUser);
$this->getConfigValues($intConfigID, 'password', $strPasswd);
$this->getConfigValues($intConfigID, 'ssh_key_path', $strSSHKeyPath);
if ($strSSHKeyPath != '') {
$strPublicKey = str_replace('//', '/', $strSSHKeyPath.'/id_rsa.pub');
$strPrivatKey = str_replace('//', '/', $strSSHKeyPath.'/id_rsa');
// Check if ssh key file are readable
if (!file_exists($strPublicKey) || !is_readable($strPublicKey)) {
$this->myDataClass->writeLog(translate('SSH public key does not exist or is not readable')
. ' ' . $strSSHKeyPath.$strPublicKey);
$this->processClassMessage(translate('SSH public key does not exist or is not readable')
. ' <b>' . $strSSHKeyPath.$strPublicKey. '</b>::', $this->strErrorMessage);
$intReturn = 1;
}
if (!file_exists($strPrivatKey) || !is_readable($strPrivatKey)) {
$this->myDataClass->writeLog(translate('SSH private key does not exist or is not readable')
. ' ' . $strPrivatKey);
$this->processClassMessage(translate('SSH private key does not exist or is not readable'). ' ' .
$strPrivatKey. '::', $this->strErrorMessage);
$intReturn = 1;
}
$intErrorReporting = error_reporting();
error_reporting(0);
if ($strPasswd == '') {
$booLogin = ssh2_auth_pubkey_file(
$this->resConnectId,
$strUser,
$strSSHKeyPath. '/id_rsa.pub',
$strSSHKeyPath. '/id_rsa'
);
} else {
$booLogin = ssh2_auth_pubkey_file(
$this->resConnectId,
$strUser,
$strSSHKeyPath. '/id_rsa.pub',
$strSSHKeyPath. '/id_rsa',
$strPasswd
);
}
$arrError = error_get_last();
error_reporting($intErrorReporting);
} else {
$intErrorReporting = error_reporting();
error_reporting(0);
$booLogin = ssh2_auth_password($this->resConnectId, $strUser, $strPasswd);
$arrError = error_get_last();
$strPasswordNote = 'If you are using ssh2 with user/password - you have to enable ' .
'PasswordAuthentication in your sshd_config';
error_reporting($intErrorReporting);
}
} else {
$this->myDataClass->writeLog(translate('Connection to remote system failed (SSH2 connection):').
' ' .$strServer);
$this->processClassMessage(translate('Connection to remote system failed (SSH2 connection):').
' <b>' .$strServer. '</b>::', $this->strErrorMessage);
if ($arrError['message'] != '') {
$this->processClassMessage($arrError['message']. '::', $this->strErrorMessage);
}
$intReturn = 1;
}
// Check connection
if ((!$this->resConnectId) || (!$booLogin)) {
$this->myDataClass->writeLog(translate('Connection to remote system failed (SSH2 connection):').
' ' .$strServer);
$this->processClassMessage(translate('Connection to remote system failed (SSH2 connection):')
. ' ' .$strServer. '::', $this->strErrorMessage);
if ($arrError['message'] != '') {
$this->processClassMessage($arrError['message']. '::', $this->strErrorMessage);
}
if ($strPasswordNote !== null) {
$this->processClassMessage($strPasswordNote. '::', $this->strErrorMessage);
}
$this->resConnectServer = '';
$this->resConnectType = 'none';
$this->resConnectId = null;
$intReturn = 1;
} else {
// Etablish an SFTP connection ressource
$this->resSFTP = ssh2_sftp($this->resConnectId);
}
}
return $intReturn;
}
/**
* Sends a command via SSH and stores the result in an array
* @param string $strCommand Command string
* @param array $arrResult Output as array (by reference)
* @param int $intLines Maximal length of output to read
* @return int 0 = successful / 1 = error
*/
public function sendSSHCommand($strCommand, &$arrResult, $intLines = 100)
{
// Define variables
$intCount1 = 0; // empty lines
$intCount2 = 0; // data lines
$booBreak = false;
$this->getConfigTargets($arrConfigSet);
// Check connection
$intReturn = $this->getSSHConnection($arrConfigSet[0]);
if (\is_resource($this->resConnectId)) {
// Send command
$resStream = ssh2_exec($this->resConnectId, $strCommand.'; echo __END__');
if ($resStream) {
// read result
stream_set_blocking($resStream, true);
stream_set_timeout($resStream, 2);
do {
$strLine = stream_get_line($resStream, 1024, "\n");
if ($strLine == '') {
$intCount1++;
} elseif (substr_count($strLine, '__END__') != 1) {
$arrResult[] = $strLine;
$intReturn = 0;
} elseif (substr_count($strLine, '__END__') == 1) {
$booBreak = true;
}
$intCount2++;
$arrStatus = stream_get_meta_data($resStream);
} while ($resStream && !feof($resStream) && ($intCount1 <= 10) && ($intCount2 <= $intLines) &&
($arrStatus['timed_out'] != true) && $booBreak == false);
fclose($resStream);
// Close SSH connection because of timing problems
unset($this->resConnectId);
//sleep(1);
}
}
return $intReturn;
}
/**
* Merge message strings and check for duplicate messages
* @param string $strNewMessage New message to add
* @param string $strOldMessage Modified message string (by reference)
*/
public function processClassMessage($strNewMessage, &$strOldMessage)
{
$strNewMessage = str_replace('::::', '::', $strNewMessage);
if (($strOldMessage != '') && ($strNewMessage != '') && (substr_count($strOldMessage, $strNewMessage) == 0)) {
$strOldMessage .= $strNewMessage;
} elseif ($strOldMessage == '') {
$strOldMessage .= $strNewMessage;
}
}
/**
* Get configuration target IDs
* @param array $arrConfigId Configuration target IDs (by reference)
* @return int 0 = successful / 1 = error
*/
public function getConfigSets(&$arrConfigId)
{
// Variable definition
$arrData = array();
$arrConfigId = array();
$intDataCount = 0;
$intReturn = 1;
// Request target ID
$strSQL = 'SELECT `targets` FROM `tbl_datadomain` WHERE `id`=' .$this->intDomainId;
$booReturn = $this->myDBClass->hasDataArray($strSQL, $arrData, $intDataCount);
if ($booReturn && ($intDataCount != 0)) {
foreach ($arrData as $elem) {
$arrConfigId[] = $elem['targets'];
}
$intReturn = 0;
}
return $intReturn;
}
/**
* Moves an existing configuration file to the backup directory and removes then the original file
* @param string $strType Type of the configuration file
* @param string $strName Name of the configuration file
* @param int $intConfigID Configuration target ID
* @return int 0 = successful / 1 = error
* Status message is stored in message class variables
*/
public function moveFile($strType, $strName, $intConfigID)
{
// Variable definitions
$strConfigDir = '';
$strBackupDir = '';
$intReturn = 0;
// Get directories
switch ($strType) {
case 'host':
$this->getConfigData($intConfigID, 'hostconfig', $strConfigDir);
$this->getConfigData($intConfigID, 'hostbackup', $strBackupDir);
break;
case 'service':
$this->getConfigData($intConfigID, 'serviceconfig', $strConfigDir);
$this->getConfigData($intConfigID, 'servicebackup', $strBackupDir);
break;
case 'basic':
$this->getConfigData($intConfigID, 'basedir', $strConfigDir);
$this->getConfigData($intConfigID, 'backupdir', $strBackupDir);
break;
case 'nagiosbasic':
$this->getConfigData($intConfigID, 'nagiosbasedir', $strConfigDir);
$this->getConfigData($intConfigID, 'backupdir', $strBackupDir);
break;
default:
$intReturn = 1;
}
if ($intReturn == 0) {
// Variable definition
$intMethod = 1;
$strDate = date('YmdHis');
$strSourceFile = $strConfigDir. '/' .$strName;
$strDestinationFile = $strBackupDir. '/' .$strName. '_old_' .$strDate;
$booRetVal = false;
// Get connection method
$this->getConfigData($intConfigID, 'method', $intMethod);
// Local file system
if ($intMethod == 1) {
// Save configuration file
if (file_exists($strSourceFile)) {
if (is_writable($strBackupDir) && is_writable($strConfigDir)) {
copy($strSourceFile, $strDestinationFile);
unlink($strSourceFile);
} else {
$this->processClassMessage(translate('Cannot backup the old file because the permissions are '
.'wrong - destination file: ').$strDestinationFile. '::', $this->strErrorMessage);
$intReturn = 1;
}
} else {
$this->processClassMessage(translate('Cannot backup the old file because the source file is '
. 'missing - source file: ') . $strSourceFile . '::', $this->strErrorMessage);
$intReturn = 1;
}
} elseif ($intMethod == 2) { // Remote file (FTP)
// Check connection
$intReturn = $this->getFTPConnection($intConfigID);
if ($intReturn == 0) {
$strSourceFile = str_replace('//', '/', $strSourceFile);
$strDestinationFile = str_replace('//', '/', $strDestinationFile);
// Save configuration file
$intFileStamp = ftp_mdtm($this->resConnectId, $strSourceFile);
if ($intFileStamp > -1) {
$intErrorReporting = error_reporting();
error_reporting(0);
$booRetVal = ftp_rename($this->resConnectId, $strSourceFile, $strDestinationFile);
error_reporting($intErrorReporting);
} else {
$this->processClassMessage(translate('Cannot backup the old file because the source file is '
.'missing (remote FTP) - source file: '). $strSourceFile. '::', $this->strErrorMessage);
$intReturn = 1;
}
}
if (($booRetVal == false) && ($intReturn == 0)) {
$this->processClassMessage(translate('Cannot backup the old file because the permissions are '
.'wrong (remote FTP) - destination file: ').$strDestinationFile. '::', $this->strErrorMessage);
$intReturn = 1;
}
} elseif ($intMethod == 3) { // Remote file (SFTP)
// Check connection
$intReturn = $this->getSSHConnection($intConfigID);
// Save configuration file
$arrResult = array();
$strSourceFile = str_replace('//', '/', $strSourceFile);
$strDestinationFile = str_replace('//', '/', $strDestinationFile);
$strCommand = 'ls '.$strSourceFile;
if (($intReturn == 0) && ($this->sendSSHCommand($strCommand, $arrResult) == 0)) {
if (isset($arrResult[0]) && $arrResult[0] == $strSourceFile) {
$arrInfo = ssh2_sftp_stat($this->resSFTP, $strSourceFile);
if ($arrInfo['mtime'] > -1) {
$booRetVal = ssh2_sftp_rename($this->resSFTP, $strSourceFile, $strDestinationFile);
}
} else {
$this->processClassMessage(translate('Cannot backup the old file because the source file is '
.'missing (remote SFTP) - source file: '). $strSourceFile. '::', $this->strErrorMessage);
$intReturn = 1;
}
}
if (($booRetVal == false) && ($intReturn == 0)) {
$this->processClassMessage(translate('Cannot backup the old file because the permissions are '
.'wrong (remote SFTP) - destination file: ').$strDestinationFile. '::', $this->strErrorMessage);
$intReturn = 1;
}
}
}
return $intReturn;
}
/**
* Remove a file
* @param string $strFileName Filename including path to remove
* @param int $intConfigID Configuration target ID
* @return int 0 = successful / 1 = error
* Status message is stored in message class variables
*/
public function removeFile($strFileName, $intConfigID)
{
// Variable definitions
$intMethod = 1;
$intReturn = 0;
$booRetVal = false;
// Get connection method
$this->getConfigData($intConfigID, 'method', $intMethod);
// Local file system
if ($intMethod == 1) {
// Save configuration file
if (file_exists($strFileName)) {
if (is_writable($strFileName)) {
unlink($strFileName);
} else {
$this->processClassMessage(translate('Cannot delete the file (wrong permissions)!').'::'.
$strFileName. '::', $this->strErrorMessage);
$intReturn = 1;
}
} else {
$this->processClassMessage(translate('Cannot delete the file (file does not exist)!').'::'.
$strFileName. '::', $this->strErrorMessage);
$intReturn = 1;
}
} elseif ($intMethod == 2) { // Remote file (FTP)
// Check connection
$intReturn = $this->getFTPConnection($intConfigID);
if ($intReturn == 0) {
// Save configuration file
$intFileStamp = ftp_mdtm($this->resConnectId, $strFileName);
if ($intFileStamp > -1) {
$intErrorReporting = error_reporting();
error_reporting(0);
$booRetVal = ftp_delete($this->resConnectId, $strFileName);
error_reporting($intErrorReporting);
} else {
$this->processClassMessage(translate('Cannot delete file because it does not exists (remote '
. 'FTP)!'). '::', $this->strErrorMessage);
$intReturn = 1;
}
}
if ($booRetVal == false) {
$this->processClassMessage(translate('Cannot delete file because the permissions are incorrect '
. '(remote FTP)!'). '::', $this->strErrorMessage);
$intReturn = 1;
}
} elseif ($intMethod == 3) { // Remote file (SFTP)
// Check connection
$intReturn = $this->getSSHConnection($intConfigID);
// Save configuration file
if (($intReturn == 0) && ($this->sendSSHCommand('ls '.$strFileName, $arrResult) == 0)) {
if (isset($arrResult[0])) {
$booRetVal = ssh2_sftp_unlink($this->resSFTP, $strFileName);
} else {
$this->processClassMessage(translate('Cannot delete file because it does not exists (remote '
. 'SSH/SFTP)!'). '::', $this->strErrorMessage);
$intReturn = 1;
}
}
if (($intReturn == 0) && ($booRetVal == false)) {
$this->processClassMessage(translate('Cannot delete file because the permissions are incorrect '
. '(remote SSH/SFTP)!'). '::', $this->strErrorMessage);
$intReturn = 1;
}
}
return $intReturn;
}
/**
* Get configuration domain parameters
* @param int $intConfigId Configuration ID
* @param string $strConfigItem Configuration key
* @param string $strValue Configuration value (by reference)
* @return int 0 = successful / 1 = error
*/
public function getConfigData($intConfigId, $strConfigItem, &$strValue)
{
$intReturn = 1;
$strSQL = 'SELECT `' .$strConfigItem. '` FROM `tbl_configtarget` WHERE `id` = ' .$intConfigId;
$strValue = $this->myDBClass->getFieldData($strSQL);
if ($strValue != '') {
$intReturn = 0;
}
return $intReturn;
}
/**
* Check a directory for write access
* @param string $strPath Physical path
* @return int 0 = successful / 1 = error
*/
public function isDirWriteable($strPath)
{
// Define variables
$intReturnFile = 1;
$intReturnDir = 1;
$intReturn = 1;
// Is input path a file?
if (file_exists($strPath) && is_file($strPath)) {
$resFile = fopen($strPath, 'ab');
if ($resFile) {
$intReturnFile = 0;
}
} else {
$intReturnFile = 0;
}
if (is_file($strPath)) {
$strDirectory = \dirname($strPath);
} else {
$strDirectory = $strPath;
}
$strFile = $strDirectory.'/'.uniqid(mt_rand(), true).'.tmp';
// Check writing in directory directly
if (is_dir($strDirectory) && is_writable($strDirectory)) {
$resFile = fopen($strFile, 'wb');
if ($resFile) {
$intReturnDir = 0;
unlink($strFile);
}
} else {
$intReturnDir = 0;
}
if (($intReturnDir == 0) && ($intReturnFile == 0)) {
$intReturn = 0;
}
return $intReturn;
}
/**
* Copy a remote file
* @param string $strFileRemote Remote file name
* @param int $intConfigID Configuration target id
* @param string $strFileLocal Local file name
* @param int $intDirection 0 = from remote to local / 1 = from local to remote
* @return int 0 = successful / 1 = error
* Status message is stored in message class variables
*/
public function remoteFileCopy($strFileRemote, $intConfigID, $strFileLocal, $intDirection = 0)
{
// Variable definitions
$intMethod = 3;
$intReturn = 0;
$arrTemp = array();
// Get method
$this->getConfigData($intConfigID, 'method', $intMethod);
if ($intMethod == 2) {
// Check connection
$intReturn = $this->getFTPConnection($intConfigID);
if (($intReturn == 0) && ($intDirection == 0)) {
$intErrorReporting = error_reporting();
error_reporting(0);
if (!ftp_get($this->resConnectId, $strFileLocal, $strFileRemote, FTP_ASCII)) {
$this->processClassMessage(translate('Cannot get the remote file (it does not exist or is not '
. 'readable) - remote file: '). $strFileRemote. '::', $this->strErrorMessage);
$intReturn = 1;
}
error_reporting($intErrorReporting);
} elseif (($intReturn == 0) && ($intDirection == 1)) {
$intErrorReporting = error_reporting();
error_reporting(0);
if (!ftp_put($this->resConnectId, $strFileRemote, $strFileLocal, FTP_ASCII)) {
$this->processClassMessage(translate('Cannot write the remote file (remote file is not writeable)'
. '- remote file: ').$strFileRemote. '::', $this->strErrorMessage);
$intReturn = 1;
}
error_reporting($intErrorReporting);
}
ftp_close($this->resConnectId);
} elseif ($intMethod == 3) { // Remote file (SFTP)
$intReturn = $this->getSSHConnection($intConfigID);
if (($intReturn == 0) && ($intDirection == 0)) {
// Copy file
$intErrorReporting = error_reporting();
error_reporting(0);
if (!ssh2_scp_recv($this->resConnectId, $strFileRemote, $strFileLocal)) {
if ($this->sendSSHCommand('ls ' . $strFileRemote, $arrTemp) != 0) {
$this->processClassMessage(translate('Cannot get the remote file (it does not exist or is not '
. 'readable) - remote file: ') .$strFileRemote. '::', $this->strErrorMessage);
} else {
$this->processClassMessage(translate('Remote file is not readable - remote file: ')
. $strFileRemote. '::', $this->strErrorMessage);
}
$intReturn = 1;
}
error_reporting($intErrorReporting);
} elseif (($intReturn == 0) && ($intDirection == 1)) {
if (file_exists($strFileLocal) && is_readable($strFileLocal)) {
$intErrorReporting = error_reporting();
error_reporting(0);
if (!ssh2_scp_send($this->resConnectId, $strFileLocal, $strFileRemote, 0644)) {
$this->processClassMessage(translate('Cannot write a remote file (remote file is not writeable)'
.' - remote file: '). $strFileRemote . '::', $this->strErrorMessage);
$intReturn = 1;
}
error_reporting($intErrorReporting);
} else {
$this->processClassMessage(translate('Cannot copy a local file to remote because the local file '.
'does not exist or is not readable - local file: ').
$strFileLocal . '::', $this->strErrorMessage);
$intReturn = 1;
}
}
}
return $intReturn;
}
/**
* Add files of a given directory to an array
* @param string $strSourceDir Source directory
* @param string $strIncPattern Include file pattern
* @param string $strExcPattern Exclude file pattern
* @param array $arrOutput Output array (by reference)
* @param string $strErrorMessage Error messages (by reference)
*/
public function storeDirToArray($strSourceDir, $strIncPattern, $strExcPattern, &$arrOutput, &$strErrorMessage)
{
// Define variables
$arrDir = array();
while (substr($strSourceDir, -1) == '/' or substr($strSourceDir, -1) == "\\") {
$strSourceDir = substr($strSourceDir, 0, -1);
}
$resHandle = opendir($strSourceDir);
if ($resHandle === false) {
if ($this->intDomainId != 0) {
$strErrorMessage .= translate('Could not open directory'). ': ' .$strSourceDir;
}
} else {
$booBreak = true;
while ($booBreak) {
if (!$arrDir[] = readdir($resHandle)) {
$booBreak = false;
}
}
closedir($resHandle);
sort($arrDir);
/** @var string $file */
foreach ($arrDir as $file) {
/** @noinspection StrlenInEmptyStringCheckContextInspection */
if (!preg_match("/^\.{1,2}/", $file) && \strlen($file)) {
if (is_dir($strSourceDir. '/' .$file)) {
$this->storeDirToArray(
$strSourceDir. '/' .$file,
$strIncPattern,
$strExcPattern,
$arrOutput,
$strErrorMessage
);
} else {
if (preg_match('/' .$strIncPattern. '/', $file) && (($strExcPattern == '') ||
!preg_match('/' .$strExcPattern. '/', $file))) {
if (0 === stripos(PHP_OS, 'WIN')) {
$strSourceDir=str_replace('/', "\\", $strSourceDir);
$arrOutput [] = $strSourceDir."\\".$file;
} else {
$arrOutput [] = $strSourceDir. '/' .$file;
}
}
}
}
}
}
}
/**
* Determines the dates of the last data table change and the last modification to the configuration files
* @param string $strTableName Name of the data table
* @param array $arrTimeData Array with time data of table and all config files
* @param string $strCheckConfig Information string (text message)
* @return int 0 = successful / 1 = error
* Status message is stored in message class variables
*/
public function lastModifiedFile($strTableName, &$arrTimeData, &$strCheckConfig)
{
// Variable definitions
$intEnableCommon = 0;
$arrDataset = array();
$strFileName = '';
$strCheckConfig = '';
$intReturn = 0;
// Get configuration filename based on table name
$arrConfigData = $this->getConfData();
if (isset($arrConfigData[$strTableName])) {
$strFileName = $arrConfigData[$strTableName]['filename'];
} else {
$intReturn = 1;
}
// Get table times
$arrTimeData = array();
$arrTimeData['table'] = 'unknown';
// Clear status cache
clearstatcache();
$intRetVal1 = $this->getDomainData('enable_common', $intEnableCommon);
// Get last change of date table
if ($intRetVal1 == 0) {
$strSQLAdd = '';
if ($intEnableCommon == 1) {
$strSQLAdd = 'OR `domainId`=0';
}
$strSQL = 'SELECT `updateTime` FROM `tbl_tablestatus` '
. 'WHERE (`domainId`=' .$this->intDomainId." $strSQLAdd) AND `tableName`='".$strTableName."' "
. 'ORDER BY `updateTime` DESC LIMIT 1';
$booReturn = $this->myDBClass->hasSingleDataset($strSQL, $arrDataset);
if ($booReturn && isset($arrDataset['updateTime'])) {
$arrTimeData['table'] = $arrDataset['updateTime'];
} else {
$strSQL = 'SELECT `last_modified` FROM `' .$strTableName. '` '
. 'WHERE `config_id`=' .$this->intDomainId. ' ORDER BY `last_modified` DESC LIMIT 1';
$booReturn = $this->myDBClass->hasSingleDataset($strSQL, $arrDataset);
if (($booReturn == true) && isset($arrDataset['last_modified'])) {
$arrTimeData['table'] = $arrDataset['last_modified'];
}
}
}
// Get config sets
$arrConfigId = array();
$strTarget = '';
$strBaseDir = '';
$intFileStampTemp = 0;
$intRetVal2 = $this->getConfigSets($arrConfigId);
if ($intRetVal2 == 0) {
foreach ($arrConfigId as $intConfigId) {
// Get configuration file data
$this->getConfigData($intConfigId, 'target', $strTarget);
$this->getConfigData($intConfigId, 'basedir', $strBaseDir);
// Get time data
$intReturn = $this->getFileDate(
$intConfigId,
$strFileName,
$strBaseDir,
$intFileStampTemp,
$arrTimeData[$strTarget]
);
if ($intFileStampTemp != 0 && strtotime($arrTimeData['table']) > $intFileStampTemp) {
$strCheckConfig = translate('Warning: configuration file is out of date!');
}
if ($arrTimeData[$strTarget] == 'unknown') {
$strCheckConfig = translate('Warning: configuration file is out of date!');
}
}
} else {
$strCheckConfig = translate('Warning: no configuration target defined!');
}
return $intReturn;
}
/**
* Writes a configuration file including all datasets of a configuration table or returns the output as a text
* file for download. (Public master function)
* @param string $strTableName Table name
* @param int $intMode 0 = Write file to filesystem
* 1 = Return Textfile for download test
* @return int 0 = successful / 1 = error
* Status message is stored in message class variables
*/
public function createConfig($strTableName, $intMode = 0)
{
// Define Variables
$intReturn = 0;
// Do not create configs in common domain
if ($this->intDomainId == 0) {
$this->processClassMessage(translate('It is not possible to write config files directly from the common '
. 'domain!'). '::', $this->strErrorMessage);
$intReturn = 1;
}
if ($intReturn == 0) {
// Get configuration targets
$this->getConfigSets($arrConfigID);
if (($arrConfigID != 1) && \is_array($arrConfigID)) {
foreach ($arrConfigID as $intConfigID) {
$intReturn = $this->writeConfTemplate($intConfigID, $strTableName, $intMode);
}
} else {
$this->processClassMessage(translate('Warning: no configuration target defined!').
'::', $this->strErrorMessage);
$intReturn = 1;
}
}
return $intReturn;
}
/**
* Writes a configuration file including one single datasets of a configuration table or returns the output as
* a text file for download.
* @param string $strTableName Table name
* @param int $intDbId Data ID
* @param int $intMode 0 = Write file to filesystem
* 1 = Return Textfile for download test
* @return int 0 = successful / 1 = error
* Status message is stored in message class variables
*/
public function createConfigSingle($strTableName, $intDbId = 0, $intMode = 0)
{
// Define Variables
$arrData = array();
$intDataCount = 0;
$setEnableCommon = 0;
$intReturn = 0;
$strDomainWhere = ' (`config_id`=' .$this->intDomainId. ') ';
// Read some settings and informations
$this->getDomainData('enable_common', $setEnableCommon);
// Variable rewritting
if ($setEnableCommon != 0) {
$strDomainWhere = str_replace(')', ' OR `config_id`=0)', $strDomainWhere);
}
// Do not create configs in common domain
if ($this->intDomainId == 0) {
$this->processClassMessage(translate('It is not possible to write config files directly from the common '
. 'domain!'). '::', $this->strErrorMessage);
$intReturn = 1;
}
if ($intReturn == 0) {
if ($intDbId == 0) {
$strSQL = 'SELECT * FROM `' .$strTableName."` WHERE $strDomainWhere AND `active`='1' ORDER BY `id`";
} else {
$strSQL = 'SELECT * FROM `' .$strTableName."` WHERE $strDomainWhere AND `active`='1' AND `id`=$intDbId";
}
$booReturn = $this->myDBClass->hasDataArray($strSQL, $arrData, $intDataCount);
if (($booReturn != false) && ($intDataCount != 0)) {
/** @noinspection ForeachInvariantsInspection */
for ($i = 0; $i < $intDataCount; $i++) {
// Process form POST variable
$strChbName = 'chbId_' .$arrData[$i]['id'];
// Check if this POST variable exists or the data ID parameter matches
if ((($intDbId != 0) && ($intDbId == $arrData[$i]['id'])) ||
(filter_input(INPUT_POST, $strChbName) !== null)) {
// Get configuration targets
$this->getConfigSets($arrConfigID);
if (($arrConfigID != 1) && \is_array($arrConfigID)) {
foreach ($arrConfigID as $intConfigID) {
$intReturn = $this->writeConfTemplate(
$intConfigID,
$strTableName,
$intMode,
$arrData,
$i
);
}
} else {
$this->processClassMessage(translate('Warning: no configuration target defined!').
'::', $this->strErrorMessage);
$intReturn = 1;
}
}
}
} else {
$this->myDataClass->writeLog(translate('Writing of the configuration failed - no dataset or not '
. 'activated dataset found'));
$this->processClassMessage(translate('Writing of the configuration failed - no dataset or not '
. 'activated dataset found'). '::', $this->strErrorMessage);
$intReturn = 1;
}
}
return $intReturn;
}
// PRIVATE functions
/**
* Determines the configuration data for each database table
* @return array filename (configuration file name)
* order_field (database order field)
*/
public function getConfData()
{
$arrConfData['tbl_timeperiod'] = array('filename' => 'timeperiods.cfg',
'order_field' => 'timeperiod_name');
$arrConfData['tbl_command'] = array('filename' => 'commands.cfg',
'order_field' => 'command_name');
$arrConfData['tbl_contact'] = array('filename' => 'contacts.cfg',
'order_field' => 'contact_name');
$arrConfData['tbl_contacttemplate'] = array('filename' => 'contacttemplates.cfg',
'order_field' => 'template_name');
$arrConfData['tbl_contactgroup'] = array('filename' => 'contactgroups.cfg',
'order_field' => 'contactgroup_name');
$arrConfData['tbl_hosttemplate'] = array('filename' => 'hosttemplates.cfg',
'order_field' => 'template_name');
$arrConfData['tbl_servicetemplate'] = array('filename' => 'servicetemplates.cfg',
'order_field' => 'template_name');
$arrConfData['tbl_hostgroup'] = array('filename' => 'hostgroups.cfg',
'order_field' => 'hostgroup_name');
$arrConfData['tbl_servicegroup'] = array('filename' => 'servicegroups.cfg',
'order_field' => 'servicegroup_name');
$arrConfData['tbl_hostdependency'] = array('filename' => 'hostdependencies.cfg',
'order_field' => 'dependent_host_name');
$arrConfData['tbl_servicedependency'] = array('filename' => 'servicedependencies.cfg',
'order_field' => 'config_name');
$arrConfData['tbl_hostescalation'] = array('filename' => 'hostescalations.cfg',
'order_field' => 'host_name`,`hostgroup_name');
$arrConfData['tbl_serviceescalation'] = array('filename' => 'serviceescalations.cfg',
'order_field' => 'config_name');
$arrConfData['tbl_hostextinfo'] = array('filename' => 'hostextinfo.cfg',
'order_field' => 'host_name');
$arrConfData['tbl_serviceextinfo'] = array('filename' => 'serviceextinfo.cfg',
'order_field' => 'host_name');
return $arrConfData;
}
/**
* Writes a configuration file including all datasets of a configuration table or returns the output as a text
* file for download. (Private worker function)
* @param int $intConfigID Configuration target ID
* @param string $strTableName Table name
* @param int $intMode 0 = Write file to filesystem
* 1 = Return Textfile for download test
* @param array $arrTableData Dataset array for host and services only
* @param int $intID Key for dataset array
* @return int 0 = successful / 1 = error
* Status message is stored in message class variables
*/
/** @noinspection ArrayTypeOfParameterByDefaultValueInspection */
private function writeConfTemplate($intConfigID, $strTableName, $intMode, $arrTableData = array(), $intID = 0)
{
// Variable definitions
$strSQL = '';
$strOrderField = '';
$strFileString = '';
$arrTplOptions = array('use_preg' => false);
$strDomainWhere = ' (`config_id`=' . $this->intDomainId . ') ';
$intType = 0;
$intReturn = 0;
// Read some settings and informations
$this->getConfigData($intConfigID, 'utf8_decode', $setUTF8Decode);
$this->getDomainData('enable_common', $setEnableCommon);
$this->getConfigData($intConfigID, 'version', $intNagiosVersion);
$arrConfigData = $this->getConfData();
if (isset($arrConfigData[$strTableName])) {
$strFileString = str_replace('.cfg', '', $arrConfigData[$strTableName]['filename']);
$strOrderField = $arrConfigData[$strTableName]['order_field'];
}
// Variable rewritting
if ($setEnableCommon != 0) {
$strDomainWhere = str_replace(')', ' OR `config_id`=0)', $strDomainWhere);
}
// Special processing for table host and service
$setTemplate = $strFileString. '.tpl.dat';
if (($strTableName == 'tbl_host') || ($strTableName == 'tbl_service')) {
// Define variable names based on table name
switch ($strTableName) {
case 'tbl_host':
$strFileString = $arrTableData[$intID]['host_name'];
$intDomainId = $arrTableData[$intID]['config_id'];
$setTemplate = 'hosts.tpl.dat';
$intType = 1;
$strSQL = 'SELECT * FROM `' . $strTableName . "` WHERE `host_name`='$strFileString' "
. "AND `active`='1' AND `config_id`=$intDomainId";
break;
case 'tbl_service':
$strFileString = $arrTableData[$intID]['config_name'];
$intDomainId = $arrTableData[$intID]['config_id'];
$setTemplate = 'services.tpl.dat';
$intType = 2;
$strSQL = 'SELECT * FROM `' . $strTableName . "` WHERE `config_name`='$strFileString' "
. "AND `active`='1' AND `config_id`=$intDomainId ORDER BY `service_description`";
break;
}
} else {
$strSQL = 'SELECT * FROM `' .$strTableName."` WHERE $strDomainWhere AND `active`='1' ".
'ORDER BY `' .$strOrderField. '`';
}
$strFile = $strFileString. '.cfg';
// Load configuration template file
$tplConf = new \HTML_Template_IT($this->arrSettings['path']['base_path']. '/templates/files/');
$tplConf->loadTemplatefile($setTemplate, true, true);
$tplConf->setOptions($arrTplOptions);
$tplConf->setVariable('CREATE_DATE', date('Y-m-d H:i:s'));
$tplConf->setVariable('NAGIOS_QL_VERSION', $this->arrSettings['db']['version']);
$tplConf->setVariable('VERSION', $this->getVersionString($intConfigID));
// Write data from configuration table
$booReturn = $this->myDBClass->hasDataArray($strSQL, $arrData, $intDataCount);
if ($booReturn && ($intDataCount != 0) && ($strFileString != '')) {
// Process every data set
/** @noinspection ForeachInvariantsInspection */
for ($i = 0; $i < $intDataCount; $i++) {
$intDataId = 0;
/** @noinspection ForeachSourceInspection */
foreach ($arrData[$i] as $key => $value) {
if ($key == 'id') {
$intDataId = $value;
}
if ($key == 'config_name') {
$key = '#NAGIOSQL_CONFIG_NAME';
}
// UTF8 decoded vaules
if ($setUTF8Decode == 1) {
$value = utf8_decode($value);
}
// Pass special fields (NagiosQL data fields not used by Nagios itselves)
if ($this->skipEntries($strTableName, $intNagiosVersion, $key, $value) == 1) {
continue;
}
// Get relation data
$intSkip = $this->getRelationData($strTableName, $tplConf, $arrData[$i], $key, $value);
// Rename field names
$this->renameFields($strTableName, $intConfigID, $intDataId, $key, $value, $intSkip);
// Inset data field
if ($intSkip != 1) {
// Insert fill spaces
$strFillLen = (30- \strlen($key));
$strSpace = ' ';
for ($f = 0; $f < $strFillLen; $f++) {
$strSpace .= ' ';
}
// Write key and value to template
$tplConf->setVariable('ITEM_TITLE', $key.$strSpace);
// Short values
if (($intNagiosVersion != 3) || (\strlen($value) < 800)) {
$tplConf->setVariable('ITEM_VALUE', $value);
$tplConf->parse('configline');
} else { // Long values
$arrValueTemp = explode(',', $value);
$strValueNew = '';
$intArrCount = \count($arrValueTemp);
$intCounter = 0;
$strSpace = ' ';
for ($f = 0; $f < 30; $f++) {
$strSpace .= ' ';
}
foreach ($arrValueTemp as $elem) {
if (\strlen($strValueNew) < 800) {
$strValueNew .= $elem. ',';
} else {
if (substr($strValueNew, -1) == ',') {
$strValueNew = substr($strValueNew, 0, -1);
}
if ($intCounter < $intArrCount) {
$strValueNew .= ",\\";
$tplConf->setVariable('ITEM_VALUE', $strValueNew);
$tplConf->parse('configline');
$tplConf->setVariable('ITEM_TITLE', $strSpace);
} else {
$tplConf->setVariable('ITEM_VALUE', $strValueNew);
$tplConf->parse('configline');
$tplConf->setVariable('ITEM_TITLE', $strSpace);
}
$strValueNew = $elem. ',';
}
$intCounter++;
}
if ($strValueNew != '') {
if (substr($strValueNew, -1) == ',') {
$strValueNew = substr($strValueNew, 0, -1);
}
$tplConf->setVariable('ITEM_VALUE', $strValueNew);
$tplConf->parse('configline');
}
}
}
}
// Special processing for time periods
if ($strTableName == 'tbl_timeperiod') {
$arrDataTime = array();
$strSQLTime = 'SELECT `definition`, `range` '
. 'FROM `tbl_timedefinition` WHERE `tipId` = ' .$arrData[$i]['id'];
$booReturn = $this->myDBClass->hasDataArray($strSQLTime, $arrDataTime, $intDataCountTime);
if ($booReturn && $intDataCountTime != 0) {
foreach ($arrDataTime as $data) {
// Skip other values than weekdays in nagios version below 3
if ($intNagiosVersion < 3) {
$arrWeekdays = array('monday','tuesday','wednesday','thursday','friday','saturday',
'sunday');
if (!\in_array($data['definition'], $arrWeekdays, true)) {
continue;
}
}
// Insert fill spaces
$strFillLen = (30- \strlen($data['definition']));
$strSpace = ' ';
for ($f = 0; $f < $strFillLen; $f++) {
$strSpace .= ' ';
}
// Write key and value
$tplConf->setVariable('ITEM_TITLE', $data['definition'].$strSpace);
$tplConf->setVariable('ITEM_VALUE', $data['range']);
$tplConf->parse('configline');
}
}
}
// Write configuration set
$tplConf->parse('configset');
}
} elseif ($booReturn && ($intDataCount == 0) && ($strFileString != '')) {
$this->processClassMessage(translate('Error while selecting data from database:')
. '::', $this->strErrorMessage);
$this->processClassMessage($this->myDBClass->strErrorMessage, $this->strErrorMessage);
$intReturn = 1;
} else {
$this->myDataClass->writeLog(translate('Writing of the configuration failed - no dataset '
. 'or not activated dataset found'));
$this->processClassMessage(translate('Writing of the configuration failed - no dataset '
. 'or not activated dataset found'). '::', $this->strErrorMessage);
$intReturn = 1;
}
if ($intMode == 0) {
$intReturn = $this->getConfigFile($strFile, $intConfigID, $intType, $resCfgFile, $strCfgFile);
if ($intReturn == 0) {
$tplConf->parse();
$strContent = $tplConf->get();
$intReturn = $this->writeConfigFile(
$strContent,
$strFile,
$intType,
$intConfigID,
$resCfgFile,
$strCfgFile
);
}
} elseif ($intMode == 1) {
$tplConf->show();
}
return $intReturn;
}
/**
* Get Nagios version string
* @param int $intConfigID Configuration target ID
* @return string Version string
*/
private function getVersionString($intConfigID)
{
$arrVersion = array(
'Nagios 2.x config file',
'Nagios 2.9 config file',
'Nagios 3.x config file',
'Nagios 4.x config file'
);
$this->getConfigData($intConfigID, 'version', $intVersion);
if (($intVersion >= 1) && ($intVersion <= \count($arrVersion))) {
$strVersion = $arrVersion[$intVersion - 1];
} else {
$strVersion = '';
}
return $strVersion;
}
/**
* Skip database values based on Nagios version
* @param string $strTableName Table name
* @param int $intVersionValue Nagios version value
* @param string $key Data key
* @param string $value Data value
* @return int
*/
private function skipEntries($strTableName, $intVersionValue, $key, &$value)
{
// Define variables
$arrOption = array();
$intReturn = 0;
// Skip common fields
$strSpecial = 'id,active,last_modified,access_rights,access_group,config_id,template,nodelete,command_type,';
$strSpecial .= 'import_hash';
// Skip fields of special tables
if ($strTableName == 'tbl_hosttemplate') {
$strSpecial .= ',parents_tploptions,hostgroups_tploptions,contacts_tploptions';
$strSpecial .= ',contact_groups_tploptions,use_template_tploptions';
}
if ($strTableName == 'tbl_servicetemplate') {
$strSpecial .= ',host_name_tploptions,hostgroup_name_tploptions,parents_tploptions,contacts_tploptions';
$strSpecial .= ',servicegroups_tploptions,contact_groups_tploptions,use_template_tploptions';
}
if ($strTableName == 'tbl_contact') {
$strSpecial .= ',use_template_tploptions,contactgroups_tploptions';
$strSpecial .= ',host_notification_commands_tploptions,service_notification_commands_tploptions';
}
if ($strTableName == 'tbl_contacttemplate') {
$strSpecial .= ',use_template_tploptions,contactgroups_tploptions';
$strSpecial .= ',host_notification_commands_tploptions,service_notification_commands_tploptions';
}
if ($strTableName == 'tbl_host') {
$strSpecial .= ',parents_tploptions,hostgroups_tploptions,contacts_tploptions';
$strSpecial .= ',contact_groups_tploptions,use_template_tploptions';
}
if ($strTableName == 'tbl_service') {
$strSpecial .= ',host_name_tploptions,hostgroup_name_tploptions,parents_tploptions';
$strSpecial .= ',servicegroups_tploptions,contacts_tploptions,contact_groups_tploptions';
$strSpecial .= ',use_template_tploptions';
}
// Pass fields based on nagios version lower than 3.x
if ($intVersionValue < 3) {
if ($strTableName == 'tbl_timeperiod') {
$strSpecial .= ',use_template,exclude,name';
}
if (($strTableName == 'tbl_contact') || ($strTableName == 'tbl_contacttemplate')) {
$strSpecial .= ',host_notifications_enabled,service_notifications_enabled,can_submit_commands';
$strSpecial .= ',retain_status_information,retain_nonstatus_information';
$arrOption['host_notification_options'] = ',s';
$arrOption['service_notification_options'] = ',s';
}
if ($strTableName == 'tbl_contactgroup') {
$strSpecial .= ',contactgroup_members';
}
if ($strTableName == 'tbl_hostgroup') {
$strSpecial .= ',hostgroup_members,notes,notes_url,action_url';
}
if ($strTableName == 'tbl_servicegroup') {
$strSpecial .= ',servicegroup_members,notes,notes_url,action_url';
}
if ($strTableName == 'tbl_hostdependency') {
$strSpecial .= ',dependent_hostgroup_name,hostgroup_name,dependency_period';
}
if ($strTableName == 'tbl_hostescalation') {
$strSpecial .= ',contacts';
}
if ($strTableName == 'tbl_servicedependency') {
$strSpecial .= ',dependent_hostgroup_name,hostgroup_name,dependency_period,dependent_servicegroup_name';
$strSpecial .= ',servicegroup_name';
}
if ($strTableName == 'tbl_serviceescalation') {
$strSpecial .= ',hostgroup_name,contacts,servicegroup_name';
}
if (($strTableName == 'tbl_host') || ($strTableName == 'tbl_hosttemplate')) {
$strSpecial .= ',initial_state,flap_detection_options,contacts,notes,notes_url,action_url';
$strSpecial .= ',icon_image,icon_image_alt,vrml_image,statusmap_image,2d_coords,3d_coords';
$arrOption['notification_options'] = ',s';
}
// Services
if (($strTableName == 'tbl_service') || ($strTableName == 'tbl_servicetemplate')) {
$strSpecial .= ',initial_state,flap_detection_options,contacts,notes,notes_url,action_url';
$strSpecial .= ',icon_image,icon_image_alt';
$arrOption['notification_options'] = ',s';
}
}
// Pass fields based on nagios version higher than 2.x
if ($intVersionValue > 2) {
if ($strTableName == 'tbl_servicetemplate') {
$strSpecial .= ',parallelize_check ';
}
if ($strTableName == 'tbl_service') {
$strSpecial .= ',parallelize_check';
}
}
// Pass fields based on nagios version lower than 4.x
if ($intVersionValue < 4) {
if (($strTableName == 'tbl_contact') || ($strTableName == 'tbl_contacttemplate')) {
$strSpecial .= ',minimum_importance';
}
if ($strTableName == 'tbl_host') {
$strSpecial .= ',importance';
}
if (($strTableName == 'tbl_service') || ($strTableName == 'tbl_servicetemplate')) {
$strSpecial .= ',importance,parents';
}
}
if ($intVersionValue == 1) {
$strSpecial .= '';
}
// Reduce option values
if (array_key_exists($key, $arrOption) && (\count($arrOption) != 0)) {
$value = str_replace(array($arrOption[$key], str_replace(',', '', $arrOption[$key])), '', $value);
if ($value == '') {
$intReturn = 1;
}
}
if ($intReturn == 0) {
// Skip entries
$arrSpecial = explode(',', $strSpecial);
if (($value == '') || \in_array($key, $arrSpecial, true)) {
$intReturn = 1;
}
}
if ($intReturn == 0) {
// Do not write config data (based on 'skip' option)
$strNoTwo = 'active_checks_enabled,passive_checks_enabled,obsess_over_host,check_freshness,';
$strNoTwo .= 'event_handler_enabled,flap_detection_enabled,process_perf_data,retain_status_information,';
$strNoTwo .= 'retain_nonstatus_information,notifications_enabled,parallelize_check,is_volatile,';
$strNoTwo .= 'host_notifications_enabled,service_notifications_enabled,can_submit_commands,';
$strNoTwo .= 'obsess_over_service';
foreach (explode(',', $strNoTwo) as $elem) {
if (($key == $elem) && ($value == '2')) {
$intReturn = 1;
}
if (($intVersionValue < 3) && ($key == $elem) && ($value == '3')) {
$intReturn = 1;
}
}
}
return $intReturn;
}
/**
* Get related data
* @param string $strTableName Table name
* @param \HTML_Template_IT $resTemplate Template ressource
* @param array $arrData Dataset array
* @param string $strDataKey Data key
* @param string $strDataValue Data value
* @return int 0 = use data / 1 = skip data
* Status message is stored in message class variables
*/
private function getRelationData($strTableName, $resTemplate, $arrData, $strDataKey, &$strDataValue)
{
// Define Variables
$intReturn = 0;
$intSkipProc = 0;
$arrRelations = array();
// Pass function for tbl_command
if ($strTableName == 'tbl_command') {
$intSkipProc = 1;
}
// Get relation info and store the value in a class variable (speedup export)
if (($intSkipProc == 0) && ($this->strRelTable != $strTableName)) {
$intReturn = $this->myDataClass->tableRelations($strTableName, $arrRelations);
$this->strRelTable = $strTableName;
$this->arrRelData = $arrRelations;
} elseif ($intSkipProc == 0) {
$arrRelations = $this->arrRelData;
$intReturn = 0;
}
if (($intSkipProc == 0) && (!\is_array($arrRelations)) && (\count($arrRelations) == 0)) {
$intSkipProc = 1;
$intReturn = 1;
}
if ($intSkipProc == 0) {
// Common domain is enabled?
$this->getDomainData('enable_common', $intCommonEnable);
if ($intCommonEnable == 1) {
$strDomainWhere1 = ' (`config_id`=' . $this->intDomainId . ' OR `config_id`=0) ';
} else {
$strDomainWhere1 = ' `config_id`=' . $this->intDomainId . ' ';
}
// Process relations
foreach ($arrRelations as $elem) {
if ($elem['fieldName'] == $strDataKey) {
// Process normal 1:n relations (1 = only data / 2 = including a * value)
if (($elem['type'] == 2) && (($strDataValue == 1) || ($strDataValue == 2))) {
$intReturn = $this->processRelation1($arrData, $strDataValue, $elem, $strDomainWhere1);
// Process normal 1:1 relations
} elseif ($elem['type'] == 1) {
$intReturn = $this->processRelation2($arrData, $strDataValue, $elem, $strDomainWhere1);
// Process normal 1:n relations with special table and idSort (template tables)
} elseif (($elem['type'] == 3) && ($strDataValue == 1)) {
$intReturn = $this->processRelation3($arrData, $strDataValue, $elem, $strDomainWhere1);
// Process special 1:n:str relations with string values (servicedependencies)
} elseif (($elem['type'] == 6) && (($strDataValue == 1) || ($strDataValue == 2))) {
$intReturn = $this->processRelation4($arrData, $strDataValue, $elem, $strDomainWhere1);
// Process special relations for free variables
} elseif (($elem['type'] == 4) && ($strDataValue == 1) && ($this->intNagVersion >= 3)) {
$intReturn = $this->processRelation5($resTemplate, $arrData, $elem);
// Process special relations for service groups
} elseif (($elem['type'] == 5) && ($strDataValue == 1)) {
$intReturn = $this->processRelation6($arrData, $strDataValue, $elem, $strDomainWhere1);
// Process special relations for service parents
} elseif (($elem['type'] == 7) && ($strDataValue == 1)) {
$intReturn = $this->processRelation7($arrData, $strDataValue, $elem);
// Process "*"
} elseif ($strDataValue == 2) {
$strDataValue = '*';
} else {
$intReturn = 1;
}
}
}
}
return $intReturn;
}
/**
* Rename field names
* @param string $strTableName Table name
* @param int $intConfigID Configuration target ID
* @param int $intDataId Data ID
* @param string $key Data key (by reference)
* @param string $value Data value (by reference)
* @param int $intSkip Skip value (by reference) 1 = skip / 0 = pass
*/
private function renameFields($strTableName, $intConfigID, $intDataId, &$key, &$value, &$intSkip)
{
if ($this->intNagVersion == 0) {
$this->getConfigData($intConfigID, 'version', $this->intNagVersion);
}
// Picture path
if ($this->strPicPath == 'none') {
$this->getConfigData($intConfigID, 'picturedir', $this->strPicPath);
}
if ($key == 'icon_image') {
$value = $this->strPicPath.$value;
}
if ($key == 'vrml_image') {
$value = $this->strPicPath.$value;
}
if ($key == 'statusmap_image') {
$value = $this->strPicPath.$value;
}
// Tables
if ($strTableName == 'tbl_host') {
if ($key == 'use_template') {
$key = 'use';
}
$strVIValues = 'active_checks_enabled,passive_checks_enabled,check_freshness,obsess_over_host,';
$strVIValues .= 'event_handler_enabled,flap_detection_enabled,process_perf_data,retain_status_information,';
$strVIValues .= 'retain_nonstatus_information,notifications_enabled';
if (\in_array($key, explode(',', $strVIValues), true)) {
if ($value == -1) {
$value = 'null';
}
if ($value == 3) {
$value = 'null';
}
}
if ($key == 'parents') {
$value = $this->checkTpl($value, 'parents_tploptions', 'tbl_host', $intDataId, $intSkip);
}
if ($key == 'hostgroups') {
$value = $this->checkTpl($value, 'hostgroups_tploptions', 'tbl_host', $intDataId, $intSkip);
}
if ($key == 'contacts') {
$value = $this->checkTpl($value, 'contacts_tploptions', 'tbl_host', $intDataId, $intSkip);
}
if ($key == 'contact_groups') {
$value = $this->checkTpl($value, 'contact_groups_tploptions', 'tbl_host', $intDataId, $intSkip);
}
if ($key == 'use') {
$value = $this->checkTpl($value, 'use_template_tploptions', 'tbl_host', $intDataId, $intSkip);
}
if ($key == 'check_command') {
$value = str_replace("\::bang::", "\!", $value);
}
if ($key == 'check_command') {
$value = str_replace('::bang::', "\!", $value);
}
}
if ($strTableName == 'tbl_service') {
if ($key == 'use_template') {
$key = 'use';
}
if ($this->intNagVersion < 2) {
if ($key == 'check_interval') {
$key = 'normal_check_interval';
}
if ($key == 'retry_interval') {
$key = 'retry_check_interval';
}
}
$strVIValues = 'is_volatile,active_checks_enabled,passive_checks_enabled,parallelize_check,';
$strVIValues .= 'obsess_over_service,check_freshness,event_handler_enabled,flap_detection_enabled,';
$strVIValues .= 'process_perf_data,retain_status_information,retain_nonstatus_information,';
$strVIValues .= 'notifications_enabled';
if (\in_array($key, explode(',', $strVIValues), true)) {
if ($value == -1) {
$value = 'null';
}
if ($value == 3) {
$value = 'null';
}
}
if ($key == 'host_name') {
$value = $this->checkTpl($value, 'host_name_tploptions', 'tbl_service', $intDataId, $intSkip);
}
if ($key == 'hostgroup_name') {
$value = $this->checkTpl($value, 'hostgroup_name_tploptions', 'tbl_service', $intDataId, $intSkip);
}
if ($key == 'parents') {
$value = $this->checkTpl($value, 'parents_tploptions', 'tbl_service', $intDataId, $intSkip);
}
if ($key == 'servicegroups') {
$value = $this->checkTpl($value, 'servicegroups_tploptions', 'tbl_service', $intDataId, $intSkip);
}
if ($key == 'contacts') {
$value = $this->checkTpl($value, 'contacts_tploptions', 'tbl_service', $intDataId, $intSkip);
}
if ($key == 'contact_groups') {
$value = $this->checkTpl($value, 'contact_groups_tploptions', 'tbl_service', $intDataId, $intSkip);
}
if ($key == 'use') {
$value = $this->checkTpl($value, 'use_template_tploptions', 'tbl_service', $intDataId, $intSkip);
}
if ($key == 'check_command') {
$value = str_replace("\::bang::", "\!", $value);
}
if ($key == 'check_command') {
$value = str_replace('::bang::', "\!", $value);
}
}
if ($strTableName == 'tbl_hosttemplate') {
if ($key == 'template_name') {
$key = 'name';
}
if ($key == 'use_template') {
$key = 'use';
}
$strVIValues = 'active_checks_enabled,passive_checks_enabled,check_freshness,obsess_over_host,';
$strVIValues .= 'event_handler_enabled,flap_detection_enabled,process_perf_data,retain_status_information,';
$strVIValues .= 'retain_nonstatus_information,notifications_enabled';
if (\in_array($key, explode(',', $strVIValues), true)) {
if ($value == -1) {
$value = 'null';
}
if ($value == 3) {
$value = 'null';
}
}
if ($key == 'parents') {
$value = $this->checkTpl($value, 'parents_tploptions', 'tbl_hosttemplate', $intDataId, $intSkip);
}
if ($key == 'hostgroups') {
$value = $this->checkTpl($value, 'hostgroups_tploptions', 'tbl_hosttemplate', $intDataId, $intSkip);
}
if ($key == 'contacts') {
$value = $this->checkTpl($value, 'contacts_tploptions', 'tbl_hosttemplate', $intDataId, $intSkip);
}
if ($key == 'contact_groups') {
$value = $this->checkTpl($value, 'contact_groups_tploptions', 'tbl_hosttemplate', $intDataId, $intSkip);
}
if ($key == 'use') {
$value = $this->checkTpl($value, 'use_template_tploptions', 'tbl_hosttemplate', $intDataId, $intSkip);
}
}
if ($strTableName == 'tbl_servicetemplate') {
if ($key == 'template_name') {
$key = 'name';
}
if ($key == 'use_template') {
$key = 'use';
}
if ($this->intNagVersion < 2) {
if ($key == 'check_interval') {
$key = 'normal_check_interval';
}
if ($key == 'retry_interval') {
$key = 'retry_check_interval';
}
}
$strVIValues = 'is_volatile,active_checks_enabled,passive_checks_enabled,parallelize_check,';
$strVIValues .= 'obsess_over_service,check_freshness,event_handler_enabled,flap_detection_enabled,';
$strVIValues .= 'process_perf_data,retain_status_information,retain_nonstatus_information,';
$strVIValues .= 'notifications_enabled';
if (\in_array($key, explode(',', $strVIValues), true)) {
if ($value == -1) {
$value = 'null';
}
if ($value == 3) {
$value = 'null';
}
}
if ($key == 'host_name') {
$value = $this->checkTpl($value, 'host_name_tploptions', 'tbl_servicetemplate', $intDataId, $intSkip);
}
if ($key == 'hostgroup_name') {
$value = $this->checkTpl(
$value,
'hostgroup_name_tploptions',
'tbl_servicetemplate',
$intDataId,
$intSkip
);
}
if ($key == 'parents') {
$value = $this->checkTpl($value, 'parents_tploptions', 'tbl_servicetemplate', $intDataId, $intSkip);
}
if ($key == 'servicegroups') {
$value = $this->checkTpl(
$value,
'servicegroups_tploptions',
'tbl_servicetemplate',
$intDataId,
$intSkip
);
}
if ($key == 'contacts') {
$value = $this->checkTpl($value, 'contacts_tploptions', 'tbl_servicetemplate', $intDataId, $intSkip);
}
if ($key == 'contact_groups') {
$value = $this->checkTpl(
$value,
'contact_groups_tploptions',
'tbl_servicetemplate',
$intDataId,
$intSkip
);
}
if ($key == 'use') {
$value = $this->checkTpl(
$value,
'use_template_tploptions',
'tbl_servicetemplate',
$intDataId,
$intSkip
);
}
}
if ($strTableName == 'tbl_contact') {
if ($key == 'use_template') {
$key = 'use';
}
$strVIValues = 'host_notifications_enabled,service_notifications_enabled,can_submit_commands,';
$strVIValues .= 'retain_status_information,retain_nonstatus_information';
if (\in_array($key, explode(',', $strVIValues), true)) {
if ($value == -1) {
$value = 'null';
}
if ($value == 3) {
$value = 'null';
}
}
if ($key == 'contactgroups') {
$value = $this->checkTpl($value, 'contactgroups_tploptions', 'tbl_contact', $intDataId, $intSkip);
}
if ($key == 'host_notification_commands') {
$value = $this->checkTpl(
$value,
'host_notification_commands_tploptions',
'tbl_contact',
$intDataId,
$intSkip
);
}
if ($key == 'service_notification_commands') {
$value = $this->checkTpl(
$value,
'service_notification_commands_tploptions',
'tbl_contact',
$intDataId,
$intSkip
);
}
if ($key == 'use') {
$value = $this->checkTpl($value, 'use_template_tploptions', 'tbl_contact', $intDataId, $intSkip);
}
}
if ($strTableName == 'tbl_contacttemplate') {
if ($key == 'template_name') {
$key = 'name';
}
if ($key == 'use_template') {
$key = 'use';
}
$strVIValues = 'host_notifications_enabled,service_notifications_enabled,can_submit_commands,';
$strVIValues .= 'retain_status_information,retain_nonstatus_information';
if (in_array($key, explode(',', $strVIValues), true)) {
if ($value == -1) {
$value = 'null';
}
if ($value == 3) {
$value = 'null';
}
}
if ($key == 'contactgroups') {
$value = $this->checkTpl(
$value,
'contactgroups_tploptions',
'tbl_contacttemplate',
$intDataId,
$intSkip
);
}
if ($key == 'host_notification_commands') {
$value = $this->checkTpl(
$value,
'host_notification_commands_tploptions',
'tbl_contacttemplate',
$intDataId,
$intSkip
);
}
if ($key == 'service_notification_commands') {
$value = $this->checkTpl(
$value,
'service_notification_commands_tploptions',
'tbl_contacttemplate',
$intDataId,
$intSkip
);
}
if ($key == 'use') {
$value = $this->checkTpl(
$value,
'use_template_tploptions',
'tbl_contacttemplate',
$intDataId,
$intSkip
);
}
}
if ((($strTableName == 'tbl_hosttemplate') || ($strTableName == 'tbl_servicetemplate') ||
($strTableName == 'tbl_contacttemplate')) && $key == 'register') {
$value = '0';
}
if ($strTableName == 'tbl_timeperiod' && $key == 'use_template') {
$key = 'use';
}
}
/**
* Open configuration file
* @param string $strFile File name
* @param int $intConfigID Configuration ID
* @param int $intType Type ID
* @param resource|bool $resConfigFile Temporary or configuration file ressource (by reference)
* @param string $strConfigFile Configuration file name (by reference)
* @return int 0 = successful / 1 = error
*/
private function getConfigFile($strFile, $intConfigID, $intType, &$resConfigFile, &$strConfigFile)
{
// Variable definitions
$strBaseDir = '';
$intMethod = 1;
$intReturn = 0;
// Get config data
if ($intType == 1) {
$this->getConfigData($intConfigID, 'hostconfig', $strBaseDir);
$strType = 'host';
} elseif ($intType == 2) {
$this->getConfigData($intConfigID, 'serviceconfig', $strBaseDir);
$strType = 'service';
} else {
$this->getConfigData($intConfigID, 'basedir', $strBaseDir);
$strType = 'basic';
}
$this->getConfigData($intConfigID, 'method', $intMethod);
// Backup config file
$this->moveFile($strType, $strFile, $intConfigID);
// Variable definition
$strConfigFile = $strBaseDir. '/' .$strFile;
// Local file system
if ($intMethod == 1) {
// Save configuration file
if (is_writable($strConfigFile) || (!file_exists($strConfigFile) && is_writable($strBaseDir))) {
$resConfigFile = fopen($strConfigFile, 'wb');
chmod($strConfigFile, 0644);
} else {
$this->myDataClass->writeLog(translate('Configuration write failed:'). ' ' .$strFile);
$this->processClassMessage(translate('Cannot open/overwrite the configuration file (check the '
.'permissions)!'). '::', $this->strErrorMessage);
$intReturn = 1;
}
} elseif ($intMethod == 2) { // Remote file (FTP)
// Check connection
if (empty($this->resConnectId) || !\is_resource($this->resConnectId) ||
($this->resConnectType != 'FTP')) {
$intReturn = $this->getFTPConnection($intConfigID);
}
if ($intReturn == 0) {
// Open the config file
if (isset($this->arrSettings['path']) && isset($this->arrSettings['path']['tempdir'])) {
$strConfigFile = tempnam($this->arrSettings['path']['tempdir'], 'nagiosql');
} else {
$strConfigFile = tempnam(sys_get_temp_dir(), 'nagiosql');
}
$resConfigFile = fopen($strConfigFile, 'wb');
}
} elseif ($intMethod == 3) { // Remote file (SFTP)
// Check connection
if (empty($this->resConnectId) || !\is_resource($this->resConnectId) ||
($this->resConnectType != 'SSH')) {
$intReturn = $this->getSSHConnection($intConfigID);
}
if ($intReturn == 0) {
if (isset($this->arrSettings['path']) && isset($this->arrSettings['path']['tempdir'])) {
$strConfigFile = tempnam($this->arrSettings['path']['tempdir'], 'nagiosql');
} else {
$strConfigFile = tempnam(sys_get_temp_dir(), 'nagiosql');
}
$resConfigFile = fopen($strConfigFile, 'wb');
}
}
return $intReturn;
}
/**
* Write configuration file
* @param string $strData Data string
* @param string $strFile File name
* @param int $intType Type ID
* @param int $intConfigID Configuration target ID
* @param resource $resConfigFile Temporary or configuration file ressource
* @param string $strConfigFile Configuration file name
* @return int 0 = successful / 1 = error
*/
private function writeConfigFile($strData, $strFile, $intType, $intConfigID, $resConfigFile, $strConfigFile)
{
// Variable definitions
$intReturn = 0;
// Get config data
if ($intType == 1) {
$this->getConfigData($intConfigID, 'hostconfig', $strBaseDir);
} elseif ($intType == 2) {
$this->getConfigData($intConfigID, 'serviceconfig', $strBaseDir);
} else {
$this->getConfigData($intConfigID, 'basedir', $strBaseDir);
}
$this->getConfigData($intConfigID, 'method', $intMethod);
$strData = str_replace("\r\n", "\n", $strData);
fwrite($resConfigFile, $strData);
// Local filesystem
if ($intMethod == 1) {
fclose($resConfigFile);
} elseif ($intMethod == 2) { // FTP access
// SSH Possible
if (!\function_exists('ftp_put')) {
$this->processClassMessage(translate('FTP module not loaded!'). '::', $this->strErrorMessage);
$intReturn = 1;
} else {
$intErrorReporting = error_reporting();
error_reporting(0);
if (!ftp_put($this->resConnectId, $strBaseDir . '/' . $strFile, $strConfigFile, FTP_ASCII)) {
$arrError = error_get_last();
error_reporting($intErrorReporting);
$this->processClassMessage(translate('Cannot open/overwrite the configuration file (FTP connection '
.'failed)!') . '::', $this->strErrorMessage);
if ($arrError['message'] != '') {
$this->processClassMessage($arrError['message'] . '::', $this->strErrorMessage);
}
$intReturn = 1;
}
error_reporting($intErrorReporting);
ftp_close($this->resConnectId);
fclose($resConfigFile);
}
} elseif ($intMethod == 3) { // SSH access
// SSH Possible
if (!\function_exists('ssh2_scp_send')) {
$this->processClassMessage(translate('SSH module not loaded!'). '::', $this->strErrorMessage);
$intReturn = 1;
} else {
$intErrorReporting = error_reporting();
error_reporting(0);
if (!ssh2_scp_send($this->resConnectId, $strConfigFile, $strBaseDir . '/' . $strFile, 0644)) {
$arrError = error_get_last();
error_reporting($intErrorReporting);
$this->processClassMessage(translate('Cannot open/overwrite the configuration file (remote SFTP)!').
'::', $this->strErrorMessage);
if ($arrError['message'] != '') {
$this->processClassMessage($arrError['message'] . '::', $this->strErrorMessage);
}
$this->resConnectId = null;
$intReturn = 1;
}
error_reporting($intErrorReporting);
fclose($resConfigFile);
unlink($strConfigFile);
$this->resConnectId = null;
}
}
if ($intReturn == 0) {
$this->myDataClass->writeLog(translate('Configuration successfully written:') . ' ' . $strFile);
$this->processClassMessage(translate('Configuration file successfully written!').
'::', $this->strInfoMessage);
}
return $intReturn;
}
/**
* Process special settings based on template option
* @param string $strValue Original data value
* @param string $strKeyField Template option field name
* @param string $strTable Table name
* @param int $intId Dataset ID
* @param int $intSkip Skip value (by reference)
* @return string Manipulated data value
*/
public function checkTpl($strValue, $strKeyField, $strTable, $intId, &$intSkip)
{
if ($this->intNagVersion < 3) {
return $strValue;
}
$strSQL = 'SELECT `' .$strKeyField. '` FROM `' .$strTable."` WHERE `id` = $intId";
$intValue = $this->myDBClass->getFieldData($strSQL);
if ($intValue == 0) {
return('+' .$strValue);
}
if ($intValue == 1) {
$intSkip = 0;
return 'null';
}
return $strValue;
}
/**
* @param array $arrData Dataset array
* @param string $strDataValue Data value
* @param array $elem Relation data array
* @param string $strDomainWhere1 SQL WHERE add-in
* @return int 0 = use data / 1 = skip data
*/
private function processRelation1($arrData, &$strDataValue, $elem, $strDomainWhere1)
{
// Define variables
$arrDataRel = array();
$intDataCountRel = 0;
$intReturn = 0;
// Get relation data
$strSQLRel = 'SELECT `' . $elem['tableName1'] . '`.`' . $elem['target1'] . '`, `' . $elem['linkTable'] .
'`.`exclude` FROM `' . $elem['linkTable'] . '` LEFT JOIN `' . $elem['tableName1'] .
'` ON `' . $elem['linkTable'] . '`.`idSlave` = `' . $elem['tableName1'] . '`.`id`' .
'WHERE `idMaster`=' . $arrData['id'] . " AND `active`='1' AND $strDomainWhere1" .
'ORDER BY `' . $elem['tableName1'] . '`.`' . $elem['target1'] . '`';
$booReturn = $this->myDBClass->hasDataArray($strSQLRel, $arrDataRel, $intDataCountRel);
if ($booReturn && ($intDataCountRel != 0)) {
// Rewrite $strDataValue with returned relation data
if ($strDataValue == 2) {
$strDataValue = '*,';
} else {
$strDataValue = '';
}
foreach ($arrDataRel as $data) {
if ($data['exclude'] == 0) {
$strDataValue .= $data[$elem['target1']] . ',';
} elseif ($this->intNagVersion >= 3) {
$strDataValue .= '!' . $data[$elem['target1']] . ',';
}
}
$strDataValue = substr($strDataValue, 0, -1);
if ($strDataValue == '') {
$intReturn = 1;
}
} else {
if ($strDataValue == 2) {
$strDataValue = '*';
} else {
$intReturn = 1;
}
}
return $intReturn;
}
/**
* @param array $arrData Dataset array
* @param string $strDataValue Data value
* @param array $elem Relation data array
* @param string $strDomainWhere1 SQL WHERE add-in
* @return int 0 = use data / 1 = skip data
*/
private function processRelation2($arrData, &$strDataValue, $elem, $strDomainWhere1)
{
// Define variables
$arrDataRel = array();
$arrField = array();
$intDataCountRel = 0;
$intReturn = 0;
$strCommand = '';
// Get relation data
if (($elem['tableName1'] == 'tbl_command') &&
(substr_count($arrData[$elem['fieldName']], '!') != 0)) {
$arrField = explode('!', $arrData[$elem['fieldName']]);
$strCommand = strstr($arrData[$elem['fieldName']], '!');
$strSQLRel = 'SELECT `' . $elem['target1'] . '` FROM `' . $elem['tableName1'] . '`' .
'WHERE `id`=' . $arrField[0] . " AND `active`='1' AND $strDomainWhere1";
} else {
$strSQLRel = 'SELECT `' . $elem['target1'] . '` FROM `' . $elem['tableName1'] . '`' .
'WHERE `id`=' . $arrData[$elem['fieldName']] . " AND `active`='1' AND $strDomainWhere1";
}
$booReturn = $this->myDBClass->hasDataArray($strSQLRel, $arrDataRel, $intDataCountRel);
if ($booReturn && ($intDataCountRel != 0)) {
// Rewrite $strDataValue with returned relation data
if (($elem['tableName1'] == 'tbl_command') && (substr_count($strDataValue, '!') != 0)) {
$strDataValue = $arrDataRel[0][$elem['target1']] . $strCommand;
} else {
$strDataValue = $arrDataRel[0][$elem['target1']];
}
} else {
if (($elem['tableName1'] == 'tbl_command') && (substr_count($strDataValue, '!') != 0) &&
($arrField[0] == -1)) {
$strDataValue = 'null';
} else {
$intReturn = 1;
}
}
return $intReturn;
}
/**
* @param array $arrData Dataset array
* @param string $strDataValue Data value
* @param array $elem Relation data array
* @param string $strDomainWhere1 SQL WHERE add-in
* @return int 0 = use data / 1 = skip data
*/
private function processRelation3($arrData, &$strDataValue, $elem, $strDomainWhere1)
{
// Define variables
$arrDataRel = array();
$intDataCountRel = 0;
$intReturn = 0;
// Get relation data
$strSQLRel = 'SELECT * FROM `' .$elem['linkTable']. '` WHERE `idMaster`=' .$arrData['id']. ' ORDER BY idSort';
$booReturn = $this->myDBClass->hasDataArray($strSQLRel, $arrDataRel, $intDataCountRel);
if ($booReturn && ($intDataCountRel != 0)) {
// Rewrite $strDataValue with returned relation data
$strDataValue = '';
foreach ($arrDataRel as $data) {
if ($data['idTable'] == 1) {
$strSQLName = 'SELECT `' .$elem['target1']. '` FROM `' .$elem['tableName1']. '`' .
"WHERE `active`='1' AND $strDomainWhere1 AND `id`=".$data['idSlave'];
} else {
$strSQLName = 'SELECT `' .$elem['target2']. '` FROM `' .$elem['tableName2']. '`' .
"WHERE `active`='1' AND $strDomainWhere1 AND `id`=".$data['idSlave'];
}
$strDataValue .= $this->myDBClass->getFieldData($strSQLName) . ',';
}
$strDataValue = substr($strDataValue, 0, -1);
} else {
$intReturn = 1;
}
return $intReturn;
}
/**
* @param array $arrData Dataset array
* @param string $strDataValue Data value
* @param array $elem Relation data array
* @param string $strDomainWhere1 SQL WHERE add-in
* @return int 0 = use data / 1 = skip data
*/
private function processRelation4($arrData, &$strDataValue, $elem, $strDomainWhere1)
{
// Define variables
$arrDataRel = array();
$intDataCountRel = 0;
$intReturn = 0;
// Get relation data
$strSQLRel = 'SELECT `' .$elem['linkTable']. '`.`strSlave`, `' .$elem['linkTable']. '`.`exclude` ' .
'FROM `' .$elem['linkTable']. '` ' .
'LEFT JOIN `tbl_service` ON `' .$elem['linkTable']. '`.`idSlave`=`tbl_service`.`id` ' .
'WHERE `' .$elem['linkTable']. '`.`idMaster`=' .$arrData['id']." AND `active`='1' AND ".
$strDomainWhere1. ' ' .
'ORDER BY `' .$elem['linkTable']. '`.`strSlave`';
$booReturn = $this->myDBClass->hasDataArray($strSQLRel, $arrDataRel, $intDataCountRel);
if ($booReturn && ($intDataCountRel != 0)) {
// Rewrite $strDataValue with returned relation data
if ($strDataValue == 2) {
$strDataValue = '*,';
} else {
$strDataValue = '';
}
foreach ($arrDataRel as $data) {
if ($data['exclude'] == 0) {
$strDataValue .= $data['strSlave'] . ',';
} elseif ($this->intNagVersion >= 3) {
$strDataValue .= '!' . $data['strSlave'] . ',';
}
}
$strDataValue = substr($strDataValue, 0, -1);
if ($strDataValue == '') {
$intReturn = 1;
}
} else {
if ($strDataValue == 2) {
$strDataValue = '*';
} else {
$intReturn = 1;
}
}
return $intReturn;
}
/**
* @param \HTML_Template_IT $resTemplate Template object
* @param array $arrData Dataset array
* @param array $elem Relation data array
* @return int 0 = use data / 1 = skip data
*/
private function processRelation5($resTemplate, $arrData, $elem)
{
// Define variables
$arrDataRel = array();
$intDataCountRel = 0;
$strSQLRel = 'SELECT * FROM `tbl_variabledefinition` LEFT JOIN `' .$elem['linkTable']. '` ' .
'ON `id`=`idSlave` WHERE `idMaster`=' .$arrData['id']. ' ORDER BY `name`';
$booReturn = $this->myDBClass->hasDataArray($strSQLRel, $arrDataRel, $intDataCountRel);
if ($booReturn && ($intDataCountRel != 0)) {
foreach ($arrDataRel as $vardata) {
// Insert fill spaces
$strFillLen = (30 - \strlen($vardata['name']));
$strSpace = ' ';
for ($f = 0; $f < $strFillLen; $f++) {
$strSpace .= ' ';
}
$resTemplate->setVariable('ITEM_TITLE', $vardata['name'] . $strSpace);
$resTemplate->setVariable('ITEM_VALUE', $vardata['value']);
$resTemplate->parse('configline');
}
}
return 1;
}
/**
* @param array $arrData Dataset array
* @param string $strDataValue Data value
* @param array $elem Relation data array
* @param string $strDomainWhere1 SQL WHERE add-in
* @return int 0 = use data / 1 = skip data
*/
private function processRelation6($arrData, &$strDataValue, $elem, $strDomainWhere1)
{
// Define variables
$arrDataRel = array();
$arrHG1 = array();
$arrHG2 = array();
$intDataCountRel = 0;
$intHG1 = 0;
$intHG2 = 0;
$intReturn = 0;
// Get relation data
$strSQLMaster = 'SELECT * FROM `' . $elem['linkTable'] . '` WHERE `idMaster`=' . $arrData['id'];
$booReturn = $this->myDBClass->hasDataArray($strSQLMaster, $arrDataRel, $intDataCountRel);
if ($booReturn && ($intDataCountRel != 0)) {
// Rewrite $strDataValue with returned relation data
$strDataValue = '';
foreach ($arrDataRel as $data) {
if ($data['idSlaveHG'] != 0) {
$strSQLSrv = 'SELECT `' . $elem['target2'] . '` FROM `' . $elem['tableName2'] .
'` WHERE `id`=' . $data['idSlaveS'];
$strService = $this->myDBClass->getFieldData($strSQLSrv);
$strSQLHG1 = 'SELECT `host_name` FROM `tbl_host` ' .
'LEFT JOIN `tbl_lnkHostgroupToHost` ON `id`=`idSlave` ' .
'WHERE `idMaster`=' . $data['idSlaveHG'] . " AND `active`='1' AND $strDomainWhere1";
$booReturn = $this->myDBClass->hasDataArray($strSQLHG1, $arrHG1, $intHG1);
if ($booReturn && ($intHG1 != 0)) {
foreach ($arrHG1 as $elemHG1) {
if (substr_count($strDataValue, $elemHG1['host_name'] . ',' . $strService) == 0) {
$strDataValue .= $elemHG1['host_name'] . ',' . $strService . ',';
}
}
}
$strSQLHG2 = 'SELECT `host_name` FROM `tbl_host` ' .
'LEFT JOIN `tbl_lnkHostToHostgroup` ON `id`=`idMaster` ' .
'WHERE `idSlave`=' . $data['idSlaveHG'] . " AND `active`='1' AND $strDomainWhere1";
$booReturn = $this->myDBClass->hasDataArray($strSQLHG2, $arrHG2, $intHG2);
if ($booReturn && ($intHG2 != 0)) {
foreach ($arrHG2 as $elemHG2) {
if (substr_count($strDataValue, $elemHG2['host_name'] . ',' . $strService) == 0) {
$strDataValue .= $elemHG2['host_name'] . ',' . $strService . ',';
}
}
}
} else {
$strSQLHost = 'SELECT `' . $elem['target1'] . '` FROM `' . $elem['tableName1'] . '` ' .
'WHERE `id`=' . $data['idSlaveH'] . " AND `active`='1' AND $strDomainWhere1";
$strHost = $this->myDBClass->getFieldData($strSQLHost);
$strSQLSrv = 'SELECT `' . $elem['target2'] . '` FROM `' . $elem['tableName2'] . '` ' .
'WHERE `id`=' . $data['idSlaveS'] . " AND `active`='1' AND $strDomainWhere1";
$strService = $this->myDBClass->getFieldData($strSQLSrv);
if (($strHost != '') && ($strService != '') &&
substr_count($strDataValue, $strHost . ',' . $strService) == 0) {
$strDataValue .= $strHost . ',' . $strService . ',';
}
}
}
$strDataValue = substr($strDataValue, 0, -1);
if ($strDataValue == '') {
$intReturn = 1;
}
} else {
$intReturn = 1;
}
return $intReturn;
}
/**
* @param array $arrData Dataset array
* @param string $strDataValue Data value
* @param array $elem Relation data array
* @return int 0 = use data / 1 = skip data
*/
private function processRelation7($arrData, &$strDataValue, $elem)
{
$intReturn = 1;
// Get relation data
$strSQLMaster = 'SELECT * FROM `' . $elem['linkTable'] . '` WHERE `idMaster`=' . $arrData['id'];
$booReturn = $this->myDBClass->hasDataArray($strSQLMaster, $arrDataRel, $intDataCountRel);
if ($booReturn && ($intDataCountRel != 0)) {
// Rewrite $strDataValue with returned relation data
$strDataValue = '';
/** @var array $arrDataRel */
foreach ($arrDataRel as $data) {
$strSQL = 'SELECT host_name FROM tbl_host WHERE id=' .$data['idHost'];
$strHost = $this->myDBClass->getFieldData($strSQL);
$strSQL = 'SELECT service_description FROM tbl_service WHERE id=' .$data['idSlave'];
$strService = $this->myDBClass->getFieldData($strSQL);
$strDataValue .= $strHost . ',' . $strService . ',';
$intReturn = 0;
}
$strDataValue = substr($strDataValue, 0, -1);
}
return $intReturn;
}
}
Reference in New Issue View Git Blame Copy Permalink