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