Mercurial > pidgin.yaz
annotate src/protocols/oscar/ft.c @ 4618:3c7d4a060d30
[gaim-migrate @ 4909]
<faceprint> ft.c:240: warning: implicit declaration of function `debug_printf'
<faceprint> naughty mr doliner
committer: Tailor Script <tailor@pidgin.im>
author | Mark Doliner <mark@kingant.net> |
---|---|
date | Wed, 26 Feb 2003 05:31:03 +0000 |
parents | 858979ab3867 |
children | 440d3d870b84 |
rev | line source |
---|---|
2086 | 1 /* |
4617 | 2 * Oscar File transfer (OFT) and Oscar Direct Connect (ODC). |
3 * (ODC is also referred to as DirectIM and IM Image.) | |
4 * | |
5 * There are a few static helper functions at the top, then | |
6 * ODC stuff, then ft stuff. | |
7 * | |
8 * I feel like this is a good place to explain OFT, so I'm going to | |
9 * do just that. Each OFT packet has a header type. I guess this | |
10 * is pretty similar to the subtype of a SNAC packet. The type | |
11 * basically tells the other client the meaning of the OFT packet. | |
12 * There are two distinct types of file transfer, which I usually | |
13 * call "sendfile" and "getfile." Sendfile is when you send a file | |
14 * to another AIM user. Getfile is when you share a group of files, | |
15 * and other users request that you send them the files. | |
16 * | |
17 * A typical sendfile file transfer goes like this: | |
18 * 1) Sender sends a channel 2 ICBM telling the other user that | |
19 * we want to send them a file. At the same time, we open a | |
20 * listener socket (this should be done before sending the | |
21 * ICBM) on some port, and wait for them to connect to us. | |
22 * The ICBM we sent should contain our IP address and the port | |
23 * number that we're listening on. | |
24 * 2) The receiver connects to the sender on the given IP address | |
25 * and port. After the connection is established, the receiver | |
26 * sends another ICBM signifying that we are ready and waiting. | |
27 * 3) The sender sends an OFT PROMPT message over the OFT | |
28 * connection. | |
29 * 4) The receiver of the file sends back an exact copy of this | |
30 * OFT packet, except the cookie is filled in with the cookie | |
31 * from the ICBM. I think this might be an attempt to verify | |
32 * that the user that is connected is actually the guy that | |
33 * we sent the ICBM to. Oh, I've been calling this the ACK. | |
34 * 5) The sender starts sending raw data across the connection | |
35 * until the entire file has been sent. | |
36 * 6) The receiver knows the file is finished because the sender | |
37 * sent the file size in an earlier OFT packet. So then the | |
38 * receiver sends the DONE thingy and closes the connection. | |
2086 | 39 */ |
40 | |
41 #define FAIM_INTERNAL | |
2931 | 42 |
2711
b7455c506979
[gaim-migrate @ 2724]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2675
diff
changeset
|
43 #ifdef HAVE_CONFIG_H |
b7455c506979
[gaim-migrate @ 2724]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2675
diff
changeset
|
44 #include <config.h> |
b7455c506979
[gaim-migrate @ 2724]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2675
diff
changeset
|
45 #endif |
2086 | 46 #include <aim.h> |
47 | |
48 #ifndef _WIN32 | |
49 #include <netdb.h> | |
50 #include <sys/socket.h> | |
51 #include <netinet/in.h> | |
4617 | 52 #include <sys/utsname.h> /* for aim_odc_initiate */ |
3630 | 53 #include <arpa/inet.h> /* for inet_ntoa */ |
3960 | 54 #define G_DIR_SEPARATOR '/' |
3646
bfd8df165f32
[gaim-migrate @ 3770]
Herman Bloggs <hermanator12002@yahoo.com>
parents:
3630
diff
changeset
|
55 #endif |
bfd8df165f32
[gaim-migrate @ 3770]
Herman Bloggs <hermanator12002@yahoo.com>
parents:
3630
diff
changeset
|
56 |
bfd8df165f32
[gaim-migrate @ 3770]
Herman Bloggs <hermanator12002@yahoo.com>
parents:
3630
diff
changeset
|
57 #ifdef _WIN32 |
3630 | 58 #include "win32dep.h" |
59 #endif | |
2086 | 60 |
4617 | 61 struct aim_odc_intdata { |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
62 fu8_t cookie[8]; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
63 char sn[MAXSNLEN+1]; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
64 char ip[22]; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
65 }; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
66 |
4617 | 67 /** |
68 * Convert the directory separator from / (0x2f) to ^A (0x01) | |
69 * | |
70 * @param name The filename to convert. | |
71 */ | |
72 static void aim_oft_dirconvert_tostupid(char *name) | |
73 { | |
74 while (name[0]) { | |
75 if (name[0] == 0x01) | |
76 name[0] = G_DIR_SEPARATOR; | |
77 name++; | |
78 } | |
79 } | |
80 | |
81 /** | |
82 * Convert the directory separator from ^A (0x01) to / (0x2f) | |
83 * | |
84 * @param name The filename to convert. | |
85 */ | |
86 static void aim_oft_dirconvert_fromstupid(char *name) | |
87 { | |
88 while (name[0]) { | |
89 if (name[0] == G_DIR_SEPARATOR) | |
90 name[0] = 0x01; | |
91 name++; | |
92 } | |
93 } | |
94 | |
95 /** | |
96 * Calculate oft checksum of buffer | |
97 * | |
98 * Prevcheck should be 0xFFFF0000 when starting a checksum of a file. The | |
99 * checksum is kind of a rolling checksum thing, so each time you get bytes | |
100 * of a file you just call this puppy and it updates the checksum. You can | |
101 * calculate the checksum of an entire file by calling this in a while or a | |
102 * for loop, or something. | |
103 * | |
104 * Thanks to Graham Booker for providing this improved checksum routine, | |
105 * which is simpler and should be more accurate than Josh Myer's original | |
106 * code. -- wtm | |
107 * | |
108 * This algorithim works every time I have tried it. The other fails | |
109 * sometimes. So, AOL who thought this up? It has got to be the weirdest | |
110 * checksum I have ever seen. | |
111 * | |
112 * @param buffer Buffer of data to checksum. Man I'd like to buff her... | |
113 * @param bufsize Size of buffer. | |
114 * @param prevcheck Previous checksum. | |
115 */ | |
116 faim_export fu32_t aim_oft_checksum(const unsigned char *buffer, int bufferlen, fu32_t prevcheck) | |
117 { | |
118 fu32_t check = (prevcheck >> 16) & 0xffff, oldcheck; | |
119 int i; | |
120 unsigned short val; | |
121 | |
122 for (i=0; i<bufferlen; i++) { | |
123 oldcheck = check; | |
124 if (i&1) | |
125 val = buffer[i]; | |
126 else | |
127 val = buffer[i] << 8; | |
128 check -= val; | |
129 /* | |
130 * The following appears to be necessary.... It happens | |
131 * every once in a while and the checksum doesn't fail. | |
132 */ | |
133 if (check > oldcheck) | |
134 check--; | |
135 } | |
136 check = ((check & 0x0000ffff) + (check >> 16)); | |
137 check = ((check & 0x0000ffff) + (check >> 16)); | |
138 return check << 16; | |
139 } | |
140 | |
2086 | 141 /** |
4617 | 142 * Create a listening socket on a given port. |
143 * | |
144 * XXX - Give the client author the responsibility of setting up a | |
145 * listener, then we no longer have a libfaim problem with broken | |
146 * solaris *innocent smile* -- jbm | |
2086 | 147 * |
4617 | 148 * @param portnum The port number to bind to. |
149 * @return The file descriptor of the listening socket. | |
150 */ | |
151 static int listenestablish(fu16_t portnum) | |
152 { | |
153 #if HAVE_GETADDRINFO | |
154 int listenfd; | |
155 const int on = 1; | |
156 struct addrinfo hints, *res, *ressave; | |
157 char serv[5]; | |
158 | |
159 snprintf(serv, sizeof(serv), "%d", portnum); | |
160 memset(&hints, 0, sizeof(struct addrinfo)); | |
161 hints.ai_flags = AI_PASSIVE; | |
162 hints.ai_family = AF_UNSPEC; | |
163 hints.ai_socktype = SOCK_STREAM; | |
164 if (getaddrinfo(NULL /* any IP */, serv, &hints, &res) != 0) { | |
165 perror("getaddrinfo"); | |
166 return -1; | |
167 } | |
168 ressave = res; | |
169 do { | |
170 listenfd = socket(res->ai_family, res->ai_socktype, res->ai_protocol); | |
171 if (listenfd < 0) | |
172 continue; | |
173 setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on)); | |
174 if (bind(listenfd, res->ai_addr, res->ai_addrlen) == 0) | |
175 break; /* success */ | |
176 close(listenfd); | |
177 } while ( (res = res->ai_next) ); | |
178 | |
179 if (!res) | |
180 return -1; | |
181 | |
182 freeaddrinfo(ressave); | |
183 #else | |
184 int listenfd; | |
185 const int on = 1; | |
186 struct sockaddr_in sockin; | |
187 | |
188 if ((listenfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) { | |
189 perror("socket"); | |
190 return -1; | |
191 } | |
192 | |
193 if (setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on)) != 0) { | |
194 perror("setsockopt"); | |
195 close(listenfd); | |
196 return -1; | |
197 } | |
198 | |
199 memset(&sockin, 0, sizeof(struct sockaddr_in)); | |
200 sockin.sin_family = AF_INET; | |
201 sockin.sin_port = htons(portnum); | |
202 | |
203 if (bind(listenfd, (struct sockaddr *)&sockin, sizeof(struct sockaddr_in)) != 0) { | |
204 perror("bind"); | |
205 close(listenfd); | |
206 return -1; | |
207 } | |
208 #endif | |
209 | |
210 if (listen(listenfd, 4) != 0) { | |
211 perror("listen"); | |
212 close(listenfd); | |
213 return -1; | |
214 } | |
215 fcntl(listenfd, F_SETFL, O_NONBLOCK); | |
216 | |
217 return listenfd; | |
218 } | |
219 | |
220 /** | |
221 * After establishing a listening socket, this is called to accept a connection. It | |
222 * clones the conn used by the listener, and passes both of these to a signal handler. | |
223 * The signal handler should close the listener conn and keep track of the new conn, | |
224 * since this is what is used for file transfers and what not. | |
225 * | |
226 * @param sess The session. | |
227 * @param cur The conn the incoming connection is on. | |
228 * @return Return 0 if no errors, otherwise return the error number. | |
2086 | 229 */ |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
230 faim_export int aim_handlerendconnect(aim_session_t *sess, aim_conn_t *cur) |
4617 | 231 { |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
232 int acceptfd = 0; |
4617 | 233 struct sockaddr addr; |
234 socklen_t addrlen = sizeof(addr); | |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
235 int ret = 0; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
236 aim_conn_t *newconn; |
4617 | 237 char ip[20]; |
238 int port; | |
2086 | 239 |
4617 | 240 if ((acceptfd = accept(cur->fd, &addr, &addrlen)) == -1) |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
241 return 0; /* not an error */ |
2086 | 242 |
4617 | 243 if (addr.sa_family != AF_INET) { /* just in case IPv6 really is happening */ |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
244 close(acceptfd); |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
245 aim_conn_close(cur); |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
246 return -1; |
4617 | 247 } |
248 | |
249 strncpy(ip, inet_ntoa(((struct sockaddr_in *)&addr)->sin_addr), sizeof(ip)); | |
250 port = ntohs(((struct sockaddr_in *)&addr)->sin_port); | |
2086 | 251 |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
252 if (!(newconn = aim_cloneconn(sess, cur))) { |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
253 close(acceptfd); |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
254 aim_conn_close(cur); |
4617 | 255 return -ENOMEM; |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
256 } |
2086 | 257 |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
258 newconn->type = AIM_CONN_TYPE_RENDEZVOUS; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
259 newconn->fd = acceptfd; |
2086 | 260 |
4617 | 261 if (newconn->subtype == AIM_CONN_SUBTYPE_OFT_DIRECTIM) { |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
262 aim_rxcallback_t userfunc; |
4617 | 263 struct aim_odc_intdata *priv; |
2086 | 264 |
4617 | 265 priv = (struct aim_odc_intdata *)(newconn->internal = cur->internal); |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
266 cur->internal = NULL; |
4617 | 267 snprintf(priv->ip, sizeof(priv->ip), "%s:%u", ip, port); |
2086 | 268 |
4617 | 269 if ((userfunc = aim_callhandler(sess, newconn, AIM_CB_FAM_OFT, AIM_CB_OFT_DIRECTIM_ESTABLISHED))) |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
270 ret = userfunc(sess, NULL, newconn, cur); |
2086 | 271 |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
272 } else if (newconn->subtype == AIM_CONN_SUBTYPE_OFT_GETFILE) { |
4617 | 273 } else if (newconn->subtype == AIM_CONN_SUBTYPE_OFT_SENDFILE) { |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
274 aim_rxcallback_t userfunc; |
2086 | 275 |
4617 | 276 if ((userfunc = aim_callhandler(sess, newconn, AIM_CB_FAM_OFT, AIM_CB_OFT_ESTABLISHED))) |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
277 ret = userfunc(sess, NULL, newconn, cur); |
3630 | 278 |
4617 | 279 } else { |
280 faimdprintf(sess, 1,"Got a connection on a listener that's not rendezvous. Closing connection.\n"); | |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
281 aim_conn_close(newconn); |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
282 ret = -1; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
283 } |
2086 | 284 |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
285 return ret; |
2086 | 286 } |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
287 |
2086 | 288 /** |
4617 | 289 * Send client-to-client typing notification over an established direct connection. |
2086 | 290 * |
4617 | 291 * @param sess The session. |
292 * @param conn The already-connected ODC connection. | |
293 * @param typing If true, notify user has started typing; if false, notify user has stopped. | |
294 * @return Return 0 if no errors, otherwise return the error number. | |
2086 | 295 */ |
4617 | 296 faim_export int aim_odc_send_typing(aim_session_t *sess, aim_conn_t *conn, int typing) |
2086 | 297 { |
4617 | 298 struct aim_odc_intdata *intdata = (struct aim_odc_intdata *)conn->internal; |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
299 aim_frame_t *fr; |
3952 | 300 aim_bstream_t *hdrbs; |
301 fu8_t *hdr; | |
302 int hdrlen = 0x44; | |
2086 | 303 |
3952 | 304 if (!sess || !conn || (conn->type != AIM_CONN_TYPE_RENDEZVOUS)) |
305 return -EINVAL; | |
2086 | 306 |
2993 | 307 if (!(fr = aim_tx_new(sess, conn, AIM_FRAMETYPE_OFT, 0x01, 0))) |
3952 | 308 return -ENOMEM; |
309 memcpy(fr->hdr.rend.magic, "ODC2", 4); | |
310 fr->hdr.rend.hdrlen = hdrlen; | |
2086 | 311 |
3952 | 312 if (!(hdr = calloc(1, hdrlen))) { |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
313 aim_frame_destroy(fr); |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
314 return -ENOMEM; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
315 } |
3952 | 316 |
317 hdrbs = &(fr->data); | |
318 aim_bstream_init(hdrbs, hdr, hdrlen); | |
2086 | 319 |
3952 | 320 aimbs_put16(hdrbs, 0x0006); |
321 aimbs_put16(hdrbs, 0x0000); | |
322 aimbs_putraw(hdrbs, intdata->cookie, 8); | |
323 aimbs_put16(hdrbs, 0x0000); | |
324 aimbs_put16(hdrbs, 0x0000); | |
325 aimbs_put16(hdrbs, 0x0000); | |
326 aimbs_put16(hdrbs, 0x0000); | |
327 aimbs_put32(hdrbs, 0x00000000); | |
328 aimbs_put16(hdrbs, 0x0000); | |
329 aimbs_put16(hdrbs, 0x0000); | |
330 aimbs_put16(hdrbs, 0x0000); | |
2086 | 331 |
2993 | 332 /* flags -- 0x000e for "started typing", 0x0002 for "stopped typing */ |
3952 | 333 aimbs_put16(hdrbs, ( typing ? 0x000e : 0x0002)); |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
334 |
3952 | 335 aimbs_put16(hdrbs, 0x0000); |
336 aimbs_put16(hdrbs, 0x0000); | |
337 aimbs_putraw(hdrbs, sess->sn, strlen(sess->sn)); | |
4617 | 338 |
3952 | 339 aim_bstream_setpos(hdrbs, 52); /* bleeehh */ |
2086 | 340 |
3952 | 341 aimbs_put8(hdrbs, 0x00); |
342 aimbs_put16(hdrbs, 0x0000); | |
343 aimbs_put16(hdrbs, 0x0000); | |
344 aimbs_put16(hdrbs, 0x0000); | |
345 aimbs_put16(hdrbs, 0x0000); | |
346 aimbs_put16(hdrbs, 0x0000); | |
347 aimbs_put16(hdrbs, 0x0000); | |
348 aimbs_put16(hdrbs, 0x0000); | |
349 aimbs_put8(hdrbs, 0x00); | |
2086 | 350 |
3952 | 351 /* end of hdr */ |
2086 | 352 |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
353 aim_tx_enqueue(sess, fr); |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
354 |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
355 return 0; |
4617 | 356 } |
2086 | 357 |
2993 | 358 /** |
4617 | 359 * Send client-to-client IM over an established direct connection. |
360 * Call this just like you would aim_send_im, to send a directim. | |
2993 | 361 * |
4617 | 362 * @param sess The session. |
363 * @param conn The already-connected ODC connection. | |
364 * @param msg Null-terminated string to send. | |
365 * @param len The length of the message to send, including binary data. | |
366 * @param encoding 0 for ascii, 2 for Unicode, 3 for ISO 8859-1. | |
367 * @return Return 0 if no errors, otherwise return the error number. | |
2993 | 368 */ |
4617 | 369 faim_export int aim_odc_send_im(aim_session_t *sess, aim_conn_t *conn, const char *msg, int len, int encoding) |
2993 | 370 { |
371 aim_frame_t *fr; | |
3952 | 372 aim_bstream_t *hdrbs; |
4617 | 373 struct aim_odc_intdata *intdata = (struct aim_odc_intdata *)conn->internal; |
3952 | 374 int hdrlen = 0x44; |
375 fu8_t *hdr; | |
2993 | 376 |
4617 | 377 if (!sess || !conn || (conn->type != AIM_CONN_TYPE_RENDEZVOUS) || !msg) |
378 return -EINVAL; | |
2993 | 379 |
3033 | 380 if (!(fr = aim_tx_new(sess, conn, AIM_FRAMETYPE_OFT, 0x01, len))) |
4617 | 381 return -ENOMEM; |
2993 | 382 |
3952 | 383 memcpy(fr->hdr.rend.magic, "ODC2", 4); |
384 fr->hdr.rend.hdrlen = hdrlen; | |
4617 | 385 |
3952 | 386 if (!(hdr = calloc(1, hdrlen + len))) { |
2993 | 387 aim_frame_destroy(fr); |
388 return -ENOMEM; | |
389 } | |
3952 | 390 |
391 hdrbs = &(fr->data); | |
392 aim_bstream_init(hdrbs, hdr, hdrlen + len); | |
393 | |
394 aimbs_put16(hdrbs, 0x0006); | |
395 aimbs_put16(hdrbs, 0x0000); | |
396 aimbs_putraw(hdrbs, intdata->cookie, 8); | |
397 aimbs_put16(hdrbs, 0x0000); | |
398 aimbs_put16(hdrbs, 0x0000); | |
399 aimbs_put16(hdrbs, 0x0000); | |
400 aimbs_put16(hdrbs, 0x0000); | |
401 aimbs_put32(hdrbs, len); | |
402 aimbs_put16(hdrbs, encoding); | |
403 aimbs_put16(hdrbs, 0x0000); | |
404 aimbs_put16(hdrbs, 0x0000); | |
4617 | 405 |
2993 | 406 /* flags -- 0x000e for "started typing", 0x0002 for "stopped typing, 0x0000 for message */ |
3952 | 407 aimbs_put16(hdrbs, 0x0000); |
408 | |
409 aimbs_put16(hdrbs, 0x0000); | |
410 aimbs_put16(hdrbs, 0x0000); | |
411 aimbs_putraw(hdrbs, sess->sn, strlen(sess->sn)); | |
412 | |
413 aim_bstream_setpos(hdrbs, 52); /* bleeehh */ | |
414 | |
415 aimbs_put8(hdrbs, 0x00); | |
416 aimbs_put16(hdrbs, 0x0000); | |
417 aimbs_put16(hdrbs, 0x0000); | |
418 aimbs_put16(hdrbs, 0x0000); | |
419 aimbs_put16(hdrbs, 0x0000); | |
420 aimbs_put16(hdrbs, 0x0000); | |
421 aimbs_put16(hdrbs, 0x0000); | |
422 aimbs_put16(hdrbs, 0x0000); | |
423 aimbs_put8(hdrbs, 0x00); | |
4617 | 424 |
2993 | 425 /* end of hdr2 */ |
4617 | 426 |
427 #if 0 /* XXX - this is how you send buddy icon info... */ | |
428 aimbs_put16(hdrbs, 0x0008); | |
429 aimbs_put16(hdrbs, 0x000c); | |
430 aimbs_put16(hdrbs, 0x0000); | |
431 aimbs_put16(hdrbs, 0x1466); | |
432 aimbs_put16(hdrbs, 0x0001); | |
433 aimbs_put16(hdrbs, 0x2e0f); | |
434 aimbs_put16(hdrbs, 0x393e); | |
435 aimbs_put16(hdrbs, 0xcac8); | |
2993 | 436 #endif |
3952 | 437 aimbs_putraw(hdrbs, msg, len); |
4617 | 438 |
2993 | 439 aim_tx_enqueue(sess, fr); |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
440 |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
441 return 0; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
442 } |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
443 |
2086 | 444 /** |
4617 | 445 * Get the screen name of the peer of a direct connection. |
446 * | |
447 * @param conn The ODC connection. | |
448 * @return The screen name of the dude, or NULL if there was an anomaly. | |
2086 | 449 */ |
4617 | 450 faim_export const char *aim_odc_getsn(aim_conn_t *conn) |
451 { | |
452 struct aim_odc_intdata *intdata; | |
3630 | 453 |
4617 | 454 if (!conn || !conn->internal) |
3952 | 455 return NULL; |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
456 |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
457 if ((conn->type != AIM_CONN_TYPE_RENDEZVOUS) || |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
458 (conn->subtype != AIM_CONN_SUBTYPE_OFT_DIRECTIM)) |
3952 | 459 return NULL; |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
460 |
4617 | 461 intdata = (struct aim_odc_intdata *)conn->internal; |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
462 |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
463 return intdata->sn; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
464 } |
2086 | 465 |
466 /** | |
4617 | 467 * Find the conn of a direct connection with the given buddy. |
468 * | |
469 * @param sess The session. | |
470 * @param sn The screen name of the buddy whose direct connection you want to find. | |
471 * @return The conn for the direct connection with the given buddy, or NULL if no | |
472 * connection was found. | |
473 */ | |
474 faim_export aim_conn_t *aim_odc_getconn(aim_session_t *sess, const char *sn) | |
475 { | |
476 aim_conn_t *cur; | |
477 struct aim_odc_intdata *intdata; | |
478 | |
479 if (!sess || !sn || !strlen(sn)) | |
480 return NULL; | |
481 | |
482 for (cur = sess->connlist; cur; cur = cur->next) { | |
483 if ((cur->type == AIM_CONN_TYPE_RENDEZVOUS) && (cur->subtype == AIM_CONN_SUBTYPE_OFT_DIRECTIM)) { | |
484 intdata = cur->internal; | |
485 if (!aim_sncmp(intdata->sn, sn)) | |
486 return cur; | |
487 } | |
488 } | |
489 | |
490 return NULL; | |
491 } | |
492 | |
493 /** | |
494 * For those times when we want to open up the direct connection channel ourselves. | |
495 * | |
496 * You'll want to set up some kind of watcher on this socket. | |
497 * When the state changes, call aim_handlerendconnection with | |
498 * the connection returned by this. aim_handlerendconnection | |
499 * will accept the pending connection and stop listening. | |
500 * | |
501 * @param sess The session | |
502 * @param conn The BOS conn. | |
503 * @param priv A dummy priv value (we'll let it get filled in later) | |
504 * (if you pass a %NULL, we alloc one). | |
505 * @param sn The screen name to connect to. | |
506 * @return The new connection. | |
507 */ | |
508 faim_export aim_conn_t *aim_odc_initiate(aim_session_t *sess, const char *sn) | |
509 { | |
510 aim_conn_t *newconn; | |
511 aim_msgcookie_t *cookie; | |
512 struct aim_odc_intdata *priv; | |
513 int listenfd; | |
514 fu16_t port = 4443; | |
515 fu8_t localip[4]; | |
516 fu8_t ck[8]; | |
517 | |
518 if (aim_util_getlocalip(localip) == -1) | |
519 return NULL; | |
520 | |
521 if ((listenfd = listenestablish(port)) == -1) | |
522 return NULL; | |
523 | |
524 aim_im_sendch2_odcrequest(sess, ck, sn, localip, port); | |
525 | |
526 cookie = (aim_msgcookie_t *)calloc(1, sizeof(aim_msgcookie_t)); | |
527 memcpy(cookie->cookie, ck, 8); | |
528 cookie->type = AIM_COOKIETYPE_OFTIM; | |
529 | |
530 /* this one is for the cookie */ | |
531 priv = (struct aim_odc_intdata *)calloc(1, sizeof(struct aim_odc_intdata)); | |
532 | |
533 memcpy(priv->cookie, ck, 8); | |
534 strncpy(priv->sn, sn, sizeof(priv->sn)); | |
535 cookie->data = priv; | |
536 aim_cachecookie(sess, cookie); | |
537 | |
538 /* XXX - switch to aim_cloneconn()? */ | |
539 if (!(newconn = aim_newconn(sess, AIM_CONN_TYPE_LISTENER, NULL))) { | |
540 close(listenfd); | |
541 return NULL; | |
542 } | |
543 | |
544 /* this one is for the conn */ | |
545 priv = (struct aim_odc_intdata *)calloc(1, sizeof(struct aim_odc_intdata)); | |
546 | |
547 memcpy(priv->cookie, ck, 8); | |
548 strncpy(priv->sn, sn, sizeof(priv->sn)); | |
549 | |
550 newconn->fd = listenfd; | |
551 newconn->subtype = AIM_CONN_SUBTYPE_OFT_DIRECTIM; | |
552 newconn->internal = priv; | |
553 newconn->lastactivity = time(NULL); | |
554 | |
555 return newconn; | |
556 } | |
557 | |
558 /** | |
559 * Connect directly to the given buddy for directim. | |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
560 * |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
561 * This is a wrapper for aim_newconn. |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
562 * |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
563 * If addr is NULL, the socket is not created, but the connection is |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
564 * allocated and setup to connect. |
2086 | 565 * |
4617 | 566 * @param sess The Godly session. |
567 * @param sn The screen name we're connecting to. I hope it's a girl... | |
568 * @param addr Address to connect to. | |
569 * @return The new connection. | |
2086 | 570 */ |
4617 | 571 faim_export aim_conn_t *aim_odc_connect(aim_session_t *sess, const char *sn, const char *addr, const fu8_t *cookie) |
572 { | |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
573 aim_conn_t *newconn; |
4617 | 574 struct aim_odc_intdata *intdata; |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
575 |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
576 if (!sess || !sn) |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
577 return NULL; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
578 |
4617 | 579 if (!(intdata = malloc(sizeof(struct aim_odc_intdata)))) |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
580 return NULL; |
4617 | 581 memset(intdata, 0, sizeof(struct aim_odc_intdata)); |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
582 memcpy(intdata->cookie, cookie, 8); |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
583 strncpy(intdata->sn, sn, sizeof(intdata->sn)); |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
584 if (addr) |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
585 strncpy(intdata->ip, addr, sizeof(intdata->ip)); |
2086 | 586 |
4617 | 587 /* XXX - verify that non-blocking connects actually work */ |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
588 if (!(newconn = aim_newconn(sess, AIM_CONN_TYPE_RENDEZVOUS, addr))) { |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
589 free(intdata); |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
590 return NULL; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
591 } |
2086 | 592 |
4617 | 593 newconn->internal = intdata; |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
594 newconn->subtype = AIM_CONN_SUBTYPE_OFT_DIRECTIM; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
595 |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
596 return newconn; |
4617 | 597 } |
2086 | 598 |
599 /** | |
4617 | 600 * Creates a listener socket so the other dude can connect to us. |
2086 | 601 * |
4617 | 602 * You'll want to set up some kind of watcher on this socket. |
603 * When the state changes, call aim_handlerendconnection with | |
604 * the connection returned by this. aim_handlerendconnection | |
605 * will accept the pending connection and stop listening. | |
2086 | 606 * |
4617 | 607 * @param sess The session. |
608 * @param cookie This better be Mrs. Fields or I'm going to be pissed. | |
609 * @param ip Should be 4 bytes, each byte is 1 quartet of the IP address. | |
610 * @param port Ye olde port number to listen on. | |
611 * @return Return the new conn if everything went as planned. Otherwise, | |
612 * return NULL. | |
2086 | 613 */ |
4617 | 614 faim_export aim_conn_t *aim_sendfile_listen(aim_session_t *sess, const fu8_t *cookie, const fu8_t *ip, fu16_t port) |
2086 | 615 { |
4617 | 616 aim_conn_t *newconn; |
617 int listenfd; | |
2086 | 618 |
4617 | 619 if ((listenfd = listenestablish(port)) == -1) |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
620 return NULL; |
2086 | 621 |
4617 | 622 if (!(newconn = aim_newconn(sess, AIM_CONN_TYPE_LISTENER, NULL))) { |
623 close(listenfd); | |
3952 | 624 return NULL; |
625 } | |
3630 | 626 |
4617 | 627 newconn->fd = listenfd; |
628 newconn->subtype = AIM_CONN_SUBTYPE_OFT_SENDFILE; | |
629 newconn->lastactivity = time(NULL); | |
3952 | 630 |
4617 | 631 return newconn; |
632 } | |
3630 | 633 |
4617 | 634 /** |
635 * Extract an &aim_fileheader_t from the given buffer. | |
636 * | |
637 * @param bs The should be from an incoming rendezvous packet. | |
638 * @return A pointer to new struct on success, or NULL on error. | |
639 */ | |
640 static struct aim_fileheader_t *aim_oft_getheader(aim_bstream_t *bs) | |
641 { | |
642 struct aim_fileheader_t *fh; | |
3630 | 643 |
4617 | 644 if (!(fh = calloc(1, sizeof(struct aim_fileheader_t)))) |
645 return NULL; | |
3630 | 646 |
4617 | 647 /* The bstream should be positioned after the hdrtype. */ |
648 aimbs_getrawbuf(bs, fh->bcookie, 8); | |
649 fh->encrypt = aimbs_get16(bs); | |
650 fh->compress = aimbs_get16(bs); | |
651 fh->totfiles = aimbs_get16(bs); | |
652 fh->filesleft = aimbs_get16(bs); | |
653 fh->totparts = aimbs_get16(bs); | |
654 fh->partsleft = aimbs_get16(bs); | |
655 fh->totsize = aimbs_get32(bs); | |
656 fh->size = aimbs_get32(bs); | |
657 fh->modtime = aimbs_get32(bs); | |
658 fh->checksum = aimbs_get32(bs); | |
659 fh->rfrcsum = aimbs_get32(bs); | |
660 fh->rfsize = aimbs_get32(bs); | |
661 fh->cretime = aimbs_get32(bs); | |
662 fh->rfcsum = aimbs_get32(bs); | |
663 fh->nrecvd = aimbs_get32(bs); | |
664 fh->recvcsum = aimbs_get32(bs); | |
665 aimbs_getrawbuf(bs, fh->idstring, 32); | |
666 fh->flags = aimbs_get8(bs); | |
667 fh->lnameoffset = aimbs_get8(bs); | |
668 fh->lsizeoffset = aimbs_get8(bs); | |
669 aimbs_getrawbuf(bs, fh->dummy, 69); | |
670 aimbs_getrawbuf(bs, fh->macfileinfo, 16); | |
671 fh->nencode = aimbs_get16(bs); | |
672 fh->nlanguage = aimbs_get16(bs); | |
673 aimbs_getrawbuf(bs, fh->name, 64); /* XXX - filenames longer than 64B */ | |
2086 | 674 |
4617 | 675 return fh; |
676 } | |
3630 | 677 |
4617 | 678 /** |
679 * Fills a buffer with network-order fh data | |
680 * | |
681 * @param bs A bstream to fill -- automatically initialized | |
682 * @param fh A struct aim_fileheader_t to get data from. | |
683 * @return Return non-zero on error. | |
684 */ | |
685 static int aim_oft_buildheader(aim_bstream_t *bs, struct aim_fileheader_t *fh) | |
686 { | |
687 fu8_t *hdr; | |
3630 | 688 |
4617 | 689 if (!bs || !fh) |
690 return -EINVAL; | |
3952 | 691 |
4617 | 692 if (!(hdr = (unsigned char *)calloc(1, 0x100 - 8))) |
693 return -ENOMEM; | |
3630 | 694 |
4617 | 695 aim_bstream_init(bs, hdr, 0x100 - 8); |
696 aimbs_putraw(bs, fh->bcookie, 8); | |
697 aimbs_put16(bs, fh->encrypt); | |
698 aimbs_put16(bs, fh->compress); | |
699 aimbs_put16(bs, fh->totfiles); | |
700 aimbs_put16(bs, fh->filesleft); | |
701 aimbs_put16(bs, fh->totparts); | |
702 aimbs_put16(bs, fh->partsleft); | |
703 aimbs_put32(bs, fh->totsize); | |
704 aimbs_put32(bs, fh->size); | |
705 aimbs_put32(bs, fh->modtime); | |
706 aimbs_put32(bs, fh->checksum); | |
707 aimbs_put32(bs, fh->rfrcsum); | |
708 aimbs_put32(bs, fh->rfsize); | |
709 aimbs_put32(bs, fh->cretime); | |
710 aimbs_put32(bs, fh->rfcsum); | |
711 aimbs_put32(bs, fh->nrecvd); | |
712 aimbs_put32(bs, fh->recvcsum); | |
713 aimbs_putraw(bs, fh->idstring, 32); | |
714 aimbs_put8(bs, fh->flags); | |
715 aimbs_put8(bs, fh->lnameoffset); | |
716 aimbs_put8(bs, fh->lsizeoffset); | |
717 aimbs_putraw(bs, fh->dummy, 69); | |
718 aimbs_putraw(bs, fh->macfileinfo, 16); | |
719 aimbs_put16(bs, fh->nencode); | |
720 aimbs_put16(bs, fh->nlanguage); | |
721 aimbs_putraw(bs, fh->name, 64); /* XXX - filenames longer than 64B */ | |
3952 | 722 |
4617 | 723 return 0; |
724 } | |
2086 | 725 |
4617 | 726 /** |
727 * Create an OFT packet based on the given information, and send it on its merry way. | |
728 * | |
729 * @param sess The session. | |
730 * @param conn The already-connected OFT connection. | |
731 * @param cookie The cookie associated with this file transfer. | |
732 * @param filename The filename. | |
733 * @param filesdone Number of files already transferred. | |
734 * @param numfiles Total number of files. | |
735 * @param size Size in bytes of this file. | |
736 * @param totsize Size in bytes of all files combined. | |
737 * @param checksum Funky checksum of this file. | |
738 * @param flags Any flags you want, baby. Send 0x21 when sending the | |
739 * "AIM_CB_OFT_DONE" message, and "0x02" for everything else. | |
740 * @return Return 0 if no errors, otherwise return the error number. | |
741 */ | |
742 faim_export int aim_oft_sendheader(aim_session_t *sess, aim_conn_t *conn, fu16_t type, const fu8_t *cookie, const char *filename, fu16_t filesdone, fu16_t numfiles, fu32_t size, fu32_t totsize, fu32_t modtime, fu32_t checksum, fu8_t flags) | |
743 { | |
744 aim_frame_t *newoft; | |
745 struct aim_fileheader_t *fh; | |
2086 | 746 |
4617 | 747 if (!sess || !conn || (conn->type != AIM_CONN_TYPE_RENDEZVOUS) || !filename) |
748 return -EINVAL; | |
749 | |
750 if (!(fh = (struct aim_fileheader_t *)calloc(1, sizeof(struct aim_fileheader_t)))) | |
751 return -ENOMEM; | |
752 | |
753 /* | |
754 * If you are receiving a file, the cookie should be null, if you are sending a | |
755 * file, the cookie should be the same as the one used in the ICBM negotiation | |
756 * SNACs. | |
757 */ | |
758 if (cookie) | |
759 memcpy(fh->bcookie, cookie, 8); | |
760 fh->totfiles = numfiles; | |
761 fh->filesleft = numfiles - filesdone; | |
762 fh->totparts = 0x0001; /* set to 0x0002 sending Mac resource forks */ | |
3952 | 763 fh->partsleft = 0x0001; |
4617 | 764 fh->totsize = totsize; |
765 fh->size = size; | |
766 fh->modtime = modtime; | |
767 fh->checksum = checksum; | |
768 | |
3952 | 769 strncpy(fh->idstring, "OFT_Windows ICBMFT V1.1 32", sizeof(fh->idstring)); |
770 fh->flags = 0x02; | |
771 fh->lnameoffset = 0x1a; | |
772 fh->lsizeoffset = 0x10; | |
773 memset(fh->dummy, 0, sizeof(fh->dummy)); | |
774 memset(fh->macfileinfo, 0, sizeof(fh->macfileinfo)); | |
2086 | 775 |
4617 | 776 /* apparently 0 is ASCII, 2 is UCS-2 */ |
777 /* it is likely that 3 is ISO 8859-1 */ | |
3952 | 778 fh->nencode = 0x0000; |
779 fh->nlanguage = 0x0000; | |
4617 | 780 |
781 strncpy(fh->name, filename, sizeof(fh->name)); | |
782 aim_oft_dirconvert_tostupid(fh->name); | |
2086 | 783 |
4617 | 784 if (!(newoft = aim_tx_new(sess, conn, AIM_FRAMETYPE_OFT, type, 0))) { |
785 free(fh); | |
786 return -ENOMEM; | |
3952 | 787 } |
2086 | 788 |
4617 | 789 if (aim_oft_buildheader(&newoft->data, fh) == -1) { |
790 aim_frame_destroy(newoft); | |
791 free(fh); | |
792 return -ENOMEM; | |
793 } | |
2086 | 794 |
4617 | 795 memcpy(newoft->hdr.rend.magic, "OFT2", 4); |
796 newoft->hdr.rend.hdrlen = aim_bstream_curpos(&newoft->data); | |
3952 | 797 |
798 aim_tx_enqueue(sess, newoft); | |
2086 | 799 |
3952 | 800 free(fh); |
801 | |
802 return 0; | |
2086 | 803 } |
804 | |
805 /** | |
4617 | 806 * Sometimes you just don't know with these kinds of people. |
2086 | 807 * |
4617 | 808 * @param sess The session. |
809 * @param conn The ODC connection of the incoming data. | |
810 * @param frr The frame allocated for the incoming data. | |
811 * @param bs It stands for "bologna sandwich." | |
812 * @return Return 0 if no errors, otherwise return the error number. | |
2086 | 813 */ |
4617 | 814 static int handlehdr_odc(aim_session_t *sess, aim_conn_t *conn, aim_frame_t *frr, aim_bstream_t *bs) |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
815 { |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
816 aim_frame_t fr; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
817 aim_rxcallback_t userfunc; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
818 fu32_t payloadlength; |
3952 | 819 fu16_t flags, encoding; |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
820 char *snptr = NULL; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
821 |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
822 fr.conn = conn; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
823 |
4617 | 824 /* AAA - ugly */ |
3952 | 825 aim_bstream_setpos(bs, 20); |
826 payloadlength = aimbs_get32(bs); | |
827 | |
828 aim_bstream_setpos(bs, 24); | |
829 encoding = aimbs_get16(bs); | |
830 | |
831 aim_bstream_setpos(bs, 30); | |
832 flags = aimbs_get16(bs); | |
833 | |
834 aim_bstream_setpos(bs, 36); | |
4617 | 835 /* XXX - create an aimbs_getnullstr function? */ |
3952 | 836 snptr = aimbs_getstr(bs, MAXSNLEN); |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
837 |
4617 | 838 faimdprintf(sess, 2, "faim: OFT frame: handlehdr_odc: %04x / %04x / %s\n", payloadlength, flags, snptr); |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
839 |
3952 | 840 if (flags & 0x0002) { |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
841 int ret = 0; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
842 |
4002 | 843 if (flags & 0x000c) { |
3952 | 844 if ((userfunc = aim_callhandler(sess, conn, AIM_CB_FAM_OFT, AIM_CB_OFT_DIRECTIMTYPING))) |
845 ret = userfunc(sess, &fr, snptr, 1); | |
846 return ret; | |
847 } | |
2993 | 848 |
849 if ((userfunc = aim_callhandler(sess, conn, AIM_CB_FAM_OFT, AIM_CB_OFT_DIRECTIMTYPING))) | |
850 ret = userfunc(sess, &fr, snptr, 0); | |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
851 |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
852 return ret; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
853 |
3952 | 854 } else if (((flags & 0x000f) == 0x0000) && payloadlength) { |
2993 | 855 char *msg, *msg2; |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
856 int ret = 0; |
2993 | 857 int recvd = 0; |
858 int i; | |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
859 |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
860 if (!(msg = calloc(1, payloadlength+1))) |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
861 return -1; |
2993 | 862 msg2 = msg; |
863 | |
864 while (payloadlength - recvd) { | |
865 if (payloadlength - recvd >= 1024) | |
866 i = aim_recv(conn->fd, msg2, 1024); | |
867 else | |
868 i = aim_recv(conn->fd, msg2, payloadlength - recvd); | |
3012 | 869 if (i <= 0) { |
2993 | 870 free(msg); |
871 return -1; | |
872 } | |
873 recvd = recvd + i; | |
874 msg2 = msg2 + i; | |
4617 | 875 if ((userfunc = aim_callhandler(sess, conn, AIM_CB_FAM_SPECIAL, AIM_CB_SPECIAL_IMAGETRANSFER))) |
2993 | 876 userfunc(sess, &fr, snptr, (double)recvd / payloadlength); |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
877 } |
2993 | 878 |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
879 if ( (userfunc = aim_callhandler(sess, conn, AIM_CB_FAM_OFT, AIM_CB_OFT_DIRECTIMINCOMING)) ) |
3952 | 880 ret = userfunc(sess, &fr, snptr, msg, payloadlength, encoding); |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
881 |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
882 free(msg); |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
883 |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
884 return ret; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
885 } |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
886 |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
887 return 0; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
888 } |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
889 |
4617 | 890 /** |
891 * Handle incoming data on a rendezvous connection. This is analogous to the | |
892 * consumesnac function in rxhandlers.c, and I really think this should probably | |
893 * be in rxhandlers.c as well, but I haven't finished cleaning everything up yet. | |
894 * | |
895 * @param sess The session. | |
896 * @param fr The frame allocated for the incoming data. | |
897 * @return Return 0 if the packet was handled correctly, otherwise return the | |
898 * error number. | |
3771 | 899 */ |
3952 | 900 faim_internal int aim_rxdispatch_rendezvous(aim_session_t *sess, aim_frame_t *fr) |
2086 | 901 { |
3952 | 902 aim_conn_t *conn = fr->conn; |
4617 | 903 int ret = 1; |
2086 | 904 |
4617 | 905 if (conn->subtype == AIM_CONN_SUBTYPE_OFT_DIRECTIM) { |
906 if (fr->hdr.rend.type == 0x0001) | |
907 ret = handlehdr_odc(sess, conn, fr, &fr->data); | |
908 else | |
909 faimdprintf(sess, 0, "faim: ODC directim frame unknown, type is %04x\n", fr->hdr.rend.type); | |
2086 | 910 |
4617 | 911 } else if (conn->subtype == AIM_CONN_SUBTYPE_OFT_GETFILE) { |
912 switch (fr->hdr.rend.type) { | |
913 case 0x1108: /* getfile listing.txt incoming tx->rx */ | |
914 break; | |
915 case 0x1209: /* get file listing ack rx->tx */ | |
916 break; | |
917 case 0x120b: /* get file listing rx confirm */ | |
3630 | 918 break; |
4617 | 919 case 0x120c: /* getfile request */ |
920 break; | |
921 case 0x0101: /* getfile sending data */ | |
3630 | 922 break; |
4617 | 923 case 0x0202: /* getfile recv data */ |
3630 | 924 break; |
4617 | 925 case 0x0204: /* getfile finished */ |
3630 | 926 break; |
927 default: | |
4617 | 928 faimdprintf(sess, 2, "faim: OFT getfile frame uknown, type is %04x\n", fr->hdr.rend.type); |
3630 | 929 break; |
930 } | |
931 | |
4617 | 932 } else if (conn->subtype == AIM_CONN_SUBTYPE_OFT_SENDFILE) { |
933 aim_rxcallback_t userfunc; | |
934 struct aim_fileheader_t *header = aim_oft_getheader(&fr->data); | |
935 aim_oft_dirconvert_fromstupid(header->name); /* XXX - This should be client-side */ | |
3771 | 936 |
4617 | 937 if ((userfunc = aim_callhandler(sess, conn, AIM_CB_FAM_OFT, fr->hdr.rend.type))) |
938 ret = userfunc(sess, fr, conn, header->bcookie, header); | |
939 | |
940 free(header); | |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
941 } |
4617 | 942 |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
943 if (ret == -1) |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
944 aim_conn_close(conn); |
2086 | 945 |
2246
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
946 return ret; |
933346315b9b
[gaim-migrate @ 2256]
Eric Warmenhoven <eric@warmenhoven.org>
parents:
2086
diff
changeset
|
947 } |