Mercurial > pidgin.yaz
annotate src/protocols/bonjour/jabber.c @ 12730:d5b8f4dc1622
[gaim-migrate @ 15074]
Update gaim_network_listen*() to have the socket type specified. This allows us to use the same functionality to listen on UDP sockets too. There are probably a couple things that should be updated to use this. I also updated SIMPLE to allow the connect port to be specified in the account options.
committer: Tailor Script <tailor@pidgin.im>
author | Daniel Atallah <daniel.atallah@gmail.com> |
---|---|
date | Thu, 05 Jan 2006 05:04:07 +0000 |
parents | 495856ce025b |
children | b6577059c9e5 |
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; | |
224 }; | |
225 | |
226 static void | |
227 _check_buddy_by_address(gpointer key, gpointer value, gpointer data) | |
11477 | 228 { |
11539 | 229 GaimBuddy *gb = (GaimBuddy*)value; |
230 BonjourBuddy *bb = (BonjourBuddy*)gb->proto_data; | |
12708 | 231 struct _check_buddy_by_address_t *d = (struct _check_buddy_by_address_t *)data; |
11539 | 232 |
12708 | 233 if (bb != NULL) { |
234 if (g_strcasecmp(bb->ip, (char*)d->address) == 0) | |
235 *(d->gb) = gb; | |
11477 | 236 } |
237 } | |
238 | |
12443 | 239 static gint |
11539 | 240 _read_data(gint socket, char **message) |
11477 | 241 { |
11539 | 242 GString *data = g_string_new(""); |
11477 | 243 char parcial_data[512]; |
244 gint total_message_length = 0; | |
245 gint parcial_message_length = 0; | |
246 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
247 /* Read chunks of 512 bytes till the end of the data */ |
11539 | 248 while ((parcial_message_length = recv(socket, parcial_data, 512, 0)) > 0) |
249 { | |
11477 | 250 g_string_append_len(data, parcial_data, parcial_message_length); |
251 total_message_length += parcial_message_length; | |
252 } | |
11539 | 253 |
254 if (parcial_message_length == -1) | |
255 { | |
11823 | 256 gaim_debug_warning("bonjour", "receive error: %s\n", strerror(errno)); |
11477 | 257 if (total_message_length == 0) { |
258 return -1; | |
259 } | |
260 } | |
261 | |
262 *message = data->str; | |
263 g_string_free(data, FALSE); | |
11539 | 264 if (total_message_length != 0) |
265 gaim_debug_info("bonjour", "Receive: -%s- %d bytes\n", *message, total_message_length); | |
266 | |
11477 | 267 return total_message_length; |
268 } | |
269 | |
12443 | 270 static gint |
11539 | 271 _send_data(gint socket, char *message) |
11477 | 272 { |
273 gint message_len = strlen(message); | |
274 gint parcial_sent = 0; | |
11539 | 275 gchar *parcial_message = message; |
276 | |
277 while ((parcial_sent = send(socket, parcial_message, message_len, 0)) < message_len) | |
278 { | |
11477 | 279 if (parcial_sent != -1) { |
280 parcial_message += parcial_sent; | |
281 message_len -= parcial_sent; | |
282 } else { | |
283 return -1; | |
284 } | |
285 } | |
11539 | 286 |
11477 | 287 return strlen(message); |
288 } | |
289 | |
12443 | 290 static void |
11539 | 291 _client_socket_handler(gpointer data, gint socket, GaimInputCondition condition) |
11477 | 292 { |
11539 | 293 char *message = NULL; |
11477 | 294 gint message_length; |
11539 | 295 GaimBuddy *gb = (GaimBuddy*)data; |
296 GaimAccount *account = gb->account; | |
297 GaimConversation *conversation; | |
298 char *closed_conv_message; | |
299 BonjourBuddy *bb = (BonjourBuddy*)gb->proto_data; | |
11477 | 300 gboolean closed_conversation = FALSE; |
301 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
302 /* Read the data from the socket */ |
11477 | 303 if ((message_length = _read_data(socket, &message)) == -1) { |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
304 /* There have been an error reading from the socket */ |
11477 | 305 return; |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
306 } else if (message_length == 0) { /* The other end has closed the socket */ |
11477 | 307 closed_conversation = TRUE; |
308 } else { | |
309 message[message_length] = '\0'; | |
11539 | 310 |
11477 | 311 while (g_ascii_iscntrl(message[message_length - 1])) { |
312 message[message_length - 1] = '\0'; | |
313 message_length--; | |
314 } | |
315 } | |
11539 | 316 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
317 /* 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
|
318 /* data is the doctype */ |
11539 | 319 if (!(bb->conversation->start_step_one)) |
320 { | |
321 if (g_str_has_prefix(message, DOCTYPE_DECLARATION)) | |
322 { | |
11477 | 323 bb->conversation->start_step_one = TRUE; |
324 } | |
325 } | |
11539 | 326 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
327 /* 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
|
328 /* data is the start of the stream */ |
11539 | 329 if (!(bb->conversation->start_step_two)) |
330 { | |
11477 | 331 if (g_str_has_suffix(message, STREAM_START)) { |
332 bb->conversation->start_step_two = TRUE; | |
11539 | 333 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
334 /* If we haven't done it yet, we have to sent the start of the stream to the other buddy */ |
11477 | 335 if (!(bb->conversation->stream_started)) { |
336 if (send(bb->conversation->socket, DOCTYPE, strlen(DOCTYPE), 0) == -1) { | |
337 gaim_debug_error("bonjour", "Unable to start a conversation with %s\n", bb->name); | |
338 } | |
339 } | |
340 } | |
341 return; | |
342 } | |
11539 | 343 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
344 /* Check that this is not the end of the conversation */ |
11477 | 345 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
|
346 /* Close the socket, clear the watcher and free memory */ |
11477 | 347 if (bb->conversation != NULL) { |
348 close(bb->conversation->socket); | |
349 gaim_input_remove(bb->conversation->watcher_id); | |
350 g_free(bb->conversation->buddy_name); | |
351 g_free(bb->conversation); | |
352 bb->conversation = NULL; | |
353 } | |
11539 | 354 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
355 /* Inform the user that the conversation has been closed */ |
11498 | 356 conversation = gaim_find_conversation_with_account(GAIM_CONV_TYPE_IM, gb->name, account); |
11477 | 357 closed_conv_message = g_strconcat(gb->name, " has closed the conversation.", NULL); |
358 gaim_conversation_write(conversation, NULL, closed_conv_message, GAIM_MESSAGE_SYSTEM, time(NULL)); | |
359 } else { | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
360 /* Parse the message to get the data and send to the ui */ |
11477 | 361 _jabber_parse_and_write_message_to_ui(message, account->gc, gb); |
362 } | |
363 } | |
364 | |
12443 | 365 static void |
11539 | 366 _server_socket_handler(gpointer data, int server_socket, GaimInputCondition condition) |
11477 | 367 { |
11539 | 368 GaimBuddy *gb = NULL; |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
369 struct sockaddr_in their_addr; /* connector's address information */ |
11515 | 370 socklen_t sin_size = sizeof(struct sockaddr); |
11477 | 371 int client_socket; |
11539 | 372 BonjourBuddy *bb = NULL; |
373 char *address_text = NULL; | |
374 GaimBuddyList *bl = gaim_get_blist(); | |
11477 | 375 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
376 /* Check that it is a read condition */ |
11477 | 377 if (condition != GAIM_INPUT_READ) { |
378 return; | |
379 } | |
380 | |
11539 | 381 if ((client_socket = accept(server_socket, (struct sockaddr *)&their_addr, &sin_size)) == -1) |
382 { | |
11477 | 383 return; |
384 } | |
385 fcntl(client_socket, F_SETFL, O_NONBLOCK); | |
386 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
387 /* Look for the buddy that has open the conversation and fill information */ |
11477 | 388 address_text = inet_ntoa(their_addr.sin_addr); |
12708 | 389 struct _check_buddy_by_address_t *cbba = g_new0(struct _check_buddy_by_address_t, 1); |
390 cbba->address = address_text; | |
391 cbba->gb = &gb; | |
392 g_hash_table_foreach(bl->buddies, _check_buddy_by_address, address_text); | |
393 g_free(cbba); | |
11539 | 394 if (gb == NULL) |
395 { | |
11477 | 396 gaim_debug_info("bonjour", "We don't like invisible buddies, this is not a superheros comic\n"); |
397 close(client_socket); | |
398 return; | |
399 } | |
400 bb = (BonjourBuddy*)gb->proto_data; | |
401 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
402 /* Check if the conversation has been previously started */ |
11539 | 403 if (bb->conversation == NULL) |
404 { | |
11477 | 405 bb->conversation = g_new(BonjourJabberConversation, 1); |
406 bb->conversation->socket = client_socket; | |
407 bb->conversation->start_step_one = FALSE; | |
408 bb->conversation->start_step_two = FALSE; | |
409 bb->conversation->stream_started = FALSE; | |
410 bb->conversation->buddy_name = g_strdup(gb->name); | |
411 bb->conversation->message_id = 1; | |
11539 | 412 |
11477 | 413 if (bb->conversation->stream_started == FALSE) { |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
414 /* Start the stream */ |
11477 | 415 send(bb->conversation->socket, DOCTYPE, strlen(DOCTYPE), 0); |
416 bb->conversation->stream_started = TRUE; | |
417 } | |
418 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
419 /* Open a watcher for the client socket */ |
11539 | 420 bb->conversation->watcher_id = gaim_input_add(client_socket, GAIM_INPUT_READ, |
11477 | 421 _client_socket_handler, gb); |
422 } else { | |
423 close(client_socket); | |
424 } | |
425 } | |
426 | |
11539 | 427 gint |
428 bonjour_jabber_start(BonjourJabber *data) | |
11477 | 429 { |
430 struct sockaddr_in my_addr; | |
431 int yes = 1; | |
11539 | 432 char *error_message = NULL; |
11477 | 433 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
434 /* Open a listening socket for incoming conversations */ |
11539 | 435 if ((data->socket = socket(PF_INET, SOCK_STREAM, 0)) < 0) |
436 { | |
11477 | 437 gaim_debug_error("bonjour", "Cannot get socket\n"); |
438 error_message = strerror(errno); | |
439 gaim_debug_error("bonjour", "%s\n", error_message); | |
440 gaim_connection_error(data->account->gc, "Cannot open socket"); | |
441 return -1; | |
442 } | |
11539 | 443 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
444 /* Make the socket reusable */ |
11539 | 445 if (setsockopt(data->socket, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int)) != 0) |
446 { | |
11477 | 447 gaim_debug_error("bonjour", "Cannot make socket reusable\n"); |
448 error_message = strerror(errno); | |
449 gaim_debug_error("bonjour", "%s\n", error_message); | |
450 gaim_connection_error(data->account->gc, "Error setting socket options"); | |
451 return -1; | |
452 } | |
453 | |
454 memset(&my_addr, 0, sizeof(struct sockaddr_in)); | |
455 my_addr.sin_family = PF_INET; | |
456 my_addr.sin_port = htons(data->port); | |
11539 | 457 |
458 if (bind(data->socket, (struct sockaddr*)&my_addr, sizeof(struct sockaddr)) != 0) | |
459 { | |
11477 | 460 gaim_debug_error("bonjour", "Cannot bind socket\n"); |
461 error_message = strerror(errno); | |
462 gaim_debug_error("bonjour", "%s\n", error_message); | |
463 gaim_connection_error(data->account->gc, "Cannot bind socket to port"); | |
464 return -1; | |
465 } | |
11539 | 466 |
467 if (listen(data->socket, 10) != 0) | |
468 { | |
11477 | 469 gaim_debug_error("bonjour", "Cannot listen to socket\n"); |
470 error_message = strerror(errno); | |
471 gaim_debug_error("bonjour", "%s\n", error_message); | |
472 gaim_connection_error(data->account->gc, "Cannot listen to socket"); | |
473 return -1; | |
474 } | |
475 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
476 #if 0 |
12730
d5b8f4dc1622
[gaim-migrate @ 15074]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12708
diff
changeset
|
477 /* TODO: Why isn't this being used? */ |
d5b8f4dc1622
[gaim-migrate @ 15074]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12708
diff
changeset
|
478 data->socket = gaim_network_listen(data->port, SOCK_STREAM); |
11477 | 479 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
480 if (data->socket == -1) |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
481 { |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
482 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
|
483 } |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
484 #endif |
11477 | 485 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
486 /* Open a watcher in the socket we have just opened */ |
11477 | 487 data->watcher_id = gaim_input_add(data->socket, GAIM_INPUT_READ, _server_socket_handler, data); |
11539 | 488 |
11477 | 489 return 0; |
490 } | |
491 | |
11693 | 492 int |
11539 | 493 bonjour_jabber_send_message(BonjourJabber *data, const gchar *to, const gchar *body) |
11477 | 494 { |
11539 | 495 xmlnode *message_node = NULL; |
496 gchar *message = NULL; | |
11477 | 497 gint message_length = -1; |
11539 | 498 xmlnode *message_body_node = NULL; |
499 xmlnode *message_html_node = NULL; | |
500 xmlnode *message_html_body_node = NULL; | |
501 xmlnode *message_html_body_font_node = NULL; | |
502 xmlnode *message_x_node = NULL; | |
11693 | 503 GaimBuddy *gb = NULL; |
504 BonjourBuddy *bb = NULL; | |
11539 | 505 char *conv_message = NULL; |
506 GaimConversation *conversation = NULL; | |
507 char *message_from_ui = NULL; | |
508 char *stripped_message = NULL; | |
509 | |
11693 | 510 gb = gaim_find_buddy(data->account, to); |
511 if (gb == NULL) | |
512 /* You can not send a message to an offline buddy */ | |
513 return -10000; | |
514 | |
515 bb = (BonjourBuddy *)gb->proto_data; | |
516 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
517 /* Enclose the message from the UI within a "font" node */ |
11477 | 518 message_body_node = xmlnode_new("body"); |
519 stripped_message = gaim_markup_strip_html(body); | |
520 xmlnode_insert_data(message_body_node, stripped_message, strlen(stripped_message)); | |
11539 | 521 |
11477 | 522 message_from_ui = g_strconcat("<font>", body, "</font>", NULL); |
523 message_html_body_font_node = xmlnode_from_str(message_from_ui, strlen(message_from_ui)); | |
11539 | 524 |
11477 | 525 message_html_body_node = xmlnode_new("body"); |
526 xmlnode_insert_child(message_html_body_node, message_html_body_font_node); | |
11539 | 527 |
11477 | 528 message_html_node = xmlnode_new("html"); |
529 xmlnode_set_attrib(message_html_node, "xmlns", "http://www.w3.org/1999/xhtml"); | |
530 xmlnode_insert_child(message_html_node, message_html_body_node); | |
531 | |
532 message_x_node = xmlnode_new("x"); | |
533 xmlnode_set_attrib(message_x_node, "xmlns", "jabber:x:event"); | |
534 xmlnode_insert_child(message_x_node, xmlnode_new("composing")); | |
11539 | 535 |
11477 | 536 message_node = xmlnode_new("message"); |
537 xmlnode_set_attrib(message_node, "to", ((BonjourBuddy*)(gb->proto_data))->name); | |
538 xmlnode_set_attrib(message_node, "type", "chat"); | |
539 xmlnode_insert_child(message_node, message_body_node); | |
540 xmlnode_insert_child(message_node, message_html_node); | |
541 xmlnode_insert_child(message_node, message_x_node); | |
11539 | 542 |
11477 | 543 message = xmlnode_to_str(message_node, &message_length); |
544 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
545 /* Check if there is a previously open conversation */ |
11539 | 546 if (bb->conversation == NULL) |
547 { | |
11477 | 548 bb->conversation = g_new(BonjourJabberConversation, 1); |
549 bb->conversation->socket = _connect_to_buddy(gb);; | |
550 bb->conversation->start_step_one = FALSE; | |
551 bb->conversation->start_step_two = FALSE; | |
552 bb->conversation->stream_started = FALSE; | |
553 bb->conversation->buddy_name = g_strdup(gb->name); | |
11539 | 554 bb->conversation->watcher_id = gaim_input_add(bb->conversation->socket, |
11477 | 555 GAIM_INPUT_READ, _client_socket_handler, gb); |
556 } | |
557 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
558 /* Check if the stream for the conversation has been started */ |
11539 | 559 if (bb->conversation->stream_started == FALSE) |
560 { | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
561 /* Start the stream */ |
11539 | 562 if (send(bb->conversation->socket, DOCTYPE, strlen(DOCTYPE), 0) == -1) |
563 { | |
11477 | 564 gaim_debug_error("bonjour", "Unable to start a conversation\n"); |
11823 | 565 gaim_debug_warning("bonjour", "send error: %s\n", strerror(errno)); |
11477 | 566 conv_message = g_strdup("Unable to send the message, the conversation couldn't be started."); |
11498 | 567 conversation = gaim_find_conversation_with_account(GAIM_CONV_TYPE_IM, bb->name, data->account); |
11477 | 568 gaim_conversation_write(conversation, NULL, conv_message, GAIM_MESSAGE_SYSTEM, time(NULL)); |
569 close(bb->conversation->socket); | |
570 gaim_input_remove(bb->conversation->watcher_id); | |
11539 | 571 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
572 /* Free all the data related to the conversation */ |
11477 | 573 g_free(bb->conversation->buddy_name); |
574 g_free(bb->conversation); | |
575 bb->conversation = NULL; | |
11693 | 576 return 0; |
11477 | 577 } |
11539 | 578 |
11477 | 579 bb->conversation->stream_started = TRUE; |
580 } | |
11539 | 581 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
582 /* Send the message */ |
11539 | 583 if (_send_data(bb->conversation->socket, message) == -1) |
11693 | 584 return -10000; |
585 | |
586 return 1; | |
11477 | 587 } |
588 | |
11539 | 589 void |
590 bonjour_jabber_close_conversation(BonjourJabber *data, GaimBuddy *gb) | |
11477 | 591 { |
11539 | 592 BonjourBuddy *bb = (BonjourBuddy*)gb->proto_data; |
593 | |
594 if (bb->conversation != NULL) | |
595 { | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
596 /* Send the end of the stream to the other end of the conversation */ |
11477 | 597 send(bb->conversation->socket, STREAM_END, strlen(STREAM_END), 0); |
11539 | 598 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
599 /* Close the socket and remove the watcher */ |
11477 | 600 close(bb->conversation->socket); |
601 gaim_input_remove(bb->conversation->watcher_id); | |
11539 | 602 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
603 /* Free all the data related to the conversation */ |
11477 | 604 g_free(bb->conversation->buddy_name); |
605 g_free(bb->conversation); | |
606 bb->conversation = NULL; | |
607 } | |
608 } | |
609 | |
11539 | 610 void |
611 bonjour_jabber_stop(BonjourJabber *data) | |
11477 | 612 { |
11539 | 613 GaimBuddy *gb = NULL; |
614 BonjourBuddy *bb = NULL; | |
615 GSList *buddies; | |
616 GSList *l; | |
617 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
618 /* Close the server socket and remove all the watcher */ |
11477 | 619 close(data->socket); |
620 gaim_input_remove(data->watcher_id); | |
11539 | 621 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
622 /* Close all the sockets and remove all the watchers after sending end streams */ |
11539 | 623 if (data->account->gc != NULL) |
624 { | |
11477 | 625 buddies = gaim_find_buddies(data->account, data->account->username); |
11539 | 626 for (l = buddies; l; l = l->next) |
627 { | |
11477 | 628 gb = (GaimBuddy*)l->data; |
629 bb = (BonjourBuddy*)gb->proto_data; | |
11539 | 630 if (bb->conversation != NULL) |
631 { | |
11477 | 632 send(bb->conversation->socket, STREAM_END, strlen(STREAM_END), 0); |
633 close(bb->conversation->socket); | |
634 gaim_input_remove(bb->conversation->watcher_id); | |
635 } | |
636 } | |
637 g_slist_free(buddies); | |
638 } | |
639 } |