summaryrefslogtreecommitdiffstats
path: root/web/api/web_api.c
diff options
context:
space:
mode:
Diffstat (limited to 'web/api/web_api.c')
-rw-r--r--web/api/web_api.c216
1 files changed, 216 insertions, 0 deletions
diff --git a/web/api/web_api.c b/web/api/web_api.c
new file mode 100644
index 000000000..7c1d0fa09
--- /dev/null
+++ b/web/api/web_api.c
@@ -0,0 +1,216 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+#include "web_api.h"
+
+int web_client_api_request_vX(RRDHOST *host, struct web_client *w, char *url_path_endpoint, struct web_api_command *api_commands) {
+ if(unlikely(!url_path_endpoint || !*url_path_endpoint)) {
+ buffer_flush(w->response.data);
+ buffer_sprintf(w->response.data, "Which API command?");
+ return HTTP_RESP_BAD_REQUEST;
+ }
+
+ uint32_t hash = simple_hash(url_path_endpoint);
+
+ for(int i = 0; api_commands[i].command ; i++) {
+ if(unlikely(hash == api_commands[i].hash && !strcmp(url_path_endpoint, api_commands[i].command))) {
+ if(unlikely(api_commands[i].acl != WEB_CLIENT_ACL_NOCHECK) && !(w->acl & api_commands[i].acl))
+ return web_client_permission_denied(w);
+
+ char *query_string = (char *)buffer_tostring(w->url_query_string_decoded);
+
+ if(*query_string == '?')
+ query_string = &query_string[1];
+
+ return api_commands[i].callback(host, w, query_string);
+ }
+ }
+
+ buffer_flush(w->response.data);
+ buffer_strcat(w->response.data, "Unsupported API command: ");
+ buffer_strcat_htmlescape(w->response.data, url_path_endpoint);
+ return HTTP_RESP_NOT_FOUND;
+}
+
+RRDCONTEXT_TO_JSON_OPTIONS rrdcontext_to_json_parse_options(char *o) {
+ RRDCONTEXT_TO_JSON_OPTIONS options = RRDCONTEXT_OPTION_NONE;
+ char *tok;
+
+ while(o && *o && (tok = strsep_skip_consecutive_separators(&o, ", |"))) {
+ if(!*tok) continue;
+
+ if(!strcmp(tok, "full") || !strcmp(tok, "all"))
+ options |= RRDCONTEXT_OPTIONS_ALL;
+ else if(!strcmp(tok, "charts") || !strcmp(tok, "instances"))
+ options |= RRDCONTEXT_OPTION_SHOW_INSTANCES;
+ else if(!strcmp(tok, "dimensions") || !strcmp(tok, "metrics"))
+ options |= RRDCONTEXT_OPTION_SHOW_METRICS;
+ else if(!strcmp(tok, "queue"))
+ options |= RRDCONTEXT_OPTION_SHOW_QUEUED;
+ else if(!strcmp(tok, "flags"))
+ options |= RRDCONTEXT_OPTION_SHOW_FLAGS;
+ else if(!strcmp(tok, "uuids"))
+ options |= RRDCONTEXT_OPTION_SHOW_UUIDS;
+ else if(!strcmp(tok, "deleted"))
+ options |= RRDCONTEXT_OPTION_SHOW_DELETED;
+ else if(!strcmp(tok, "labels"))
+ options |= RRDCONTEXT_OPTION_SHOW_LABELS;
+ else if(!strcmp(tok, "deepscan"))
+ options |= RRDCONTEXT_OPTION_DEEPSCAN;
+ else if(!strcmp(tok, "hidden"))
+ options |= RRDCONTEXT_OPTION_SHOW_HIDDEN;
+ }
+
+ return options;
+}
+
+int web_client_api_request_weights(RRDHOST *host, struct web_client *w, char *url, WEIGHTS_METHOD method, WEIGHTS_FORMAT format, size_t api_version) {
+ if (!netdata_ready)
+ return HTTP_RESP_BACKEND_FETCH_FAILED;
+
+ time_t baseline_after = 0, baseline_before = 0, after = 0, before = 0;
+ size_t points = 0;
+ RRDR_OPTIONS options = 0;
+ RRDR_TIME_GROUPING time_group_method = RRDR_GROUPING_AVERAGE;
+ time_t timeout_ms = 0;
+ size_t tier = 0;
+ const char *time_group_options = NULL, *scope_contexts = NULL, *scope_nodes = NULL, *contexts = NULL, *nodes = NULL,
+ *instances = NULL, *dimensions = NULL, *labels = NULL, *alerts = NULL;
+
+ struct group_by_pass group_by = {
+ .group_by = RRDR_GROUP_BY_NONE,
+ .group_by_label = NULL,
+ .aggregation = RRDR_GROUP_BY_FUNCTION_AVERAGE,
+ };
+
+ 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;
+
+ if (!strcmp(name, "baseline_after"))
+ baseline_after = str2l(value);
+
+ else if (!strcmp(name, "baseline_before"))
+ baseline_before = str2l(value);
+
+ else if (!strcmp(name, "after") || !strcmp(name, "highlight_after"))
+ after = str2l(value);
+
+ else if (!strcmp(name, "before") || !strcmp(name, "highlight_before"))
+ before = str2l(value);
+
+ else if (!strcmp(name, "points") || !strcmp(name, "max_points"))
+ points = str2ul(value);
+
+ else if (!strcmp(name, "timeout"))
+ timeout_ms = str2l(value);
+
+ else if((api_version == 1 && !strcmp(name, "group")) || (api_version >= 2 && !strcmp(name, "time_group")))
+ time_group_method = time_grouping_parse(value, RRDR_GROUPING_AVERAGE);
+
+ else if((api_version == 1 && !strcmp(name, "group_options")) || (api_version >= 2 && !strcmp(name, "time_group_options")))
+ time_group_options = value;
+
+ else if(!strcmp(name, "options"))
+ options |= web_client_api_request_v1_data_options(value);
+
+ else if(!strcmp(name, "method"))
+ method = weights_string_to_method(value);
+
+ else if(api_version == 1 && (!strcmp(name, "context") || !strcmp(name, "contexts")))
+ scope_contexts = value;
+
+ else if(api_version >= 2 && !strcmp(name, "scope_nodes")) scope_nodes = value;
+ else if(api_version >= 2 && !strcmp(name, "scope_contexts")) scope_contexts = value;
+ else if(api_version >= 2 && !strcmp(name, "nodes")) nodes = value;
+ else if(api_version >= 2 && !strcmp(name, "contexts")) contexts = value;
+ else if(api_version >= 2 && !strcmp(name, "instances")) instances = value;
+ else if(api_version >= 2 && !strcmp(name, "dimensions")) dimensions = value;
+ else if(api_version >= 2 && !strcmp(name, "labels")) labels = value;
+ else if(api_version >= 2 && !strcmp(name, "alerts")) alerts = value;
+ else if(api_version >= 2 && (!strcmp(name, "group_by") || !strcmp(name, "group_by[0]"))) {
+ group_by.group_by = group_by_parse(value);
+ }
+ else if(api_version >= 2 && (!strcmp(name, "group_by_label") || !strcmp(name, "group_by_label[0]"))) {
+ group_by.group_by_label = value;
+ }
+ else if(api_version >= 2 && (!strcmp(name, "aggregation") || !strcmp(name, "aggregation[0]"))) {
+ group_by.aggregation = group_by_aggregate_function_parse(value);
+ }
+
+ else if(!strcmp(name, "tier")) {
+ tier = str2ul(value);
+ if(tier < storage_tiers)
+ options |= RRDR_OPTION_SELECTED_TIER;
+ else
+ tier = 0;
+ }
+ }
+
+ if(options == 0)
+ // the user did not set any options
+ options = RRDR_OPTION_NOT_ALIGNED | RRDR_OPTION_NULL2ZERO | RRDR_OPTION_NONZERO;
+ else
+ // the user set some options, add also these
+ options |= RRDR_OPTION_NOT_ALIGNED | RRDR_OPTION_NULL2ZERO;
+
+ if(options & RRDR_OPTION_PERCENTAGE)
+ options |= RRDR_OPTION_ABSOLUTE;
+
+ if(options & RRDR_OPTION_DEBUG)
+ options &= ~RRDR_OPTION_MINIFY;
+
+ BUFFER *wb = w->response.data;
+ buffer_flush(wb);
+ wb->content_type = CT_APPLICATION_JSON;
+
+ QUERY_WEIGHTS_REQUEST qwr = {
+ .version = api_version,
+ .host = (api_version == 1) ? NULL : host,
+ .scope_nodes = scope_nodes,
+ .scope_contexts = scope_contexts,
+ .nodes = nodes,
+ .contexts = contexts,
+ .instances = instances,
+ .dimensions = dimensions,
+ .labels = labels,
+ .alerts = alerts,
+ .group_by = {
+ .group_by = group_by.group_by,
+ .group_by_label = group_by.group_by_label,
+ .aggregation = group_by.aggregation,
+ },
+ .method = method,
+ .format = format,
+ .time_group_method = time_group_method,
+ .time_group_options = time_group_options,
+ .baseline_after = baseline_after,
+ .baseline_before = baseline_before,
+ .after = after,
+ .before = before,
+ .points = points,
+ .options = options,
+ .tier = tier,
+ .timeout_ms = timeout_ms,
+
+ .interrupt_callback = web_client_interrupt_callback,
+ .interrupt_callback_data = w,
+ };
+
+ return web_api_v12_weights(wb, &qwr);
+}
+
+bool web_client_interrupt_callback(void *data) {
+ struct web_client *w = data;
+
+ if(w->interrupt.callback)
+ return w->interrupt.callback(w, w->interrupt.callback_data);
+
+ return sock_has_output_error(w->ofd);
+}