1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
|
// SPDX-License-Identifier: GPL-3.0-or-later
#include "api_v2_calls.h"
// --------------------------------------------------------------------------------------------------------------------
int api_v2_contexts_internal(RRDHOST *host __maybe_unused, struct web_client *w, char *url, CONTEXTS_V2_MODE mode) {
struct api_v2_contexts_request req = { 0 };
while(url) {
char *value = strsep_skip_consecutive_separators(&url, "&");
if(!value || !*value) continue;
char *name = strsep_skip_consecutive_separators(&value, "=");
if(!name || !*name) continue;
if(!value || !*value) continue;
// name and value are now the parameters
// they are not null and not empty
if(!strcmp(name, "scope_nodes"))
req.scope_nodes = value;
else if(!strcmp(name, "nodes"))
req.nodes = value;
else if((mode & (CONTEXTS_V2_CONTEXTS | CONTEXTS_V2_SEARCH | CONTEXTS_V2_ALERTS | CONTEXTS_V2_ALERT_TRANSITIONS)) && !strcmp(name, "scope_contexts"))
req.scope_contexts = value;
else if((mode & (CONTEXTS_V2_CONTEXTS | CONTEXTS_V2_SEARCH | CONTEXTS_V2_ALERTS | CONTEXTS_V2_ALERT_TRANSITIONS)) && !strcmp(name, "contexts"))
req.contexts = value;
else if((mode & CONTEXTS_V2_SEARCH) && !strcmp(name, "q"))
req.q = value;
else if(!strcmp(name, "options"))
req.options = contexts_options_str_to_id(value);
else if(!strcmp(name, "after"))
req.after = str2l(value);
else if(!strcmp(name, "before"))
req.before = str2l(value);
else if(!strcmp(name, "timeout"))
req.timeout_ms = str2l(value);
else if(mode & (CONTEXTS_V2_ALERTS | CONTEXTS_V2_ALERT_TRANSITIONS)) {
if (!strcmp(name, "alert"))
req.alerts.alert = value;
else if (!strcmp(name, "transition"))
req.alerts.transition = value;
else if(mode & CONTEXTS_V2_ALERTS) {
if (!strcmp(name, "status"))
req.alerts.status = contexts_alert_status_str_to_id(value);
}
else if(mode & CONTEXTS_V2_ALERT_TRANSITIONS) {
if (!strcmp(name, "last"))
req.alerts.last = strtoul(value, NULL, 0);
else if(!strcmp(name, "context"))
req.contexts = value;
else if (!strcmp(name, "anchor_gi")) {
req.alerts.global_id_anchor = str2ull(value, NULL);
}
else {
for(int i = 0; i < ATF_TOTAL_ENTRIES ;i++) {
if(!strcmp(name, alert_transition_facets[i].query_param))
req.alerts.facets[i] = value;
}
}
}
}
}
if ((mode & CONTEXTS_V2_ALERT_TRANSITIONS) && !req.alerts.last)
req.alerts.last = 1;
buffer_flush(w->response.data);
buffer_no_cacheable(w->response.data);
return rrdcontext_to_json_v2(w->response.data, &req, mode);
}
int api_v2_contexts(RRDHOST *host __maybe_unused, struct web_client *w, char *url) {
return api_v2_contexts_internal(
host, w, url, CONTEXTS_V2_CONTEXTS | CONTEXTS_V2_NODES | CONTEXTS_V2_AGENTS | CONTEXTS_V2_VERSIONS);
}
|
