src/transport/test_plugin_transport_http.c

   1 /*
   2      This file is part of GNUnet.
   3      (C) 2010 Christian Grothoff (and other contributing authors)
   4
   5      GNUnet is free software; you can redistribute it and/or modify
   6      it under the terms of the GNU General Public License as published
   7      by the Free Software Foundation; either version 2, or (at your
   8      option) any later version.
   9
  10      GNUnet is distributed in the hope that it will be useful, but
  11      WITHOUT ANY WARRANTY; without even the implied warranty of
  12      MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13      General Public License for more details.
  14
  15      You should have received a copy of the GNU General Public License
  16      along with GNUnet; see the file COPYING.  If not, write to the
  17      Free Software Foundation, Inc., 59 Temple Place - Suite 330,
  18      Boston, MA 02111-1307, USA.
  19 */
  20 /**
  21  * @file transport/test_plugin_transport_http.c
  22  * @brief testcase for plugin_transport_http.c
  23  * @author Matthias Wachs
  24  */
  25
  26 #include "platform.h"
  27 #include "gnunet_constants.h"
  28 #include "gnunet_getopt_lib.h"
  29 #include "gnunet_hello_lib.h"
  30 #include "gnunet_os_lib.h"
  31 #include "gnunet_peerinfo_service.h"
  32 #include "gnunet_plugin_lib.h"
  33 #include "gnunet_protocols.h"
  34 #include "gnunet_program_lib.h"
  35 #include "gnunet_signatures.h"
  36 #include "plugin_transport.h"
  37 #include "transport.h"
  38
  39 #define VERBOSE GNUNET_YES
  40
  41 /**
  42  * How long until we give up on transmitting the message?
  43  */
  44 #define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 30)
  45
  46 /**
  47  * Our public key.
  48  */
  49 static struct GNUNET_CRYPTO_RsaPublicKeyBinaryEncoded my_public_key;
  50
  51 /**
  52  * Our identity.
  53  */
  54 static struct GNUNET_PeerIdentity my_identity;
  55
  56 /**
  57  * Our private key.
  58  */
  59 static struct GNUNET_CRYPTO_RsaPrivateKey *my_private_key;
  60
  61 /**
  62  * Our scheduler.
  63  */
  64 struct GNUNET_SCHEDULER_Handle *sched;
  65
  66 /**
  67  * Our configuration.
  68  */
  69 const struct GNUNET_CONFIGURATION_Handle *cfg;
  70
  71 /**
  72  * Number of neighbours we'd like to have.
  73  */
  74 static uint32_t max_connect_per_transport;
  75
  76 /**
  77  * Environment for this plugin.
  78  */
  79 struct GNUNET_TRANSPORT_PluginEnvironment env;
  80
  81 /**
  82  *handle for the api provided by this plugin
  83  */
  84 struct GNUNET_TRANSPORT_PluginFunctions *api;
  85
  86 /**
  87  * Did the test pass or fail?
  88  */
  89 static int ok;
  90
  91 /**
  92  * Initialize Environment for this plugin
  93  */
  94 static void
  95 receive (void *cls,
  96         const struct GNUNET_PeerIdentity * peer,
  97         const struct GNUNET_MessageHeader * message,
  98         uint32_t distance,
  99         const char *sender_address,
 100         size_t sender_address_len)
 101 {
 102   /* do nothing */
 103 }
 104
 105 void
 106 notify_address (void *cls,
 107                 const char *name,
 108                 const void *addr,
 109                 size_t addrlen, struct GNUNET_TIME_Relative expires)
 110 {
 111 }
 112
 113 /**
 114  * Function called when the service shuts
 115  * down.  Unloads our plugins.
 116  *
 117  * @param cls closure
 118  * @param cfg configuration to use
 119  */
 120 static void
 121 unload_plugins (void *cls, const struct GNUNET_CONFIGURATION_Handle *cfg)
 122 {
 123   GNUNET_assert (NULL ==
 124                  GNUNET_PLUGIN_unload ("libgnunet_plugin_transport_udp",
 125                                        api));
 126   if (my_private_key != NULL)
 127     GNUNET_CRYPTO_rsa_key_free (my_private_key);
 128
 129   ok = 0;
 130 }
 131
 132 /**
 133  * Simple example test that invokes
 134  * the check_address function of the plugin.
 135  */
 136 /* FIXME: won't work on IPv6 enabled systems where IPv4 mapping
 137  * isn't enabled (eg. FreeBSD > 4)
 138  */
 139 static void
 140 test_validation ()
 141 {
 142   struct sockaddr_in soaddr;
 143
 144   memset (&soaddr, 0, sizeof (soaddr));
 145 #if HAVE_SOCKADDR_IN_SIN_LEN
 146   soaddr.sin_len = sizeof (soaddr);
 147 #endif
 148   soaddr.sin_family = AF_INET;
 149   soaddr.sin_port = htons (2368 /* FIXME: get from config! */ );
 150   soaddr.sin_addr.s_addr = htonl (INADDR_LOOPBACK);
 151
 152   api->check_address(api->cls,
 153       &soaddr, sizeof (soaddr));
 154
 155   unload_plugins(env.cls, env.cfg);
 156 }
 157
 158
 159 static void
 160 setup_plugin_environment ()
 161 {
 162   env.cfg = cfg;
 163   env.sched = sched;
 164   env.my_identity = &my_identity;
 165   env.cls = &env;
 166   env.receive = &receive;
 167   env.notify_address = &notify_address;
 168   env.max_connections = max_connect_per_transport;
 169 }
 170
 171 /**
 172  * Runs the test.
 173  *
 174  * @param cls closure
 175  * @param s scheduler to use
 176  * @param c configuration to use
 177  */
 178 static void
 179 run (void *cls,
 180      struct GNUNET_SCHEDULER_Handle *s,
 181      char *const *args,
 182      const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *c)
 183 {
 184   unsigned long long tneigh;
 185   char *keyfile;
 186   char *libname;
 187
 188   sched = s;
 189   cfg = c;
 190   /* parse configuration */
 191   if ((GNUNET_OK !=
 192        GNUNET_CONFIGURATION_get_value_number (c,
 193                                               "TRANSPORT",
 194                                               "NEIGHBOUR_LIMIT",
 195                                               &tneigh)) ||
 196       (GNUNET_OK !=
 197        GNUNET_CONFIGURATION_get_value_filename (c,
 198                                                 "GNUNETD",
 199                                                 "HOSTKEY", &keyfile)))
 200     {
 201       GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
 202                   _
 203                   ("Transport service is lacking key configuration settings.  Exiting.\n"));
 204       GNUNET_SCHEDULER_shutdown (s);
 205       return;
 206     }
 207   max_connect_per_transport = (uint32_t) tneigh;
 208   my_private_key = GNUNET_CRYPTO_rsa_key_create_from_file (keyfile);
 209   GNUNET_free (keyfile);
 210   if (my_private_key == NULL)
 211     {
 212       GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
 213                   _
 214                   ("Transport service could not access hostkey.  Exiting.\n"));
 215       GNUNET_SCHEDULER_shutdown (s);
 216       return;
 217     }
 218   GNUNET_CRYPTO_rsa_key_get_public (my_private_key, &my_public_key);
 219   GNUNET_CRYPTO_hash (&my_public_key,
 220                       sizeof (my_public_key), &my_identity.hashPubKey);
 221
 222   /* load plugins... */
 223   setup_plugin_environment ();
 224   GNUNET_log (GNUNET_ERROR_TYPE_INFO, _("Loading http transport plugin\n"));
 225   GNUNET_asprintf (&libname, "libgnunet_plugin_transport_http");
 226
 227   api = GNUNET_PLUGIN_load (libname, &env);
 228   GNUNET_free (libname);
 229   if (api == NULL)
 230     {
 231       GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
 232                   _("Failed to load transport plugin for http\n"));
 233       /* FIXME: set some error code for main */
 234       return;
 235     }
 236   test_validation ();
 237 }
 238
 239
 240 /**
 241  * The main function for the transport service.
 242  *
 243  * @param argc number of arguments from the command line
 244  * @param argv command line arguments
 245  * @return 0 ok, 1 on error
 246  */
 247 int
 248 main (int argc, char *const *argv)
 249 {
 250   static struct GNUNET_GETOPT_CommandLineOption options[] = {
 251     GNUNET_GETOPT_OPTION_END
 252   };
 253   int ret;
 254   char *const argv_prog[] = {
 255     "test-gnunetd-plugin-transport_http",
 256     "-c",
 257     "test_plugin_transport_data_http.conf",
 258     "-L",
 259 #if VERBOSE
 260     "DEBUG",
 261 #else
 262     "WARNING",
 263 #endif
 264     NULL
 265   };
 266   GNUNET_log_setup ("test-gnunetd-plugin-transport_http",
 267 #if VERBOSE
 268                     "DEBUG",
 269 #else
 270                     "WARNING",
 271 #endif
 272                     NULL);
 273   ok = 1;                       /* set to fail */
 274   ret = (GNUNET_OK ==
 275          GNUNET_PROGRAM_run (5,
 276                              argv_prog,
 277                              "test-plugin-transport_http",
 278                              "testcase", options, &run, NULL)) ? ok : 1;
 279   GNUNET_DISK_directory_remove ("/tmp/test-gnunetd-plugin-transport_http");
 280   /* FIXME: return correct value */
 281   /* return ret; */
 282   return GNUNET_NO;
 283 }
 284
 285 /* end of test_plugin_transport_http.c */