jabber.c

   1 /*
   2 ** Copyright (C) 2006 Thadeu Lima de Souza Cascardo <cascardo@minaslivre.org>
   3 **
   4 ** This program is free software; you can redistribute it and/or modify
   5 ** it under the terms of the GNU General Public License as published by
   6 ** the Free Software Foundation; either version 2 of the License, or
   7 ** (at your option) any later version.
   8 **
   9 ** This program is distributed in the hope that it will be useful,
  10 ** but WITHOUT ANY WARRANTY; without even the implied warranty of
  11 ** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12 ** GNU General Public License for more details.
  13 **
  14 ** You should have received a copy of the GNU General Public License
  15 ** along with this program; if not, write to the Free Software
  16 ** Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
  17 **
  18 */
  19
  20 #include <gnet.h>
  21 #include <glib.h>
  22 #include <iksemel.h>
  23 #include "iksemel_extra.h"
  24 #include "jabber.h"
  25
  26 static void jabber_connect (net_hook_t* hook)
  27 {
  28 }
  29
  30 static void jabber_close (net_hook_t* hook)
  31 {
  32   if (hook->peer)
  33     {
  34       hook->peer->peer = NULL;
  35       gnet_conn_disconnect (hook->peer->conn);
  36     }
  37   gnet_conn_delete (hook->conn);
  38   iks_parser_delete (hook->data);
  39   g_slice_free (net_hook_t, hook);
  40 }
  41
  42 static void jabber_write (net_hook_t* hook)
  43 {
  44 }
  45
  46 static void jabber_read (net_hook_t* hook, gchar* buffer, size_t len)
  47 {
  48   iks_parse (hook->data, buffer, len, FALSE);
  49 }
  50
  51 void jabber_error (net_hook_t* hook)
  52 {
  53   g_message ("Error in jabber client connection.");
  54 }
  55
  56 GString* jabber_new_start (iks* node)
  57 {
  58   GString* buffer;
  59   buffer = g_string_sized_new (256);
  60   g_string_append (buffer, iks_string (iks_stack (node), node));
  61   g_string_erase (buffer, buffer->len - 2, 1);
  62   return buffer;
  63 }
  64
  65 void jabber_connect_server (net_hook_t* hook, char* server, iks* node)
  66 {
  67   net_hook_t* server_hook;
  68   GString* buffer;
  69   g_message ("Received new stream.");
  70   if (hook->peer == NULL)
  71     {
  72       server_hook = jabber_server_hook_new (hook, server);
  73       hook->peer = server_hook;
  74       g_message ("Trying to connect to server %s.", server);
  75       gnet_conn_connect (hook->peer->conn);
  76       gnet_conn_read (hook->peer->conn);
  77     }
  78   buffer = jabber_new_start (node);
  79   gnet_conn_write (hook->peer->conn, buffer->str, buffer->len);
  80   g_string_free (buffer, TRUE);
  81 }
  82
  83 void
  84 jabber_sasl_plain_filter (iks *node)
  85 {
  86   if (g_str_equal (iks_name (node), "auth") &&
  87       g_str_equal (iks_find_attrib (node, "xmlns"),
  88                                     "urn:ietf:params:xml:ns:xmpp-sasl"))
  89     {
  90       char *b64;
  91       char *uname;
  92       gsize uname_len;
  93       b64 = iks_cdata (iks_child (node));
  94       uname = g_base64_decode (b64, &uname_len);
  95       g_message ("User trying authentication as %s", uname);
  96       g_free (uname);
  97     }
  98 }
  99
 100 void jabber_send (net_hook_t* hook, iks* node)
 101 {
 102   GString* buffer;
 103   jabber_sasl_plain_filter (node);
 104   buffer = g_string_new (iks_string (iks_stack (node), node));
 105   gnet_conn_write (hook->peer->conn, buffer->str, buffer->len);
 106   g_string_free (buffer, TRUE);
 107 }
 108
 109 int jabber_parser (gpointer data, int type, iks* node)
 110 {
 111   net_hook_t* hook;
 112   char* server;
 113   hook = (net_hook_t*) data;
 114   switch (type)
 115     {
 116     case IKS_NODE_START:
 117       server = iks_find_attrib (node, "to");
 118       if (server == NULL)
 119         {
 120           jabber_error (hook);
 121         }
 122       jabber_connect_server (hook, server, node);
 123       iks_delete (node);
 124       break;
 125     case IKS_NODE_NORMAL:
 126       jabber_send (hook, node);
 127       iks_delete (node);
 128       break;
 129     case IKS_NODE_STOP:
 130       gnet_conn_write (hook->peer->conn, "</stream:stream>", 16);
 131       break;
 132     case IKS_NODE_ERROR:
 133       break;
 134     }
 135   return IKS_OK;
 136 }
 137
 138 net_hook_t* jabber_hook_new (GConn* conn)
 139 {
 140   net_hook_t* hook;
 141   hook = g_slice_new (net_hook_t);
 142   hook->conn = conn;
 143   hook->peer = NULL;
 144   hook->server = FALSE;
 145   hook->connect = jabber_connect;
 146   hook->close = jabber_close;
 147   hook->write = jabber_write;
 148   hook->read = jabber_read;
 149   hook->data = iks_extra_stream_new (hook, jabber_parser);
 150   gnet_conn_set_callback (hook->conn, nethook_event, hook);
 151   return hook;
 152 }
 153
 154 void jabber_destroy (net_hook_t* hook)
 155 {
 156   g_slice_free (net_hook_t, hook);
 157 }