Mercurial > pidgin
annotate src/protocols/bonjour/jabber.c @ 13900:47c3d00713af
[gaim-migrate @ 16386]
sf patch #1497232, from Jono Cole, "Segfault in bonjour
when another protocol is logged in"
"The Bonjour protocol plugin was causing Gaim to
segfault on receiving a message when other protocols
were logged in. This is dependant on the active buddies
in the buddy list and has been noticed the most when
msn is used."
committer: Tailor Script <tailor@pidgin.im>
author | Mark Doliner <mark@kingant.net> |
---|---|
date | Sat, 01 Jul 2006 18:04:55 +0000 |
parents | d1088b7771d4 |
children | 425e0f861e88 |
rev | line source |
---|---|
11477 | 1 /* |
2 * gaim - Bonjour Protocol Plugin | |
3 * | |
4 * Gaim is the legal property of its developers, whose names are too numerous | |
5 * to list here. Please refer to the COPYRIGHT file distributed with this | |
6 * source distribution. | |
7 * | |
8 * This program is free software; you can redistribute it and/or modify | |
9 * it under the terms of the GNU General Public License as published by | |
10 * the Free Software Foundation; either version 2 of the License, or | |
11 * (at your option) any later version. | |
12 * | |
13 * This program is distributed in the hope that it will be useful, | |
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of | |
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | |
16 * GNU General Public License for more details. | |
17 * | |
18 * You should have received a copy of the GNU General Public License | |
19 * along with this program; if not, write to the Free Software | |
20 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA | |
21 */ | |
11688
1fd2a974379f
[gaim-migrate @ 13974]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
11539
diff
changeset
|
22 #ifndef _WIN32 |
11477 | 23 #include <sys/socket.h> |
24 #include <netinet/in.h> | |
25 #include <arpa/inet.h> | |
11688
1fd2a974379f
[gaim-migrate @ 13974]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
11539
diff
changeset
|
26 #else |
1fd2a974379f
[gaim-migrate @ 13974]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
11539
diff
changeset
|
27 #include "libc_interface.h" |
1fd2a974379f
[gaim-migrate @ 13974]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
11539
diff
changeset
|
28 #endif |
1fd2a974379f
[gaim-migrate @ 13974]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
11539
diff
changeset
|
29 #include <sys/types.h> |
11477 | 30 #include <glib.h> |
31 #include <glib/gprintf.h> | |
32 #include <unistd.h> | |
33 #include <fcntl.h> | |
34 | |
35 #include "network.h" | |
36 #include "eventloop.h" | |
37 #include "connection.h" | |
38 #include "blist.h" | |
39 #include "xmlnode.h" | |
40 #include "debug.h" | |
41 #include "notify.h" | |
42 #include "util.h" | |
43 | |
44 #include "jabber.h" | |
45 #include "bonjour.h" | |
46 #include "buddy.h" | |
47 | |
12443 | 48 static gint |
11539 | 49 _connect_to_buddy(GaimBuddy *gb) |
11477 | 50 { |
51 gint socket_fd; | |
52 gint retorno = 0; | |
53 struct sockaddr_in buddy_address; | |
11539 | 54 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
55 /* Create a socket and make it non-blocking */ |
11477 | 56 socket_fd = socket(PF_INET, SOCK_STREAM, 0); |
11539 | 57 |
11477 | 58 buddy_address.sin_family = PF_INET; |
59 buddy_address.sin_port = htons(((BonjourBuddy*)(gb->proto_data))->port_p2pj); | |
60 inet_aton(((BonjourBuddy*)(gb->proto_data))->ip, &(buddy_address.sin_addr)); | |
61 memset(&(buddy_address.sin_zero), '\0', 8); | |
11539 | 62 |
11477 | 63 retorno = connect(socket_fd, (struct sockaddr*)&buddy_address, sizeof(struct sockaddr)); |
64 if (retorno == -1) { | |
11823 | 65 gaim_debug_warning("bonjour", "connect error: %s\n", strerror(errno)); |
11477 | 66 } |
67 fcntl(socket_fd, F_SETFL, O_NONBLOCK); | |
68 | |
69 return socket_fd; | |
70 } | |
71 | |
12443 | 72 #if 0 /* this isn't used anywhere... */ |
73 static const char * | |
11539 | 74 _font_size_gaim_to_ichat(int size) |
11477 | 75 { |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
76 switch (size) { |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
77 case 1: |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
78 return "8"; |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
79 case 2: |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
80 return "10"; |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
81 case 3: |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
82 return "12"; |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
83 case 4: |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
84 return "14"; |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
85 case 5: |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
86 return "17"; |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
87 case 6: |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
88 return "21"; |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
89 case 7: |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
90 return "24"; |
11477 | 91 } |
11539 | 92 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
93 return "12"; |
11477 | 94 } |
12443 | 95 #endif |
11477 | 96 |
12443 | 97 static const char * |
11539 | 98 _font_size_ichat_to_gaim(int size) |
11477 | 99 { |
100 if (size > 24) { | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
101 return "7"; |
11539 | 102 } else if (size >= 21) { |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
103 return "6"; |
11539 | 104 } else if (size >= 17) { |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
105 return "5"; |
11539 | 106 } else if (size >= 14) { |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
107 return "4"; |
11539 | 108 } else if (size >= 12) { |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
109 return "3"; |
11539 | 110 } else if (size >= 10) { |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
111 return "2"; |
11477 | 112 } |
113 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
114 return "1"; |
11477 | 115 } |
12443 | 116 static void |
11539 | 117 _jabber_parse_and_write_message_to_ui(char *message, GaimConnection *connection, GaimBuddy *gb) |
11477 | 118 { |
11539 | 119 xmlnode *body_node = NULL; |
120 char *body = NULL; | |
121 xmlnode *html_node = NULL; | |
11477 | 122 gboolean isHTML = FALSE; |
11539 | 123 xmlnode *html_body_node = NULL; |
124 const char *ichat_balloon_color = NULL; | |
125 const char *ichat_text_color = NULL; | |
126 xmlnode *html_body_font_node = NULL; | |
127 const char *font_face = NULL; | |
128 const char *font_size = NULL; | |
129 const char *font_color = NULL; | |
130 char *html_body = NULL; | |
131 xmlnode *events_node = NULL; | |
11477 | 132 gboolean composing_event = FALSE; |
133 gint garbage = -1; | |
11539 | 134 xmlnode *message_node = NULL; |
11477 | 135 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
136 /* Parsing of the message */ |
11477 | 137 message_node = xmlnode_from_str(message, strlen(message)); |
138 if (message_node == NULL) { | |
139 return; | |
140 } | |
11539 | 141 |
11477 | 142 body_node = xmlnode_get_child(message_node, "body"); |
143 if (body_node != NULL) { | |
144 body = xmlnode_get_data(body_node); | |
145 } else { | |
146 return; | |
147 } | |
11539 | 148 |
11477 | 149 html_node = xmlnode_get_child(message_node, "html"); |
11539 | 150 if (html_node != NULL) |
151 { | |
11477 | 152 isHTML = TRUE; |
153 html_body_node = xmlnode_get_child(html_node, "body"); | |
11539 | 154 if (html_body_node != NULL) |
155 { | |
11477 | 156 ichat_balloon_color = xmlnode_get_attrib(html_body_node, "ichatballooncolor"); |
157 ichat_text_color = xmlnode_get_attrib(html_body_node, "ichattextcolor"); | |
158 html_body_font_node = xmlnode_get_child(html_body_node, "font"); | |
11539 | 159 if (html_body_font_node != NULL) |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
160 { /* Types of messages sent by iChat */ |
11477 | 161 font_face = xmlnode_get_attrib(html_body_font_node, "face"); |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
162 /* The absolute iChat font sizes should be converted to 1..7 range */ |
11477 | 163 font_size = xmlnode_get_attrib(html_body_font_node, "ABSZ"); |
11539 | 164 if (font_size != NULL) |
165 { | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
166 font_size = _font_size_ichat_to_gaim(atoi(font_size)); |
11477 | 167 } |
168 font_color = xmlnode_get_attrib(html_body_font_node, "color"); | |
169 html_body = xmlnode_get_data(html_body_font_node); | |
11539 | 170 if (html_body == NULL) |
171 { | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
172 /* This is the kind of formated messages that Gaim creates */ |
11477 | 173 html_body = xmlnode_to_str(html_body_font_node, &garbage); |
174 } | |
175 } else { | |
176 isHTML = FALSE; | |
177 } | |
178 } else { | |
179 isHTML = FALSE; | |
180 } | |
11539 | 181 |
11477 | 182 } |
11539 | 183 |
11477 | 184 events_node = xmlnode_get_child_with_namespace(message_node, "x", "jabber:x:event"); |
11539 | 185 if (events_node != NULL) |
186 { | |
187 if (xmlnode_get_child(events_node, "composing") != NULL) | |
188 { | |
11477 | 189 composing_event = TRUE; |
190 } | |
11539 | 191 if (xmlnode_get_child(events_node, "id") != NULL) |
192 { | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
193 /* The user is just typing */ |
11477 | 194 xmlnode_free(message_node); |
195 g_free(body); | |
196 g_free(html_body); | |
197 return; | |
198 } | |
199 } | |
11539 | 200 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
201 /* Compose the message */ |
11539 | 202 if (isHTML) |
203 { | |
11477 | 204 if (font_face == NULL) font_face = "Helvetica"; |
205 if (font_size == NULL) font_size = "3"; | |
206 if (ichat_text_color == NULL) ichat_text_color = "#000000"; | |
207 if (ichat_balloon_color == NULL) ichat_balloon_color = "#FFFFFF"; | |
11539 | 208 body = g_strconcat("<font face='", font_face, "' size='", font_size, "' color='", ichat_text_color, |
11477 | 209 "' back='", ichat_balloon_color, "'>", html_body, "</font>", NULL); |
210 } | |
11539 | 211 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
212 /* Send the message to the UI */ |
11477 | 213 serv_got_im(connection, gb->name, body, 0, time(NULL)); |
11539 | 214 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
215 /* Free all the strings and nodes (the attributes are freed with their nodes) */ |
11477 | 216 xmlnode_free(message_node); |
217 g_free(body); | |
218 g_free(html_body); | |
219 } | |
220 | |
12708 | 221 struct _check_buddy_by_address_t { |
222 char *address; | |
223 GaimBuddy **gb; | |
13900 | 224 BonjourJabber *bj; |
12708 | 225 }; |
226 | |
227 static void | |
228 _check_buddy_by_address(gpointer key, gpointer value, gpointer data) | |
11477 | 229 { |
11539 | 230 GaimBuddy *gb = (GaimBuddy*)value; |
13900 | 231 BonjourBuddy *bb; |
232 struct _check_buddy_by_address_t *cbba; | |
233 | |
234 gb = value; | |
235 cbba = data; | |
11539 | 236 |
13900 | 237 /* |
238 * If the current GaimBuddy's data is not null and the GaimBuddy's account | |
239 * is the same as the account requesting the check then continue to determine | |
240 * whether the buddies IP matches the target IP. | |
241 */ | |
242 if (cbba->bj->account == gb->account) | |
243 { | |
244 bb = gb->proto_data; | |
245 if ((bb != NULL) && (g_strcasecmp(bb->ip, cbba->address) == 0)) | |
246 *(cbba->gb) = gb; | |
11477 | 247 } |
248 } | |
249 | |
12443 | 250 static gint |
11539 | 251 _read_data(gint socket, char **message) |
11477 | 252 { |
11539 | 253 GString *data = g_string_new(""); |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
254 char partial_data[512]; |
11477 | 255 gint total_message_length = 0; |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
256 gint partial_message_length = 0; |
11477 | 257 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
258 /* Read chunks of 512 bytes till the end of the data */ |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
259 while ((partial_message_length = recv(socket, partial_data, 512, 0)) > 0) |
11539 | 260 { |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
261 g_string_append_len(data, partial_data, partial_message_length); |
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
262 total_message_length += partial_message_length; |
11477 | 263 } |
11539 | 264 |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
265 if (partial_message_length == -1) |
11539 | 266 { |
11823 | 267 gaim_debug_warning("bonjour", "receive error: %s\n", strerror(errno)); |
11477 | 268 if (total_message_length == 0) { |
269 return -1; | |
270 } | |
271 } | |
272 | |
273 *message = data->str; | |
274 g_string_free(data, FALSE); | |
11539 | 275 if (total_message_length != 0) |
276 gaim_debug_info("bonjour", "Receive: -%s- %d bytes\n", *message, total_message_length); | |
277 | |
11477 | 278 return total_message_length; |
279 } | |
280 | |
12443 | 281 static gint |
11539 | 282 _send_data(gint socket, char *message) |
11477 | 283 { |
284 gint message_len = strlen(message); | |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
285 gint partial_sent = 0; |
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
286 gchar *partial_message = message; |
11539 | 287 |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
288 while ((partial_sent = send(socket, partial_message, message_len, 0)) < message_len) |
11539 | 289 { |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
290 if (partial_sent != -1) { |
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
291 partial_message += partial_sent; |
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
292 message_len -= partial_sent; |
11477 | 293 } else { |
294 return -1; | |
295 } | |
296 } | |
11539 | 297 |
11477 | 298 return strlen(message); |
299 } | |
300 | |
12443 | 301 static void |
11539 | 302 _client_socket_handler(gpointer data, gint socket, GaimInputCondition condition) |
11477 | 303 { |
11539 | 304 char *message = NULL; |
11477 | 305 gint message_length; |
11539 | 306 GaimBuddy *gb = (GaimBuddy*)data; |
307 GaimAccount *account = gb->account; | |
308 GaimConversation *conversation; | |
309 char *closed_conv_message; | |
310 BonjourBuddy *bb = (BonjourBuddy*)gb->proto_data; | |
11477 | 311 gboolean closed_conversation = FALSE; |
312 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
313 /* Read the data from the socket */ |
11477 | 314 if ((message_length = _read_data(socket, &message)) == -1) { |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
315 /* There have been an error reading from the socket */ |
11477 | 316 return; |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
317 } else if (message_length == 0) { /* The other end has closed the socket */ |
11477 | 318 closed_conversation = TRUE; |
319 } else { | |
320 message[message_length] = '\0'; | |
11539 | 321 |
11477 | 322 while (g_ascii_iscntrl(message[message_length - 1])) { |
323 message[message_length - 1] = '\0'; | |
324 message_length--; | |
325 } | |
326 } | |
11539 | 327 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
328 /* Check if the start of the doctype has been received, if not check that the current */ |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
329 /* data is the doctype */ |
11539 | 330 if (!(bb->conversation->start_step_one)) |
331 { | |
332 if (g_str_has_prefix(message, DOCTYPE_DECLARATION)) | |
333 { | |
11477 | 334 bb->conversation->start_step_one = TRUE; |
335 } | |
336 } | |
11539 | 337 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
338 /* Check if the start of the stream has been received, if not check that the current */ |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
339 /* data is the start of the stream */ |
11539 | 340 if (!(bb->conversation->start_step_two)) |
341 { | |
11477 | 342 if (g_str_has_suffix(message, STREAM_START)) { |
343 bb->conversation->start_step_two = TRUE; | |
11539 | 344 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
345 /* If we haven't done it yet, we have to sent the start of the stream to the other buddy */ |
11477 | 346 if (!(bb->conversation->stream_started)) { |
347 if (send(bb->conversation->socket, DOCTYPE, strlen(DOCTYPE), 0) == -1) { | |
348 gaim_debug_error("bonjour", "Unable to start a conversation with %s\n", bb->name); | |
349 } | |
350 } | |
351 } | |
352 return; | |
353 } | |
11539 | 354 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
355 /* Check that this is not the end of the conversation */ |
11477 | 356 if (g_str_has_prefix(message, STREAM_END) || (closed_conversation == TRUE)) { |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
357 /* Close the socket, clear the watcher and free memory */ |
11477 | 358 if (bb->conversation != NULL) { |
359 close(bb->conversation->socket); | |
360 gaim_input_remove(bb->conversation->watcher_id); | |
361 g_free(bb->conversation->buddy_name); | |
362 g_free(bb->conversation); | |
363 bb->conversation = NULL; | |
364 } | |
11539 | 365 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
366 /* Inform the user that the conversation has been closed */ |
11498 | 367 conversation = gaim_find_conversation_with_account(GAIM_CONV_TYPE_IM, gb->name, account); |
13266 | 368 closed_conv_message = g_strdup_printf(_("%s has closed the conversation."), gb->name); |
11477 | 369 gaim_conversation_write(conversation, NULL, closed_conv_message, GAIM_MESSAGE_SYSTEM, time(NULL)); |
13266 | 370 g_free(closed_conv_message); |
11477 | 371 } else { |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
372 /* Parse the message to get the data and send to the ui */ |
11477 | 373 _jabber_parse_and_write_message_to_ui(message, account->gc, gb); |
374 } | |
375 } | |
376 | |
12443 | 377 static void |
11539 | 378 _server_socket_handler(gpointer data, int server_socket, GaimInputCondition condition) |
11477 | 379 { |
11539 | 380 GaimBuddy *gb = NULL; |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
381 struct sockaddr_in their_addr; /* connector's address information */ |
11515 | 382 socklen_t sin_size = sizeof(struct sockaddr); |
11477 | 383 int client_socket; |
11539 | 384 BonjourBuddy *bb = NULL; |
13900 | 385 BonjourJabber *bj = data; |
11539 | 386 char *address_text = NULL; |
387 GaimBuddyList *bl = gaim_get_blist(); | |
12733 | 388 struct _check_buddy_by_address_t *cbba; |
11477 | 389 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
390 /* Check that it is a read condition */ |
11477 | 391 if (condition != GAIM_INPUT_READ) { |
392 return; | |
393 } | |
394 | |
11539 | 395 if ((client_socket = accept(server_socket, (struct sockaddr *)&their_addr, &sin_size)) == -1) |
396 { | |
11477 | 397 return; |
398 } | |
399 fcntl(client_socket, F_SETFL, O_NONBLOCK); | |
400 | |
13900 | 401 /* Look for the buddy that has opened the conversation and fill information */ |
11477 | 402 address_text = inet_ntoa(their_addr.sin_addr); |
12733 | 403 cbba = g_new0(struct _check_buddy_by_address_t, 1); |
12708 | 404 cbba->address = address_text; |
405 cbba->gb = &gb; | |
13900 | 406 cbba->bj = bj; |
13249 | 407 g_hash_table_foreach(bl->buddies, _check_buddy_by_address, cbba); |
12708 | 408 g_free(cbba); |
11539 | 409 if (gb == NULL) |
410 { | |
11477 | 411 gaim_debug_info("bonjour", "We don't like invisible buddies, this is not a superheros comic\n"); |
412 close(client_socket); | |
413 return; | |
414 } | |
415 bb = (BonjourBuddy*)gb->proto_data; | |
416 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
417 /* Check if the conversation has been previously started */ |
11539 | 418 if (bb->conversation == NULL) |
419 { | |
11477 | 420 bb->conversation = g_new(BonjourJabberConversation, 1); |
421 bb->conversation->socket = client_socket; | |
422 bb->conversation->start_step_one = FALSE; | |
423 bb->conversation->start_step_two = FALSE; | |
424 bb->conversation->stream_started = FALSE; | |
425 bb->conversation->buddy_name = g_strdup(gb->name); | |
426 bb->conversation->message_id = 1; | |
11539 | 427 |
11477 | 428 if (bb->conversation->stream_started == FALSE) { |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
429 /* Start the stream */ |
11477 | 430 send(bb->conversation->socket, DOCTYPE, strlen(DOCTYPE), 0); |
431 bb->conversation->stream_started = TRUE; | |
432 } | |
433 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
434 /* Open a watcher for the client socket */ |
11539 | 435 bb->conversation->watcher_id = gaim_input_add(client_socket, GAIM_INPUT_READ, |
11477 | 436 _client_socket_handler, gb); |
437 } else { | |
438 close(client_socket); | |
439 } | |
440 } | |
441 | |
11539 | 442 gint |
443 bonjour_jabber_start(BonjourJabber *data) | |
11477 | 444 { |
445 struct sockaddr_in my_addr; | |
446 int yes = 1; | |
447 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
448 /* Open a listening socket for incoming conversations */ |
11539 | 449 if ((data->socket = socket(PF_INET, SOCK_STREAM, 0)) < 0) |
450 { | |
13266 | 451 gaim_debug_error("bonjour", "Cannot open socket: %s\n", strerror(errno)); |
452 gaim_connection_error(data->account->gc, _("Cannot open socket")); | |
11477 | 453 return -1; |
454 } | |
11539 | 455 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
456 /* Make the socket reusable */ |
11539 | 457 if (setsockopt(data->socket, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int)) != 0) |
458 { | |
13266 | 459 gaim_debug_error("bonjour", "Error setting socket options: %s\n", strerror(errno)); |
460 gaim_connection_error(data->account->gc, _("Error setting socket options")); | |
11477 | 461 return -1; |
462 } | |
463 | |
464 memset(&my_addr, 0, sizeof(struct sockaddr_in)); | |
465 my_addr.sin_family = PF_INET; | |
466 my_addr.sin_port = htons(data->port); | |
11539 | 467 |
468 if (bind(data->socket, (struct sockaddr*)&my_addr, sizeof(struct sockaddr)) != 0) | |
469 { | |
13266 | 470 gaim_debug_error("bonjour", "Cannot bind socket: %s\n", strerror(errno)); |
471 gaim_connection_error(data->account->gc, _("Cannot bind socket to port")); | |
11477 | 472 return -1; |
473 } | |
11539 | 474 |
475 if (listen(data->socket, 10) != 0) | |
476 { | |
13266 | 477 gaim_debug_error("bonjour", "Cannot listen on socket: %s\n", strerror(errno)); |
478 gaim_connection_error(data->account->gc, _("Cannot listen on socket")); | |
11477 | 479 return -1; |
480 } | |
481 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
482 #if 0 |
12730
d5b8f4dc1622
[gaim-migrate @ 15074]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12708
diff
changeset
|
483 /* TODO: Why isn't this being used? */ |
d5b8f4dc1622
[gaim-migrate @ 15074]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12708
diff
changeset
|
484 data->socket = gaim_network_listen(data->port, SOCK_STREAM); |
11477 | 485 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
486 if (data->socket == -1) |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
487 { |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
488 gaim_debug_error("bonjour", "No se ha podido crear el socket\n"); |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
489 } |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
490 #endif |
11477 | 491 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
492 /* Open a watcher in the socket we have just opened */ |
11477 | 493 data->watcher_id = gaim_input_add(data->socket, GAIM_INPUT_READ, _server_socket_handler, data); |
11539 | 494 |
11477 | 495 return 0; |
496 } | |
497 | |
11693 | 498 int |
11539 | 499 bonjour_jabber_send_message(BonjourJabber *data, const gchar *to, const gchar *body) |
11477 | 500 { |
11539 | 501 xmlnode *message_node = NULL; |
502 gchar *message = NULL; | |
11477 | 503 gint message_length = -1; |
11539 | 504 xmlnode *message_body_node = NULL; |
505 xmlnode *message_html_node = NULL; | |
506 xmlnode *message_html_body_node = NULL; | |
507 xmlnode *message_html_body_font_node = NULL; | |
508 xmlnode *message_x_node = NULL; | |
11693 | 509 GaimBuddy *gb = NULL; |
510 BonjourBuddy *bb = NULL; | |
11539 | 511 char *conv_message = NULL; |
512 GaimConversation *conversation = NULL; | |
513 char *message_from_ui = NULL; | |
514 char *stripped_message = NULL; | |
515 | |
11693 | 516 gb = gaim_find_buddy(data->account, to); |
517 if (gb == NULL) | |
518 /* You can not send a message to an offline buddy */ | |
519 return -10000; | |
520 | |
521 bb = (BonjourBuddy *)gb->proto_data; | |
522 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
523 /* Enclose the message from the UI within a "font" node */ |
11477 | 524 message_body_node = xmlnode_new("body"); |
525 stripped_message = gaim_markup_strip_html(body); | |
526 xmlnode_insert_data(message_body_node, stripped_message, strlen(stripped_message)); | |
11539 | 527 |
11477 | 528 message_from_ui = g_strconcat("<font>", body, "</font>", NULL); |
529 message_html_body_font_node = xmlnode_from_str(message_from_ui, strlen(message_from_ui)); | |
11539 | 530 |
11477 | 531 message_html_body_node = xmlnode_new("body"); |
532 xmlnode_insert_child(message_html_body_node, message_html_body_font_node); | |
11539 | 533 |
11477 | 534 message_html_node = xmlnode_new("html"); |
535 xmlnode_set_attrib(message_html_node, "xmlns", "http://www.w3.org/1999/xhtml"); | |
536 xmlnode_insert_child(message_html_node, message_html_body_node); | |
537 | |
538 message_x_node = xmlnode_new("x"); | |
539 xmlnode_set_attrib(message_x_node, "xmlns", "jabber:x:event"); | |
540 xmlnode_insert_child(message_x_node, xmlnode_new("composing")); | |
11539 | 541 |
11477 | 542 message_node = xmlnode_new("message"); |
543 xmlnode_set_attrib(message_node, "to", ((BonjourBuddy*)(gb->proto_data))->name); | |
544 xmlnode_set_attrib(message_node, "type", "chat"); | |
545 xmlnode_insert_child(message_node, message_body_node); | |
546 xmlnode_insert_child(message_node, message_html_node); | |
547 xmlnode_insert_child(message_node, message_x_node); | |
11539 | 548 |
11477 | 549 message = xmlnode_to_str(message_node, &message_length); |
550 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
551 /* Check if there is a previously open conversation */ |
11539 | 552 if (bb->conversation == NULL) |
553 { | |
11477 | 554 bb->conversation = g_new(BonjourJabberConversation, 1); |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
555 bb->conversation->socket = _connect_to_buddy(gb); |
11477 | 556 bb->conversation->start_step_one = FALSE; |
557 bb->conversation->start_step_two = FALSE; | |
558 bb->conversation->stream_started = FALSE; | |
559 bb->conversation->buddy_name = g_strdup(gb->name); | |
11539 | 560 bb->conversation->watcher_id = gaim_input_add(bb->conversation->socket, |
11477 | 561 GAIM_INPUT_READ, _client_socket_handler, gb); |
562 } | |
563 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
564 /* Check if the stream for the conversation has been started */ |
11539 | 565 if (bb->conversation->stream_started == FALSE) |
566 { | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
567 /* Start the stream */ |
11539 | 568 if (send(bb->conversation->socket, DOCTYPE, strlen(DOCTYPE), 0) == -1) |
569 { | |
11477 | 570 gaim_debug_error("bonjour", "Unable to start a conversation\n"); |
11823 | 571 gaim_debug_warning("bonjour", "send error: %s\n", strerror(errno)); |
13266 | 572 conv_message = g_strdup(_("Unable to send the message, the conversation couldn't be started.")); |
11498 | 573 conversation = gaim_find_conversation_with_account(GAIM_CONV_TYPE_IM, bb->name, data->account); |
11477 | 574 gaim_conversation_write(conversation, NULL, conv_message, GAIM_MESSAGE_SYSTEM, time(NULL)); |
575 close(bb->conversation->socket); | |
576 gaim_input_remove(bb->conversation->watcher_id); | |
11539 | 577 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
578 /* Free all the data related to the conversation */ |
11477 | 579 g_free(bb->conversation->buddy_name); |
580 g_free(bb->conversation); | |
581 bb->conversation = NULL; | |
11693 | 582 return 0; |
11477 | 583 } |
11539 | 584 |
11477 | 585 bb->conversation->stream_started = TRUE; |
586 } | |
11539 | 587 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
588 /* Send the message */ |
11539 | 589 if (_send_data(bb->conversation->socket, message) == -1) |
11693 | 590 return -10000; |
591 | |
592 return 1; | |
11477 | 593 } |
594 | |
11539 | 595 void |
596 bonjour_jabber_close_conversation(BonjourJabber *data, GaimBuddy *gb) | |
11477 | 597 { |
11539 | 598 BonjourBuddy *bb = (BonjourBuddy*)gb->proto_data; |
599 | |
600 if (bb->conversation != NULL) | |
601 { | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
602 /* Send the end of the stream to the other end of the conversation */ |
11477 | 603 send(bb->conversation->socket, STREAM_END, strlen(STREAM_END), 0); |
11539 | 604 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
605 /* Close the socket and remove the watcher */ |
11477 | 606 close(bb->conversation->socket); |
607 gaim_input_remove(bb->conversation->watcher_id); | |
11539 | 608 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
609 /* Free all the data related to the conversation */ |
11477 | 610 g_free(bb->conversation->buddy_name); |
611 g_free(bb->conversation); | |
612 bb->conversation = NULL; | |
613 } | |
614 } | |
615 | |
11539 | 616 void |
617 bonjour_jabber_stop(BonjourJabber *data) | |
11477 | 618 { |
11539 | 619 GaimBuddy *gb = NULL; |
620 BonjourBuddy *bb = NULL; | |
621 GSList *buddies; | |
622 GSList *l; | |
623 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
624 /* Close the server socket and remove all the watcher */ |
11477 | 625 close(data->socket); |
626 gaim_input_remove(data->watcher_id); | |
11539 | 627 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
628 /* Close all the sockets and remove all the watchers after sending end streams */ |
11539 | 629 if (data->account->gc != NULL) |
630 { | |
11477 | 631 buddies = gaim_find_buddies(data->account, data->account->username); |
11539 | 632 for (l = buddies; l; l = l->next) |
633 { | |
11477 | 634 gb = (GaimBuddy*)l->data; |
635 bb = (BonjourBuddy*)gb->proto_data; | |
11539 | 636 if (bb->conversation != NULL) |
637 { | |
11477 | 638 send(bb->conversation->socket, STREAM_END, strlen(STREAM_END), 0); |
639 close(bb->conversation->socket); | |
640 gaim_input_remove(bb->conversation->watcher_id); | |
641 } | |
642 } | |
643 g_slist_free(buddies); | |
644 } | |
645 } |