jabber_server.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_server_connect (net_hook_t* hook)
  27 {
  28   g_message ("Connected to jabber server.");
  29 }
  30
  31 static void jabber_server_close (net_hook_t* hook)
  32 {
  33   if (hook->peer)
  34     {
  35       hook->peer->peer = NULL;
  36       gnet_conn_disconnect (hook->peer->conn);
  37     }
  38   gnet_conn_delete (hook->conn);
  39   jabber_data_destroy (hook->data);
  40   g_slice_free (net_hook_t, hook);
  41   g_message ("Server disconnected.");
  42 }
  43
  44 static void jabber_server_write (net_hook_t* hook)
  45 {
  46 }
  47
  48 static void jabber_server_read (net_hook_t* hook, gchar* buffer, size_t len)
  49 {
  50   jabber_data_t *jdata = (jabber_data_t*) hook->data;
  51   iks_parse (jdata->parser, buffer, len, FALSE);
  52 }
  53
  54 void jabber_server_tls_filter (iks* node)
  55 {
  56   iks* tls;
  57   if (g_str_equal (iks_name (node), "stream:features"))
  58     {
  59       tls = iks_find (node, "starttls");
  60       if (tls)
  61         iks_hide (tls);
  62     }
  63 }
  64
  65 void jabber_server_sasl_filter (iks* node)
  66 {
  67   iks* sasl;
  68   GString* mechs = NULL;
  69   gboolean plain = FALSE;
  70   if (g_str_equal (iks_name (node), "stream:features"))
  71     {
  72       sasl = iks_find (node, "mechanisms");
  73       if (sasl && g_str_equal (iks_find_attrib (sasl, "xmlns"),
  74                                "urn:ietf:params:xml:ns:xmpp-sasl"))
  75         {
  76           mechs = g_string_sized_new (256);
  77           iks* mech;
  78           for (mech = iks_child (sasl); mech != NULL; mech = iks_next (mech))
  79             {
  80               char* mech_name;
  81               mech_name = iks_cdata (iks_child (mech));
  82               if (g_str_equal (mech_name, "PLAIN"))
  83                 plain = TRUE;
  84               mechs = g_string_append (mechs, mech_name);
  85               mechs = g_string_append_c (mechs, ' ');
  86             }
  87           g_debug ("Mechanisms supported by server: %s", mechs->str);
  88           g_string_free (mechs, TRUE);
  89           if (plain)
  90             {
  91               for (mech = iks_child (sasl); mech != NULL; mech = iks_next (mech))
  92                 {
  93                   char* mech_name;
  94                   mech_name = iks_cdata (iks_child (mech));
  95                   if (!g_str_equal (mech_name, "PLAIN"))
  96                     iks_hide (mech);
  97                 }
  98             }
  99         }
 100     }
 101 }
 102
 103 int jabber_server_parser (gpointer data, int type, iks* node)
 104 {
 105   net_hook_t* hook;
 106   GString* buffer;
 107   hook = (net_hook_t*) data;
 108   switch (type)
 109     {
 110     case IKS_NODE_START:
 111       buffer = jabber_new_start (node);
 112       gnet_conn_write (hook->peer->conn, buffer->str, buffer->len);
 113       g_string_free (buffer, TRUE);
 114       iks_delete (node);
 115       break;
 116     case IKS_NODE_NORMAL:
 117       jabber_server_tls_filter (node);
 118       jabber_server_sasl_filter (node);
 119       buffer = g_string_new (iks_string (iks_stack (node), node));
 120       gnet_conn_write (hook->peer->conn, buffer->str, buffer->len);
 121       g_string_free (buffer, TRUE);
 122       iks_delete (node);
 123       break;
 124     case IKS_NODE_STOP:
 125       gnet_conn_write (hook->peer->conn, "</stream:stream>", 16);
 126       break;
 127     case IKS_NODE_ERROR:
 128       g_debug ("Parse error!!");
 129       break;
 130     }
 131   return IKS_OK;
 132 }
 133
 134 net_hook_t* jabber_server_hook_new (net_hook_t* client_hook, char* server)
 135 {
 136   net_hook_t* hook;
 137   hook = g_slice_new (net_hook_t);
 138   hook->conn = gnet_conn_new (server, 5222, nethook_event, hook);
 139   hook->peer = client_hook;
 140   hook->server = TRUE;
 141   hook->connect = jabber_server_connect;
 142   hook->close = jabber_server_close;
 143   hook->write = jabber_server_write;
 144   hook->read = jabber_server_read;
 145   hook->data = jabber_data_new (hook, jabber_server_parser);
 146   return hook;
 147 }