........S. [ZBXNEXT-6955] added trendanomalystl() anomaly detection function

1 files changed, 187 insertions, 0 deletions

diff --git a/tests/libs/zbxserver/evaluate_percentage_deviations_in_remainder.c b/tests/libs/zbxserver/evaluate_percentage_deviations_in_remainder.c
new file mode 100644
index 00000000000..100f94fef0a
--- /dev/null
+++ b/tests/libs/zbxserver/evaluate_percentage_deviations_in_remainder.c
@@ -0,0 +1,187 @@
+/*
+** Zabbix
+** Copyright (C) 2001-2021 Zabbix SIA
+**
+** This program is free software; you can redistribute it and/or modify
+** it under the terms of the GNU General Public License as published by
+** the Free Software Foundation; either version 2 of the License, or
+** (at your option) any later version.
+**
+** This program is distributed in the hope that it will be useful,
+** but WITHOUT ANY WARRANTY; without even the implied warranty of
+** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+** GNU General Public License for more details.
+**
+** You should have received a copy of the GNU General Public License
+** along with this program; if not, write to the Free Software
+** Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
+**/
+
+#include "common.h"
+
+#include "zbxmocktest.h"
+#include "zbxmockdata.h"
+#include "zbxmockassert.h"
+#include "zbxmockutil.h"
+
+#include "valuecache.h"
+#include "zbxserver.h"
+#include "zbxtrends.h"
+
+#include "mocks/valuecache/valuecache_mock.h"
+
+#include "../../../src/libs/zbxserver/anomalystl.h"
+#include "../../../src/libs/zbxserver/evalfunc_common.h"
+
+int	__wrap_substitute_simple_macros(zbx_uint64_t *actionid, const DB_EVENT *event, const DB_EVENT *r_event,
+		zbx_uint64_t *userid, const zbx_uint64_t *hostid, const DC_HOST *dc_host, const DC_ITEM *dc_item,
+		DB_ALERT *alert, const DB_ACKNOWLEDGE *ack, const zbx_service_alarm_t *service_alarm,
+		const DB_SERVICE *service, const char *tz, char **data, int macro_type, char *error,
+		int maxerrlen);
+
+int	__wrap_DCget_data_expected_from(zbx_uint64_t itemid, int *seconds);
+
+int	__wrap_substitute_simple_macros(zbx_uint64_t *actionid, const DB_EVENT *event, const DB_EVENT *r_event,
+		zbx_uint64_t *userid, const zbx_uint64_t *hostid, const DC_HOST *dc_host, const DC_ITEM *dc_item,
+		DB_ALERT *alert, const DB_ACKNOWLEDGE *ack, const zbx_service_alarm_t *service_alarm,
+		const DB_SERVICE *service, const char *tz, char **data, int macro_type, char *error,
+		int maxerrlen)
+{
+	ZBX_UNUSED(actionid);
+	ZBX_UNUSED(event);
+	ZBX_UNUSED(r_event);
+	ZBX_UNUSED(userid);
+	ZBX_UNUSED(hostid);
+	ZBX_UNUSED(dc_host);
+	ZBX_UNUSED(dc_item);
+	ZBX_UNUSED(alert);
+	ZBX_UNUSED(ack);
+	ZBX_UNUSED(tz);
+	ZBX_UNUSED(data);
+	ZBX_UNUSED(macro_type);
+	ZBX_UNUSED(error);
+	ZBX_UNUSED(maxerrlen);
+	ZBX_UNUSED(service_alarm);
+	ZBX_UNUSED(service);
+
+	return SUCCEED;
+}
+
+int	__wrap_DCget_data_expected_from(zbx_uint64_t itemid, int *seconds)
+{
+	ZBX_UNUSED(itemid);
+	*seconds = zbx_vcmock_get_ts().sec - 600;
+
+	return SUCCEED;
+}
+
+void	zbx_mock_test_entry(void **state)
+{
+	int				start_detect_period, end_detect_period, detect_period_season_shift, err,
+					detect_period, start_evaluate_period, end_evaluate_period, evaluate_seconds = 0,
+					evaluate_nvalues = 0;
+	zbx_uint64_t			deviations_count;
+	double				result;
+	char				*error = NULL, *evaluate_period = NULL;
+	const char			*params, *dev_alg = NULL;
+	DC_ITEM				item;
+	zbx_vcmock_ds_item_t		*ds_item;
+	zbx_timespec_t			ts, ts_evaluate_end;
+	zbx_mock_handle_t		handle;
+	zbx_vector_history_record_t	values_in;
+	zbx_value_type_t		detect_period_season_type;
+
+	/* ZBX_DOUBLE_EPSILON = 0.000001; results into output that is different from python test case output */
+	ZBX_DOUBLE_EPSILON = 0.0001;
+
+	zbx_history_record_vector_create(&values_in);
+
+	err = zbx_vc_init(&error);
+	zbx_mock_assert_result_eq("Value cache initialization failed", SUCCEED, err);
+	zbx_vc_enable();
+	zbx_vcmock_ds_init();
+	memset(&item, 0, sizeof(DC_ITEM));
+	ds_item = zbx_vcmock_ds_first_item();
+	item.itemid = ds_item->itemid;
+	item.value_type = ds_item->value_type;
+
+	deviations_count = zbx_mock_get_parameter_uint64("in.deviations_count");
+	dev_alg = zbx_mock_get_parameter_string("in.dev_alg");
+	handle = zbx_mock_get_parameter_handle("in");
+	zbx_vcmock_set_time(handle, "time");
+	ts = zbx_vcmock_get_ts();
+	ts_evaluate_end = ts;
+
+	params = zbx_mock_get_parameter_string("in.params");
+
+	if (2 != num_param(params))
+	{
+		fail_msg("invalid number of parameters");
+		goto out;
+	}
+
+	if (SUCCEED != get_function_parameter_str(params, 1, &evaluate_period))
+	{
+		fail_msg("invalid second parameter");
+		goto out;
+	}
+
+	if (SUCCEED != zbx_trends_parse_range(ts.sec, evaluate_period, &start_evaluate_period, &end_evaluate_period,
+			&error))
+	{
+		fail_msg("failed to parse seconds parameter: %s", error);
+		goto out;
+	}
+
+	ts_evaluate_end.sec = end_evaluate_period;
+	evaluate_seconds = end_evaluate_period - start_evaluate_period;
+
+	if (SUCCEED != get_function_parameter_hist_range(ts.sec, params, 2, &detect_period, &detect_period_season_type,
+			&detect_period_season_shift))
+	{
+		fail_msg("invalid third parameter");
+		goto out;
+	}
+
+	start_detect_period = ts_evaluate_end.sec - detect_period;
+	end_detect_period = ts_evaluate_end.sec;
+
+	if (FAIL == zbx_vc_get_values(item.itemid, item.value_type, &values_in, evaluate_seconds, evaluate_nvalues,
+			&ts_evaluate_end))
+	{
+		fail_msg("cannot get values from value cache");
+		goto out;
+	}
+
+	zbx_vc_flush_stats();
+
+	if (0 >= values_in.values_num)
+	{
+		fail_msg("not enough data");
+		goto out;
+	}
+
+	if (SUCCEED != zbx_get_percentage_of_deviations_in_stl_remainder(&values_in, deviations_count, dev_alg,
+			start_detect_period, end_detect_period, &result, &error))
+	{
+		fail_msg("zbx_get_percentage_of_deviations_in_stl_remainder returned error: %s\n", error);
+		zbx_free(error);
+	}
+	else
+	{
+		const char	*expected_value;
+
+		handle = zbx_mock_get_parameter_handle("out.value");
+
+		if (ZBX_MOCK_SUCCESS != (err = zbx_mock_string_ex(handle, &expected_value)))
+			fail_msg("Cannot read output value: %s", zbx_mock_error_string(err));
+
+		zbx_mock_assert_double_eq("function result", atof(expected_value), result);
+	}
+out:
+	zbx_history_record_vector_destroy(&values_in, item.value_type);
+
+	zbx_vcmock_ds_destroy();
+	zbx_free(evaluate_period);
+	ZBX_UNUSED(state);
+}