X-Git-Url: https://git.tokkee.org/?p=sysdb.git;a=blobdiff_plain;f=t%2Funit%2Ffrontend%2Fquery_test.c;h=52fd58a4e0c75256fb5e3f77e7db604854534831;hp=7640511b692f7bfaa68f5a627066d7b5afa0bf90;hb=98439daa576d4dbc533e9d4b8a5f493926389554;hpb=026ce2bb377f4055e3a0a1d20a2f91e5a73a49b0

diff --git a/t/unit/frontend/query_test.c b/t/unit/frontend/query_test.c
index 7640511..52fd58a 100644
--- a/t/unit/frontend/query_test.c
+++ b/t/unit/frontend/query_test.c
@@ -29,6 +29,7 @@
 #	include "config.h"
 #endif
 
+#include "core/memstore.h"
 #include "core/plugin.h"
 #include "frontend/connection.h"
 #include "frontend/connection-private.h"
@@ -43,16 +44,16 @@
 static void
 populate(void)
 {
-	sdb_store_t *store;
+	sdb_memstore_t *store;
 	sdb_data_t datum;
 
 	/* the frontend accesses the store via the plugin API */
-	store = sdb_store_create();
+	store = sdb_memstore_create();
 	ck_assert(store != NULL);
 	ck_assert(sdb_plugin_register_writer("test-writer",
-				&sdb_store_writer, SDB_OBJ(store)) == 0);
+				&sdb_memstore_writer, SDB_OBJ(store)) == 0);
 	ck_assert(sdb_plugin_register_reader("test-reader",
-				&sdb_store_reader, SDB_OBJ(store)) == 0);
+				&sdb_memstore_reader, SDB_OBJ(store)) == 0);
 	sdb_object_deref(SDB_OBJ(store));
 
 	/* populate the store */
@@ -69,7 +70,8 @@ populate(void)
 
 	sdb_plugin_store_metric("h1", "m1", /* store */ NULL, 2 * SDB_INTERVAL_SECOND);
 	sdb_plugin_store_metric("h1", "m2", /* store */ NULL, 1 * SDB_INTERVAL_SECOND);
-	sdb_plugin_store_metric("h2", "m1", /* store */ NULL, 1 * SDB_INTERVAL_SECOND);
+	sdb_plugin_store_metric("h2", "m1", /* store */ NULL, 5 * SDB_INTERVAL_SECOND);
+	sdb_plugin_store_metric("h2", "m1", /* store */ NULL, 10 * SDB_INTERVAL_SECOND);
 
 	datum.type = SDB_TYPE_INTEGER;
 	datum.data.integer = 42;
@@ -129,12 +131,12 @@ turndown(void)
 			"\"update_interval\": \"0s\", \"backends\": [], " \
 		"\"metrics\": [" \
 			"{\"name\": \"m1\", \"timeseries\": false, " \
-				"\"last_update\": \"1970-01-01 00:00:01 +0000\", " \
-				"\"update_interval\": \"0s\", \"backends\": [], " \
+				"\"last_update\": \"1970-01-01 00:00:10 +0000\", " \
+				"\"update_interval\": \"5s\", \"backends\": [], " \
 				"\"attributes\": [" \
 					"{\"name\": \"hostname\", \"value\": \"h2\", " \
-						"\"last_update\": \"1970-01-01 00:00:01 +0000\", " \
-						"\"update_interval\": \"0s\", \"backends\": []}]}], " \
+						"\"last_update\": \"1970-01-01 00:00:10 +0000\", " \
+						"\"update_interval\": \"5s\", \"backends\": []}]}], " \
 		"\"services\": [" \
 			"{\"name\": \"s1\", \"last_update\": \"1970-01-01 00:00:01 +0000\", " \
 				"\"update_interval\": \"0s\", \"backends\": [], " \
@@ -173,6 +175,28 @@ turndown(void)
 					"{\"name\": \"hostname\", \"value\": \"h2\", " \
 						"\"last_update\": \"1970-01-01 00:00:01 +0000\", " \
 						"\"update_interval\": \"0s\", \"backends\": []}]}]}"
+#define SERVICE_H2_S12 \
+	"{\"name\": \"h2\", \"last_update\": \"1970-01-01 00:00:03 +0000\", " \
+			"\"update_interval\": \"0s\", \"backends\": [], " \
+		"\"services\": [" \
+			"{\"name\": \"s1\", \"last_update\": \"1970-01-01 00:00:01 +0000\", " \
+				"\"update_interval\": \"0s\", \"backends\": [], " \
+				"\"attributes\": [" \
+					"{\"name\": \"hostname\", \"value\": \"h2\", " \
+						"\"last_update\": \"1970-01-01 00:00:01 +0000\", " \
+						"\"update_interval\": \"0s\", \"backends\": []}]}," \
+			"{\"name\": \"s2\", \"last_update\": \"1970-01-01 00:00:02 +0000\", " \
+				"\"update_interval\": \"0s\", \"backends\": [], " \
+				"\"attributes\": [" \
+					"{\"name\": \"hostname\", \"value\": \"h2\", " \
+						"\"last_update\": \"1970-01-01 00:00:02 +0000\", " \
+						"\"update_interval\": \"0s\", \"backends\": []}," \
+					"{\"name\": \"k1\", \"value\": 123, " \
+						"\"last_update\": \"1970-01-01 00:00:02 +0000\", " \
+						"\"update_interval\": \"0s\", \"backends\": []}," \
+					"{\"name\": \"k2\", \"value\": 4711, " \
+						"\"last_update\": \"1970-01-01 00:00:01 +0000\", " \
+						"\"update_interval\": \"0s\", \"backends\": []}]}]}"
 #define SERVICE_H2_S1_ARRAY "["SERVICE_H2_S1"]"
 #define SERVICE_H2_S12_LISTING \
 	"[{\"name\": \"h2\", \"last_update\": \"1970-01-01 00:00:03 +0000\", " \
@@ -197,18 +221,19 @@ turndown(void)
 					"{\"name\": \"k3\", \"value\": 42, " \
 						"\"last_update\": \"1970-01-01 00:00:02 +0000\", " \
 						"\"update_interval\": \"0s\", \"backends\": []}]}]}"
-#define METRIC_H12_M1_ARRAY \
-	"["METRIC_H1_M1"," \
+#define METRIC_H2_M1 \
 	"{\"name\": \"h2\", \"last_update\": \"1970-01-01 00:00:03 +0000\", " \
 			"\"update_interval\": \"0s\", \"backends\": [], " \
 		"\"metrics\": [" \
 			"{\"name\": \"m1\", \"timeseries\": false, " \
-				"\"last_update\": \"1970-01-01 00:00:01 +0000\", " \
-				"\"update_interval\": \"0s\", \"backends\": [], " \
+				"\"last_update\": \"1970-01-01 00:00:10 +0000\", " \
+				"\"update_interval\": \"5s\", \"backends\": [], " \
 				"\"attributes\": [" \
 					"{\"name\": \"hostname\", \"value\": \"h2\", " \
-						"\"last_update\": \"1970-01-01 00:00:01 +0000\", " \
-						"\"update_interval\": \"0s\", \"backends\": []}]}]}]"
+						"\"last_update\": \"1970-01-01 00:00:10 +0000\", " \
+						"\"update_interval\": \"5s\", \"backends\": []}]}]}"
+#define METRIC_H12_M1_ARRAY \
+	"["METRIC_H1_M1","METRIC_H2_M1"]"
 #define METRIC_H12_M12_LISTING \
 	"[{\"name\": \"h1\", \"last_update\": \"1970-01-01 00:00:01 +0000\", " \
 			"\"update_interval\": \"0s\", \"backends\": [], " \
@@ -223,8 +248,8 @@ turndown(void)
 			"\"update_interval\": \"0s\", \"backends\": [], " \
 		"\"metrics\": [" \
 			"{\"name\": \"m1\", \"timeseries\": false, " \
-				"\"last_update\": \"1970-01-01 00:00:01 +0000\", " \
-				"\"update_interval\": \"0s\", \"backends\": []}]}]"
+				"\"last_update\": \"1970-01-01 00:00:10 +0000\", " \
+				"\"update_interval\": \"5s\", \"backends\": []}]}]"
 
 typedef struct {
 	sdb_conn_t conn;
@@ -471,6 +496,27 @@ static struct {
 		SDB_CONNECTION_QUERY, "LOOKUP services MATCHING name = 's1'", -1,
 		0, SDB_CONNECTION_DATA, 358, SDB_CONNECTION_LOOKUP, SERVICE_H2_S1_ARRAY,
 	},
+	{
+		SDB_CONNECTION_QUERY, "LOOKUP services MATCHING host.name = 'h2'", -1,
+		0, SDB_CONNECTION_DATA, 825, SDB_CONNECTION_LOOKUP, "["SERVICE_H2_S12"]",
+	},
+	{
+		SDB_CONNECTION_QUERY, "LOOKUP services MATCHING ANY host.metric.name = 'm1'", -1,
+		0, SDB_CONNECTION_DATA, 825, SDB_CONNECTION_LOOKUP, "["SERVICE_H2_S12"]",
+	},
+	{
+		SDB_CONNECTION_QUERY, "LOOKUP services MATCHING ANY host.metric.last_update = 10s", -1,
+		0, SDB_CONNECTION_DATA, 825, SDB_CONNECTION_LOOKUP, "["SERVICE_H2_S12"]",
+	},
+	{
+		/* stupid but valid ;-) */
+		SDB_CONNECTION_QUERY, "LOOKUP services MATCHING ANY host.host.metric.metric.interval = 5s", -1,
+		0, SDB_CONNECTION_DATA, 825, SDB_CONNECTION_LOOKUP, "["SERVICE_H2_S12"]",
+	},
+	{
+		SDB_CONNECTION_QUERY, "LOOKUP services MATCHING ANY host.metric.name = 'mX'", -1,
+		0, SDB_CONNECTION_DATA, 6, SDB_CONNECTION_LOOKUP, "[]",
+	},
 	{
 		SDB_CONNECTION_LOOKUP, "\0\0\0\2""name = 's1'", 16,
 		0, SDB_CONNECTION_DATA, 358, SDB_CONNECTION_LOOKUP, SERVICE_H2_S1_ARRAY,
@@ -545,6 +591,16 @@ static struct {
 		SDB_CONNECTION_QUERY, "LOOKUP metrics MATCHING name = 'm1'", -1,
 		0, SDB_CONNECTION_DATA, 864, SDB_CONNECTION_LOOKUP, METRIC_H12_M1_ARRAY,
 	},
+	{
+		/* stupid but valid ;-) */
+		SDB_CONNECTION_QUERY, "LOOKUP metrics MATCHING metric.metric.name = 'm1'", -1,
+		0, SDB_CONNECTION_DATA, 864, SDB_CONNECTION_LOOKUP, METRIC_H12_M1_ARRAY,
+	},
+	{
+		/* also stupid but valid ;-) */
+		SDB_CONNECTION_QUERY, "LOOKUP metrics MATCHING metric.metric.host.host.last_update = 3s", -1,
+		0, SDB_CONNECTION_DATA, 378, SDB_CONNECTION_LOOKUP, "["METRIC_H2_M1"]",
+	},
 	{
 		SDB_CONNECTION_LOOKUP, "\0\0\0\3""name = 'm1'", 16,
 		0, SDB_CONNECTION_DATA, 864, SDB_CONNECTION_LOOKUP, METRIC_H12_M1_ARRAY,