1 files changed, 145 insertions, 0 deletions
diff --git a/src/daemon/config/dyncfg-internals.h b/src/daemon/config/dyncfg-internals.h
new file mode 100644
index 000000000..181d2328f
--- /dev/null
+++ b/src/daemon/config/dyncfg-internals.h
@@ -0,0 +1,145 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+#ifndef NETDATA_DYNCFG_INTERNALS_H
+#define NETDATA_DYNCFG_INTERNALS_H
+
+#include "../common.h"
+#include "database/rrd.h"
+#include "database/rrdfunctions.h"
+#include "database/rrdfunctions-internals.h"
+#include "database/rrdcollector-internals.h"
+
+typedef struct dyncfg {
+    UUID host_uuid;
+    STRING *function;
+    STRING *template;
+    STRING *path;
+    DYNCFG_CMDS cmds;
+    DYNCFG_TYPE type;
+
+    HTTP_ACCESS view_access;
+    HTTP_ACCESS edit_access;
+
+    struct {
+        DYNCFG_STATUS status;
+        DYNCFG_SOURCE_TYPE source_type;
+        STRING *source;
+        usec_t created_ut;
+        usec_t modified_ut;
+    } current;
+
+    struct {
+        uint32_t saves;
+        bool restart_required;
+        bool plugin_rejected;
+        bool user_disabled;
+        DYNCFG_STATUS status;
+        DYNCFG_SOURCE_TYPE source_type;
+        STRING *source;
+        BUFFER *payload;
+        usec_t created_ut;
+        usec_t modified_ut;
+    } dyncfg;
+
+    bool sync;
+    rrd_function_execute_cb_t execute_cb;
+    void *execute_cb_data;
+} DYNCFG;
+
+struct dyncfg_globals {
+    const char *dir;
+    DICTIONARY *nodes;
+};
+
+extern struct dyncfg_globals dyncfg_globals;
+
+void dyncfg_load_all(void);
+void dyncfg_file_load(const char *filename);
+void dyncfg_file_save(const char *id, DYNCFG *df);
+void dyncfg_file_delete(const char *id);
+
+bool dyncfg_get_schema(const char *id, BUFFER *dst);
+
+void dyncfg_echo_cb(BUFFER *wb, int code, void *result_cb_data);
+void dyncfg_echo(const DICTIONARY_ITEM *item, DYNCFG *df, const char *id, DYNCFG_CMDS cmd);
+void dyncfg_echo_update(const DICTIONARY_ITEM *item, DYNCFG *df, const char *id);
+void dyncfg_echo_add(const DICTIONARY_ITEM *item_template, const DICTIONARY_ITEM *item_job, DYNCFG *df_template, DYNCFG *df_job, const char *template_id, const char *job_name);
+
+const DICTIONARY_ITEM *dyncfg_add_internal(RRDHOST *host, const char *id, const char *path,
+                                           DYNCFG_STATUS status, DYNCFG_TYPE type, DYNCFG_SOURCE_TYPE source_type,
+                                           const char *source, DYNCFG_CMDS cmds,
+                                           usec_t created_ut, usec_t modified_ut,
+                                           bool sync, HTTP_ACCESS view_access, HTTP_ACCESS edit_access,
+                                           rrd_function_execute_cb_t execute_cb, void *execute_cb_data,
+                                           bool overwrite_cb);
+
+int dyncfg_function_intercept_cb(struct rrd_function_execute *rfe, void *data);
+void dyncfg_cleanup(DYNCFG *v);
+
+const DICTIONARY_ITEM *dyncfg_get_template_of_new_job(const char *job_id);
+
+bool dyncfg_is_user_disabled(const char *id);
+
+RRDHOST *dyncfg_rrdhost_by_uuid(UUID *uuid);
+RRDHOST *dyncfg_rrdhost(DYNCFG *df);
+
+static inline void dyncfg_copy_dyncfg_source_to_current(DYNCFG *df) {
+    STRING *old = df->current.source;
+    df->current.source = string_dup(df->dyncfg.source);
+    string_freez(old);
+}
+
+static inline void dyncfg_set_dyncfg_source_from_txt(DYNCFG *df, const char *source) {
+    STRING *old = df->dyncfg.source;
+    df->dyncfg.source = string_strdupz(source);
+    string_freez(old);
+}
+
+static inline void dyncfg_set_current_from_dyncfg(DYNCFG *df) {
+    df->current.status = df->dyncfg.status;
+    df->current.source_type = df->dyncfg.source_type;
+
+    dyncfg_copy_dyncfg_source_to_current(df);
+
+    if(df->dyncfg.created_ut < df->current.created_ut)
+        df->current.created_ut = df->dyncfg.created_ut;
+
+    if(df->dyncfg.modified_ut > df->current.modified_ut)
+        df->current.modified_ut = df->dyncfg.modified_ut;
+}
+
+static inline void dyncfg_update_status_on_successful_add_or_update(DYNCFG *df, int code) {
+    df->dyncfg.plugin_rejected = false;
+
+    if (code == DYNCFG_RESP_ACCEPTED_RESTART_REQUIRED)
+        df->dyncfg.restart_required = true;
+    else
+        df->dyncfg.restart_required = false;
+
+    dyncfg_set_current_from_dyncfg(df);
+}
+
+static inline DYNCFG_STATUS dyncfg_status_from_successful_response(int code) {
+    DYNCFG_STATUS status = DYNCFG_STATUS_ACCEPTED;
+
+    switch(code) {
+        default:
+        case DYNCFG_RESP_ACCEPTED:
+        case DYNCFG_RESP_ACCEPTED_RESTART_REQUIRED:
+            status = DYNCFG_STATUS_ACCEPTED;
+            break;
+
+        case DYNCFG_RESP_ACCEPTED_DISABLED:
+            status = DYNCFG_STATUS_DISABLED;
+            break;
+
+        case DYNCFG_RESP_RUNNING:
+            status = DYNCFG_STATUS_RUNNING;
+            break;
+
+    }
+
+    return status;
+}
+
+#endif //NETDATA_DYNCFG_INTERNALS_H