src/gns/gnunet-service-gns_resolver.c

   1 /*
   2      This file is part of GNUnet.
   3      Copyright (C) 2011-2013 GNUnet e.V.
   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 3, 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., 51 Franklin Street, Fifth Floor,
  18      Boston, MA 02110-1301, USA.
  19 */
  20
  21 /**
  22  * @file gns/gnunet-service-gns_resolver.c
  23  * @brief GNU Name System resolver logic
  24  * @author Martin Schanzenbach
  25  * @author Christian Grothoff
  26  */
  27 #include "platform.h"
  28 #include "gnunet_util_lib.h"
  29 #include "gnunet_dnsstub_lib.h"
  30 #include "gnunet_dht_service.h"
  31 #include "gnunet_gnsrecord_lib.h"
  32 #include "gnunet_namecache_service.h"
  33 #include "gnunet_namestore_service.h"
  34 #include "gnunet_dns_service.h"
  35 #include "gnunet_resolver_service.h"
  36 #include "gnunet_revocation_service.h"
  37 #include "gnunet_dnsparser_lib.h"
  38 #include "gnunet_tun_lib.h"
  39 #include "gnunet_gns_service.h"
  40 #include "gns.h"
  41 #include "gnunet-service-gns_resolver.h"
  42 #include "gnunet-service-gns_shorten.h"
  43 #include "gnunet_vpn_service.h"
  44
  45
  46 /**
  47  * Default DHT timeout for lookups.
  48  */
  49 #define DHT_LOOKUP_TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 60)
  50
  51 /**
  52  * Default timeout for DNS lookups.
  53  */
  54 #define DNS_LOOKUP_TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 15)
  55
  56 /**
  57  * Default timeout for VPN redirections.
  58  */
  59 #define VPN_TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MINUTES, 30)
  60
  61 /**
  62  * DHT replication level
  63  */
  64 #define DHT_GNS_REPLICATION_LEVEL 5
  65
  66 /**
  67  * How deep do we allow recursions to go before we abort?
  68  */
  69 #define MAX_RECURSION 256
  70
  71
  72 /**
  73  * DLL to hold the authority chain we had to pass in the resolution
  74  * process.
  75  */
  76 struct AuthorityChain
  77 {
  78   /**
  79    * This is a DLL.
  80    */
  81   struct AuthorityChain *prev;
  82
  83   /**
  84    * This is a DLL.
  85    */
  86   struct AuthorityChain *next;
  87
  88   /**
  89    * Resolver handle this entry in the chain belongs to.
  90    */
  91   struct GNS_ResolverHandle *rh;
  92
  93   /**
  94    * label/name corresponding to the authority
  95    */
  96   char *label;
  97
  98   /**
  99    * label/name suggested for shortening to the authority
 100    */
 101   char *suggested_shortening_label;
 102
 103   /**
 104    * Do we already try to shorten this authority?
 105    */
 106   int shortening_started;
 107
 108   /**
 109    * #GNUNET_YES if the authority was a GNS authority,
 110    * #GNUNET_NO if the authority was a DNS authority.
 111    */
 112   int gns_authority;
 113
 114   /**
 115    * Information about the resolver authority for this label.
 116    */
 117   union
 118   {
 119
 120     /**
 121      * The zone of the GNS authority
 122      */
 123     struct GNUNET_CRYPTO_EcdsaPublicKey gns_authority;
 124
 125     struct
 126     {
 127       /**
 128        * Domain of the DNS resolver that is the authority.
 129        * (appended to construct the DNS name to resolve;
 130        * this is NOT the DNS name of the DNS server!).
 131        */
 132       char name[GNUNET_DNSPARSER_MAX_NAME_LENGTH + 1];
 133
 134       /**
 135        * IP address of the DNS resolver that is authoritative.
 136        * (this implementation currently only supports one
 137        * IP at a time).
 138        */
 139       struct sockaddr_storage dns_ip;
 140
 141     } dns_authority;
 142
 143   } authority_info;
 144
 145 };
 146
 147
 148 /**
 149  * A result we got from DNS.
 150  */
 151 struct DnsResult
 152 {
 153
 154   /**
 155    * Kept in DLL.
 156    */
 157   struct DnsResult *next;
 158
 159   /**
 160    * Kept in DLL.
 161    */
 162   struct DnsResult *prev;
 163
 164   /**
 165    * Binary value stored in the DNS record (appended to this struct)
 166    */
 167   const void *data;
 168
 169   /**
 170    * Expiration time for the DNS record, 0 if we didn't
 171    * get anything useful (i.e. 'gethostbyname()' was used).
 172    */
 173   uint64_t expiration_time;
 174
 175   /**
 176    * Number of bytes in @e data.
 177    */
 178   size_t data_size;
 179
 180   /**
 181    * Type of the GNS/DNS record.
 182    */
 183   uint32_t record_type;
 184
 185 };
 186
 187
 188 /**
 189  * Closure for #vpn_allocation_cb.
 190  */
 191 struct VpnContext
 192 {
 193
 194   /**
 195    * Which resolution process are we processing.
 196    */
 197   struct GNS_ResolverHandle *rh;
 198
 199   /**
 200    * Handle to the VPN request that we were performing.
 201    */
 202   struct GNUNET_VPN_RedirectionRequest *vpn_request;
 203
 204   /**
 205    * Number of records serialized in @e rd_data.
 206    */
 207   unsigned int rd_count;
 208
 209   /**
 210    * Serialized records.
 211    */
 212   char *rd_data;
 213
 214   /**
 215    * Number of bytes in @e rd_data.
 216    */
 217   size_t rd_data_size;
 218 };
 219
 220
 221 /**
 222  * Information we keep during the resolution of an
 223  * IP address for a DNS server while handling a
 224  * GNS2DNS record.
 225  */
 226 struct Gns2DnsContext
 227 {
 228
 229   /**
 230    * DNS domain in which the resolution will continue
 231    * (first part of the GNS2DNS record).
 232    */
 233   char *ns;
 234
 235   /**
 236    * Handle for the resolution of the IP part of the
 237    * GNS2DNS record.  Will return to us the addresses
 238    * of the DNS resolver to use.
 239    */
 240   struct GNS_ResolverHandle *rh;
 241
 242 };
 243
 244
 245 /**
 246  * Handle to a currenty pending resolution.  On result (positive or
 247  * negative) the #GNS_ResultProcessor is called.
 248  */
 249 struct GNS_ResolverHandle
 250 {
 251
 252   /**
 253    * DLL
 254    */
 255   struct GNS_ResolverHandle *next;
 256
 257   /**
 258    * DLL
 259    */
 260   struct GNS_ResolverHandle *prev;
 261
 262   /**
 263    * The top-level GNS authoritative zone to query
 264    */
 265   struct GNUNET_CRYPTO_EcdsaPublicKey authority_zone;
 266
 267   /**
 268    * called when resolution phase finishes
 269    */
 270   GNS_ResultProcessor proc;
 271
 272   /**
 273    * closure passed to @e proc
 274    */
 275   void* proc_cls;
 276
 277   /**
 278    * Handle used during GNS2DNS resolution for looking up the
 279    * IP address of the DNS server.
 280    */
 281   struct Gns2DnsContext *g2dc;
 282
 283   /**
 284    * Handle for DHT lookups. should be NULL if no lookups are in progress
 285    */
 286   struct GNUNET_DHT_GetHandle *get_handle;
 287
 288   /**
 289    * Handle to a VPN request, NULL if none is active.
 290    */
 291   struct VpnContext *vpn_ctx;
 292
 293   /**
 294    * Socket for a DNS request, NULL if none is active.
 295    */
 296   struct GNUNET_DNSSTUB_RequestSocket *dns_request;
 297
 298   /**
 299    * Handle for standard DNS resolution, NULL if none is active.
 300    */
 301   struct GNUNET_RESOLVER_RequestHandle *std_resolve;
 302
 303   /**
 304    * Pending Namecache lookup task
 305    */
 306   struct GNUNET_NAMECACHE_QueueEntry *namecache_qe;
 307
 308   /**
 309    * Pending revocation check.
 310    */
 311   struct GNUNET_REVOCATION_Query *rev_check;
 312
 313   /**
 314    * Heap node associated with this lookup.  Used to limit number of
 315    * concurrent requests.
 316    */
 317   struct GNUNET_CONTAINER_HeapNode *dht_heap_node;
 318
 319   /**
 320    * DLL to store the authority chain
 321    */
 322   struct AuthorityChain *ac_head;
 323
 324   /**
 325    * DLL to store the authority chain
 326    */
 327   struct AuthorityChain *ac_tail;
 328
 329   /**
 330    * Private key of the shorten zone, NULL to not shorten.
 331    */
 332   struct GNUNET_CRYPTO_EcdsaPrivateKey *shorten_key;
 333
 334   /**
 335    * ID of a task associated with the resolution process.
 336    */
 337   struct GNUNET_SCHEDULER_Task * task_id;
 338
 339   /**
 340    * The name to resolve
 341    */
 342   char *name;
 343
 344   /**
 345    * DLL of results we got from DNS.
 346    */
 347   struct DnsResult *dns_result_head;
 348
 349   /**
 350    * DLL of results we got from DNS.
 351    */
 352   struct DnsResult *dns_result_tail;
 353
 354   /**
 355    * Current offset in 'name' where we are resolving.
 356    */
 357   size_t name_resolution_pos;
 358
 359   /**
 360    * Use only cache
 361    */
 362   enum GNUNET_GNS_LocalOptions options;
 363
 364   /**
 365    * For SRV and TLSA records, the number of the
 366    * protocol specified in the name.  0 if no protocol was given.
 367    */
 368   int protocol;
 369
 370   /**
 371    * For SRV and TLSA records, the number of the
 372    * service specified in the name.  0 if no service was given.
 373    */
 374   int service;
 375
 376   /**
 377    * Desired type for the resolution.
 378    */
 379   int record_type;
 380
 381   /**
 382    * We increment the loop limiter for each step in a recursive
 383    * resolution.  If it passes our threshold (i.e. due to
 384    * self-recursion in the resolution, i.e CNAME fun), we stop.
 385    */
 386   unsigned int loop_limiter;
 387
 388 };
 389
 390
 391 /**
 392  * Active namestore caching operations.
 393  */
 394 struct CacheOps
 395 {
 396
 397   /**
 398    * Organized in a DLL.
 399    */
 400   struct CacheOps *next;
 401
 402   /**
 403    * Organized in a DLL.
 404    */
 405   struct CacheOps *prev;
 406
 407   /**
 408    * Pending Namestore caching task.
 409    */
 410   struct GNUNET_NAMECACHE_QueueEntry *namecache_qe_cache;
 411
 412 };
 413
 414
 415 /**
 416  * Our handle to the namecache service
 417  */
 418 static struct GNUNET_NAMECACHE_Handle *namecache_handle;
 419
 420 /**
 421  * Our handle to the vpn service
 422  */
 423 static struct GNUNET_VPN_Handle *vpn_handle;
 424
 425 /**
 426  * Resolver handle to the dht
 427  */
 428 static struct GNUNET_DHT_Handle *dht_handle;
 429
 430 /**
 431  * Handle to perform DNS lookups.
 432  */
 433 static struct GNUNET_DNSSTUB_Context *dns_handle;
 434
 435 /**
 436  * Heap for limiting parallel DHT lookups
 437  */
 438 static struct GNUNET_CONTAINER_Heap *dht_lookup_heap;
 439
 440 /**
 441  * Maximum amount of parallel queries to the DHT
 442  */
 443 static unsigned long long max_allowed_background_queries;
 444
 445 /**
 446  * Head of resolver lookup list
 447  */
 448 static struct GNS_ResolverHandle *rlh_head;
 449
 450 /**
 451  * Tail of resolver lookup list
 452  */
 453 static struct GNS_ResolverHandle *rlh_tail;
 454
 455 /**
 456  * Organized in a DLL.
 457  */
 458 static struct CacheOps *co_head;
 459
 460 /**
 461  * Organized in a DLL.
 462  */
 463 static struct CacheOps *co_tail;
 464
 465 /**
 466  * Use namecache
 467  */
 468 static int use_cache;
 469
 470 /**
 471  * Global configuration.
 472  */
 473 static const struct GNUNET_CONFIGURATION_Handle *cfg;
 474
 475
 476 /**
 477  * Determine if this name is canonical (is a legal name in a zone, without delegation);
 478  * note that we do not test that the name does not contain illegal characters, we only
 479  * test for delegation.  Note that service records (i.e. _foo._srv) are canonical names
 480  * even though they consist of multiple labels.
 481  *
 482  * Examples:
 483  * a.b.gnu  = not canonical
 484  * a         = canonical
 485  * _foo._srv = canonical
 486  * _f.bar    = not canonical
 487  *
 488  * @param name the name to test
 489  * @return #GNUNET_YES if canonical
 490  */
 491 static int
 492 is_canonical (const char *name)
 493 {
 494   const char *pos;
 495   const char *dot;
 496
 497   if (NULL == strchr (name, '.'))
 498     return GNUNET_YES;
 499   if ('_' != name[0])
 500     return GNUNET_NO;
 501   pos = &name[1];
 502   while (NULL != (dot = strchr (pos, '.')))
 503     if ('_' != dot[1])
 504       return GNUNET_NO;
 505     else
 506       pos = dot + 1;
 507   return GNUNET_YES;
 508 }
 509
 510 /* ************************** Resolution **************************** */
 511
 512 /**
 513  * Expands a name ending in .+ with the zone of origin.
 514  *
 515  * @param rh resolution context
 516  * @param name name to modify (to be free'd or returned)
 517  * @return updated name
 518  */
 519 static char *
 520 translate_dot_plus (struct GNS_ResolverHandle *rh,
 521                     char *name)
 522 {
 523   char *ret;
 524   size_t s_len = strlen (name);
 525
 526   if (0 != strcmp (&name[s_len - 2],
 527                    ".+"))
 528     return name; /* did not end in ".+" */
 529   GNUNET_assert (GNUNET_YES == rh->ac_tail->gns_authority);
 530   GNUNET_asprintf (&ret,
 531                    "%.*s.%s",
 532                    (int) (s_len - 2),
 533                    name,
 534                    GNUNET_GNSRECORD_pkey_to_zkey (&rh->ac_tail->authority_info.gns_authority));
 535   GNUNET_free (name);
 536   return ret;
 537 }
 538
 539
 540 /**
 541  * Task scheduled to asynchronously fail a resolution.
 542  *
 543  * @param cls the 'struct GNS_ResolverHandle' of the resolution to fail
 544  */
 545 static void
 546 fail_resolution (void *cls)
 547 {
 548   struct GNS_ResolverHandle *rh = cls;
 549
 550   rh->task_id = NULL;
 551   rh->proc (rh->proc_cls, 0, NULL);
 552   GNS_resolver_lookup_cancel (rh);
 553 }
 554
 555
 556 #if (defined WINDOWS) || (defined DARWIN)
 557 /* Don't have this on W32, here's a naive implementation
 558  * Was somehow removed on OS X ...  */
 559 static void *
 560 memrchr (const void *s,
 561          int c,
 562          size_t n)
 563 {
 564   const unsigned char *ucs = s;
 565   ssize_t i;
 566
 567   for (i = n - 1; i >= 0; i--)
 568     if (c == (int) ucs[i])
 569       return (void *) &ucs[i];
 570   return NULL;
 571 }
 572 #endif
 573
 574
 575 /**
 576  * Get the next, rightmost label from the name that we are trying to resolve,
 577  * and update the resolution position accordingly.  Labels usually consist
 578  * of up to 63 characters without a period ("."); however, we use a special
 579  * convention to support SRV and TLSA records where the domain name
 580  * includes an encoding for a service and protocol in the name.  The
 581  * syntax (see RFC 2782) here is "_Service._Proto.Name" and in this
 582  * special case we include the "_Service._Proto" in the rightmost label.
 583  * Thus, for "_443._tcp.foo.bar" we first return the label "bar" and then
 584  * the label "_443._tcp.foo".  The special case is detected by the
 585  * presence of labels beginning with an underscore.  Whenever a label
 586  * begins with an underscore, it is combined with the label to its right
 587  * (and the "." is preserved).
 588  *
 589  * @param rh handle to the resolution operation to get the next label from
 590  * @return NULL if there are no more labels
 591  */
 592 static char *
 593 resolver_lookup_get_next_label (struct GNS_ResolverHandle *rh)
 594 {
 595   const char *rp;
 596   const char *dot;
 597   size_t len;
 598   char *ret;
 599   char *srv_name;
 600   char *proto_name;
 601   struct protoent *pe;
 602   struct servent *se;
 603
 604   if (0 == rh->name_resolution_pos)
 605     return NULL;
 606   dot = memrchr (rh->name,
 607                  (int) '.',
 608                  rh->name_resolution_pos);
 609   if (NULL == dot)
 610   {
 611     /* done, this was the last one */
 612     len = rh->name_resolution_pos;
 613     rp = rh->name;
 614     rh->name_resolution_pos = 0;
 615   }
 616   else
 617   {
 618     /* advance by one label */
 619     len = rh->name_resolution_pos - (dot - rh->name) - 1;
 620     rp = dot + 1;
 621     rh->name_resolution_pos = dot - rh->name;
 622   }
 623   rh->protocol = 0;
 624   rh->service = 0;
 625   ret = GNUNET_strndup (rp, len);
 626   /* If we have labels starting with underscore with label on
 627    * the right (SRV/DANE/BOX case), determine port/protocol;
 628    * The format of `rh->name` must be "_PORT._PROTOCOL".
 629    */
 630   if ( ('_' == rh->name[0]) &&
 631        (NULL != (dot = memrchr (rh->name,
 632                                 (int) '.',
 633                                 rh->name_resolution_pos))) &&
 634        ('_' == dot[1]) &&
 635        (NULL == memrchr (rh->name,
 636                          (int) '.',
 637                          dot - rh->name)) )
 638   {
 639     srv_name = GNUNET_strndup (&rh->name[1],
 640                                (dot - rh->name) - 1);
 641     proto_name = GNUNET_strndup (&dot[2],
 642                                  rh->name_resolution_pos - (dot - rh->name) - 1);
 643     rh->name_resolution_pos = 0;
 644     pe = getprotobyname (proto_name);
 645     if (NULL == pe)
 646     {
 647       GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
 648                   _("Protocol `%s' unknown, skipping labels.\n"),
 649                   proto_name);
 650       GNUNET_free (proto_name);
 651       GNUNET_free (srv_name);
 652       return ret;
 653     }
 654     se = getservbyname (srv_name,
 655                         proto_name);
 656     if (NULL == se)
 657     {
 658       GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
 659                   _("Service `%s' unknown for protocol `%s', skipping labels.\n"),
 660                   srv_name,
 661                   proto_name);
 662       GNUNET_free (proto_name);
 663       GNUNET_free (srv_name);
 664       return ret;
 665     }
 666     rh->protocol = pe->p_proto;
 667     rh->service = se->s_port;
 668   }
 669   return ret;
 670 }
 671
 672
 673 /**
 674  * Gives the cummulative result obtained to the callback and clean up the request.
 675  *
 676  * @param rh resolution process that has culminated in a result
 677  */
 678 static void
 679 transmit_lookup_dns_result (struct GNS_ResolverHandle *rh)
 680 {
 681   struct DnsResult *pos;
 682   unsigned int n;
 683   unsigned int i;
 684
 685   n = 0;
 686   for (pos = rh->dns_result_head; NULL != pos; pos = pos->next)
 687     n++;
 688   {
 689     struct GNUNET_GNSRECORD_Data rd[n];
 690
 691     i = 0;
 692     for (pos = rh->dns_result_head; NULL != pos; pos = pos->next)
 693     {
 694       rd[i].data = pos->data;
 695       rd[i].data_size = pos->data_size;
 696       rd[i].record_type = pos->record_type;
 697       if (0 == pos->expiration_time)
 698       {
 699         rd[i].flags = GNUNET_GNSRECORD_RF_RELATIVE_EXPIRATION;
 700         rd[i].expiration_time = 0;
 701       }
 702       else
 703       {
 704         rd[i].flags = GNUNET_GNSRECORD_RF_NONE;
 705         rd[i].expiration_time = pos->expiration_time;
 706       }
 707       i++;
 708     }
 709     GNUNET_assert (i == n);
 710     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
 711                 "Transmitting standard DNS result with %u records\n",
 712                 n);
 713     rh->proc (rh->proc_cls,
 714               n,
 715               rd);
 716   }
 717   GNS_resolver_lookup_cancel (rh);
 718 }
 719
 720
 721 /**
 722  * Add a result from DNS to the records to be returned to the application.
 723  *
 724  * @param rh resolution request to extend with a result
 725  * @param expiration_time expiration time for the answer
 726  * @param record_type DNS record type of the answer
 727  * @param data_size number of bytes in @a data
 728  * @param data binary data to return in DNS record
 729  */
 730 static void
 731 add_dns_result (struct GNS_ResolverHandle *rh,
 732                 uint64_t expiration_time,
 733                 uint32_t record_type,
 734                 size_t data_size,
 735                 const void *data)
 736 {
 737   struct DnsResult *res;
 738
 739   res = GNUNET_malloc (sizeof (struct DnsResult) + data_size);
 740   res->expiration_time = expiration_time;
 741   res->data_size = data_size;
 742   res->record_type = record_type;
 743   res->data = &res[1];
 744   memcpy (&res[1], data, data_size);
 745   GNUNET_CONTAINER_DLL_insert (rh->dns_result_head,
 746                                rh->dns_result_tail,
 747                                res);
 748 }
 749
 750
 751 /**
 752  * We had to do a DNS lookup.  Convert the result (if any) and return
 753  * it.
 754  *
 755  * @param cls closure with the `struct GNS_ResolverHandle`
 756  * @param addr one of the addresses of the host, NULL for the last address
 757  * @param addrlen length of the address
 758  */
 759 static void
 760 handle_dns_result (void *cls,
 761                    const struct sockaddr *addr,
 762                    socklen_t addrlen)
 763 {
 764   struct GNS_ResolverHandle *rh = cls;
 765   const struct sockaddr_in *sa4;
 766   const struct sockaddr_in6 *sa6;
 767
 768   if (NULL == addr)
 769   {
 770     rh->std_resolve = NULL;
 771     transmit_lookup_dns_result (rh);
 772     return;
 773   }
 774   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
 775               "Received %u bytes of DNS IP data\n",
 776               addrlen);
 777   switch (addr->sa_family)
 778   {
 779   case AF_INET:
 780     sa4 = (const struct sockaddr_in *) addr;
 781     add_dns_result (rh,
 782                     0 /* expiration time is unknown */,
 783                     GNUNET_DNSPARSER_TYPE_A,
 784                     sizeof (struct in_addr),
 785                     &sa4->sin_addr);
 786     break;
 787   case AF_INET6:
 788     sa6 = (const struct sockaddr_in6 *) addr;
 789     add_dns_result (rh,
 790                     0 /* expiration time is unknown */,
 791                     GNUNET_DNSPARSER_TYPE_AAAA,
 792                     sizeof (struct in6_addr),
 793                     &sa6->sin6_addr);
 794     break;
 795   default:
 796     GNUNET_break (0);
 797     break;
 798   }
 799 }
 800
 801
 802 /**
 803  * Task scheduled to continue with the resolution process.
 804  *
 805  * @param cls the 'struct GNS_ResolverHandle' of the resolution
 806  * @param tc task context
 807  */
 808 static void
 809 recursive_resolution (void *cls);
 810
 811
 812 /**
 813  * Begin the resolution process from 'name', starting with
 814  * the identification of the zone specified by 'name'.
 815  *
 816  * @param rh resolution to perform
 817  */
 818 static void
 819 start_resolver_lookup (struct GNS_ResolverHandle *rh);
 820
 821
 822 /**
 823  * Function called with the result of a DNS resolution.
 824  *
 825  * @param cls the request handle of the resolution that
 826  *        we were attempting to make
 827  * @param rs socket that received the response
 828  * @param dns dns response, never NULL
 829  * @param dns_len number of bytes in @a dns
 830  */
 831 static void
 832 dns_result_parser (void *cls,
 833                    struct GNUNET_DNSSTUB_RequestSocket *rs,
 834                    const struct GNUNET_TUN_DnsHeader *dns,
 835                    size_t dns_len)
 836 {
 837   struct GNS_ResolverHandle *rh = cls;
 838   struct GNUNET_DNSPARSER_Packet *p;
 839   const struct GNUNET_DNSPARSER_Record *rec;
 840   unsigned int rd_count;
 841   unsigned int i;
 842
 843   rh->dns_request = NULL;
 844   GNUNET_SCHEDULER_cancel (rh->task_id);
 845   rh->task_id = NULL;
 846   p = GNUNET_DNSPARSER_parse ((const char *) dns,
 847                               dns_len);
 848   if (NULL == p)
 849   {
 850     GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
 851                 _("Failed to parse DNS response\n"));
 852     rh->proc (rh->proc_cls, 0, NULL);
 853     GNS_resolver_lookup_cancel (rh);
 854     return;
 855   }
 856   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
 857               "Received DNS response for `%s' with %u answers\n",
 858               rh->ac_tail->label,
 859               (unsigned int) p->num_answers);
 860   if ( (p->num_answers > 0) &&
 861        (GNUNET_DNSPARSER_TYPE_CNAME == p->answers[0].type) &&
 862        (GNUNET_DNSPARSER_TYPE_CNAME != rh->record_type) )
 863     {
 864       GNUNET_free (rh->name);
 865       rh->name = GNUNET_strdup (p->answers[0].data.hostname);
 866       rh->name_resolution_pos = strlen (rh->name);
 867       start_resolver_lookup (rh);
 868       GNUNET_DNSPARSER_free_packet (p);
 869       return;
 870     }
 871
 872   /* convert from (parsed) DNS to (binary) GNS format! */
 873   rd_count = p->num_answers + p->num_authority_records + p->num_additional_records;
 874   {
 875     struct GNUNET_GNSRECORD_Data rd[rd_count];
 876     unsigned int skip;
 877     char buf[UINT16_MAX];
 878     size_t buf_off;
 879     size_t buf_start;
 880
 881     buf_off = 0;
 882     skip = 0;
 883     memset (rd, 0, sizeof (rd));
 884     for (i=0;i<rd_count;i++)
 885     {
 886       if (i < p->num_answers)
 887         rec = &p->answers[i];
 888       else if (i < p->num_answers + p->num_authority_records)
 889         rec = &p->authority_records[i - p->num_answers];
 890       else
 891         rec = &p->additional_records[i - p->num_answers - p->num_authority_records];
 892       /* As we copied the full DNS name to 'rh->ac_tail->label', this
 893          should be the correct check to see if this record is actually
 894          a record for our label... */
 895       if (0 != strcmp (rec->name,
 896                        rh->ac_tail->label))
 897       {
 898         GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
 899                     "Dropping record `%s', does not match desired name `%s'\n",
 900                     rec->name,
 901                     rh->ac_tail->label);
 902         skip++;
 903         continue;
 904       }
 905       rd[i - skip].record_type = rec->type;
 906       rd[i - skip].expiration_time = rec->expiration_time.abs_value_us;
 907       switch (rec->type)
 908       {
 909       case GNUNET_DNSPARSER_TYPE_A:
 910         if (rec->data.raw.data_len != sizeof (struct in_addr))
 911         {
 912           GNUNET_break_op (0);
 913           skip++;
 914           continue;
 915         }
 916         rd[i - skip].data_size = rec->data.raw.data_len;
 917         rd[i - skip].data = rec->data.raw.data;
 918         break;
 919       case GNUNET_DNSPARSER_TYPE_AAAA:
 920         if (rec->data.raw.data_len != sizeof (struct in6_addr))
 921         {
 922           GNUNET_break_op (0);
 923           skip++;
 924           continue;
 925         }
 926         rd[i - skip].data_size = rec->data.raw.data_len;
 927         rd[i - skip].data = rec->data.raw.data;
 928         break;
 929       case GNUNET_DNSPARSER_TYPE_CNAME:
 930       case GNUNET_DNSPARSER_TYPE_PTR:
 931       case GNUNET_DNSPARSER_TYPE_NS:
 932         buf_start = buf_off;
 933         if (GNUNET_OK !=
 934             GNUNET_DNSPARSER_builder_add_name (buf,
 935                                                sizeof (buf),
 936                                                &buf_off,
 937                                                rec->data.hostname))
 938         {
 939           GNUNET_break (0);
 940           skip++;
 941           continue;
 942         }
 943         rd[i - skip].data_size = buf_off - buf_start;
 944         rd[i - skip].data = &buf[buf_start];
 945         break;
 946       case GNUNET_DNSPARSER_TYPE_SOA:
 947         buf_start = buf_off;
 948         if (GNUNET_OK !=
 949             GNUNET_DNSPARSER_builder_add_soa (buf,
 950                                                sizeof (buf),
 951                                                &buf_off,
 952                                                rec->data.soa))
 953         {
 954           GNUNET_break (0);
 955           skip++;
 956           continue;
 957         }
 958         rd[i - skip].data_size = buf_off - buf_start;
 959         rd[i - skip].data = &buf[buf_start];
 960         break;
 961       case GNUNET_DNSPARSER_TYPE_MX:
 962         buf_start = buf_off;
 963         if (GNUNET_OK !=
 964             GNUNET_DNSPARSER_builder_add_mx (buf,
 965                                              sizeof (buf),
 966                                              &buf_off,
 967                                              rec->data.mx))
 968         {
 969           GNUNET_break (0);
 970           skip++;
 971           continue;
 972         }
 973         rd[i - skip].data_size = buf_off - buf_start;
 974         rd[i - skip].data = &buf[buf_start];
 975         break;
 976       case GNUNET_DNSPARSER_TYPE_SRV:
 977         buf_start = buf_off;
 978         if (GNUNET_OK !=
 979             GNUNET_DNSPARSER_builder_add_srv (buf,
 980                                               sizeof (buf),
 981                                               &buf_off,
 982                                               rec->data.srv))
 983         {
 984           GNUNET_break (0);
 985           skip++;
 986           continue;
 987         }
 988         rd[i - skip].data_size = buf_off - buf_start;
 989         rd[i - skip].data = &buf[buf_start];
 990         break;
 991       default:
 992         GNUNET_log (GNUNET_ERROR_TYPE_INFO,
 993                     _("Skipping record of unsupported type %d\n"),
 994                     rec->type);
 995         skip++;
 996         continue;
 997       }
 998     }
 999     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1000                 "Returning DNS response for `%s' with %u answers\n",
1001                 rh->ac_tail->label,
1002                 (unsigned int) p->num_answers);
1003     rh->proc (rh->proc_cls, rd_count - skip, rd);
1004     GNS_resolver_lookup_cancel (rh);
1005   }
1006   GNUNET_DNSPARSER_free_packet (p);
1007 }
1008
1009
1010 /**
1011  * Perform recursive DNS resolution.  Asks the given DNS resolver to
1012  * resolve "rh->dns_name", possibly recursively proceeding following
1013  * NS delegations, CNAMES, etc., until 'rh->loop_limiter' bounds us or
1014  * we find the answer.
1015  *
1016  * @param rh resolution information
1017  */
1018 static void
1019 recursive_dns_resolution (struct GNS_ResolverHandle *rh)
1020 {
1021   struct AuthorityChain *ac;
1022   socklen_t sa_len;
1023   struct GNUNET_DNSPARSER_Query *query;
1024   struct GNUNET_DNSPARSER_Packet *p;
1025   char *dns_request;
1026   size_t dns_request_length;
1027
1028   ac = rh->ac_tail;
1029   GNUNET_assert (NULL != ac);
1030   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1031               "Starting DNS lookup for `%s'\n",
1032               ac->label);
1033   GNUNET_assert (GNUNET_NO == ac->gns_authority);
1034   switch (((const struct sockaddr *) &ac->authority_info.dns_authority.dns_ip)->sa_family)
1035   {
1036   case AF_INET:
1037     sa_len = sizeof (struct sockaddr_in);
1038     break;
1039   case AF_INET6:
1040     sa_len = sizeof (struct sockaddr_in6);
1041     break;
1042   default:
1043     GNUNET_break (0);
1044     rh->proc (rh->proc_cls, 0, NULL);
1045     GNS_resolver_lookup_cancel (rh);
1046     return;
1047   }
1048   query = GNUNET_new (struct GNUNET_DNSPARSER_Query);
1049   query->name = GNUNET_strdup (ac->label);
1050   query->type = rh->record_type;
1051   query->dns_traffic_class = GNUNET_TUN_DNS_CLASS_INTERNET;
1052   p = GNUNET_new (struct GNUNET_DNSPARSER_Packet);
1053   p->queries = query;
1054   p->num_queries = 1;
1055   p->id = (uint16_t) GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_NONCE,
1056                                                UINT16_MAX);
1057   p->flags.opcode = GNUNET_TUN_DNS_OPCODE_QUERY;
1058   p->flags.recursion_desired = 1;
1059   if (GNUNET_OK !=
1060       GNUNET_DNSPARSER_pack (p, 1024, &dns_request, &dns_request_length))
1061   {
1062     GNUNET_break (0);
1063     rh->proc (rh->proc_cls, 0, NULL);
1064     GNS_resolver_lookup_cancel (rh);
1065   }
1066   else
1067   {
1068     rh->dns_request = GNUNET_DNSSTUB_resolve (dns_handle,
1069                                               (const struct sockaddr *) &ac->authority_info.dns_authority.dns_ip,
1070                                               sa_len,
1071                                               dns_request,
1072                                               dns_request_length,
1073                                               &dns_result_parser,
1074                                               rh);
1075     rh->task_id = GNUNET_SCHEDULER_add_delayed (DNS_LOOKUP_TIMEOUT,
1076                                                 &fail_resolution,
1077                                                 rh);
1078   }
1079   GNUNET_free (dns_request);
1080   GNUNET_DNSPARSER_free_packet (p);
1081 }
1082
1083
1084 /**
1085  * We encountered a CNAME record during our resolution.
1086  * Merge it into our chain.
1087  *
1088  * @param rh resolution we are performing
1089  * @param cname value of the cname record we got for the current
1090  *        authority chain tail
1091  */
1092 static void
1093 handle_gns_cname_result (struct GNS_ResolverHandle *rh,
1094                          const char *cname)
1095 {
1096   size_t nlen;
1097   char *res;
1098   struct AuthorityChain *ac;
1099
1100   nlen = strlen (cname);
1101   if ( (nlen > 2) &&
1102        (0 == strcmp (".+",
1103                      &cname[nlen - 2])) )
1104   {
1105     /* CNAME resolution continues relative to current domain */
1106     if (0 == rh->name_resolution_pos)
1107     {
1108       res = GNUNET_strndup (cname, nlen - 2);
1109       rh->name_resolution_pos = nlen - 2;
1110     }
1111     else
1112     {
1113       GNUNET_asprintf (&res,
1114                        "%.*s.%.*s",
1115                        (int) rh->name_resolution_pos,
1116                        rh->name,
1117                        (int) (nlen - 2),
1118                        cname);
1119       rh->name_resolution_pos = strlen (res);
1120     }
1121     GNUNET_free (rh->name);
1122     rh->name = res;
1123     ac = GNUNET_new (struct AuthorityChain);
1124     ac->rh = rh;
1125     ac->gns_authority = GNUNET_YES;
1126     ac->authority_info.gns_authority = rh->ac_tail->authority_info.gns_authority;
1127     ac->label = resolver_lookup_get_next_label (rh);
1128     ac->suggested_shortening_label = NULL;
1129     ac->shortening_started = GNUNET_NO;
1130     /* add AC to tail */
1131     GNUNET_CONTAINER_DLL_insert_tail (rh->ac_head,
1132                                       rh->ac_tail,
1133                                       ac);
1134     rh->task_id = GNUNET_SCHEDULER_add_now (&recursive_resolution,
1135                                             rh);
1136     return;
1137   }
1138   /* name is absolute, start from the beginning */
1139   GNUNET_free (rh->name);
1140   rh->name = GNUNET_strdup (cname);
1141   rh->name_resolution_pos = strlen (rh->name);
1142   start_resolver_lookup (rh);
1143 }
1144
1145
1146 /**
1147  * Process a records that were decrypted from a block.
1148  *
1149  * @param cls closure with the 'struct GNS_ResolverHandle'
1150  * @param rd_count number of entries in @a rd array
1151  * @param rd array of records with data to store
1152  */
1153 static void
1154 handle_gns_resolution_result (void *cls,
1155                               unsigned int rd_count,
1156                               const struct GNUNET_GNSRECORD_Data *rd);
1157
1158
1159 /**
1160  * Callback invoked from the VPN service once a redirection is
1161  * available.  Provides the IP address that can now be used to
1162  * reach the requested destination.  Replaces the "VPN" record
1163  * with the respective A/AAAA record and continues processing.
1164  *
1165  * @param cls closure
1166  * @param af address family, AF_INET or AF_INET6; AF_UNSPEC on error;
1167  *                will match 'result_af' from the request
1168  * @param address IP address (struct in_addr or struct in_addr6, depending on 'af')
1169  *                that the VPN allocated for the redirection;
1170  *                traffic to this IP will now be redirected to the
1171  *                specified target peer; NULL on error
1172  */
1173 static void
1174 vpn_allocation_cb (void *cls,
1175                    int af,
1176                    const void *address)
1177 {
1178   struct VpnContext *vpn_ctx = cls;
1179   struct GNS_ResolverHandle *rh = vpn_ctx->rh;
1180   struct GNUNET_GNSRECORD_Data rd[vpn_ctx->rd_count];
1181   unsigned int i;
1182
1183   vpn_ctx->vpn_request = NULL;
1184   rh->vpn_ctx = NULL;
1185   GNUNET_assert (GNUNET_OK ==
1186                  GNUNET_GNSRECORD_records_deserialize (vpn_ctx->rd_data_size,
1187                                                        vpn_ctx->rd_data,
1188                                                        vpn_ctx->rd_count,
1189                                                        rd));
1190   for (i=0;i<vpn_ctx->rd_count;i++)
1191   {
1192     if (GNUNET_GNSRECORD_TYPE_VPN == rd[i].record_type)
1193     {
1194       switch (af)
1195       {
1196       case AF_INET:
1197         rd[i].record_type = GNUNET_DNSPARSER_TYPE_A;
1198         rd[i].data_size = sizeof (struct in_addr);
1199         rd[i].expiration_time = GNUNET_TIME_relative_to_absolute (VPN_TIMEOUT).abs_value_us;
1200         rd[i].flags = 0;
1201         rd[i].data = address;
1202         break;
1203       case AF_INET6:
1204         rd[i].record_type = GNUNET_DNSPARSER_TYPE_AAAA;
1205         rd[i].expiration_time = GNUNET_TIME_relative_to_absolute (VPN_TIMEOUT).abs_value_us;
1206         rd[i].flags = 0;
1207         rd[i].data = address;
1208         rd[i].data_size = sizeof (struct in6_addr);
1209         break;
1210       default:
1211         GNUNET_assert (0);
1212       }
1213       break;
1214     }
1215   }
1216   GNUNET_assert (i < vpn_ctx->rd_count);
1217   handle_gns_resolution_result (rh,
1218                                 vpn_ctx->rd_count,
1219                                 rd);
1220   GNUNET_free (vpn_ctx->rd_data);
1221   GNUNET_free (vpn_ctx);
1222 }
1223
1224
1225 /**
1226  * We've resolved the IP address for the DNS resolver to use
1227  * after encountering a GNS2DNS record.
1228  *
1229  * TODO: Right now we only foward the request to ONE DNS resolver,
1230  * even if we get multiple IP addresses back; a correct implementation
1231  * should try all DNS resolvers.
1232  *
1233  * @param cls the `struct GNS_ResolverHandle` where we encountered
1234  *            the GNS2DNS record
1235  * @param rd_count number of records in @a rd
1236  * @param rd addresses for the DNS resolver  (presumably)
1237  */
1238 static void
1239 handle_gns2dns_result (void *cls,
1240                        unsigned int rd_count,
1241                        const struct GNUNET_GNSRECORD_Data *rd)
1242 {
1243   struct GNS_ResolverHandle *rh = cls;
1244   struct AuthorityChain *ac;
1245   unsigned int j;
1246   struct sockaddr *sa;
1247   struct sockaddr_in v4;
1248   struct sockaddr_in6 v6;
1249   size_t sa_len;
1250
1251   /* find suitable A/AAAA record */
1252   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1253               "Received %u results for IP address of DNS server for GNS2DNS transition\n",
1254               rd_count);
1255   /* enable cleanup of 'rh' handle that comes next... */
1256   GNUNET_CONTAINER_DLL_insert (rlh_head,
1257                                rlh_tail,
1258                                rh->g2dc->rh);
1259   rh->g2dc->rh = NULL;
1260   sa = NULL;
1261   sa_len = 0;
1262   for (j=0;j<rd_count;j++)
1263   {
1264     switch (rd[j].record_type)
1265     {
1266     case GNUNET_DNSPARSER_TYPE_A:
1267       if (sizeof (struct in_addr) != rd[j].data_size)
1268       {
1269         GNUNET_break_op (0);
1270         rh->proc (rh->proc_cls, 0, NULL);
1271         GNS_resolver_lookup_cancel (rh);
1272         return;
1273       }
1274       /* FIXME: might want to check if we support IPv4 here,
1275          and otherwise skip this one and hope we find another */
1276       memset (&v4, 0, sizeof (v4));
1277       sa_len = sizeof (v4);
1278       v4.sin_family = AF_INET;
1279       v4.sin_port = htons (53);
1280 #if HAVE_SOCKADDR_IN_SIN_LEN
1281       v4.sin_len = (u_char) sa_len;
1282 #endif
1283       memcpy (&v4.sin_addr,
1284               rd[j].data,
1285               sizeof (struct in_addr));
1286       sa = (struct sockaddr *) &v4;
1287       break;
1288     case GNUNET_DNSPARSER_TYPE_AAAA:
1289       if (sizeof (struct in6_addr) != rd[j].data_size)
1290       {
1291         GNUNET_break_op (0);
1292         rh->proc (rh->proc_cls, 0, NULL);
1293         GNS_resolver_lookup_cancel (rh);
1294         return;
1295       }
1296       /* FIXME: might want to check if we support IPv6 here,
1297          and otherwise skip this one and hope we find another */
1298       memset (&v6, 0, sizeof (v6));
1299       sa_len = sizeof (v6);
1300       v6.sin6_family = AF_INET6;
1301       v6.sin6_port = htons (53);
1302 #if HAVE_SOCKADDR_IN_SIN_LEN
1303       v6.sin6_len = (u_char) sa_len;
1304 #endif
1305       memcpy (&v6.sin6_addr,
1306               rd[j].data,
1307               sizeof (struct in6_addr));
1308       sa = (struct sockaddr *) &v6;
1309       break;
1310     default:
1311       break;
1312     }
1313     if (NULL != sa)
1314       break;
1315   }
1316   if (NULL == sa)
1317   {
1318     /* we cannot continue; NS without A/AAAA */
1319     rh->proc (rh->proc_cls, 0, NULL);
1320     GNS_resolver_lookup_cancel (rh);
1321     return;
1322   }
1323   /* expand authority chain */
1324   ac = GNUNET_new (struct AuthorityChain);
1325   ac->rh = rh;
1326   strcpy (ac->authority_info.dns_authority.name,
1327           rh->g2dc->ns);
1328   memcpy (&ac->authority_info.dns_authority.dns_ip,
1329           sa,
1330           sa_len);
1331   /* for DNS recursion, the label is the full DNS name,
1332      created from the remainder of the GNS name and the
1333      name in the NS record */
1334   GNUNET_asprintf (&ac->label,
1335                    "%.*s%s%s",
1336                    (int) rh->name_resolution_pos,
1337                    rh->name,
1338                    (0 != rh->name_resolution_pos) ? "." : "",
1339                    rh->g2dc->ns);
1340   GNUNET_free (rh->g2dc->ns);
1341   GNUNET_free (rh->g2dc);
1342   rh->g2dc = NULL;
1343   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1344               "Will continue resolution using DNS server `%s' to resolve `%s'\n",
1345               GNUNET_a2s (sa, sa_len),
1346               ac->label);
1347   GNUNET_CONTAINER_DLL_insert_tail (rh->ac_head,
1348                                     rh->ac_tail,
1349                                     ac);
1350   if (strlen (ac->label) > GNUNET_DNSPARSER_MAX_NAME_LENGTH)
1351   {
1352     GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
1353                 _("GNS lookup resulted in DNS name that is too long (`%s')\n"),
1354                 ac->label);
1355     rh->proc (rh->proc_cls, 0, NULL);
1356     GNS_resolver_lookup_cancel (rh);
1357     return;
1358   }
1359   /* recurse */
1360   rh->task_id = GNUNET_SCHEDULER_add_now (&recursive_resolution,
1361                                           rh);
1362 }
1363
1364
1365 /**
1366  * Process a records that were decrypted from a block.
1367  *
1368  * @param cls closure with the `struct GNS_ResolverHandle`
1369  * @param rd_count number of entries in @a rd array
1370  * @param rd array of records with data to store
1371  */
1372 static void
1373 handle_gns_resolution_result (void *cls,
1374                               unsigned int rd_count,
1375                               const struct GNUNET_GNSRECORD_Data *rd)
1376 {
1377   struct GNS_ResolverHandle *rh = cls;
1378   struct AuthorityChain *ac;
1379   struct AuthorityChain *shorten_ac;
1380   unsigned int i;
1381   char *cname;
1382   struct VpnContext *vpn_ctx;
1383   const struct GNUNET_TUN_GnsVpnRecord *vpn;
1384   const char *vname;
1385   struct GNUNET_HashCode vhash;
1386   int af;
1387   char scratch[UINT16_MAX];
1388   size_t scratch_off;
1389   size_t scratch_start;
1390   size_t off;
1391   struct GNUNET_GNSRECORD_Data rd_new[rd_count];
1392   unsigned int rd_off;
1393
1394   GNUNET_log (GNUNET_ERROR_TYPE_INFO,
1395               "Resolution succeeded for `%s' in zone %s, got %u records\n",
1396               rh->ac_tail->label,
1397               GNUNET_GNSRECORD_z2s (&rh->ac_tail->authority_info.gns_authority),
1398               rd_count);
1399   if (0 == rh->name_resolution_pos)
1400   {
1401     /* top-level match, are we done yet? */
1402     if ( (rd_count > 0) &&
1403          (GNUNET_DNSPARSER_TYPE_CNAME == rd[0].record_type) &&
1404          (GNUNET_DNSPARSER_TYPE_CNAME != rh->record_type) )
1405     {
1406       off = 0;
1407       cname = GNUNET_DNSPARSER_parse_name (rd[0].data,
1408                                            rd[0].data_size,
1409                                            &off);
1410       if ( (NULL == cname) ||
1411            (off != rd[0].data_size) )
1412       {
1413         GNUNET_break_op (0);
1414         rh->proc (rh->proc_cls, 0, NULL);
1415         GNS_resolver_lookup_cancel (rh);
1416         GNUNET_free_non_null (cname);
1417         return;
1418       }
1419       handle_gns_cname_result (rh,
1420                                cname);
1421       GNUNET_free (cname);
1422       return;
1423     }
1424     /* If A/AAAA was requested, but we got a VPN
1425        record, we convert it to A/AAAA using GNUnet VPN */
1426     if ( (GNUNET_DNSPARSER_TYPE_A == rh->record_type) ||
1427          (GNUNET_DNSPARSER_TYPE_AAAA == rh->record_type) )
1428     {
1429       for (i=0;i<rd_count;i++)
1430       {
1431         switch (rd[i].record_type)
1432         {
1433         case GNUNET_GNSRECORD_TYPE_VPN:
1434           {
1435             af = (GNUNET_DNSPARSER_TYPE_A == rh->record_type) ? AF_INET : AF_INET6;
1436             if (sizeof (struct GNUNET_TUN_GnsVpnRecord) >
1437                 rd[i].data_size)
1438             {
1439               GNUNET_break_op (0);
1440               rh->proc (rh->proc_cls, 0, NULL);
1441               GNS_resolver_lookup_cancel (rh);
1442               return;
1443             }
1444             vpn = (const struct GNUNET_TUN_GnsVpnRecord *) rd[i].data;
1445             vname = (const char *) &vpn[1];
1446             if ('\0' != vname[rd[i].data_size - 1 - sizeof (struct GNUNET_TUN_GnsVpnRecord)])
1447             {
1448               GNUNET_break_op (0);
1449               rh->proc (rh->proc_cls, 0, NULL);
1450               GNS_resolver_lookup_cancel (rh);
1451               return;
1452             }
1453             GNUNET_TUN_service_name_to_hash (vname,
1454                                              &vhash);
1455             GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1456                         "Attempting VPN allocation for %s-%s (AF: %d, proto %d)\n",
1457                         GNUNET_i2s (&vpn->peer),
1458                         vname,
1459                         (int) af,
1460                         (int) ntohs (vpn->proto));
1461             vpn_ctx = GNUNET_new (struct VpnContext);
1462             rh->vpn_ctx = vpn_ctx;
1463             vpn_ctx->rh = rh;
1464             vpn_ctx->rd_data_size = GNUNET_GNSRECORD_records_get_size (rd_count,
1465                                                                        rd);
1466             vpn_ctx->rd_data = GNUNET_malloc (vpn_ctx->rd_data_size);
1467             vpn_ctx->rd_count = rd_count;
1468             GNUNET_assert (vpn_ctx->rd_data_size ==
1469                            GNUNET_GNSRECORD_records_serialize (rd_count,
1470                                                                rd,
1471                                                                vpn_ctx->rd_data_size,
1472                                                                vpn_ctx->rd_data));
1473             vpn_ctx->vpn_request = GNUNET_VPN_redirect_to_peer (vpn_handle,
1474                                                                 af,
1475                                                                 ntohs (vpn->proto),
1476                                                                 &vpn->peer,
1477                                                                 &vhash,
1478                                                                 GNUNET_TIME_relative_to_absolute (VPN_TIMEOUT),
1479                                                                 &vpn_allocation_cb,
1480                                                                 vpn_ctx);
1481             return;
1482           }
1483         case GNUNET_GNSRECORD_TYPE_GNS2DNS:
1484           {
1485             /* delegation to DNS */
1486             GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1487                         "Found GNS2DNS record, delegating to DNS!\n");
1488             goto do_recurse;
1489           }
1490         default:
1491           break;
1492         } /* end: switch */
1493       } /* end: for rd */
1494     } /* end: name_resolution_pos */
1495     /* convert relative names in record values to absolute names,
1496        using 'scratch' array for memory allocations */
1497     scratch_off = 0;
1498     rd_off = 0;
1499     shorten_ac = rh->ac_tail;
1500     for (i=0;i<rd_count;i++)
1501     {
1502       if ( (0 != rh->protocol) &&
1503            (0 != rh->service) &&
1504            (GNUNET_GNSRECORD_TYPE_BOX != rd[i].record_type) )
1505         continue; /* we _only_ care about boxed records */
1506
1507       rd_new[rd_off] = rd[i];
1508       /* Check if the embedded name(s) end in "+", and if so,
1509          replace the "+" with the zone at "ac_tail", changing the name
1510          to a ".zkey".  The name is allocated on the 'scratch' array,
1511          so we can free it afterwards. */
1512       switch (rd[i].record_type)
1513       {
1514       case GNUNET_DNSPARSER_TYPE_CNAME:
1515         {
1516           char *cname;
1517
1518           off = 0;
1519           cname = GNUNET_DNSPARSER_parse_name (rd[i].data,
1520                                                rd[i].data_size,
1521                                                &off);
1522           if ( (NULL == cname) ||
1523                (off != rd[i].data_size) )
1524           {
1525             GNUNET_break_op (0); /* record not well-formed */
1526           }
1527           else
1528           {
1529             cname = translate_dot_plus (rh, cname);
1530             GNUNET_break (NULL != cname);
1531             scratch_start = scratch_off;
1532             if (GNUNET_OK !=
1533                 GNUNET_DNSPARSER_builder_add_name (scratch,
1534                                                    sizeof (scratch),
1535                                                    &scratch_off,
1536                                                    cname))
1537             {
1538               GNUNET_break (0);
1539             }
1540             else
1541             {
1542               rd_new[rd_off].data = &scratch[scratch_start];
1543               rd_new[rd_off].data_size = scratch_off - scratch_start;
1544               rd_off++;
1545             }
1546           }
1547           GNUNET_free_non_null (cname);
1548         }
1549         break;
1550       case GNUNET_DNSPARSER_TYPE_SOA:
1551         {
1552           struct GNUNET_DNSPARSER_SoaRecord *soa;
1553
1554           off = 0;
1555           soa = GNUNET_DNSPARSER_parse_soa (rd[i].data,
1556                                             rd[i].data_size,
1557                                             &off);
1558           if ( (NULL == soa) ||
1559                (off != rd[i].data_size) )
1560           {
1561             GNUNET_break_op (0); /* record not well-formed */
1562           }
1563           else
1564           {
1565             soa->mname = translate_dot_plus (rh, soa->mname);
1566             soa->rname = translate_dot_plus (rh, soa->rname);
1567             scratch_start = scratch_off;
1568             if (GNUNET_OK !=
1569                 GNUNET_DNSPARSER_builder_add_soa (scratch,
1570                                                   sizeof (scratch),
1571                                                   &scratch_off,
1572                                                   soa))
1573             {
1574               GNUNET_break (0);
1575             }
1576             else
1577             {
1578               rd_new[rd_off].data = &scratch[scratch_start];
1579               rd_new[rd_off].data_size = scratch_off - scratch_start;
1580               rd_off++;
1581             }
1582           }
1583           if (NULL != soa)
1584             GNUNET_DNSPARSER_free_soa (soa);
1585         }
1586         break;
1587       case GNUNET_DNSPARSER_TYPE_MX:
1588         {
1589           struct GNUNET_DNSPARSER_MxRecord *mx;
1590
1591           off = 0;
1592           mx = GNUNET_DNSPARSER_parse_mx (rd[i].data,
1593                                           rd[i].data_size,
1594                                           &off);
1595           if ( (NULL == mx) ||
1596                (off != rd[i].data_size) )
1597           {
1598             GNUNET_break_op (0); /* record not well-formed */
1599           }
1600           else
1601           {
1602             mx->mxhost = translate_dot_plus (rh, mx->mxhost);
1603             scratch_start = scratch_off;
1604             if (GNUNET_OK !=
1605                 GNUNET_DNSPARSER_builder_add_mx (scratch,
1606                                                  sizeof (scratch),
1607                                                  &scratch_off,
1608                                                  mx))
1609             {
1610               GNUNET_break (0);
1611             }
1612             else
1613             {
1614               rd_new[rd_off].data = &scratch[scratch_start];
1615               rd_new[rd_off].data_size = scratch_off - scratch_start;
1616               rd_off++;
1617             }
1618           }
1619           if (NULL != mx)
1620             GNUNET_DNSPARSER_free_mx (mx);
1621         }
1622         break;
1623       case GNUNET_DNSPARSER_TYPE_SRV:
1624         {
1625           struct GNUNET_DNSPARSER_SrvRecord *srv;
1626
1627           off = 0;
1628           srv = GNUNET_DNSPARSER_parse_srv (rd[i].data,
1629                                             rd[i].data_size,
1630                                             &off);
1631           if ( (NULL == srv) ||
1632                (off != rd[i].data_size) )
1633           {
1634             GNUNET_break_op (0); /* record not well-formed */
1635           }
1636           else
1637           {
1638             srv->target = translate_dot_plus (rh, srv->target);
1639             scratch_start = scratch_off;
1640             if (GNUNET_OK !=
1641                 GNUNET_DNSPARSER_builder_add_srv (scratch,
1642                                                   sizeof (scratch),
1643                                                   &scratch_off,
1644                                                   srv))
1645             {
1646               GNUNET_break (0);
1647             }
1648             else
1649             {
1650               rd_new[rd_off].data = &scratch[scratch_start];
1651               rd_new[rd_off].data_size = scratch_off - scratch_start;
1652               rd_off++;
1653             }
1654           }
1655           if (NULL != srv)
1656             GNUNET_DNSPARSER_free_srv (srv);
1657         }
1658         break;
1659
1660       case GNUNET_GNSRECORD_TYPE_NICK:
1661         {
1662           const char *nick;
1663
1664           nick = rd[i].data;
1665           if ((rd[i].data_size > 0) &&
1666               (nick[rd[i].data_size -1] != '\0'))
1667           {
1668             GNUNET_break_op (0);
1669             break;
1670           }
1671           if (NULL == shorten_ac->suggested_shortening_label)
1672             shorten_ac->suggested_shortening_label = GNUNET_strdup (nick);
1673           break;
1674         }
1675       case GNUNET_GNSRECORD_TYPE_PKEY:
1676         {
1677           struct GNUNET_CRYPTO_EcdsaPublicKey pub;
1678
1679           if (rd[i].data_size != sizeof (struct GNUNET_CRYPTO_EcdsaPublicKey))
1680           {
1681             GNUNET_break_op (0);
1682             break;
1683           }
1684           memcpy (&pub, rd[i].data, rd[i].data_size);
1685           rd_off++;
1686           if (GNUNET_GNSRECORD_TYPE_PKEY != rh->record_type)
1687           {
1688             /* try to resolve "+" */
1689             struct AuthorityChain *ac;
1690
1691             ac = GNUNET_new (struct AuthorityChain);
1692             ac->rh = rh;
1693             ac->gns_authority = GNUNET_YES;
1694             ac->authority_info.gns_authority = pub;
1695             ac->label = GNUNET_strdup (GNUNET_GNS_MASTERZONE_STR);
1696             ac->suggested_shortening_label = NULL;
1697             ac->shortening_started = GNUNET_NO;
1698             GNUNET_CONTAINER_DLL_insert_tail (rh->ac_head,
1699                                               rh->ac_tail,
1700                                               ac);
1701             rh->task_id = GNUNET_SCHEDULER_add_now (&recursive_resolution,
1702                                                     rh);
1703             return;
1704           }
1705         }
1706         break;
1707       case GNUNET_GNSRECORD_TYPE_GNS2DNS:
1708         {
1709           /* delegation to DNS */
1710           if (GNUNET_GNSRECORD_TYPE_GNS2DNS == rh->record_type)
1711           {
1712             rd_off++;
1713             break; /* do not follow to DNS, we wanted the GNS2DNS record! */
1714           }
1715           GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1716                       "Found GNS2DNS record, delegating to DNS!\n");
1717           goto do_recurse;
1718         }
1719       case GNUNET_GNSRECORD_TYPE_BOX:
1720         {
1721           /* unbox SRV/TLSA records if a specific one was requested */
1722           if ( (0 != rh->protocol) &&
1723                (0 != rh->service) &&
1724                (rd[i].data_size >= sizeof (struct GNUNET_GNSRECORD_BoxRecord)) )
1725           {
1726             const struct GNUNET_GNSRECORD_BoxRecord *box;
1727
1728             box = rd[i].data;
1729             if ( (ntohs (box->protocol) == rh->protocol) &&
1730                  (ntohs (box->service) == rh->service) )
1731             {
1732               /* Box matches, unbox! */
1733               rd_new[rd_off].record_type = ntohl (box->record_type);
1734               rd_new[rd_off].data_size -= sizeof (struct GNUNET_GNSRECORD_BoxRecord);
1735               rd_new[rd_off].data = &box[1];
1736               rd_off++;
1737             }
1738           }
1739           else
1740           {
1741             /* no specific protocol/service specified, preserve all BOX
1742                records (for modern, GNS-enabled applications) */
1743             rd_off++;
1744           }
1745         }
1746       default:
1747         rd_off++;
1748         break;
1749       } /* end: switch */
1750     } /* end: for rd_count */
1751
1752     /* trigger shortening */
1753     if ((NULL != rh->shorten_key) &&
1754         (NULL != shorten_ac) &&
1755         (GNUNET_NO == shorten_ac->shortening_started) &&
1756         (NULL != shorten_ac->suggested_shortening_label))
1757     {
1758         GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1759                     "Start shortening for label `%s' based on nick `%s'\n",
1760                     shorten_ac->label,
1761                     shorten_ac->suggested_shortening_label);
1762         shorten_ac->shortening_started = GNUNET_YES;
1763         GNS_shorten_start (shorten_ac->label,
1764                          shorten_ac->suggested_shortening_label,
1765                          &shorten_ac->authority_info.gns_authority,
1766                          rh->shorten_key);
1767     }
1768
1769     /* yes, we are done, return result */
1770     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1771                 "Returning GNS response for `%s' with %u answers\n",
1772                 rh->ac_tail->label,
1773                 rd_off);
1774     rh->proc (rh->proc_cls, rd_off, rd_new);
1775     GNS_resolver_lookup_cancel (rh);
1776     return;
1777   }
1778  do_recurse:
1779   /* need to recurse, check if we can */
1780   for (i=0;i<rd_count;i++)
1781   {
1782     switch (rd[i].record_type)
1783     {
1784     case GNUNET_GNSRECORD_TYPE_PKEY:
1785       /* delegation to another zone */
1786       if (sizeof (struct GNUNET_CRYPTO_EcdsaPublicKey) !=
1787           rd[i].data_size)
1788       {
1789         GNUNET_break_op (0);
1790         rh->proc (rh->proc_cls, 0, NULL);
1791         GNS_resolver_lookup_cancel (rh);
1792         return;
1793       }
1794       /* expand authority chain */
1795       ac = GNUNET_new (struct AuthorityChain);
1796       ac->rh = rh;
1797       ac->gns_authority = GNUNET_YES;
1798       ac->suggested_shortening_label = NULL;
1799       ac->shortening_started = GNUNET_NO;
1800       memcpy (&ac->authority_info.gns_authority,
1801               rd[i].data,
1802               sizeof (struct GNUNET_CRYPTO_EcdsaPublicKey));
1803       ac->label = resolver_lookup_get_next_label (rh);
1804       /* add AC to tail */
1805       GNUNET_CONTAINER_DLL_insert_tail (rh->ac_head,
1806                                         rh->ac_tail,
1807                                         ac);
1808       /* recurse */
1809       rh->task_id = GNUNET_SCHEDULER_add_now (&recursive_resolution,
1810                                               rh);
1811       return;
1812     case GNUNET_GNSRECORD_TYPE_GNS2DNS:
1813       {
1814         /* resolution continues within DNS */
1815         struct Gns2DnsContext *g2dc;
1816         char *ip;
1817         char *ns;
1818
1819         off = 0;
1820         ns = GNUNET_DNSPARSER_parse_name (rd[i].data,
1821                                           rd[i].data_size,
1822                                           &off);
1823         ip = GNUNET_DNSPARSER_parse_name (rd[i].data,
1824                                           rd[i].data_size,
1825                                           &off);
1826         if ( (NULL == ns) ||
1827              (NULL == ip) ||
1828              (off != rd[i].data_size) )
1829         {
1830           GNUNET_break_op (0);
1831           GNUNET_free_non_null (ns);
1832           GNUNET_free_non_null (ip);
1833           rh->proc (rh->proc_cls, 0, NULL);
1834           GNS_resolver_lookup_cancel (rh);
1835           return;
1836         }
1837         GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1838                     "Resolving `%s' to determine IP address of DNS server for GNS2DNS transition\n",
1839                     ip);
1840         /* resolve 'ip' to determine the IP(s) of the DNS
1841            resolver to use */
1842         g2dc = GNUNET_new (struct Gns2DnsContext);
1843         g2dc->ns = ns;
1844
1845         g2dc->rh = GNUNET_new (struct GNS_ResolverHandle);
1846         g2dc->rh->authority_zone = rh->ac_tail->authority_info.gns_authority;
1847         ip = translate_dot_plus (rh, ip);
1848         g2dc->rh->name = ip;
1849         g2dc->rh->name_resolution_pos = strlen (ip);
1850         g2dc->rh->proc = &handle_gns2dns_result;
1851         g2dc->rh->proc_cls = rh;
1852         g2dc->rh->record_type = GNUNET_GNSRECORD_TYPE_ANY;
1853         g2dc->rh->options = GNUNET_GNS_LO_DEFAULT;
1854         g2dc->rh->loop_limiter = rh->loop_limiter + 1;
1855         rh->g2dc = g2dc;
1856         start_resolver_lookup (g2dc->rh);
1857         return;
1858       }
1859     case GNUNET_DNSPARSER_TYPE_CNAME:
1860       {
1861         char *cname;
1862
1863         off = 0;
1864         cname = GNUNET_DNSPARSER_parse_name (rd[i].data,
1865                                              rd[i].data_size,
1866                                              &off);
1867         if ( (NULL == cname) ||
1868              (off != rd[i].data_size) )
1869         {
1870           GNUNET_break_op (0); /* record not well-formed */
1871           rh->proc (rh->proc_cls, 0, NULL);
1872           GNS_resolver_lookup_cancel (rh);
1873           GNUNET_free_non_null (cname);
1874           return;
1875         }
1876         handle_gns_cname_result (rh,
1877                                  cname);
1878         GNUNET_free (cname);
1879         return;
1880       }
1881       /* FIXME: handle DNAME */
1882     default:
1883       /* skip */
1884       break;
1885     }
1886   }
1887   GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
1888               _("GNS lookup recursion failed (no delegation record found)\n"));
1889   rh->proc (rh->proc_cls, 0, NULL);
1890   GNS_resolver_lookup_cancel (rh);
1891 }
1892
1893
1894 /**
1895  * Function called once the namestore has completed the request for
1896  * caching a block.
1897  *
1898  * @param cls closure with the `struct CacheOps`
1899  * @param success #GNUNET_OK on success
1900  * @param emsg error message
1901  */
1902 static void
1903 namecache_cache_continuation (void *cls,
1904                               int32_t success,
1905                               const char *emsg)
1906 {
1907   struct CacheOps *co = cls;
1908
1909   co->namecache_qe_cache = NULL;
1910   if (NULL != emsg)
1911     GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
1912                 _("Failed to cache GNS resolution: %s\n"),
1913                 emsg);
1914   GNUNET_CONTAINER_DLL_remove (co_head,
1915                                co_tail,
1916                                co);
1917   GNUNET_free (co);
1918 }
1919
1920
1921 /**
1922  * Iterator called on each result obtained for a DHT
1923  * operation that expects a reply
1924  *
1925  * @param cls closure with the `struct GNS_ResolverHandle`
1926  * @param exp when will this value expire
1927  * @param key key of the result
1928  * @param get_path peers on reply path (or NULL if not recorded)
1929  *                 [0] = datastore's first neighbor, [length - 1] = local peer
1930  * @param get_path_length number of entries in @a get_path
1931  * @param put_path peers on the PUT path (or NULL if not recorded)
1932  *                 [0] = origin, [length - 1] = datastore
1933  * @param put_path_length number of entries in @a put_path
1934  * @param type type of the result
1935  * @param size number of bytes in data
1936  * @param data pointer to the result data
1937  */
1938 static void
1939 handle_dht_response (void *cls,
1940                      struct GNUNET_TIME_Absolute exp,
1941                      const struct GNUNET_HashCode *key,
1942                      const struct GNUNET_PeerIdentity *get_path,
1943                      unsigned int get_path_length,
1944                      const struct GNUNET_PeerIdentity *put_path,
1945                      unsigned int put_path_length,
1946                      enum GNUNET_BLOCK_Type type,
1947                      size_t size, const void *data)
1948 {
1949   struct GNS_ResolverHandle *rh = cls;
1950   struct AuthorityChain *ac = rh->ac_tail;
1951   const struct GNUNET_GNSRECORD_Block *block;
1952   struct CacheOps *co;
1953
1954   GNUNET_DHT_get_stop (rh->get_handle);
1955   rh->get_handle = NULL;
1956   GNUNET_CONTAINER_heap_remove_node (rh->dht_heap_node);
1957   rh->dht_heap_node = NULL;
1958   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1959               "Handling response from the DHT\n");
1960   if (size < sizeof (struct GNUNET_GNSRECORD_Block))
1961   {
1962     /* how did this pass DHT block validation!? */
1963     GNUNET_break (0);
1964     rh->proc (rh->proc_cls, 0, NULL);
1965     GNS_resolver_lookup_cancel (rh);
1966     return;
1967   }
1968   block = data;
1969   if (size !=
1970       ntohl (block->purpose.size) +
1971       sizeof (struct GNUNET_CRYPTO_EcdsaPublicKey) +
1972       sizeof (struct GNUNET_CRYPTO_EcdsaSignature))
1973   {
1974     /* how did this pass DHT block validation!? */
1975     GNUNET_break (0);
1976     rh->proc (rh->proc_cls, 0, NULL);
1977     GNS_resolver_lookup_cancel (rh);
1978     return;
1979   }
1980   if (GNUNET_OK !=
1981       GNUNET_GNSRECORD_block_decrypt (block,
1982                                       &ac->authority_info.gns_authority,
1983                                       ac->label,
1984                                       &handle_gns_resolution_result,
1985                                       rh))
1986   {
1987     GNUNET_break_op (0); /* block was ill-formed */
1988     rh->proc (rh->proc_cls, 0, NULL);
1989     GNS_resolver_lookup_cancel (rh);
1990     return;
1991   }
1992   if (0 == GNUNET_TIME_absolute_get_remaining (GNUNET_TIME_absolute_ntoh (block->expiration_time)).rel_value_us)
1993   {
1994     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
1995                 "Received expired block from the DHT, will not cache it.\n");
1996     return;
1997   }
1998   /* Cache well-formed blocks */
1999   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
2000               "Caching response from the DHT in namecache\n");
2001   co = GNUNET_new (struct CacheOps);
2002   co->namecache_qe_cache = GNUNET_NAMECACHE_block_cache (namecache_handle,
2003                                                          block,
2004                                                          &namecache_cache_continuation,
2005                                                          co);
2006   GNUNET_CONTAINER_DLL_insert (co_head,
2007                                co_tail,
2008                                co);
2009 }
2010
2011
2012 /**
2013  * Initiate a DHT query for a set of GNS records.
2014  *
2015  * @param rh resolution handle
2016  * @param query key to use in the DHT lookup
2017  */
2018 static void
2019 start_dht_request (struct GNS_ResolverHandle *rh,
2020                    const struct GNUNET_HashCode *query)
2021 {
2022   struct GNS_ResolverHandle *rx;
2023
2024   GNUNET_assert (NULL == rh->get_handle);
2025   rh->get_handle = GNUNET_DHT_get_start (dht_handle,
2026                                          GNUNET_BLOCK_TYPE_GNS_NAMERECORD,
2027                                          query,
2028                                          DHT_GNS_REPLICATION_LEVEL,
2029                                          GNUNET_DHT_RO_DEMULTIPLEX_EVERYWHERE,
2030                                          NULL, 0,
2031                                          &handle_dht_response, rh);
2032   rh->dht_heap_node = GNUNET_CONTAINER_heap_insert (dht_lookup_heap,
2033                                                     rh,
2034                                                     GNUNET_TIME_absolute_get ().abs_value_us);
2035   if (GNUNET_CONTAINER_heap_get_size (dht_lookup_heap) > max_allowed_background_queries)
2036   {
2037     /* fail longest-standing DHT request */
2038     rx = GNUNET_CONTAINER_heap_peek (dht_lookup_heap);
2039     GNUNET_assert (NULL != rx);
2040     rx->proc (rx->proc_cls, 0, NULL);
2041     GNS_resolver_lookup_cancel (rx);
2042   }
2043 }
2044
2045
2046 /**
2047  * Process a records that were decrypted from a block that we got from
2048  * the namecache.  Simply calls #handle_gns_resolution_result().
2049  *
2050  * @param cls closure with the `struct GNS_ResolverHandle`
2051  * @param rd_count number of entries in @a rd array
2052  * @param rd array of records with data to store
2053  */
2054 static void
2055 handle_gns_namecache_resolution_result (void *cls,
2056                                         unsigned int rd_count,
2057                                         const struct GNUNET_GNSRECORD_Data *rd)
2058 {
2059   struct GNS_ResolverHandle *rh = cls;
2060
2061   handle_gns_resolution_result (rh,
2062                                 rd_count,
2063                                 rd);
2064 }
2065
2066
2067 /**
2068  * Process a record that was stored in the namecache.
2069  *
2070  * @param cls closure with the `struct GNS_ResolverHandle`
2071  * @param block block that was stored in the namecache
2072  */
2073 static void
2074 handle_namecache_block_response (void *cls,
2075                                  const struct GNUNET_GNSRECORD_Block *block)
2076 {
2077   struct GNS_ResolverHandle *rh = cls;
2078   struct AuthorityChain *ac = rh->ac_tail;
2079   const char *label = ac->label;
2080   const struct GNUNET_CRYPTO_EcdsaPublicKey *auth = &ac->authority_info.gns_authority;
2081   struct GNUNET_HashCode query;
2082
2083   GNUNET_assert (NULL != rh->namecache_qe);
2084   rh->namecache_qe = NULL;
2085   if ( ( (GNUNET_GNS_LO_DEFAULT == rh->options) ||
2086          ( (GNUNET_GNS_LO_LOCAL_MASTER == rh->options) &&
2087            (ac != rh->ac_head) ) ) &&
2088        ( (NULL == block) ||
2089          (0 == GNUNET_TIME_absolute_get_remaining (GNUNET_TIME_absolute_ntoh (block->expiration_time)).rel_value_us) ) )
2090   {
2091     /* namecache knows nothing; try DHT lookup */
2092     GNUNET_GNSRECORD_query_from_public_key (auth,
2093                                             label,
2094                                             &query);
2095     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
2096                 "Starting DHT lookup for `%s' in zone `%s' under key `%s'\n",
2097                 ac->label,
2098                 GNUNET_GNSRECORD_z2s (&ac->authority_info.gns_authority),
2099                 GNUNET_h2s (&query));
2100     start_dht_request (rh, &query);
2101     return;
2102   }
2103
2104   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
2105               "Received result from namecache for label `%s'\n",
2106               ac->label);
2107
2108   if ( (NULL == block) ||
2109        (0 == GNUNET_TIME_absolute_get_remaining (GNUNET_TIME_absolute_ntoh (block->expiration_time)).rel_value_us) )
2110   {
2111     /* DHT not permitted and no local result, fail */
2112     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
2113                 "Resolution failed for `%s' in zone %s (DHT lookup not permitted by configuration)\n",
2114                 ac->label,
2115                 GNUNET_GNSRECORD_z2s (&ac->authority_info.gns_authority));
2116     rh->proc (rh->proc_cls, 0, NULL);
2117     GNS_resolver_lookup_cancel (rh);
2118     return;
2119   }
2120   if (GNUNET_OK !=
2121       GNUNET_GNSRECORD_block_decrypt (block,
2122                                       auth,
2123                                       label,
2124                                       &handle_gns_namecache_resolution_result,
2125                                       rh))
2126   {
2127     GNUNET_break_op (0); /* block was ill-formed */
2128     /* try DHT instead */
2129     GNUNET_GNSRECORD_query_from_public_key (auth,
2130                                             label,
2131                                             &query);
2132     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
2133                 "Starting DHT lookup for `%s' in zone `%s' under key `%s'\n",
2134                 ac->label,
2135                 GNUNET_GNSRECORD_z2s (&ac->authority_info.gns_authority),
2136                 GNUNET_h2s (&query));
2137     start_dht_request (rh, &query);
2138     return;
2139   }
2140 }
2141
2142
2143 /**
2144  * Lookup tail of our authority chain in the namecache.
2145  *
2146  * @param rh query we are processing
2147  */
2148 static void
2149 recursive_gns_resolution_namecache (struct GNS_ResolverHandle *rh)
2150 {
2151   struct AuthorityChain *ac = rh->ac_tail;
2152   struct GNUNET_HashCode query;
2153
2154   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
2155               "Starting GNS resolution for `%s' in zone %s\n",
2156               ac->label,
2157               GNUNET_GNSRECORD_z2s (&ac->authority_info.gns_authority));
2158   GNUNET_GNSRECORD_query_from_public_key (&ac->authority_info.gns_authority,
2159                                           ac->label,
2160                                           &query);
2161   if (GNUNET_YES == use_cache)
2162   {
2163     rh->namecache_qe
2164       = GNUNET_NAMECACHE_lookup_block (namecache_handle,
2165                                        &query,
2166                                        &handle_namecache_block_response,
2167                                        rh);
2168     GNUNET_assert (NULL != rh->namecache_qe);
2169   }
2170   else
2171   {
2172     start_dht_request (rh, &query);
2173   }
2174 }
2175
2176
2177 /**
2178  * Function called with the result from a revocation check.
2179  *
2180  * @param cls the `struct GNS_ResovlerHandle`
2181  * @param is_valid #GNUNET_YES if the zone was not yet revoked
2182  */
2183 static void
2184 handle_revocation_result (void *cls,
2185                           int is_valid)
2186 {
2187   struct GNS_ResolverHandle *rh = cls;
2188   struct AuthorityChain *ac = rh->ac_tail;
2189
2190   rh->rev_check = NULL;
2191   if (GNUNET_YES != is_valid)
2192   {
2193     GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
2194                 _("Zone %s was revoked, resolution fails\n"),
2195                 GNUNET_GNSRECORD_z2s (&ac->authority_info.gns_authority));
2196     rh->proc (rh->proc_cls, 0, NULL);
2197     GNS_resolver_lookup_cancel (rh);
2198     return;
2199   }
2200   recursive_gns_resolution_namecache (rh);
2201 }
2202
2203
2204 /**
2205  * Perform revocation check on tail of our authority chain.
2206  *
2207  * @param rh query we are processing
2208  */
2209 static void
2210 recursive_gns_resolution_revocation (struct GNS_ResolverHandle *rh)
2211 {
2212   struct AuthorityChain *ac = rh->ac_tail;
2213
2214   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
2215               "Starting revocation check for zone %s\n",
2216               GNUNET_GNSRECORD_z2s (&ac->authority_info.gns_authority));
2217   rh->rev_check = GNUNET_REVOCATION_query (cfg,
2218                                            &ac->authority_info.gns_authority,
2219                                            &handle_revocation_result,
2220                                            rh);
2221   GNUNET_assert (NULL != rh->rev_check);
2222 }
2223
2224
2225 /**
2226  * Task scheduled to continue with the resolution process.
2227  *
2228  * @param cls the `struct GNS_ResolverHandle` of the resolution
2229  */
2230 static void
2231 recursive_resolution (void *cls)
2232 {
2233   struct GNS_ResolverHandle *rh = cls;
2234
2235   rh->task_id = NULL;
2236   if (MAX_RECURSION < rh->loop_limiter++)
2237   {
2238     GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
2239                 "Encountered unbounded recursion resolving `%s'\n",
2240                 rh->name);
2241     rh->proc (rh->proc_cls, 0, NULL);
2242     GNS_resolver_lookup_cancel (rh);
2243     return;
2244   }
2245   if (GNUNET_YES == rh->ac_tail->gns_authority)
2246     recursive_gns_resolution_revocation (rh);
2247   else
2248     recursive_dns_resolution (rh);
2249 }
2250
2251
2252 /**
2253  * Begin the resolution process from 'name', starting with
2254  * the identification of the zone specified by 'name'.
2255  *
2256  * @param rh resolution to perform
2257  */
2258 static void
2259 start_resolver_lookup (struct GNS_ResolverHandle *rh)
2260 {
2261   struct AuthorityChain *ac;
2262   char *y;
2263   struct in_addr v4;
2264   struct in6_addr v6;
2265
2266   if (1 == inet_pton (AF_INET,
2267                       rh->name,
2268                       &v4))
2269   {
2270     /* name is IPv4 address, pretend it's an A record */
2271     struct GNUNET_GNSRECORD_Data rd;
2272
2273     rd.data = &v4;
2274     rd.data_size = sizeof (v4);
2275     rd.expiration_time = UINT64_MAX;
2276     rd.record_type = GNUNET_DNSPARSER_TYPE_A;
2277     rd.flags = 0;
2278     rh->proc (rh->proc_cls, 1, &rd);
2279     GNS_resolver_lookup_cancel (rh);
2280     return;
2281   }
2282   if (1 == inet_pton (AF_INET6,
2283                       rh->name,
2284                       &v6))
2285   {
2286     /* name is IPv6 address, pretend it's an AAAA record */
2287     struct GNUNET_GNSRECORD_Data rd;
2288
2289     rd.data = &v6;
2290     rd.data_size = sizeof (v6);
2291     rd.expiration_time = UINT64_MAX;
2292     rd.record_type = GNUNET_DNSPARSER_TYPE_AAAA;
2293     rd.flags = 0;
2294     rh->proc (rh->proc_cls, 1, &rd);
2295     GNS_resolver_lookup_cancel (rh);
2296     return;
2297   }
2298   if ( ( (GNUNET_YES == is_canonical (rh->name)) &&
2299          (0 != strcmp (GNUNET_GNS_TLD, rh->name)) ) ||
2300        ( (GNUNET_YES != is_gnu_tld (rh->name)) &&
2301          (GNUNET_YES != is_zkey_tld (rh->name)) ) )
2302   {
2303     /* use standard DNS lookup */
2304     int af;
2305
2306     switch (rh->record_type)
2307     {
2308     case GNUNET_DNSPARSER_TYPE_A:
2309       af = AF_INET;
2310       break;
2311     case GNUNET_DNSPARSER_TYPE_AAAA:
2312       af = AF_INET6;
2313       break;
2314     default:
2315       af = AF_UNSPEC;
2316       break;
2317     }
2318     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
2319                 "Doing standard DNS lookup for `%s'\n",
2320                 rh->name);
2321     rh->std_resolve = GNUNET_RESOLVER_ip_get (rh->name,
2322                                               af,
2323                                               DNS_LOOKUP_TIMEOUT,
2324                                               &handle_dns_result,
2325                                               rh);
2326     return;
2327   }
2328   if (is_zkey_tld (rh->name))
2329   {
2330     /* Name ends with ".zkey", try to replace authority zone with zkey
2331        authority */
2332     GNUNET_free (resolver_lookup_get_next_label (rh)); /* will return "zkey" */
2333     y = resolver_lookup_get_next_label (rh); /* will return 'y' coordinate */
2334     if ( (NULL == y) ||
2335          (GNUNET_OK !=
2336           GNUNET_CRYPTO_ecdsa_public_key_from_string (y,
2337                                                       strlen (y),
2338                                                       &rh->authority_zone)) )
2339     {
2340       GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
2341                   _("Hostname `%s' is not well-formed, resolution fails\n"),
2342                   rh->name);
2343       rh->task_id = GNUNET_SCHEDULER_add_now (&fail_resolution, rh);
2344     }
2345     GNUNET_free_non_null (y);
2346   }
2347   else
2348   {
2349     /* Name ends with ".gnu", eat ".gnu" and continue with resolution */
2350     GNUNET_free (resolver_lookup_get_next_label (rh));
2351   }
2352   ac = GNUNET_new (struct AuthorityChain);
2353   ac->rh = rh;
2354   ac->label = resolver_lookup_get_next_label (rh);
2355   ac->suggested_shortening_label = NULL;
2356   if (NULL == ac->label)
2357     /* name was just "gnu", so we default to label '+' */
2358     ac->label = GNUNET_strdup (GNUNET_GNS_MASTERZONE_STR);
2359   ac->gns_authority = GNUNET_YES;
2360   ac->authority_info.gns_authority = rh->authority_zone;
2361   GNUNET_CONTAINER_DLL_insert_tail (rh->ac_head,
2362                                     rh->ac_tail,
2363                                     ac);
2364   rh->task_id = GNUNET_SCHEDULER_add_now (&recursive_resolution,
2365                                           rh);
2366 }
2367
2368
2369 /**
2370  * Lookup of a record in a specific zone calls lookup result processor
2371  * on result.
2372  *
2373  * @param zone the zone to perform the lookup in
2374  * @param record_type the record type to look up
2375  * @param name the name to look up
2376  * @param shorten_key a private key for use with PSEU import (can be NULL)
2377  * @param options local options to control local lookup
2378  * @param proc the processor to call on result
2379  * @param proc_cls the closure to pass to @a proc
2380  * @return handle to cancel operation
2381  */
2382 struct GNS_ResolverHandle *
2383 GNS_resolver_lookup (const struct GNUNET_CRYPTO_EcdsaPublicKey *zone,
2384                      uint32_t record_type,
2385                      const char *name,
2386                      const struct GNUNET_CRYPTO_EcdsaPrivateKey *shorten_key,
2387                      enum GNUNET_GNS_LocalOptions options,
2388                      GNS_ResultProcessor proc, void *proc_cls)
2389 {
2390   struct GNS_ResolverHandle *rh;
2391
2392   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
2393               (NULL == shorten_key)
2394               ? "Starting lookup for `%s' with shortening disabled\n"
2395               : "Starting lookup for `%s' with shortening enabled\n",
2396               name);
2397   rh = GNUNET_new (struct GNS_ResolverHandle);
2398   GNUNET_CONTAINER_DLL_insert (rlh_head,
2399                                rlh_tail,
2400                                rh);
2401   rh->authority_zone = *zone;
2402   rh->proc = proc;
2403   rh->proc_cls = proc_cls;
2404   rh->options = options;
2405   rh->record_type = record_type;
2406   rh->name = GNUNET_strdup (name);
2407   rh->name_resolution_pos = strlen (name);
2408   if (NULL != shorten_key)
2409   {
2410     rh->shorten_key = GNUNET_new (struct GNUNET_CRYPTO_EcdsaPrivateKey);
2411     *rh->shorten_key = *shorten_key;
2412   }
2413   start_resolver_lookup (rh);
2414   return rh;
2415 }
2416
2417
2418 /**
2419  * Cancel active resolution (i.e. client disconnected).
2420  *
2421  * @param rh resolution to abort
2422  */
2423 void
2424 GNS_resolver_lookup_cancel (struct GNS_ResolverHandle *rh)
2425 {
2426   struct DnsResult *dr;
2427   struct AuthorityChain *ac;
2428   struct VpnContext *vpn_ctx;
2429
2430   GNUNET_CONTAINER_DLL_remove (rlh_head,
2431                                rlh_tail,
2432                                rh);
2433   while (NULL != (ac = rh->ac_head))
2434   {
2435     GNUNET_CONTAINER_DLL_remove (rh->ac_head,
2436                                  rh->ac_tail,
2437                                  ac);
2438     GNUNET_free (ac->label);
2439     GNUNET_free_non_null (ac->suggested_shortening_label);
2440     GNUNET_free (ac);
2441   }
2442   if (NULL != rh->g2dc)
2443   {
2444     /* rh->g2dc->rh is NOT in the DLL yet, so to enable us
2445        using GNS_resolver_lookup_cancel here, we need to
2446        add it first... */
2447     if (NULL != rh->g2dc->rh)
2448     {
2449       GNUNET_CONTAINER_DLL_insert (rlh_head,
2450                                    rlh_tail,
2451                                    rh->g2dc->rh);
2452       GNS_resolver_lookup_cancel (rh->g2dc->rh);
2453       rh->g2dc->rh = NULL;
2454     }
2455     GNUNET_free (rh->g2dc->ns);
2456     GNUNET_free (rh->g2dc);
2457     rh->g2dc = NULL;
2458   }
2459   if (NULL != rh->task_id)
2460   {
2461     GNUNET_SCHEDULER_cancel (rh->task_id);
2462     rh->task_id = NULL;
2463   }
2464   if (NULL != rh->get_handle)
2465   {
2466     GNUNET_DHT_get_stop (rh->get_handle);
2467     rh->get_handle = NULL;
2468   }
2469   if (NULL != rh->dht_heap_node)
2470   {
2471     GNUNET_CONTAINER_heap_remove_node (rh->dht_heap_node);
2472     rh->dht_heap_node = NULL;
2473   }
2474   if (NULL != (vpn_ctx = rh->vpn_ctx))
2475   {
2476     GNUNET_VPN_cancel_request (vpn_ctx->vpn_request);
2477     GNUNET_free (vpn_ctx->rd_data);
2478     GNUNET_free (vpn_ctx);
2479   }
2480   if (NULL != rh->dns_request)
2481   {
2482     GNUNET_DNSSTUB_resolve_cancel (rh->dns_request);
2483     rh->dns_request = NULL;
2484   }
2485   if (NULL != rh->namecache_qe)
2486   {
2487     GNUNET_NAMECACHE_cancel (rh->namecache_qe);
2488     rh->namecache_qe = NULL;
2489   }
2490   if (NULL != rh->rev_check)
2491   {
2492     GNUNET_REVOCATION_query_cancel (rh->rev_check);
2493     rh->rev_check = NULL;
2494   }
2495   if (NULL != rh->std_resolve)
2496   {
2497     GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
2498                 "Canceling standard DNS resolution\n");
2499     GNUNET_RESOLVER_request_cancel (rh->std_resolve);
2500     rh->std_resolve = NULL;
2501   }
2502   while (NULL != (dr = rh->dns_result_head))
2503   {
2504     GNUNET_CONTAINER_DLL_remove (rh->dns_result_head,
2505                                  rh->dns_result_tail,
2506                                  dr);
2507     GNUNET_free (dr);
2508   }
2509   GNUNET_free_non_null (rh->shorten_key);
2510   GNUNET_free (rh->name);
2511   GNUNET_free (rh);
2512 }
2513
2514
2515 /* ***************** Resolver initialization ********************* */
2516
2517
2518 /**
2519  * Initialize the resolver
2520  *
2521  * @param nc the namecache handle
2522  * @param dht the dht handle
2523  * @param c configuration handle
2524  * @param max_bg_queries maximum number of parallel background queries in dht
2525  */
2526 void
2527 GNS_resolver_init (struct GNUNET_NAMECACHE_Handle *nc,
2528                    struct GNUNET_DHT_Handle *dht,
2529                    const struct GNUNET_CONFIGURATION_Handle *c,
2530                    unsigned long long max_bg_queries)
2531 {
2532   char *dns_ip;
2533
2534   cfg = c;
2535   namecache_handle = nc;
2536   dht_handle = dht;
2537   dht_lookup_heap =
2538     GNUNET_CONTAINER_heap_create (GNUNET_CONTAINER_HEAP_ORDER_MIN);
2539   max_allowed_background_queries = max_bg_queries;
2540   if (GNUNET_SYSERR == (use_cache =
2541                         GNUNET_CONFIGURATION_get_value_yesno (c,
2542                                                               "gns",
2543                                                               "USE_CACHE")))
2544     use_cache = GNUNET_YES;
2545   if (GNUNET_NO == use_cache)
2546     GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2547                 "Namecache disabled\n");
2548
2549   if (GNUNET_OK !=
2550       GNUNET_CONFIGURATION_get_value_string (c,
2551                                              "gns",
2552                                              "DNS_RESOLVER",
2553                                              &dns_ip))
2554   {
2555     /* user did not specify DNS resolver, use 8.8.8.8 */
2556     dns_ip = GNUNET_strdup ("8.8.8.8");
2557   }
2558   dns_handle = GNUNET_DNSSTUB_start (dns_ip);
2559   GNUNET_free (dns_ip);
2560   vpn_handle = GNUNET_VPN_connect (cfg);
2561 }
2562
2563
2564 /**
2565  * Shutdown resolver
2566  */
2567 void
2568 GNS_resolver_done ()
2569 {
2570   struct GNS_ResolverHandle *rh;
2571   struct CacheOps *co;
2572
2573   /* abort active resolutions */
2574   while (NULL != (rh = rlh_head))
2575   {
2576     rh->proc (rh->proc_cls, 0, NULL);
2577     GNS_resolver_lookup_cancel (rh);
2578   }
2579   while (NULL != (co = co_head))
2580   {
2581     GNUNET_CONTAINER_DLL_remove (co_head,
2582                                  co_tail,
2583                                  co);
2584     GNUNET_NAMECACHE_cancel (co->namecache_qe_cache);
2585     GNUNET_free (co);
2586   }
2587   GNUNET_CONTAINER_heap_destroy (dht_lookup_heap);
2588   dht_lookup_heap = NULL;
2589   GNUNET_DNSSTUB_stop (dns_handle);
2590   dns_handle = NULL;
2591   GNUNET_VPN_disconnect (vpn_handle);
2592   vpn_handle = NULL;
2593   dht_handle = NULL;
2594   namecache_handle = NULL;
2595 }
2596
2597
2598 /* *************** common helper functions (do not really belong here) *********** */
2599
2600 /**
2601  * Checks if @a name ends in ".TLD"
2602  *
2603  * @param name the name to check
2604  * @param tld the TLD to check for
2605  * @return GNUNET_YES or GNUNET_NO
2606  */
2607 int
2608 is_tld (const char* name, const char* tld)
2609 {
2610   size_t offset = 0;
2611
2612   if (strlen (name) <= strlen (tld))
2613     return GNUNET_NO;
2614   offset = strlen (name) - strlen (tld);
2615   if (0 != strcmp (name + offset, tld))
2616     return GNUNET_NO;
2617   return GNUNET_YES;
2618 }
2619
2620
2621 /* end of gnunet-service-gns_resolver.c */