Adding upstream version 1.34.0.upstream/1.34.0

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 0 insertions, 189 deletions

diff --git a/backends/mongodb/mongodb.c b/backends/mongodb/mongodb.c
deleted file mode 100644
index d0527a72..00000000
--- a/backends/mongodb/mongodb.c
+++ /dev/null
@@ -1,189 +0,0 @@
-// SPDX-License-Identifier: GPL-3.0-or-later
-
-#define BACKENDS_INTERNALS
-#include "mongodb.h"
-#include <mongoc.h>
-
-#define CONFIG_FILE_LINE_MAX ((CONFIG_MAX_NAME + CONFIG_MAX_VALUE + 1024) * 2)
-
-static mongoc_client_t *mongodb_client;
-static mongoc_collection_t *mongodb_collection;
-
-int backends_mongodb_init(const char *uri_string,
-                 const char *database_string,
-                 const char *collection_string,
-                 int32_t default_socket_timeout) {
-    mongoc_uri_t *uri;
-    bson_error_t error;
-
-    mongoc_init();
-
-    uri = mongoc_uri_new_with_error(uri_string, &error);
-    if(unlikely(!uri)) {
-        error("BACKEND: failed to parse URI: %s. Error message: %s", uri_string, error.message);
-        return 1;
-    }
-
-    int32_t socket_timeout = mongoc_uri_get_option_as_int32(uri, MONGOC_URI_SOCKETTIMEOUTMS, default_socket_timeout);
-    if(!mongoc_uri_set_option_as_int32(uri, MONGOC_URI_SOCKETTIMEOUTMS, socket_timeout)) {
-        error("BACKEND: failed to set %s to the value %d", MONGOC_URI_SOCKETTIMEOUTMS, socket_timeout);
-        return 1;
-    };
-
-    mongodb_client = mongoc_client_new_from_uri(uri);
-    if(unlikely(!mongodb_client)) {
-        error("BACKEND: failed to create a new client");
-        return 1;
-    }
-
-    if(!mongoc_client_set_appname(mongodb_client, "netdata")) {
-        error("BACKEND: failed to set client appname");
-    };
-
-    mongodb_collection = mongoc_client_get_collection(mongodb_client, database_string, collection_string);
-
-    mongoc_uri_destroy(uri);
-
-    return 0;
-}
-
-void backends_free_bson(bson_t **insert, size_t n_documents) {
-    size_t i;
-
-    for(i = 0; i < n_documents; i++)
-        bson_destroy(insert[i]);
-
-    free(insert);
-}
-
-int backends_mongodb_insert(char *data, size_t n_metrics) {
-    bson_t **insert = calloc(n_metrics, sizeof(bson_t *));
-    bson_error_t error;
-    char *start = data, *end = data;
-    size_t n_documents = 0;
-
-    while(*end && n_documents <= n_metrics) {
-        while(*end && *end != '\n') end++;
-
-        if(likely(*end)) {
-            *end = '\0';
-            end++;
-        }
-        else {
-            break;
-        }
-
-        insert[n_documents] = bson_new_from_json((const uint8_t *)start, -1, &error);
-
-        if(unlikely(!insert[n_documents])) {
-           error("BACKEND: %s", error.message);
-           backends_free_bson(insert, n_documents);
-           return 1;
-        }
-
-        start = end;
-
-        n_documents++;
-    }
-
-    if(unlikely(!mongoc_collection_insert_many(mongodb_collection, (const bson_t **)insert, n_documents, NULL, NULL, &error))) {
-       error("BACKEND: %s", error.message);
-       backends_free_bson(insert, n_documents);
-       return 1;
-    }
-
-    backends_free_bson(insert, n_documents);
-
-    return 0;
-}
-
-void backends_mongodb_cleanup() {
-    mongoc_collection_destroy(mongodb_collection);
-    mongoc_client_destroy(mongodb_client);
-    mongoc_cleanup();
-
-    return;
-}
-
-int read_mongodb_conf(const char *path, char **uri_p, char **database_p, char **collection_p) {
-    char *uri = *uri_p;
-    char *database = *database_p;
-    char *collection = *collection_p;
-
-    if(unlikely(uri)) freez(uri);
-    if(unlikely(database)) freez(database);
-    if(unlikely(collection)) freez(collection);
-    uri = NULL;
-    database = NULL;
-    collection = NULL;
-
-    int line = 0;
-
-    char filename[FILENAME_MAX + 1];
-    snprintfz(filename, FILENAME_MAX, "%s/mongodb.conf", path);
-
-    char buffer[CONFIG_FILE_LINE_MAX + 1], *s;
-
-    debug(D_BACKEND, "BACKEND: opening config file '%s'", filename);
-
-    FILE *fp = fopen(filename, "r");
-    if(!fp) {
-        return 1;
-    }
-
-    while(fgets(buffer, CONFIG_FILE_LINE_MAX, fp) != NULL) {
-        buffer[CONFIG_FILE_LINE_MAX] = '\0';
-        line++;
-
-        s = trim(buffer);
-        if(!s || *s == '#') {
-            debug(D_BACKEND, "BACKEND: ignoring line %d of file '%s', it is empty.", line, filename);
-            continue;
-        }
-
-        char *name = s;
-        char *value = strchr(s, '=');
-        if(unlikely(!value)) {
-            error("BACKEND: ignoring line %d ('%s') of file '%s', there is no = in it.", line, s, filename);
-            continue;
-        }
-        *value = '\0';
-        value++;
-
-        name = trim(name);
-        value = trim(value);
-
-        if(unlikely(!name || *name == '#')) {
-            error("BACKEND: ignoring line %d of file '%s', name is empty.", line, filename);
-            continue;
-        }
-
-        if(!value)
-            value = "";
-        else
-            value = strip_quotes(value);
-
-        if(name[0] == 'u' && !strcmp(name, "uri")) {
-            uri = strdupz(value);
-        }
-        else if(name[0] == 'd' && !strcmp(name, "database")) {
-            database = strdupz(value);
-        }
-        else if(name[0] == 'c' && !strcmp(name, "collection")) {
-            collection = strdupz(value);
-        }
-    }
-
-    fclose(fp);
-
-    if(unlikely(!collection || !*collection)) {
-        error("BACKEND: collection name is a mandatory MongoDB parameter, but it is not configured");
-        return 1;
-    }
-
-    *uri_p = uri;
-    *database_p = database;
-    *collection_p = collection;
-
-    return 0;
-}