* * * * * <user> wget -q -O - --no-check-certificate --load-cookies /tmp/cron-session-cookies --save-cookies /tmp/cron-session-cookies --keep-session-cookies ';
- $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 >>
';
+ if (enterprise_installed()) {
+ $message_conf_cron .= '* * * * * <user> wget -q -O - --no-check-certificate --load-cookies /tmp/cron-session-cookies --save-cookies /tmp/cron-session-cookies --keep-session-cookies ';
+ $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 >>
';
+ } else {
+ $message_conf_cron .= '* * * * * <user> wget -q -O - --no-check-certificate --load-cookies /tmp/cron-session-cookies --save-cookies /tmp/cron-session-cookies --keep-session-cookies ';
+ $message_conf_cron .= ui_get_full_url(false).'cron.php >>
';
+ }
+
$message_conf_cron .= $config['homedir'].'/log/cron.log';
}
diff --git a/pandora_console/include/class/DiscoveryConsoleTask.php b/pandora_console/include/class/DiscoveryConsoleTask.php
new file mode 100644
index 0000000000..b0bd4846e9
--- /dev/null
+++ b/pandora_console/include/class/DiscoveryConsoleTask.php
@@ -0,0 +1,345 @@
+ 0) {
+ $console_exists = db_get_row('tconsole', 'id_console', $config['id_console']);
+ if ($console_exists === false) {
+ db_process_sql_insert(
+ 'tconsole',
+ [
+ 'id_console' => $config['id_console'],
+ 'description' => $config['console_description'],
+ 'version' => $pandora_version,
+ 'console_type' => ($config['reporting_console_node'] === true) ? 1 : 0,
+ 'timezone' => $config['timezone'],
+ 'public_url' => $config['public_url'],
+ ]
+ );
+ } else {
+ db_process_sql_update(
+ 'tconsole',
+ [
+ 'description' => $config['console_description'],
+ 'timezone' => $config['timezone'],
+ 'public_url' => $config['public_url'],
+ 'console_type' => (int) $config['reporting_console_node'],
+ 'version' => $pandora_version,
+ ],
+ [
+ 'id_console' => $config['id_console'],
+ ]
+ );
+ }
+ }
+
+ // Maintenance task: schedule daily task to manage GoTTY processes if not defined yet.
+ // Must do at every Cron execution.
+ $gotty_ssh_enabled = (bool) $config['gotty_ssh_enabled'];
+ $gotty_telnet_enabled = (bool) $config['gotty_telnet_enabled'];
+
+ if ($gotty_ssh_enabled === true || $gotty_telnet_enabled === true) {
+ // Create necessary data in task tables when some method of GoTTY is enabled in setup.
+ if ((bool) $config['enterprise_installed'] === false) {
+ $call_func_user_task_id = db_get_value_sql('SELECT id FROM `tuser_task` WHERE `function_name` = "cron_task_call_user_function"');
+ if ($call_func_user_task_id === false) {
+ db_process_sql("INSERT INTO `tuser_task` (`function_name`, `parameters`, `name`) VALUES ('cron_task_call_user_function','a:1:{i:0;a:2:{s:11:\"description\";s:13:\"Function name\";s:4:\"type\";s:4:\"text\";}}','Call PHP function')");
+ }
+ }
+
+ $user_function_task_id = db_get_value_sql('SELECT id FROM `tuser_task_scheduled` WHERE `args` LIKE "%cron_task_start_gotty%"');
+
+ if ($user_function_task_id === false) {
+ // Schedule task to manage GoTTY processes daily if it is not scheduled yet.
+ $this->schedule(
+ 'cron_task_call_user_function',
+ [
+ 0 => 'cron_task_start_gotty',
+ 'function_name' => 'cron_task_start_gotty',
+ 'internal' => 1,
+ ],
+ 'daily',
+ 0,
+ 0,
+ strtotime('tomorrow')
+ );
+ }
+ }
+
+ // Maintenance task: check whether start GoTTY SSH and Telnet processes are running and start otherwise.
+ // Must do at every Cron execution.
+ cron_task_start_gotty(false);
+
+ // Do not output anything until is completed. There're session
+ // operations inside cron_task_run function.
+ ob_start();
+
+ if (cron_task_lock() === false) {
+ // Cannot continue. Locked.
+ echo ob_get_clean();
+ exit;
+ }
+
+ $time = get_system_time();
+ $scheduled_tasks = db_get_all_rows_in_table('tuser_task_scheduled');
+ if (!$scheduled_tasks) {
+ $scheduled_tasks = [];
+ }
+
+ /*
+ Watch out! First_execution corresponds to next_execution the name
+ of the bbdd is maintained to ensure integrity.
+ */
+
+ foreach ($scheduled_tasks as $task) {
+ $params = unserialize($task['args']);
+ if ($this->shouldTaskRun($task) === false) {
+ continue;
+ }
+
+ if ($task['scheduled'] == 'no') {
+ if (($params['first_execution']) < $time) {
+ echo date('Y/m/d H:i:s').' Execute once time cron task: ';
+ echo $task['id'];
+ echo "\n\n";
+ cron_task_run($task['id']);
+ // The task was not scheduled and was executed once.
+ db_process_sql_delete(
+ 'tuser_task_scheduled',
+ ['id' => $task['id']]
+ );
+ }
+ } else {
+ if (($params['first_execution']) < $time) {
+ echo date('Y/m/d H:i:s').' EXECUTED CRON TASK: '.$task['id'];
+ echo "\n";
+ echo "\n";
+ cron_task_run($task['id']);
+ }
+ }
+ }
+
+ // Dump to output.
+ echo ob_get_clean();
+
+ // Release the lock.
+ cron_task_release_lock();
+
+ }
+
+
+ /**
+ * Schedules a discovery console task to be executed by cron.
+ *
+ * @param string $function_name Name of the function:
+ * cron_task_generate_report
+ * cron_task_generate_report_by_template
+ * cron_task_save_report_to_disk
+ * cron_task_do_backup
+ * cron_task_execute_custom_script
+ * cron_task_save_xml_report_to_disk
+ * cron_task_feedback_send_mail
+ * cron_task_generate_csv_log.
+ * @param array $arguments Task execution arguments (if needed).
+ * @param string $schedule Task schedule options:
+ * 'no',
+ * 'hourly',
+ * 'daily',
+ * 'weekly',
+ * 'monthly',
+ * 'yearly',
+ * 'custom'.
+ * @param integer $group_id Group id (0 => all).
+ * @param string|null $id_user User id, if null, current user.
+ * @param integer|null $time_start When to start, if null, now.
+ *
+ * @return boolean Sucessfully scheduled or not.
+ */
+ public function schedule(
+ string $function_name,
+ array $arguments=[],
+ string $schedule='no',
+ int $group_id=0,
+ ?string $id_user=null,
+ ?int $time_start=null
+ ) {
+ global $config;
+
+ if ($id_user === null) {
+ $id_user = $config['id_user'];
+ }
+
+ $idUserTask = db_get_value(
+ 'id',
+ 'tuser_task',
+ 'function_name',
+ $function_name
+ );
+
+ if ($idUserTask === false) {
+ // Failed to identify function.
+ return false;
+ }
+
+ if (in_array($schedule, self::SCHEDULES) === false) {
+ // Failed to schedule. Not a valid schedule option.
+ return false;
+ }
+
+ if ($time_start === null) {
+ $time_start = strtotime('now');
+ }
+
+ // Params for send mail with cron.
+ $parameters = array_merge(
+ $arguments,
+ [ 'first_execution' => $time_start ]
+ );
+
+ // Values insert task cron.
+ $task = [
+ 'id_usuario' => $id_user,
+ 'id_user_task' => $idUserTask,
+ 'args' => serialize($parameters),
+ 'scheduled' => $schedule,
+ 'id_grupo' => $group_id,
+ ];
+
+ $result = db_process_sql_insert(
+ 'tuser_task_scheduled',
+ $task
+ );
+
+ return ($result !== false);
+ }
+
+
+}
diff --git a/pandora_console/include/functions_config.php b/pandora_console/include/functions_config.php
index 28f5f695cd..f2579fe53a 100644
--- a/pandora_console/include/functions_config.php
+++ b/pandora_console/include/functions_config.php
@@ -1497,7 +1497,6 @@ function config_update_config()
$interval_values = implode(',', $interval_values_array);
}
- hd($interval_values, true);
if (config_update_value('interval_values', $interval_values, true) === false) {
$error_update[] = __('Delete interval');
}
@@ -2034,20 +2033,6 @@ function config_update_config()
}
break;
- case 'websocket_engine':
- if (config_update_value('ws_bind_address', get_parameter('ws_bind_address'), true) === false) {
- $error_update[] = __('WebSocket bind address');
- }
-
- if (config_update_value('ws_port', get_parameter('ws_port'), true) === false) {
- $error_update[] = __('WebSocket port');
- }
-
- if (config_update_value('ws_proxy_url', get_parameter('ws_proxy_url'), true) === false) {
- $error_update[] = __('WebSocket proxy url');
- }
- break;
-
default:
// Ignore.
break;
@@ -2504,6 +2489,18 @@ function config_process_config()
config_update_value('2Fa_auth', '');
}
+ if (!isset($config['gotty_ssh_enabled'])) {
+ config_update_value('gotty_ssh_enabled', 1);
+ }
+
+ if (!isset($config['gotty_telnet_enabled'])) {
+ config_update_value('gotty_telnet_enabled', 0);
+ }
+
+ if (!isset($config['gotty_port'])) {
+ config_update_value('gotty_port', 8080);
+ }
+
if (isset($config['performance_variables_control']) === false) {
config_update_value(
'performance_variables_control',
diff --git a/pandora_console/include/functions_cron.php b/pandora_console/include/functions_cron.php
index 2eafd8dccb..711ed7f6ba 100644
--- a/pandora_console/include/functions_cron.php
+++ b/pandora_console/include/functions_cron.php
@@ -463,7 +463,6 @@ function cron_list_table()
);
$defined_tasks = db_get_all_rows_sql($sql);
-
if (!check_acl($config['id_user'], 0, 'PM')) {
$read_tasks = [];
foreach ($defined_tasks as $task) {
diff --git a/pandora_console/include/functions_cron_task.php b/pandora_console/include/functions_cron_task.php
new file mode 100644
index 0000000000..ffc5958d85
--- /dev/null
+++ b/pandora_console/include/functions_cron_task.php
@@ -0,0 +1,542 @@
+ time())
+ ) {
+ // Locked!
+ return false;
+ }
+ }
+
+ // Try to get a lock from DB.
+ $dblock = db_get_lock($config['dbname'].'.'.$lockfile);
+ if ($dblock !== 1) {
+ // Locked!
+ return false;
+ }
+
+ // Store PID in lock file.
+ $PID = getmypid();
+ echo 'CRON running ['.$PID."]\n";
+ file_put_contents($lock, $PID);
+ return true;
+}
+
+
+/**
+ * Check if CRON.task is available to start.
+ *
+ * @return boolean True, available. False not available.
+ */
+function cron_task_lock()
+{
+ return cron_lock('cron.lock');
+}
+
+/**
+ * Release CRON.task lock
+ *
+ * @return void
+ */
+function cron_task_release_lock()
+{
+ global $config;
+
+ // Release DB lock.
+ $dblock = db_release_lock($config['dbname'].'.cron.lock');
+ unlink($config['attachment_store'].'/cron.lock');
+}
+
+/**
+ * Calculates target schedule time
+ *
+ * @param string $scheduled_time Desired scheduled time.
+ * @param integer $custom_data Custom scheduled time.
+ * @param integer|null $timestamp Custom timestamp.
+ *
+ * @return integer amount of time.
+ */
+function cron_get_scheduled_time(
+ string $scheduled_time,
+ int $custom_data=0,
+ $timestamp=null
+) {
+ if ($scheduled_time == 'no') {
+ return 0;
+ }
+
+ if ($scheduled_time == 'hourly') {
+ return SECONDS_1HOUR;
+ }
+
+ if ($scheduled_time == 'daily') {
+ return SECONDS_1DAY;
+ }
+
+ if ($scheduled_time == 'weekly') {
+ return SECONDS_1WEEK;
+ }
+
+ if ($scheduled_time == 'monthly') {
+ $month = (($timestamp === null) ? date('m') : date('m', $timestamp));
+ $year = (($timestamp === null) ? date('Y') : date('Y', $timestamp));
+
+ $days_month = (cal_days_in_month(
+ CAL_GREGORIAN,
+ $month,
+ $year
+ ) * SECONDS_1DAY);
+
+ return $days_month;
+ }
+
+ if ($scheduled_time == 'yearly') {
+ return SECONDS_1YEAR;
+ }
+
+ if ($scheduled_time == 'custom') {
+ return $custom_data;
+ }
+
+ return 0;
+}
+
+/**
+ * Run scheduled task.
+ *
+ * @param integer $id_user_task Task to be run.
+ * @param boolean $force_run Force run.
+ *
+ * @return void
+ */
+function cron_task_run(
+ int $id_user_task,
+ bool $force_run=false
+) {
+ global $config;
+
+ if (isset($config['id_console']) === true && $config['id_console'] > 0) {
+ $sql = sprintf(
+ 'SELECT *
+ FROM tuser_task_scheduled
+ WHERE id=%d AND id_console IN (0, %d)',
+ $id_user_task,
+ $config['id_console']
+ );
+
+ $task_scheduled = db_get_row_sql($sql);
+
+ if ($task_scheduled !== false) {
+ db_process_sql_update(
+ 'tconsole',
+ ['last_execution' => time()],
+ ['id_console' => $config['id_console']]
+ );
+ }
+ } else {
+ $filter = [
+ 'id' => $id_user_task,
+ 'id_console' => 0,
+ ];
+
+ $task_scheduled = db_get_row_filter('tuser_task_scheduled', $filter, false);
+ }
+
+ $args = unserialize($task_scheduled['args']);
+
+ if ((bool) $config['enterprise_installed'] === false
+ && isset($args['function_name']) === true
+ && $args['function_name'] !== 'cron_task_start_gotty'
+ ) {
+ // Only cron_task_start_gotty is allowed to run in non enterprise environments.
+ return;
+ }
+
+ if ((bool) $config['enterprise_installed'] === true) {
+ $task = db_get_row('tuser_task', 'id', $task_scheduled['id_user_task']);
+ } else {
+ $task = [
+ 'name' => 'Call PHP function',
+ 'function_name' => 'cron_task_call_user_function',
+ ];
+ }
+
+ // Register shutdown function in case of fatal error, like.
+ register_shutdown_function('cron_task_handle_error', $task_scheduled, $task, $force_run);
+
+ if (is_metaconsole() && !defined('METACONSOLE')) {
+ define('METACONSOLE', 1);
+ }
+
+ if (! function_exists($task['function_name'])) {
+ return;
+ }
+
+ // If the task is disable, not run.
+ if ((bool) $task_scheduled['enabled'] === false) {
+ return;
+ }
+
+ if (session_status() === PHP_SESSION_DISABLED) {
+ return;
+ }
+
+ $old_user = '';
+ if (isset($config['id_user']) === false) {
+ $config['id_user'] = $task_scheduled['id_usuario'];
+ }
+
+ $old_user = $config['id_user'];
+
+ $old_session_id = session_id();
+ $new_session_id = 'cron-'.uniqid();
+
+ // Simulate user login.
+ session_id($new_session_id);
+ session_start();
+ $_SESSION['id_usuario'] = $config['id_user'];
+ session_write_close();
+
+ set_time_limit(0);
+
+ if ($task['function_name'] == 'cron_task_generate_report_by_template'
+ || $task['function_name'] == 'cron_task_generate_report'
+ ) {
+ // If empty agent position, add it.
+ if (!isset($args[1])) {
+ array_splice($args, 1, 0, '');
+ }
+
+ $args[] = $task_scheduled['scheduled'];
+ }
+
+ call_user_func_array(
+ $task['function_name'],
+ array_merge(array_values(($args ?? [])), [$id_user_task])
+ );
+
+ if (session_status() === PHP_SESSION_ACTIVE) {
+ @session_destroy();
+ }
+
+ session_id($old_session_id);
+ session_start();
+
+ $config['id_user'] = $old_user;
+ $sql = '';
+ $sql2 = '';
+
+ if (!$force_run) {
+ $period = cron_get_scheduled_time(
+ $task_scheduled['scheduled'],
+ $task_scheduled['custom_data']
+ );
+ $old_args = unserialize($task_scheduled['args']);
+ if ($period > 3600) {
+ $array_explode = explode(
+ ':',
+ date('H:i', $old_args['first_execution'])
+ );
+ $hora_en_segundos = (($array_explode[0] * 3600 ) + ($array_explode[1] * 60));
+
+ $array_explode_period = explode(
+ ':',
+ date('H:i', ($old_args['first_execution'] + $period))
+ );
+ $hora_en_segundos2 = (($array_explode_period[0] * 3600 ) + ($array_explode_period[1] * 60));
+
+ if ($hora_en_segundos !== $hora_en_segundos2) {
+ $period = ($period + ($hora_en_segundos - $hora_en_segundos2));
+ }
+ }
+
+ try {
+ /*
+ Calculate the number of periods between last execution and
+ current time.
+ */
+
+ $num_of_periods = 0;
+ if ($period !== 0) {
+ $num_of_periods = ceil(
+ (time() - $old_args['first_execution']) / $period
+ );
+ }
+
+ if ($task_scheduled['scheduled'] == 'monthly') {
+ $updated_time = $old_args['first_execution'];
+
+ // Update updated_time adding the period for each month individually since it is a variable value depending on the number of days a month has.
+ while ($num_of_periods > 0) {
+ // Get days of current month.
+ $monthly_period = cron_get_scheduled_time(
+ 'monthly',
+ $task_scheduled['custom_data'],
+ $updated_time
+ );
+ $updated_time += $monthly_period;
+ $num_of_periods--;
+ }
+
+ $old_args['first_execution'] = $updated_time;
+ } else if ($task_scheduled['scheduled'] == 'weekly') {
+ $weekly_schedule = json_decode(io_safe_output($old_args['weekly_schedule']), true);
+ if (empty($weekly_schedule) !== true) {
+ $datetime = new DateTime('tomorrow');
+ $nameday = strtolower($datetime->format('l'));
+ $continue = true;
+ while ($continue === true) {
+ if (isset($weekly_schedule[$nameday]) === true) {
+ $weekly_date = $datetime->format('Y-m-d');
+ $weekly_time = $weekly_schedule[$nameday][0]['start'];
+ $old_args['first_execution'] = strtotime($weekly_date.' '.$weekly_time);
+
+ $continue = false;
+ } else {
+ $datetime->modify('+1 day');
+ $nameday = strtolower($datetime->format('l'));
+ }
+ }
+ }
+ } else {
+ // Add it to next execution.
+ $old_args['first_execution'] += ($period * $num_of_periods);
+ }
+ } catch (Exception $e) {
+ // If some error (ex $period=0) next execution=current time+period.
+ $old_args['first_execution'] = (time() + $period);
+ }
+
+ $new_args = serialize($old_args);
+ }
+
+ if ($config['timesource'] == 'sql') {
+ $sql = sprintf(
+ 'UPDATE tuser_task_scheduled
+ SET last_run=UNIX_TIMESTAMP()
+ WHERE id=%d',
+ $id_user_task
+ );
+ } else {
+ $sql = sprintf(
+ 'UPDATE tuser_task_scheduled
+ SET last_run= %d
+ WHERE id=%d',
+ time(),
+ $id_user_task
+ );
+ }
+
+ if (!$force_run) {
+ $sql2 = "UPDATE tuser_task_scheduled
+ SET args = '".$new_args."'
+ WHERE id=".$id_user_task;
+ }
+
+ db_process_sql($sql);
+ db_process_sql($sql2);
+}
+
+
+/**
+ * Execuytes custom function defined in PHP.
+ *
+ * @param string $function_name Name to execute.
+ *
+ * @return void
+ */
+function cron_task_call_user_function(string $function_name)
+{
+ global $config;
+
+ include_once $config['homedir'].'/vendor/autoload.php';
+
+ call_user_func($function_name);
+}
+
+
+/**
+ * Check whether GoTTY SSH and Telnet processes are running and start otherwise.
+ *
+ * @param boolean $restart_mode Restart the processes if running.
+ *
+ * @return void
+ */
+function cron_task_start_gotty(bool $restart_mode=true)
+{
+ global $config;
+
+ include_once $config['homedir'].'/include/functions_config.php';
+
+ $gotty_ssh_enabled = (bool) $config['gotty_ssh_enabled'];
+ $gotty_telnet_enabled = (bool) $config['gotty_telnet_enabled'];
+
+ // Check prev process running and kill it (only if port changed in setup params).
+ if (empty($config['restart_gotty_next_cron_port']) === false) {
+ config_update_value('restart_gotty_next_cron_port', '');
+
+ $prevProcessRunning = shell_exec("pgrep -f 'pandora_gotty.*-p ".$config['restart_gotty_next_cron_port']."'");
+
+ if (empty($prevProcessRunning) === false) {
+ shell_exec("pkill -f 'pandora_gotty.*-p ".$config['restart_gotty_next_cron_port']."'");
+ }
+ }
+
+ // Check if gotty is running on the configured port.
+ $processRunning = shell_exec("pgrep -f 'pandora_gotty.*-p ".$config['gotty_port']."'");
+
+ $start_proc = true;
+
+ // If both methods are disabled, do not start process.
+ if ($gotty_ssh_enabled === false && $gotty_telnet_enabled === false) {
+ $start_proc = false;
+ }
+
+ if (empty($processRunning) === false) {
+ // Process is running.
+ if ($restart_mode === true || $start_proc === false) {
+ // Stop the process for restarting or in case GoTTY method is disabled in this iteration.
+ shell_exec("pkill -f 'pandora_gotty.*-p ".$config['gotty_port']."'");
+ } else {
+ // Prevent starting if already running and must not be restarted or terminated.
+ return;
+ }
+ }
+
+ if ($start_proc === true) {
+ $logFilePath = $config['homedir'].'/log/gotty_cron_tmp.log';
+ shell_exec('touch '.$logFilePath);
+
+ // Start gotty process and capture the output.
+ $command = '/usr/bin/nohup /usr/bin/pandora_gotty --config /etc/pandora_gotty/pandora_gotty.conf -p '.$config['gotty_port'].' /usr/bin/pandora_gotty_exec > '.$logFilePath.' 2>&1 &';
+ shell_exec($command);
+ } else {
+ return;
+ }
+
+ $hash_read = false;
+
+ // Maximum wait time to read asynchronously the output of the executed commands (seconds).
+ $maxWaitTime = 10;
+
+ // Wait for content to appear in the log file.
+ $startTime = time();
+
+ // Workaround to wait until process inputs data in the log.
+ while (time() - $startTime < $maxWaitTime) {
+ if ($start_proc === true) {
+ // Read command output.
+ $log_content = file_get_contents($logFilePath);
+ }
+
+ if ($start_proc === true
+ && !empty($log_content)
+ && $hash_read === false
+ ) {
+ // Extract the URL from the output.
+ if (preg_match('/.*?HTTP server is listening at:\s+(\S+)/', $log_content, $matches)) {
+ $url = $matches[1];
+
+ // Extract the hash.
+ $parts = explode('/', $url);
+ $hash = array_slice($parts, -2, 1)[0];
+
+ config_update_value('gotty_connection_hash', $hash);
+ $hash_read = true;
+ }
+
+ unlink($logFilePath);
+ }
+
+ if ($start_proc === false || $hash_read === true) {
+ // As soon as the read has completed, the timing loop will terminate.
+ break;
+ }
+
+ // Sleep for a short interval before checking again.
+ usleep(100000);
+ }
+}
diff --git a/pandora_console/pandora_websocket_engine b/pandora_console/pandora_websocket_engine
deleted file mode 100755
index 2d4536aae0..0000000000
--- a/pandora_console/pandora_websocket_engine
+++ /dev/null
@@ -1,175 +0,0 @@
-#!/bin/bash
-# Copyright (c) 2005-2023 Pandora FMS
-#
-# /etc/init.d/websocket
-#
-# System startup script for Pandora FMS Console websocket engine
-#
-# Comments to support chkconfig on RedHat Linux
-# chkconfig: 2345 90 10
-# description: Pandora FMS Console webscoket engine startup script
-#
-# Comments to support LSB init script conventions
-### BEGIN INIT INFO
-# Provides: websocket
-# Required-Start: $syslog cron
-# Should-Start: $network cron mysql
-# Required-Stop: $syslog
-# Should-Stop: $network
-# Default-Start: 2 3 5
-# Default-Stop: 0 1 6
-# Short-Description: Pandora FMS Console websocket engine startup script
-# Description: Pandora FMS Console websocket engine startup script
-### END INIT INFO
-
-if [ -x /lib/lsb/init-functions ]; then
-. /lib/lsb/init-functions
-fi
-
-# If you want to run several pandora Console Websocket engines in this machine, just copy
-# this script to another name, editing PANDORA_HOME to the new .conf
-
-export WS_ENGINE="/var/www/html/pandora_console/ws.php"
-export PHP=/usr/bin/php
-export WS_LOG="/var/log/pandora/web_socket.log"
-export GOTTY="/tmp/"
-
-# Environment variables
-if [[ -z ${PANDORA_RB_PRODUCT_NAME} ]]; then
- PANDORA_RB_PRODUCT_NAME="Pandora FMS"
-fi
-if [[ -z ${PANDORA_RB_COPYRIGHT_NOTICE} ]]; then
- PANDORA_RB_COPYRIGHT_NOTICE="Pandora FMS"
-fi
-
-export PANDORA_RB_PRODUCT_NAME=$PANDORA_RB_PRODUCT_NAME
-export PANDORA_RB_COPYRIGHT_NOTICE=$PANDORA_RB_COPYRIGHT_NOTICE
-
-# Uses a wait limit before sending a KILL signal, before trying to stop
-# Pandora FMS Console Websocket engine nicely. Some big systems need some time before close
-# all pending tasks / threads.
-
-export MAXWAIT=60
-
-# Check for SUSE status scripts
-if [ -f /etc/rc.status ]
-then
- . /etc/rc.status
- rc_reset
-else
- # Define part of rc functions for non-suse systems
- function rc_status () {
- RETVAL=$?
- case $1 in
- -v) RETVAL=0;;
- esac
- }
- function rc_exit () { exit $RETVAL; }
- function rc_failed () { RETVAL=${1:-1}; }
- RETVAL=0
-fi
-
-# This function replace pidof, not working in the same way in different linux distros
-
-function pidof_pandora () {
- # This sets COLUMNS to XXX chars, because if command is run
- # in a "strech" term, ps aux don't report more than COLUMNS
- # characters and this will not work.
- COLUMNS=300
- PANDORA_PID=`ps aux | grep "$PHP $WS_ENGINE" | grep -v grep | tail -1 | awk '{ print $2 }'`
- echo $PANDORA_PID
-}
-
-# Main script
-
-if [ ! -x $GOTTY ]
-then
- echo "Gotty not found in $GOTTY"
- rc_failed 5 # program is not installed
- rc_exit
-fi
-
-if [ ! -f $PHP ]
-then
- echo "$PHP not found, please install version >= 7.0"
- rc_failed 5 # program is not installed
- rc_exit
-fi
-
-case "$1" in
- start)
- PANDORA_PID=`pidof_pandora`
- if [ ! -z "$PANDORA_PID" ]
- then
- echo "$PANDORA_RB_PRODUCT_NAME Console Websocket engine is currently running on this machine with PID ($PANDORA_PID)."
- rc_exit # running start on a service already running
- fi
-
- export PERL_LWP_SSL_VERIFY_HOSTNAME=0
- $PHP $WS_ENGINE >> $WS_LOG 2>&1 &
- sleep 1
-
- PANDORA_PID=`pidof_pandora`
-
- if [ ! -z "$PANDORA_PID" ]
- then
- echo "$PANDORA_RB_PRODUCT_NAME Console Websocket engine is now running with PID $PANDORA_PID"
- rc_status -v
- else
- echo "Cannot start $PANDORA_RB_PRODUCT_NAME Console Websocket engine. Aborted."
- echo "Check $PANDORA_RB_PRODUCT_NAME log files at $WS_LOG"
- rc_failed 7 # program is not running
- fi
- ;;
-
- stop)
- PANDORA_PID=`pidof_pandora`
- if [ -z "$PANDORA_PID" ]
- then
- echo "$PANDORA_RB_PRODUCT_NAME Console Websocket engine is not running, cannot stop it."
- rc_exit # running stop on a service already stopped or not running
- else
- echo "Stopping $PANDORA_RB_PRODUCT_NAME Console Websocket engine"
- kill $PANDORA_PID > /dev/null 2>&1
- COUNTER=0
-
- while [ $COUNTER -lt $MAXWAIT ]
- do
- _PID=`pidof_pandora`
- if [ "$_PID" != "$PANDORA_PID" ]
- then
- COUNTER=$MAXWAIT
- fi
- COUNTER=`expr $COUNTER + 1`
- sleep 1
- done
-
- # Send a KILL -9 signal to process, if it's alive after 60secs, we need
- # to be sure is really dead, and not pretending...
- if [ "$_PID" = "$PANDORA_PID" ]
- then
- kill -9 $PANDORA_PID > /dev/null 2>&1
- fi
- rc_status -v
- fi
- ;;
- status)
- PANDORA_PID=`pidof_pandora`
- if [ -z "$PANDORA_PID" ]
- then
- echo "$PANDORA_RB_PRODUCT_NAME Console Websocket engine is not running."
- rc_failed 7 # program is not running
- else
- echo "$PANDORA_RB_PRODUCT_NAME Console Websocket engine is running with PID $PANDORA_PID."
- rc_status
- fi
- ;;
- force-reload|restart)
- $0 stop
- $0 start
- ;;
- *)
- echo "Usage: $0 { start | stop | restart | status }"
- exit 1
-esac
-rc_exit