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