Mercurial > pidgin
annotate src/protocols/gg/libgg.c @ 3630:9682c0e022c6
[gaim-migrate @ 3753]
Yeah this will probably break a lot of shit knowing my luck. But hey, I really don't care what people thnk.
committer: Tailor Script <tailor@pidgin.im>
author | Rob Flynn <gaim@robflynn.com> |
---|---|
date | Fri, 11 Oct 2002 03:14:01 +0000 |
parents | 4b3f17ca66bf |
children | 988485669631 |
rev | line source |
---|---|
3630 | 1 /* $Id: libgg.c 3753 2002-10-11 03:14:01Z robflynn $ */ |
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 | |
3630 | 21 #ifndef _WIN32 |
2393 | 22 #include <sys/socket.h> |
23 #include <netinet/in.h> | |
24 #include <arpa/inet.h> | |
25 #include <sys/ioctl.h> | |
26 #include <sys/wait.h> | |
3630 | 27 #include <netdb.h> |
28 #include <pwd.h> | |
29 #else | |
30 #include <winsock.h> | |
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 |
2393 | 52 #include "libgg.h" |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
53 #include "config.h" |
3630 | 54 #include "gaim.h" |
55 #include "proxy.h" | |
2393 | 56 |
3630 | 57 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
|
58 int gg_http_use_proxy = 0; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
59 int gg_http_proxy_port = 0; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
60 char *gg_http_proxy_host = NULL; |
2393 | 61 |
3630 | 62 /* temp -Herman */ |
63 static int ping_outstanding = 0; | |
64 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
65 #ifndef lint |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
66 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
67 static char rcsid[] |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
68 #ifdef __GNUC__ |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
69 __attribute__ ((unused)) |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
70 #endif |
3630 | 71 = "$Id: libgg.c 3753 2002-10-11 03:14:01Z robflynn $"; |
2393 | 72 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
73 #endif |
2393 | 74 |
75 /* | |
76 * fix32() // funkcja wewnętrzna | |
77 * | |
78 * dla maszyn big-endianowych zamienia kolejność bajtów w ,,long''ach. | |
79 */ | |
80 static inline unsigned long fix32(unsigned long x) | |
81 { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
82 #ifndef WORDS_BIGENDIAN |
2393 | 83 return x; |
84 #else | |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
85 return (unsigned long) |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
86 (((x & (unsigned long) 0x000000ffU) << 24) | |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
87 ((x & (unsigned long) 0x0000ff00U) << 8) | |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
88 ((x & (unsigned long) 0x00ff0000U) >> 8) | |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
89 ((x & (unsigned long) 0xff000000U) >> 24)); |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
90 #endif |
2393 | 91 } |
92 | |
93 /* | |
94 * fix16() // funkcja wewnętrzna | |
95 * | |
96 * dla maszyn big-endianowych zamienia kolejność bajtów w ,,short''ach. | |
97 */ | |
98 static inline unsigned short fix16(unsigned short x) | |
99 { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
100 #ifndef WORDS_BIGENDIAN |
2393 | 101 return x; |
102 #else | |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
103 return (unsigned short) |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
104 (((x & (unsigned short) 0x00ffU) << 8) | |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
105 ((x & (unsigned short) 0xff00U) >> 8)); |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
106 #endif |
2393 | 107 } |
108 | |
3630 | 109 #ifndef _WIN32 |
2393 | 110 /* |
111 * gg_resolve() // funkcja wewnętrzna | |
112 * | |
113 * tworzy pipe'y, forkuje się i w drugim procesie zaczyna resolvować | |
114 * podanego hosta. zapisuje w sesji deskryptor pipe'u. jeśli coś tam | |
115 * będzie gotowego, znaczy, że można wczytać ,,struct in_addr''. jeśli | |
116 * nie znajdzie, zwraca INADDR_NONE. | |
117 * | |
118 * - fd - wskaźnik gdzie wrzucić deskryptor, | |
119 * - pid - gdzie wrzucić pid dzieciaka, | |
120 * - hostname - nazwa hosta do zresolvowania. | |
121 * | |
122 * zwraca 0 jeśli udało się odpalić proces lub -1 w przypadku błędu. | |
123 */ | |
124 int gg_resolve(int *fd, int *pid, char *hostname) | |
125 { | |
126 int pipes[2], res; | |
127 struct in_addr a; | |
128 | |
129 gg_debug(GG_DEBUG_FUNCTION, "** gg_resolve(..., \"%s\");\n", hostname); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
130 |
2393 | 131 if (!fd | !pid) { |
132 errno = EFAULT; | |
133 return -1; | |
134 } | |
135 | |
136 if (pipe(pipes) == -1) | |
137 return -1; | |
138 | |
139 if ((res = fork()) == -1) | |
140 return -1; | |
141 | |
142 if (!res) { | |
143 if ((a.s_addr = inet_addr(hostname)) == INADDR_NONE) { | |
144 struct hostent *he; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
145 |
2393 | 146 if (!(he = gethostbyname(hostname))) |
147 a.s_addr = INADDR_NONE; | |
148 else | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
149 memcpy((char*) &a, he->h_addr, sizeof(a)); |
2393 | 150 } |
151 | |
152 write(pipes[1], &a, sizeof(a)); | |
153 | |
154 exit(0); | |
155 } | |
156 | |
157 close(pipes[1]); | |
158 | |
159 *fd = pipes[0]; | |
160 *pid = res; | |
161 | |
162 return 0; | |
163 } | |
3630 | 164 #endif /*!_WIN32*/ |
2393 | 165 |
166 /* | |
167 * gg_recv_packet() // funkcja wewnętrzna | |
168 * | |
169 * odbiera jeden pakiet gg i zwraca wskaźnik do niego. pamięć po nim | |
170 * wypadałoby uwolnić. | |
171 * | |
172 * - sock - połączony socket. | |
173 * | |
174 * jeśli wystąpił błąd, zwraca NULL. reszta w errno. | |
175 */ | |
176 static void *gg_recv_packet(struct gg_session *sess) | |
177 { | |
178 struct gg_header h; | |
179 char *buf = NULL; | |
180 int ret = 0, offset, size = 0; | |
3630 | 181 int sizeh = sizeof(struct gg_header); |
2393 | 182 |
183 gg_debug(GG_DEBUG_FUNCTION, "** gg_recv_packet(...);\n"); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
184 |
2393 | 185 if (!sess) { |
186 errno = EFAULT; | |
187 return NULL; | |
188 } | |
189 | |
190 if (sess->recv_left < 1) { | |
3630 | 191 while (ret != sizeh) { |
192 #ifndef _WIN32 | |
193 ret = read(sess->fd, &h, sizeh); | |
194 gg_debug(GG_DEBUG_MISC, "-- header recv(..., %d) = %d\n", sizeh, ret); | |
195 if (ret < sizeh) { | |
2393 | 196 if (errno != EINTR) { |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
197 gg_debug(GG_DEBUG_MISC, "-- errno = %d (%s)\n", errno, strerror(errno)); |
2393 | 198 return NULL; |
199 } | |
200 } | |
3630 | 201 #else |
202 ret = recv(sess->fd, (char*)&h, sizeh, 0); | |
203 gg_debug(GG_DEBUG_MISC, "-- header recv(..., %d) = %d\n", sizeh, ret); | |
204 if (ret < sizeh) { | |
205 /* connection has been gracefully closed */ | |
206 if (ret == 0) { | |
207 gg_debug(GG_DEBUG_MISC, "Connection has been gracefully closed\n"); | |
208 WSASetLastError(WSAEDISCON); | |
209 return NULL; | |
210 } | |
211 else if (ret == SOCKET_ERROR) { | |
212 if(WSAGetLastError() != WSAEINTR) { | |
213 gg_debug(GG_DEBUG_MISC, "-- socket error = %d\n", WSAGetLastError()); | |
214 return NULL; | |
215 } | |
216 } | |
217 | |
218 } | |
219 #endif | |
2393 | 220 } |
221 | |
222 h.type = fix32(h.type); | |
223 h.length = fix32(h.length); | |
224 } else { | |
3630 | 225 memcpy(&h, sess->recv_buf, sizeh); |
2393 | 226 } |
227 | |
228 /* jakieś sensowne limity na rozmiar pakietu */ | |
229 if (h.length < 0 || h.length > 65535) { | |
230 gg_debug(GG_DEBUG_MISC, "-- invalid packet length (%d)\n", h.length); | |
231 errno = ERANGE; | |
232 return NULL; | |
233 } | |
234 | |
235 if (sess->recv_left > 0) { | |
236 gg_debug(GG_DEBUG_MISC, "-- resuming last gg_recv_packet()\n"); | |
237 size = sess->recv_left; | |
238 offset = sess->recv_done; | |
239 buf = sess->recv_buf; | |
240 } else { | |
3630 | 241 if (!(buf = malloc(sizeh + h.length + 1))) { |
2393 | 242 gg_debug(GG_DEBUG_MISC, "-- not enough memory\n"); |
243 return NULL; | |
244 } | |
245 | |
3630 | 246 memcpy(buf, &h, sizeh); |
2393 | 247 |
248 offset = 0; | |
249 size = h.length; | |
250 } | |
251 | |
252 while (size > 0) { | |
3630 | 253 #ifndef _WIN32 |
254 ret = read(sess->fd, buf + sizeh + offset, size); | |
255 #else | |
256 ret = recv(sess->fd, buf + sizeh + offset, size, 0); | |
257 #endif | |
2393 | 258 gg_debug(GG_DEBUG_MISC, "-- body recv(..., %d) = %d\n", size, ret); |
259 if (ret > -1 && ret <= size) { | |
260 offset += ret; | |
261 size -= ret; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
262 } else if (ret == -1) { |
3630 | 263 #ifndef _WIN32 |
2393 | 264 gg_debug(GG_DEBUG_MISC, "-- errno = %d (%s)\n", errno, strerror(errno)); |
265 if (errno == EAGAIN) { | |
266 gg_debug(GG_DEBUG_MISC, "-- %d bytes received, %d left\n", offset, size); | |
267 sess->recv_buf = buf; | |
268 sess->recv_left = size; | |
269 sess->recv_done = offset; | |
270 return NULL; | |
271 } | |
272 if (errno != EINTR) { | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
273 // errno = EINVAL; |
2393 | 274 free(buf); |
275 return NULL; | |
276 } | |
3630 | 277 #else |
278 gg_debug(GG_DEBUG_MISC, "-- errno = %d\n", WSAGetLastError()); | |
279 if (WSAGetLastError()!= WSAEINTR) { | |
280 free(buf); | |
281 return NULL; | |
282 } | |
283 #endif | |
2393 | 284 } |
285 } | |
286 | |
287 sess->recv_left = 0; | |
288 | |
289 if ((gg_debug_level & GG_DEBUG_DUMP)) { | |
290 int i; | |
291 | |
292 gg_debug(GG_DEBUG_DUMP, ">> received packet (type=%.2x):", h.type); | |
3630 | 293 for (i = 0; i < sizeh + h.length; i++) |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
294 gg_debug(GG_DEBUG_DUMP, " %.2x", (unsigned char) buf[i]); |
2393 | 295 gg_debug(GG_DEBUG_DUMP, "\n"); |
296 } | |
297 | |
298 return buf; | |
299 } | |
300 | |
301 /* | |
302 * gg_send_packet() // funkcja wewnętrzna | |
303 * | |
304 * konstruuje pakiet i wysyła go w do serwera. | |
305 * | |
306 * - sock - połączony socket, | |
307 * - type - typ pakietu, | |
308 * - packet - wskaźnik do struktury pakietu, | |
309 * - length - długość struktury pakietu, | |
310 * - payload - dodatkowy tekst doklejany do pakietu (np. wiadomość), | |
311 * - payload_length - długość dodatkowego tekstu. | |
312 * | |
313 * jeśli poszło dobrze, zwraca 0. w przypadku błędu -1. jeśli errno=ENOMEM, | |
314 * zabrakło pamięci. inaczej był błąd przy wysyłaniu pakietu. dla errno=0 | |
315 * nie wysłano całego pakietu. | |
316 */ | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
317 static int gg_send_packet(int sock, int type, void *packet, int length, void *payload, int payload_length) |
2393 | 318 { |
319 struct gg_header *h; | |
320 int res, plen; | |
321 char *tmp; | |
322 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
323 gg_debug(GG_DEBUG_FUNCTION, "** gg_send_packet(0x%.2x, %d, %d);\n", type, length, payload_length); |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
324 |
2393 | 325 if (length < 0 || payload_length < 0) { |
326 gg_debug(GG_DEBUG_MISC, "-- invalid packet/payload length\n"); | |
327 errno = ERANGE; | |
328 return -1; | |
329 } | |
330 | |
331 if (!(tmp = malloc(sizeof(struct gg_header) + length + payload_length))) { | |
332 gg_debug(GG_DEBUG_MISC, "-- not enough memory\n"); | |
333 return -1; | |
334 } | |
335 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
336 h = (struct gg_header*) tmp; |
2393 | 337 h->type = fix32(type); |
338 h->length = fix32(length + payload_length); | |
339 | |
340 if (packet) | |
341 memcpy(tmp + sizeof(struct gg_header), packet, length); | |
342 if (payload) | |
343 memcpy(tmp + sizeof(struct gg_header) + length, payload, payload_length); | |
344 | |
345 if ((gg_debug_level & GG_DEBUG_DUMP)) { | |
346 int i; | |
347 | |
348 gg_debug(GG_DEBUG_DUMP, "%%%% sending packet (type=%.2x):", fix32(h->type)); | |
349 for (i = 0; i < sizeof(struct gg_header) + fix32(h->length); i++) | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
350 gg_debug(GG_DEBUG_DUMP, " %.2x", (unsigned char) tmp[i]); |
2393 | 351 gg_debug(GG_DEBUG_DUMP, "\n"); |
352 } | |
353 | |
354 plen = sizeof(struct gg_header) + length + payload_length; | |
3630 | 355 #ifndef _WIN32 |
2393 | 356 if ((res = write(sock, tmp, plen)) < plen) { |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
357 gg_debug(GG_DEBUG_MISC, "-- write() failed. res = %d, errno = %d (%s)\n", res, errno, strerror(errno)); |
3630 | 358 #else |
359 if ((res = send(sock, tmp, plen, 0)) < plen) { | |
360 gg_debug(GG_DEBUG_MISC, "-- send() failed. res = %d, errno = %d\n", | |
361 res, (res == SOCKET_ERROR) ? WSAGetLastError() : 0); | |
362 #endif | |
2393 | 363 free(tmp); |
364 return -1; | |
365 } | |
366 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
367 free(tmp); |
2393 | 368 return 0; |
369 } | |
370 | |
3630 | 371 #ifndef _WIN32 |
2393 | 372 /* |
373 * gg_login() | |
374 * | |
375 * rozpoczyna procedurę łączenia się z serwerem. resztę obsłguje się przez | |
376 * gg_watch_event. | |
377 * | |
378 * - uin - numerek usera, | |
379 * - password - jego hasełko, | |
380 * - async - ma być asynchronicznie? | |
381 * | |
382 * UWAGA! program musi obsłużyć SIGCHLD, jeśli łączy się asynchronicznie, | |
383 * żeby zrobić pogrzeb zmarłemu procesowi resolvera. | |
384 * | |
385 * w przypadku błędu zwraca NULL, jeśli idzie dobrze (async) albo poszło | |
386 * dobrze (sync), zwróci wskaźnik do zaalokowanej struktury `gg_session'. | |
387 */ | |
388 struct gg_session *gg_login(uin_t uin, char *password, int async) | |
389 { | |
390 struct gg_session *sess; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
391 char *hostname; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
392 int port; |
2393 | 393 |
394 gg_debug(GG_DEBUG_FUNCTION, "** gg_login(%u, \"...\", %d);\n", uin, async); | |
395 | |
396 if (!(sess = malloc(sizeof(*sess)))) | |
397 return NULL; | |
398 | |
399 sess->uin = uin; | |
400 if (!(sess->password = strdup(password))) { | |
401 free(sess); | |
402 return NULL; | |
403 } | |
404 sess->state = GG_STATE_RESOLVING; | |
405 sess->check = GG_CHECK_READ; | |
406 sess->async = async; | |
407 sess->seq = 0; | |
408 sess->recv_left = 0; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
409 sess->last_pong = 0; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
410 sess->server_ip = 0; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
411 sess->initial_status = 0; |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
412 sess->type = GG_SESSION_GG; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
413 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
414 if (gg_http_use_proxy) { |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
415 hostname = gg_http_proxy_host; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
416 port = gg_http_proxy_port; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
417 } else { |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
418 hostname = GG_APPMSG_HOST; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
419 port = GG_APPMSG_PORT; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
420 }; |
2393 | 421 |
422 if (async) { | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
423 if (gg_resolve(&sess->fd, &sess->pid, hostname)) { |
2393 | 424 gg_debug(GG_DEBUG_MISC, "-- resolving failed\n"); |
425 free(sess); | |
426 return NULL; | |
427 } | |
428 } else { | |
429 struct in_addr a; | |
430 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
431 if ((a.s_addr = inet_addr(hostname)) == INADDR_NONE) { |
2393 | 432 struct hostent *he; |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
433 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
434 if (!(he = gethostbyname(hostname))) { |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
435 gg_debug(GG_DEBUG_MISC, "-- host %s not found\n", hostname); |
2393 | 436 free(sess); |
437 return NULL; | |
438 } else | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
439 memcpy((char*) &a, he->h_addr, sizeof(a)); |
2393 | 440 } |
441 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
442 if (!(sess->fd = gg_connect(&a, port, 0)) == -1) { |
2393 | 443 gg_debug(GG_DEBUG_MISC, "-- connection failed\n"); |
444 free(sess); | |
445 return NULL; | |
446 } | |
447 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
448 sess->state = GG_STATE_CONNECTING; |
2393 | 449 |
450 while (sess->state != GG_STATE_CONNECTED) { | |
451 struct gg_event *e; | |
452 | |
453 if (!(e = gg_watch_fd(sess))) { | |
454 gg_debug(GG_DEBUG_MISC, "-- some nasty error in gg_watch_fd()\n"); | |
455 free(sess); | |
456 return NULL; | |
457 } | |
458 | |
459 if (e->type == GG_EVENT_CONN_FAILED) { | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
460 errno = EACCES; |
2393 | 461 gg_debug(GG_DEBUG_MISC, "-- could not login\n"); |
462 gg_free_event(e); | |
463 free(sess); | |
464 return NULL; | |
465 } | |
466 | |
467 gg_free_event(e); | |
468 } | |
469 } | |
470 | |
471 return sess; | |
472 } | |
3630 | 473 #endif /*!_WIN32*/ |
2393 | 474 |
475 /* | |
476 * gg_free_session() | |
477 * | |
478 * zwalnia pamięć zajmowaną przez opis sesji. | |
479 * | |
480 * - sess - opis sesji. | |
481 * | |
482 * nie zwraca niczego, bo i po co? | |
483 */ | |
484 void gg_free_session(struct gg_session *sess) | |
485 { | |
486 if (!sess) | |
487 return; | |
488 | |
489 free(sess->password); | |
490 free(sess); | |
491 } | |
492 | |
493 /* | |
494 * gg_change_status() | |
495 * | |
496 * zmienia status użytkownika. przydatne do /away i /busy oraz /quit. | |
497 * | |
498 * - sess - opis sesji, | |
499 * - status - nowy status użytkownika. | |
500 * | |
501 * jeśli wysłał pakiet zwraca 0, jeśli nie udało się, zwraca -1. | |
502 */ | |
503 int gg_change_status(struct gg_session *sess, int status) | |
504 { | |
505 struct gg_new_status p; | |
506 | |
507 if (!sess) { | |
508 errno = EFAULT; | |
509 return -1; | |
510 } | |
511 | |
512 if (sess->state != GG_STATE_CONNECTED) { | |
3630 | 513 #ifndef _WIN32 |
2393 | 514 errno = ENOTCONN; |
3630 | 515 #else |
516 WSASetLastError( WSAENOTCONN ); | |
517 #endif | |
2393 | 518 return -1; |
519 } | |
520 | |
521 gg_debug(GG_DEBUG_FUNCTION, "** gg_change_status(..., %d);\n", status); | |
522 | |
523 p.status = fix32(status); | |
524 | |
525 return gg_send_packet(sess->fd, GG_NEW_STATUS, &p, sizeof(p), NULL, 0); | |
526 } | |
527 | |
528 /* | |
529 * gg_logoff() | |
530 * | |
531 * wylogowuje użytkownika i zamyka połączenie. | |
532 * | |
533 * - sock - deskryptor socketu. | |
534 * | |
535 * nie zwraca błędów. skoro się żegnamy, to olewamy wszystko. | |
536 */ | |
537 void gg_logoff(struct gg_session *sess) | |
538 { | |
539 if (!sess) | |
540 return; | |
541 | |
542 gg_debug(GG_DEBUG_FUNCTION, "** gg_logoff(...);\n"); | |
543 | |
544 if (sess->state == GG_STATE_CONNECTED) | |
545 gg_change_status(sess, GG_STATUS_NOT_AVAIL); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
546 |
2393 | 547 if (sess->fd) { |
548 shutdown(sess->fd, 2); | |
549 close(sess->fd); | |
550 } | |
551 } | |
552 | |
553 /* | |
554 * gg_send_message() | |
555 * | |
556 * wysyła wiadomość do innego użytkownika. zwraca losowy numer | |
557 * sekwencyjny, który można olać albo wykorzystać do potwierdzenia. | |
558 * | |
559 * - sess - opis sesji, | |
560 * - msgclass - rodzaj wiadomości, | |
561 * - recipient - numer adresata, | |
562 * - message - treść wiadomości. | |
563 * | |
564 * w przypadku błędu zwraca -1, inaczej numer sekwencyjny. | |
565 */ | |
566 int gg_send_message(struct gg_session *sess, int msgclass, uin_t recipient, unsigned char *message) | |
567 { | |
568 struct gg_send_msg s; | |
569 | |
570 if (!sess) { | |
571 errno = EFAULT; | |
572 return -1; | |
573 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
574 |
2393 | 575 if (sess->state != GG_STATE_CONNECTED) { |
3630 | 576 #ifndef _WIN32 |
2393 | 577 errno = ENOTCONN; |
3630 | 578 #else |
579 WSASetLastError( WSAENOTCONN ); | |
580 #endif | |
2393 | 581 return -1; |
582 } | |
583 | |
584 gg_debug(GG_DEBUG_FUNCTION, "** gg_send_message(..., %d, %u, \"...\");\n", msgclass, recipient); | |
585 | |
586 s.recipient = fix32(recipient); | |
587 if (!sess->seq) | |
588 sess->seq = 0x01740000 | (rand() & 0xffff); | |
589 s.seq = fix32(sess->seq); | |
590 s.msgclass = fix32(msgclass); | |
591 sess->seq += (rand() % 0x300) + 0x300; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
592 |
2393 | 593 if (gg_send_packet(sess->fd, GG_SEND_MSG, &s, sizeof(s), message, strlen(message) + 1) == -1) |
594 return -1; | |
595 | |
596 return fix32(s.seq); | |
597 } | |
598 | |
599 /* | |
600 * gg_ping() | |
601 * | |
602 * wysyła do serwera pakiet typu yeah-i'm-still-alive. | |
603 * | |
604 * - sess - zgadnij. | |
605 * | |
606 * jeśli nie powiodło się wysłanie pakietu, zwraca -1. otherwise 0. | |
607 */ | |
608 int gg_ping(struct gg_session *sess) | |
609 { | |
610 if (!sess) { | |
611 errno = EFAULT; | |
612 return -1; | |
613 } | |
614 | |
615 if (sess->state != GG_STATE_CONNECTED) { | |
3630 | 616 #ifndef _WIN32 |
2393 | 617 errno = ENOTCONN; |
3630 | 618 #else |
619 WSASetLastError( WSAENOTCONN ); | |
620 #endif | |
2393 | 621 return -1; |
622 } | |
623 | |
624 gg_debug(GG_DEBUG_FUNCTION, "** gg_ping(...);\n"); | |
3630 | 625 |
626 if(ping_outstanding) { | |
627 debug_printf("Trying to send ping, when we havn't been ponged on last ping\n"); | |
628 return 1; | |
629 } | |
630 else { | |
631 ping_outstanding = 1; | |
632 return gg_send_packet(sess->fd, GG_PING, NULL, 0, NULL, 0); | |
633 } | |
2393 | 634 } |
635 | |
636 /* | |
637 * gg_free_event() | |
638 * | |
639 * zwalnia pamięć zajmowaną przez informację o zdarzeniu | |
640 * | |
641 * - event - wskaźnik do informacji o zdarzeniu | |
642 * | |
643 * nie ma czego zwracać. | |
644 */ | |
645 void gg_free_event(struct gg_event *e) | |
646 { | |
647 if (!e) | |
648 return; | |
649 if (e->type == GG_EVENT_MSG) | |
650 free(e->event.msg.message); | |
651 if (e->type == GG_EVENT_NOTIFY) | |
652 free(e->event.notify); | |
653 free(e); | |
654 } | |
655 | |
656 /* | |
657 * gg_notify() | |
658 * | |
659 * wysyła serwerowi listę ludków, za którymi tęsknimy. | |
660 * | |
661 * - sess - identyfikator sesji, | |
662 * - userlist - wskaźnik do tablicy numerów, | |
663 * - count - ilość numerków. | |
664 * | |
665 * jeśli udało się, zwraca 0. jeśli błąd, dostajemy -1. | |
666 */ | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
667 int gg_notify(struct gg_session *sess, uin_t *userlist, int count) |
2393 | 668 { |
669 struct gg_notify *n; | |
670 uin_t *u; | |
671 int i, res = 0; | |
672 | |
673 if (!sess) { | |
674 errno = EFAULT; | |
675 return -1; | |
676 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
677 |
2393 | 678 if (sess->state != GG_STATE_CONNECTED) { |
3630 | 679 #ifndef _WIN32 |
2393 | 680 errno = ENOTCONN; |
3630 | 681 #else |
682 WSASetLastError( WSAENOTCONN ); | |
683 #endif | |
2393 | 684 return -1; |
685 } | |
686 | |
687 gg_debug(GG_DEBUG_FUNCTION, "** gg_notify(..., %d);\n", count); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
688 |
2393 | 689 if (!userlist || !count) |
690 return 0; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
691 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
692 if (!(n = (struct gg_notify*) malloc(sizeof(*n) * count))) |
2393 | 693 return -1; |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
694 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
695 for (u = userlist, i = 0; i < count; u++, i++) { |
2393 | 696 n[i].uin = fix32(*u); |
697 n[i].dunno1 = 3; | |
698 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
699 |
2393 | 700 if (gg_send_packet(sess->fd, GG_NOTIFY, n, sizeof(*n) * count, NULL, 0) == -1) |
701 res = -1; | |
702 | |
703 free(n); | |
704 | |
705 return res; | |
706 } | |
707 | |
708 /* | |
709 * gg_add_notify() | |
710 * | |
711 * dodaje w locie do listy ukochanych dany numerek. | |
712 * | |
713 * - sess - identyfikator sesji, | |
714 * - uin - numerek ukochanej. | |
715 * | |
716 * jeśli udało się wysłać, daje 0. inaczej -1. | |
717 */ | |
718 int gg_add_notify(struct gg_session *sess, uin_t uin) | |
719 { | |
720 struct gg_add_remove a; | |
721 | |
722 if (!sess) { | |
723 errno = EFAULT; | |
724 return -1; | |
725 } | |
726 | |
727 if (sess->state != GG_STATE_CONNECTED) { | |
3630 | 728 #ifndef _WIN32 |
2393 | 729 errno = ENOTCONN; |
3630 | 730 #else |
731 WSASetLastError( WSAENOTCONN ); | |
732 #endif | |
2393 | 733 return -1; |
734 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
735 |
2393 | 736 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
|
737 |
2393 | 738 a.uin = fix32(uin); |
739 a.dunno1 = 3; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
740 |
2393 | 741 return gg_send_packet(sess->fd, GG_ADD_NOTIFY, &a, sizeof(a), NULL, 0); |
742 } | |
743 | |
744 /* | |
745 * gg_remove_notify() | |
746 * | |
747 * w locie usuwa z listy zainteresowanych. | |
748 * | |
749 * - sess - id sesji, | |
750 * - uin - numerek. | |
751 * | |
752 * zwraca -1 jeśli był błąd, 0 jeśli się udało wysłać pakiet. | |
753 */ | |
754 int gg_remove_notify(struct gg_session *sess, uin_t uin) | |
755 { | |
756 struct gg_add_remove a; | |
757 | |
758 if (!sess) { | |
759 errno = EFAULT; | |
760 return -1; | |
761 } | |
762 | |
763 if (sess->state != GG_STATE_CONNECTED) { | |
3630 | 764 #ifndef _WIN32 |
2393 | 765 errno = ENOTCONN; |
3630 | 766 #else |
767 WSASetLastError( WSAENOTCONN ); | |
768 #endif | |
2393 | 769 return -1; |
770 } | |
771 | |
772 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
|
773 |
2393 | 774 a.uin = fix32(uin); |
775 a.dunno1 = 3; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
776 |
2393 | 777 return gg_send_packet(sess->fd, GG_REMOVE_NOTIFY, &a, sizeof(a), NULL, 0); |
778 } | |
779 | |
780 /* | |
781 * gg_watch_fd_connected() // funkcja wewnętrzna | |
782 * | |
783 * patrzy na socketa, odbiera pakiet i wypełnia strukturę zdarzenia. | |
784 * | |
785 * - sock - lalala, trudno zgadnąć. | |
786 * | |
787 * jeśli błąd -1, jeśli dobrze 0. | |
788 */ | |
789 static int gg_watch_fd_connected(struct gg_session *sess, struct gg_event *e) | |
790 { | |
791 struct gg_header *h; | |
792 void *p; | |
793 | |
794 if (!sess) { | |
795 errno = EFAULT; | |
796 return -1; | |
797 } | |
798 | |
799 gg_debug(GG_DEBUG_FUNCTION, "** gg_watch_fd_connected(...);\n"); | |
800 | |
801 if (!(h = gg_recv_packet(sess))) { | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
802 gg_debug(GG_DEBUG_MISC, "-- gg_recv_packet failed. errno = %d (%d)\n", errno, strerror(errno)); |
2393 | 803 return -1; |
804 } | |
805 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
806 p = (void*) h + sizeof(struct gg_header); |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
807 |
2393 | 808 if (h->type == GG_RECV_MSG) { |
809 struct gg_recv_msg *r = p; | |
810 | |
811 gg_debug(GG_DEBUG_MISC, "-- received a message\n"); | |
812 | |
813 if (h->length >= sizeof(*r)) { | |
814 e->type = GG_EVENT_MSG; | |
815 e->event.msg.msgclass = fix32(r->msgclass); | |
816 e->event.msg.sender = fix32(r->sender); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
817 e->event.msg.message = strdup((char*) r + sizeof(*r)); |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
818 e->event.msg.time = fix32(r->time); |
2393 | 819 } |
820 } | |
821 | |
822 if (h->type == GG_NOTIFY_REPLY) { | |
823 struct gg_notify_reply *n = p; | |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
824 int count, i; |
2393 | 825 |
826 gg_debug(GG_DEBUG_MISC, "-- received a notify reply\n"); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
827 |
2393 | 828 e->type = GG_EVENT_NOTIFY; |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
829 if (!(e->event.notify = (void*) malloc(h->length + 2 * sizeof(*n)))) { |
2393 | 830 gg_debug(GG_DEBUG_MISC, "-- not enough memory\n"); |
831 free(h); | |
832 return -1; | |
833 } | |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
834 count = h->length / sizeof(*n); |
2393 | 835 memcpy(e->event.notify, p, h->length); |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
836 e->event.notify[count].uin = 0; |
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
837 for (i = 0; i < count; i++) { |
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
838 e->event.notify[i].uin = fix32(e->event.notify[i].uin); |
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
839 e->event.notify[i].status = fix32(e->event.notify[i].status); |
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
840 } |
2393 | 841 } |
842 | |
843 if (h->type == GG_STATUS) { | |
844 struct gg_status *s = p; | |
845 | |
846 gg_debug(GG_DEBUG_MISC, "-- received a status change\n"); | |
847 | |
848 if (h->length >= sizeof(*s)) { | |
849 e->type = GG_EVENT_STATUS; | |
850 memcpy(&e->event.status, p, h->length); | |
2399
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
851 e->event.status.uin = fix32(e->event.status.uin); |
b2926d21f067
[gaim-migrate @ 2412]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2393
diff
changeset
|
852 e->event.status.status = fix32(e->event.status.status); |
2393 | 853 } |
854 } | |
855 | |
856 if (h->type == GG_SEND_MSG_ACK) { | |
857 struct gg_send_msg_ack *s = p; | |
858 | |
859 gg_debug(GG_DEBUG_MISC, "-- received a message ack\n"); | |
860 | |
861 if (h->length >= sizeof(*s)) { | |
862 e->type = GG_EVENT_ACK; | |
863 e->event.ack.status = fix32(s->status); | |
864 e->event.ack.recipient = fix32(s->recipient); | |
865 e->event.ack.seq = fix32(s->seq); | |
866 } | |
867 } | |
868 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
869 if (h->type == GG_PONG) { |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
870 gg_debug(GG_DEBUG_MISC, "-- received a pong\n"); |
3630 | 871 ping_outstanding = 0; |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
872 sess->last_pong = time(NULL); |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
873 } |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
874 |
2393 | 875 free(h); |
876 | |
877 return 0; | |
878 } | |
879 | |
880 /* | |
881 * gg_watch_fd() | |
882 * | |
883 * funkcja wywoływana, gdy coś się stanie na obserwowanym deskryptorze. | |
884 * zwraca klientowi informację o tym, co się dzieje. | |
885 * | |
886 * - sess - identyfikator sesji. | |
887 * | |
888 * zwraca wskaźnik do struktury gg_event, którą trzeba zwolnić później | |
889 * za pomocą gg_free_event(). jesli rodzaj zdarzenia jest równy | |
890 * GG_EVENT_NONE, należy je olać kompletnie. jeśli zwróciło NULL, | |
891 * stało się coś niedobrego -- albo brakło pamięci albo zerwało | |
892 * połączenie albo coś takiego. | |
893 */ | |
894 struct gg_event *gg_watch_fd(struct gg_session *sess) | |
895 { | |
896 struct gg_event *e; | |
897 int res = 0; | |
3630 | 898 #ifndef _WIN32 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
899 int port; |
3630 | 900 #endif |
2393 | 901 |
902 if (!sess) { | |
903 errno = EFAULT; | |
904 return NULL; | |
905 } | |
906 | |
907 gg_debug(GG_DEBUG_FUNCTION, "** gg_watch_fd(...);\n"); | |
908 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
909 if (!(e = (void*) malloc(sizeof(*e)))) { |
2393 | 910 gg_debug(GG_DEBUG_MISC, "-- not enough memory\n"); |
911 return NULL; | |
912 } | |
913 | |
914 e->type = GG_EVENT_NONE; | |
915 | |
916 switch (sess->state) { | |
3630 | 917 #ifndef _WIN32 |
918 /* Apparantly we will never be in this state as long as we are | |
919 using proxy_connect instead of gg_login - Herman */ | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
920 case GG_STATE_RESOLVING: |
2393 | 921 { |
922 struct in_addr a; | |
923 | |
924 gg_debug(GG_DEBUG_MISC, "== GG_STATE_RESOLVING\n"); | |
925 | |
926 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
|
927 gg_debug(GG_DEBUG_MISC, "-- resolving failed\n"); |
2393 | 928 |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
929 errno = ENOENT; |
2393 | 930 e->type = GG_EVENT_CONN_FAILED; |
931 e->event.failure = GG_FAILURE_RESOLVING; | |
932 sess->state = GG_STATE_IDLE; | |
933 | |
934 close(sess->fd); | |
935 | |
936 break; | |
937 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
938 |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
939 sess->server_ip = a.s_addr; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
940 |
2393 | 941 close(sess->fd); |
942 | |
943 waitpid(sess->pid, NULL, 0); | |
944 | |
945 gg_debug(GG_DEBUG_MISC, "-- resolved, now connecting\n"); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
946 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
947 if (gg_http_use_proxy) { |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
948 port = gg_http_proxy_port; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
949 } else { |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
950 port = GG_APPMSG_PORT; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
951 }; |
2393 | 952 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
953 if ((sess->fd = gg_connect(&a, port, sess->async)) == -1) { |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
954 struct in_addr *addr = (struct in_addr*) &sess->server_ip; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
955 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
956 gg_debug(GG_DEBUG_MISC, "-- connection failed, trying direct connection\n"); |
2393 | 957 |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
958 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
|
959 gg_debug(GG_DEBUG_MISC, "-- connection failed, trying https connection\n"); |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
960 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
|
961 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
|
962 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
963 e->type = GG_EVENT_CONN_FAILED; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
964 e->event.failure = GG_FAILURE_CONNECTING; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
965 sess->state = GG_STATE_IDLE; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
966 break; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
967 } |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
968 } |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
969 sess->state = GG_STATE_CONNECTING_GG; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
970 sess->check = GG_CHECK_WRITE; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
971 } else { |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
972 sess->state = GG_STATE_CONNECTING; |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
973 sess->check = GG_CHECK_WRITE; |
2393 | 974 } |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
975 |
2393 | 976 break; |
977 } | |
3630 | 978 #endif /* !_WIN32 */ |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
979 case GG_STATE_CONNECTING: |
2393 | 980 { |
981 char buf[1024]; | |
982 int res, res_size = sizeof(res); | |
983 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
984 gg_debug(GG_DEBUG_MISC, "== GG_STATE_CONNECTING\n"); |
2393 | 985 |
3630 | 986 if (sess->async && (getsockopt(sess->fd, SOL_SOCKET, SO_ERROR, |
987 #ifndef _WIN32 | |
988 &res, | |
989 #else | |
990 (char*)&res, | |
991 #endif | |
992 &res_size) || res)) { | |
993 #if 0 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
994 struct in_addr *addr = (struct in_addr*) &sess->server_ip; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
995 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
|
996 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
|
997 gg_debug(GG_DEBUG_MISC, "-- connection failed, trying https connection\n"); |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
998 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
|
999 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
|
1000 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1001 e->type = GG_EVENT_CONN_FAILED; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1002 e->event.failure = GG_FAILURE_CONNECTING; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1003 sess->state = GG_STATE_IDLE; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1004 break; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1005 } |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1006 } |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1007 |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1008 sess->state = GG_STATE_CONNECTING_GG; |
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1009 sess->check = GG_CHECK_WRITE; |
3630 | 1010 #else |
1011 gg_debug(GG_DEBUG_MISC, "-- http connection failed, errno = %d\n", res); | |
1012 e->type = GG_EVENT_CONN_FAILED; | |
1013 e->event.failure = GG_FAILURE_CONNECTING; | |
1014 sess->state = GG_STATE_IDLE; | |
1015 #endif | |
2393 | 1016 break; |
1017 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1018 |
2393 | 1019 gg_debug(GG_DEBUG_MISC, "-- http connection succeded, sending query\n"); |
1020 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1021 if (gg_http_use_proxy) { |
3630 | 1022 g_snprintf(buf, sizeof(buf) - 1, |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1023 "GET http://" GG_APPMSG_HOST "/appsvc/appmsg.asp?fmnumber=%lu HTTP/1.0\r\n" |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1024 "Host: " GG_APPMSG_HOST "\r\n" |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1025 "User-Agent: " GG_HTTP_USERAGENT "\r\n" |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1026 "Pragma: no-cache\r\n" |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1027 "\r\n", sess->uin); |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1028 } else { |
3630 | 1029 g_snprintf(buf, sizeof(buf) - 1, |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1030 "GET /appsvc/appmsg.asp?fmnumber=%lu HTTP/1.0\r\n" |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1031 "Host: " GG_APPMSG_HOST "\r\n" |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1032 "User-Agent: " GG_HTTP_USERAGENT "\r\n" |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1033 "Pragma: no-cache\r\n" |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1034 "\r\n", sess->uin); |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1035 }; |
2393 | 1036 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1037 gg_debug(GG_DEBUG_MISC, "=> -----BEGIN-HTTP-QUERY-----\n%s\n=> -----END-HTTP-QUERY-----\n", buf); |
3630 | 1038 #ifndef _WIN32 |
2393 | 1039 if (write(sess->fd, buf, strlen(buf)) < strlen(buf)) { |
3630 | 1040 #else |
1041 if (send(sess->fd, buf, strlen(buf), 0) < strlen(buf)) { | |
1042 #endif | |
2393 | 1043 gg_debug(GG_DEBUG_MISC, "-- sending query failed\n"); |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1044 errno = EIO; |
2393 | 1045 e->type = GG_EVENT_CONN_FAILED; |
1046 e->event.failure = GG_FAILURE_WRITING; | |
1047 sess->state = GG_STATE_IDLE; | |
1048 break; | |
1049 } | |
1050 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1051 sess->state = GG_STATE_READING_DATA; |
2393 | 1052 sess->check = GG_CHECK_READ; |
1053 | |
1054 break; | |
1055 } | |
1056 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1057 case GG_STATE_READING_DATA: |
2393 | 1058 { |
1059 char buf[1024], *tmp, *host; | |
1060 int port = GG_DEFAULT_PORT; | |
1061 struct in_addr a; | |
1062 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1063 gg_debug(GG_DEBUG_MISC, "== GG_STATE_READING_DATA\n"); |
2393 | 1064 |
1065 gg_read_line(sess->fd, buf, sizeof(buf) - 1); | |
1066 gg_chomp(buf); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1067 |
2393 | 1068 gg_debug(GG_DEBUG_TRAFFIC, "-- got http response (%s)\n", buf); |
1069 if (strncmp(buf, "HTTP/1.", 7) || strncmp(buf + 9, "200", 3)) { | |
1070 gg_debug(GG_DEBUG_MISC, "-- but that's not what we've expected\n"); | |
1071 | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1072 errno = EINVAL; |
2393 | 1073 e->type = GG_EVENT_CONN_FAILED; |
1074 e->event.failure = GG_FAILURE_INVALID; | |
1075 sess->state = GG_STATE_IDLE; | |
1076 break; | |
1077 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1078 |
2393 | 1079 while (strcmp(buf, "\r\n") && strcmp(buf, "")) |
1080 gg_read_line(sess->fd, buf, sizeof(buf) - 1); | |
1081 | |
1082 gg_read_line(sess->fd, buf, sizeof(buf) - 1); | |
1083 gg_chomp(buf); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1084 |
2393 | 1085 close(sess->fd); |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1086 |
2393 | 1087 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
|
1088 |
2393 | 1089 tmp = buf; |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1090 |
2393 | 1091 while (*tmp && *tmp != ' ') |
1092 tmp++; | |
1093 while (*tmp && *tmp == ' ') | |
1094 tmp++; | |
1095 while (*tmp && *tmp != ' ') | |
1096 tmp++; | |
1097 while (*tmp && *tmp == ' ') | |
1098 tmp++; | |
1099 while (*tmp && *tmp != ' ') | |
1100 tmp++; | |
1101 while (*tmp && *tmp == ' ') | |
1102 tmp++; | |
1103 host = tmp; | |
1104 while (*tmp && *tmp != ' ') | |
1105 tmp++; | |
1106 *tmp = 0; | |
1107 | |
1108 if ((tmp = strchr(host, ':'))) { | |
1109 *tmp = 0; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1110 port = atoi(tmp+1); |
2393 | 1111 } |
1112 | |
1113 a.s_addr = inet_addr(host); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1114 sess->server_ip = a.s_addr; |
3630 | 1115 #if 0 |
1116 /* We need to watch this non-blocking socket so lets use proxy_connect | |
1117 in gg.c - Herman */ | |
1118 if((sess->fd = gg_connect(&a, port, sess->assync)) == -1) { | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1119 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
|
1120 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
|
1121 gg_debug(GG_DEBUG_MISC, "-- connection failed, errno = %d (%s)\n", errno, strerror(errno)); |
2393 | 1122 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1123 e->type = GG_EVENT_CONN_FAILED; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1124 e->event.failure = GG_FAILURE_CONNECTING; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1125 sess->state = GG_STATE_IDLE; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1126 break; |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1127 } |
2393 | 1128 } |
3630 | 1129 #else |
1130 sess->port = port; | |
1131 #endif | |
2393 | 1132 sess->state = GG_STATE_CONNECTING_GG; |
1133 sess->check = GG_CHECK_WRITE; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1134 |
2393 | 1135 break; |
1136 } | |
1137 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1138 case GG_STATE_CONNECTING_GG: |
2393 | 1139 { |
1140 int res, res_size = sizeof(res); | |
1141 | |
1142 gg_debug(GG_DEBUG_MISC, "== GG_STATE_CONNECTING_GG\n"); | |
1143 | |
3630 | 1144 if (sess->async && (getsockopt(sess->fd, SOL_SOCKET, SO_ERROR, |
1145 #ifndef _WIN32 | |
1146 &res, | |
1147 #else | |
1148 (char*)&res, | |
1149 #endif | |
1150 &res_size) || res)) { | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1151 struct in_addr *addr = (struct in_addr*) &sess->server_ip; |
2393 | 1152 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1153 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
|
1154 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
|
1155 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
|
1156 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1157 e->type = GG_EVENT_CONN_FAILED; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1158 e->event.failure = GG_FAILURE_CONNECTING; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1159 sess->state = GG_STATE_IDLE; |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1160 break; |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1161 } |
2393 | 1162 } |
1163 | |
1164 gg_debug(GG_DEBUG_MISC, "-- connected\n"); | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1165 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1166 sess->state = GG_STATE_READING_KEY; |
2393 | 1167 sess->check = GG_CHECK_READ; |
1168 | |
1169 break; | |
1170 } | |
1171 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1172 case GG_STATE_READING_KEY: |
2393 | 1173 { |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1174 struct gg_header *h; |
2393 | 1175 struct gg_welcome *w; |
1176 struct gg_login l; | |
1177 unsigned int hash; | |
1178 char *password = sess->password; | |
1179 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1180 gg_debug(GG_DEBUG_MISC, "== GG_STATE_READING_KEY\n"); |
2393 | 1181 |
1182 if (!(h = gg_recv_packet(sess))) { | |
3630 | 1183 #ifndef _WIN32 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1184 gg_debug(GG_DEBUG_MISC, "-- gg_recv_packet() failed. errno = %d (%s)\n", errno, strerror(errno)); |
3630 | 1185 #else |
1186 gg_debug(GG_DEBUG_MISC, "-- gg_recv_packet() failed. errno = %d\n", WSAGetLastError()); | |
1187 #endif | |
2393 | 1188 e->type = GG_EVENT_CONN_FAILED; |
1189 e->event.failure = GG_FAILURE_READING; | |
1190 sess->state = GG_STATE_IDLE; | |
1191 close(sess->fd); | |
1192 break; | |
1193 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1194 |
2393 | 1195 if (h->type != GG_WELCOME) { |
1196 gg_debug(GG_DEBUG_MISC, "-- invalid packet received\n"); | |
1197 | |
1198 free(h); | |
1199 close(sess->fd); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1200 errno = EINVAL; |
2393 | 1201 e->type = GG_EVENT_CONN_FAILED; |
1202 e->event.failure = GG_FAILURE_INVALID; | |
1203 sess->state = GG_STATE_IDLE; | |
1204 break; | |
1205 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1206 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1207 w = (void*) h + sizeof(struct gg_header); |
2393 | 1208 w->key = fix32(w->key); |
1209 | |
1210 for (hash = 1; *password; password++) | |
1211 hash *= (*password) + 1; | |
1212 hash *= w->key; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1213 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1214 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
|
1215 |
2393 | 1216 free(h); |
1217 | |
1218 free(sess->password); | |
1219 sess->password = NULL; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1220 |
2393 | 1221 l.uin = fix32(sess->uin); |
1222 l.hash = fix32(hash); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1223 l.status = fix32(sess->initial_status ? sess->initial_status : GG_STATUS_AVAIL); |
2393 | 1224 l.dunno = fix32(0x0b); |
1225 l.local_ip = 0; | |
1226 l.local_port = 0; | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1227 |
2393 | 1228 gg_debug(GG_DEBUG_TRAFFIC, "-- sending GG_LOGIN packet\n"); |
1229 | |
1230 if (gg_send_packet(sess->fd, GG_LOGIN, &l, sizeof(l), NULL, 0) == -1) { | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1231 gg_debug(GG_DEBUG_TRAFFIC, "-- oops, failed. errno = %d (%s)\n", errno, strerror(errno)); |
2393 | 1232 |
1233 close(sess->fd); | |
1234 e->type = GG_EVENT_CONN_FAILED; | |
1235 e->event.failure = GG_FAILURE_WRITING; | |
1236 sess->state = GG_STATE_IDLE; | |
1237 break; | |
1238 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1239 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1240 sess->state = GG_STATE_READING_REPLY; |
2393 | 1241 |
1242 break; | |
1243 } | |
1244 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1245 case GG_STATE_READING_REPLY: |
2393 | 1246 { |
1247 struct gg_header *h; | |
1248 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1249 gg_debug(GG_DEBUG_MISC, "== GG_STATE_READING_REPLY\n"); |
2393 | 1250 |
1251 if (!(h = gg_recv_packet(sess))) { | |
1252 gg_debug(GG_DEBUG_MISC, "-- recv_packet failed\n"); | |
1253 e->type = GG_EVENT_CONN_FAILED; | |
1254 e->event.failure = GG_FAILURE_READING; | |
1255 sess->state = GG_STATE_IDLE; | |
1256 close(sess->fd); | |
1257 break; | |
1258 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1259 |
2393 | 1260 if (h->type == GG_LOGIN_OK) { |
1261 gg_debug(GG_DEBUG_MISC, "-- login succeded\n"); | |
1262 e->type = GG_EVENT_CONN_SUCCESS; | |
1263 sess->state = GG_STATE_CONNECTED; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1264 free(h); |
2393 | 1265 break; |
1266 } | |
1267 | |
1268 if (h->type == GG_LOGIN_FAILED) { | |
1269 gg_debug(GG_DEBUG_MISC, "-- login failed\n"); | |
1270 e->event.failure = GG_FAILURE_PASSWORD; | |
1271 errno = EACCES; | |
1272 } else { | |
1273 gg_debug(GG_DEBUG_MISC, "-- invalid packet\n"); | |
1274 e->event.failure = GG_FAILURE_INVALID; | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1275 errno = EINVAL; |
2393 | 1276 } |
1277 | |
1278 e->type = GG_EVENT_CONN_FAILED; | |
1279 sess->state = GG_STATE_IDLE; | |
1280 close(sess->fd); | |
2792
9123abd0db92
[gaim-migrate @ 2805]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2595
diff
changeset
|
1281 free(h); |
2393 | 1282 |
1283 break; | |
1284 } | |
1285 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1286 case GG_STATE_CONNECTED: |
2393 | 1287 { |
1288 gg_debug(GG_DEBUG_MISC, "== GG_STATE_CONNECTED\n"); | |
1289 | |
1290 if ((res = gg_watch_fd_connected(sess, e)) == -1) { | |
1291 | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1292 gg_debug(GG_DEBUG_MISC, "-- watch_fd_connected failed. errno = %d (%s)\n", errno, strerror(errno)); |
2393 | 1293 |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1294 if (errno == EAGAIN) { |
2393 | 1295 e->type = GG_EVENT_NONE; |
1296 res = 0; | |
1297 } else | |
1298 res = -1; | |
1299 } | |
1300 break; | |
1301 } | |
1302 } | |
1303 | |
1304 if (res == -1) { | |
1305 free(e); | |
1306 e = NULL; | |
1307 } | |
1308 | |
1309 return e; | |
1310 } | |
2846
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1311 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1312 /* |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1313 * Local variables: |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1314 * c-indentation-style: k&r |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1315 * c-basic-offset: 8 |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1316 * indent-tabs-mode: notnil |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1317 * End: |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1318 * |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1319 * vim: shiftwidth=8: |
4b3f17ca66bf
[gaim-migrate @ 2859]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2792
diff
changeset
|
1320 */ |