From f6ed626671a54fc560c82f536963b0d78dc136b6 Mon Sep 17 00:00:00 2001
From: tanguyvda <tcharles@centreon.com>
Date: Tue, 18 May 2021 16:54:18 +0200
Subject: [PATCH] start dedup

---
 .../sc_event.lua                              | 70 +++++++++++++++++++
 1 file changed, 70 insertions(+)

diff --git a/modules/centreon-stream-connectors-lib/sc_event.lua b/modules/centreon-stream-connectors-lib/sc_event.lua
index df619aa5..def770a2 100644
--- a/modules/centreon-stream-connectors-lib/sc_event.lua
+++ b/modules/centreon-stream-connectors-lib/sc_event.lua
@@ -884,6 +884,76 @@ function ScEvent:get_most_recent_status_code(timestamp)
   return status_info.status
 end
 
+--- is_service_status_event_duplicated
+-- @return true|false (boolean)
+function ScEvent:is_service_status_event_duplicated()
+  -- return false if option is not activated
+  if self.params.enable_service_status_dedup ~= 1 then
+    self.sc_logger:debug("[sc_event:is_service_status_event_duplicated]: service status is not enabled option enable_service_status_dedup is set to: " .. tostring(self.params.enable_service_status_dedup))
+    return false
+  end
+
+  -- if last check is the same than last_hard_state_change, it means the event just change its status so it cannot be a duplicated event
+  if self.event.last_hard_state_change == self.event.last_check then
+    return false
+  end
+
+  -- map the status known dates to their respective status code
+  local timestamp = {
+    [0] = tonumber(self.event.cache.service.last_time_ok),
+    [1] = tonumber(self.event.cache.service.last_time_warning),
+    [2] = tonumber(self.event.cache.service.last_time_critical),
+    [3] = tonumber(self.event.cache.service.last_time_unknown)
+  }
+
+  -- if we find a last time status older than the last_hard_state_change then we are not facing a duplicated event
+  for status_code, status_timestamp in ipairs(timestamp) do
+    -- of course it needs to be a different status code than the actual one
+    if status_code ~= self.event.state and status_timestamp >= self.event.last_hard_state_change then
+      return false
+    end
+  end
+
+  -- at the end, it only remains two cases, the first one is a duplicated event. The second one is when we have:
+  -- OK(H) --> NOT-OK(S) --> OK(H) 
+  return true
+end
+
+--- is_host_status_event_duplicated
+-- @return true|false (boolean)
+function ScEvent:is_host_status_event_duplicated()
+  -- return false if option is not activated
+  if self.params.enable_host_status_dedup ~= 1 then
+    self.sc_logger:debug("[sc_event:is_host_status_event_duplicated]: host status is not enabled option enable_host_status_dedup is set to: " .. tostring(self.params.enable_host_status_dedup))
+    return false
+  end
+
+  -- if last check is the same than last_hard_state_change, it means the event just change its status so it cannot be a duplicated event
+  if self.event.last_hard_state_change == self.event.last_check then
+    return false
+  end
+
+  -- map the status known dates to their respective status code
+  local timestamp = {
+    [0] = tonumber(self.event.cache.service.last_time_up),
+    [1] = tonumber(self.event.cache.service.last_time_down),
+    [2] = tonumber(self.event.cache.service.last_time_unreachable),
+  }
+
+  -- if we find a last time status older than the last_hard_state_change then we are not facing a duplicated event
+  for status_code, status_timestamp in ipairs(timestamp) do
+    -- of course it needs to be a different status code than the actual one
+    if status_code ~= self.event.state and status_timestamp >= self.event.last_hard_state_change then
+      return false
+    end
+  end
+
+  -- at the end, it only remains two cases, the first one is a duplicated event. The second one is when we have:
+  -- UP(H) --> NOT-UP(S) --> UP(H) 
+  return true
+end
+
+
 --- is_valid_storage: DEPRECATED method, use NEB category to get metric data instead
 -- @return true (boolean)
 function ScEvent:is_valid_storage_event()