From: Sebastian Harl Date: Tue, 19 Aug 2014 03:31:00 +0000 (-0700) Subject: Moved backends from src/backend/ to src/plugins/backend/. X-Git-Tag: sysdb-0.4.0~24 X-Git-Url: https://git.tokkee.org/?a=commitdiff_plain;h=dc433b9c8b4187faee94d972b333a91b22eaf9e0;p=sysdb.git Moved backends from src/backend/ to src/plugins/backend/. --- diff --git a/src/Makefile.am b/src/Makefile.am index faea551..97c3188 100644 --- a/src/Makefile.am +++ b/src/Makefile.am @@ -159,27 +159,27 @@ sysdbd_DEPENDENCIES += plugins/cname/dns.la endif if BUILD_PLUGIN_COLLECTD -pkgbackendcollectdlib_LTLIBRARIES += backend/collectd/unixsock.la -backend_collectd_unixsock_la_SOURCES = backend/collectd/unixsock.c -backend_collectd_unixsock_la_LDFLAGS = $(AM_LDFLAGS) -module -avoid-version -sysdbd_LDADD += -dlopen backend/collectd/unixsock.la -sysdbd_DEPENDENCIES += backend/collectd/unixsock.la +pkgbackendcollectdlib_LTLIBRARIES += plugins/backend/collectd/unixsock.la +plugins_backend_collectd_unixsock_la_SOURCES = plugins/backend/collectd/unixsock.c +plugins_backend_collectd_unixsock_la_LDFLAGS = $(AM_LDFLAGS) -module -avoid-version +sysdbd_LDADD += -dlopen plugins/backend/collectd/unixsock.la +sysdbd_DEPENDENCIES += plugins/backend/collectd/unixsock.la endif if BUILD_PLUGIN_MKLIVESTATUS -pkgbackendlib_LTLIBRARIES += backend/mk-livestatus.la -backend_mk_livestatus_la_SOURCES = backend/mk-livestatus.c -backend_mk_livestatus_la_LDFLAGS = $(AM_LDFLAGS) -module -avoid-version -sysdbd_LDADD += -dlopen backend/mk-livestatus.la -sysdbd_DEPENDENCIES += backend/mk-livestatus.la +pkgbackendlib_LTLIBRARIES += plugins/backend/mk-livestatus.la +plugins_backend_mk_livestatus_la_SOURCES = plugins/backend/mk-livestatus.c +plugins_backend_mk_livestatus_la_LDFLAGS = $(AM_LDFLAGS) -module -avoid-version +sysdbd_LDADD += -dlopen plugins/backend/mk-livestatus.la +sysdbd_DEPENDENCIES += plugins/backend/mk-livestatus.la endif if BUILD_PLUGIN_PUPPETSTORECONFIGS -pkgbackendpuppetlib_LTLIBRARIES += backend/puppet/store-configs.la -backend_puppet_store_configs_la_SOURCES = backend/puppet/store-configs.c -backend_puppet_store_configs_la_LDFLAGS = $(AM_LDFLAGS) -module -avoid-version -sysdbd_LDADD += -dlopen backend/puppet/store-configs.la -sysdbd_DEPENDENCIES += backend/puppet/store-configs.la +pkgbackendpuppetlib_LTLIBRARIES += plugins/backend/puppet/store-configs.la +plugins_backend_puppet_store_configs_la_SOURCES = plugins/backend/puppet/store-configs.c +plugins_backend_puppet_store_configs_la_LDFLAGS = $(AM_LDFLAGS) -module -avoid-version +sysdbd_LDADD += -dlopen plugins/backend/puppet/store-configs.la +sysdbd_DEPENDENCIES += plugins/backend/puppet/store-configs.la endif if BUILD_PLUGIN_SYSLOG diff --git a/src/backend/collectd/unixsock.c b/src/backend/collectd/unixsock.c deleted file mode 100644 index c0d023e..0000000 --- a/src/backend/collectd/unixsock.c +++ /dev/null @@ -1,429 +0,0 @@ -/* - * SysDB - src/backend/collectd/unixsock.c - * Copyright (C) 2012 Sebastian 'tokkee' Harl - * All rights reserved. - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions - * are met: - * 1. Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * 2. Redistributions in binary form must reproduce the above copyright - * notice, this list of conditions and the following disclaimer in the - * documentation and/or other materials provided with the distribution. - * - * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS - * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED - * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR - * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDERS OR - * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, - * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, - * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; - * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, - * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR - * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF - * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - */ - -#if HAVE_CONFIG_H -# include "config.h" -#endif /* HAVE_CONFIG_H */ - -#include "sysdb.h" -#include "core/plugin.h" -#include "core/store.h" -#include "utils/error.h" -#include "utils/unixsock.h" - -#include "liboconfig/utils.h" - -#include - -#include - -#include -#include -#include - -SDB_PLUGIN_MAGIC; - -/* - * private data types - */ - -typedef struct { - char *current_host; - sdb_time_t current_timestamp; - int metrics_updated; - int metrics_failed; -} sdb_collectd_state_t; -#define SDB_COLLECTD_STATE_INIT { NULL, 0, 0, 0 } - -/* - * private helper functions - */ - -/* store the specified host-name (once per iteration) */ -static int -sdb_collectd_store_host(sdb_collectd_state_t *state, - const char *hostname, sdb_time_t last_update) -{ - int status; - - if (last_update > state->current_timestamp) - state->current_timestamp = last_update; - - if (state->current_host && (! strcasecmp(state->current_host, hostname))) - return 0; - /* else: first/new host */ - - if (state->current_host) { - sdb_log(SDB_LOG_DEBUG, "collectd::unixsock backend: Added/updated " - "%i metric%s (%i failed) for host '%s'.", - state->metrics_updated, state->metrics_updated == 1 ? "" : "s", - state->metrics_failed, state->current_host); - state->metrics_updated = state->metrics_failed = 0; - free(state->current_host); - } - - state->current_host = strdup(hostname); - if (! state->current_host) { - char errbuf[1024]; - sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to allocate " - "string buffer: %s", - sdb_strerror(errno, errbuf, sizeof(errbuf))); - return -1; - } - - status = sdb_store_host(hostname, last_update); - - if (status < 0) { - sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to " - "store/update host '%s'.", hostname); - return -1; - } - else if (status > 0) /* value too old */ - return 0; - - sdb_log(SDB_LOG_DEBUG, "collectd::unixsock backend: Added/updated " - "host '%s' (last update timestamp = %"PRIsdbTIME").", - hostname, last_update); - return 0; -} /* sdb_collectd_store_host */ - -static int -sdb_collectd_add_metrics(const char *hostname, char *plugin, char *type, - sdb_time_t last_update) -{ - char name[strlen(plugin) + strlen(type) + 2]; - char *plugin_instance, *type_instance; - - sdb_data_t data = { SDB_TYPE_STRING, { .string = NULL } }; - - int status; - - snprintf(name, sizeof(name), "%s/%s", plugin, type); - - status = sdb_store_metric(hostname, name, NULL, last_update); - if (status < 0) { - sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to " - "store/update metric '%s/%s'.", hostname, name); - return -1; - } - - plugin_instance = strchr(plugin, '-'); - if (plugin_instance) { - *plugin_instance = '\0'; - ++plugin_instance; - - data.data.string = plugin_instance; - sdb_store_metric_attr(hostname, name, - "plugin_instance", &data, last_update); - } - - type_instance = strchr(type, '-'); - if (type_instance) { - *type_instance = '\0'; - ++type_instance; - - data.data.string = type_instance; - sdb_store_metric_attr(hostname, name, - "type_instance", &data, last_update); - } - - data.data.string = plugin; - sdb_store_metric_attr(hostname, name, "plugin", &data, last_update); - data.data.string = type; - sdb_store_metric_attr(hostname, name, "type", &data, last_update); - return 0; -} /* sdb_collectd_add_metrics */ - -static int -sdb_collectd_get_data(sdb_unixsock_client_t __attribute__((unused)) *client, - size_t n, sdb_data_t *data, sdb_object_t *user_data) -{ - sdb_collectd_state_t *state; - sdb_data_t last_update; - - char *hostname; - char *plugin; - char *type; - - assert(user_data); - - /* 0: - * 1: - * 2: */ - assert(n == 3); - assert((data[0].type == SDB_TYPE_STRING) - && (data[1].type == SDB_TYPE_STRING) - && (data[2].type == SDB_TYPE_STRING)); - - hostname = data[0].data.string; - plugin = data[1].data.string; - type = data[2].data.string; - - hostname = strchr(hostname, ' '); - if (! hostname) { - sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Expected to find " - "a space character in the LISTVAL response"); - return -1; - } - *hostname = '\0'; - ++hostname; - - if (sdb_data_parse(data[0].data.string, SDB_TYPE_DATETIME, &last_update)) { - char errbuf[1024]; - sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to parse " - "timestamp '%s' returned by LISTVAL: %s", data[0].data.string, - sdb_strerror(errno, errbuf, sizeof(errbuf))); - return -1; - } - - state = SDB_OBJ_WRAPPER(user_data)->data; - if (sdb_collectd_store_host(state, hostname, last_update.data.datetime)) - return -1; - - if (sdb_collectd_add_metrics(hostname, plugin, type, - last_update.data.datetime)) - ++state->metrics_failed; - else - ++state->metrics_updated; - return 0; -} /* sdb_collectd_get_data */ - -/* - * plugin API - */ - -static int -sdb_collectd_init(sdb_object_t *user_data) -{ - sdb_unixsock_client_t *client; - - if (! user_data) - return -1; - - client = SDB_OBJ_WRAPPER(user_data)->data; - if (sdb_unixsock_client_connect(client)) { - sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: " - "Failed to connect to collectd."); - return -1; - } - - sdb_log(SDB_LOG_INFO, "collectd::unixsock backend: Successfully " - "connected to collectd @ %s.", - sdb_unixsock_client_path(client)); - return 0; -} /* sdb_collectd_init */ - -static int -sdb_collectd_shutdown(__attribute__((unused)) sdb_object_t *user_data) -{ - if (! user_data) - return -1; - - sdb_unixsock_client_destroy(SDB_OBJ_WRAPPER(user_data)->data); - SDB_OBJ_WRAPPER(user_data)->data = NULL; - return 0; -} /* sdb_collectd_shutdown */ - -static int -sdb_collectd_collect(sdb_object_t *user_data) -{ - sdb_unixsock_client_t *client; - - char buffer[1024]; - char *line; - char *msg; - - char *endptr = NULL; - long int count; - - sdb_collectd_state_t state = SDB_COLLECTD_STATE_INIT; - sdb_object_wrapper_t state_obj = SDB_OBJECT_WRAPPER_STATIC(&state); - - if (! user_data) - return -1; - - client = SDB_OBJ_WRAPPER(user_data)->data; - - if (sdb_unixsock_client_send(client, "LISTVAL") <= 0) { - sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to send " - "LISTVAL command to collectd @ %s.", - sdb_unixsock_client_path(client)); - return -1; - } - - line = sdb_unixsock_client_recv(client, buffer, sizeof(buffer)); - if (! line) { - sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to read " - "status of LISTVAL command from collectd @ %s.", - sdb_unixsock_client_path(client)); - return -1; - } - - msg = strchr(line, ' '); - if (msg) { - *msg = '\0'; - ++msg; - } - - errno = 0; - count = strtol(line, &endptr, /* base */ 0); - if (errno || (line == endptr)) { - sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to parse " - "status of LISTVAL command from collectd @ %s.", - sdb_unixsock_client_path(client)); - return -1; - } - - if (count < 0) { - sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to get " - "value list from collectd @ %s: %s", - sdb_unixsock_client_path(client), - msg ? msg : line); - return -1; - } - - if (sdb_unixsock_client_process_lines(client, sdb_collectd_get_data, - SDB_OBJ(&state_obj), count, /* delim */ "/", - /* column count = */ 3, - SDB_TYPE_STRING, SDB_TYPE_STRING, SDB_TYPE_STRING)) { - sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed " - "to read response from collectd @ %s.", - sdb_unixsock_client_path(client)); - return -1; - } - - if (state.current_host) { - sdb_log(SDB_LOG_DEBUG, "collectd::unixsock backend: Added/updated " - "%i metric%s (%i failed) for host '%s'.", - state.metrics_updated, state.metrics_updated == 1 ? "" : "s", - state.metrics_failed, state.current_host); - free(state.current_host); - } - return 0; -} /* sdb_collectd_collect */ - -static int -sdb_collectd_config_instance(oconfig_item_t *ci) -{ - char *name = NULL; - char *socket_path = NULL; - - sdb_object_t *user_data; - sdb_unixsock_client_t *client; - - int i; - - if (oconfig_get_string(ci, &name)) { - sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Instance requires " - "a single string argument\n\tUsage: "); - return -1; - } - - for (i = 0; i < ci->children_num; ++i) { - oconfig_item_t *child = ci->children + i; - - if (! strcasecmp(child->key, "Socket")) - oconfig_get_string(child, &socket_path); - else - sdb_log(SDB_LOG_WARNING, "collectd::unixsock backend: Ignoring " - "unknown config option '%s' inside .", - child->key, name); - } - - if (! socket_path) { - sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Instance '%s' " - "missing the 'Socket' option.", name); - return -1; - } - - client = sdb_unixsock_client_create(socket_path); - if (! client) { - char errbuf[1024]; - sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to create " - "unixsock client: %s", - sdb_strerror(errno, errbuf, sizeof(errbuf))); - return -1; - } - - user_data = sdb_object_create_wrapper("unixsock-client", client, - (void (*)(void *))sdb_unixsock_client_destroy); - if (! user_data) { - sdb_unixsock_client_destroy(client); - sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to allocate " - "sdb_object_t"); - return -1; - } - - sdb_plugin_register_init(name, sdb_collectd_init, user_data); - sdb_plugin_register_shutdown(name, sdb_collectd_shutdown, user_data); - - sdb_plugin_register_collector(name, sdb_collectd_collect, - /* interval */ NULL, user_data); - - /* pass control to the list */ - sdb_object_deref(user_data); - return 0; -} /* sdb_collectd_config_instance */ - -static int -sdb_collectd_config(oconfig_item_t *ci) -{ - int i; - - if (! ci) /* nothing to do to deconfigure this plugin */ - return 0; - - for (i = 0; i < ci->children_num; ++i) { - oconfig_item_t *child = ci->children + i; - - if (! strcasecmp(child->key, "Instance")) - sdb_collectd_config_instance(child); - else - sdb_log(SDB_LOG_WARNING, "collectd::unixsock backend: Ignoring " - "unknown config option '%s'.", child->key); - } - return 0; -} /* sdb_collectd_config */ - -int -sdb_module_init(sdb_plugin_info_t *info) -{ - sdb_plugin_set_info(info, SDB_PLUGIN_INFO_DESC, - "backend accessing the system statistics collection daemon " - "throught the UNIXSOCK interface"); - sdb_plugin_set_info(info, SDB_PLUGIN_INFO_COPYRIGHT, - "Copyright (C) 2012 Sebastian 'tokkee' Harl "); - sdb_plugin_set_info(info, SDB_PLUGIN_INFO_LICENSE, "BSD"); - sdb_plugin_set_info(info, SDB_PLUGIN_INFO_VERSION, SDB_VERSION); - sdb_plugin_set_info(info, SDB_PLUGIN_INFO_PLUGIN_VERSION, SDB_VERSION); - - sdb_plugin_register_config(sdb_collectd_config); - return 0; -} /* sdb_version_extra */ - -/* vim: set tw=78 sw=4 ts=4 noexpandtab : */ - diff --git a/src/backend/mk-livestatus.c b/src/backend/mk-livestatus.c deleted file mode 100644 index 0f94ce3..0000000 --- a/src/backend/mk-livestatus.c +++ /dev/null @@ -1,333 +0,0 @@ -/* - * SysDB - src/backend/mk-livestatus.c - * Copyright (C) 2012 Sebastian 'tokkee' Harl - * All rights reserved. - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions - * are met: - * 1. Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * 2. Redistributions in binary form must reproduce the above copyright - * notice, this list of conditions and the following disclaimer in the - * documentation and/or other materials provided with the distribution. - * - * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS - * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED - * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR - * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDERS OR - * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, - * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, - * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; - * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, - * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR - * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF - * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - */ - -#if HAVE_CONFIG_H -# include "config.h" -#endif /* HAVE_CONFIG_H */ - -#include "sysdb.h" -#include "core/plugin.h" -#include "core/store.h" -#include "utils/error.h" -#include "utils/unixsock.h" - -#include "liboconfig/utils.h" - -#include - -#include - -#include -#include -#include - -SDB_PLUGIN_MAGIC; - -/* - * private helper functions - */ - -static int -sdb_livestatus_get_host(sdb_unixsock_client_t __attribute__((unused)) *client, - size_t n, sdb_data_t *data, - sdb_object_t __attribute__((unused)) *user_data) -{ - const char *hostname; - sdb_time_t timestamp; - - int status; - - assert(n == 2); - assert((data[0].type == SDB_TYPE_STRING) - && (data[1].type == SDB_TYPE_DATETIME)); - - hostname = data[0].data.string; - timestamp = data[1].data.datetime; - - status = sdb_store_host(hostname, timestamp); - - if (status < 0) { - sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to " - "store/update host '%s'.", hostname); - return -1; - } - else if (status > 0) /* value too old */ - return 0; - - sdb_log(SDB_LOG_DEBUG, "MK Livestatus backend: Added/updated " - "host '%s' (last update timestamp = %"PRIsdbTIME").", - hostname, timestamp); - return 0; -} /* sdb_livestatus_get_host */ - -static int -sdb_livestatus_get_svc(sdb_unixsock_client_t __attribute__((unused)) *client, - size_t n, sdb_data_t *data, - sdb_object_t __attribute__((unused)) *user_data) -{ - const char *hostname = NULL; - const char *svcname = NULL; - sdb_time_t timestamp = 0; - - int status; - - assert(n == 3); - assert((data[0].type == SDB_TYPE_STRING) - && (data[1].type == SDB_TYPE_STRING) - && (data[2].type == SDB_TYPE_DATETIME)); - - hostname = data[0].data.string; - svcname = data[1].data.string; - timestamp = data[2].data.datetime; - - status = sdb_store_service(hostname, svcname, timestamp); - - if (status < 0) { - sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to " - "store/update service '%s / %s'.", hostname, svcname); - return -1; - } - else if (status > 0) /* value too old */ - return 0; - - sdb_log(SDB_LOG_DEBUG, "MK Livestatus backend: Added/updated " - "service '%s / %s' (last update timestamp = %"PRIsdbTIME").", - hostname, svcname, timestamp); - return 0; -} /* sdb_livestatus_get_svc */ - -/* - * plugin API - */ - -static int -sdb_livestatus_init(sdb_object_t *user_data) -{ - sdb_unixsock_client_t *client; - - if (! user_data) - return -1; - - client = SDB_OBJ_WRAPPER(user_data)->data; - if (sdb_unixsock_client_connect(client)) { - sdb_log(SDB_LOG_ERR, "MK Livestatus backend: " - "Failed to connect to livestatus @ %s.", - sdb_unixsock_client_path(client)); - return -1; - } - - sdb_log(SDB_LOG_INFO, "MK Livestatus backend: Successfully " - "connected to livestatus @ %s.", - sdb_unixsock_client_path(client)); - return 0; -} /* sdb_livestatus_init */ - -static int -sdb_livestatus_shutdown(sdb_object_t *user_data) -{ - if (! user_data) - return -1; - - sdb_unixsock_client_destroy(SDB_OBJ_WRAPPER(user_data)->data); - SDB_OBJ_WRAPPER(user_data)->data = NULL; - return 0; -} /* sdb_livestatus_shutdown */ - -static int -sdb_livestatus_collect(sdb_object_t *user_data) -{ - sdb_unixsock_client_t *client; - - int status; - - if (! user_data) - return -1; - - client = SDB_OBJ_WRAPPER(user_data)->data; - - status = sdb_unixsock_client_send(client, "GET hosts\r\n" - "Columns: name last_check"); - if (status <= 0) { - sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to send " - "'GET hosts' command to livestatus @ %s.", - sdb_unixsock_client_path(client)); - return -1; - } - - sdb_unixsock_client_shutdown(client, SHUT_WR); - - if (sdb_unixsock_client_process_lines(client, sdb_livestatus_get_host, - /* user data */ NULL, /* -> EOF */ -1, /* delim */ ";", - /* column count */ 2, SDB_TYPE_STRING, SDB_TYPE_DATETIME)) { - sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to read " - "response from livestatus @ %s while reading hosts.", - sdb_unixsock_client_path(client)); - return -1; - } - - if ((! sdb_unixsock_client_eof(client)) - || sdb_unixsock_client_error(client)) { - char errbuf[1024]; - sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to read " - "host from livestatus @ %s: %s", - sdb_unixsock_client_path(client), - sdb_strerror(errno, errbuf, sizeof(errbuf))); - return -1; - } - - status = sdb_unixsock_client_send(client, "GET services\r\n" - "Columns: host_name description last_check"); - if (status <= 0) { - sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to send " - "'GET services' command to livestatus @ %s.", - sdb_unixsock_client_path(client)); - return -1; - } - - sdb_unixsock_client_shutdown(client, SHUT_WR); - - if (sdb_unixsock_client_process_lines(client, sdb_livestatus_get_svc, - /* user data */ NULL, /* -> EOF */ -1, /* delim */ ";", - /* column count */ 3, SDB_TYPE_STRING, SDB_TYPE_STRING, - SDB_TYPE_DATETIME)) { - sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to read " - "response from livestatus @ %s while reading services.", - sdb_unixsock_client_path(client)); - return -1; - } - - if ((! sdb_unixsock_client_eof(client)) - || sdb_unixsock_client_error(client)) { - char errbuf[1024]; - sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to read " - "services from livestatus @ %s: %s", - sdb_unixsock_client_path(client), - sdb_strerror(errno, errbuf, sizeof(errbuf))); - return -1; - } - return 0; -} /* sdb_livestatus_collect */ - -static int -sdb_livestatus_config_instance(oconfig_item_t *ci) -{ - char *name = NULL; - char *socket_path = NULL; - - sdb_object_t *user_data; - sdb_unixsock_client_t *client; - - int i; - - if (oconfig_get_string(ci, &name)) { - sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Instance requires " - "a single string argument\n\tUsage: "); - return -1; - } - - for (i = 0; i < ci->children_num; ++i) { - oconfig_item_t *child = ci->children + i; - - if (! strcasecmp(child->key, "Socket")) - oconfig_get_string(child, &socket_path); - else - sdb_log(SDB_LOG_WARNING, "MK Livestatus backend: Ignoring " - "unknown config option '%s' inside .", - child->key, name); - } - - if (! socket_path) { - sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Instance '%s' " - "missing the 'Socket' option.", name); - return -1; - } - - client = sdb_unixsock_client_create(socket_path); - if (! client) { - char errbuf[1024]; - sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to create " - "unixsock client: %s", - sdb_strerror(errno, errbuf, sizeof(errbuf))); - return -1; - } - - user_data = sdb_object_create_wrapper("unixsock-client", client, - (void (*)(void *))sdb_unixsock_client_destroy); - if (! user_data) { - sdb_unixsock_client_destroy(client); - sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to " - "allocate sdb_object_t"); - return -1; - } - - sdb_plugin_register_init(name, sdb_livestatus_init, user_data); - sdb_plugin_register_shutdown(name, sdb_livestatus_shutdown, user_data); - sdb_plugin_register_collector(name, sdb_livestatus_collect, - /* interval */ NULL, user_data); - - /* pass control to the list */ - sdb_object_deref(user_data); - return 0; -} /* sdb_livestatus_config_instance */ - -static int -sdb_livestatus_config(oconfig_item_t *ci) -{ - int i; - - if (! ci) /* nothing to do to deconfigure this plugin */ - return 0; - - for (i = 0; i < ci->children_num; ++i) { - oconfig_item_t *child = ci->children + i; - - if (! strcasecmp(child->key, "Instance")) - sdb_livestatus_config_instance(child); - else - sdb_log(SDB_LOG_WARNING, "MK Livestatus backend: Ignoring " - "unknown config option '%s'.", child->key); - } - return 0; -} /* sdb_livestatus_config */ - -int -sdb_module_init(sdb_plugin_info_t *info) -{ - sdb_plugin_set_info(info, SDB_PLUGIN_INFO_DESC, - "backend accessing Nagios/Icinga/Shinken using MK Livestatus"); - sdb_plugin_set_info(info, SDB_PLUGIN_INFO_COPYRIGHT, - "Copyright (C) 2012 Sebastian 'tokkee' Harl "); - sdb_plugin_set_info(info, SDB_PLUGIN_INFO_LICENSE, "BSD"); - sdb_plugin_set_info(info, SDB_PLUGIN_INFO_VERSION, SDB_VERSION); - sdb_plugin_set_info(info, SDB_PLUGIN_INFO_PLUGIN_VERSION, SDB_VERSION); - - sdb_plugin_register_config(sdb_livestatus_config); - return 0; -} /* sdb_version_extra */ - -/* vim: set tw=78 sw=4 ts=4 noexpandtab : */ - diff --git a/src/backend/puppet/store-configs.c b/src/backend/puppet/store-configs.c deleted file mode 100644 index 5efc531..0000000 --- a/src/backend/puppet/store-configs.c +++ /dev/null @@ -1,384 +0,0 @@ -/* - * SysDB - src/backend/puppet/store-configs.c - * Copyright (C) 2012 Sebastian 'tokkee' Harl - * All rights reserved. - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions - * are met: - * 1. Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * 2. Redistributions in binary form must reproduce the above copyright - * notice, this list of conditions and the following disclaimer in the - * documentation and/or other materials provided with the distribution. - * - * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS - * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED - * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR - * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDERS OR - * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, - * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, - * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; - * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, - * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR - * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF - * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - */ - -#include "sysdb.h" -#include "core/plugin.h" -#include "core/store.h" -#include "utils/dbi.h" -#include "utils/error.h" - -#include "liboconfig/utils.h" - -#include -#include - -#include -#include - -SDB_PLUGIN_MAGIC; - -/* - * private helper functions - */ - -static int -sdb_puppet_stcfg_get_hosts(sdb_dbi_client_t __attribute__((unused)) *client, - size_t n, sdb_data_t *data, - sdb_object_t __attribute__((unused)) *user_data) -{ - const char *hostname; - sdb_time_t timestamp; - - int status; - - assert(n == 2); - assert((data[0].type == SDB_TYPE_STRING) - && (data[1].type == SDB_TYPE_DATETIME)); - - hostname = data[0].data.string; - timestamp = data[1].data.datetime; - - status = sdb_store_host(hostname, timestamp); - - if (status < 0) { - sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: Failed to " - "store/update host '%s'.", hostname); - return -1; - } - else if (! status) - sdb_log(SDB_LOG_DEBUG, "puppet::store-configs backend: " - "Added/updated host '%s' (last update timestamp = " - "%"PRIsdbTIME").", hostname, timestamp); - return 0; -} /* sdb_puppet_stcfg_get_hosts */ - -static int -sdb_puppet_stcfg_get_attrs(sdb_dbi_client_t __attribute__((unused)) *client, - size_t n, sdb_data_t *data, - sdb_object_t __attribute__((unused)) *user_data) -{ - int status; - - const char *hostname; - const char *key; - sdb_data_t value; - sdb_time_t last_update; - - assert(n == 4); - assert((data[0].type == SDB_TYPE_STRING) - && (data[1].type == SDB_TYPE_STRING) - && (data[2].type == SDB_TYPE_STRING) - && (data[3].type == SDB_TYPE_DATETIME)); - - hostname = data[0].data.string; - key = data[1].data.string; - value.type = SDB_TYPE_STRING; - value.data.string = data[2].data.string; - last_update = data[3].data.datetime; - - status = sdb_store_attribute(hostname, key, &value, last_update); - - if (status < 0) { - sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: Failed to " - "store/update host attribute '%s' for host '%s'.", - key, hostname); - return -1; - } - - return 0; -} /* sdb_puppet_stcfg_get_attrs */ - -/* - * plugin API - */ - -static int -sdb_puppet_stcfg_init(sdb_object_t *user_data) -{ - sdb_dbi_client_t *client; - - if (! user_data) - return -1; - - client = SDB_OBJ_WRAPPER(user_data)->data; - if (sdb_dbi_client_connect(client)) { - sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " - "Failed to connect to the storeconfigs DB."); - return -1; - } - - sdb_log(SDB_LOG_INFO, "puppet::store-configs backend: Successfully " - "connected to the storeconfigs DB."); - return 0; -} /* sdb_puppet_stcfg_init */ - -static int -sdb_puppet_stcfg_shutdown(sdb_object_t *user_data) -{ - if (! user_data) - return -1; - - sdb_dbi_client_destroy(SDB_OBJ_WRAPPER(user_data)->data); - SDB_OBJ_WRAPPER(user_data)->data = NULL; - return 0; -} /* sdb_puppet_stcfg_shutdown */ - -static int -sdb_puppet_stcfg_collect(sdb_object_t *user_data) -{ - sdb_dbi_client_t *client; - - if (! user_data) - return -1; - - client = SDB_OBJ_WRAPPER(user_data)->data; - if (sdb_dbi_client_check_conn(client)) { - sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " - "Connection to storeconfigs DB failed."); - return -1; - } - - if (sdb_dbi_exec_query(client, "SELECT name, updated_at FROM hosts;", - sdb_puppet_stcfg_get_hosts, NULL, /* #columns = */ 2, - /* col types = */ SDB_TYPE_STRING, SDB_TYPE_DATETIME)) { - sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: Failed to " - "retrieve hosts from the storeconfigs DB."); - return -1; - } - - if (sdb_dbi_exec_query(client, "SELECT " - "hosts.name AS hostname, " - "fact_names.name AS name, " - "fact_values.value AS value, " - "fact_values.updated_at AS updated_at " - "FROM fact_values " - "INNER JOIN hosts " - "ON fact_values.host_id = hosts.id " - "INNER JOIN fact_names " - "ON fact_values.fact_name_id = fact_names.id;", - sdb_puppet_stcfg_get_attrs, NULL, /* #columns = */ 4, - /* col types = */ SDB_TYPE_STRING, SDB_TYPE_STRING, - SDB_TYPE_STRING, SDB_TYPE_DATETIME)) { - sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: Failed to " - "retrieve host attributes from the storeconfigs DB."); - return -1; - } - return 0; -} /* sdb_puppet_stcfg_collect */ - -static int -sdb_puppet_stcfg_config_conn(oconfig_item_t *ci) -{ - char *name = NULL; - - sdb_object_t *user_data; - sdb_dbi_client_t *client; - sdb_dbi_options_t *options = NULL; - - char *driver = NULL; - char *database = NULL; - - int i; - - if (oconfig_get_string(ci, &name)) { - sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: Connection " - "requires a single string argument\n" - "\tUsage: "); - return -1; - } - - for (i = 0; i < ci->children_num; ++i) { - oconfig_item_t *child = ci->children + i; - char *key = NULL, *value = NULL; - - int status = 0; - - if (! strcasecmp(child->key, "DBAdapter")) { - if (oconfig_get_string(child, &driver)) { - sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " - "DBAdapter requires a single string argument inside " - "\n\tUsage: DBAdapter NAME", - name); - } - continue; - } - else if (! strcasecmp(child->key, "DBName")) { - if (oconfig_get_string(child, &database)) { - sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " - "DBName requires a single string argument inside " - "\n\tUsage: DBName NAME", - name); - } - continue; - } - else if (! strcasecmp(child->key, "DBServer")) { - status = oconfig_get_string(child, &value); - key = "host"; - } - else if (! strcasecmp(child->key, "DBPort")) { - status = oconfig_get_string(child, &value); - key = "port"; - } - else if (! strcasecmp(child->key, "DBUser")) { - status = oconfig_get_string(child, &value); - key = "username"; - } - else if (! strcasecmp(child->key, "DBPassword")) { - status = oconfig_get_string(child, &value); - key = "password"; - } - else if (! strcasecmp(child->key, "DBIOption")) { - if ((child->values_num != 2) - || (child->values[0].type != OCONFIG_TYPE_STRING) - || (child->values[1].type != OCONFIG_TYPE_STRING)) { - sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " - "DBIOption requires exactly two string arguments " - "inside \n" - "\tUsage: DBIOption KEY VALUE", name); - continue; - } - - status = 0; - key = child->values[0].value.string; - value = child->values[1].value.string; - } - else { - sdb_log(SDB_LOG_WARNING, "puppet::store-configs backend: " - "Ignoring unknown config option '%s' inside " - ".", child->key, name); - continue; - } - - if (status) { - sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: Option " - "'%s' requires a single string argument inside " - "\n\tUsage: DBAdapter NAME", - child->key, name); - continue; - } - - assert(key && value); - - if (! options) { - if (! (options = sdb_dbi_options_create())) { - char errmsg[1024]; - sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " - "Failed to create DBI options object: %s", - sdb_strerror(errno, errmsg, sizeof(errmsg))); - continue; - } - } - - if (sdb_dbi_options_add(options, key, value)) { - char errmsg[1024]; - sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " - "Failed to add option '%s': %s", key, - sdb_strerror(errno, errmsg, sizeof(errmsg))); - continue; - } - } - - if (! driver) { - sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " - "Connection '%s' " "missing the 'DBAdapter' option.", - name); - return -1; - } - if (! database) { - sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " - "Connection '%s' missing the 'DBName' option.", name); - return -1; - } - - client = sdb_dbi_client_create(driver, database); - if (! client) { - char errbuf[1024]; - sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " - "Failed to create DBI client: %s", - sdb_strerror(errno, errbuf, sizeof(errbuf))); - return -1; - } - - sdb_dbi_client_set_options(client, options); - - user_data = sdb_object_create_wrapper("dbi-client", client, - (void (*)(void *))sdb_dbi_client_destroy); - if (! user_data) { - sdb_dbi_client_destroy(client); - sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " - "Failed to allocate sdb_object_t"); - return -1; - } - - sdb_plugin_register_init(name, sdb_puppet_stcfg_init, user_data); - sdb_plugin_register_shutdown(name, sdb_puppet_stcfg_shutdown, - user_data); - sdb_plugin_register_collector(name, sdb_puppet_stcfg_collect, - /* interval */ NULL, user_data); - - /* pass control to the list */ - sdb_object_deref(user_data); - return 0; -} /* sdb_puppet_stcfg_config_conn */ - -static int -sdb_puppet_stcfg_config(oconfig_item_t *ci) -{ - int i; - - if (! ci) /* nothing to do to deconfigure this plugin */ - return 0; - - for (i = 0; i < ci->children_num; ++i) { - oconfig_item_t *child = ci->children + i; - - if (! strcasecmp(child->key, "Connection")) - sdb_puppet_stcfg_config_conn(child); - else - sdb_log(SDB_LOG_WARNING, "puppet::store-configs backend: " - "Ignoring unknown config option '%s'.", child->key); - } - return 0; -} /* sdb_puppet_stcfg_config */ - -int -sdb_module_init(sdb_plugin_info_t *info) -{ - sdb_plugin_set_info(info, SDB_PLUGIN_INFO_DESC, - "backend accessing the Puppet stored configuration database"); - sdb_plugin_set_info(info, SDB_PLUGIN_INFO_COPYRIGHT, - "Copyright (C) 2012 Sebastian 'tokkee' Harl "); - sdb_plugin_set_info(info, SDB_PLUGIN_INFO_LICENSE, "BSD"); - sdb_plugin_set_info(info, SDB_PLUGIN_INFO_VERSION, SDB_VERSION); - sdb_plugin_set_info(info, SDB_PLUGIN_INFO_PLUGIN_VERSION, SDB_VERSION); - - sdb_plugin_register_config(sdb_puppet_stcfg_config); - return 0; -} /* sdb_version_extra */ - -/* vim: set tw=78 sw=4 ts=4 noexpandtab : */ - diff --git a/src/plugins/backend/collectd/unixsock.c b/src/plugins/backend/collectd/unixsock.c new file mode 100644 index 0000000..29d7802 --- /dev/null +++ b/src/plugins/backend/collectd/unixsock.c @@ -0,0 +1,429 @@ +/* + * SysDB - src/plugins/backend/collectd/unixsock.c + * Copyright (C) 2012 Sebastian 'tokkee' Harl + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS + * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED + * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR + * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDERS OR + * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, + * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, + * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; + * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, + * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR + * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF + * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +#if HAVE_CONFIG_H +# include "config.h" +#endif /* HAVE_CONFIG_H */ + +#include "sysdb.h" +#include "core/plugin.h" +#include "core/store.h" +#include "utils/error.h" +#include "utils/unixsock.h" + +#include "liboconfig/utils.h" + +#include + +#include + +#include +#include +#include + +SDB_PLUGIN_MAGIC; + +/* + * private data types + */ + +typedef struct { + char *current_host; + sdb_time_t current_timestamp; + int metrics_updated; + int metrics_failed; +} sdb_collectd_state_t; +#define SDB_COLLECTD_STATE_INIT { NULL, 0, 0, 0 } + +/* + * private helper functions + */ + +/* store the specified host-name (once per iteration) */ +static int +sdb_collectd_store_host(sdb_collectd_state_t *state, + const char *hostname, sdb_time_t last_update) +{ + int status; + + if (last_update > state->current_timestamp) + state->current_timestamp = last_update; + + if (state->current_host && (! strcasecmp(state->current_host, hostname))) + return 0; + /* else: first/new host */ + + if (state->current_host) { + sdb_log(SDB_LOG_DEBUG, "collectd::unixsock backend: Added/updated " + "%i metric%s (%i failed) for host '%s'.", + state->metrics_updated, state->metrics_updated == 1 ? "" : "s", + state->metrics_failed, state->current_host); + state->metrics_updated = state->metrics_failed = 0; + free(state->current_host); + } + + state->current_host = strdup(hostname); + if (! state->current_host) { + char errbuf[1024]; + sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to allocate " + "string buffer: %s", + sdb_strerror(errno, errbuf, sizeof(errbuf))); + return -1; + } + + status = sdb_store_host(hostname, last_update); + + if (status < 0) { + sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to " + "store/update host '%s'.", hostname); + return -1; + } + else if (status > 0) /* value too old */ + return 0; + + sdb_log(SDB_LOG_DEBUG, "collectd::unixsock backend: Added/updated " + "host '%s' (last update timestamp = %"PRIsdbTIME").", + hostname, last_update); + return 0; +} /* sdb_collectd_store_host */ + +static int +sdb_collectd_add_metrics(const char *hostname, char *plugin, char *type, + sdb_time_t last_update) +{ + char name[strlen(plugin) + strlen(type) + 2]; + char *plugin_instance, *type_instance; + + sdb_data_t data = { SDB_TYPE_STRING, { .string = NULL } }; + + int status; + + snprintf(name, sizeof(name), "%s/%s", plugin, type); + + status = sdb_store_metric(hostname, name, NULL, last_update); + if (status < 0) { + sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to " + "store/update metric '%s/%s'.", hostname, name); + return -1; + } + + plugin_instance = strchr(plugin, '-'); + if (plugin_instance) { + *plugin_instance = '\0'; + ++plugin_instance; + + data.data.string = plugin_instance; + sdb_store_metric_attr(hostname, name, + "plugin_instance", &data, last_update); + } + + type_instance = strchr(type, '-'); + if (type_instance) { + *type_instance = '\0'; + ++type_instance; + + data.data.string = type_instance; + sdb_store_metric_attr(hostname, name, + "type_instance", &data, last_update); + } + + data.data.string = plugin; + sdb_store_metric_attr(hostname, name, "plugin", &data, last_update); + data.data.string = type; + sdb_store_metric_attr(hostname, name, "type", &data, last_update); + return 0; +} /* sdb_collectd_add_metrics */ + +static int +sdb_collectd_get_data(sdb_unixsock_client_t __attribute__((unused)) *client, + size_t n, sdb_data_t *data, sdb_object_t *user_data) +{ + sdb_collectd_state_t *state; + sdb_data_t last_update; + + char *hostname; + char *plugin; + char *type; + + assert(user_data); + + /* 0: + * 1: + * 2: */ + assert(n == 3); + assert((data[0].type == SDB_TYPE_STRING) + && (data[1].type == SDB_TYPE_STRING) + && (data[2].type == SDB_TYPE_STRING)); + + hostname = data[0].data.string; + plugin = data[1].data.string; + type = data[2].data.string; + + hostname = strchr(hostname, ' '); + if (! hostname) { + sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Expected to find " + "a space character in the LISTVAL response"); + return -1; + } + *hostname = '\0'; + ++hostname; + + if (sdb_data_parse(data[0].data.string, SDB_TYPE_DATETIME, &last_update)) { + char errbuf[1024]; + sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to parse " + "timestamp '%s' returned by LISTVAL: %s", data[0].data.string, + sdb_strerror(errno, errbuf, sizeof(errbuf))); + return -1; + } + + state = SDB_OBJ_WRAPPER(user_data)->data; + if (sdb_collectd_store_host(state, hostname, last_update.data.datetime)) + return -1; + + if (sdb_collectd_add_metrics(hostname, plugin, type, + last_update.data.datetime)) + ++state->metrics_failed; + else + ++state->metrics_updated; + return 0; +} /* sdb_collectd_get_data */ + +/* + * plugin API + */ + +static int +sdb_collectd_init(sdb_object_t *user_data) +{ + sdb_unixsock_client_t *client; + + if (! user_data) + return -1; + + client = SDB_OBJ_WRAPPER(user_data)->data; + if (sdb_unixsock_client_connect(client)) { + sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: " + "Failed to connect to collectd."); + return -1; + } + + sdb_log(SDB_LOG_INFO, "collectd::unixsock backend: Successfully " + "connected to collectd @ %s.", + sdb_unixsock_client_path(client)); + return 0; +} /* sdb_collectd_init */ + +static int +sdb_collectd_shutdown(__attribute__((unused)) sdb_object_t *user_data) +{ + if (! user_data) + return -1; + + sdb_unixsock_client_destroy(SDB_OBJ_WRAPPER(user_data)->data); + SDB_OBJ_WRAPPER(user_data)->data = NULL; + return 0; +} /* sdb_collectd_shutdown */ + +static int +sdb_collectd_collect(sdb_object_t *user_data) +{ + sdb_unixsock_client_t *client; + + char buffer[1024]; + char *line; + char *msg; + + char *endptr = NULL; + long int count; + + sdb_collectd_state_t state = SDB_COLLECTD_STATE_INIT; + sdb_object_wrapper_t state_obj = SDB_OBJECT_WRAPPER_STATIC(&state); + + if (! user_data) + return -1; + + client = SDB_OBJ_WRAPPER(user_data)->data; + + if (sdb_unixsock_client_send(client, "LISTVAL") <= 0) { + sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to send " + "LISTVAL command to collectd @ %s.", + sdb_unixsock_client_path(client)); + return -1; + } + + line = sdb_unixsock_client_recv(client, buffer, sizeof(buffer)); + if (! line) { + sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to read " + "status of LISTVAL command from collectd @ %s.", + sdb_unixsock_client_path(client)); + return -1; + } + + msg = strchr(line, ' '); + if (msg) { + *msg = '\0'; + ++msg; + } + + errno = 0; + count = strtol(line, &endptr, /* base */ 0); + if (errno || (line == endptr)) { + sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to parse " + "status of LISTVAL command from collectd @ %s.", + sdb_unixsock_client_path(client)); + return -1; + } + + if (count < 0) { + sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to get " + "value list from collectd @ %s: %s", + sdb_unixsock_client_path(client), + msg ? msg : line); + return -1; + } + + if (sdb_unixsock_client_process_lines(client, sdb_collectd_get_data, + SDB_OBJ(&state_obj), count, /* delim */ "/", + /* column count = */ 3, + SDB_TYPE_STRING, SDB_TYPE_STRING, SDB_TYPE_STRING)) { + sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed " + "to read response from collectd @ %s.", + sdb_unixsock_client_path(client)); + return -1; + } + + if (state.current_host) { + sdb_log(SDB_LOG_DEBUG, "collectd::unixsock backend: Added/updated " + "%i metric%s (%i failed) for host '%s'.", + state.metrics_updated, state.metrics_updated == 1 ? "" : "s", + state.metrics_failed, state.current_host); + free(state.current_host); + } + return 0; +} /* sdb_collectd_collect */ + +static int +sdb_collectd_config_instance(oconfig_item_t *ci) +{ + char *name = NULL; + char *socket_path = NULL; + + sdb_object_t *user_data; + sdb_unixsock_client_t *client; + + int i; + + if (oconfig_get_string(ci, &name)) { + sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Instance requires " + "a single string argument\n\tUsage: "); + return -1; + } + + for (i = 0; i < ci->children_num; ++i) { + oconfig_item_t *child = ci->children + i; + + if (! strcasecmp(child->key, "Socket")) + oconfig_get_string(child, &socket_path); + else + sdb_log(SDB_LOG_WARNING, "collectd::unixsock backend: Ignoring " + "unknown config option '%s' inside .", + child->key, name); + } + + if (! socket_path) { + sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Instance '%s' " + "missing the 'Socket' option.", name); + return -1; + } + + client = sdb_unixsock_client_create(socket_path); + if (! client) { + char errbuf[1024]; + sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to create " + "unixsock client: %s", + sdb_strerror(errno, errbuf, sizeof(errbuf))); + return -1; + } + + user_data = sdb_object_create_wrapper("unixsock-client", client, + (void (*)(void *))sdb_unixsock_client_destroy); + if (! user_data) { + sdb_unixsock_client_destroy(client); + sdb_log(SDB_LOG_ERR, "collectd::unixsock backend: Failed to allocate " + "sdb_object_t"); + return -1; + } + + sdb_plugin_register_init(name, sdb_collectd_init, user_data); + sdb_plugin_register_shutdown(name, sdb_collectd_shutdown, user_data); + + sdb_plugin_register_collector(name, sdb_collectd_collect, + /* interval */ NULL, user_data); + + /* pass control to the list */ + sdb_object_deref(user_data); + return 0; +} /* sdb_collectd_config_instance */ + +static int +sdb_collectd_config(oconfig_item_t *ci) +{ + int i; + + if (! ci) /* nothing to do to deconfigure this plugin */ + return 0; + + for (i = 0; i < ci->children_num; ++i) { + oconfig_item_t *child = ci->children + i; + + if (! strcasecmp(child->key, "Instance")) + sdb_collectd_config_instance(child); + else + sdb_log(SDB_LOG_WARNING, "collectd::unixsock backend: Ignoring " + "unknown config option '%s'.", child->key); + } + return 0; +} /* sdb_collectd_config */ + +int +sdb_module_init(sdb_plugin_info_t *info) +{ + sdb_plugin_set_info(info, SDB_PLUGIN_INFO_DESC, + "backend accessing the system statistics collection daemon " + "throught the UNIXSOCK interface"); + sdb_plugin_set_info(info, SDB_PLUGIN_INFO_COPYRIGHT, + "Copyright (C) 2012 Sebastian 'tokkee' Harl "); + sdb_plugin_set_info(info, SDB_PLUGIN_INFO_LICENSE, "BSD"); + sdb_plugin_set_info(info, SDB_PLUGIN_INFO_VERSION, SDB_VERSION); + sdb_plugin_set_info(info, SDB_PLUGIN_INFO_PLUGIN_VERSION, SDB_VERSION); + + sdb_plugin_register_config(sdb_collectd_config); + return 0; +} /* sdb_version_extra */ + +/* vim: set tw=78 sw=4 ts=4 noexpandtab : */ + diff --git a/src/plugins/backend/mk-livestatus.c b/src/plugins/backend/mk-livestatus.c new file mode 100644 index 0000000..599758b --- /dev/null +++ b/src/plugins/backend/mk-livestatus.c @@ -0,0 +1,333 @@ +/* + * SysDB - src/plugins/backend/mk-livestatus.c + * Copyright (C) 2012 Sebastian 'tokkee' Harl + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS + * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED + * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR + * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDERS OR + * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, + * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, + * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; + * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, + * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR + * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF + * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +#if HAVE_CONFIG_H +# include "config.h" +#endif /* HAVE_CONFIG_H */ + +#include "sysdb.h" +#include "core/plugin.h" +#include "core/store.h" +#include "utils/error.h" +#include "utils/unixsock.h" + +#include "liboconfig/utils.h" + +#include + +#include + +#include +#include +#include + +SDB_PLUGIN_MAGIC; + +/* + * private helper functions + */ + +static int +sdb_livestatus_get_host(sdb_unixsock_client_t __attribute__((unused)) *client, + size_t n, sdb_data_t *data, + sdb_object_t __attribute__((unused)) *user_data) +{ + const char *hostname; + sdb_time_t timestamp; + + int status; + + assert(n == 2); + assert((data[0].type == SDB_TYPE_STRING) + && (data[1].type == SDB_TYPE_DATETIME)); + + hostname = data[0].data.string; + timestamp = data[1].data.datetime; + + status = sdb_store_host(hostname, timestamp); + + if (status < 0) { + sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to " + "store/update host '%s'.", hostname); + return -1; + } + else if (status > 0) /* value too old */ + return 0; + + sdb_log(SDB_LOG_DEBUG, "MK Livestatus backend: Added/updated " + "host '%s' (last update timestamp = %"PRIsdbTIME").", + hostname, timestamp); + return 0; +} /* sdb_livestatus_get_host */ + +static int +sdb_livestatus_get_svc(sdb_unixsock_client_t __attribute__((unused)) *client, + size_t n, sdb_data_t *data, + sdb_object_t __attribute__((unused)) *user_data) +{ + const char *hostname = NULL; + const char *svcname = NULL; + sdb_time_t timestamp = 0; + + int status; + + assert(n == 3); + assert((data[0].type == SDB_TYPE_STRING) + && (data[1].type == SDB_TYPE_STRING) + && (data[2].type == SDB_TYPE_DATETIME)); + + hostname = data[0].data.string; + svcname = data[1].data.string; + timestamp = data[2].data.datetime; + + status = sdb_store_service(hostname, svcname, timestamp); + + if (status < 0) { + sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to " + "store/update service '%s / %s'.", hostname, svcname); + return -1; + } + else if (status > 0) /* value too old */ + return 0; + + sdb_log(SDB_LOG_DEBUG, "MK Livestatus backend: Added/updated " + "service '%s / %s' (last update timestamp = %"PRIsdbTIME").", + hostname, svcname, timestamp); + return 0; +} /* sdb_livestatus_get_svc */ + +/* + * plugin API + */ + +static int +sdb_livestatus_init(sdb_object_t *user_data) +{ + sdb_unixsock_client_t *client; + + if (! user_data) + return -1; + + client = SDB_OBJ_WRAPPER(user_data)->data; + if (sdb_unixsock_client_connect(client)) { + sdb_log(SDB_LOG_ERR, "MK Livestatus backend: " + "Failed to connect to livestatus @ %s.", + sdb_unixsock_client_path(client)); + return -1; + } + + sdb_log(SDB_LOG_INFO, "MK Livestatus backend: Successfully " + "connected to livestatus @ %s.", + sdb_unixsock_client_path(client)); + return 0; +} /* sdb_livestatus_init */ + +static int +sdb_livestatus_shutdown(sdb_object_t *user_data) +{ + if (! user_data) + return -1; + + sdb_unixsock_client_destroy(SDB_OBJ_WRAPPER(user_data)->data); + SDB_OBJ_WRAPPER(user_data)->data = NULL; + return 0; +} /* sdb_livestatus_shutdown */ + +static int +sdb_livestatus_collect(sdb_object_t *user_data) +{ + sdb_unixsock_client_t *client; + + int status; + + if (! user_data) + return -1; + + client = SDB_OBJ_WRAPPER(user_data)->data; + + status = sdb_unixsock_client_send(client, "GET hosts\r\n" + "Columns: name last_check"); + if (status <= 0) { + sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to send " + "'GET hosts' command to livestatus @ %s.", + sdb_unixsock_client_path(client)); + return -1; + } + + sdb_unixsock_client_shutdown(client, SHUT_WR); + + if (sdb_unixsock_client_process_lines(client, sdb_livestatus_get_host, + /* user data */ NULL, /* -> EOF */ -1, /* delim */ ";", + /* column count */ 2, SDB_TYPE_STRING, SDB_TYPE_DATETIME)) { + sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to read " + "response from livestatus @ %s while reading hosts.", + sdb_unixsock_client_path(client)); + return -1; + } + + if ((! sdb_unixsock_client_eof(client)) + || sdb_unixsock_client_error(client)) { + char errbuf[1024]; + sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to read " + "host from livestatus @ %s: %s", + sdb_unixsock_client_path(client), + sdb_strerror(errno, errbuf, sizeof(errbuf))); + return -1; + } + + status = sdb_unixsock_client_send(client, "GET services\r\n" + "Columns: host_name description last_check"); + if (status <= 0) { + sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to send " + "'GET services' command to livestatus @ %s.", + sdb_unixsock_client_path(client)); + return -1; + } + + sdb_unixsock_client_shutdown(client, SHUT_WR); + + if (sdb_unixsock_client_process_lines(client, sdb_livestatus_get_svc, + /* user data */ NULL, /* -> EOF */ -1, /* delim */ ";", + /* column count */ 3, SDB_TYPE_STRING, SDB_TYPE_STRING, + SDB_TYPE_DATETIME)) { + sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to read " + "response from livestatus @ %s while reading services.", + sdb_unixsock_client_path(client)); + return -1; + } + + if ((! sdb_unixsock_client_eof(client)) + || sdb_unixsock_client_error(client)) { + char errbuf[1024]; + sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to read " + "services from livestatus @ %s: %s", + sdb_unixsock_client_path(client), + sdb_strerror(errno, errbuf, sizeof(errbuf))); + return -1; + } + return 0; +} /* sdb_livestatus_collect */ + +static int +sdb_livestatus_config_instance(oconfig_item_t *ci) +{ + char *name = NULL; + char *socket_path = NULL; + + sdb_object_t *user_data; + sdb_unixsock_client_t *client; + + int i; + + if (oconfig_get_string(ci, &name)) { + sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Instance requires " + "a single string argument\n\tUsage: "); + return -1; + } + + for (i = 0; i < ci->children_num; ++i) { + oconfig_item_t *child = ci->children + i; + + if (! strcasecmp(child->key, "Socket")) + oconfig_get_string(child, &socket_path); + else + sdb_log(SDB_LOG_WARNING, "MK Livestatus backend: Ignoring " + "unknown config option '%s' inside .", + child->key, name); + } + + if (! socket_path) { + sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Instance '%s' " + "missing the 'Socket' option.", name); + return -1; + } + + client = sdb_unixsock_client_create(socket_path); + if (! client) { + char errbuf[1024]; + sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to create " + "unixsock client: %s", + sdb_strerror(errno, errbuf, sizeof(errbuf))); + return -1; + } + + user_data = sdb_object_create_wrapper("unixsock-client", client, + (void (*)(void *))sdb_unixsock_client_destroy); + if (! user_data) { + sdb_unixsock_client_destroy(client); + sdb_log(SDB_LOG_ERR, "MK Livestatus backend: Failed to " + "allocate sdb_object_t"); + return -1; + } + + sdb_plugin_register_init(name, sdb_livestatus_init, user_data); + sdb_plugin_register_shutdown(name, sdb_livestatus_shutdown, user_data); + sdb_plugin_register_collector(name, sdb_livestatus_collect, + /* interval */ NULL, user_data); + + /* pass control to the list */ + sdb_object_deref(user_data); + return 0; +} /* sdb_livestatus_config_instance */ + +static int +sdb_livestatus_config(oconfig_item_t *ci) +{ + int i; + + if (! ci) /* nothing to do to deconfigure this plugin */ + return 0; + + for (i = 0; i < ci->children_num; ++i) { + oconfig_item_t *child = ci->children + i; + + if (! strcasecmp(child->key, "Instance")) + sdb_livestatus_config_instance(child); + else + sdb_log(SDB_LOG_WARNING, "MK Livestatus backend: Ignoring " + "unknown config option '%s'.", child->key); + } + return 0; +} /* sdb_livestatus_config */ + +int +sdb_module_init(sdb_plugin_info_t *info) +{ + sdb_plugin_set_info(info, SDB_PLUGIN_INFO_DESC, + "backend accessing Nagios/Icinga/Shinken using MK Livestatus"); + sdb_plugin_set_info(info, SDB_PLUGIN_INFO_COPYRIGHT, + "Copyright (C) 2012 Sebastian 'tokkee' Harl "); + sdb_plugin_set_info(info, SDB_PLUGIN_INFO_LICENSE, "BSD"); + sdb_plugin_set_info(info, SDB_PLUGIN_INFO_VERSION, SDB_VERSION); + sdb_plugin_set_info(info, SDB_PLUGIN_INFO_PLUGIN_VERSION, SDB_VERSION); + + sdb_plugin_register_config(sdb_livestatus_config); + return 0; +} /* sdb_version_extra */ + +/* vim: set tw=78 sw=4 ts=4 noexpandtab : */ + diff --git a/src/plugins/backend/puppet/store-configs.c b/src/plugins/backend/puppet/store-configs.c new file mode 100644 index 0000000..95dd549 --- /dev/null +++ b/src/plugins/backend/puppet/store-configs.c @@ -0,0 +1,384 @@ +/* + * SysDB - src/plugins/backend/puppet/store-configs.c + * Copyright (C) 2012 Sebastian 'tokkee' Harl + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS + * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED + * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR + * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDERS OR + * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, + * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, + * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; + * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, + * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR + * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF + * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +#include "sysdb.h" +#include "core/plugin.h" +#include "core/store.h" +#include "utils/dbi.h" +#include "utils/error.h" + +#include "liboconfig/utils.h" + +#include +#include + +#include +#include + +SDB_PLUGIN_MAGIC; + +/* + * private helper functions + */ + +static int +sdb_puppet_stcfg_get_hosts(sdb_dbi_client_t __attribute__((unused)) *client, + size_t n, sdb_data_t *data, + sdb_object_t __attribute__((unused)) *user_data) +{ + const char *hostname; + sdb_time_t timestamp; + + int status; + + assert(n == 2); + assert((data[0].type == SDB_TYPE_STRING) + && (data[1].type == SDB_TYPE_DATETIME)); + + hostname = data[0].data.string; + timestamp = data[1].data.datetime; + + status = sdb_store_host(hostname, timestamp); + + if (status < 0) { + sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: Failed to " + "store/update host '%s'.", hostname); + return -1; + } + else if (! status) + sdb_log(SDB_LOG_DEBUG, "puppet::store-configs backend: " + "Added/updated host '%s' (last update timestamp = " + "%"PRIsdbTIME").", hostname, timestamp); + return 0; +} /* sdb_puppet_stcfg_get_hosts */ + +static int +sdb_puppet_stcfg_get_attrs(sdb_dbi_client_t __attribute__((unused)) *client, + size_t n, sdb_data_t *data, + sdb_object_t __attribute__((unused)) *user_data) +{ + int status; + + const char *hostname; + const char *key; + sdb_data_t value; + sdb_time_t last_update; + + assert(n == 4); + assert((data[0].type == SDB_TYPE_STRING) + && (data[1].type == SDB_TYPE_STRING) + && (data[2].type == SDB_TYPE_STRING) + && (data[3].type == SDB_TYPE_DATETIME)); + + hostname = data[0].data.string; + key = data[1].data.string; + value.type = SDB_TYPE_STRING; + value.data.string = data[2].data.string; + last_update = data[3].data.datetime; + + status = sdb_store_attribute(hostname, key, &value, last_update); + + if (status < 0) { + sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: Failed to " + "store/update host attribute '%s' for host '%s'.", + key, hostname); + return -1; + } + + return 0; +} /* sdb_puppet_stcfg_get_attrs */ + +/* + * plugin API + */ + +static int +sdb_puppet_stcfg_init(sdb_object_t *user_data) +{ + sdb_dbi_client_t *client; + + if (! user_data) + return -1; + + client = SDB_OBJ_WRAPPER(user_data)->data; + if (sdb_dbi_client_connect(client)) { + sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " + "Failed to connect to the storeconfigs DB."); + return -1; + } + + sdb_log(SDB_LOG_INFO, "puppet::store-configs backend: Successfully " + "connected to the storeconfigs DB."); + return 0; +} /* sdb_puppet_stcfg_init */ + +static int +sdb_puppet_stcfg_shutdown(sdb_object_t *user_data) +{ + if (! user_data) + return -1; + + sdb_dbi_client_destroy(SDB_OBJ_WRAPPER(user_data)->data); + SDB_OBJ_WRAPPER(user_data)->data = NULL; + return 0; +} /* sdb_puppet_stcfg_shutdown */ + +static int +sdb_puppet_stcfg_collect(sdb_object_t *user_data) +{ + sdb_dbi_client_t *client; + + if (! user_data) + return -1; + + client = SDB_OBJ_WRAPPER(user_data)->data; + if (sdb_dbi_client_check_conn(client)) { + sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " + "Connection to storeconfigs DB failed."); + return -1; + } + + if (sdb_dbi_exec_query(client, "SELECT name, updated_at FROM hosts;", + sdb_puppet_stcfg_get_hosts, NULL, /* #columns = */ 2, + /* col types = */ SDB_TYPE_STRING, SDB_TYPE_DATETIME)) { + sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: Failed to " + "retrieve hosts from the storeconfigs DB."); + return -1; + } + + if (sdb_dbi_exec_query(client, "SELECT " + "hosts.name AS hostname, " + "fact_names.name AS name, " + "fact_values.value AS value, " + "fact_values.updated_at AS updated_at " + "FROM fact_values " + "INNER JOIN hosts " + "ON fact_values.host_id = hosts.id " + "INNER JOIN fact_names " + "ON fact_values.fact_name_id = fact_names.id;", + sdb_puppet_stcfg_get_attrs, NULL, /* #columns = */ 4, + /* col types = */ SDB_TYPE_STRING, SDB_TYPE_STRING, + SDB_TYPE_STRING, SDB_TYPE_DATETIME)) { + sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: Failed to " + "retrieve host attributes from the storeconfigs DB."); + return -1; + } + return 0; +} /* sdb_puppet_stcfg_collect */ + +static int +sdb_puppet_stcfg_config_conn(oconfig_item_t *ci) +{ + char *name = NULL; + + sdb_object_t *user_data; + sdb_dbi_client_t *client; + sdb_dbi_options_t *options = NULL; + + char *driver = NULL; + char *database = NULL; + + int i; + + if (oconfig_get_string(ci, &name)) { + sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: Connection " + "requires a single string argument\n" + "\tUsage: "); + return -1; + } + + for (i = 0; i < ci->children_num; ++i) { + oconfig_item_t *child = ci->children + i; + char *key = NULL, *value = NULL; + + int status = 0; + + if (! strcasecmp(child->key, "DBAdapter")) { + if (oconfig_get_string(child, &driver)) { + sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " + "DBAdapter requires a single string argument inside " + "\n\tUsage: DBAdapter NAME", + name); + } + continue; + } + else if (! strcasecmp(child->key, "DBName")) { + if (oconfig_get_string(child, &database)) { + sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " + "DBName requires a single string argument inside " + "\n\tUsage: DBName NAME", + name); + } + continue; + } + else if (! strcasecmp(child->key, "DBServer")) { + status = oconfig_get_string(child, &value); + key = "host"; + } + else if (! strcasecmp(child->key, "DBPort")) { + status = oconfig_get_string(child, &value); + key = "port"; + } + else if (! strcasecmp(child->key, "DBUser")) { + status = oconfig_get_string(child, &value); + key = "username"; + } + else if (! strcasecmp(child->key, "DBPassword")) { + status = oconfig_get_string(child, &value); + key = "password"; + } + else if (! strcasecmp(child->key, "DBIOption")) { + if ((child->values_num != 2) + || (child->values[0].type != OCONFIG_TYPE_STRING) + || (child->values[1].type != OCONFIG_TYPE_STRING)) { + sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " + "DBIOption requires exactly two string arguments " + "inside \n" + "\tUsage: DBIOption KEY VALUE", name); + continue; + } + + status = 0; + key = child->values[0].value.string; + value = child->values[1].value.string; + } + else { + sdb_log(SDB_LOG_WARNING, "puppet::store-configs backend: " + "Ignoring unknown config option '%s' inside " + ".", child->key, name); + continue; + } + + if (status) { + sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: Option " + "'%s' requires a single string argument inside " + "\n\tUsage: DBAdapter NAME", + child->key, name); + continue; + } + + assert(key && value); + + if (! options) { + if (! (options = sdb_dbi_options_create())) { + char errmsg[1024]; + sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " + "Failed to create DBI options object: %s", + sdb_strerror(errno, errmsg, sizeof(errmsg))); + continue; + } + } + + if (sdb_dbi_options_add(options, key, value)) { + char errmsg[1024]; + sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " + "Failed to add option '%s': %s", key, + sdb_strerror(errno, errmsg, sizeof(errmsg))); + continue; + } + } + + if (! driver) { + sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " + "Connection '%s' " "missing the 'DBAdapter' option.", + name); + return -1; + } + if (! database) { + sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " + "Connection '%s' missing the 'DBName' option.", name); + return -1; + } + + client = sdb_dbi_client_create(driver, database); + if (! client) { + char errbuf[1024]; + sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " + "Failed to create DBI client: %s", + sdb_strerror(errno, errbuf, sizeof(errbuf))); + return -1; + } + + sdb_dbi_client_set_options(client, options); + + user_data = sdb_object_create_wrapper("dbi-client", client, + (void (*)(void *))sdb_dbi_client_destroy); + if (! user_data) { + sdb_dbi_client_destroy(client); + sdb_log(SDB_LOG_ERR, "puppet::store-configs backend: " + "Failed to allocate sdb_object_t"); + return -1; + } + + sdb_plugin_register_init(name, sdb_puppet_stcfg_init, user_data); + sdb_plugin_register_shutdown(name, sdb_puppet_stcfg_shutdown, + user_data); + sdb_plugin_register_collector(name, sdb_puppet_stcfg_collect, + /* interval */ NULL, user_data); + + /* pass control to the list */ + sdb_object_deref(user_data); + return 0; +} /* sdb_puppet_stcfg_config_conn */ + +static int +sdb_puppet_stcfg_config(oconfig_item_t *ci) +{ + int i; + + if (! ci) /* nothing to do to deconfigure this plugin */ + return 0; + + for (i = 0; i < ci->children_num; ++i) { + oconfig_item_t *child = ci->children + i; + + if (! strcasecmp(child->key, "Connection")) + sdb_puppet_stcfg_config_conn(child); + else + sdb_log(SDB_LOG_WARNING, "puppet::store-configs backend: " + "Ignoring unknown config option '%s'.", child->key); + } + return 0; +} /* sdb_puppet_stcfg_config */ + +int +sdb_module_init(sdb_plugin_info_t *info) +{ + sdb_plugin_set_info(info, SDB_PLUGIN_INFO_DESC, + "backend accessing the Puppet stored configuration database"); + sdb_plugin_set_info(info, SDB_PLUGIN_INFO_COPYRIGHT, + "Copyright (C) 2012 Sebastian 'tokkee' Harl "); + sdb_plugin_set_info(info, SDB_PLUGIN_INFO_LICENSE, "BSD"); + sdb_plugin_set_info(info, SDB_PLUGIN_INFO_VERSION, SDB_VERSION); + sdb_plugin_set_info(info, SDB_PLUGIN_INFO_PLUGIN_VERSION, SDB_VERSION); + + sdb_plugin_register_config(sdb_puppet_stcfg_config); + return 0; +} /* sdb_version_extra */ + +/* vim: set tw=78 sw=4 ts=4 noexpandtab : */ +