Basic get/walk support.

2 files changed, 405 insertions, 1 deletions

diff --git a/tools/Makefile.am b/tools/Makefile.am
index 94dfa06..a2185ab 100644
--- a/tools/Makefile.am
+++ b/tools/Makefile.am
@@ -1,8 +1,19 @@
 
-sbin_PROGRAMS = rrdbot-create
+sbin_PROGRAMS = rrdbot-create rrdbot-get
 
 rrdbot_create_SOURCES = rrdbot-create.c ../common/usuals.h \
                 ../common/config-parser.h ../common/config-parser.c \
                 ../common/compat.h ../common/compat.c
 rrdbot_create_CFLAGS = -I${top_srcdir}/common/ -I${top_srcdir} \
                 -DCONF_PREFIX=\"$(sysconfdir)\" -DDATA_PREFIX=\"$(datadir)\"
+
+rrdbot_get_SOURCES = rrdbot-get.c ../common/usuals.h \
+                ../common/compat.h ../common/compat.c \
+                ../common/config-parser.h ../common/config-parser.c \
+                ../common/server-mainloop.h ../common/server-mainloop.c \
+                ../common/sock-any.h ../common/sock-any.c \
+                ../mib/mib-parser.c ../mib/mib-parser.h \
+                ../bsnmp/asn1.h ../bsnmp/asn1.c \
+                ../bsnmp/snmp.h ../bsnmp/snmp.c
+rrdbot_get_CFLAGS = -I${top_srcdir}/common/ -I${top_srcdir} \
+                -DCONF_PREFIX=\"$(sysconfdir)\" -DDATA_PREFIX=\"$(datadir)\"
diff --git a/tools/rrdbot-get.c b/tools/rrdbot-get.c
new file mode 100644
index 0000000..3abdc77
--- /dev/null
+++ b/tools/rrdbot-get.c
@@ -0,0 +1,393 @@
+/*
+ * Copyright (c) 2005, Nate Nielsen
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ *
+ *     * Redistributions of source code must retain the above
+ *       copyright notice, this list of conditions and the
+ *       following disclaimer.
+ *     * 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.
+ *     * The names of contributors to this software may not be
+ *       used to endorse or promote products derived from this
+ *       software without specific prior written permission.
+ *
+ * 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 OWNER 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.
+ *
+ *
+ * CONTRIBUTORS
+ *  Nate Nielsen <nielsen@memberwebs.com>
+ *
+ */
+
+#include "usuals.h"
+#include <errno.h>
+#include <unistd.h>
+#include <syslog.h>
+#include <err.h>
+
+#include <bsnmp/asn1.h>
+#include <bsnmp/snmp.h>
+#include <mib/mib-parser.h>
+
+#include "sock-any.h"
+#include "server-mainloop.h"
+#include "config-parser.h"
+
+/* The socket to use */
+static int snmp_socket = -1;
+
+/* Since we only deal with one packet at a time, global buffer */
+static unsigned char snmp_buffer[0x1000];
+
+/* The actual request data */
+static struct snmp_pdu snmp_data;
+
+/* The first OID we've done */
+static struct asn_oid oid_first;
+
+/* The remote host */
+static struct sockaddr_any snmp_hostaddr;
+static char* snmp_hostname = NULL;
+
+static int retries = 0;
+
+/* Whether we're going recursive or not */
+static int recursive = 0;
+
+/* -----------------------------------------------------------------------------
+ * DUMMY CONFIG FUNCTIONS
+ */
+
+int
+cfg_value(const char* filename, const char* header, const char* name,
+          char* value, void* data)
+{
+    return 0;
+}
+
+int
+cfg_error(const char* filename, const char* errmsg, void* data)
+{
+    return 0;
+}
+
+/* -----------------------------------------------------------------------------
+ * SNMP ENGINE
+ */
+
+static void
+send_req()
+{
+    struct asn_buf b;
+    ssize_t ret;
+
+    b.asn_ptr = snmp_buffer;
+    b.asn_len = sizeof(snmp_buffer);
+
+    if(snmp_pdu_encode(&snmp_data, &b))
+        errx(1, "couldn't encode snmp buffer");
+
+    ret = sendto(snmp_socket, snmp_buffer, b.asn_ptr - snmp_buffer, 0,
+                 &SANY_ADDR(snmp_hostaddr), SANY_LEN(snmp_hostaddr));
+    if(ret == -1)
+        err(1, "couldn't send snmp packet to: %s", snmp_hostname);
+
+}
+
+static void
+setup_req(char* uri)
+{
+    const char* msg;
+    char* scheme;
+    char* copy;
+    char* user;
+    char* path;
+
+    /* Parse the SNMP URI */
+    copy = strdup(uri);
+    msg = cfg_parse_uri(uri, &scheme, &snmp_hostname, &user, &path);
+    if(msg)
+        errx(2, "%s: %s", msg, copy);
+    free(copy);
+
+    ASSERT(host && path);
+
+    /* Currently we only support SNMP pollers */
+    if(strcmp(scheme, "snmp") != 0)
+        errx(2, "invalid scheme: %s", scheme);
+
+    if(sock_any_pton(snmp_hostname, &snmp_hostaddr,
+                     SANY_OPT_DEFPORT(161) | SANY_OPT_DEFLOCAL) == -1)
+        err(1, "couldn't resolve host address (ignoring): %s", snmp_hostname);
+
+    memset(&snmp_data, 0, sizeof(snmp_data));
+    snmp_data.version = 1;
+    snmp_data.request_id = 0;
+    snmp_data.type = recursive ? SNMP_PDU_GETNEXT : SNMP_PDU_GET;
+    snmp_data.error_status = 0;
+    snmp_data.error_index = 0;
+    strlcpy(snmp_data.community, user ? user : "public",
+            sizeof(snmp_data.community));
+
+
+    /* And parse the OID */
+    snmp_data.bindings[0].syntax = 0;
+    if(mib_parse(path, &(snmp_data.bindings[0])) == -1)
+        errx(2, "invalid MIB: %s", path);
+
+    /* Add an item to this request */
+    snmp_data.nbindings = 1;
+
+    /* Keep track of top for recursiveness */
+    memcpy(&oid_first, &(snmp_data.bindings[0].var), sizeof(oid_first));
+
+}
+
+static void
+setup_next(struct snmp_value* value)
+{
+    snmp_data.request_id++;
+    snmp_data.type = SNMP_PDU_GETNEXT;
+
+    /* And parse the OID */
+    memcpy(&(snmp_data.bindings[0]), value, sizeof(struct snmp_value));
+    snmp_data.bindings[0].syntax = 0;
+    snmp_data.nbindings = 1;
+}
+
+
+static int
+print_resp(struct snmp_pdu* pdu, uint64_t when)
+{
+    struct snmp_value* value;
+    char *t;
+    int i;
+
+    ASSERT(req->id == pdu->request_id);
+
+    for(i = 0; i < pdu->nbindings; i++)
+    {
+        value = &(pdu->bindings[i]);
+
+        printf("%s: ", asn_oid2str(&(value->var)));
+
+        switch(value->syntax)
+        {
+        case SNMP_SYNTAX_NULL:
+            printf("[null]\n");
+            break;
+        case SNMP_SYNTAX_INTEGER:
+            printf("%d\n", value->v.integer);
+            break;
+        case SNMP_SYNTAX_COUNTER:
+        case SNMP_SYNTAX_GAUGE:
+        case SNMP_SYNTAX_TIMETICKS:
+            printf("%d\n", value->v.uint32);
+            break;
+        case SNMP_SYNTAX_COUNTER64:
+            printf("%lld\n", value->v.counter64);
+            break;
+        case SNMP_SYNTAX_OCTETSTRING:
+            t = xcalloc(value->v.octetstring.len + 1);
+            memcpy(t, value->v.octetstring.octets, value->v.octetstring.len);
+            printf("%s\n", t);
+            free(t);
+            break;
+        case SNMP_SYNTAX_OID:
+            printf("%s\n", asn_oid2str(&(value->v.oid)));
+            break;
+        case SNMP_SYNTAX_IPADDRESS:
+            printf("%c.%c.%c.%c\n", value->v.ipaddress[0], value->v.ipaddress[1],
+                   value->v.ipaddress[2], value->v.ipaddress[3]);
+            break;
+        case SNMP_SYNTAX_NOSUCHOBJECT:
+            printf("[field not available on snmp server]\n");
+            break;
+        case SNMP_SYNTAX_NOSUCHINSTANCE:
+            printf("[no such instance on snmp server]\n");
+            break;
+        case SNMP_SYNTAX_ENDOFMIBVIEW:
+            return 0;
+        default:
+            printf("[unknown]\n");
+            break;
+        }
+    }
+
+    return 1;
+}
+
+static void
+receive_resp(int fd, int type, void* arg)
+{
+    char hostname[MAXPATHLEN];
+    struct sockaddr_any from;
+    struct snmp_pdu pdu;
+    struct snmp_value *val;
+    struct asn_buf b;
+    const char* msg;
+    int len, ret, subid;
+    int32_t ip;
+
+    ASSERT(snmp_socket == fd);
+
+    /* Read in the packet */
+
+    SANY_LEN(from) = sizeof(from);
+    len = recvfrom(snmp_socket, snmp_buffer, sizeof(snmp_buffer), 0,
+                   &SANY_ADDR(from), &SANY_LEN(from));
+    if(len < 0)
+    {
+        if(errno != EAGAIN && errno != EWOULDBLOCK)
+            err(1, "error receiving snmp packet from network");
+    }
+
+    if(sock_any_ntop(&from, hostname, MAXPATHLEN, 0) == -1)
+        strcpy(hostname, "[UNKNOWN]");
+
+    /* Now parse the packet */
+
+    b.asn_ptr = snmp_buffer;
+    b.asn_len = len;
+
+    ret = snmp_pdu_decode(&b, &pdu, &ip);
+    if(ret != SNMP_CODE_OK)
+        errx(1, "invalid snmp packet received from: %s", hostname);
+
+    /* It needs to match something we're waiting for */
+    if(pdu.request_id != snmp_data.request_id)
+        return;
+
+    /* Check for errors */
+    if(pdu.error_status != SNMP_ERR_NOERROR)
+    {
+        snmp_pdu_dump (&pdu);
+        msg = snmp_get_errmsg (pdu.error_status);
+        if(msg)
+            errx(1, "snmp error from host '%s': %s", hostname, msg);
+        else
+            errx(1, "unknown snmp error from host '%s': %d", hostname, pdu.error_status);
+        return;
+    }
+
+    subid = ret = 1;
+
+    if(pdu.nbindings > 0)
+    {
+        val = &(pdu.bindings[pdu.nbindings - 1]);
+        subid = asn_compare_oid(&oid_first, &(val->var)) == 0 ||
+                asn_is_suboid(&oid_first, &(val->var));
+    }
+
+    /* Print the packet values */
+    if(!recursive || subid)
+        ret = print_resp(&pdu, server_get_time());
+
+    if(ret && recursive && subid)
+    {
+        /* If recursive, move onto next one */
+        setup_next(&(pdu.bindings[pdu.nbindings - 1]));
+        send_req();
+        return;
+    }
+
+    server_stop ();
+}
+
+/* -----------------------------------------------------------------------------
+ * STARTUP
+ */
+
+static void
+usage()
+{
+    fprintf(stderr, "usage: rrdbot-get [-nr] snmp://community@host/oid\n");
+    fprintf(stderr, "       rrdbot-get -V\n");
+    exit(2);
+}
+
+static void
+version()
+{
+    printf("rrdbot-get (version %s)\n", VERSION);
+    exit(0);
+}
+
+int
+main(int argc, char* argv[])
+{
+    struct sockaddr_in addr;
+    int numeric = 0;
+    char ch;
+
+    /* Parse the arguments nicely */
+    while((ch = getopt(argc, argv, "nrV")) != -1)
+    {
+        switch(ch)
+        {
+
+        /* Numeric output */
+        case 'n':
+            numeric = 1;
+            break;
+
+        /* SNMP walk (recursive)*/
+        case 'r':
+            recursive = 1;
+            break;
+
+        /* Print version number */
+        case 'V':
+            version();
+            break;
+
+        /* Usage information */
+        case '?':
+        default:
+            usage();
+            break;
+        }
+    }
+
+    argc -= optind;
+    argv += optind;
+
+    if(argc != 1)
+        usage();
+
+    setup_req (argv[0]);
+
+    /* Setup the SNMP socket */
+    snmp_socket = socket(PF_INET, SOCK_DGRAM, 0);
+    if(snmp_socket < 0)
+        err(1, "couldn't open snmp socket");
+    memset(&addr, 0, sizeof(addr));
+    addr.sin_family = AF_INET;
+    if(bind(snmp_socket, (struct sockaddr*)&addr, sizeof(addr)) < 0)
+        err(1, "couldn't listen on port");
+    if(server_watch(snmp_socket, SERVER_READ, receive_resp, NULL) == -1)
+        err(1, "couldn't listen on socket");
+
+    send_req();
+
+    server_run();
+
+    return 0;
+}