src/telepathy/telepathy-dnsquery.c

   1 /**
   2  * @file telepathy-dnsquery.c
   3  *
   4  * pidgin-sipe
   5  *
   6  * Copyright (C) 2012 SIPE Project <http://sipe.sourceforge.net/>
   7  *
   8  * This program is free software; you can redistribute it and/or modify
   9  * it under the terms of the GNU General Public License as published by
  10  * the Free Software Foundation; either version 2 of the License, or
  11  * (at your option) any later version.
  12  *
  13  * This program is distributed in the hope that it will be useful,
  14  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  15  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  16  * GNU General Public License for more details.
  17  *
  18  * You should have received a copy of the GNU General Public License
  19  * along with this program; if not, write to the Free Software
  20  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  21  */
  22
  23 #include <glib.h>
  24 #include <gio/gio.h>
  25
  26 #include "sipe-backend.h"
  27 #include "sipe-common.h"
  28 #include "sipe-core.h"
  29
  30 struct sipe_dns_query {
  31         sipe_dns_resolved_cb  callback;
  32         gpointer              extradata;
  33         guint                 port;
  34         GCancellable         *cancel;
  35 };
  36
  37 static void dns_srv_response(GObject *resolver,
  38                              GAsyncResult *result,
  39                              gpointer data)
  40 {
  41         GError *error  = NULL;
  42         GList *targets = g_resolver_lookup_service_finish(G_RESOLVER(resolver),
  43                                                           result,
  44                                                           &error);
  45         struct sipe_dns_query *query = data;
  46
  47         if (targets) {
  48                 GSrvTarget *target = targets->data;
  49                 query->callback(query->extradata,
  50                                 g_srv_target_get_hostname(target),
  51                                 g_srv_target_get_port(target));
  52                 g_resolver_free_targets(targets);
  53         } else {
  54                 SIPE_DEBUG_INFO("dns_srv_response: failed: %s",
  55                                 error ? error->message : "UNKNOWN");
  56                 g_error_free(error);
  57                 query->callback(query->extradata, NULL, 0);
  58         }
  59         g_object_unref(query->cancel);
  60         g_free(query);
  61 }
  62
  63 struct sipe_dns_query *sipe_backend_dns_query_srv(SIPE_UNUSED_PARAMETER struct sipe_core_public *sipe_public,
  64                                                   const gchar *protocol,
  65                                                   const gchar *transport,
  66                                                   const gchar *domain,
  67                                                   sipe_dns_resolved_cb callback,
  68                                                   gpointer data)
  69 {
  70         struct sipe_dns_query *query = g_new0(struct sipe_dns_query, 1);
  71         GResolver *resolver          = g_resolver_get_default();
  72
  73         SIPE_DEBUG_INFO("sipe_backend_dns_query_srv: %s/%s/%s",
  74                         protocol, transport, domain);
  75
  76         query->callback  = callback;
  77         query->extradata = data;
  78         query->cancel    = g_cancellable_new();
  79         g_resolver_lookup_service_async(resolver,
  80                                         protocol, transport, domain,
  81                                         query->cancel,
  82                                         dns_srv_response,
  83                                         query);
  84
  85         g_object_unref(resolver);
  86         return(query);
  87 }
  88
  89 static void dns_a_response(GObject *resolver,
  90                            GAsyncResult *result,
  91                            gpointer data)
  92 {
  93         GError *error    = NULL;
  94         GList *addresses = g_resolver_lookup_by_name_finish(G_RESOLVER(resolver),
  95                                                             result,
  96                                                             &error);
  97         struct sipe_dns_query *query = data;
  98
  99         if (addresses) {
 100                 GInetAddress *address  = addresses->data;
 101                 gchar        *ipstr    = g_inet_address_to_string(address);
 102                 query->callback(query->extradata, ipstr, query->port);
 103                 g_free(ipstr);
 104                 g_resolver_free_addresses(addresses);
 105         } else {
 106                 SIPE_DEBUG_INFO("dns_a_response: failed: %s",
 107                                 error ? error->message : "UNKNOWN");
 108                 g_error_free(error);
 109                 query->callback(query->extradata, NULL, 0);
 110         }
 111         g_object_unref(query->cancel);
 112         g_free(query);
 113 }
 114
 115 struct sipe_dns_query *sipe_backend_dns_query_a(SIPE_UNUSED_PARAMETER struct sipe_core_public *sipe_public,
 116                                                 const gchar *hostname,
 117                                                 guint port,
 118                                                 sipe_dns_resolved_cb callback,
 119                                                 gpointer data)
 120 {
 121         struct sipe_dns_query *query = g_new0(struct sipe_dns_query, 1);
 122         GResolver *resolver          = g_resolver_get_default();
 123
 124         SIPE_DEBUG_INFO("sipe_backend_dns_query_a: %s", hostname);
 125
 126         query->callback  = callback;
 127         query->extradata = data;
 128         query->port      = port;
 129         query->cancel    = g_cancellable_new();
 130         g_resolver_lookup_by_name_async(resolver,
 131                                         hostname,
 132                                         query->cancel,
 133                                         dns_a_response,
 134                                         query);
 135
 136         g_object_unref(resolver);
 137         return(query);
 138 }
 139
 140 void sipe_backend_dns_query_cancel(struct sipe_dns_query *query)
 141 {
 142         g_cancellable_cancel(query->cancel);
 143 }
 144
 145 /*
 146   Local Variables:
 147   mode: c
 148   c-file-style: "bsd"
 149   indent-tabs-mode: t
 150   tab-width: 8
 151   End:
 152 */