ros_connect, create_socket: Free (struct addrinfo *).
[routeros-api.git] / src / main.c
index 919ae59..e328ef8 100644 (file)
@@ -1,5 +1,5 @@
 /**
- * libmikrotik - src/main.c
+ * librouteros - src/main.c
  * Copyright (C) 2009  Florian octo Forster
  *
  * This program is free software; you can redistribute it and/or modify it
  *   Florian octo Forster <octo at verplant.org>
  **/
 
+#ifndef _ISOC99_SOURCE
+# define _ISOC99_SOURCE
+#endif
+
+#ifndef _POSIX_C_SOURCE
+# define _POSIX_C_SOURCE 200112L
+#endif
+
+#include "config.h"
+
 #include <stdlib.h>
 #include <stdio.h>
 #include <unistd.h>
 #include <errno.h>
 #include <assert.h>
 
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <netdb.h>
+
+#include <gcrypt.h>
+
 #include "routeros_api.h"
 
+#if WITH_DEBUG
+# define ros_debug(...) fprintf (stdout, __VA_ARGS__)
+#else
+# define ros_debug(...) /**/
+#endif
+
+#if !__GNUC__
+# define __attribute__(x) /**/
+#endif
+
+/* FIXME */
+char *strdup (const char *);
+
 /*
  * Private structures
  */
-struct mt_connection_s
+struct ros_connection_s
 {
        int fd;
 };
 
-struct mt_reply_s
+struct ros_reply_s
 {
        unsigned int params_num;
        char *status;
        char **keys;
        char **values;
 
-       mt_reply_t *next;
+       ros_reply_t *next;
+};
+
+struct ros_login_data_s
+{
+       const char *username;
+       const char *password;
 };
+typedef struct ros_login_data_s ros_login_data_t;
 
 /*
  * Private functions
  */
-static mt_reply_t *reply_alloc (void) /* {{{ */
+static int read_exact (int fd, void *buffer, size_t buffer_size) /* {{{ */
+{
+       char *buffer_ptr;
+       size_t have_bytes;
+
+       if ((fd < 0) || (buffer == NULL))
+               return (EINVAL);
+
+       if (buffer_size == 0)
+               return (0);
+
+       buffer_ptr = buffer;
+       have_bytes = 0;
+       while (have_bytes < buffer_size)
+       {
+               size_t want_bytes;
+               ssize_t status;
+
+               want_bytes = buffer_size - have_bytes;
+               errno = 0;
+               status = read (fd, buffer_ptr, want_bytes);
+               if (status < 0)
+               {
+                       if (errno == EAGAIN)
+                               continue;
+                       else
+                               return (status);
+               }
+
+               assert (((size_t) status) <= want_bytes);
+               have_bytes += status;
+               buffer_ptr += status;
+       }
+
+       return (0);
+} /* }}} int read_exact */
+
+static ros_reply_t *reply_alloc (void) /* {{{ */
 {
-       mt_reply_t *r;
+       ros_reply_t *r;
 
        r = malloc (sizeof (*r));
        if (r == NULL)
@@ -65,19 +138,87 @@ static mt_reply_t *reply_alloc (void) /* {{{ */
        r->next = NULL;
 
        return (r);
-} /* }}} mt_reply_s *reply_alloc */
+} /* }}} ros_reply_s *reply_alloc */
 
-static void reply_free (mt_reply_t *r) /* {{{ */
+static int reply_add_keyval (ros_reply_t *r, const char *key, /* {{{ */
+               const char *val)
 {
-       mt_reply_t *next;
+       char **tmp;
+
+       tmp = realloc (r->keys, (r->params_num + 1) * sizeof (*tmp));
+       if (tmp == NULL)
+               return (ENOMEM);
+       r->keys = tmp;
+
+       tmp = realloc (r->values, (r->params_num + 1) * sizeof (*tmp));
+       if (tmp == NULL)
+               return (ENOMEM);
+       r->values = tmp;
+
+       r->keys[r->params_num] = strdup (key);
+       if (r->keys[r->params_num] == NULL)
+               return (ENOMEM);
+
+       r->values[r->params_num] = strdup (val);
+       if (r->values[r->params_num] == NULL)
+       {
+               free (r->keys[r->params_num]);
+               r->keys[r->params_num] = NULL;
+               return (ENOMEM);
+       }
+
+       r->params_num++;
+       return (0);
+} /* }}} int reply_add_keyval */
+
+#if WITH_DEBUG
+static void reply_dump (const ros_reply_t *r) /* {{{ */
+{
+       if (r == NULL)
+               return;
+
+       printf ("=== BEGIN REPLY ===\n"
+                       "Address: %p\n"
+                       "Status: %s\n",
+                       (void *) r, r->status);
+       if (r->params_num > 0)
+       {
+               unsigned int i;
+
+               printf ("Arguments:\n");
+               for (i = 0; i < r->params_num; i++)
+                       printf (" %3u: %s = %s\n", i, r->keys[i], r->values[i]);
+       }
+       if (r->next != NULL)
+               printf ("Next: %p\n", (void *) r->next);
+       printf ("=== END REPLY ===\n");
+
+       reply_dump (r->next);
+} /* }}} void reply_dump */
+#else
+# define reply_dump(foo) /**/
+#endif
+
+static void reply_free (ros_reply_t *r) /* {{{ */
+{
+       ros_reply_t *next;
+       unsigned int i;
 
        if (r == NULL)
                return;
 
        next = r->next;
 
+       for (i = 0; i < r->params_num; i++)
+       {
+               free (r->keys[i]);
+               free (r->values[i]);
+       }
+
+       free (r->status);
        free (r->keys);
        free (r->values);
+
        free (r);
 
        reply_free (next);
@@ -197,68 +338,139 @@ static int buffer_end (char **ret_buffer, size_t *ret_buffer_size) /* {{{ */
        return (0);
 } /* }}} int buffer_end */
 
-static int buffer_decode_next (char **ret_buffer, size_t *ret_buffer_size, /* {{{ */
-               char *dst, size_t *dst_size)
+static int send_command (ros_connection_t *c, /* {{{ */
+               const char *command,
+               size_t args_num, const char * const *args)
 {
-       uint8_t *buffer;
+       char buffer[4096];
+       char *buffer_ptr;
        size_t buffer_size;
-       size_t req_size;
 
-       if ((ret_buffer == NULL) || (ret_buffer_size == NULL) || (dst_size == NULL))
+       size_t i;
+       int status;
+
+       assert (c != NULL);
+       assert (command != NULL);
+
+       if ((args == NULL) && (args_num > 0))
                return (EINVAL);
 
-       buffer = (uint8_t *) (*ret_buffer);
-       buffer_size = *ret_buffer_size;
+       /* FIXME: For debugging only */
+       memset (buffer, 0, sizeof (buffer));
+
+       buffer_ptr = buffer;
+       buffer_size = sizeof (buffer);
+
+       status = buffer_init (&buffer_ptr, &buffer_size);
+       if (status != 0)
+               return (status);
+
+       ros_debug ("send_command: command = %s;\n", command);
+       status = buffer_add (&buffer_ptr, &buffer_size, command);
+       if (status != 0)
+               return (status);
+
+       for (i = 0; i < args_num; i++)
+       {
+               if (args[i] == NULL)
+                       return (EINVAL);
+
+               ros_debug ("send_command: arg[%zu] = %s;\n", i, args[i]);
+               status = buffer_add (&buffer_ptr, &buffer_size, args[i]);
+               if (status != 0)
+                       return (status);
+       }
+
+       status = buffer_end (&buffer_ptr, &buffer_size);
+       if (status != 0)
+               return (status);
+
+       buffer_ptr = buffer;
+       buffer_size = sizeof (buffer) - buffer_size;
+       while (buffer_size > 0)
+       {
+               ssize_t bytes_written;
+
+               errno = 0;
+               bytes_written = write (c->fd, buffer_ptr, buffer_size);
+               if (bytes_written < 0)
+               {
+                       if (errno == EAGAIN)
+                               continue;
+                       else
+                               return (errno);
+               }
+               assert (((size_t) bytes_written) <= buffer_size);
+
+               buffer_ptr += bytes_written;
+               buffer_size -= bytes_written;
+       } /* while (buffer_size > 0) */
+
+       return (0);
+} /* }}} int send_command */
 
-       if (buffer_size < 1)
+static int read_word (ros_connection_t *c, /* {{{ */
+               char *buffer, size_t *buffer_size)
+{
+       size_t req_size;
+       uint8_t word_length[5];
+       int status;
+
+       if ((buffer == NULL) || (*buffer_size < 1))
                return (EINVAL);
 
-       /* Calculate `req_size' and update `buffer' and `buffer_size'. */
-       if (buffer[0] == 0xF0) /* {{{ */
+       assert (c != NULL);
+
+       /* read one byte from the socket */
+       status = read_exact (c->fd, word_length, 1);
+       if (status != 0)
+               return (status);
+
+       /* Calculate `req_size' */
+       if (((unsigned char) word_length[0]) == 0xF0) /* {{{ */
        {
-               if (buffer_size < (0x10000000 + 5))
-                       return (EPROTO);
-               req_size = (buffer[1] << 24)
-                       | (buffer[2] << 16)
-                       | (buffer[3] << 8)
-                       | buffer[4];
-               buffer += 5;
-               buffer_size -= 5;
+               status = read_exact (c->fd, &word_length[1], 4);
+               if (status != 0)
+                       return (status);
+
+               req_size = (word_length[1] << 24)
+                       | (word_length[2] << 16)
+                       | (word_length[3] << 8)
+                       | word_length[4];
        }
-       else if ((buffer[0] & 0xE0) == 0xE0)
-       {
-               if (buffer_size < (0x200000 + 4))
-                       return (EPROTO);
-               req_size = ((buffer[0] & 0x1F) << 24)
-                       | (buffer[1] << 16)
-                       | (buffer[2] << 8)
-                       | buffer[3];
-               buffer += 4;
-               buffer_size -= 4;
+       else if ((word_length[0] & 0xE0) == 0xE0)
+       {
+               status = read_exact (c->fd, &word_length[1], 3);
+               if (status != 0)
+                       return (status);
+
+               req_size = ((word_length[0] & 0x1F) << 24)
+                       | (word_length[1] << 16)
+                       | (word_length[2] << 8)
+                       | word_length[3];
        }
-       else if ((buffer[0] & 0xC0) == 0xC0)
+       else if ((word_length[0] & 0xC0) == 0xC0)
        {
-               if (buffer_size < (0x4000 + 3))
-                       return (EPROTO);
-               req_size = ((buffer[0] & 0x3F) << 16)
-                       | (buffer[1] << 8)
-                       | buffer[2];
-               buffer += 3;
-               buffer_size -= 3;
+               status = read_exact (c->fd, &word_length[1], 2);
+               if (status != 0)
+                       return (status);
+
+               req_size = ((word_length[0] & 0x3F) << 16)
+                       | (word_length[1] << 8)
+                       | word_length[2];
        }
-       else if ((buffer[0] & 0x80) == 0x80)
+       else if ((word_length[0] & 0x80) == 0x80)
        {
-               if (buffer_size < (0x80 + 2))
-                       return (EPROTO);
-               req_size = ((buffer[0] & 0x7F) << 8) | buffer[1];
-               buffer += 2;
-               buffer_size -= 2;
+               status = read_exact (c->fd, &word_length[1], 1);
+               if (status != 0)
+                       return (status);
+
+               req_size = ((word_length[0] & 0x7F) << 8)
+                       | word_length[1];
        }
-       else if ((buffer[0] & 0x80) == 0)
+       else if ((word_length[0] & 0x80) == 0)
        {
-               req_size = buffer[0];
-               buffer += 1;
-               buffer_size -= 1;
+               req_size = (size_t) word_length[0];
        }
        else
        {
@@ -266,100 +478,434 @@ static int buffer_decode_next (char **ret_buffer, size_t *ret_buffer_size, /* {{
                return (EPROTO);
        } /* }}} */
 
-       if (buffer_size < req_size)
-               return (EPROTO);
+       if (*buffer_size < req_size)
+               return (ENOMEM);
 
-       if (dst == NULL)
+       /* Empty word. This ends a `sentence' and must therefore be valid. */
+       if (req_size == 0)
        {
-               *dst_size = (req_size + 1);
+               buffer[0] = 0;
+               *buffer_size = 0;
                return (0);
        }
 
-       if (*dst_size <= req_size)
-               return (ENOMEM);
+       status = read_exact (c->fd, buffer, req_size);
+       if (status != 0)
+               return (status);
+       *buffer_size = req_size;
 
-       memcpy (dst, buffer, req_size);
-       dst[req_size] = 0;
-       *dst_size = (req_size + 1);
+       return (0);
+} /* }}} int buffer_decode_next */
 
-       assert (buffer_size >= req_size);
-       buffer += req_size;
-       buffer_size -= req_size;
+static ros_reply_t *receive_sentence (ros_connection_t *c) /* {{{ */
+{
+       char buffer[4096];
+       size_t buffer_size;
+       int status;
 
-       *ret_buffer = buffer;
-       *ret_buffer_size = buffer_size;
+       ros_reply_t *r;
+
+       r = reply_alloc ();
+       if (r == NULL)
+               return (NULL);
+
+       while (42)
+       {
+               buffer_size = sizeof (buffer) - 1;
+               status = read_word (c, buffer, &buffer_size);
+               if (status != 0)
+                       break;
+               assert (buffer_size < sizeof (buffer));
+               buffer[buffer_size] = 0;
+
+               /* Empty word means end of reply */
+               if (buffer_size == 0)
+                       break;
+
+               if (buffer[0] == '!') /* {{{ */
+               {
+                       if (r->status != NULL)
+                               free (r->status);
+                       r->status = strdup (&buffer[1]);
+                       if (r->status == NULL)
+                               break;
+               } /* }}} if (buffer[0] == '!') */
+               else if (buffer[0] == '=') /* {{{ */
+               {
+                       char *key = &buffer[1];
+                       char *val;
+
+                       key = &buffer[1];
+                       val = strchr (key, '=');
+                       if (val == NULL)
+                       {
+                               fprintf (stderr, "Ignoring misformed word: %s\n", buffer);
+                               continue;
+                       }
+                       *val = 0;
+                       val++;
+
+                       reply_add_keyval (r, key, val);
+               } /* }}} if (buffer[0] == '=') */
+               else
+               {
+                       ros_debug ("receive_sentence: Ignoring unknown word: %s\n", buffer);
+               }
+       } /* while (42) */
        
+       if (r->status == NULL)
+       {
+               reply_free (r);
+               return (NULL);
+       }
+
+       return (r);
+} /* }}} ros_reply_t *receive_sentence */
+
+static ros_reply_t *receive_reply (ros_connection_t *c) /* {{{ */
+{
+       ros_reply_t *head;
+       ros_reply_t *tail;
+
+       if (c == NULL)
+               return (NULL);
+
+       head = NULL;
+       tail = NULL;
+
+       while (42)
+       {
+               ros_reply_t *tmp;
+
+               tmp = receive_sentence (c);
+               if (tmp == NULL)
+                       break;
+
+               if (tail == NULL)
+               {
+                       head = tmp;
+                       tail = tmp;
+               }
+               else
+               {
+                       tail->next = tmp;
+                       tail = tmp;
+               }
+
+               if (strcmp ("done", tmp->status) == 0)
+                       break;
+       } /* while (42) */
+       
+       return (head);
+} /* }}} ros_reply_t *receive_reply */
+
+static int create_socket (const char *node, const char *service) /* {{{ */
+{
+       struct addrinfo  ai_hint;
+       struct addrinfo *ai_list;
+       struct addrinfo *ai_ptr;
+       int status;
+
+       ros_debug ("create_socket (node = %s, service = %s);\n",
+                       node, service);
+
+       memset (&ai_hint, 0, sizeof (ai_hint));
+#ifdef AI_ADDRCONFIG
+       ai_hint.ai_flags |= AI_ADDRCONFIG;
+#endif
+       ai_hint.ai_family = AF_UNSPEC;
+       ai_hint.ai_socktype = SOCK_STREAM;
+
+       ai_list = NULL;
+       status = getaddrinfo (node, service, &ai_hint, &ai_list);
+       if (status != 0)
+               return (-1);
+       assert (ai_list != NULL);
+
+       for (ai_ptr = ai_list; ai_ptr != NULL; ai_ptr = ai_ptr->ai_next)
+       {
+               int fd;
+               int status;
+
+               fd = socket (ai_ptr->ai_family, ai_ptr->ai_socktype,
+                               ai_ptr->ai_protocol);
+               if (fd < 0)
+               {
+                       ros_debug ("create_socket: socket(2) failed.\n");
+                       continue;
+               }
+
+               status = connect (fd, ai_ptr->ai_addr, ai_ptr->ai_addrlen);
+               if (status != 0)
+               {
+                       ros_debug ("create_socket: connect(2) failed.\n");
+                       close (fd);
+                       continue;
+               }
+
+               freeaddrinfo (ai_list);
+               return (fd);
+       }
+
+       freeaddrinfo (ai_list);
+       return (-1);
+} /* }}} int create_socket */
+
+static int login2_handler (__attribute__((unused)) ros_connection_t *c, /* {{{ */
+               const ros_reply_t *r,
+               __attribute__((unused)) void *user_data)
+{
+       if (r == NULL)
+               return (EINVAL);
+
+       reply_dump (r);
+
+       if (strcmp (r->status, "trap") == 0)
+       {
+               ros_debug ("login2_handler: Logging in failed: %s.\n",
+                               ros_reply_param_val_by_key (r, "message"));
+               return (EACCES);
+       }
+       else if (strcmp (r->status, "done") != 0)
+       {
+               ros_debug ("login2_handler: Unexpected status: %s.\n", r->status);
+               return (EPROTO);
+       }
+
        return (0);
-} /* }}} int buffer_decode_next */
+} /* }}} int login2_handler */
+
+static void hash_binary_to_hex (char hex[33], uint8_t binary[16]) /* {{{ */
+{
+       int i;
+
+       for (i = 0; i < 16; i++)
+       {
+               char tmp[3];
+               snprintf (tmp, 3, "%02"PRIx8, binary[i]);
+               tmp[2] = 0;
+               hex[2*i] = tmp[0];
+               hex[2*i+1] = tmp[1];
+       }
+       hex[32] = 0;
+} /* }}} void hash_binary_to_hex */
+
+static void hash_hex_to_binary (uint8_t binary[16], char hex[33]) /* {{{ */
+{
+       int i;
+
+       for (i = 0; i < 16; i++)
+       {
+               char tmp[3];
+
+               tmp[0] = hex[2*i];
+               tmp[1] = hex[2*i + 1];
+               tmp[2] = 0;
+
+               binary[i] = (uint8_t) strtoul (tmp, /* endptr = */ NULL, /* base = */ 16);
+       }
+} /* }}} void hash_hex_to_binary */
+
+static void make_password_hash (char response_hex[33], /* {{{ */
+               const char *password, size_t password_length, char challenge_hex[33])
+{
+       uint8_t challenge_bin[16];
+       uint8_t response_bin[16];
+       char data_buffer[password_length+17];
+       gcry_md_hd_t md_handle;
+
+       hash_hex_to_binary (challenge_bin, challenge_hex);
+
+       data_buffer[0] = 0;
+       memcpy (&data_buffer[1], password, password_length);
+       memcpy (&data_buffer[1+password_length], challenge_bin, 16);
+
+       gcry_md_open (&md_handle, GCRY_MD_MD5, /* flags = */ 0);
+       gcry_md_write (md_handle, data_buffer, sizeof (data_buffer));
+       memcpy (response_bin, gcry_md_read (md_handle, GCRY_MD_MD5), 16);
+       gcry_md_close (md_handle);
+
+       hash_binary_to_hex (response_hex, response_bin);
+} /* }}} void make_password_hash */
+
+static int login_handler (ros_connection_t *c, const ros_reply_t *r, /* {{{ */
+               void *user_data)
+{
+       const char *ret;
+       char challenge_hex[33];
+       char response_hex[33];
+       ros_login_data_t *login_data;
+
+       const char *params[2];
+       char param_name[1024];
+       char param_response[64];
+
+       if (r == NULL)
+               return (EINVAL);
+
+       /* The expected result looks like this:
+        * -- 8< --
+        *  !done 
+        *  =ret=ebddd18303a54111e2dea05a92ab46b4
+        * -- >8 --
+        */
+       reply_dump (r);
+
+       if (strcmp (r->status, "done") != 0)
+       {
+               ros_debug ("login_handler: Unexpected status: %s.\n", r->status);
+               return (EPROTO);
+       }
+
+       login_data = user_data;
+       if (login_data == NULL)
+               return (EINVAL);
+
+       ret = ros_reply_param_val_by_key (r, "ret");
+       if (ret == NULL)
+       {
+               ros_debug ("login_handler: Reply does not have parameter \"ret\".\n");
+               return (EPROTO);
+       }
+       ros_debug ("login_handler: ret = %s;\n", ret);
+
+       if (strlen (ret) != 32)
+       {
+               ros_debug ("login_handler: Unexpected length of the \"ret\" argument.\n");
+               return (EPROTO);
+       }
+       strcpy (challenge_hex, ret);
+
+       make_password_hash (response_hex, 
+                       login_data->password, strlen (login_data->password),
+                       challenge_hex);
+
+       snprintf (param_name, sizeof (param_name), "=name=%s", login_data->username);
+       snprintf (param_response, sizeof (param_response),
+                       "=response=00%s", response_hex);
+       params[0] = param_name;
+       params[1] = param_response;
+
+       return (ros_query (c, "/login", 2, params, login2_handler,
+                               /* user data = */ NULL));
+} /* }}} int login_handler */
 
 /*
  * Public functions
  */
-mt_connection_t *mt_connect (const char *node, const char *service,
-               const char *username, const char *password);
-int mt_disconnect (mt_connection_t *con);
-
-int mt_query (mt_connection_t *c,
-               const char *command,
-               size_t args_num, const char * const *args,
-               mt_reply_handler_t *handler, void *user_data)
+ros_connection_t *ros_connect (const char *node, const char *service, /* {{{ */
+               const char *username, const char *password)
 {
-       char buffer[4096];
-       char *buffer_ptr;
-       size_t buffer_size;
-
-       size_t i;
+       int fd;
+       ros_connection_t *c;
        int status;
+       ros_login_data_t user_data;
 
-       buffer_ptr = buffer;
-       buffer_size = sizeof (buffer);
+       if ((node == NULL) || (username == NULL) || (password == NULL))
+               return (NULL);
 
-       status = buffer_init (&buffer_ptr, &buffer_size);
-       if (status != 0)
-               return (status);
+       fd = create_socket (node, (service != NULL) ? service : ROUTEROS_API_PORT);
+       if (fd < 0)
+               return (NULL);
 
-       status = buffer_add (&buffer_ptr, &buffer_size, command);
-       if (status != 0)
-               return (status);
+       c = malloc (sizeof (*c));
+       if (c == NULL)
+       {
+               close (fd);
+               return (NULL);
+       }
+       memset (c, 0, sizeof (*c));
 
-       for (i = 0; i < args_num; i++)
+       c->fd = fd;
+
+       user_data.username = username;
+       user_data.password = password;
+       status = ros_query (c, "/login", /* args num = */ 0, /* args = */ NULL,
+                       login_handler, &user_data);
+
+       if (status != 0)
        {
-               if (args[i] == NULL)
-                       return (EINVAL);
+               ros_disconnect (c);
+               errno = status;
+               return (NULL);
+       }
 
-               status = buffer_add (&buffer_ptr, &buffer_size, args[i]);
-               if (status != 0)
-                       return (status);
+       return (c);
+} /* }}} ros_connection_t *ros_connect */
+
+int ros_disconnect (ros_connection_t *c) /* {{{ */
+{
+       if (c == NULL)
+               return (EINVAL);
+
+       if (c->fd >= 0)
+       {
+               close (c->fd);
+               c->fd = -1;
        }
 
-       status = buffer_end (&buffer_ptr, &buffer_size);
+       free (c);
+
+       return (0);
+} /* }}} int ros_disconnect */
+
+int ros_query (ros_connection_t *c, /* {{{ */
+               const char *command,
+               size_t args_num, const char * const *args,
+               ros_reply_handler_t handler, void *user_data)
+{
+       int status;
+       ros_reply_t *r;
+
+       if ((c == NULL) || (command == NULL) || (handler == NULL))
+               return (EINVAL);
+
+       status = send_command (c, command, args_num, args);
        if (status != 0)
                return (status);
 
-       /* FIXME: Send out the buffer and read back results. */
-}
+       r = receive_reply (c);
+       if (r == NULL)
+               return (EPROTO);
+
+       /* Call the callback function with the data we received. */
+       status = (*handler) (c, r, user_data);
+
+       /* Free the allocated memory ... */
+       reply_free (r);
+
+       /* ... and return. */
+       return (status);
+} /* }}} int ros_query */
 
-const mt_reply_t *mt_reply_next (const mt_reply_t *r) /* {{{ */
+const ros_reply_t *ros_reply_next (const ros_reply_t *r) /* {{{ */
 {
        if (r == NULL)
                return (NULL);
 
        return (r->next);
-} /* }}} mt_reply_t *mt_reply_next */
+} /* }}} ros_reply_t *ros_reply_next */
 
-int mt_reply_num (const mt_reply_t *r) /* {{{ */
+int ros_reply_num (const ros_reply_t *r) /* {{{ */
 {
        int ret;
-       const mt_reply_t *ptr;
+       const ros_reply_t *ptr;
 
        ret = 0;
        for (ptr = r; ptr != NULL; ptr = ptr->next)
                ret++;
 
        return (ret);
-} /* }}} int mt_reply_num */
+} /* }}} int ros_reply_num */
 
-const char *mt_reply_param_key_by_index (const mt_reply_t *r, /* {{{ */
+const char *ros_reply_status (const ros_reply_t *r) /* {{{ */
+{
+       if (r == NULL)
+               return (NULL);
+       return (r->status);
+} /* }}} char *ros_reply_status */
+
+const char *ros_reply_param_key_by_index (const ros_reply_t *r, /* {{{ */
                unsigned int index)
 {
        if (r == NULL)
@@ -369,9 +915,9 @@ const char *mt_reply_param_key_by_index (const mt_reply_t *r, /* {{{ */
                return (NULL);
 
        return (r->keys[index]);
-} /* }}} char *mt_reply_param_key_by_index */
+} /* }}} char *ros_reply_param_key_by_index */
 
-const char *mt_reply_param_val_by_index (const mt_reply_t *r, /* {{{ */
+const char *ros_reply_param_val_by_index (const ros_reply_t *r, /* {{{ */
                unsigned int index)
 {
        if (r == NULL)
@@ -381,9 +927,9 @@ const char *mt_reply_param_val_by_index (const mt_reply_t *r, /* {{{ */
                return (NULL);
 
        return (r->values[index]);
-} /* }}} char *mt_reply_param_key_by_index */
+} /* }}} char *ros_reply_param_key_by_index */
 
-const char *mt_reply_param_val_by_key (const mt_reply_t *r, /* {{{ */
+const char *ros_reply_param_val_by_key (const ros_reply_t *r, /* {{{ */
                const char *key)
 {
        unsigned int i;
@@ -396,6 +942,16 @@ const char *mt_reply_param_val_by_key (const mt_reply_t *r, /* {{{ */
                        return (r->values[i]);
 
        return (NULL);
-} /* }}} char *mt_reply_param_val_by_key */
+} /* }}} char *ros_reply_param_val_by_key */
+
+int ros_version (void) /* {{{ */
+{
+       return (ROS_VERSION);
+} /* }}} int ros_version */
+
+const char *ros_version_string (void) /* {{{ */
+{
+       return (ROS_VERSION_STRING);
+} /* }}} char *ros_version_string */
 
 /* vim: set ts=2 sw=2 noet fdm=marker : */