Mercurial > pidgin.yaz
annotate src/protocols/bonjour/jabber.c @ 13296:263c2db78f77
[gaim-migrate @ 15662]
Kill the other media_prpl_ops.
committer: Tailor Script <tailor@pidgin.im>
author | Richard Laager <rlaager@wiktel.com> |
---|---|
date | Thu, 16 Feb 2006 02:00:25 +0000 |
parents | d1088b7771d4 |
children | 47c3d00713af |
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; | |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
231 struct _check_buddy_by_address_t *d = (struct _check_buddy_by_address_t *)data; |
11539 | 232 |
12708 | 233 if (bb != NULL) { |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
234 if (g_strcasecmp(bb->ip, (char*)d->address) == 0) |
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
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(""); |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
243 char partial_data[512]; |
11477 | 244 gint total_message_length = 0; |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
245 gint partial_message_length = 0; |
11477 | 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 */ |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
248 while ((partial_message_length = recv(socket, partial_data, 512, 0)) > 0) |
11539 | 249 { |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
250 g_string_append_len(data, partial_data, partial_message_length); |
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
251 total_message_length += partial_message_length; |
11477 | 252 } |
11539 | 253 |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
254 if (partial_message_length == -1) |
11539 | 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); | |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
274 gint partial_sent = 0; |
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
275 gchar *partial_message = message; |
11539 | 276 |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
277 while ((partial_sent = send(socket, partial_message, message_len, 0)) < message_len) |
11539 | 278 { |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
279 if (partial_sent != -1) { |
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
280 partial_message += partial_sent; |
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
281 message_len -= partial_sent; |
11477 | 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); |
13266 | 357 closed_conv_message = g_strdup_printf(_("%s has closed the conversation."), gb->name); |
11477 | 358 gaim_conversation_write(conversation, NULL, closed_conv_message, GAIM_MESSAGE_SYSTEM, time(NULL)); |
13266 | 359 g_free(closed_conv_message); |
11477 | 360 } else { |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
361 /* Parse the message to get the data and send to the ui */ |
11477 | 362 _jabber_parse_and_write_message_to_ui(message, account->gc, gb); |
363 } | |
364 } | |
365 | |
12443 | 366 static void |
11539 | 367 _server_socket_handler(gpointer data, int server_socket, GaimInputCondition condition) |
11477 | 368 { |
11539 | 369 GaimBuddy *gb = NULL; |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
370 struct sockaddr_in their_addr; /* connector's address information */ |
11515 | 371 socklen_t sin_size = sizeof(struct sockaddr); |
11477 | 372 int client_socket; |
11539 | 373 BonjourBuddy *bb = NULL; |
374 char *address_text = NULL; | |
375 GaimBuddyList *bl = gaim_get_blist(); | |
12733 | 376 struct _check_buddy_by_address_t *cbba; |
11477 | 377 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
378 /* Check that it is a read condition */ |
11477 | 379 if (condition != GAIM_INPUT_READ) { |
380 return; | |
381 } | |
382 | |
11539 | 383 if ((client_socket = accept(server_socket, (struct sockaddr *)&their_addr, &sin_size)) == -1) |
384 { | |
11477 | 385 return; |
386 } | |
387 fcntl(client_socket, F_SETFL, O_NONBLOCK); | |
388 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
389 /* Look for the buddy that has open the conversation and fill information */ |
11477 | 390 address_text = inet_ntoa(their_addr.sin_addr); |
12733 | 391 cbba = g_new0(struct _check_buddy_by_address_t, 1); |
12708 | 392 cbba->address = address_text; |
393 cbba->gb = &gb; | |
13249 | 394 g_hash_table_foreach(bl->buddies, _check_buddy_by_address, cbba); |
12708 | 395 g_free(cbba); |
11539 | 396 if (gb == NULL) |
397 { | |
11477 | 398 gaim_debug_info("bonjour", "We don't like invisible buddies, this is not a superheros comic\n"); |
399 close(client_socket); | |
400 return; | |
401 } | |
402 bb = (BonjourBuddy*)gb->proto_data; | |
403 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
404 /* Check if the conversation has been previously started */ |
11539 | 405 if (bb->conversation == NULL) |
406 { | |
11477 | 407 bb->conversation = g_new(BonjourJabberConversation, 1); |
408 bb->conversation->socket = client_socket; | |
409 bb->conversation->start_step_one = FALSE; | |
410 bb->conversation->start_step_two = FALSE; | |
411 bb->conversation->stream_started = FALSE; | |
412 bb->conversation->buddy_name = g_strdup(gb->name); | |
413 bb->conversation->message_id = 1; | |
11539 | 414 |
11477 | 415 if (bb->conversation->stream_started == FALSE) { |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
416 /* Start the stream */ |
11477 | 417 send(bb->conversation->socket, DOCTYPE, strlen(DOCTYPE), 0); |
418 bb->conversation->stream_started = TRUE; | |
419 } | |
420 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
421 /* Open a watcher for the client socket */ |
11539 | 422 bb->conversation->watcher_id = gaim_input_add(client_socket, GAIM_INPUT_READ, |
11477 | 423 _client_socket_handler, gb); |
424 } else { | |
425 close(client_socket); | |
426 } | |
427 } | |
428 | |
11539 | 429 gint |
430 bonjour_jabber_start(BonjourJabber *data) | |
11477 | 431 { |
432 struct sockaddr_in my_addr; | |
433 int yes = 1; | |
434 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
435 /* Open a listening socket for incoming conversations */ |
11539 | 436 if ((data->socket = socket(PF_INET, SOCK_STREAM, 0)) < 0) |
437 { | |
13266 | 438 gaim_debug_error("bonjour", "Cannot open socket: %s\n", strerror(errno)); |
439 gaim_connection_error(data->account->gc, _("Cannot open socket")); | |
11477 | 440 return -1; |
441 } | |
11539 | 442 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
443 /* Make the socket reusable */ |
11539 | 444 if (setsockopt(data->socket, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int)) != 0) |
445 { | |
13266 | 446 gaim_debug_error("bonjour", "Error setting socket options: %s\n", strerror(errno)); |
447 gaim_connection_error(data->account->gc, _("Error setting socket options")); | |
11477 | 448 return -1; |
449 } | |
450 | |
451 memset(&my_addr, 0, sizeof(struct sockaddr_in)); | |
452 my_addr.sin_family = PF_INET; | |
453 my_addr.sin_port = htons(data->port); | |
11539 | 454 |
455 if (bind(data->socket, (struct sockaddr*)&my_addr, sizeof(struct sockaddr)) != 0) | |
456 { | |
13266 | 457 gaim_debug_error("bonjour", "Cannot bind socket: %s\n", strerror(errno)); |
458 gaim_connection_error(data->account->gc, _("Cannot bind socket to port")); | |
11477 | 459 return -1; |
460 } | |
11539 | 461 |
462 if (listen(data->socket, 10) != 0) | |
463 { | |
13266 | 464 gaim_debug_error("bonjour", "Cannot listen on socket: %s\n", strerror(errno)); |
465 gaim_connection_error(data->account->gc, _("Cannot listen on socket")); | |
11477 | 466 return -1; |
467 } | |
468 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
469 #if 0 |
12730
d5b8f4dc1622
[gaim-migrate @ 15074]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12708
diff
changeset
|
470 /* TODO: Why isn't this being used? */ |
d5b8f4dc1622
[gaim-migrate @ 15074]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12708
diff
changeset
|
471 data->socket = gaim_network_listen(data->port, SOCK_STREAM); |
11477 | 472 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
473 if (data->socket == -1) |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
474 { |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
475 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
|
476 } |
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
477 #endif |
11477 | 478 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
479 /* Open a watcher in the socket we have just opened */ |
11477 | 480 data->watcher_id = gaim_input_add(data->socket, GAIM_INPUT_READ, _server_socket_handler, data); |
11539 | 481 |
11477 | 482 return 0; |
483 } | |
484 | |
11693 | 485 int |
11539 | 486 bonjour_jabber_send_message(BonjourJabber *data, const gchar *to, const gchar *body) |
11477 | 487 { |
11539 | 488 xmlnode *message_node = NULL; |
489 gchar *message = NULL; | |
11477 | 490 gint message_length = -1; |
11539 | 491 xmlnode *message_body_node = NULL; |
492 xmlnode *message_html_node = NULL; | |
493 xmlnode *message_html_body_node = NULL; | |
494 xmlnode *message_html_body_font_node = NULL; | |
495 xmlnode *message_x_node = NULL; | |
11693 | 496 GaimBuddy *gb = NULL; |
497 BonjourBuddy *bb = NULL; | |
11539 | 498 char *conv_message = NULL; |
499 GaimConversation *conversation = NULL; | |
500 char *message_from_ui = NULL; | |
501 char *stripped_message = NULL; | |
502 | |
11693 | 503 gb = gaim_find_buddy(data->account, to); |
504 if (gb == NULL) | |
505 /* You can not send a message to an offline buddy */ | |
506 return -10000; | |
507 | |
508 bb = (BonjourBuddy *)gb->proto_data; | |
509 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
510 /* Enclose the message from the UI within a "font" node */ |
11477 | 511 message_body_node = xmlnode_new("body"); |
512 stripped_message = gaim_markup_strip_html(body); | |
513 xmlnode_insert_data(message_body_node, stripped_message, strlen(stripped_message)); | |
11539 | 514 |
11477 | 515 message_from_ui = g_strconcat("<font>", body, "</font>", NULL); |
516 message_html_body_font_node = xmlnode_from_str(message_from_ui, strlen(message_from_ui)); | |
11539 | 517 |
11477 | 518 message_html_body_node = xmlnode_new("body"); |
519 xmlnode_insert_child(message_html_body_node, message_html_body_font_node); | |
11539 | 520 |
11477 | 521 message_html_node = xmlnode_new("html"); |
522 xmlnode_set_attrib(message_html_node, "xmlns", "http://www.w3.org/1999/xhtml"); | |
523 xmlnode_insert_child(message_html_node, message_html_body_node); | |
524 | |
525 message_x_node = xmlnode_new("x"); | |
526 xmlnode_set_attrib(message_x_node, "xmlns", "jabber:x:event"); | |
527 xmlnode_insert_child(message_x_node, xmlnode_new("composing")); | |
11539 | 528 |
11477 | 529 message_node = xmlnode_new("message"); |
530 xmlnode_set_attrib(message_node, "to", ((BonjourBuddy*)(gb->proto_data))->name); | |
531 xmlnode_set_attrib(message_node, "type", "chat"); | |
532 xmlnode_insert_child(message_node, message_body_node); | |
533 xmlnode_insert_child(message_node, message_html_node); | |
534 xmlnode_insert_child(message_node, message_x_node); | |
11539 | 535 |
11477 | 536 message = xmlnode_to_str(message_node, &message_length); |
537 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
538 /* Check if there is a previously open conversation */ |
11539 | 539 if (bb->conversation == NULL) |
540 { | |
11477 | 541 bb->conversation = g_new(BonjourJabberConversation, 1); |
13006
e19c59a6ff11
[gaim-migrate @ 15359]
Daniel Atallah <daniel.atallah@gmail.com>
parents:
12733
diff
changeset
|
542 bb->conversation->socket = _connect_to_buddy(gb); |
11477 | 543 bb->conversation->start_step_one = FALSE; |
544 bb->conversation->start_step_two = FALSE; | |
545 bb->conversation->stream_started = FALSE; | |
546 bb->conversation->buddy_name = g_strdup(gb->name); | |
11539 | 547 bb->conversation->watcher_id = gaim_input_add(bb->conversation->socket, |
11477 | 548 GAIM_INPUT_READ, _client_socket_handler, gb); |
549 } | |
550 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
551 /* Check if the stream for the conversation has been started */ |
11539 | 552 if (bb->conversation->stream_started == FALSE) |
553 { | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
554 /* Start the stream */ |
11539 | 555 if (send(bb->conversation->socket, DOCTYPE, strlen(DOCTYPE), 0) == -1) |
556 { | |
11477 | 557 gaim_debug_error("bonjour", "Unable to start a conversation\n"); |
11823 | 558 gaim_debug_warning("bonjour", "send error: %s\n", strerror(errno)); |
13266 | 559 conv_message = g_strdup(_("Unable to send the message, the conversation couldn't be started.")); |
11498 | 560 conversation = gaim_find_conversation_with_account(GAIM_CONV_TYPE_IM, bb->name, data->account); |
11477 | 561 gaim_conversation_write(conversation, NULL, conv_message, GAIM_MESSAGE_SYSTEM, time(NULL)); |
562 close(bb->conversation->socket); | |
563 gaim_input_remove(bb->conversation->watcher_id); | |
11539 | 564 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
565 /* Free all the data related to the conversation */ |
11477 | 566 g_free(bb->conversation->buddy_name); |
567 g_free(bb->conversation); | |
568 bb->conversation = NULL; | |
11693 | 569 return 0; |
11477 | 570 } |
11539 | 571 |
11477 | 572 bb->conversation->stream_started = TRUE; |
573 } | |
11539 | 574 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
575 /* Send the message */ |
11539 | 576 if (_send_data(bb->conversation->socket, message) == -1) |
11693 | 577 return -10000; |
578 | |
579 return 1; | |
11477 | 580 } |
581 | |
11539 | 582 void |
583 bonjour_jabber_close_conversation(BonjourJabber *data, GaimBuddy *gb) | |
11477 | 584 { |
11539 | 585 BonjourBuddy *bb = (BonjourBuddy*)gb->proto_data; |
586 | |
587 if (bb->conversation != NULL) | |
588 { | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
589 /* Send the end of the stream to the other end of the conversation */ |
11477 | 590 send(bb->conversation->socket, STREAM_END, strlen(STREAM_END), 0); |
11539 | 591 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
592 /* Close the socket and remove the watcher */ |
11477 | 593 close(bb->conversation->socket); |
594 gaim_input_remove(bb->conversation->watcher_id); | |
11539 | 595 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
596 /* Free all the data related to the conversation */ |
11477 | 597 g_free(bb->conversation->buddy_name); |
598 g_free(bb->conversation); | |
599 bb->conversation = NULL; | |
600 } | |
601 } | |
602 | |
11539 | 603 void |
604 bonjour_jabber_stop(BonjourJabber *data) | |
11477 | 605 { |
11539 | 606 GaimBuddy *gb = NULL; |
607 BonjourBuddy *bb = NULL; | |
608 GSList *buddies; | |
609 GSList *l; | |
610 | |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
611 /* Close the server socket and remove all the watcher */ |
11477 | 612 close(data->socket); |
613 gaim_input_remove(data->watcher_id); | |
11539 | 614 |
11826
e05778d4f12d
[gaim-migrate @ 14117]
Richard Laager <rlaager@wiktel.com>
parents:
11823
diff
changeset
|
615 /* Close all the sockets and remove all the watchers after sending end streams */ |
11539 | 616 if (data->account->gc != NULL) |
617 { | |
11477 | 618 buddies = gaim_find_buddies(data->account, data->account->username); |
11539 | 619 for (l = buddies; l; l = l->next) |
620 { | |
11477 | 621 gb = (GaimBuddy*)l->data; |
622 bb = (BonjourBuddy*)gb->proto_data; | |
11539 | 623 if (bb->conversation != NULL) |
624 { | |
11477 | 625 send(bb->conversation->socket, STREAM_END, strlen(STREAM_END), 0); |
626 close(bb->conversation->socket); | |
627 gaim_input_remove(bb->conversation->watcher_id); | |
628 } | |
629 } | |
630 g_slist_free(buddies); | |
631 } | |
632 } |