Checks different record types and checks against an expected address (Bill Kunkel)

git-svn-id: https://nagiosplug.svn.sourceforge.net/svnroot/nagiosplug/nagiosplug/trunk@888 f882894a-f735-0410-b71e-b25c423dba1c

1 files changed, 58 insertions, 21 deletions

diff --git a/plugins/check_dig.c b/plugins/check_dig.c
index 9e1d8479..41c445c5 100644
--- a/plugins/check_dig.c
+++ b/plugins/check_dig.c
@@ -37,6 +37,8 @@ enum {
 };
 
 char *query_address = NULL;
+char *record_type = "A";
+char *expected_address = NULL;
 char *dns_server = NULL;
 int verbose = FALSE;
 int server_port = DEFAULT_PORT;
@@ -68,14 +70,20 @@ main (int argc, char **argv)
                 usage (_("Could not parse arguments\n"));
 
         /* get the command to run */
-        asprintf (&command_line, "%s @%s -p %d %s",
-                  PATH_TO_DIG, dns_server, server_port, query_address);
+        asprintf (&command_line, "%s @%s -p %d %s -t %s",
+                  PATH_TO_DIG, dns_server, server_port, query_address, record_type);
 
         alarm (timeout_interval);
         gettimeofday (&tv, NULL);
 
-        if (verbose)
+        if (verbose) {
                 printf ("%s\n", command_line);
+                if(expected_address != NULL) {
+                        printf ("Looking for: '%s'\n", expected_address);
+                } else {
+                        printf ("Looking for: '%s'\n", query_address);
+                }
+        }
 
         /* run the command */
         child_process = spopen (command_line);
@@ -93,28 +101,39 @@ main (int argc, char **argv)
                 /* the server is responding, we just got the host name... */
                 if (strstr (input_buffer, ";; ANSWER SECTION:")) {
 
-                        /* get the host address */
-                        if (!fgets (input_buffer, MAX_INPUT_BUFFER - 1, child_process))
-                                break;
+                        /* loop through the whole 'ANSWER SECTION' */
+                        do {
+                                /* get the host address */
+                                if (!fgets (input_buffer, MAX_INPUT_BUFFER - 1, child_process))
+                                        break;
 
-                        if (strpbrk (input_buffer, "\r\n"))
-                                input_buffer[strcspn (input_buffer, "\r\n")] = '\0';
+                                if (strpbrk (input_buffer, "\r\n"))
+                                        input_buffer[strcspn (input_buffer, "\r\n")] = '\0';
 
-                        if (strstr (input_buffer, query_address) == input_buffer) {
-                                output = strdup(input_buffer);
-                                result = STATE_OK;
-                        }
-                        else {
-                                asprintf (&output, _("Server not found in ANSWER SECTION"));
-                                result = STATE_WARNING;
-                        }
+                                if (verbose && !strstr (input_buffer, ";; ")) 
+                                        printf ("%s\n", input_buffer); 
+
+                                if (expected_address==NULL && strstr (input_buffer, query_address) != NULL) {
+                                        output = strdup(input_buffer);
+                                        result = STATE_OK;
+                                }
+                                else if (expected_address != NULL && strstr (input_buffer, expected_address) != NULL) {
+                                        output = strdup(input_buffer);
+                                        result = STATE_OK;
+                                }
+
+                        } while (!strstr (input_buffer, ";; "));
+
+                        if (result == STATE_UNKNOWN) {
+                                asprintf (&output, _("Server not found in ANSWER SECTION"));
+                                result = STATE_WARNING;
+                        }
 
-                        continue;
                 }
 
         }
 
-        if (result != STATE_OK) {
+        if (result == STATE_UNKNOWN) {
                 asprintf (&output, _("No ANSWER SECTION found"));
         }
 
@@ -181,6 +200,8 @@ process_arguments (int argc, char **argv)
                 {"verbose", no_argument, 0, 'v'},
                 {"version", no_argument, 0, 'V'},
                 {"help", no_argument, 0, 'h'},
+                {"record_type", required_argument, 0, 'T'},
+                {"expected_address", required_argument, 0, 'a'},
                 {0, 0, 0, 0}
         };
 
@@ -188,7 +209,7 @@ process_arguments (int argc, char **argv)
                 return ERROR;
 
         while (1) {
-                c = getopt_long (argc, argv, "hVvt:l:H:w:c:", longopts, &option);
+                c = getopt_long (argc, argv, "hVvt:l:H:w:c:T:a:", longopts, &option);
 
                 if (c == -1 || c == EOF)
                         break;
@@ -248,6 +269,12 @@ process_arguments (int argc, char **argv)
                 case 'v':                                                                       /* verbose */
                         verbose = TRUE;
                         break;
+                case 'T':
+                        record_type = optarg;
+                        break;
+                case 'a':
+                        expected_address = optarg;
+                        break;
                 }
         }
 
@@ -309,6 +336,15 @@ print_help (void)
  -l, --lookup=STRING\n\
    machine name to lookup\n"));
 
+        printf (_("\
+ -T, --record_type=STRING\n\
+   record type to lookup (default: A)\n"));
+
+        printf (_("\
+ -a, --expected_address=STRING\n\
+   an address expected to be in the asnwer section.\n\
+   if not set, uses whatever was in -l\n"));
+
         printf (_(UT_WARN_CRIT));
 
         printf (_(UT_TIMEOUT), DEFAULT_SOCKET_TIMEOUT);
@@ -325,8 +361,9 @@ void
 print_usage (void)
 {
         printf (_("\
-Usage: %s -H host -l lookup [-p <server port>] [-w <warning interval>]\n\
-         [-c <critical interval>] [-t <timeout>] [-v]\n"),
+Usage: %s -H host -l lookup [-p <server port>] [-T <query type>]\n\
+         [-w <warning interval>] [-c <critical interval>] [-t <timeout>]\n\
+         [-a <expected answer address>] [-v]\n"),
                 progname);
         printf ("       %s (-h|--help)\n", progname);
         printf ("       %s (-V|--version)\n", progname);