Mercurial > pidgin.yaz
annotate src/protocols/gg/libgg.c @ 9663:318d14658f95
[gaim-migrate @ 10513]
gg fix from proton
committer: Tailor Script <tailor@pidgin.im>
author | Luke Schierer <lschiere@pidgin.im> |
---|---|
date | Wed, 04 Aug 2004 18:27:09 +0000 |
parents | 1c4092217e4a |
children | db62420a53a2 |
rev | line source |
---|---|
9663 | 1 /* $Id: libgg.c 10513 2004-08-04 18:27:09Z lschiere $ */ |
2393 | 2 |
3 /* | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
4 * (C) Copyright 2001 Wojtek Kaniewski <wojtekka@irc.pl>, |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
5 * Robert J. Wo¼ny <speedy@ziew.org> |
2393 | 6 * |
7 * This program is free software; you can redistribute it and/or modify | |
8 * it under the terms of the GNU General Public License Version 2 as | |
9 * published by the Free Software Foundation. | |
10 * | |
11 * This program is distributed in the hope that it will be useful, | |
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of | |
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | |
14 * GNU General Public License for more details. | |
15 * | |
16 * You should have received a copy of the GNU General Public License | |
17 * along with this program; if not, write to the Free Software | |
18 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. | |
19 */ | |
20 | |
4016 | 21 #include <sys/types.h> |
3630 | 22 #ifndef _WIN32 |
2393 | 23 #include <sys/socket.h> |
24 #include <netinet/in.h> | |
25 #include <arpa/inet.h> | |
26 #include <sys/ioctl.h> | |
27 #include <sys/wait.h> | |
3630 | 28 #include <netdb.h> |
29 #include <pwd.h> | |
30 #else | |
31 #include <fcntl.h> | |
32 #endif | |
33 | |
34 #include <stdio.h> | |
35 #include <stdlib.h> | |
36 #include <unistd.h> | |
37 #include <stdio.h> | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
38 #include <sys/time.h> |
2393 | 39 #include <errno.h> |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
40 #ifndef _AIX |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
41 # include <string.h> |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
42 #endif |
2393 | 43 #include <stdarg.h> |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
44 #include <time.h> |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
45 #ifdef sun |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
46 #include <sys/filio.h> |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
47 #endif |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
48 #include <glib.h> |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
49 #if G_BYTE_ORDER == G_BIG_ENDIAN |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
50 # define WORDS_BIGENDIAN 1 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
51 #endif |
9265 | 52 #include "internal.h" |
2393 | 53 #include "libgg.h" |
5872
059d95c67cda
[gaim-migrate @ 6304]
Christian Hammond <chipx86@chipx86.com>
parents:
5681
diff
changeset
|
54 |
3630 | 55 #include "proxy.h" |
5872
059d95c67cda
[gaim-migrate @ 6304]
Christian Hammond <chipx86@chipx86.com>
parents:
5681
diff
changeset
|
56 #include "debug.h" |
2393 | 57 |
3717
988485669631
[gaim-migrate @ 3850]
Herman Bloggs <hermanator12002@yahoo.com>
parents:
3630
diff
changeset
|
58 #ifdef _WIN32 |
988485669631
[gaim-migrate @ 3850]
Herman Bloggs <hermanator12002@yahoo.com>
parents:
3630
diff
changeset
|
59 #include "win32dep.h" |
988485669631
[gaim-migrate @ 3850]
Herman Bloggs <hermanator12002@yahoo.com>
parents:
3630
diff
changeset
|
60 #endif |
988485669631
[gaim-migrate @ 3850]
Herman Bloggs <hermanator12002@yahoo.com>
parents:
3630
diff
changeset
|
61 |
3630 | 62 int gg_debug_level = (GG_DEBUG_NET | GG_DEBUG_TRAFFIC | GG_DEBUG_DUMP | GG_DEBUG_FUNCTION | GG_DEBUG_MISC); |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
63 int gg_http_use_proxy = 0; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
64 int gg_http_proxy_port = 0; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
65 char *gg_http_proxy_host = NULL; |
2393 | 66 |
3630 | 67 /* temp -Herman */ |
68 static int ping_outstanding = 0; | |
69 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
70 #ifndef lint |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
71 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
72 static char rcsid[] |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
73 #ifdef __GNUC__ |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
74 __attribute__ ((unused)) |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
75 #endif |
9663 | 76 = "$Id: libgg.c 10513 2004-08-04 18:27:09Z lschiere $"; |
2393 | 77 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
78 #endif |
2393 | 79 |
80 /* | |
81 * fix32() // funkcja wewnźtrzna | |
82 * | |
83 * dla maszyn big-endianowych zamienia kolejno¶ę bajtów w ,,long''ach. | |
84 */ | |
85 static inline unsigned long fix32(unsigned long x) | |
86 { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
87 #ifndef WORDS_BIGENDIAN |
2393 | 88 return x; |
89 #else | |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
90 return (unsigned long) |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
91 (((x & (unsigned long) 0x000000ffU) << 24) | |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
92 ((x & (unsigned long) 0x0000ff00U) << 8) | |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
93 ((x & (unsigned long) 0x00ff0000U) >> 8) | |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
94 ((x & (unsigned long) 0xff000000U) >> 24)); |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
95 #endif |
2393 | 96 } |
97 | |
98 /* | |
99 * fix16() // funkcja wewnźtrzna | |
100 * | |
101 * dla maszyn big-endianowych zamienia kolejno¶ę bajtów w ,,short''ach. | |
102 */ | |
4298 | 103 |
2393 | 104 static inline unsigned short fix16(unsigned short x) |
105 { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
106 #ifndef WORDS_BIGENDIAN |
2393 | 107 return x; |
108 #else | |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
109 return (unsigned short) |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
110 (((x & (unsigned short) 0x00ffU) << 8) | |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
111 ((x & (unsigned short) 0xff00U) >> 8)); |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
112 #endif |
2393 | 113 } |
114 | |
3630 | 115 #ifndef _WIN32 |
2393 | 116 /* |
117 * gg_resolve() // funkcja wewnźtrzna | |
118 * | |
119 * tworzy pipe'y, forkuje siź i w drugim procesie zaczyna resolvowaę | |
120 * podanego hosta. zapisuje w sesji deskryptor pipe'u. je¶li co¶ tam | |
121 * bździe gotowego, znaczy, æe moæna wczytaę ,,struct in_addr''. je¶li | |
122 * nie znajdzie, zwraca INADDR_NONE. | |
123 * | |
124 * - fd - wska¼nik gdzie wrzucię deskryptor, | |
125 * - pid - gdzie wrzucię pid dzieciaka, | |
126 * - hostname - nazwa hosta do zresolvowania. | |
127 * | |
128 * zwraca 0 je¶li uda³o siź odpalię proces lub -1 w przypadku b³źdu. | |
129 */ | |
130 int gg_resolve(int *fd, int *pid, char *hostname) | |
131 { | |
132 int pipes[2], res; | |
133 struct in_addr a; | |
134 | |
135 gg_debug(GG_DEBUG_FUNCTION, "** gg_resolve(..., \"%s\");\n", hostname); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
136 |
2393 | 137 if (!fd | !pid) { |
138 errno = EFAULT; | |
139 return -1; | |
140 } | |
141 | |
142 if (pipe(pipes) == -1) | |
143 return -1; | |
144 | |
145 if ((res = fork()) == -1) | |
146 return -1; | |
147 | |
148 if (!res) { | |
149 if ((a.s_addr = inet_addr(hostname)) == INADDR_NONE) { | |
150 struct hostent *he; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
151 |
2393 | 152 if (!(he = gethostbyname(hostname))) |
153 a.s_addr = INADDR_NONE; | |
154 else | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
155 memcpy((char*) &a, he->h_addr, sizeof(a)); |
2393 | 156 } |
157 | |
158 write(pipes[1], &a, sizeof(a)); | |
159 | |
160 exit(0); | |
161 } | |
162 | |
163 close(pipes[1]); | |
164 | |
165 *fd = pipes[0]; | |
166 *pid = res; | |
167 | |
168 return 0; | |
169 } | |
3630 | 170 #endif /*!_WIN32*/ |
2393 | 171 |
172 /* | |
173 * gg_recv_packet() // funkcja wewnźtrzna | |
174 * | |
175 * odbiera jeden pakiet gg i zwraca wska¼nik do niego. pamiźę po nim | |
176 * wypada³oby uwolnię. | |
177 * | |
178 * - sock - po³±czony socket. | |
179 * | |
180 * je¶li wyst±pi³ b³±d, zwraca NULL. reszta w errno. | |
181 */ | |
182 static void *gg_recv_packet(struct gg_session *sess) | |
183 { | |
184 struct gg_header h; | |
185 char *buf = NULL; | |
186 int ret = 0, offset, size = 0; | |
3630 | 187 int sizeh = sizeof(struct gg_header); |
2393 | 188 |
189 gg_debug(GG_DEBUG_FUNCTION, "** gg_recv_packet(...);\n"); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
190 |
2393 | 191 if (!sess) { |
192 errno = EFAULT; | |
193 return NULL; | |
194 } | |
195 | |
196 if (sess->recv_left < 1) { | |
3630 | 197 while (ret != sizeh) { |
198 ret = read(sess->fd, &h, sizeh); | |
199 gg_debug(GG_DEBUG_MISC, "-- header recv(..., %d) = %d\n", sizeh, ret); | |
200 if (ret < sizeh) { | |
2393 | 201 if (errno != EINTR) { |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
202 gg_debug(GG_DEBUG_MISC, "-- errno = %d (%s)\n", errno, strerror(errno)); |
2393 | 203 return NULL; |
204 } | |
205 } | |
206 } | |
207 | |
208 h.type = fix32(h.type); | |
209 h.length = fix32(h.length); | |
210 } else { | |
3630 | 211 memcpy(&h, sess->recv_buf, sizeh); |
2393 | 212 } |
213 | |
214 /* jakie¶ sensowne limity na rozmiar pakietu */ | |
215 if (h.length < 0 || h.length > 65535) { | |
216 gg_debug(GG_DEBUG_MISC, "-- invalid packet length (%d)\n", h.length); | |
217 errno = ERANGE; | |
218 return NULL; | |
219 } | |
220 | |
221 if (sess->recv_left > 0) { | |
222 gg_debug(GG_DEBUG_MISC, "-- resuming last gg_recv_packet()\n"); | |
223 size = sess->recv_left; | |
224 offset = sess->recv_done; | |
225 buf = sess->recv_buf; | |
226 } else { | |
3630 | 227 if (!(buf = malloc(sizeh + h.length + 1))) { |
2393 | 228 gg_debug(GG_DEBUG_MISC, "-- not enough memory\n"); |
229 return NULL; | |
230 } | |
231 | |
3630 | 232 memcpy(buf, &h, sizeh); |
2393 | 233 |
234 offset = 0; | |
235 size = h.length; | |
236 } | |
237 | |
238 while (size > 0) { | |
3630 | 239 ret = read(sess->fd, buf + sizeh + offset, size); |
2393 | 240 gg_debug(GG_DEBUG_MISC, "-- body recv(..., %d) = %d\n", size, ret); |
241 if (ret > -1 && ret <= size) { | |
242 offset += ret; | |
243 size -= ret; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
244 } else if (ret == -1) { |
2393 | 245 gg_debug(GG_DEBUG_MISC, "-- errno = %d (%s)\n", errno, strerror(errno)); |
246 if (errno == EAGAIN) { | |
247 gg_debug(GG_DEBUG_MISC, "-- %d bytes received, %d left\n", offset, size); | |
248 sess->recv_buf = buf; | |
249 sess->recv_left = size; | |
250 sess->recv_done = offset; | |
251 return NULL; | |
252 } | |
253 if (errno != EINTR) { | |
6063 | 254 /* errno = EINVAL; */ |
2393 | 255 free(buf); |
256 return NULL; | |
257 } | |
258 } | |
259 } | |
260 | |
261 sess->recv_left = 0; | |
262 | |
263 if ((gg_debug_level & GG_DEBUG_DUMP)) { | |
264 int i; | |
265 | |
266 gg_debug(GG_DEBUG_DUMP, ">> received packet (type=%.2x):", h.type); | |
3630 | 267 for (i = 0; i < sizeh + h.length; i++) |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
268 gg_debug(GG_DEBUG_DUMP, " %.2x", (unsigned char) buf[i]); |
2393 | 269 gg_debug(GG_DEBUG_DUMP, "\n"); |
270 } | |
271 | |
272 return buf; | |
273 } | |
274 | |
275 /* | |
276 * gg_send_packet() // funkcja wewnźtrzna | |
277 * | |
8775 | 278 * konstruuje pakiet i wysy³a go do serwera. |
2393 | 279 * |
8775 | 280 * - sock - deskryptor gniazda |
281 * - type - typ pakietu | |
282 * - payload_1 - pierwsza czź¶ę pakietu | |
283 * - payload_length_1 - d³ugo¶ę pierwszej czź¶ci | |
284 * - payload_2 - druga czź¶ę pakietu | |
285 * - payload_length_2 - d³ugo¶ę drugiej czź¶ci | |
286 * - ... - kolejne czź¶ci pakietu i ich d³ugo¶ci | |
287 * - NULL - końcowym parametr (konieczny!) | |
2393 | 288 * |
8775 | 289 * je¶li siź powiod³o, zwraca 0, w przypadku b³źdu -1. je¶li errno == ENOMEM, |
290 * zabrak³o pamiźci. inaczej by³ b³±d przy wysy³aniu pakietu. dla errno == 0 | |
2393 | 291 * nie wys³ano ca³ego pakietu. |
292 */ | |
8775 | 293 int gg_send_packet(struct gg_session *sess, int type, ...) |
2393 | 294 { |
295 struct gg_header *h; | |
296 char *tmp; | |
8775 | 297 int tmp_length; |
298 void *payload; | |
299 int payload_length; | |
300 va_list ap; | |
301 int res; | |
2393 | 302 |
8775 | 303 gg_debug(GG_DEBUG_FUNCTION, "** gg_send_packet(%p, 0x%.2x, ...)\n", sess, type); |
2393 | 304 |
8775 | 305 tmp_length = 0; |
306 | |
307 if (!(tmp = malloc(sizeof(struct gg_header)))) { | |
308 gg_debug(GG_DEBUG_MISC, "// gg_send_packet() not enough memory for packet header\n"); | |
2393 | 309 return -1; |
310 } | |
311 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
312 h = (struct gg_header*) tmp; |
2393 | 313 h->type = fix32(type); |
8775 | 314 h->length = fix32(0); |
315 | |
316 va_start(ap, type); | |
317 | |
318 payload = va_arg(ap, void *); | |
319 | |
320 while (payload) { | |
321 char *tmp2; | |
322 | |
323 payload_length = va_arg(ap, int); | |
2393 | 324 |
8775 | 325 if (payload_length < 0) |
326 gg_debug(GG_DEBUG_MISC, "// gg_send_packet() invalid payload length (%d)\n", payload_length); | |
327 | |
328 if (!(tmp2 = realloc(tmp, sizeof(struct gg_header) + tmp_length + payload_length))) { | |
329 gg_debug(GG_DEBUG_MISC, "// gg_send_packet() not enough memory for payload\n"); | |
330 free(tmp); | |
331 va_end(ap); | |
332 return -1; | |
333 } | |
334 | |
335 tmp = tmp2; | |
336 | |
337 memcpy(tmp + sizeof(struct gg_header) + tmp_length, payload, payload_length); | |
338 tmp_length += payload_length; | |
339 | |
340 payload = va_arg(ap, void *); | |
341 } | |
342 | |
343 va_end(ap); | |
344 | |
345 h = (struct gg_header*) tmp; | |
346 h->length = fix32(tmp_length); | |
2393 | 347 |
348 if ((gg_debug_level & GG_DEBUG_DUMP)) { | |
8775 | 349 unsigned int i; |
350 | |
351 gg_debug(GG_DEBUG_DUMP, "// gg_send_packet(0x%.2x)", fix32(h->type)); | |
352 for (i = 0; i < sizeof(struct gg_header) + fix32(h->length); i++) | |
353 gg_debug(GG_DEBUG_DUMP, " %.2x", (unsigned char) tmp[i]); | |
354 gg_debug(GG_DEBUG_DUMP, "\n"); | |
355 } | |
356 | |
357 tmp_length += sizeof(struct gg_header); | |
358 | |
359 if ((res = gg_write(sess, tmp, tmp_length)) < tmp_length) { | |
360 gg_debug(GG_DEBUG_MISC, "// gg_send_packet() write() failed. res = %d, errno = %d (%s)\n", res, errno, strerror(errno)); | |
2393 | 361 free(tmp); |
362 return -1; | |
363 } | |
8775 | 364 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
365 free(tmp); |
2393 | 366 return 0; |
367 } | |
368 | |
8775 | 369 /* |
370 * gg_write() // funkcja pomocnicza | |
371 * | |
372 * zapisuje do gniazda okre¶lon± ilo¶ę bajtów. bierze pod uwagź, czy mamy | |
373 * po³±czenie zwyk³e czy TLS. | |
374 * | |
375 * - sess - sesja, | |
376 * - buf - bufor, | |
377 * - length - ilo¶ę bajtów, | |
378 * | |
379 * takie same warto¶ci jak write(). | |
380 */ | |
381 int gg_write(struct gg_session *sess, const char *buf, int length) | |
382 { | |
383 int res; | |
384 | |
385 #ifdef __GG_LIBGADU_HAVE_OPENSSL | |
386 if (sess->ssl) { | |
387 int err; | |
388 | |
389 res = SSL_write(sess->ssl, buf, length); | |
390 | |
391 if (res < 0) { | |
392 err = SSL_get_error(sess->ssl, res); | |
393 | |
394 if (err == SSL_ERROR_WANT_WRITE) | |
395 errno = EAGAIN; | |
396 | |
397 return -1; | |
398 } | |
399 } else | |
400 #endif | |
401 res = write(sess->fd, buf, length); | |
402 | |
403 return res; | |
404 } | |
405 | |
406 | |
3630 | 407 #ifndef _WIN32 |
2393 | 408 /* |
409 * gg_login() | |
410 * | |
411 * rozpoczyna procedurź ³±czenia siź z serwerem. resztź obs³guje siź przez | |
412 * gg_watch_event. | |
413 * | |
414 * - uin - numerek usera, | |
415 * - password - jego hase³ko, | |
416 * - async - ma byę asynchronicznie? | |
417 * | |
418 * UWAGA! program musi obs³uæyę SIGCHLD, je¶li ³±czy siź asynchronicznie, | |
419 * æeby zrobię pogrzeb zmar³emu procesowi resolvera. | |
420 * | |
421 * w przypadku b³źdu zwraca NULL, je¶li idzie dobrze (async) albo posz³o | |
422 * dobrze (sync), zwróci wska¼nik do zaalokowanej struktury `gg_session'. | |
423 */ | |
424 struct gg_session *gg_login(uin_t uin, char *password, int async) | |
425 { | |
426 struct gg_session *sess; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
427 char *hostname; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
428 int port; |
2393 | 429 |
430 gg_debug(GG_DEBUG_FUNCTION, "** gg_login(%u, \"...\", %d);\n", uin, async); | |
431 | |
432 if (!(sess = malloc(sizeof(*sess)))) | |
433 return NULL; | |
434 | |
435 sess->uin = uin; | |
436 if (!(sess->password = strdup(password))) { | |
437 free(sess); | |
438 return NULL; | |
439 } | |
440 sess->state = GG_STATE_RESOLVING; | |
441 sess->check = GG_CHECK_READ; | |
442 sess->async = async; | |
443 sess->seq = 0; | |
444 sess->recv_left = 0; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
445 sess->last_pong = 0; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
446 sess->server_ip = 0; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
447 sess->initial_status = 0; |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
448 sess->type = GG_SESSION_GG; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
449 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
450 if (gg_http_use_proxy) { |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
451 hostname = gg_http_proxy_host; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
452 port = gg_http_proxy_port; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
453 } else { |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
454 hostname = GG_APPMSG_HOST; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
455 port = GG_APPMSG_PORT; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
456 }; |
2393 | 457 |
458 if (async) { | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
459 if (gg_resolve(&sess->fd, &sess->pid, hostname)) { |
2393 | 460 gg_debug(GG_DEBUG_MISC, "-- resolving failed\n"); |
461 free(sess); | |
462 return NULL; | |
463 } | |
464 } else { | |
465 struct in_addr a; | |
466 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
467 if ((a.s_addr = inet_addr(hostname)) == INADDR_NONE) { |
2393 | 468 struct hostent *he; |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
469 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
470 if (!(he = gethostbyname(hostname))) { |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
471 gg_debug(GG_DEBUG_MISC, "-- host %s not found\n", hostname); |
2393 | 472 free(sess); |
473 return NULL; | |
474 } else | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
475 memcpy((char*) &a, he->h_addr, sizeof(a)); |
2393 | 476 } |
477 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
478 if (!(sess->fd = gg_connect(&a, port, 0)) == -1) { |
2393 | 479 gg_debug(GG_DEBUG_MISC, "-- connection failed\n"); |
480 free(sess); | |
481 return NULL; | |
482 } | |
483 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
484 sess->state = GG_STATE_CONNECTING; |
2393 | 485 |
486 while (sess->state != GG_STATE_CONNECTED) { | |
487 struct gg_event *e; | |
488 | |
489 if (!(e = gg_watch_fd(sess))) { | |
490 gg_debug(GG_DEBUG_MISC, "-- some nasty error in gg_watch_fd()\n"); | |
491 free(sess); | |
492 return NULL; | |
493 } | |
494 | |
495 if (e->type == GG_EVENT_CONN_FAILED) { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
496 errno = EACCES; |
2393 | 497 gg_debug(GG_DEBUG_MISC, "-- could not login\n"); |
498 gg_free_event(e); | |
499 free(sess); | |
500 return NULL; | |
501 } | |
502 | |
503 gg_free_event(e); | |
504 } | |
505 } | |
506 | |
507 return sess; | |
508 } | |
3630 | 509 #endif /*!_WIN32*/ |
2393 | 510 |
511 /* | |
8775 | 512 * gg_login_hash() // funkcja wewnźtrzna |
513 * | |
514 * liczy hash z has³a i danego seeda. | |
515 * | |
516 * - password - has³o do hashowania | |
517 * - seed - warto¶ę podana przez serwer | |
518 * | |
519 * hash. | |
520 */ | |
521 unsigned int gg_login_hash(const unsigned char *password, unsigned int seed) | |
522 { | |
523 unsigned int x, y, z; | |
524 | |
525 y = seed; | |
526 | |
527 for (x = 0; *password; password++) { | |
528 x = (x & 0xffffff00) | *password; | |
529 y ^= x; | |
530 y += x; | |
531 x <<= 8; | |
532 y ^= x; | |
533 x <<= 8; | |
534 y -= x; | |
535 x <<= 8; | |
536 y ^= x; | |
537 | |
538 z = y & 0x1F; | |
539 y = (y << z) | (y >> (32 - z)); | |
540 } | |
541 | |
542 return y; | |
543 } | |
544 | |
545 /* | |
2393 | 546 * gg_free_session() |
547 * | |
548 * zwalnia pamiźę zajmowan± przez opis sesji. | |
549 * | |
550 * - sess - opis sesji. | |
551 * | |
552 * nie zwraca niczego, bo i po co? | |
553 */ | |
554 void gg_free_session(struct gg_session *sess) | |
555 { | |
556 if (!sess) | |
557 return; | |
558 | |
559 free(sess->password); | |
560 free(sess); | |
561 } | |
562 | |
563 /* | |
564 * gg_change_status() | |
565 * | |
566 * zmienia status uæytkownika. przydatne do /away i /busy oraz /quit. | |
567 * | |
568 * - sess - opis sesji, | |
569 * - status - nowy status uæytkownika. | |
570 * | |
571 * je¶li wys³a³ pakiet zwraca 0, je¶li nie uda³o siź, zwraca -1. | |
572 */ | |
573 int gg_change_status(struct gg_session *sess, int status) | |
574 { | |
575 struct gg_new_status p; | |
576 | |
577 if (!sess) { | |
578 errno = EFAULT; | |
579 return -1; | |
580 } | |
581 | |
582 if (sess->state != GG_STATE_CONNECTED) { | |
583 errno = ENOTCONN; | |
584 return -1; | |
585 } | |
586 | |
587 gg_debug(GG_DEBUG_FUNCTION, "** gg_change_status(..., %d);\n", status); | |
588 | |
589 p.status = fix32(status); | |
590 | |
8775 | 591 return gg_send_packet(sess, GG_NEW_STATUS, &p, sizeof(p), NULL, 0); |
2393 | 592 } |
593 | |
594 /* | |
9415 | 595 * gg_change_status_descr() |
596 * | |
597 * zmienia status uĆøytkownika na opisowy. | |
598 * | |
599 * - sess - opis sesji | |
600 * - status - nowy status uĆøytkownika | |
601 * - descr - opis statusu | |
602 * | |
603 * 0, -1. | |
604 */ | |
605 int gg_change_status_descr(struct gg_session *sess, int status, const char *descr) | |
606 { | |
607 struct gg_new_status p; | |
608 | |
609 gg_debug(GG_DEBUG_FUNCTION, "** gg_change_status_descr(%p, %d, \"%s\");\n", sess, status, descr); | |
610 | |
611 if (!sess || !descr) { | |
612 errno = EFAULT; | |
613 return -1; | |
614 } | |
615 | |
616 if (sess->state != GG_STATE_CONNECTED) { | |
617 errno = ENOTCONN; | |
618 return -1; | |
619 } | |
620 | |
621 p.status = fix32(status); | |
622 | |
623 return gg_send_packet(sess, GG_NEW_STATUS, &p, sizeof(p), descr, (strlen(descr) > GG_STATUS_DESCR_MAXSIZE) ? GG_STATUS_DESCR_MAXSIZE : strlen(descr), NULL); | |
624 } | |
625 | |
626 /* | |
2393 | 627 * gg_logoff() |
628 * | |
629 * wylogowuje uæytkownika i zamyka po³±czenie. | |
630 * | |
631 * - sock - deskryptor socketu. | |
632 * | |
633 * nie zwraca b³źdów. skoro siź æegnamy, to olewamy wszystko. | |
634 */ | |
635 void gg_logoff(struct gg_session *sess) | |
636 { | |
637 if (!sess) | |
638 return; | |
639 | |
640 gg_debug(GG_DEBUG_FUNCTION, "** gg_logoff(...);\n"); | |
641 | |
642 if (sess->state == GG_STATE_CONNECTED) | |
643 gg_change_status(sess, GG_STATUS_NOT_AVAIL); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
644 |
2393 | 645 if (sess->fd) { |
646 shutdown(sess->fd, 2); | |
647 close(sess->fd); | |
648 } | |
649 } | |
650 | |
651 /* | |
652 * gg_send_message() | |
653 * | |
654 * wysy³a wiadomo¶ę do innego uæytkownika. zwraca losowy numer | |
8775 | 655 * sekwencyjny, który moæna zignorowaę albo wykorzystaę do potwierdzenia. |
656 * | |
657 * - sess - opis sesji | |
658 * - msgclass - rodzaj wiadomo¶ci | |
659 * - recipient - numer adresata | |
660 * - message - tre¶ę wiadomo¶ci | |
2393 | 661 * |
8775 | 662 * numer sekwencyjny wiadomo¶ci lub -1 w przypadku b³źdu. |
663 */ | |
664 int gg_send_message(struct gg_session *sess, int msgclass, uin_t recipient, const unsigned char *message) | |
665 { | |
666 gg_debug(GG_DEBUG_FUNCTION, "** gg_send_message(%p, %d, %u, %p)\n", sess, msgclass, recipient, message); | |
667 | |
668 return gg_send_message_richtext(sess, msgclass, recipient, message, NULL, 0); | |
669 } | |
670 | |
671 /* | |
672 * gg_send_message_richtext() | |
2393 | 673 * |
8775 | 674 * wysy³a kolorow± wiadomo¶ę do innego uæytkownika. zwraca losowy numer |
675 * sekwencyjny, który moæna zignorowaę albo wykorzystaę do potwierdzenia. | |
676 * | |
677 * - sess - opis sesji | |
678 * - msgclass - rodzaj wiadomo¶ci | |
679 * - recipient - numer adresata | |
680 * - message - tre¶ę wiadomo¶ci | |
681 * - format - informacje o formatowaniu | |
682 * - formatlen - d³ugo¶ę informacji o formatowaniu | |
683 * | |
684 * numer sekwencyjny wiadomo¶ci lub -1 w przypadku b³źdu. | |
2393 | 685 */ |
8775 | 686 int gg_send_message_richtext(struct gg_session *sess, int msgclass, uin_t recipient, const unsigned char *message, const unsigned char *format, int formatlen) |
2393 | 687 { |
688 struct gg_send_msg s; | |
689 | |
8775 | 690 gg_debug(GG_DEBUG_FUNCTION, "** gg_send_message_richtext(%p, %d, %u, %p, %p, %d);\n", sess, msgclass, recipient, message, format, formatlen); |
691 | |
2393 | 692 if (!sess) { |
693 errno = EFAULT; | |
694 return -1; | |
695 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
696 |
2393 | 697 if (sess->state != GG_STATE_CONNECTED) { |
698 errno = ENOTCONN; | |
699 return -1; | |
700 } | |
701 | |
702 s.recipient = fix32(recipient); | |
703 if (!sess->seq) | |
704 sess->seq = 0x01740000 | (rand() & 0xffff); | |
705 s.seq = fix32(sess->seq); | |
706 s.msgclass = fix32(msgclass); | |
707 sess->seq += (rand() % 0x300) + 0x300; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
708 |
8775 | 709 if (gg_send_packet(sess, GG_SEND_MSG, &s, sizeof(s), message, strlen(message) + 1, format, formatlen, NULL) == -1) |
2393 | 710 return -1; |
711 | |
712 return fix32(s.seq); | |
713 } | |
714 | |
715 /* | |
716 * gg_ping() | |
717 * | |
718 * wysy³a do serwera pakiet typu yeah-i'm-still-alive. | |
719 * | |
720 * - sess - zgadnij. | |
721 * | |
722 * je¶li nie powiod³o siź wys³anie pakietu, zwraca -1. otherwise 0. | |
723 */ | |
724 int gg_ping(struct gg_session *sess) | |
725 { | |
726 if (!sess) { | |
727 errno = EFAULT; | |
728 return -1; | |
729 } | |
730 | |
731 if (sess->state != GG_STATE_CONNECTED) { | |
732 errno = ENOTCONN; | |
733 return -1; | |
734 } | |
735 | |
736 gg_debug(GG_DEBUG_FUNCTION, "** gg_ping(...);\n"); | |
3630 | 737 |
8775 | 738 return gg_send_packet(sess, GG_PING, NULL); |
2393 | 739 } |
740 | |
741 /* | |
742 * gg_free_event() | |
743 * | |
744 * zwalnia pamiźę zajmowan± przez informacjź o zdarzeniu | |
745 * | |
746 * - event - wska¼nik do informacji o zdarzeniu | |
747 * | |
748 * nie ma czego zwracaę. | |
749 */ | |
750 void gg_free_event(struct gg_event *e) | |
751 { | |
752 if (!e) | |
753 return; | |
754 if (e->type == GG_EVENT_MSG) | |
755 free(e->event.msg.message); | |
756 if (e->type == GG_EVENT_NOTIFY) | |
757 free(e->event.notify); | |
758 free(e); | |
759 } | |
760 | |
761 /* | |
762 * gg_notify() | |
763 * | |
764 * wysy³a serwerowi listź ludków, za którymi tźsknimy. | |
765 * | |
766 * - sess - identyfikator sesji, | |
767 * - userlist - wska¼nik do tablicy numerów, | |
768 * - count - ilo¶ę numerków. | |
769 * | |
770 * je¶li uda³o siź, zwraca 0. je¶li b³±d, dostajemy -1. | |
771 */ | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
772 int gg_notify(struct gg_session *sess, uin_t *userlist, int count) |
2393 | 773 { |
774 struct gg_notify *n; | |
775 uin_t *u; | |
776 int i, res = 0; | |
777 | |
778 if (!sess) { | |
779 errno = EFAULT; | |
780 return -1; | |
781 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
782 |
2393 | 783 if (sess->state != GG_STATE_CONNECTED) { |
784 errno = ENOTCONN; | |
785 return -1; | |
786 } | |
787 | |
788 gg_debug(GG_DEBUG_FUNCTION, "** gg_notify(..., %d);\n", count); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
789 |
2393 | 790 if (!userlist || !count) |
791 return 0; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
792 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
793 if (!(n = (struct gg_notify*) malloc(sizeof(*n) * count))) |
2393 | 794 return -1; |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
795 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
796 for (u = userlist, i = 0; i < count; u++, i++) { |
2393 | 797 n[i].uin = fix32(*u); |
798 n[i].dunno1 = 3; | |
799 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
800 |
8775 | 801 if (gg_send_packet(sess, GG_NOTIFY, n, sizeof(*n) * count, NULL, 0) == -1) |
2393 | 802 res = -1; |
803 | |
804 free(n); | |
805 | |
806 return res; | |
807 } | |
808 | |
809 /* | |
810 * gg_add_notify() | |
811 * | |
812 * dodaje w locie do listy ukochanych dany numerek. | |
813 * | |
814 * - sess - identyfikator sesji, | |
815 * - uin - numerek ukochanej. | |
816 * | |
817 * je¶li uda³o siź wys³aę, daje 0. inaczej -1. | |
818 */ | |
819 int gg_add_notify(struct gg_session *sess, uin_t uin) | |
820 { | |
821 struct gg_add_remove a; | |
822 | |
823 if (!sess) { | |
824 errno = EFAULT; | |
825 return -1; | |
826 } | |
827 | |
828 if (sess->state != GG_STATE_CONNECTED) { | |
829 errno = ENOTCONN; | |
830 return -1; | |
831 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
832 |
2393 | 833 gg_debug(GG_DEBUG_FUNCTION, "** gg_add_notify(..., %u);\n", uin); |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
834 |
2393 | 835 a.uin = fix32(uin); |
836 a.dunno1 = 3; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
837 |
8775 | 838 return gg_send_packet(sess, GG_ADD_NOTIFY, &a, sizeof(a), NULL); |
2393 | 839 } |
840 | |
841 /* | |
842 * gg_remove_notify() | |
843 * | |
844 * w locie usuwa z listy zainteresowanych. | |
845 * | |
846 * - sess - id sesji, | |
847 * - uin - numerek. | |
848 * | |
849 * zwraca -1 je¶li by³ b³±d, 0 je¶li siź uda³o wys³aę pakiet. | |
850 */ | |
851 int gg_remove_notify(struct gg_session *sess, uin_t uin) | |
852 { | |
853 struct gg_add_remove a; | |
854 | |
855 if (!sess) { | |
856 errno = EFAULT; | |
857 return -1; | |
858 } | |
859 | |
860 if (sess->state != GG_STATE_CONNECTED) { | |
861 errno = ENOTCONN; | |
862 return -1; | |
863 } | |
864 | |
865 gg_debug(GG_DEBUG_FUNCTION, "** gg_remove_notify(..., %u);\n", uin); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
866 |
2393 | 867 a.uin = fix32(uin); |
868 a.dunno1 = 3; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
869 |
8775 | 870 return gg_send_packet(sess, GG_REMOVE_NOTIFY, &a, sizeof(a), NULL, 0); |
871 } | |
872 | |
873 /* | |
874 * gg_userlist_request() | |
875 * | |
876 * wysy³a æ±danie/zapytanie listy kontaktów na serwerze. | |
877 * | |
878 * - sess - opis sesji | |
879 * - type - rodzaj zapytania/æ±dania | |
880 * - request - tre¶ę zapytania/æ±dania (moæe byę NULL) | |
881 * | |
882 * 0, -1 | |
883 */ | |
884 int gg_userlist_request(struct gg_session *sess, char type, const char *request) | |
885 { | |
886 int len; | |
887 | |
888 if (!sess) { | |
889 errno = EINVAL; | |
890 return -1; | |
891 } | |
892 | |
893 if (!request) { | |
894 sess->userlist_blocks = 1; | |
895 return gg_send_packet(sess, GG_USERLIST_REQUEST, &type, sizeof(type), NULL); | |
896 } | |
897 | |
898 len = strlen(request); | |
899 | |
900 sess->userlist_blocks = 0; | |
901 | |
902 while (len > 2047) { | |
903 sess->userlist_blocks++; | |
904 | |
905 if (gg_send_packet(sess, GG_USERLIST_REQUEST, &type, sizeof(type), request, 2047, NULL) == -1) | |
906 return -1; | |
907 | |
908 if (type == GG_USERLIST_PUT) | |
909 type = GG_USERLIST_PUT_MORE; | |
910 | |
911 request += 2047; | |
912 len -= 2047; | |
913 } | |
914 | |
915 sess->userlist_blocks++; | |
916 | |
917 return gg_send_packet(sess, GG_USERLIST_REQUEST, &type, sizeof(type), request, len, NULL); | |
2393 | 918 } |
919 | |
920 /* | |
921 * gg_watch_fd_connected() // funkcja wewnźtrzna | |
922 * | |
923 * patrzy na socketa, odbiera pakiet i wype³nia strukturź zdarzenia. | |
924 * | |
925 * - sock - lalala, trudno zgadn±ę. | |
926 * | |
927 * je¶li b³±d -1, je¶li dobrze 0. | |
928 */ | |
929 static int gg_watch_fd_connected(struct gg_session *sess, struct gg_event *e) | |
930 { | |
931 struct gg_header *h; | |
8775 | 932 char *p; |
2393 | 933 |
934 if (!sess) { | |
935 errno = EFAULT; | |
936 return -1; | |
937 } | |
938 | |
939 gg_debug(GG_DEBUG_FUNCTION, "** gg_watch_fd_connected(...);\n"); | |
940 | |
941 if (!(h = gg_recv_packet(sess))) { | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
942 gg_debug(GG_DEBUG_MISC, "-- gg_recv_packet failed. errno = %d (%d)\n", errno, strerror(errno)); |
2393 | 943 return -1; |
944 } | |
945 | |
6247 | 946 p = (void *)h + sizeof(struct gg_header); |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
947 |
8775 | 948 |
949 switch (h->type) { | |
950 case GG_RECV_MSG: | |
951 { | |
952 struct gg_recv_msg *r = (void *)p; | |
2393 | 953 |
954 gg_debug(GG_DEBUG_MISC, "-- received a message\n"); | |
955 | |
956 if (h->length >= sizeof(*r)) { | |
957 e->type = GG_EVENT_MSG; | |
958 e->event.msg.msgclass = fix32(r->msgclass); | |
959 e->event.msg.sender = fix32(r->sender); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
960 e->event.msg.message = strdup((char*) r + sizeof(*r)); |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
961 e->event.msg.time = fix32(r->time); |
2393 | 962 } |
8775 | 963 break; |
964 } | |
965 case GG_NOTIFY_REPLY: | |
966 { | |
967 struct gg_notify_reply *n = (void *)p; | |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
968 int count, i; |
2393 | 969 |
970 gg_debug(GG_DEBUG_MISC, "-- received a notify reply\n"); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
971 |
2393 | 972 e->type = GG_EVENT_NOTIFY; |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
973 if (!(e->event.notify = (void*) malloc(h->length + 2 * sizeof(*n)))) { |
2393 | 974 gg_debug(GG_DEBUG_MISC, "-- not enough memory\n"); |
975 free(h); | |
976 return -1; | |
977 } | |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
978 count = h->length / sizeof(*n); |
2393 | 979 memcpy(e->event.notify, p, h->length); |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
980 e->event.notify[count].uin = 0; |
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
981 for (i = 0; i < count; i++) { |
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
982 e->event.notify[i].uin = fix32(e->event.notify[i].uin); |
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
983 e->event.notify[i].status = fix32(e->event.notify[i].status); |
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
984 } |
8775 | 985 break; |
986 } | |
987 | |
988 case GG_NOTIFY_REPLY60: | |
989 { | |
990 struct gg_notify_reply60 *n = (void*) p; | |
991 unsigned int length = h->length, i = 0; | |
992 | |
993 gg_debug(GG_DEBUG_MISC, "// gg_watch_fd_connected() received a notify reply\n"); | |
994 | |
995 e->type = GG_EVENT_NOTIFY60; | |
996 e->event.notify60 = malloc(sizeof(*e->event.notify60)); | |
997 | |
998 if (!e->event.notify60) { | |
999 gg_debug(GG_DEBUG_MISC, "// gg_watch_fd_connected() not enough memory for notify data\n"); | |
1000 goto fail; | |
1001 } | |
1002 | |
1003 e->event.notify60[0].uin = 0; | |
1004 | |
1005 while (length >= sizeof(struct gg_notify_reply60)) { | |
1006 uin_t uin = fix32(n->uin); | |
1007 char *tmp; | |
1008 | |
1009 e->event.notify60[i].uin = uin & 0x00ffffff; | |
1010 e->event.notify60[i].status = n->status; | |
1011 e->event.notify60[i].remote_ip = n->remote_ip; | |
1012 e->event.notify60[i].remote_port = fix16(n->remote_port); | |
1013 e->event.notify60[i].version = n->version; | |
1014 e->event.notify60[i].image_size = n->image_size; | |
1015 e->event.notify60[i].descr = NULL; | |
1016 e->event.notify60[i].time = 0; | |
1017 | |
1018 if (GG_S_D(n->status)) { | |
1019 unsigned char descr_len = *((char*) n + sizeof(struct gg_notify_reply60)); | |
2393 | 1020 |
8775 | 1021 if (descr_len < length) { |
1022 if (!(e->event.notify60[i].descr = malloc(descr_len + 1))) { | |
1023 gg_debug(GG_DEBUG_MISC, "// gg_watch_fd_connected() not enough memory for notify data\n"); | |
1024 goto fail; | |
1025 } | |
1026 | |
1027 memcpy(e->event.notify60[i].descr, (char*) n + sizeof(struct gg_notify_reply60) + 1, descr_len); | |
1028 e->event.notify60[i].descr[descr_len] = 0; | |
1029 | |
1030 /* XXX czas */ | |
1031 } | |
1032 | |
1033 length -= sizeof(struct gg_notify_reply60) + descr_len + 1; | |
1034 n = (void*) ((char*) n + sizeof(struct gg_notify_reply60) + descr_len + 1); | |
1035 } else { | |
1036 length -= sizeof(struct gg_notify_reply60); | |
1037 n = (void*) ((char*) n + sizeof(struct gg_notify_reply60)); | |
1038 } | |
1039 | |
1040 if (!(tmp = realloc(e->event.notify60, (i + 2) * sizeof(*e->event.notify60)))) { | |
1041 gg_debug(GG_DEBUG_MISC, "// gg_watch_fd_connected() not enough memory for notify data\n"); | |
1042 free(e->event.notify60); | |
1043 goto fail; | |
1044 } | |
1045 | |
1046 e->event.notify60 = (void*) tmp; | |
1047 e->event.notify60[++i].uin = 0; | |
1048 } | |
1049 | |
1050 break; | |
1051 } | |
1052 | |
1053 case GG_STATUS: | |
1054 { | |
1055 struct gg_status *s = (void *)p; | |
2393 | 1056 |
1057 gg_debug(GG_DEBUG_MISC, "-- received a status change\n"); | |
1058 | |
1059 if (h->length >= sizeof(*s)) { | |
1060 e->type = GG_EVENT_STATUS; | |
1061 memcpy(&e->event.status, p, h->length); | |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
1062 e->event.status.uin = fix32(e->event.status.uin); |
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
1063 e->event.status.status = fix32(e->event.status.status); |
2393 | 1064 } |
8775 | 1065 break; |
1066 } | |
1067 | |
1068 case GG_STATUS60: | |
1069 { | |
1070 struct gg_status60 *s = (void*) p; | |
1071 uint32_t uin; | |
1072 | |
1073 gg_debug(GG_DEBUG_MISC, "// gg_watch_fd_connected() received a status change\n"); | |
1074 | |
1075 if (h->length < sizeof(*s)) | |
1076 break; | |
1077 | |
1078 uin = fix32(s->uin); | |
1079 | |
1080 e->type = GG_EVENT_STATUS60; | |
1081 e->event.status60.uin = uin & 0x00ffffff; | |
1082 e->event.status60.status = s->status; | |
1083 e->event.status60.remote_ip = s->remote_ip; | |
1084 e->event.status60.remote_port = fix16(s->remote_port); | |
1085 e->event.status60.version = s->version; | |
1086 e->event.status60.image_size = s->image_size; | |
1087 e->event.status60.descr = NULL; | |
1088 e->event.status60.time = 0; | |
2393 | 1089 |
8775 | 1090 if (uin & 0x40000000) |
1091 e->event.status60.version |= GG_HAS_AUDIO_MASK; | |
1092 | |
1093 if (h->length > sizeof(*s)) { | |
1094 int len = h->length - sizeof(*s); | |
1095 char *buf = malloc(len + 1); | |
1096 | |
1097 if (buf) { | |
1098 memcpy(buf, (char*) p + sizeof(*s), len); | |
1099 buf[len] = 0; | |
1100 } | |
1101 | |
1102 e->event.status60.descr = buf; | |
1103 | |
1104 if (len > 4 && p[h->length - 5] == 0) | |
1105 e->event.status60.time = *((int*) (p + h->length - 4)); | |
1106 } | |
1107 | |
1108 break; | |
1109 } | |
1110 | |
1111 case GG_SEND_MSG_ACK: | |
1112 { | |
1113 struct gg_send_msg_ack *s = (void *)p; | |
2393 | 1114 |
1115 gg_debug(GG_DEBUG_MISC, "-- received a message ack\n"); | |
1116 | |
1117 if (h->length >= sizeof(*s)) { | |
1118 e->type = GG_EVENT_ACK; | |
1119 e->event.ack.status = fix32(s->status); | |
1120 e->event.ack.recipient = fix32(s->recipient); | |
1121 e->event.ack.seq = fix32(s->seq); | |
1122 } | |
8775 | 1123 break; |
1124 } | |
2393 | 1125 |
8775 | 1126 case GG_PONG: |
1127 { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1128 gg_debug(GG_DEBUG_MISC, "-- received a pong\n"); |
3630 | 1129 ping_outstanding = 0; |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1130 sess->last_pong = time(NULL); |
8775 | 1131 break; |
1132 } | |
1133 | |
1134 case GG_USERLIST_REPLY: | |
1135 { | |
1136 gg_debug(GG_DEBUG_MISC, "// gg_watch_fd_connected() received userlist reply\n"); | |
1137 | |
1138 if (h->length < 1) | |
1139 break; | |
1140 | |
1141 /* je¶li odpowied¼ na eksport, wywo³aj zdarzenie tylko | |
1142 * gdy otrzymano wszystkie odpowiedzi */ | |
1143 if (p[0] == GG_USERLIST_PUT_REPLY || p[0] == GG_USERLIST_PUT_MORE_REPLY) { | |
1144 if (--sess->userlist_blocks) | |
1145 break; | |
1146 | |
1147 p[0] = GG_USERLIST_PUT_REPLY; | |
1148 } | |
1149 | |
1150 if (h->length > 1) { | |
1151 char *tmp; | |
1152 int len = (sess->userlist_reply) ? strlen(sess->userlist_reply) : 0; | |
1153 | |
1154 gg_debug(GG_DEBUG_MISC, "userlist_reply=%p, len=%d\n", sess->userlist_reply, len); | |
1155 | |
1156 if (!(tmp = realloc(sess->userlist_reply, len + h->length))) { | |
1157 gg_debug(GG_DEBUG_MISC, "// gg_watch_fd_connected() not enough memory for userlist reply\n"); | |
1158 free(sess->userlist_reply); | |
1159 sess->userlist_reply = NULL; | |
1160 goto fail; | |
1161 } | |
1162 | |
1163 sess->userlist_reply = tmp; | |
1164 sess->userlist_reply[len + h->length - 1] = 0; | |
1165 memcpy(sess->userlist_reply + len, p + 1, h->length - 1); | |
1166 } | |
1167 | |
1168 if (p[0] == GG_USERLIST_GET_MORE_REPLY) | |
1169 break; | |
1170 | |
1171 e->type = GG_EVENT_USERLIST; | |
1172 e->event.userlist.type = p[0]; | |
1173 e->event.userlist.reply = sess->userlist_reply; | |
1174 sess->userlist_reply = NULL; | |
1175 | |
1176 break; | |
1177 } | |
1178 | |
1179 default: | |
1180 gg_debug(GG_DEBUG_MISC, "// gg_watch_fd_connected() received unknown packet 0x%.2x\n", h->type); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1181 } |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1182 |
2393 | 1183 free(h); |
1184 | |
1185 return 0; | |
8775 | 1186 |
1187 fail: | |
1188 free(h); | |
1189 return -1; | |
2393 | 1190 } |
1191 | |
1192 /* | |
1193 * gg_watch_fd() | |
1194 * | |
1195 * funkcja wywo³ywana, gdy co¶ siź stanie na obserwowanym deskryptorze. | |
1196 * zwraca klientowi informacjź o tym, co siź dzieje. | |
1197 * | |
1198 * - sess - identyfikator sesji. | |
1199 * | |
1200 * zwraca wska¼nik do struktury gg_event, któr± trzeba zwolnię pó¼niej | |
1201 * za pomoc± gg_free_event(). jesli rodzaj zdarzenia jest równy | |
1202 * GG_EVENT_NONE, naleæy je olaę kompletnie. je¶li zwróci³o NULL, | |
1203 * sta³o siź co¶ niedobrego -- albo brak³o pamiźci albo zerwa³o | |
1204 * po³±czenie albo co¶ takiego. | |
1205 */ | |
1206 struct gg_event *gg_watch_fd(struct gg_session *sess) | |
1207 { | |
1208 struct gg_event *e; | |
1209 int res = 0; | |
3630 | 1210 #ifndef _WIN32 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1211 int port; |
3630 | 1212 #endif |
2393 | 1213 |
1214 if (!sess) { | |
1215 errno = EFAULT; | |
1216 return NULL; | |
1217 } | |
1218 | |
1219 gg_debug(GG_DEBUG_FUNCTION, "** gg_watch_fd(...);\n"); | |
1220 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1221 if (!(e = (void*) malloc(sizeof(*e)))) { |
2393 | 1222 gg_debug(GG_DEBUG_MISC, "-- not enough memory\n"); |
1223 return NULL; | |
1224 } | |
1225 | |
1226 e->type = GG_EVENT_NONE; | |
1227 | |
1228 switch (sess->state) { | |
3630 | 1229 #ifndef _WIN32 |
1230 /* Apparantly we will never be in this state as long as we are | |
5681
46d7ad0dfa26
[gaim-migrate @ 6100]
Christian Hammond <chipx86@chipx86.com>
parents:
4298
diff
changeset
|
1231 using gaim_proxy_connect instead of gg_login - Herman */ |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1232 case GG_STATE_RESOLVING: |
2393 | 1233 { |
1234 struct in_addr a; | |
1235 | |
1236 gg_debug(GG_DEBUG_MISC, "== GG_STATE_RESOLVING\n"); | |
1237 | |
1238 if (read(sess->fd, &a, sizeof(a)) < sizeof(a) || a.s_addr == INADDR_NONE) { | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1239 gg_debug(GG_DEBUG_MISC, "-- resolving failed\n"); |
2393 | 1240 |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1241 errno = ENOENT; |
2393 | 1242 e->type = GG_EVENT_CONN_FAILED; |
1243 e->event.failure = GG_FAILURE_RESOLVING; | |
1244 sess->state = GG_STATE_IDLE; | |
1245 | |
1246 close(sess->fd); | |
1247 | |
1248 break; | |
1249 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1250 |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1251 sess->server_ip = a.s_addr; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1252 |
2393 | 1253 close(sess->fd); |
1254 | |
1255 waitpid(sess->pid, NULL, 0); | |
1256 | |
1257 gg_debug(GG_DEBUG_MISC, "-- resolved, now connecting\n"); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1258 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1259 if (gg_http_use_proxy) { |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1260 port = gg_http_proxy_port; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1261 } else { |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1262 port = GG_APPMSG_PORT; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1263 }; |
2393 | 1264 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1265 if ((sess->fd = gg_connect(&a, port, sess->async)) == -1) { |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1266 struct in_addr *addr = (struct in_addr*) &sess->server_ip; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1267 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1268 gg_debug(GG_DEBUG_MISC, "-- connection failed, trying direct connection\n"); |
2393 | 1269 |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1270 if ((sess->fd = gg_connect(addr, GG_DEFAULT_PORT, sess->async)) == -1) { |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1271 gg_debug(GG_DEBUG_MISC, "-- connection failed, trying https connection\n"); |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1272 if ((sess->fd = gg_connect(&a, GG_HTTPS_PORT, sess->async)) == -1) { |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1273 gg_debug(GG_DEBUG_MISC, "-- connect() failed. errno = %d (%s)\n", errno, strerror(errno)); |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1274 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1275 e->type = GG_EVENT_CONN_FAILED; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1276 e->event.failure = GG_FAILURE_CONNECTING; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1277 sess->state = GG_STATE_IDLE; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1278 break; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1279 } |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1280 } |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1281 sess->state = GG_STATE_CONNECTING_GG; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1282 sess->check = GG_CHECK_WRITE; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1283 } else { |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1284 sess->state = GG_STATE_CONNECTING; |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1285 sess->check = GG_CHECK_WRITE; |
2393 | 1286 } |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1287 |
2393 | 1288 break; |
1289 } | |
3630 | 1290 #endif /* !_WIN32 */ |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1291 case GG_STATE_CONNECTING: |
2393 | 1292 { |
1293 char buf[1024]; | |
6063 | 1294 unsigned int res, res_size = sizeof(res); |
2393 | 1295 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1296 gg_debug(GG_DEBUG_MISC, "== GG_STATE_CONNECTING\n"); |
2393 | 1297 |
3717
988485669631
[gaim-migrate @ 3850]
Herman Bloggs <hermanator12002@yahoo.com>
parents:
3630
diff
changeset
|
1298 if (sess->async && (getsockopt(sess->fd, SOL_SOCKET, SO_ERROR, &res, &res_size) || res)) { |
3630 | 1299 #if 0 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1300 struct in_addr *addr = (struct in_addr*) &sess->server_ip; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1301 gg_debug(GG_DEBUG_MISC, "-- http connection failed, errno = %d (%s), trying direct connection\n", res, strerror(res)); |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1302 if ((sess->fd = gg_connect(addr, GG_DEFAULT_PORT, sess->async)) == -1) { |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1303 gg_debug(GG_DEBUG_MISC, "-- connection failed, trying https connection\n"); |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1304 if ((sess->fd = gg_connect(addr, GG_HTTPS_PORT, sess->async)) == -1) { |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1305 gg_debug(GG_DEBUG_MISC, "-- connect() failed. errno = %d (%s)\n", errno, strerror(errno)); |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1306 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1307 e->type = GG_EVENT_CONN_FAILED; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1308 e->event.failure = GG_FAILURE_CONNECTING; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1309 sess->state = GG_STATE_IDLE; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1310 break; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1311 } |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1312 } |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1313 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1314 sess->state = GG_STATE_CONNECTING_GG; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1315 sess->check = GG_CHECK_WRITE; |
3630 | 1316 #else |
1317 gg_debug(GG_DEBUG_MISC, "-- http connection failed, errno = %d\n", res); | |
1318 e->type = GG_EVENT_CONN_FAILED; | |
1319 e->event.failure = GG_FAILURE_CONNECTING; | |
1320 sess->state = GG_STATE_IDLE; | |
1321 #endif | |
2393 | 1322 break; |
1323 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1324 |
2393 | 1325 gg_debug(GG_DEBUG_MISC, "-- http connection succeded, sending query\n"); |
1326 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1327 if (gg_http_use_proxy) { |
3630 | 1328 g_snprintf(buf, sizeof(buf) - 1, |
9663 | 1329 "GET http://" GG_APPMSG_HOST "/appsvc/appmsg2.asp?fmnumber=%lu&version=%s&lastmsg=0 HTTP/1.0\r\n" |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1330 "Host: " GG_APPMSG_HOST "\r\n" |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1331 "User-Agent: " GG_HTTP_USERAGENT "\r\n" |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1332 "Pragma: no-cache\r\n" |
9663 | 1333 "\r\n", sess->uin, gg_urlencode(GG_DEFAULT_CLIENT_VERSION)); |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1334 } else { |
3630 | 1335 g_snprintf(buf, sizeof(buf) - 1, |
9663 | 1336 "GET /appsvc/appmsg2.asp?fmnumber=%lu&version=%s&lastmsg=0 HTTP/1.0\r\n" |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1337 "Host: " GG_APPMSG_HOST "\r\n" |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1338 "User-Agent: " GG_HTTP_USERAGENT "\r\n" |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1339 "Pragma: no-cache\r\n" |
9663 | 1340 "\r\n", sess->uin, gg_urlencode(GG_DEFAULT_CLIENT_VERSION)); |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1341 }; |
2393 | 1342 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1343 gg_debug(GG_DEBUG_MISC, "=> -----BEGIN-HTTP-QUERY-----\n%s\n=> -----END-HTTP-QUERY-----\n", buf); |
2393 | 1344 if (write(sess->fd, buf, strlen(buf)) < strlen(buf)) { |
1345 gg_debug(GG_DEBUG_MISC, "-- sending query failed\n"); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1346 errno = EIO; |
2393 | 1347 e->type = GG_EVENT_CONN_FAILED; |
1348 e->event.failure = GG_FAILURE_WRITING; | |
1349 sess->state = GG_STATE_IDLE; | |
1350 break; | |
1351 } | |
1352 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1353 sess->state = GG_STATE_READING_DATA; |
2393 | 1354 sess->check = GG_CHECK_READ; |
1355 | |
1356 break; | |
1357 } | |
1358 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1359 case GG_STATE_READING_DATA: |
2393 | 1360 { |
1361 char buf[1024], *tmp, *host; | |
1362 int port = GG_DEFAULT_PORT; | |
1363 struct in_addr a; | |
1364 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1365 gg_debug(GG_DEBUG_MISC, "== GG_STATE_READING_DATA\n"); |
2393 | 1366 |
1367 gg_read_line(sess->fd, buf, sizeof(buf) - 1); | |
1368 gg_chomp(buf); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1369 |
2393 | 1370 gg_debug(GG_DEBUG_TRAFFIC, "-- got http response (%s)\n", buf); |
1371 if (strncmp(buf, "HTTP/1.", 7) || strncmp(buf + 9, "200", 3)) { | |
1372 gg_debug(GG_DEBUG_MISC, "-- but that's not what we've expected\n"); | |
1373 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1374 errno = EINVAL; |
2393 | 1375 e->type = GG_EVENT_CONN_FAILED; |
1376 e->event.failure = GG_FAILURE_INVALID; | |
1377 sess->state = GG_STATE_IDLE; | |
1378 break; | |
1379 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1380 |
2393 | 1381 while (strcmp(buf, "\r\n") && strcmp(buf, "")) |
1382 gg_read_line(sess->fd, buf, sizeof(buf) - 1); | |
1383 | |
1384 gg_read_line(sess->fd, buf, sizeof(buf) - 1); | |
1385 gg_chomp(buf); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1386 |
2393 | 1387 close(sess->fd); |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1388 |
2393 | 1389 gg_debug(GG_DEBUG_TRAFFIC, "-- received http data (%s)\n", buf); |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1390 |
8775 | 1391 /* analizujemy otrzymane dane. */ |
2393 | 1392 tmp = buf; |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1393 |
2393 | 1394 while (*tmp && *tmp != ' ') |
9663 | 1395 tmp++; |
1396 while (*tmp && *tmp == ' ') | |
1397 tmp++; | |
1398 host = tmp; | |
1399 while (*tmp && *tmp != ' ') | |
1400 tmp++; | |
1401 *tmp = 0; | |
2393 | 1402 |
1403 if ((tmp = strchr(host, ':'))) { | |
1404 *tmp = 0; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1405 port = atoi(tmp+1); |
2393 | 1406 } |
1407 | |
1408 a.s_addr = inet_addr(host); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1409 sess->server_ip = a.s_addr; |
8775 | 1410 |
3630 | 1411 #if 0 |
5681
46d7ad0dfa26
[gaim-migrate @ 6100]
Christian Hammond <chipx86@chipx86.com>
parents:
4298
diff
changeset
|
1412 /* We need to watch this non-blocking socket so lets use gaim_proxy_connect |
3630 | 1413 in gg.c - Herman */ |
1414 if((sess->fd = gg_connect(&a, port, sess->assync)) == -1) { | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1415 gg_debug(GG_DEBUG_MISC, "-- connection failed, trying https connection\n"); |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1416 if ((sess->fd = gg_connect(&a, GG_HTTPS_PORT, sess->async)) == -1) { |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1417 gg_debug(GG_DEBUG_MISC, "-- connection failed, errno = %d (%s)\n", errno, strerror(errno)); |
2393 | 1418 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1419 e->type = GG_EVENT_CONN_FAILED; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1420 e->event.failure = GG_FAILURE_CONNECTING; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1421 sess->state = GG_STATE_IDLE; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1422 break; |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1423 } |
2393 | 1424 } |
3630 | 1425 #else |
1426 sess->port = port; | |
1427 #endif | |
2393 | 1428 sess->state = GG_STATE_CONNECTING_GG; |
1429 sess->check = GG_CHECK_WRITE; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1430 |
2393 | 1431 break; |
1432 } | |
1433 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1434 case GG_STATE_CONNECTING_GG: |
2393 | 1435 { |
6063 | 1436 unsigned int res, res_size = sizeof(res); |
2393 | 1437 |
1438 gg_debug(GG_DEBUG_MISC, "== GG_STATE_CONNECTING_GG\n"); | |
1439 | |
3717
988485669631
[gaim-migrate @ 3850]
Herman Bloggs <hermanator12002@yahoo.com>
parents:
3630
diff
changeset
|
1440 if (sess->async && (getsockopt(sess->fd, SOL_SOCKET, SO_ERROR, &res, &res_size) || res)) { |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1441 struct in_addr *addr = (struct in_addr*) &sess->server_ip; |
2393 | 1442 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1443 gg_debug(GG_DEBUG_MISC, "-- connection failed, trying https connection\n"); |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1444 if ((sess->fd = gg_connect(addr, GG_HTTPS_PORT, sess->async)) == -1) { |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1445 gg_debug(GG_DEBUG_MISC, "-- connection failed, errno = %d (%s)\n", errno, strerror(errno)); |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1446 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1447 e->type = GG_EVENT_CONN_FAILED; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1448 e->event.failure = GG_FAILURE_CONNECTING; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1449 sess->state = GG_STATE_IDLE; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1450 break; |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1451 } |
2393 | 1452 } |
1453 | |
1454 gg_debug(GG_DEBUG_MISC, "-- connected\n"); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1455 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1456 sess->state = GG_STATE_READING_KEY; |
2393 | 1457 sess->check = GG_CHECK_READ; |
1458 | |
1459 break; | |
1460 } | |
1461 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1462 case GG_STATE_READING_KEY: |
2393 | 1463 { |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1464 struct gg_header *h; |
2393 | 1465 struct gg_welcome *w; |
8775 | 1466 struct gg_login60 l; |
2393 | 1467 unsigned int hash; |
1468 char *password = sess->password; | |
1469 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1470 gg_debug(GG_DEBUG_MISC, "== GG_STATE_READING_KEY\n"); |
2393 | 1471 |
1472 if (!(h = gg_recv_packet(sess))) { | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1473 gg_debug(GG_DEBUG_MISC, "-- gg_recv_packet() failed. errno = %d (%s)\n", errno, strerror(errno)); |
2393 | 1474 e->type = GG_EVENT_CONN_FAILED; |
1475 e->event.failure = GG_FAILURE_READING; | |
1476 sess->state = GG_STATE_IDLE; | |
1477 close(sess->fd); | |
1478 break; | |
1479 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1480 |
2393 | 1481 if (h->type != GG_WELCOME) { |
1482 gg_debug(GG_DEBUG_MISC, "-- invalid packet received\n"); | |
1483 | |
1484 free(h); | |
1485 close(sess->fd); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1486 errno = EINVAL; |
2393 | 1487 e->type = GG_EVENT_CONN_FAILED; |
1488 e->event.failure = GG_FAILURE_INVALID; | |
1489 sess->state = GG_STATE_IDLE; | |
1490 break; | |
1491 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1492 |
6247 | 1493 w = (struct gg_welcome *)((void *)h + sizeof(struct gg_header)); |
2393 | 1494 w->key = fix32(w->key); |
8775 | 1495 |
1496 hash = gg_login_hash(password, w->key); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1497 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1498 gg_debug(GG_DEBUG_DUMP, "%%%% klucz serwera %.4x, hash has³a %.8x\n", w->key, hash); |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1499 |
2393 | 1500 free(h); |
1501 | |
1502 free(sess->password); | |
1503 sess->password = NULL; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1504 |
2393 | 1505 l.uin = fix32(sess->uin); |
1506 l.hash = fix32(hash); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1507 l.status = fix32(sess->initial_status ? sess->initial_status : GG_STATUS_AVAIL); |
8775 | 1508 l.version = fix32(0x20); |
2393 | 1509 l.local_ip = 0; |
1510 l.local_port = 0; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1511 |
2393 | 1512 gg_debug(GG_DEBUG_TRAFFIC, "-- sending GG_LOGIN packet\n"); |
1513 | |
8775 | 1514 if (gg_send_packet(sess, GG_LOGIN60, &l, sizeof(l), NULL, 0) == -1) { |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1515 gg_debug(GG_DEBUG_TRAFFIC, "-- oops, failed. errno = %d (%s)\n", errno, strerror(errno)); |
2393 | 1516 |
1517 close(sess->fd); | |
1518 e->type = GG_EVENT_CONN_FAILED; | |
1519 e->event.failure = GG_FAILURE_WRITING; | |
1520 sess->state = GG_STATE_IDLE; | |
1521 break; | |
1522 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1523 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1524 sess->state = GG_STATE_READING_REPLY; |
2393 | 1525 |
1526 break; | |
1527 } | |
1528 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1529 case GG_STATE_READING_REPLY: |
2393 | 1530 { |
1531 struct gg_header *h; | |
1532 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1533 gg_debug(GG_DEBUG_MISC, "== GG_STATE_READING_REPLY\n"); |
2393 | 1534 |
1535 if (!(h = gg_recv_packet(sess))) { | |
1536 gg_debug(GG_DEBUG_MISC, "-- recv_packet failed\n"); | |
1537 e->type = GG_EVENT_CONN_FAILED; | |
1538 e->event.failure = GG_FAILURE_READING; | |
1539 sess->state = GG_STATE_IDLE; | |
1540 close(sess->fd); | |
1541 break; | |
1542 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1543 |
2393 | 1544 if (h->type == GG_LOGIN_OK) { |
1545 gg_debug(GG_DEBUG_MISC, "-- login succeded\n"); | |
1546 e->type = GG_EVENT_CONN_SUCCESS; | |
1547 sess->state = GG_STATE_CONNECTED; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1548 free(h); |
2393 | 1549 break; |
1550 } | |
1551 | |
1552 if (h->type == GG_LOGIN_FAILED) { | |
1553 gg_debug(GG_DEBUG_MISC, "-- login failed\n"); | |
1554 e->event.failure = GG_FAILURE_PASSWORD; | |
1555 errno = EACCES; | |
1556 } else { | |
1557 gg_debug(GG_DEBUG_MISC, "-- invalid packet\n"); | |
1558 e->event.failure = GG_FAILURE_INVALID; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1559 errno = EINVAL; |
2393 | 1560 } |
1561 | |
1562 e->type = GG_EVENT_CONN_FAILED; | |
1563 sess->state = GG_STATE_IDLE; | |
1564 close(sess->fd); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1565 free(h); |
2393 | 1566 |
1567 break; | |
1568 } | |
1569 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1570 case GG_STATE_CONNECTED: |
2393 | 1571 { |
1572 gg_debug(GG_DEBUG_MISC, "== GG_STATE_CONNECTED\n"); | |
1573 | |
1574 if ((res = gg_watch_fd_connected(sess, e)) == -1) { | |
1575 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1576 gg_debug(GG_DEBUG_MISC, "-- watch_fd_connected failed. errno = %d (%s)\n", errno, strerror(errno)); |
2393 | 1577 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1578 if (errno == EAGAIN) { |
2393 | 1579 e->type = GG_EVENT_NONE; |
1580 res = 0; | |
1581 } else | |
1582 res = -1; | |
1583 } | |
1584 break; | |
1585 } | |
1586 } | |
1587 | |
1588 if (res == -1) { | |
1589 free(e); | |
1590 e = NULL; | |
1591 } | |
1592 | |
1593 return e; | |
1594 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1595 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1596 /* |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1597 * Local variables: |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1598 * c-indentation-style: k&r |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1599 * c-basic-offset: 8 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1600 * indent-tabs-mode: notnil |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1601 * End: |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1602 * |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1603 * vim: shiftwidth=8: |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1604 */ |