[GNUnet-SVN] r14597 - in gnunet/src: include util vpn

[gnunet]

Author: toelke
Date: 2011-03-05 12:17:09 +0100 (Sat, 05 Mar 2011)
New Revision: 14597

Modified:
   gnunet/src/include/gnunet_configuration_lib.h
   gnunet/src/util/configuration.c
   gnunet/src/vpn/gnunet-service-dns.c
Log:
read the dns-config from the file

Modified: gnunet/src/include/gnunet_configuration_lib.h
===================================================================
--- gnunet/src/include/gnunet_configuration_lib.h       2011-03-05 11:17:07 UTC 
(rev 14596)
+++ gnunet/src/include/gnunet_configuration_lib.h       2011-03-05 11:17:09 UTC 
(rev 14597)
@@ -142,6 +142,16 @@
 
 
 /**
+ * Function to iterate over section.
+ *
+ * @param cls closure
+ * @param section name of the section
+ */
+typedef void (*GNUNET_CONFIGURATION_Section_Iterator)(void *cls,
+                                             const char *section);
+
+
+/**
  * Iterate over all options in the configuration.
  *
  * @param cfg configuration to inspect
@@ -154,6 +164,17 @@
 
 
 /**
+ * Iterate over all sections in the configuration.
+ *
+ * @param cfg configuration to inspect
+ * @param iter function to call on each section
+ * @param iter_cls closure for iter
+ */
+void GNUNET_CONFIGURATION_iterate_sections (const struct 
GNUNET_CONFIGURATION_Handle *cfg,
+                                            
GNUNET_CONFIGURATION_Section_Iterator iter,
+                                            void *iter_cls);
+
+/**
  * Get a configuration value that should be a number.
  *
  * @param cfg configuration to inspect

Modified: gnunet/src/util/configuration.c
===================================================================
--- gnunet/src/util/configuration.c     2011-03-05 11:17:07 UTC (rev 14596)
+++ gnunet/src/util/configuration.c     2011-03-05 11:17:09 UTC (rev 14597)
@@ -402,6 +402,25 @@
 
 
 /**
+ * Iterate over all sections in the configuration.
+ *
+ * @param cfg configuration to inspect
+ * @param iter function to call on each section
+ * @param iter_cls closure for iter
+ */
+void
+GNUNET_CONFIGURATION_iterate_sections (const struct 
GNUNET_CONFIGURATION_Handle *cfg,
+                                       GNUNET_CONFIGURATION_Section_Iterator 
iter,
+                                       void *iter_cls)
+{
+  struct ConfigSection *spos;
+
+  for (spos = cfg->sections; spos != NULL; spos = spos->next)
+    iter (iter_cls, spos->name);
+}
+
+
+/**
  * Copy a configuration value to the given target configuration.
  * Overwrites existing entries.
  *

Modified: gnunet/src/vpn/gnunet-service-dns.c
===================================================================
--- gnunet/src/vpn/gnunet-service-dns.c 2011-03-05 11:17:07 UTC (rev 14596)
+++ gnunet/src/vpn/gnunet-service-dns.c 2011-03-05 11:17:09 UTC (rev 14597)
@@ -61,6 +61,11 @@
 static const struct GNUNET_CONFIGURATION_Handle *cfg;
 
 /**
+ * The handle to the service-configuration
+ */
+static struct GNUNET_CONFIGURATION_Handle *servicecfg;
+
+/**
  * A list of DNS-Responses that have to be sent to the requesting client
  */
 static struct answer_packet_list *head;
@@ -568,74 +573,222 @@
 }
 
 /**
- * Publish a DNS-record in the DHT. This is up to now just for testing.
+ * @brief Create a port-map from udp and tcp redirects
+ *
+ * @param udp_redirects
+ * @param tcp_redirects
+ *
+ * @return 
  */
-static void
-publish_name (void *cls,
-             const struct GNUNET_SCHEDULER_TaskContext *tc) {
-    if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN))
+uint64_t
+get_port_from_redirects (const char *udp_redirects, const char *tcp_redirects)
+{
+  uint64_t ret = 0;
+  char* cpy, *hostname, *redirect;
+  int local_port, count = 0;
+
+  if (NULL != udp_redirects)
+    {
+      cpy = GNUNET_strdup (udp_redirects);
+      for (redirect = strtok (cpy, " "); redirect != NULL; redirect = strtok 
(NULL, " "))
+        {
+          if (NULL == (hostname = strstr (redirect, ":")))
+            {
+              // FIXME: bitch
+              continue;
+            }
+          hostname[0] = '\0';
+          local_port = atoi (redirect);
+          GNUNET_assert ((local_port > 0) && (local_port < 65536)); // FIXME: 
don't crash!!!
+
+          ret |= (0xFFFF & htons(local_port));
+          ret <<= 16;
+          count ++;
+
+          if(count > 4)
+            {
+              ret = 0;
+              goto out;
+            }
+        }
+      GNUNET_free(cpy);
+      cpy = NULL;
+    }
+
+  if (NULL != tcp_redirects)
+    {
+      cpy = GNUNET_strdup (tcp_redirects);
+      for (redirect = strtok (cpy, " "); redirect != NULL; redirect = strtok 
(NULL, " "))
+        {
+          if (NULL == (hostname = strstr (redirect, ":")))
+            {
+              // FIXME: bitch
+              continue;
+            }
+          hostname[0] = '\0';
+          local_port = atoi (redirect);
+          GNUNET_assert ((local_port > 0) && (local_port < 65536)); // FIXME: 
don't crash!!!
+
+          ret |= (0xFFFF & htons(local_port));
+          ret <<= 16;
+          count ++;
+
+          if(count > 4)
+            {
+              ret = 0;
+              goto out;
+            }
+        }
+      GNUNET_free(cpy);
+      cpy = NULL;
+    }
+
+out:
+  if (NULL != cpy)
+    GNUNET_free(cpy);
+  return ret;
+}
+
+void
+publish_name (const char *name, uint64_t ports, uint32_t service_type,
+              struct GNUNET_CRYPTO_RsaPrivateKey *my_private_key)
+{
+  size_t size = sizeof (struct GNUNET_DNS_Record);
+  struct GNUNET_DNS_Record data;
+  memset (&data, 0, size);
+
+  data.purpose.size =
+    htonl (size - sizeof (struct GNUNET_CRYPTO_RsaSignature));
+  data.purpose.purpose = GNUNET_SIGNATURE_PURPOSE_DNS_RECORD;
+
+  GNUNET_CRYPTO_hash (name, strlen (name) + 1, &data.service_descriptor);
+  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Store with key1 %x\n",
+              *((unsigned long long *) &data.service_descriptor));
+
+  data.service_type = service_type;
+  data.ports = ports;
+
+  GNUNET_CRYPTO_rsa_key_get_public (my_private_key, &data.peer);
+
+  data.expiration_time =
+    GNUNET_TIME_relative_to_absolute 
(GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_HOURS, 2));
+
+  /* Sign the block */
+  if (GNUNET_OK != GNUNET_CRYPTO_rsa_sign (my_private_key,
+                                           &data.purpose, &data.signature))
+    {
+      GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "could not sign DNS_Record\n");
       return;
+    }
 
-    char* name = "philipptoelke.gnunet.";
-    size_t size = sizeof(struct GNUNET_DNS_Record);
-    struct GNUNET_DNS_Record data;
-    memset(&data, 0, size);
+  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+              "Putting with key %08x, size = %d\n",
+              *((unsigned int *) &data.service_descriptor), size);
 
-    data.purpose.size = htonl(size - sizeof(struct 
GNUNET_CRYPTO_RsaSignature));
-    data.purpose.purpose = GNUNET_SIGNATURE_PURPOSE_DNS_RECORD;
+  GNUNET_DHT_put (dht,
+                  &data.service_descriptor,
+                  DEFAULT_PUT_REPLICATION,
+                  GNUNET_DHT_RO_NONE,
+                  GNUNET_BLOCK_TYPE_DNS,
+                  size,
+                  (char *) &data,
+                  GNUNET_TIME_relative_to_absolute (GNUNET_TIME_UNIT_HOURS),
+                  GNUNET_TIME_UNIT_MINUTES, NULL, NULL);
+}
 
-    GNUNET_CRYPTO_hash(name, strlen(name)+1, &data.service_descriptor);
-    GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Store with key1 %x\n", *((unsigned 
long long*)&data.service_descriptor));
+/**
+ * @brief Publishes the record defined by the section section
+ *
+ * @param cls closure
+ * @param section the current section
+ */
+void
+publish_iterate (void *cls, const char *section)
+{
+  char *udp_redirects, *tcp_redirects, *alternative_names, *alternative_name,
+    *keyfile;
 
-    data.service_type = htonl(GNUNET_DNS_SERVICE_TYPE_UDP);
-    data.ports = htons(69);
+  GNUNET_CONFIGURATION_get_value_string (servicecfg, section,
+                                         "UDP_REDIRECTS", &udp_redirects);
+  GNUNET_CONFIGURATION_get_value_string (servicecfg, section, "TCP_REDIRECTS",
+                                         &tcp_redirects);
 
-    char* keyfile;
-    if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_filename(cfg, "GNUNETD",
-                                                            "HOSTKEY", 
&keyfile))
-      {
-       GNUNET_log(GNUNET_ERROR_TYPE_ERROR, "could not read keyfile-value\n");
-       if (keyfile != NULL) GNUNET_free(keyfile);
-       return;
-      }
+  if (GNUNET_OK != GNUNET_CONFIGURATION_get_value_filename (cfg, "GNUNETD",
+                                                            "HOSTKEY",
+                                                            &keyfile))
+    {
+      GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "could not read keyfile-value\n");
+      if (keyfile != NULL)
+        GNUNET_free (keyfile);
+      return;
+    }
 
-    struct GNUNET_CRYPTO_RsaPrivateKey *my_private_key = 
GNUNET_CRYPTO_rsa_key_create_from_file(keyfile);
-    GNUNET_free(keyfile);
-    GNUNET_assert(my_private_key != NULL);
+  struct GNUNET_CRYPTO_RsaPrivateKey *my_private_key =
+    GNUNET_CRYPTO_rsa_key_create_from_file (keyfile);
+  GNUNET_free (keyfile);
+  GNUNET_assert (my_private_key != NULL);
 
-    GNUNET_CRYPTO_rsa_key_get_public(my_private_key, &data.peer);
+  uint64_t ports = get_port_from_redirects (udp_redirects, tcp_redirects);
+  uint32_t service_type = 0;
 
-    data.expiration_time = 
GNUNET_TIME_relative_to_absolute(GNUNET_TIME_UNIT_HOURS);
+  if (NULL != udp_redirects)
+    service_type = GNUNET_DNS_SERVICE_TYPE_UDP;
 
-  /* Sign the block */
-    if (GNUNET_OK != GNUNET_CRYPTO_rsa_sign(my_private_key,
-                                           &data.purpose,
-                                           &data.signature))
+  if (NULL != tcp_redirects)
+    service_type = GNUNET_DNS_SERVICE_TYPE_TCP;
+
+  service_type = htonl (service_type);
+
+
+  publish_name (section, ports, service_type, my_private_key);
+
+  GNUNET_CONFIGURATION_get_value_string (servicecfg, section,
+                                         "ALTERNATIVE_NAMES",
+                                         &alternative_names);
+  for (alternative_name = strtok (alternative_names, " ");
+       alternative_name != NULL; alternative_name = strtok (NULL, " "))
+    {
+      char *altname =
+        alloca (strlen (alternative_name) + strlen (section) + 1 + 1);
+      strcpy (altname, alternative_name);
+      strcpy (altname + strlen (alternative_name) + 1, section);
+      altname[strlen (alternative_name)] = '.';
+
+      publish_name (altname, ports, service_type, my_private_key);
+    }
+
+  GNUNET_free_non_null(alternative_names);
+  GNUNET_CRYPTO_rsa_key_free (my_private_key);
+  GNUNET_free_non_null (udp_redirects);
+  GNUNET_free_non_null (tcp_redirects);
+}
+
+/**
+ * Publish a DNS-record in the DHT. This is up to now just for testing.
+ */
+static void
+publish_names (void *cls,
+               const struct GNUNET_SCHEDULER_TaskContext *tc) {
+    char *services;
+    if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN))
+      return;
+
+    if (NULL != servicecfg)
+      GNUNET_CONFIGURATION_destroy(servicecfg);
+
+    GNUNET_CONFIGURATION_get_value_filename(cfg, "dns", "SERVICES", &services);
+
+    servicecfg = GNUNET_CONFIGURATION_create();
+    if (GNUNET_OK == GNUNET_CONFIGURATION_parse(servicecfg, services))
       {
-       GNUNET_log(GNUNET_ERROR_TYPE_ERROR, "could not sign DNS_Record\n");
-       return;
+        GNUNET_log(GNUNET_ERROR_TYPE_INFO, "Parsing services %s\n", services);
+        GNUNET_CONFIGURATION_iterate_sections(servicecfg, publish_iterate, 
NULL);
       }
-    GNUNET_CRYPTO_rsa_key_free(my_private_key);
+    if (NULL != services)
+      GNUNET_free(services);
 
-    GNUNET_log(GNUNET_ERROR_TYPE_DEBUG,
-              "Putting with key %08x, size = %d\n",
-              *((unsigned int*)&data.service_descriptor),
-               size);
-
-    GNUNET_DHT_put(dht,
-                  &data.service_descriptor,
-                  DEFAULT_PUT_REPLICATION,
-                  GNUNET_DHT_RO_NONE,
-                  GNUNET_BLOCK_TYPE_DNS,
-                  size,
-                  (char*)&data,
-                  GNUNET_TIME_relative_to_absolute(GNUNET_TIME_UNIT_HOURS),
-                  GNUNET_TIME_UNIT_MINUTES,
-                  NULL,
-                  NULL);
-
     GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_HOURS,
-                                 publish_name,
+                                 publish_names,
                                  NULL);
 }
 
@@ -689,7 +842,7 @@
 
   dnsoutport = htons(addr.sin_port);
 
-  GNUNET_SCHEDULER_add_now (publish_name, NULL);
+  GNUNET_SCHEDULER_add_now (publish_names, NULL);
 
   GNUNET_SCHEDULER_add_read_net(GNUNET_TIME_UNIT_FOREVER_REL, dnsout, 
&read_response, NULL);