From 0ecf2bb9c46157089758400746917751bc0d95fd Mon Sep 17 00:00:00 2001
From: fermin831 <fermin.hernandez@artica.es>
Date: Wed, 13 Feb 2019 14:43:55 +0100
Subject: [PATCH] Added pandora db messages purgue

Former-commit-id: 23d1f55ac6b7d6d5470fa25860b9bbb1575875df
---
 pandora_console/godmode/setup/performance.php | 12 ++++++++++++
 pandora_console/include/functions_config.php  |  8 ++++++++
 pandora_server/util/pandora_db.pl             |  8 ++++++++
 3 files changed, 28 insertions(+)

diff --git a/pandora_console/godmode/setup/performance.php b/pandora_console/godmode/setup/performance.php
index b8a397531e..a426c44cc2 100644
--- a/pandora_console/godmode/setup/performance.php
+++ b/pandora_console/godmode/setup/performance.php
@@ -82,6 +82,18 @@ if (enterprise_installed()) {
     $table->data[12][1] = html_print_input_text('inventory_purge', $config['inventory_purge'], '', 5, 5, true);
 }
 
+$table->data[] = [
+    __('Max. days before delete old messages'),
+    html_print_input_text(
+        'delete_old_messages',
+        $config['delete_old_messages'],
+        '',
+        5,
+        5,
+        true
+    ),
+];
+
 $table_other = new stdClass();
 $table_other->width = '100%';
 $table_other->class = 'databox filters';
diff --git a/pandora_console/include/functions_config.php b/pandora_console/include/functions_config.php
index e532deea15..d55eda62e5 100644
--- a/pandora_console/include/functions_config.php
+++ b/pandora_console/include/functions_config.php
@@ -748,6 +748,10 @@ function config_update_config()
                         }
                     }
 
+                    if (!config_update_value('delete_old_messages', get_parameter('delete_old_messages'))) {
+                        $error_update[] = __('Max. days before delete old messages');
+                    }
+
                     if (!config_update_value('max_graph_container', get_parameter('max_graph_container'))) {
                         $error_update[] = __('Graph container - Max. Items');
                     }
@@ -1535,6 +1539,10 @@ function config_process_config()
         }
     }
 
+    if (!isset($config['delete_old_messages'])) {
+        config_update_value('delete_old_messages', 21);
+    }
+
     if (!isset($config['max_graph_container'])) {
         config_update_value('max_graph_container', 10);
     }
diff --git a/pandora_server/util/pandora_db.pl b/pandora_server/util/pandora_db.pl
index d1ff8d455f..ee3ab0d1fa 100644
--- a/pandora_server/util/pandora_db.pl
+++ b/pandora_server/util/pandora_db.pl
@@ -437,6 +437,13 @@ sub pandora_purgedb ($$) {
 	
 	# Delete old tgraph_source data
 	db_do ($dbh,"DELETE FROM tgraph_source WHERE id_graph NOT IN (SELECT id_graph FROM tgraph)");
+
+	# Delete old messages
+	log_message ('PURGE', "Deleting old messages.");
+	if ($conf->{'_delete_old_messages'} > 0) {
+		my $message_limit = time() - 86400 * $conf->{'_delete_old_messages'};
+		db_do ($dbh, "DELETE FROM tmensajes WHERE timestamp < ?", $message_limit);
+	}
 }
 
 ###############################################################################
@@ -656,6 +663,7 @@ sub pandora_load_config_pdb ($) {
 	$conf->{'_history_db_delay'} = get_db_value ($dbh, "SELECT value FROM tconfig WHERE token = 'history_db_delay'");
 	$conf->{'_days_delete_unknown'} = get_db_value ($dbh, "SELECT value FROM tconfig WHERE token = 'days_delete_unknown'");
 	$conf->{'_inventory_purge'} = get_db_value ($dbh, "SELECT value FROM tconfig WHERE token = 'inventory_purge'");
+	$conf->{'_delete_old_messages'} = get_db_value ($dbh, "SELECT value FROM tconfig WHERE token = 'delete_old_messages'");
 	$conf->{'_enterprise_installed'} = get_db_value ($dbh, "SELECT value FROM tconfig WHERE token = 'enterprise_installed'");
 	$conf->{'_metaconsole'} = get_db_value ($dbh, "SELECT value FROM tconfig WHERE token = 'metaconsole'");
 	$conf->{'_metaconsole_events_history'} = get_db_value ($dbh, "SELECT value FROM tconfig WHERE token = 'metaconsole_events_history'");