'.$notification['url'],
io_safe_output($notification['subject']),
null,
$blacklist,
]
);
}
}
}
$insertion_string = substr($insertion_string, 0, -1);
db_process_sql($groups_sql.' VALUES '.$insertion_string);
}
}
/**
* Generates notifications for target users and groups.
*
* @param array $data Message to be delivered:
* - boolean status (false: notify, true: do not notify)
* - string title
* - string message
* - string url.
* @param integer $source_id Target source_id, by default $this->sourceId.
* @param integer $max_age Maximum age for generated notification.
*
* @return void
*/
public function notify(
array $data,
int $source_id=0,
int $max_age=86400
) {
// Uses 'check failed' logic.
if (is_array($data) === false) {
// Skip.
return;
}
if ($this->targetUpdated === false) {
$targets = get_notification_source_targets($this->sourceId);
$this->targetGroups = $targets['groups'];
$this->targetUsers = $targets['users'];
$this->targetUpdated = false;
}
if ($source_id === 0) {
$source_id = $this->sourceId;
// Assign targets.
$targets = get_notification_source_targets($source_id);
$this->targetGroups = $targets['groups'];
$this->targetUsers = $targets['users'];
$this->targetUpdated = false;
}
switch ($data['type']) {
case 'NOTIF.LICENSE.EXPIRATION':
case 'NOTIF.FILES.ATTACHMENT':
case 'NOTIF.FILES.DATAIN':
case 'NOTIF.FILES.DATAIN.BADXML':
case 'NOTIF.PHP.SAFE_MODE':
case 'NOTIF.PHP.INPUT_TIME':
case 'NOTIF.PHP.EXECUTION_TIME':
case 'NOTIF.PHP.UPLOAD_MAX_FILESIZE':
case 'NOTIF.PHP.MEMORY_LIMIT':
case 'NOTIF.PHP.DISABLE_FUNCTIONS':
case 'NOTIF.PHP.PHANTOMJS':
case 'NOTIF.PHP.VERSION':
case 'NOTIF.HISTORYDB':
case 'NOTIF.PANDORADB':
case 'NOTIF.PANDORADB.HISTORICAL':
case 'NOTIF.HISTORYDB.MR':
case 'NOTIF.EXT.ELASTICSEARCH':
case 'NOTIF.EXT.LOGSTASH':
case 'NOTIF.METACONSOLE.DB_CONNECTION':
case 'NOTIF.DOWNTIME':
case 'NOTIF.UPDATEMANAGER.REGISTRATION':
case 'NOTIF.MISC.EVENTSTORMPROTECTION':
case 'NOTIF.MISC.DEVELOPBYPASS':
case 'NOTIF.MISC.FONTPATH':
case 'NOTIF.SECURITY.DEFAULT_PASSWORD':
case 'NOTIF.NEWSLETTER.SUBSCRIPTION':
case 'NOTIF.UPDATEMANAGER.OPENSETUP':
case 'NOTIF.UPDATEMANAGER.UPDATE':
case 'NOTIF.UPDATEMANAGER.MINOR':
case 'NOTIF.CRON.CONFIGURED':
default:
// NOTIF.SERVER.STATUS.
// NOTIF.SERVER.STATUS.ID_SERVER.
// NOTIF.SERVER.QUEUE.ID_SERVER.
// NOTIF.SERVER.MASTER.
// NOTIF.SERVER.STATUS.ID_SERVER.
if (preg_match('/^NOTIF.SERVER/', $data['type']) === true) {
// Component notifications require be inmediate.
$max_age = 0;
}
// Else ignored.
break;
}
// Get previous notification.
$prev = db_get_row(
'tmensajes',
'subtype',
$data['type']
);
if ($prev !== false
&& (time() - $prev['timestamp']) > $max_age
) {
// Clean previous notification.
$this->cleanNotifications($data['type']);
} else if ($prev !== false) {
// Avoid creation. Previous notification is still valid.
// Update message with latest information.
$r = db_process_sql_update(
'tmensajes',
[
'mensaje' => io_safe_input($data['message']),
'subject' => io_safe_input($data['title']),
],
['id_mensaje' => $prev['id_mensaje']]
);
$this->updateTargets($prev, true);
return;
}
if (isset($data['type']) === false) {
$data['type'] = '';
}
// Create notification.
$notification = [];
$notification['timestamp'] = time();
$notification['id_source'] = $source_id;
$notification['mensaje'] = io_safe_input($data['message']);
$notification['subject'] = io_safe_input($data['title']);
$notification['subtype'] = $data['type'];
$notification['url'] = io_safe_input($data['url']);
$id = db_process_sql_insert('tmensajes', $notification);
if ($id === false) {
// Failed to generate notification.
$this->warn('Failed to generate notification');
return;
}
// Update reference to update targets.
$notification['id_mensaje'] = $id;
$this->updateTargets($notification);
}
/**
* Deletes useless notifications.
*
* @param string $subtype Subtype to be deleted.
*
* @return mixed False in case of error or invalid values passed.
* Affected rows otherwise
*/
public function cleanNotifications(string $subtype)
{
$not_count = db_get_value_sql(
sprintf(
'SELECT count(*) as n
FROM tmensajes
WHERE subtype like "%s"',
$subtype
)
);
if ($not_count > 0) {
return db_process_sql_delete(
'tmensajes',
sprintf('subtype like "%s"', $subtype)
);
}
return true;
}
/**
* Check license status and validity.
*
* @return boolean Return true if license is valid, false if not.
*/
public function checkLicense()
{
global $config;
$license = enterprise_hook('license_get_info');
if ($license === ENTERPRISE_NOT_HOOK) {
return false;
}
$days_to_expiry = ((strtotime($license['expiry_date']) - time()) / (60 * 60 * 24));
if (($days_to_expiry <= 15) && ($days_to_expiry > 0)) {
// Warn user if license is going to expire in 15 days or less.
$this->notify(
[
'type' => 'NOTIF.LICENSE_EXPIRATION',
'title' => __('License is going to expire.'),
'message' => __(
'Your license is going to expire in %d days. Please contact sales.',
$days_to_expiry
),
'url' => 'index.php?sec=gsetup&sec2=godmode/setup/license',
]
);
} else if ($days_to_expiry < 0) {
// Warn user, license has expired.
$this->notify(
[
'type' => 'NOTIF.LICENSE.EXPIRATION',
'title' => __('License is expired.'),
'message' => __('Your license has expired. Please contact sales.'),
'url' => 'index.php?sec=gsetup&sec2=godmode/setup/license',
]
);
return false;
} else {
$this->cleanNotifications('NOTIF.LICENSE.EXPIRATION');
}
return true;
}
/**
* Count files in target path.
*
* @param string $path Path to be checked.
* @param string $regex Regular expression to find files.
* @param integer $max_files Maximum number of files to find.
*
* @return integer Number of files in target path.
*/
public function countFiles(
string $path='',
string $regex='',
int $max_files=500
) {
if (empty($path) === true) {
return -1;
}
$nitems = 0;
// Count files up to max_files.
$dir = opendir($path);
if ($dir !== false) {
// Used instead of glob to avoid check directories with
// more than 1M files.
while (false !== ($file = readdir($dir)) && $nitems <= $max_files) {
if ($file != '.' && $file != '..') {
if (empty($regex) === false) {
if (preg_match($regex, $file) === 1) {
$nitems++;
continue;
}
} else {
$nitems++;
}
}
}
closedir($dir);
}
return $nitems;
}
/**
* Check excesive files in attachment directory.
*
* @return void
*/
public function checkAttachment()
{
global $config;
if (is_writable($config['attachment_store']) !== true) {
$this->notify(
[
'type' => 'NOTIF.WRITABLE.ATTACHMENT',
'title' => __('Attachment directory is not writable.'),
'message' => __(
'Directory %s is not writable. Please configure proper permissions.',
$config['attachment_store']
),
'url' => 'index.php?sec=general&sec2=godmode/setup/setup§ion=general',
]
);
return;
} else {
$this->cleanNotifications('NOTIF.WRITABLE.ATTACHMENT');
}
$filecount = $this->countFiles(
$config['attachment_store'],
'',
$config['num_files_attachment']
);
if ($filecount > $config['num_files_attachment']) {
$this->notify(
[
'type' => 'NOTIF.FILES.ATTACHMENT',
'title' => __('There are too much files in attachment directory.'),
'message' => __(
'There are more than %d files in attachment, you should consider cleaning up your attachment directory manually.',
$config['num_files_attachment']
),
'url' => 'index.php?sec=general&sec2=godmode/setup/setup§ion=perf',
]
);
} else {
$this->cleanNotifications('NOTIF.FILES.ATTACHMENT');
}
}
/**
* Check excesive files in data_in directory.
*
* @return void
*/
public function checkDataIn()
{
global $config;
if (enterprise_installed()
&& isset($config['license_nms'])
&& $config['license_nms'] != 1
) {
if (is_readable($config['remote_config']) !== true) {
$this->notify(
[
'type' => 'NOTIF.PERMISSIONS.REMOTE_CONFIG',
'title' => __('Remote configuration directory is not readable.'),
'message' => __(
'Remote configuration directory %s is not readable. Please configure it.',
$config['remote_config']
),
'url' => 'index.php?sec=general&sec2=godmode/setup/setup§ion=general',
]
);
return;
} else {
$this->cleanNotifications(
'NOTIF.PERMISSIONS.REMOTE_CONFIG'
);
}
if (is_writable($config['remote_config'].'/conf') !== true) {
$this->notify(
[
'type' => 'NOTIF.PERMISSIONS.REMOTE_CONFIG.CONF',
'title' => __('Remote configuration directory is not writable.'),
'message' => __(
'Remote configuration directory %s is not writable. Please configure it.',
$config['remote_config'].'/conf'
),
'url' => 'index.php?sec=general&sec2=godmode/setup/setup§ion=general',
]
);
} else {
$this->cleanNotifications(
'NOTIF.PERMISSIONS.REMOTE_CONFIG.CONF'
);
}
if (is_writable($config['remote_config'].'/collections') !== true) {
$this->notify(
[
'type' => 'NOTIF.PERMISSIONS.REMOTE_CONFIG.COLLECTIONS',
'title' => __('Remote collections directory is not writable.'),
'message' => __(
'Collections directory %s is not writable. Please configure it.',
$config['remote_config'].'/collections'
),
'url' => 'index.php?sec=general&sec2=godmode/setup/setup§ion=general',
]
);
} else {
$this->cleanNotifications(
'NOTIF.PERMISSIONS.REMOTE_CONFIG.COLLECTIONS'
);
}
if (is_writable($config['remote_config'].'/md5') !== true) {
$this->notify(
[
'type' => 'NOTIF.PERMISSIONS.REMOTE_CONFIG.MD5',
'title' => __('Remote md5 directory is not writable.'),
'message' => __(
'MD5 directory %s is not writable. Please configure it.',
$config['remote_config'].'/md5'
),
'url' => 'index.php?sec=general&sec2=godmode/setup/setup§ion=general',
]
);
} else {
$this->cleanNotifications(
'NOTIF.PERMISSIONS.REMOTE_CONFIG.MD5'
);
}
} else {
$this->cleanNotifications('NOTIF.PERMISSIONS.REMOTE_CONF%');
}
$MAX_FILES_DATA_IN = 1000;
$MAX_BADXML_FILES_DATA_IN = 150;
$filecount = $this->countFiles(
$config['remote_config'],
'',
$MAX_FILES_DATA_IN
);
// If cannot open directory, count is '-1', skip.
if ($filecount > $MAX_FILES_DATA_IN) {
$this->notify(
[
'type' => 'NOTIF.FILES.DATAIN',
'title' => __('There are too much files in spool').'.',
'message' => __(
'There are more than %d files in %s, you should consider checking DataServer performance',
$MAX_FILES_DATA_IN,
$config['remote_config']
),
'url' => 'index.php?sec=general&sec2=godmode/setup/setup§ion=perf',
]
);
} else {
$this->cleanNotifications('NOTIF.FILES.DATAIN');
}
$filecount = $this->countFiles(
$config['remote_config'],
'/^.*BADXML$/',
$MAX_BADXML_FILES_DATA_IN
);
// If cannot open directory, count is '-1', skip.
if ($filecount > $MAX_BADXML_FILES_DATA_IN) {
$this->notify(
[
'type' => 'NOTIF.FILES.DATAIN.BADXML',
'title' => __('There are too much BADXML files in spool.'),
'message' => __(
'There are more than %d files in %s, you should consider checking software agents.',
$MAX_BADXML_FILES_DATA_IN,
$config['remote_config']
),
'url' => 'index.php?sec=general&sec2=godmode/setup/setup§ion=perf',
]
);
} else {
$this->cleanNotifications('NOTIF.FILES.DATAIN.BADXML');
}
}
/**
* Check growing queues in servers.
*
* @return void
*/
public function checkServers()
{
global $config;
$idx_file = $config['attachment_store'].'/.cron.supervisor.servers.idx';
$MAX_QUEUE = 1500;
$MAX_GROWN = 50;
$queue_state = [];
$previous = [];
$new = [];
if (file_exists($idx_file) === true) {
// Read previous values from file.
$previous = json_decode(file_get_contents($idx_file), true);
}
// DataServer queue status.
$queue_state = db_get_all_rows_sql(
'SELECT id_server,name,server_type,queued_modules,status
FROM tserver ORDER BY 1'
);
$time = time();
if (is_array($queue_state) === true) {
foreach ($queue_state as $queue) {
$key = $queue['id_server'];
$type = $queue['server_type'];
$new_data[$key] = $queue['queued_modules'];
// Compare queue increments in a not over 900 seconds.
if (empty($previous[$key]['modules'])
|| ($time - $previous[$key]['utime']) > 900
) {
$previous[$key]['modules'] = 0;
}
$modules_queued = ($queue['queued_modules'] - $previous[$key]['modules']);
// 50 Modules queued since last check. Or more than 1500 queued.
if ($modules_queued > $MAX_GROWN
|| $queue['queued_modules'] > $MAX_QUEUE
) {
$msg = 'Queue has grown %d modules. Total %d';
if ($modules_queued <= 0) {
$msg = 'Queue is decreasing in %d modules. But there are %d queued.';
$modules_queued *= -1;
}
$this->notify(
[
'type' => 'NOTIF.SERVER.QUEUE.'.$key,
'title' => __(
'%s (%s) performance is being lacked.',
servers_get_server_string_name($type),
$queue['name']
),
'message' => __(
$msg,
$modules_queued,
$queue['queued_modules']
),
'url' => 'index.php?sec=gservers&sec2=godmode/servers/modificar_server&refr=60',
]
);
} else {
$this->cleanNotifications('NOTIF.SERVER.QUEUE.'.$key);
}
$new[$key]['modules'] = $queue['queued_modules'];
$new[$key]['utime'] = $time;
}
// Update file content.
file_put_contents($idx_file, json_encode($new));
} else {
// No queue data, ignore.
unlink($idx_file);
// Clean notifications.
$this->cleanNotifications('NOTIF.SERVER.QUEUE.%');
}
}
/**
* Check Pandora component statuses.
*
* @return void
*/
public function checkPandoraServers()
{
$servers = db_get_all_rows_sql(
'SELECT
id_server,
name,
server_type,
status,
unix_timestamp() - unix_timestamp(keepalive) as downtime
FROM tserver
WHERE
unix_timestamp() - unix_timestamp(keepalive) > server_keepalive
OR status = 0'
);
if ($servers === false) {
$nservers = db_get_value_sql(
'SELECT count(*) as nservers
FROM tserver'
);
if ($nservers == 0) {
$url = 'https://wiki.pandorafms.com/index.php?title=Pandora:Documentation_en:Configuration';
if ($config['language'] == 'es') {
$url = 'https://wiki.pandorafms.com/index.php?title=Pandora:Documentation_es:Configuracion';
}
$this->notify(
[
'type' => 'NOTIF.SERVER.STATUS',
'title' => __('No servers available.'),
'message' => __('There are no servers registered in this console, please check installation guide.'),
'url' => $url,
]
);
}
// At this point there's no servers with issues.
$this->cleanNotifications('NOTIF.SERVER.STATUS%');
return;
}
foreach ($servers as $server) {
if ($server['status'] == 1) {
// Fatal error. Component has die.
$msg = __(
'%s (%s) crashed.',
servers_get_server_string_name($server['server_type']),
$server['name']
);
$description = __(
'%s (%s) has died, please check log files',
servers_get_server_string_name($server['server_type']),
$server['name']
);
} else {
// Non-fatal error. Controlated exit. Component is not running.
$msg = __(
'%s (%s) is stopped.',
servers_get_server_string_name($server['server_type']),
$server['name']
);
$description = __(
'%s (%s) is stopped, please check configuration file or remove this server from server list.',
servers_get_server_string_name($server['server_type']),
$server['name']
);
}
$this->notify(
[
'type' => 'NOTIF.SERVER.STATUS.'.$server['id_server'],
'title' => $msg,
'message' => $description,
'url' => 'index.php?sec=gservers&sec2=godmode/servers/modificar_server&refr=60',
]
);
}
}
/**
* Checks if there's at last one server running in master mode.
*
* @return void
*/
public function checkPandoraServerMasterAvailable()
{
$n_masters = db_get_value_sql(
'SELECT
count(*) as n
FROM tserver
WHERE
unix_timestamp() - unix_timestamp(keepalive) <= server_keepalive
AND master > 0
AND status = 1'
);
if ($n_masters === false) {
// Failed to retrieve server list.
return;
}
if ($n_masters <= 0) {
// No server running in master.
$url = 'https://wiki.pandorafms.com/index.php?title=Pandora:Documentation_en:Configuration#master';
if ($config['language'] == 'es') {
$url = 'https://wiki.pandorafms.com/index.php?title=Pandora:Documentation_es:Configuracion#master';
}
$this->notify(
[
'type' => 'NOTIF.SERVER.MASTER',
'title' => __('No master servers found.'),
'message' => __('You should define at last one server to run as master, please check documentation.'),
'url' => $url,
]
);
} else {
$this->cleanNotifications('NOTIF.SERVER.MASTER%');
}
}
/**
* Checks PHP settings to be correct. Generates system notifications if not.
*
* @return void
*/
public function checkPHPSettings()
{
global $config;
$PHPupload_max_filesize = config_return_in_bytes(
ini_get('upload_max_filesize')
);
// PHP configuration.
$PHPmax_input_time = ini_get('max_input_time');
$PHPmemory_limit = config_return_in_bytes(ini_get('memory_limit'));
$PHPmax_execution_time = ini_get('max_execution_time');
$PHPsafe_mode = ini_get('safe_mode');
$PHPdisable_functions = ini_get('disable_functions');
$PHPupload_max_filesize_min = config_return_in_bytes('800M');
$PHPmemory_limit_min = config_return_in_bytes('500M');
// PhantomJS status.
$result_ejecution = exec($config['phantomjs_bin'].'/phantomjs --version');
// PHP version checks.
$php_version = phpversion();
$php_version_array = explode('.', $php_version);
if ($PHPsafe_mode === '1') {
$this->notify(
[
'type' => 'NOTIF.PHP.SAFE_MODE',
'title' => __('PHP safe mode is enabled. Some features may not properly work.'),
'message' => __('To disable, change it on your PHP configuration file (php.ini) and put safe_mode = Off (Dont forget restart apache process after changes)'),
'url' => 'index.php',
]
);
} else {
$this->cleanNotifications('NOTIF.PHP.SAFE_MODE');
}
if ($PHPmax_input_time !== '-1') {
$this->notify(
[
'type' => 'NOTIF.PHP.INPUT_TIME',
'title' => sprintf(
__("Not recommended '%s' value in PHP configuration"),
'max_input_time'
),
'message' => sprintf(
__('Recommended value is %s'),
'-1 ('.__('Unlimited').')'
).'
'.__('Please, change it on your PHP configuration file (php.ini) or contact with administrator (Dont forget restart apache process after changes)'),
'url' => 'index.php',
]
);
} else {
$this->cleanNotifications('NOTIF.PHP.INPUT_TIME');
}
if ($PHPmax_execution_time !== '0') {
$this->notify(
[
'type' => 'NOTIF.PHP.EXECUTION_TIME',
'title' => sprintf(
__("Not recommended '%s' value in PHP configuration"),
'max_execution_time'
),
'message' => sprintf(
__('Recommended value is: %s'),
'0 ('.__('Unlimited').')'
).'
'.__('Please, change it on your PHP configuration file (php.ini) or contact with administrator (Dont forget restart apache process after changes)'),
'url' => 'index.php',
]
);
} else {
$this->cleanNotifications('NOTIF.PHP.EXECUTION_TIME');
}
if ($PHPupload_max_filesize < $PHPupload_max_filesize_min) {
$this->notify(
[
'type' => 'NOTIF.PHP.UPLOAD_MAX_FILESIZE',
'title' => sprintf(
__("Not recommended '%s' value in PHP configuration"),
'upload_max_filesize'
),
'message' => sprintf(
__('Recommended value is: %s'),
sprintf(__('%s or greater'), '800M')
).'
'.__('Please, change it on your PHP configuration file (php.ini) or contact with administrator (Dont forget restart apache process after changes)'),
'url' => 'index.php',
]
);
} else {
$this->cleanNotifications('NOTIF.PHP.UPLOAD_MAX_FILESIZE');
}
if ($PHPmemory_limit < $PHPmemory_limit_min && $PHPmemory_limit !== '-1') {
$this->notify(
[
'type' => 'NOTIF.PHP.MEMORY_LIMIT',
'title' => sprintf(
__("Not recommended '%s' value in PHP configuration"),
'memory_limit'
),
'message' => sprintf(
__('Recommended value is: %s'),
sprintf(__('%s or greater'), '500M')
).'
'.__('Please, change it on your PHP configuration file (php.ini) or contact with administrator'),
'url' => 'index.php',
]
);
} else {
$this->cleanNotifications('NOTIF.PHP.MEMORY_LIMIT');
}
if (preg_match('/system/', $PHPdisable_functions) || preg_match('/exec/', $PHPdisable_functions)) {
$this->notify(
[
'type' => 'NOTIF.PHP.DISABLE_FUNCTIONS',
'title' => __('Problems with disable functions in PHP.INI'),
'message' => __('Variable disable_functions containts functions system() or exec(), in PHP configuration file (php.ini)').'
'.__('Please, change it on your PHP configuration file (php.ini) or contact with administrator (Dont forget restart apache process after changes)'),
'url' => 'index.php',
]
);
} else {
$this->cleanNotifications('NOTIF.PHP.DISABLE_FUNCTIONS');
}
if (!isset($result_ejecution) || $result_ejecution == '') {
$url = 'https://wiki.pandorafms.com/index.php?title=Pandora:Documentation_en:Configuration#Phantomjs';
if ($config['language'] == 'es') {
$url = 'https://wiki.pandorafms.com/index.php?title=Pandora:Documentation_es:Configuracion#Phantomjs';
}
$this->notify(
[
'type' => 'NOTIF.PHP.PHANTOMJS',
'title' => __('phantomjs is not installed'),
'message' => __('To be able to create images of the graphs for PDFs, please install the phantom.js extension. For that, it is necessary to follow these steps:'),
'url' => $url,
]
);
} else {
$this->cleanNotifications('NOTIF.PHP.PHANTOMJS');
}
if ($php_version_array[0] < 7) {
$url = 'https://wiki.pandorafms.com/index.php?title=Pandora:Documentation_en:_PHP_7';
if ($config['language'] == 'es') {
$url = 'https://wiki.pandorafms.com/index.php?title=Pandora:Documentation_es:Instalaci%C3%B3n_y_actualizaci%C3%B3n_PHP_7';
}
$this->notify(
[
'type' => 'NOTIF.PHP.VERSION',
'title' => __('PHP UPDATE REQUIRED'),
'message' => __('For a correct operation of PandoraFMS, PHP must be updated to version 7.0 or higher.').'
'.__('Otherwise, functionalities will be lost.').'
'."- ".__('Report download in PDF format').'
'."- ".__('Emails Sending').'
- '.__('Metaconsole Collections').'
- ...
',
'url' => $url,
]
);
} else {
$this->cleanNotifications('NOTIF.PHP.VERSION');
}
}
/**
* Checks if history DB is available.
*
* @return void
*/
public function checkPandoraHistoryDB()
{
global $config;
if (isset($config['history_db_enabled'])
&& $config['history_db_enabled'] == 1
) {
if (! isset($config['history_db_connection'])
|| $config['history_db_connection'] === false
) {
ob_start();
$config['history_db_connection'] = db_connect(
$config['history_db_host'],
$config['history_db_name'],
$config['history_db_user'],
io_output_password($config['history_db_pass']),
$config['history_db_port'],
false
);
ob_get_clean();
}
if ($config['history_db_connection'] === false) {
$this->notify(
[
'type' => 'NOTIF.HISTORYDB',
'title' => __('Historical database not available'),
'message' => __('Historical database is enabled. But not available using given configuration. Please check it.'),
'url' => 'index.php?sec=general&sec2=godmode/setup/setup§ion=hist_db',
]
);
} else {
$this->cleanNotifications('NOTIF.HISTORYDB');
}
} else {
$this->cleanNotifications('NOTIF.HISTORYDB');
}
}
/**
* Check if pandora_db is running in all available DB instances.
* Generating notifications.
*
* @return void
*/
public function checkPandoraDBMaintenance()
{
global $config;
// Main DB db_maintenance value.
$db_maintance = db_get_value(
'value',
'tconfig',
'token',
'db_maintance'
);
// If never was executed, it means we are in the first Pandora FMS execution. Set current timestamp.
if (empty($db_maintance)) {
config_update_value('db_maintance', date('U'));
}
$last_maintance = (date('U') - $db_maintance);
// Limit 48h.
if ($last_maintance > 172800) {
$this->notify(
[
'type' => 'NOTIF.PANDORADB',
'title' => __('Database maintance problem'),
'message' => __(
'Your database is not maintained correctly. It seems that more than 48hrs have passed without proper maintenance. Please review documents of %s on how to perform this maintenance process (DB Tool) and enable it as soon as possible.',
io_safe_output(get_product_name())
),
'url' => 'index.php?sec=general&sec2=godmode/setup/setup§ion=perf',
]
);
} else {
$this->cleanNotifications('NOTIF.PANDORADB');
}
if (isset($config['history_db_enabled'])
&& $config['history_db_enabled'] == 1
) {
// History DB db_maintenance value.
$db_maintenance = db_get_value(
'value',
'tconfig',
'token',
'db_maintenance',
true
);
// History db connection is supossed to be enabled since we use
// db_get_value, wich initializes target db connection.
if (empty($db_maintance)) {
$sql = sprintf(
'UPDATE tconfig SET `value`=%d WHERE `token`="%s"',
date('U'),
'db_maintenance'
);
$affected_rows = db_process_sql(
$sql,
$rettype = 'affected_rows',
$dbconnection = $config['history_db_connection']
);
if ($affected_rows == 0) {
// Failed to update. Maybe the row does not exist?
$sql = sprintf(
'INSERT INTO tconfig(`token`,`value`) VALUES("%s",%d)',
'db_maintenance',
date('U')
);
$affected_rows = db_process_sql(
$sql,
$rettype = 'affected_rows',
$dbconnection = $config['history_db_connection']
);
}
}
$last_maintance = (date('U') - $db_maintance);
// Limit 48h.
if ($last_maintance > 172800) {
$this->notify(
[
'type' => 'NOTIF.PANDORADB.HISTORY',
'title' => __(
'Historical database maintance problem.'
),
'message' => __('Your historical database is not being maintained correctly. It seems that more than 48hrs have passed without proper maintenance. Please review documents of %s on how to perform this maintenance process (DB Tool) and enable it as soon as possible.', get_product_name()),
'url' => 'index.php?sec=general&sec2=godmode/setup/setup§ion=perf',
]
);
} else {
// Historical db working fine.
$this->cleanNotifications('NOTIF.PANDORADB.HISTORY');
}
} else {
// Disabled historical db.
$this->cleanNotifications('NOTIF.PANDORADB.HISTORY');
}
}
/**
* Check MR package applied in historical DB
*
* @return void
*/
public function checkPandoraHistoryDBMR()
{
global $config;
if (isset($config['history_db_enabled'])
&& $config['history_db_enabled'] == 1
) {
$mrh_version = db_get_value(
'value',
'tconfig',
'token',
'MR',
true
);
if ($mrh_version != $config['MR']) {
$this->notify(
[
'type' => 'NOTIF.HISTORYDB.MR',
'title' => __('Historical database MR missmatch'),
'message' => __('Your historical database is not using the same schema of main DB. This could produce anomalyes while storing historical data.'),
'url' => 'index.php?sec=general&sec2=godmode/setup/setup§ion=hist_db',
]
);
} else {
// MR version OK.
$this->cleanNotifications('NOTIF.HISTORYDB.MR');
}
} else {
// Disabled historical db.
$this->cleanNotifications('NOTIF.HISTORYDB.MR');
}
}
/**
* Check if elasticsearch is available.
*
* @return void
*/
public function checkExternalComponents()
{
global $config;
// Cannot check logstash, configuration is only available from server.
// Cannot check selenium, configuration is only available from server.
if (isset($config['log_collector'])
&& $config['log_collector'] == 1
) {
$elasticsearch = @fsockopen(
$config['elasticsearch_ip'],
$config['elasticsearch_port'],
$errno,
$errstr,
5
);
if ($elasticsearch === false) {
$this->notify(
[
'type' => 'NOTIF.EXT.ELASTICSEARCH',
'title' => __('Log collector cannot connect to ElasticSearch'),
'message' => __('ElasticSearch is not available using current configuration. Please check it.'),
'url' => 'index.php?sec=general&sec2=godmode/setup/setup§ion=log',
]
);
} else {
fclose($elasticsearch);
$this->cleanNotifications('NOTIF.EXT.ELASTICSEARCH');
}
} else {
$this->cleanNotifications('NOTIF.EXT.ELASTICSEARCH');
}
}
/**
* Checks if metaconsole DB connection is ready.
*
* @return void
*/
public function checkMetaconsole()
{
global $config;
$check_ok = true;
if (license_free()
&& is_metaconsole() === false
&& isset($config['node_metaconsole'])
&& $config['node_metaconsole'] == 1
) {
// Check if node is successfully registered in MC.
$server_name = db_get_value(
'distinct(name)',
'tserver',
'server_type',
1
);
$mc_db_conn = enterprise_hook(
'metaconsole_load_external_db',
[
[
'dbhost' => $config['replication_dbhost'],
'dbuser' => $config['replication_dbuser'],
'dbpass' => io_output_password(
$config['replication_dbpass']
),
'dbname' => $config['replication_dbname'],
],
]
);
if ($mc_db_conn === NOERR) {
$check_ok = true;
} else {
$check_ok = false;
}
// Restore the default connection.
enterprise_hook('metaconsole_restore_db');
}
if ($check_ok === true) {
$this->cleanNotifications('NOTIF.METACONSOLE.DB_CONNECTION');
} else {
$this->notify(
[
'type' => 'NOTIF.METACONSOLE.DB_CONNECTION',
'title' => __('Metaconsole DB is not available.'),
'message' => __('Cannot connect with Metaconsole DB using stored configuration. Please check it.'),
'url' => 'index.php?sec=general&sec2=godmode/setup/setup§ion=enterprise',
]
);
}
}
/**
* Check if there are any incoming scheduled downtime in less than 15d.
*
* @return void
*/
public function checkDowntimes()
{
// 15 Days.
$THRESHOLD_SECONDS = (15 * 3600 * 24);
// Check first if any planned runtime is running.
$currently_running = (int) db_get_value_sql(
'SELECT count(*) as "n" FROM tplanned_downtime
WHERE executed = 1'
);
if ($currently_running > 0) {
$this->notify(
[
'type' => 'NOTIF.DOWNTIME',
'title' => __('Scheduled downtime running.'),
'message' => __('A scheduled downtime is running. Some monitorization data won\'t be available while downtime is taking place.'),
'url' => 'index.php?sec=gagente&sec2=godmode/agentes/planned_downtime.list',
]
);
return;
} else {
// Retrieve downtimes.
$downtimes = db_get_all_rows_sql(
'SELECT * FROM tplanned_downtime
WHERE
(type_execution="once" AND date_from > now())
OR type_execution!="once" ORDER BY `id` DESC'
);
// Initialize searchers.
$next_downtime_begin = PHP_INT_MAX;
$now = time();
if ($downtimes === false) {
$this->cleanNotifications('NOTIF.DOWNTIME');
return;
}
$weekdays = [
'monday',
'tuesday',
'wednesday',
'thursday',
'friday',
'saturday',
'sunday',
];
foreach ($downtimes as $dt) {
if ($dt['type_execution'] == 'once'
&& ($dt['date_from'] - $now) < $THRESHOLD_SECONDS
) {
if ($next_downtime_begin > $dt['date_from']) {
// Store datetime for next downtime.
$next_downtime_begin = $dt['date_from'];
$next_downtime_end = $dt['date_to'];
}
} else if ($dt['type_periodicity'] == 'monthly') {
$schd_time_begin = explode(
':',
$dt['periodically_time_from']
);
$schd_time_end = explode(
':',
$dt['periodically_time_to']
);
$begin = mktime(
// Hour.
$schd_time_begin[0],
// Minute.
$schd_time_begin[1],
// Second.
$schd_time_begin[2],
// Month.
date('n', $now),
// Day.
$dt['periodically_day_from'],
// Year.
date('Y', $now)
);
$end = mktime(
// Hour.
$schd_time_end[0],
// Minute.
$schd_time_end[1],
// Second.
$schd_time_end[2],
// Month.
date('n', $now),
// Day.
$dt['periodically_day_to'],
// Year.
date('Y', $now)
);
if ($next_downtime_begin > $begin) {
$next_downtime_begin = $begin;
$next_downtime_end = $end;
}
} else if ($dt['type_periodicity'] == 'weekly') {
// Always applies.
$current_week_day = date('N', $now);
$schd_time_begin = explode(
':',
$dt['periodically_time_from']
);
$schd_time_end = explode(
':',
$dt['periodically_time_to']
);
$i = 0;
$max = 7;
while ($dt[$weekdays[(($current_week_day + $i) % 7)]] != 1
&& $max-- >= 0
) {
// Calculate day of the week matching downtime
// definition.
$i++;
}
if ($max < 0) {
// No days set.
continue;
}
// Calculate utimestamp.
$begin = mktime(
// Hour.
$schd_time_begin[0],
// Minute.
$schd_time_begin[1],
// Second.
$schd_time_begin[2],
// Month.
date('n', $now),
// Day.
(date('j', $now) + $i + 1),
// Year.
date('Y', $now)
);
$end = mktime(
// Hour.
$schd_time_end[0],
// Minute.
$schd_time_end[1],
// Second.
$schd_time_end[2],
// Month.
date('n', $now),
// Day.
(date('j', $now) + $i + 1),
// Year.
date('Y', $now)
);
if ($next_downtime_begin > $begin) {
$next_downtime_begin = $begin;
$next_downtime_end = $end;
}
}
}
if ($next_downtime_begin != PHP_INT_MAX) {
$this->notify(
[
'type' => 'NOTIF.DOWNTIME',
'title' => __('Downtime scheduled soon.'),
'message' => __(
'A scheduled downtime is going to be executed from %s to %s. Some monitorization data won\'t be available while downtime is taking place.',
date('M j, G:i:s ', $next_downtime_begin),
date('M j, G:i:s ', $next_downtime_end)
),
'url' => 'index.php?sec=gagente&sec2=godmode/agentes/planned_downtime.list',
]
);
return;
} else {
$this->cleanNotifications('NOTIF.DOWNTIME');
}
}
}
/**
* Check if current instance of Pandora FMS is registered in Update Manager.
*
* @return void
*/
public function checkUpdateManagerRegistration()
{
global $config;
$login = get_parameter('login', false);
if (license_free() === true
&& users_is_admin($config['id_user']) === true
) {
$login = get_parameter('login', false);
// Registration advice.
if ((isset($config['instance_registered']) === true
|| ($config['instance_registered'] != 1)) && ($login === false)
) {
$this->notify(
[
'type' => 'NOTIF.UPDATEMANAGER.REGISTRATION',
'title' => __('This instance is not registered in the Update manager'),
'message' => __('Click here to start the registration process'),
'url' => 'javascript: force_run_register();',
]
);
} else {
$this->cleanNotifications('NOTIF.UPDATEMANAGER.REGISTRATION');
}
} else {
$this->cleanNotifications('NOTIF.UPDATEMANAGER.REGISTRATION');
}
}
/**
* Check if instance is subscribed to newsletter.
*
* @return void
*/
public function checkNewsletterSubscription()
{
global $config;
$login = get_parameter('login', false);
// Newsletter advice.
$newsletter = db_get_value(
'middlename',
'tusuario',
'id_user',
$config['id_user']
);
if (license_free() === true
&& $newsletter != 1
&& $login === false
) {
$this->notify(
[
'type' => 'NOTIF.NEWSLETTER.SUBSCRIPTION',
'title' => __('Not subscribed to the newsletter'),
'message' => __('Click here to start the newsletter subscription process'),
'url' => 'javascript: force_run_newsletter();',
]
);
} else {
$this->cleanNotifications('NOTIF.NEWSLETTER.SUBSCRIPTION');
}
}
/**
* Check if user 'admin' is enabled and using default password.
*
* @return void
*/
public function checkDefaultPassword()
{
global $config;
// Check default password for "admin".
$admin_with_default_pass = db_get_value_sql(
'SELECT count(*) FROM tusuario
WHERE
id_user="admin"
AND password="1da7ee7d45b96d0e1f45ee4ee23da560"
AND is_admin=1
and disabled!=1'
);
if ($admin_with_default_pass > 0) {
$this->notify(
[
'type' => 'NOTIF.SECURITY.DEFAULT_PASSWORD',
'title' => __('Default password for "Admin" user has not been changed.'),
'message' => __('Please change the default password because is a common vulnerability reported.'),
'url' => 'index.php?sec=gusuarios&sec2=godmode/users/user_list',
]
);
} else {
$this->cleanNotifications('NOTIF.SECURITY.DEFAULT_PASSWORD');
}
}
/**
* Undocumented function
*
* @return void
*/
public function checkFont()
{
global $config;
if (($config['fontpath'] == '')
|| (file_exists($config['fontpath']) === false)
) {
$this->notify(
[
'type' => 'NOTIF.MISC.FONTPATH',
'title' => __('Default font doesnt exist'),
'message' => __('Your defined font doesnt exist or is not defined. Please check font parameters in your config'),
'url' => 'index.php?sec=gsetup&sec2=godmode/setup/setup§ion=vis',
]
);
} else {
$this->cleanNotifications('NOTIF.MISC.FONTPATH');
}
}
/**
* Checks if develop_bypass is enabbled.
*
* @return void
*/
public function checkDevelopBypass()
{
global $develop_bypass;
if ($develop_bypass == 1) {
$this->notify(
[
'type' => 'NOTIF.MISC.DEVELOPBYPASS',
'title' => __('Developer mode is enabled'),
'message' => __(
'Your %s has the "develop_bypass" mode enabled. This is a developer mode and should be disabled in a production system. This value is written in the main index.php file',
get_product_name()
),
'url' => 'index.php',
]
);
} else {
$this->cleanNotifications('NOTIF.MISC.DEVELOPBYPASS');
}
}
/**
* Check if event storm protection is enabled.
*
* @return void
*/
public function checkEventStormProtection()
{
global $config;
if ($config['event_storm_protection']) {
$this->notify(
[
'type' => 'NOTIF.MISC.EVENTSTORMPROTECTION',
'title' => __('Event storm protection is activated.'),
'message' => __('You need to restart server after altering this configuration setting. No events will be generated during this mode.'),
'url' => 'index.php?sec=gsetup&sec2=godmode/setup/setup§ion=general',
]
);
} else {
$this->cleanNotifications('NOTIF.MISC.EVENTSTORMPROTECTION');
}
}
/**
* Check if there're new updates available.
*
* @return void
*/
public function checkUpdates()
{
global $config;
if (isset($_SESSION['new_update'])) {
if (!empty($_SESSION['return_installation_open'])) {
if (!$_SESSION['return_installation_open']['return']) {
foreach ($_SESSION['return_installation_open']['text'] as $message) {
$this->notify(
[
'type' => 'NOTIF.UPDATEMANAGER.OPENSETUP',
'title' => __('Error, first setup "Open update".'),
'message' => $message,
'url' => 'index.php?sec=gsetup&sec2=godmode/setup/setup§ion=general',
]
);
}
} else {
$this->cleanNotifications('NOTIF.UPDATEMANAGER.OPENSETUP');
}
} else {
$this->cleanNotifications('NOTIF.UPDATEMANAGER.OPENSETUP');
}
if ($_SESSION['new_update'] == 'new') {
$this->notify(
[
'type' => 'NOTIF.UPDATEMANAGER.UPDATE',
'title' => __(
'New %s Console update',
get_product_name()
),
'message' => __('There is a new update available. Please go to Administration:Setup:Update Manager for more details.'),
'url' => 'index.php?sec=gsetup&sec2=godmode/update_manager/update_manager&tab=online',
]
);
} else {
$this->cleanNotifications('NOTIF.UPDATEMANAGER.UPDATE');
}
} else {
$this->cleanNotifications('NOTIF.UPDATEMANAGER.OPENSETUP');
$this->cleanNotifications('NOTIF.UPDATEMANAGER.UPDATE');
}
}
/**
* Check if there're minor updates available.
*
* @return void
*/
public function checkMinorRelease()
{
global $config;
$check_minor_release_available = db_check_minor_relase_available();
if ($check_minor_release_available) {
$url = 'http://wiki.pandorafms.com/index.php?title=Pandora:Documentation_en:Anexo_Upgrade#Version_7.0NG_.28_Rolling_Release_.29';
if ($config['language'] == 'es') {
$url = 'http://wiki.pandorafms.com/index.php?title=Pandora:Documentation_es:Actualizacion#Versi.C3.B3n_7.0NG_.28_Rolling_Release_.29';
}
$this->notify(
[
'type' => 'NOTIF.UPDATEMANAGER.MINOR',
'title' => __('Minor release/s available'),
'message' => __(
'There are one or more minor releases waiting for update. .About minor release update.',
$url
),
'url' => $url,
]
);
} else {
$this->cleanNotifications('NOTIF.UPDATEMANAGER.MINOR');
}
}
/**
* Check if CRON utility has been configured.
*
* @return void
*/
public function checkCronRunning()
{
global $config;
// Check if DiscoveryCronTasks is running. Warn user if not.
if ($config['cron_last_run'] == 0
|| (get_system_time() - $config['cron_last_run']) > 3600
) {
$message_conf_cron = __('DiscoveryConsoleTasks is not running properly');
if (strtoupper(substr(PHP_OS, 0, 3)) != 'WIN') {
$message_conf_cron .= __('Discovery relies on a proper setup of cron, the time-based scheduling service');
$message_conf_cron .= '. '.__('Please, add the following line to your crontab file:');
$message_conf_cron .= '* * * * * <user> wget -q -O - --no-check-certificate ';
$message_conf_cron .= str_replace(
ENTERPRISE_DIR.'/meta/',
'',
ui_get_full_url(false)
);
$message_conf_cron .= ENTERPRISE_DIR.'/'.EXTENSIONS_DIR;
$message_conf_cron .= '/cron/cron.php >> ';
$message_conf_cron .= $config['homedir'].'/pandora_console.log';
}
if (isset($config['cron_last_run']) === true) {
$message_conf_cron .= __('Last execution').': ';
$message_conf_cron .= date('Y/m/d H:i:s', $config['cron_last_run']);
$message_conf_cron .= __('Please check process is no locked.');
}
$this->notify(
[
'type' => 'NOTIF.CRON.CONFIGURED',
'title' => __('DiscoveryConsoleTasks is not configured.'),
'message' => __($message_conf_cron),
'url' => 'index.php?extension_in_menu=gservers&sec=extensions&sec2=enterprise/extensions/cron',
]
);
} else {
$this->cleanNotifications('NOTIF.CRON.CONFIGURED');
}
}
}