gnet_conn_disconnect (hook->peer->conn);
}
gnet_conn_delete (hook->conn);
- iks_parser_delete (hook->data);
+ jabber_data_destroy (hook->data);
g_slice_free (net_hook_t, hook);
g_message ("Server disconnected.");
}
static void jabber_server_read (net_hook_t* hook, gchar* buffer, size_t len)
{
- iks_parse (hook->data, buffer, len, FALSE);
+ jabber_data_t *jdata = (jabber_data_t*) hook->data;
+ iks_parse (jdata->parser, buffer, len, FALSE);
+}
+
+void jabber_server_tls_filter (iks* node)
+{
+ iks* tls;
+ if (g_str_equal (iks_name (node), "stream:features"))
+ {
+ tls = iks_find (node, "starttls");
+ if (tls)
+ iks_hide (tls);
+ }
+}
+
+void jabber_server_sasl_filter (iks* node)
+{
+ iks* sasl;
+ GString* mechs = NULL;
+ gboolean plain = FALSE;
+ if (g_str_equal (iks_name (node), "stream:features"))
+ {
+ sasl = iks_find (node, "mechanisms");
+ if (sasl && g_str_equal (iks_find_attrib (sasl, "xmlns"),
+ "urn:ietf:params:xml:ns:xmpp-sasl"))
+ {
+ mechs = g_string_sized_new (256);
+ iks* mech;
+ for (mech = iks_child (sasl); mech != NULL; mech = iks_next (mech))
+ {
+ char* mech_name;
+ mech_name = iks_cdata (iks_child (mech));
+ if (g_str_equal (mech_name, "PLAIN"))
+ plain = TRUE;
+ mechs = g_string_append (mechs, mech_name);
+ mechs = g_string_append_c (mechs, ' ');
+ }
+ g_debug ("Mechanisms supported by server: %s", mechs->str);
+ g_string_free (mechs, TRUE);
+ if (plain)
+ {
+ for (mech = iks_child (sasl); mech != NULL; mech = iks_next (mech))
+ {
+ char* mech_name;
+ mech_name = iks_cdata (iks_child (mech));
+ if (!g_str_equal (mech_name, "PLAIN"))
+ iks_hide (mech);
+ }
+ }
+ }
+ }
}
int jabber_server_parser (gpointer data, int type, iks* node)
iks_delete (node);
break;
case IKS_NODE_NORMAL:
+ jabber_server_tls_filter (node);
+ jabber_server_sasl_filter (node);
buffer = g_string_new (iks_string (iks_stack (node), node));
gnet_conn_write (hook->peer->conn, buffer->str, buffer->len);
g_string_free (buffer, TRUE);
hook->close = jabber_server_close;
hook->write = jabber_server_write;
hook->read = jabber_server_read;
- hook->data = iks_extra_stream_new (hook, jabber_server_parser);
+ hook->data = jabber_data_new (hook, jabber_server_parser);
return hook;
}