Mercurial > pidgin
annotate src/protocols/jabber/iq.c @ 7792:27f55b264446
[gaim-migrate @ 8438]
Smileys will work again... and maybe they won't crash either.
That was dumb.
committer: Tailor Script <tailor@pidgin.im>
author | Sean Egan <seanegan@gmail.com> |
---|---|
date | Sun, 07 Dec 2003 19:31:17 +0000 |
parents | 43a214a385d1 |
children | 45f37d7a20dc |
rev | line source |
---|---|
7014 | 1 /* |
2 * gaim - Jabber Protocol Plugin | |
3 * | |
4 * Copyright (C) 2003, Nathan Walp <faceprint@faceprint.com> | |
5 * | |
6 * This program is free software; you can redistribute it and/or modify | |
7 * it under the terms of the GNU General Public License as published by | |
8 * the Free Software Foundation; either version 2 of the License, or | |
9 * (at your option) any later version. | |
10 * | |
11 * This program is distributed in the hope that it will be useful, | |
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of | |
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | |
14 * GNU General Public License for more details. | |
15 * | |
16 * You should have received a copy of the GNU General Public License | |
17 * along with this program; if not, write to the Free Software | |
18 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA | |
19 * | |
20 */ | |
21 #include "internal.h" | |
22 #include "debug.h" | |
23 #include "prefs.h" | |
24 | |
7395 | 25 #include "buddy.h" |
7014 | 26 #include "iq.h" |
7170 | 27 #include "oob.h" |
7014 | 28 #include "roster.h" |
7395 | 29 #include "si.h" |
7014 | 30 |
7058
06e7697f3fae
[gaim-migrate @ 7621]
Herman Bloggs <hermanator12002@yahoo.com>
parents:
7014
diff
changeset
|
31 #ifdef _WIN32 |
06e7697f3fae
[gaim-migrate @ 7621]
Herman Bloggs <hermanator12002@yahoo.com>
parents:
7014
diff
changeset
|
32 #include "utsname.h" |
06e7697f3fae
[gaim-migrate @ 7621]
Herman Bloggs <hermanator12002@yahoo.com>
parents:
7014
diff
changeset
|
33 #endif |
7014 | 34 |
35 JabberIq *jabber_iq_new(JabberStream *js, JabberIqType type) | |
36 { | |
37 JabberIq *iq; | |
38 | |
39 iq = g_new0(JabberIq, 1); | |
40 | |
41 iq->type = type; | |
42 | |
43 iq->node = xmlnode_new("iq"); | |
44 switch(iq->type) { | |
45 case JABBER_IQ_SET: | |
46 xmlnode_set_attrib(iq->node, "type", "set"); | |
47 break; | |
48 case JABBER_IQ_GET: | |
49 xmlnode_set_attrib(iq->node, "type", "get"); | |
50 break; | |
51 case JABBER_IQ_ERROR: | |
52 xmlnode_set_attrib(iq->node, "type", "error"); | |
53 break; | |
54 case JABBER_IQ_RESULT: | |
55 xmlnode_set_attrib(iq->node, "type", "result"); | |
56 break; | |
57 case JABBER_IQ_NONE: | |
58 /* this shouldn't ever happen */ | |
59 break; | |
60 } | |
61 | |
62 iq->js = js; | |
63 | |
64 if(type == JABBER_IQ_GET || type == JABBER_IQ_SET) { | |
65 iq->id = jabber_get_next_id(js); | |
66 xmlnode_set_attrib(iq->node, "id", iq->id); | |
67 } | |
68 | |
69 return iq; | |
70 } | |
71 | |
72 JabberIq *jabber_iq_new_query(JabberStream *js, JabberIqType type, | |
73 const char *xmlns) | |
74 { | |
75 JabberIq *iq = jabber_iq_new(js, type); | |
76 xmlnode *query; | |
77 | |
78 query = xmlnode_new_child(iq->node, "query"); | |
79 xmlnode_set_attrib(query, "xmlns", xmlns); | |
80 | |
81 return iq; | |
82 } | |
83 | |
7395 | 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) | |
7014 | 91 { |
92 iq->callback = callback; | |
7395 | 93 iq->callback_data = data; |
7014 | 94 } |
95 | |
96 void jabber_iq_set_id(JabberIq *iq, const char *id) | |
97 { | |
98 if(iq->id) | |
99 g_free(iq->id); | |
100 | |
101 if(id) { | |
102 xmlnode_set_attrib(iq->node, "id", id); | |
103 iq->id = g_strdup(id); | |
104 } else { | |
105 xmlnode_remove_attrib(iq->node, "id"); | |
106 iq->id = NULL; | |
107 } | |
108 } | |
109 | |
110 void jabber_iq_send(JabberIq *iq) | |
111 { | |
7395 | 112 JabberCallbackData *jcd; |
7014 | 113 g_return_if_fail(iq != NULL); |
114 | |
115 jabber_send(iq->js, iq->node); | |
116 | |
7395 | 117 if(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 } | |
7014 | 123 |
124 jabber_iq_free(iq); | |
125 } | |
126 | |
127 void jabber_iq_free(JabberIq *iq) | |
128 { | |
129 g_return_if_fail(iq != NULL); | |
130 | |
131 g_free(iq->id); | |
132 xmlnode_free(iq->node); | |
133 g_free(iq); | |
134 } | |
135 | |
136 static void jabber_iq_handle_last(JabberStream *js, xmlnode *packet) | |
137 { | |
138 JabberIq *iq; | |
139 const char *from; | |
140 const char *id; | |
141 xmlnode *query; | |
142 char *idle_time; | |
143 | |
144 from = xmlnode_get_attrib(packet, "from"); | |
145 id = xmlnode_get_attrib(packet, "id"); | |
146 | |
147 iq = jabber_iq_new_query(js, JABBER_IQ_RESULT, "jabber:iq:last"); | |
148 jabber_iq_set_id(iq, id); | |
149 xmlnode_set_attrib(iq->node, "to", from); | |
150 | |
151 query = xmlnode_get_child(iq->node, "query"); | |
152 | |
153 idle_time = g_strdup_printf("%ld", js->idle ? time(NULL) - js->idle : 0); | |
154 xmlnode_set_attrib(query, "seconds", idle_time); | |
155 g_free(idle_time); | |
7401 | 156 |
157 jabber_iq_send(iq); | |
7014 | 158 } |
159 | |
160 static void jabber_iq_handle_time(JabberStream *js, xmlnode *packet) | |
161 { | |
162 const char *from, *id; | |
163 JabberIq *iq; | |
164 char buf[1024]; | |
165 xmlnode *query; | |
166 time_t now_t; | |
167 struct tm now; | |
168 time(&now_t); | |
169 localtime_r(&now_t, &now); | |
170 | |
171 from = xmlnode_get_attrib(packet, "from"); | |
172 id = xmlnode_get_attrib(packet, "id"); | |
173 | |
174 iq = jabber_iq_new_query(js, JABBER_IQ_RESULT, "jabber:iq:time"); | |
175 jabber_iq_set_id(iq, id); | |
176 xmlnode_set_attrib(iq->node, "to", from); | |
177 | |
178 query = xmlnode_get_child(iq->node, "query"); | |
179 | |
180 strftime(buf, sizeof(buf), "%Y%m%dT%T", &now); | |
181 xmlnode_insert_data(xmlnode_new_child(query, "utc"), buf, -1); | |
182 strftime(buf, sizeof(buf), "%Z", &now); | |
183 xmlnode_insert_data(xmlnode_new_child(query, "tz"), buf, -1); | |
184 strftime(buf, sizeof(buf), "%d %b %Y %T", &now); | |
185 xmlnode_insert_data(xmlnode_new_child(query, "display"), buf, -1); | |
186 | |
187 jabber_iq_send(iq); | |
188 } | |
189 | |
190 static void jabber_iq_handle_version(JabberStream *js, xmlnode *packet) | |
191 { | |
192 JabberIq *iq; | |
193 const char *from, *id; | |
194 xmlnode *query; | |
195 char *os = NULL; | |
196 | |
197 if(!gaim_prefs_get_bool("/plugins/prpl/jabber/hide_os")) { | |
198 struct utsname osinfo; | |
199 | |
200 uname(&osinfo); | |
201 os = g_strdup_printf("%s %s %s", osinfo.sysname, osinfo.release, | |
202 osinfo.machine); | |
203 } | |
204 | |
205 from = xmlnode_get_attrib(packet, "from"); | |
206 id = xmlnode_get_attrib(packet, "id"); | |
207 | |
208 iq = jabber_iq_new_query(js, JABBER_IQ_RESULT, "jabber:iq:version"); | |
209 xmlnode_set_attrib(iq->node, "to", from); | |
210 jabber_iq_set_id(iq, id); | |
211 | |
212 query = xmlnode_get_child(iq->node, "query"); | |
213 | |
214 xmlnode_insert_data(xmlnode_new_child(query, "name"), PACKAGE, -1); | |
215 xmlnode_insert_data(xmlnode_new_child(query, "version"), VERSION, -1); | |
216 if(os) { | |
217 xmlnode_insert_data(xmlnode_new_child(query, "os"), os, -1); | |
218 g_free(os); | |
219 } | |
220 | |
221 jabber_iq_send(iq); | |
222 } | |
223 | |
7395 | 224 #define SUPPORT_FEATURE(x) \ |
225 feature = xmlnode_new_child(query, "feature"); \ | |
226 xmlnode_set_attrib(feature, "var", x); | |
227 | |
228 | |
229 void jabber_disco_info_parse(JabberStream *js, xmlnode *packet) { | |
230 const char *from = xmlnode_get_attrib(packet, "from"); | |
231 const char *type = xmlnode_get_attrib(packet, "type"); | |
232 | |
233 if(!from || !type) | |
234 return; | |
235 | |
236 if(!strcmp(type, "get")) { | |
237 xmlnode *query, *identity, *feature; | |
238 JabberIq *iq = jabber_iq_new_query(js, JABBER_IQ_RESULT, | |
239 "http://jabber.org/protocol/disco#info"); | |
240 | |
241 jabber_iq_set_id(iq, xmlnode_get_attrib(packet, "id")); | |
242 | |
243 xmlnode_set_attrib(iq->node, "to", from); | |
244 query = xmlnode_get_child(iq->node, "query"); | |
245 | |
246 identity = xmlnode_new_child(query, "identity"); | |
247 xmlnode_set_attrib(identity, "category", "client"); | |
248 xmlnode_set_attrib(identity, "type", "pc"); /* XXX: bot, console, | |
249 * handheld, pc, phone, | |
250 * web */ | |
251 | |
252 SUPPORT_FEATURE("jabber:iq:last") | |
253 SUPPORT_FEATURE("jabber:iq:oob") | |
254 SUPPORT_FEATURE("jabber:iq:time") | |
255 SUPPORT_FEATURE("jabber:iq:version") | |
256 SUPPORT_FEATURE("jabber:x:conference") | |
7425 | 257 /* |
7395 | 258 SUPPORT_FEATURE("http://jabber.org/protocol/bytestreams") |
7425 | 259 */ |
7395 | 260 SUPPORT_FEATURE("http://jabber.org/protocol/disco#info") |
261 SUPPORT_FEATURE("http://jabber.org/protocol/disco#items") | |
262 SUPPORT_FEATURE("http://jabber.org/protocol/muc") | |
263 SUPPORT_FEATURE("http://jabber.org/protocol/muc#user") | |
7425 | 264 /* |
7395 | 265 SUPPORT_FEATURE("http://jabber.org/protocol/si") |
266 SUPPORT_FEATURE("http://jabber.org/protocol/si/profile/file-transfer") | |
7425 | 267 */ |
7395 | 268 |
269 jabber_iq_send(iq); | |
270 }else if(!strcmp(type, "result")) { | |
271 xmlnode *query = xmlnode_get_child(packet, "query"); | |
272 xmlnode *child; | |
273 JabberID *jid; | |
274 JabberBuddy *jb; | |
275 JabberBuddyResource *jbr = NULL; | |
276 | |
277 if(!(jid = jabber_id_new(from))) | |
278 return; | |
279 | |
280 if(jid->resource && (jb = jabber_buddy_find(js, from, TRUE))) | |
281 jbr = jabber_buddy_find_resource(jb, jid->resource); | |
7445 | 282 jabber_id_free(jid); |
7395 | 283 |
7445 | 284 if(!jbr) |
7395 | 285 return; |
286 | |
287 for(child = query->child; child; child = child->next) { | |
288 if(child->type != NODE_TYPE_TAG) | |
289 continue; | |
290 | |
291 if(!strcmp(child->name, "feature")) { | |
292 const char *var = xmlnode_get_attrib(child, "var"); | |
293 if(!var) | |
294 continue; | |
295 | |
296 if(!strcmp(var, "http://jabber.org/protocol/si")) | |
297 jbr->capabilities |= JABBER_CAP_SI; | |
298 else if(!strcmp(var, | |
299 "http://jabber.org/protocol/si/profile/file-transfer")) | |
300 jbr->capabilities |= JABBER_CAP_SI_FILE_XFER; | |
301 else if(!strcmp(var, "http://jabber.org/protocol/bytestreams")) | |
302 jbr->capabilities |= JABBER_CAP_BYTESTREAMS; | |
303 } | |
304 } | |
305 } | |
306 } | |
307 | |
308 void jabber_disco_items_parse(JabberStream *js, xmlnode *packet) { | |
309 const char *from = xmlnode_get_attrib(packet, "from"); | |
310 const char *type = xmlnode_get_attrib(packet, "type"); | |
311 | |
312 if(!strcmp(type, "get")) { | |
313 JabberIq *iq = jabber_iq_new_query(js, JABBER_IQ_RESULT, | |
314 "http://jabber.org/protocol/disco#items"); | |
315 | |
316 jabber_iq_set_id(iq, xmlnode_get_attrib(packet, "id")); | |
317 | |
318 xmlnode_set_attrib(iq->node, "to", from); | |
319 jabber_iq_send(iq); | |
320 } | |
321 } | |
322 | |
7014 | 323 void jabber_iq_parse(JabberStream *js, xmlnode *packet) |
324 { | |
7395 | 325 JabberCallbackData *jcd; |
7014 | 326 xmlnode *query; |
327 const char *xmlns; | |
7395 | 328 const char *type, *id; |
7014 | 329 |
330 query = xmlnode_get_child(packet, "query"); | |
331 | |
7395 | 332 if(query) { |
7014 | 333 |
7395 | 334 xmlns = xmlnode_get_attrib(query, "xmlns"); |
7014 | 335 |
7395 | 336 if(!xmlns) |
337 return; | |
7014 | 338 |
7395 | 339 if(!strcmp(xmlns, "jabber:iq:roster")) { |
340 jabber_roster_parse(js, packet); | |
341 return; | |
342 } else if(!strcmp(xmlns, "jabber:iq:last")) { | |
343 jabber_iq_handle_last(js, packet); | |
344 return; | |
345 } else if(!strcmp(xmlns, "jabber:iq:time")) { | |
346 jabber_iq_handle_time(js, packet); | |
347 return; | |
348 } else if(!strcmp(xmlns, "jabber:iq:version")) { | |
349 jabber_iq_handle_version(js, packet); | |
350 return; | |
351 } else if(!strcmp(xmlns, "jabber:iq:register")) { | |
352 jabber_register_parse(js, packet); | |
353 return; | |
354 } else if(!strcmp(xmlns, "jabber:iq:oob")) { | |
355 jabber_oob_parse(js, packet); | |
356 return; | |
357 } else if(!strcmp(xmlns, "http://jabber.org/protocol/disco#info")) { | |
358 jabber_disco_info_parse(js, packet); | |
359 return; | |
360 } else if(!strcmp(xmlns, "http://jabber.org/protocol/disco#items")) { | |
361 jabber_disco_items_parse(js, packet); | |
362 return; | |
363 } | |
7514 | 364 /* |
7395 | 365 } else if(xmlnode_get_child(packet, "si")) { |
366 jabber_si_parse(js, packet); | |
367 return; | |
7514 | 368 */ |
7395 | 369 } |
370 | |
371 /* If we got here, no pre-defined handlers got it, lets see if a special | |
372 * callback got registered */ | |
373 | |
374 type = xmlnode_get_attrib(packet, "type"); | |
375 id = xmlnode_get_attrib(packet, "id"); | |
376 | |
377 if(type && (!strcmp(type, "result") || !strcmp(type, "error")) && id | |
378 && *id && (jcd = g_hash_table_lookup(js->callbacks, id))) { | |
379 jcd->callback(js, packet, jcd->data); | |
7435 | 380 g_hash_table_remove(js->callbacks, id); |
7014 | 381 } |
382 } | |
383 |