Mercurial > pidgin

comparison src/protocols/jabber/iq.c @ 7395:b250288fa948

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
[gaim-migrate @ 7990] this would be the non-working start of file transfer (the real way) for jabber also approximately eleventy billion jabber tweaks committer: Tailor Script <tailor@pidgin.im>
author Nathan Walp <nwalp@pidgin.im>
date Fri, 31 Oct 2003 02:43:58 +0000
parents 1cf80749f2f0
children aaf91a891cd9
comparison
equal deleted inserted replaced
7394:c6ff3c1fb1b3 7395:b250288fa948
20 */ 20 */
21 #include "internal.h" 21 #include "internal.h"
22 #include "debug.h" 22 #include "debug.h"
23 #include "prefs.h" 23 #include "prefs.h"
24 24
25 #include "buddy.h"
25 #include "iq.h" 26 #include "iq.h"
26 #include "oob.h" 27 #include "oob.h"
27 #include "roster.h" 28 #include "roster.h"
29 #include "si.h"
28 30
29 #ifdef _WIN32 31 #ifdef _WIN32
30 #include "utsname.h" 32 #include "utsname.h"
31 #endif 33 #endif
32 34
77 xmlnode_set_attrib(query, "xmlns", xmlns); 79 xmlnode_set_attrib(query, "xmlns", xmlns);
78 80
79 return iq; 81 return iq;
80 } 82 }
81 83
82 void jabber_iq_set_callback(JabberIq *iq, JabberCallback *callback) 84 typedef struct _JabberCallbackData {
85 JabberIqCallback *callback;
86 gpointer data;
87 } JabberCallbackData;
88
89 void
90 jabber_iq_set_callback(JabberIq *iq, JabberIqCallback *callback, gpointer data)
83 { 91 {
84 iq->callback = callback; 92 iq->callback = callback;
93 iq->callback_data = data;
85 } 94 }
86 95
87 void jabber_iq_set_id(JabberIq *iq, const char *id) 96 void jabber_iq_set_id(JabberIq *iq, const char *id)
88 { 97 {
89 if(iq->id) 98 if(iq->id)
98 } 107 }
99 } 108 }
100 109
101 void jabber_iq_send(JabberIq *iq) 110 void jabber_iq_send(JabberIq *iq)
102 { 111 {
112 JabberCallbackData *jcd;
103 g_return_if_fail(iq != NULL); 113 g_return_if_fail(iq != NULL);
104 114
105 jabber_send(iq->js, iq->node); 115 jabber_send(iq->js, iq->node);
106 116
107 if(iq->id && iq->callback) 117 if(iq->id && iq->callback) {
108 g_hash_table_insert(iq->js->callbacks, g_strdup(iq->id), iq->callback); 118 jcd = g_new0(JabberCallbackData, 1);
119 jcd->callback = iq->callback;
120 jcd->data = iq->callback_data;
121 g_hash_table_insert(iq->js->callbacks, g_strdup(iq->id), jcd);
122 }
109 123
110 jabber_iq_free(iq); 124 jabber_iq_free(iq);
111 } 125 }
112 126
113 void jabber_iq_free(JabberIq *iq) 127 void jabber_iq_free(JabberIq *iq)
203 } 217 }
204 218
205 jabber_iq_send(iq); 219 jabber_iq_send(iq);
206 } 220 }
207 221
222 #define SUPPORT_FEATURE(x) \
223 feature = xmlnode_new_child(query, "feature"); \
224 xmlnode_set_attrib(feature, "var", x);
225
226
227 void jabber_disco_info_parse(JabberStream *js, xmlnode *packet) {
228 const char *from = xmlnode_get_attrib(packet, "from");
229 const char *type = xmlnode_get_attrib(packet, "type");
230
231 if(!from || !type)
232 return;
233
234 if(!strcmp(type, "get")) {
235 xmlnode *query, *identity, *feature;
236 JabberIq *iq = jabber_iq_new_query(js, JABBER_IQ_RESULT,
237 "http://jabber.org/protocol/disco#info");
238
239 jabber_iq_set_id(iq, xmlnode_get_attrib(packet, "id"));
240
241 xmlnode_set_attrib(iq->node, "to", from);
242 query = xmlnode_get_child(iq->node, "query");
243
244 identity = xmlnode_new_child(query, "identity");
245 xmlnode_set_attrib(identity, "category", "client");
246 xmlnode_set_attrib(identity, "type", "pc"); /* XXX: bot, console,
247 * handheld, pc, phone,
248 * web */
249
250 SUPPORT_FEATURE("jabber:iq:last")
251 SUPPORT_FEATURE("jabber:iq:oob")
252 SUPPORT_FEATURE("jabber:iq:time")
253 SUPPORT_FEATURE("jabber:iq:version")
254 SUPPORT_FEATURE("jabber:x:conference")
255 SUPPORT_FEATURE("http://jabber.org/protocol/bytestreams")
256 SUPPORT_FEATURE("http://jabber.org/protocol/disco#info")
257 SUPPORT_FEATURE("http://jabber.org/protocol/disco#items")
258 SUPPORT_FEATURE("http://jabber.org/protocol/muc")
259 SUPPORT_FEATURE("http://jabber.org/protocol/muc#user")
260 SUPPORT_FEATURE("http://jabber.org/protocol/si")
261 SUPPORT_FEATURE("http://jabber.org/protocol/si/profile/file-transfer")
262
263 jabber_iq_send(iq);
264 }else if(!strcmp(type, "result")) {
265 xmlnode *query = xmlnode_get_child(packet, "query");
266 xmlnode *child;
267 JabberID *jid;
268 JabberBuddy *jb;
269 JabberBuddyResource *jbr = NULL;
270
271 if(!(jid = jabber_id_new(from)))
272 return;
273
274 if(jid->resource && (jb = jabber_buddy_find(js, from, TRUE)))
275 jbr = jabber_buddy_find_resource(jb, jid->resource);
276
277 if(!jbr) {
278 jabber_id_free(jid);
279 return;
280 }
281
282 for(child = query->child; child; child = child->next) {
283 if(child->type != NODE_TYPE_TAG)
284 continue;
285
286 if(!strcmp(child->name, "feature")) {
287 const char *var = xmlnode_get_attrib(child, "var");
288 if(!var)
289 continue;
290
291 if(!strcmp(var, "http://jabber.org/protocol/si"))
292 jbr->capabilities |= JABBER_CAP_SI;
293 else if(!strcmp(var,
294 "http://jabber.org/protocol/si/profile/file-transfer"))
295 jbr->capabilities |= JABBER_CAP_SI_FILE_XFER;
296 else if(!strcmp(var, "http://jabber.org/protocol/bytestreams"))
297 jbr->capabilities |= JABBER_CAP_BYTESTREAMS;
298 }
299 }
300 jabber_id_free(jid);
301 }
302 }
303
304 void jabber_disco_items_parse(JabberStream *js, xmlnode *packet) {
305 const char *from = xmlnode_get_attrib(packet, "from");
306 const char *type = xmlnode_get_attrib(packet, "type");
307
308 if(!strcmp(type, "get")) {
309 JabberIq *iq = jabber_iq_new_query(js, JABBER_IQ_RESULT,
310 "http://jabber.org/protocol/disco#items");
311
312 jabber_iq_set_id(iq, xmlnode_get_attrib(packet, "id"));
313
314 xmlnode_set_attrib(iq->node, "to", from);
315 jabber_iq_send(iq);
316 }
317 }
318
208 void jabber_iq_parse(JabberStream *js, xmlnode *packet) 319 void jabber_iq_parse(JabberStream *js, xmlnode *packet)
209 { 320 {
321 JabberCallbackData *jcd;
210 xmlnode *query; 322 xmlnode *query;
211 const char *xmlns; 323 const char *xmlns;
324 const char *type, *id;
212 325
213 query = xmlnode_get_child(packet, "query"); 326 query = xmlnode_get_child(packet, "query");
214 327
215 if(!query) 328 if(query) {
329
330 xmlns = xmlnode_get_attrib(query, "xmlns");
331
332 if(!xmlns)
333 return;
334
335 if(!strcmp(xmlns, "jabber:iq:roster")) {
336 jabber_roster_parse(js, packet);
337 return;
338 } else if(!strcmp(xmlns, "jabber:iq:last")) {
339 jabber_iq_handle_last(js, packet);
340 return;
341 } else if(!strcmp(xmlns, "jabber:iq:time")) {
342 jabber_iq_handle_time(js, packet);
343 return;
344 } else if(!strcmp(xmlns, "jabber:iq:version")) {
345 jabber_iq_handle_version(js, packet);
346 return;
347 } else if(!strcmp(xmlns, "jabber:iq:register")) {
348 jabber_register_parse(js, packet);
349 return;
350 } else if(!strcmp(xmlns, "jabber:iq:oob")) {
351 jabber_oob_parse(js, packet);
352 return;
353 } else if(!strcmp(xmlns, "http://jabber.org/protocol/disco#info")) {
354 jabber_disco_info_parse(js, packet);
355 return;
356 } else if(!strcmp(xmlns, "http://jabber.org/protocol/disco#items")) {
357 jabber_disco_items_parse(js, packet);
358 return;
359 }
360 } else if(xmlnode_get_child(packet, "si")) {
361 jabber_si_parse(js, packet);
216 return; 362 return;
217 363 }
218 xmlns = xmlnode_get_attrib(query, "xmlns"); 364
219 365 /* If we got here, no pre-defined handlers got it, lets see if a special
220 if(!xmlns) 366 * callback got registered */
221 return; 367
222 368 type = xmlnode_get_attrib(packet, "type");
223 if(!strcmp(xmlns, "jabber:iq:roster")) { 369 id = xmlnode_get_attrib(packet, "id");
224 jabber_roster_parse(js, packet); 370
225 } else if(!strcmp(xmlns, "jabber:iq:last")) { 371 if(type && (!strcmp(type, "result") || !strcmp(type, "error")) && id
226 jabber_iq_handle_last(js, packet); 372 && *id && (jcd = g_hash_table_lookup(js->callbacks, id))) {
227 } else if(!strcmp(xmlns, "jabber:iq:time")) { 373 jcd->callback(js, packet, jcd->data);
228 jabber_iq_handle_time(js, packet); 374 g_free(jcd);
229 } else if(!strcmp(xmlns, "jabber:iq:version")) { 375 }
230 jabber_iq_handle_version(js, packet); 376 }
231 } else if(!strcmp(xmlns, "jabber:iq:register")) { 377
232 jabber_register_parse(js, packet);
233 } else if(!strcmp(xmlns, "jabber:iq:oob")) {
234 jabber_oob_parse(js, packet);
235 } else {
236 gaim_debug(GAIM_DEBUG_WARNING, "jabber", "Unknown query: %s\n", xmlns);
237 }
238 }
239