Mercurial > gftp.yaz
annotate lib/rfc959.c @ 41:4bcfaf6307b5
2002-10-29 Brian Masney <masneyb@gftp.org>
* lib/config_file.c lib/gftp.h lib/options.h src/gtk/menu-items.c
src/gtk/view_dialog.c - removed tmp_directory variable. Instead use
g_get_tmp_dir ()
* lib/gftp.h (struct gftp_request) - added int cancel : 1
* lib/misc.c lib/protocols.c lib/rfc2068.c lib/rfc959.c lib/ssh.c
lib/sshv2.c - check for interrupted signal calls
* lib/protocols.c - added gftp_fgets() and gftp_fwrite() functions
* src/gtk/delete_dialog.c src/gtk/misc-gtk.c src/gtk/transfer.c - use
g_main_context_iteration in GTK+ 2.0 port
* src/gtk/misc-gtk.c - use g_object_unref instead of gdk_drawable_unref
in GTK+ 2.0 port
author | masneyb |
---|---|
date | Wed, 30 Oct 2002 02:53:21 +0000 |
parents | 66c064fd05bc |
children | e5f6054590b5 |
rev | line source |
---|---|
1 | 1 /*****************************************************************************/ |
2 /* rfc959.c - General purpose routines for the FTP protocol (RFC 959) */ | |
3 /* Copyright (C) 1998-2002 Brian Masney <masneyb@gftp.org> */ | |
4 /* */ | |
5 /* This program is free software; you can redistribute it and/or modify */ | |
6 /* it under the terms of the GNU General Public License as published by */ | |
7 /* the Free Software Foundation; either version 2 of the License, or */ | |
8 /* (at your option) any later version. */ | |
9 /* */ | |
10 /* This program is distributed in the hope that it will be useful, */ | |
11 /* but WITHOUT ANY WARRANTY; without even the implied warranty of */ | |
12 /* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the */ | |
13 /* GNU General Public License for more details. */ | |
14 /* */ | |
15 /* You should have received a copy of the GNU General Public License */ | |
16 /* along with this program; if not, write to the Free Software */ | |
17 /* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111 USA */ | |
18 /*****************************************************************************/ | |
19 | |
20 #include "gftp.h" | |
33 | 21 static const char cvsid[] = "$Id$"; |
1 | 22 |
23 static int rfc959_connect ( gftp_request * request ); | |
24 static void rfc959_disconnect ( gftp_request * request ); | |
25 static long rfc959_get_file ( gftp_request * request, | |
26 const char *filename, | |
27 FILE * fd, | |
28 off_t startsize ); | |
29 static int rfc959_put_file ( gftp_request * request, | |
30 const char *filename, | |
31 FILE * fd, | |
32 off_t startsize, | |
33 off_t totalsize ); | |
34 static long rfc959_transfer_file ( gftp_request *fromreq, | |
35 const char *fromfile, | |
36 off_t fromsize, | |
37 gftp_request *toreq, | |
38 const char *tofile, | |
39 off_t tosize ); | |
40 static int rfc959_end_transfer ( gftp_request * request ); | |
40 | 41 static int rfc959_abort_transfer ( gftp_request * request ); |
1 | 42 static int rfc959_list_files ( gftp_request * request ); |
43 static int rfc959_set_data_type ( gftp_request * request, | |
44 int data_type ); | |
45 static off_t rfc959_get_file_size ( gftp_request * request, | |
46 const char *filename ); | |
47 static int rfc959_data_connection_new ( gftp_request * request ); | |
48 static int rfc959_accept_active_connection ( gftp_request * request ); | |
49 static int rfc959_send_command ( gftp_request * request, | |
50 const char *command ); | |
51 static int rfc959_read_response ( gftp_request * request ); | |
52 static int rfc959_chdir ( gftp_request * request, | |
53 const char *directory ); | |
54 static int rfc959_rmdir ( gftp_request * request, | |
55 const char *directory ); | |
56 static int rfc959_rmfile ( gftp_request * request, | |
57 const char *file ); | |
58 static int rfc959_mkdir ( gftp_request * request, | |
59 const char *directory ); | |
60 static int rfc959_rename ( gftp_request * request, | |
61 const char *oldname, | |
62 const char *newname ); | |
63 static int rfc959_chmod ( gftp_request * request, | |
64 const char *file, | |
65 int mode ); | |
66 static int rfc959_site ( gftp_request * request, | |
67 const char *command ); | |
68 static char *parse_ftp_proxy_string ( gftp_request * request ); | |
69 | |
70 void | |
71 rfc959_init (gftp_request * request) | |
72 { | |
73 g_return_if_fail (request != NULL); | |
74 | |
75 request->protonum = GFTP_FTP_NUM; | |
76 request->init = rfc959_init; | |
77 request->destroy = NULL; | |
78 request->connect = rfc959_connect; | |
79 request->disconnect = rfc959_disconnect; | |
80 request->get_file = rfc959_get_file; | |
81 request->put_file = rfc959_put_file; | |
82 request->transfer_file = rfc959_transfer_file; | |
83 request->get_next_file_chunk = NULL; | |
84 request->put_next_file_chunk = NULL; | |
85 request->end_transfer = rfc959_end_transfer; | |
40 | 86 request->abort_transfer = rfc959_abort_transfer; |
1 | 87 request->list_files = rfc959_list_files; |
88 request->get_next_file = rfc959_get_next_file; | |
89 request->set_data_type = rfc959_set_data_type; | |
90 request->get_file_size = rfc959_get_file_size; | |
91 request->chdir = rfc959_chdir; | |
92 request->rmdir = rfc959_rmdir; | |
93 request->rmfile = rfc959_rmfile; | |
94 request->mkdir = rfc959_mkdir; | |
95 request->rename = rfc959_rename; | |
96 request->chmod = rfc959_chmod; | |
97 request->set_file_time = NULL; | |
98 request->site = rfc959_site; | |
99 request->parse_url = NULL; | |
100 request->url_prefix = "ftp"; | |
101 request->protocol_name = "FTP"; | |
102 request->need_hostport = 1; | |
103 request->need_userpass = 1; | |
104 request->use_cache = 1; | |
105 request->use_threads = 1; | |
106 request->always_connected = 0; | |
107 gftp_set_config_options (request); | |
108 } | |
109 | |
110 | |
111 static int | |
112 rfc959_connect (gftp_request * request) | |
113 { | |
114 char tempchar, *startpos, *endpos, *tempstr, *dir; | |
115 int sock, ret, resp; | |
116 | |
117 g_return_val_if_fail (request != NULL, -2); | |
118 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
119 g_return_val_if_fail (request->hostname != NULL, -2); | |
120 | |
7 | 121 if (request->username == NULL || *request->username == '\0') |
122 { | |
123 gftp_set_username (request, "anonymous"); | |
124 gftp_set_password (request, emailaddr); | |
125 } | |
126 else if (strcasecmp (request->username, "anonymous") == 0) | |
127 gftp_set_password (request, emailaddr); | |
128 | |
1 | 129 if (request->sockfd != NULL) |
130 return (0); | |
131 | |
132 if ((sock = gftp_connect_server (request, "ftp")) < 0) | |
133 return (-1); | |
134 | |
14
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
135 if ((request->sockfd = fdopen (sock, "rb+")) == NULL) |
1 | 136 { |
137 request->logging_function (gftp_logging_error, request->user_data, | |
138 _("Cannot fdopen() socket: %s\n"), | |
139 g_strerror (errno)); | |
140 close (sock); | |
141 return (-2); | |
142 } | |
143 | |
14
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
144 if ((request->sockfd_write = fdopen (dup (sock), "wb+")) == NULL) |
1 | 145 { |
146 request->logging_function (gftp_logging_error, request->user_data, | |
147 _("Cannot fdopen() socket: %s\n"), | |
148 g_strerror (errno)); | |
149 gftp_disconnect (request); | |
150 return (-2); | |
151 } | |
152 | |
153 /* Get the banner */ | |
154 if (rfc959_read_response (request) != '2') | |
155 { | |
156 gftp_disconnect (request); | |
157 return (-2); | |
158 } | |
159 | |
160 /* Login the proxy server if available */ | |
161 if (request->use_proxy) | |
162 { | |
163 resp = '3'; | |
164 startpos = endpos = tempstr = parse_ftp_proxy_string (request); | |
165 while ((resp == '3' || resp == '2') && *startpos != '\0') | |
166 { | |
167 if (*endpos == '\n' || *endpos == '\0') | |
168 { | |
169 tempchar = *(endpos + 1); | |
170 if (*endpos != '\0') | |
171 *(endpos + 1) = '\0'; | |
172 if ((resp = rfc959_send_command (request, startpos)) < 0) | |
173 return (-2); | |
174 if (*endpos != '\0') | |
175 *(endpos + 1) = tempchar; | |
176 else | |
177 break; | |
178 startpos = endpos + 1; | |
179 } | |
180 endpos++; | |
181 } | |
182 g_free (tempstr); | |
183 } | |
184 else | |
185 { | |
186 tempstr = g_strconcat ("USER ", request->username, "\r\n", NULL); | |
187 resp = rfc959_send_command (request, tempstr); | |
188 g_free (tempstr); | |
189 if (resp < 0) | |
190 return (-2); | |
191 if (resp == '3') | |
192 { | |
193 tempstr = g_strconcat ("PASS ", request->password, "\r\n", NULL); | |
194 resp = rfc959_send_command (request, tempstr); | |
195 g_free (tempstr); | |
196 if (resp < 0) | |
197 return (-2); | |
198 } | |
199 if (resp == '3' && request->account) | |
200 { | |
201 tempstr = g_strconcat ("ACCT ", request->account, "\r\n", NULL); | |
202 resp = rfc959_send_command (request, tempstr); | |
203 g_free (tempstr); | |
204 if (resp < 0) | |
205 return (-2); | |
206 } | |
207 } | |
208 | |
209 if (resp != '2') | |
210 { | |
211 gftp_disconnect (request); | |
212 return (-2); | |
213 } | |
214 | |
215 if (request->data_type == GFTP_TYPE_BINARY) | |
216 tempstr = "TYPE I\r\n"; | |
217 else | |
218 tempstr = "TYPE A\r\n"; | |
219 | |
220 if (rfc959_send_command (request, tempstr) < 0) | |
221 return (-2); | |
222 | |
223 ret = -1; | |
224 if (request->directory != NULL && *request->directory != '\0') | |
225 { | |
226 ret = rfc959_chdir (request, request->directory); | |
227 if (request->sockfd == NULL) | |
228 return (-2); | |
229 } | |
230 | |
231 if (ret != 0) | |
232 { | |
233 if (rfc959_send_command (request, "PWD\r\n") != '2' || | |
234 request->sockfd == NULL) | |
235 { | |
236 gftp_disconnect (request); | |
237 return (-2); | |
238 } | |
239 | |
240 if ((tempstr = strchr (request->last_ftp_response, '"')) == NULL) | |
241 { | |
242 gftp_disconnect (request); | |
243 return (-2); | |
244 } | |
245 dir = tempstr + 1; | |
246 | |
247 if ((tempstr = strchr (dir, '"')) == NULL) | |
248 { | |
249 gftp_disconnect (request); | |
250 return (0); | |
251 } | |
252 if (tempstr != NULL) | |
253 *tempstr = '\0'; | |
254 | |
255 request->directory = g_malloc (strlen (dir) + 1); | |
256 strcpy (request->directory, dir); | |
257 } | |
258 | |
259 if (request->sockfd == NULL) | |
260 return (-2); | |
261 | |
262 return (0); | |
263 } | |
264 | |
265 | |
266 static void | |
267 rfc959_disconnect (gftp_request * request) | |
268 { | |
269 g_return_if_fail (request != NULL); | |
270 g_return_if_fail (request->protonum == GFTP_FTP_NUM); | |
271 | |
272 if (request->sockfd != NULL) | |
273 { | |
274 request->logging_function (gftp_logging_misc, request->user_data, | |
275 _("Disconnecting from site %s\n"), | |
276 request->hostname); | |
277 fclose (request->sockfd); | |
278 fclose (request->sockfd_write); | |
279 request->sockfd = request->sockfd_write = NULL; | |
280 if (request->datafd) | |
281 { | |
282 fclose (request->datafd); | |
283 request->datafd = NULL; | |
284 } | |
285 } | |
286 } | |
287 | |
288 | |
289 static long | |
290 rfc959_get_file (gftp_request * request, const char *filename, FILE * fd, | |
291 off_t startsize) | |
292 { | |
293 char *command, *tempstr, resp; | |
294 int ret, flags; | |
295 | |
296 g_return_val_if_fail (request != NULL, -2); | |
297 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
298 g_return_val_if_fail (filename != NULL, -2); | |
299 g_return_val_if_fail (request->sockfd != NULL, -2); | |
300 | |
301 if (fd != NULL) | |
302 request->datafd = fd; | |
303 | |
304 if (request->datafd == NULL && | |
305 (ret = rfc959_data_connection_new (request)) < 0) | |
306 return (ret); | |
307 | |
308 flags = fcntl (fileno (request->datafd), F_GETFL, 0); | |
309 if (fcntl (fileno (request->datafd), F_SETFL, flags | O_NONBLOCK) < 0) | |
310 { | |
311 fclose (request->datafd); | |
312 request->datafd = NULL; | |
313 return (-1); | |
314 } | |
315 | |
316 if (startsize > 0) | |
317 { | |
14
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
318 #if defined (_LARGEFILE_SOURCE) |
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
319 command = g_strdup_printf ("REST %lld\r\n", startsize); |
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
320 #else |
1 | 321 command = g_strdup_printf ("REST %ld\r\n", startsize); |
14
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
322 #endif |
1 | 323 resp = rfc959_send_command (request, command); |
324 g_free (command); | |
325 | |
326 if (resp != '3') | |
327 { | |
328 fclose (request->datafd); | |
329 request->datafd = NULL; | |
330 return (-2); | |
331 } | |
332 } | |
333 | |
334 tempstr = g_strconcat ("RETR ", filename, "\r\n", NULL); | |
335 ret = rfc959_send_command (request, tempstr); | |
336 g_free (tempstr); | |
337 | |
338 if (ret != '1') | |
40 | 339 return (-2); |
1 | 340 |
341 if (request->transfer_type == gftp_transfer_active && | |
342 (ret = rfc959_accept_active_connection (request)) < 0) | |
343 return (ret); | |
344 | |
345 if ((tempstr = strrchr (request->last_ftp_response, '(')) == NULL) | |
346 { | |
347 tempstr = request->last_ftp_response + 4; | |
348 while (!isdigit ((int) *tempstr) && *tempstr != '\0') | |
349 tempstr++; | |
350 } | |
351 else | |
352 tempstr++; | |
353 | |
354 return (strtol (tempstr, NULL, 10) + startsize); | |
355 } | |
356 | |
357 | |
358 static int | |
359 rfc959_put_file (gftp_request * request, const char *filename, FILE * fd, | |
360 off_t startsize, off_t totalsize) | |
361 { | |
362 char *command, *tempstr, resp; | |
363 int ret, flags; | |
364 | |
365 g_return_val_if_fail (request != NULL, -2); | |
366 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
367 g_return_val_if_fail (filename != NULL, -2); | |
368 g_return_val_if_fail (request->sockfd != NULL, -2); | |
369 | |
370 if (fd != NULL) | |
371 fd = request->datafd; | |
372 | |
373 if (request->datafd == NULL && | |
374 (ret = rfc959_data_connection_new (request)) < 0) | |
375 return (ret); | |
376 | |
377 flags = fcntl (fileno (request->datafd), F_GETFL, 0); | |
378 if (fcntl (fileno (request->datafd), F_SETFL, flags | O_NONBLOCK) < 0) | |
379 { | |
380 fclose (request->datafd); | |
381 request->datafd = NULL; | |
382 return (-1); | |
383 } | |
384 | |
385 if (startsize > 0) | |
386 { | |
14
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
387 #if defined (_LARGEFILE_SOURCE) |
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
388 command = g_strdup_printf ("REST %lld\r\n", startsize); |
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
389 #else |
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
390 command = g_strdup_printf ("REST %ld\r\n", startsize); |
83090328581e
* More largefile support. Hopefully all that is left is the configure stuff
masneyb
parents:
7
diff
changeset
|
391 #endif |
1 | 392 resp = rfc959_send_command (request, command); |
393 g_free (command); | |
394 if (resp != '3') | |
395 { | |
396 fclose (request->datafd); | |
397 request->datafd = NULL; | |
398 return (-2); | |
399 } | |
400 } | |
401 | |
402 tempstr = g_strconcat ("STOR ", filename, "\r\n", NULL); | |
403 ret = rfc959_send_command (request, tempstr); | |
404 g_free (tempstr); | |
405 if (ret != '1') | |
40 | 406 return (-2); |
1 | 407 |
408 if (request->transfer_type == gftp_transfer_active && | |
409 (ret = rfc959_accept_active_connection (request)) < 0) | |
410 return (ret); | |
411 | |
412 return (0); | |
413 } | |
414 | |
415 static long | |
416 rfc959_transfer_file (gftp_request *fromreq, const char *fromfile, | |
417 off_t fromsize, gftp_request *toreq, | |
418 const char *tofile, off_t tosize) | |
419 { | |
420 char *tempstr, *pos, *endpos; | |
421 | |
422 g_return_val_if_fail (fromreq != NULL, -2); | |
423 g_return_val_if_fail (fromfile != NULL, -2); | |
424 g_return_val_if_fail (toreq != NULL, -2); | |
425 g_return_val_if_fail (tofile != NULL, -2); | |
426 g_return_val_if_fail (fromreq->sockfd != NULL, -2); | |
427 g_return_val_if_fail (toreq->sockfd != NULL, -2); | |
428 | |
429 fromreq->transfer_type = gftp_transfer_passive; | |
430 toreq->transfer_type = gftp_transfer_active; | |
431 | |
432 if (rfc959_send_command (fromreq, "PASV\r\n") != '2' || | |
433 fromreq->sockfd == NULL) | |
434 return (-2); | |
435 | |
436 pos = fromreq->last_ftp_response + 4; | |
437 while (!isdigit ((int) *pos) && *pos != '\0') | |
438 pos++; | |
439 if (*pos == '\0') | |
440 return (-2); | |
441 | |
442 endpos = pos; | |
443 while (*endpos != ')' && *endpos != '\0') | |
444 endpos++; | |
445 if (*endpos == ')') | |
446 *endpos = '\0'; | |
447 | |
448 tempstr = g_strconcat ("PORT ", pos, "\r\n", NULL); | |
15
82fabd6ef1c4
FXP fixes (from Tobias Gruetzmacher <tobias@portfolio16.de>)
masneyb
parents:
14
diff
changeset
|
449 if (rfc959_send_command (toreq, tempstr) != '2') |
82fabd6ef1c4
FXP fixes (from Tobias Gruetzmacher <tobias@portfolio16.de>)
masneyb
parents:
14
diff
changeset
|
450 { |
82fabd6ef1c4
FXP fixes (from Tobias Gruetzmacher <tobias@portfolio16.de>)
masneyb
parents:
14
diff
changeset
|
451 g_free (tempstr); |
82fabd6ef1c4
FXP fixes (from Tobias Gruetzmacher <tobias@portfolio16.de>)
masneyb
parents:
14
diff
changeset
|
452 return (-2); |
82fabd6ef1c4
FXP fixes (from Tobias Gruetzmacher <tobias@portfolio16.de>)
masneyb
parents:
14
diff
changeset
|
453 } |
1 | 454 g_free (tempstr); |
455 | |
456 tempstr = g_strconcat ("RETR ", fromfile, "\r\n", NULL); | |
41 | 457 if (gftp_fwrite (fromreq, tempstr, strlen (tempstr), |
458 fromreq->sockfd_write) < 0) | |
15
82fabd6ef1c4
FXP fixes (from Tobias Gruetzmacher <tobias@portfolio16.de>)
masneyb
parents:
14
diff
changeset
|
459 { |
82fabd6ef1c4
FXP fixes (from Tobias Gruetzmacher <tobias@portfolio16.de>)
masneyb
parents:
14
diff
changeset
|
460 g_free (tempstr); |
82fabd6ef1c4
FXP fixes (from Tobias Gruetzmacher <tobias@portfolio16.de>)
masneyb
parents:
14
diff
changeset
|
461 return (-2); |
82fabd6ef1c4
FXP fixes (from Tobias Gruetzmacher <tobias@portfolio16.de>)
masneyb
parents:
14
diff
changeset
|
462 } |
1 | 463 g_free (tempstr); |
464 | |
465 tempstr = g_strconcat ("STOR ", tofile, "\r\n", NULL); | |
41 | 466 if (gftp_fwrite (toreq, tempstr, strlen (tempstr), toreq->sockfd_write) < 0) |
15
82fabd6ef1c4
FXP fixes (from Tobias Gruetzmacher <tobias@portfolio16.de>)
masneyb
parents:
14
diff
changeset
|
467 { |
82fabd6ef1c4
FXP fixes (from Tobias Gruetzmacher <tobias@portfolio16.de>)
masneyb
parents:
14
diff
changeset
|
468 g_free (tempstr); |
82fabd6ef1c4
FXP fixes (from Tobias Gruetzmacher <tobias@portfolio16.de>)
masneyb
parents:
14
diff
changeset
|
469 return (-2); |
82fabd6ef1c4
FXP fixes (from Tobias Gruetzmacher <tobias@portfolio16.de>)
masneyb
parents:
14
diff
changeset
|
470 } |
1 | 471 g_free (tempstr); |
472 | |
473 if (rfc959_read_response (fromreq) < 0) | |
474 return (-2); | |
475 if (rfc959_read_response (toreq) < 0) | |
476 return (-2); | |
477 | |
478 return (0); | |
479 } | |
480 | |
481 | |
482 static int | |
483 rfc959_end_transfer (gftp_request * request) | |
484 { | |
485 g_return_val_if_fail (request != NULL, -2); | |
486 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
487 g_return_val_if_fail (request->sockfd != NULL, -2); | |
488 | |
489 if (request->datafd) | |
490 { | |
491 fclose (request->datafd); | |
492 request->datafd = NULL; | |
493 } | |
494 return (rfc959_read_response (request) == '2' ? 0 : -2); | |
495 } | |
496 | |
497 | |
498 static int | |
40 | 499 rfc959_abort_transfer (gftp_request * request) |
500 { | |
501 int ret; | |
502 | |
503 g_return_val_if_fail (request != NULL, -2); | |
504 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
505 g_return_val_if_fail (request->sockfd != NULL, -2); | |
506 | |
507 if (request->datafd) | |
508 { | |
509 fclose (request->datafd); | |
510 request->datafd = NULL; | |
511 } | |
512 | |
513 /* We need to read two lines of output. The first one is acknowleging | |
514 the transfer and the second line acknowleges the ABOR command */ | |
515 rfc959_send_command (request, "ABOR\r\n"); | |
516 | |
517 if (request->sockfd != NULL) | |
518 { | |
519 ret = rfc959_read_response (request); | |
520 | |
521 if (ret != '2') | |
522 gftp_disconnect (request); | |
523 } | |
524 | |
525 return (0); | |
526 } | |
527 | |
528 | |
529 static int | |
1 | 530 rfc959_list_files (gftp_request * request) |
531 { | |
532 char *tempstr, parms[3]; | |
533 int ret; | |
534 | |
535 g_return_val_if_fail (request != NULL, -2); | |
536 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
537 g_return_val_if_fail (request->sockfd != NULL, -2); | |
538 | |
539 if ((ret = rfc959_data_connection_new (request)) < 0) | |
540 return (ret); | |
541 | |
542 *parms = '\0'; | |
543 strcat (parms, show_hidden_files ? "a" : ""); | |
544 strcat (parms, resolve_symlinks ? "L" : ""); | |
545 tempstr = g_strconcat ("LIST", *parms != '\0' ? " -" : "", parms, "\r\n", | |
546 NULL); | |
547 | |
548 ret = rfc959_send_command (request, tempstr); | |
549 g_free (tempstr); | |
550 | |
551 if (ret != '1') | |
552 return (-2); | |
553 | |
554 ret = 0; | |
555 if (request->transfer_type == gftp_transfer_active) | |
556 ret = rfc959_accept_active_connection (request); | |
557 | |
558 return (ret); | |
559 } | |
560 | |
561 | |
562 int | |
563 rfc959_get_next_file (gftp_request * request, gftp_file * fle, FILE * fd) | |
564 { | |
565 char tempstr[255]; | |
566 size_t len; | |
567 | |
568 g_return_val_if_fail (request != NULL, -2); | |
569 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
570 g_return_val_if_fail (fle != NULL, -2); | |
571 g_return_val_if_fail (fd != NULL, -2); | |
572 | |
573 if (request->last_dir_entry) | |
574 { | |
575 g_free (request->last_dir_entry); | |
576 request->last_dir_entry = NULL; | |
577 } | |
578 do | |
579 { | |
41 | 580 if (!gftp_fgets (request, tempstr, sizeof (tempstr), fd)) |
1 | 581 { |
582 gftp_file_destroy (fle); | |
583 if (ferror (fd)) | |
584 gftp_disconnect (request); | |
585 return (-2); | |
586 } | |
587 tempstr[sizeof (tempstr) - 1] = '\0'; | |
588 | |
589 if (gftp_parse_ls (tempstr, fle) != 0) | |
590 { | |
591 if (strncmp (tempstr, "total", strlen("total")) != 0 && | |
592 strncmp (tempstr, _("total"), strlen(_("total"))) != 0) | |
593 request->logging_function (gftp_logging_misc, request->user_data, | |
594 _("Warning: Cannot parse listing %s\n"), | |
595 tempstr); | |
596 gftp_file_destroy (fle); | |
597 continue; | |
598 } | |
599 else | |
600 break; | |
601 } | |
602 while (1); | |
603 | |
604 len = strlen (tempstr); | |
605 if (!request->cached) | |
606 { | |
607 request->last_dir_entry = g_malloc (len + 1); | |
608 strcpy (request->last_dir_entry, tempstr); | |
609 request->last_dir_entry_len = len; | |
610 } | |
611 return (len); | |
612 } | |
613 | |
614 | |
615 static int | |
616 rfc959_set_data_type (gftp_request * request, int data_type) | |
617 { | |
618 char *tempstr; | |
619 | |
620 g_return_val_if_fail (request != NULL, -2); | |
621 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
622 | |
623 if (request->sockfd != NULL && request->data_type != data_type) | |
624 { | |
625 if (data_type == GFTP_TYPE_BINARY) | |
626 tempstr = "TYPE I\r\n"; | |
627 else | |
628 tempstr = "TYPE A\r\n"; | |
629 | |
630 if (rfc959_send_command (request, tempstr) != '2') | |
631 return (-2); | |
632 } | |
633 request->data_type = data_type; | |
634 return (0); | |
635 } | |
636 | |
637 | |
638 static off_t | |
639 rfc959_get_file_size (gftp_request * request, const char *filename) | |
640 { | |
641 char *tempstr; | |
642 int ret; | |
643 | |
644 g_return_val_if_fail (request != NULL, 0); | |
645 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
646 g_return_val_if_fail (filename != NULL, 0); | |
647 g_return_val_if_fail (request->sockfd != NULL, 0); | |
648 | |
649 tempstr = g_strconcat ("SIZE ", filename, "\r\n", NULL); | |
650 ret = rfc959_send_command (request, tempstr); | |
651 g_free (tempstr); | |
652 if (ret < 0) | |
653 return (-2); | |
654 | |
655 if (*request->last_ftp_response != '2') | |
656 return (0); | |
657 return (strtol (request->last_ftp_response + 4, NULL, 10)); | |
658 } | |
659 | |
660 | |
661 static int | |
662 rfc959_data_connection_new (gftp_request * request) | |
663 { | |
664 char *pos, *pos1, resp, *command; | |
665 struct sockaddr_in data_addr; | |
666 size_t data_addr_len; | |
667 unsigned int temp[6]; | |
668 unsigned char ad[6]; | |
669 int i, sock; | |
670 | |
671 g_return_val_if_fail (request != NULL, -2); | |
672 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
673 g_return_val_if_fail (request->sockfd != NULL, -2); | |
674 | |
675 if ((sock = socket (AF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0) | |
676 { | |
677 request->logging_function (gftp_logging_error, request->user_data, | |
678 _("Failed to create a socket: %s\n"), | |
679 g_strerror (errno)); | |
680 gftp_disconnect (request); | |
681 return (-1); | |
682 } | |
683 | |
684 data_addr_len = sizeof (data_addr); | |
685 memset (&data_addr, 0, data_addr_len); | |
686 data_addr.sin_family = AF_INET; | |
687 | |
688 if (request->transfer_type == gftp_transfer_passive) | |
689 { | |
690 if ((resp = rfc959_send_command (request, "PASV\r\n")) != '2') | |
691 { | |
692 if (request->sockfd == NULL) | |
693 return (-2); | |
694 | |
695 request->transfer_type = gftp_transfer_active; | |
696 return (rfc959_data_connection_new (request)); | |
697 } | |
698 pos = request->last_ftp_response + 4; | |
699 while (!isdigit ((int) *pos) && *pos != '\0') | |
700 pos++; | |
701 if (*pos == '\0') | |
702 { | |
703 gftp_disconnect (request); | |
704 close (sock); | |
705 return (-2); | |
706 } | |
707 if (sscanf (pos, "%u,%u,%u,%u,%u,%u", &temp[0], &temp[1], &temp[2], | |
708 &temp[3], &temp[4], &temp[5]) != 6) | |
709 { | |
710 gftp_disconnect (request); | |
711 close (sock); | |
712 return (-2); | |
713 } | |
714 for (i = 0; i < 6; i++) | |
715 ad[i] = (unsigned char) (temp[i] & 0xff); | |
716 | |
717 memcpy (&data_addr.sin_addr, &ad[0], 4); | |
718 memcpy (&data_addr.sin_port, &ad[4], 2); | |
719 if (connect (sock, (struct sockaddr *) &data_addr, data_addr_len) == -1) | |
720 { | |
721 request->logging_function (gftp_logging_error, request->user_data, | |
722 _("Cannot create a data connection: %s\n"), | |
723 g_strerror (errno)); | |
724 gftp_disconnect (request); | |
725 close (sock); | |
726 return (-1); | |
727 } | |
728 } | |
729 else | |
730 { | |
731 getsockname (fileno (request->sockfd), (struct sockaddr *) &data_addr, | |
732 &data_addr_len); | |
733 data_addr.sin_port = 0; | |
734 if (bind (sock, (struct sockaddr *) &data_addr, data_addr_len) == -1) | |
735 { | |
736 request->logging_function (gftp_logging_error, request->user_data, | |
737 _("Cannot bind a port: %s\n"), | |
738 g_strerror (errno)); | |
739 gftp_disconnect (request); | |
740 close (sock); | |
741 return (-1); | |
742 } | |
743 | |
744 getsockname (sock, (struct sockaddr *) &data_addr, &data_addr_len); | |
745 if (listen (sock, 1) == -1) | |
746 { | |
747 request->logging_function (gftp_logging_error, request->user_data, | |
748 _("Cannot listen on port %d: %s\n"), | |
749 ntohs (data_addr.sin_port), | |
750 g_strerror (errno)); | |
751 gftp_disconnect (request); | |
752 close (sock); | |
753 return (-1); | |
754 } | |
755 pos = (char *) &data_addr.sin_addr; | |
756 pos1 = (char *) &data_addr.sin_port; | |
757 command = g_strdup_printf ("PORT %u,%u,%u,%u,%u,%u\r\n", | |
758 pos[0] & 0xff, pos[1] & 0xff, pos[2] & 0xff, | |
759 pos[3] & 0xff, pos1[0] & 0xff, | |
760 pos1[1] & 0xff); | |
761 resp = rfc959_send_command (request, command); | |
762 g_free (command); | |
763 if (resp != '2') | |
764 { | |
765 gftp_disconnect (request); | |
766 close (sock); | |
767 return (-2); | |
768 } | |
769 } | |
770 | |
771 if ((request->datafd = fdopen (sock, "rb+")) == NULL) | |
772 { | |
773 request->logging_function (gftp_logging_error, request->user_data, | |
774 _("Cannot fdopen() socket: %s\n"), | |
775 g_strerror (errno)); | |
776 gftp_disconnect (request); | |
777 return (-2); | |
778 } | |
779 | |
780 return (0); | |
781 } | |
782 | |
783 | |
784 static int | |
785 rfc959_accept_active_connection (gftp_request * request) | |
786 { | |
787 struct sockaddr_in cli_addr; | |
788 size_t cli_addr_len; | |
789 int infd; | |
790 | |
791 g_return_val_if_fail (request != NULL, -2); | |
792 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
793 g_return_val_if_fail (request->datafd != NULL, -2); | |
794 g_return_val_if_fail (request->transfer_type == gftp_transfer_active, -2); | |
795 | |
796 cli_addr_len = sizeof (cli_addr); | |
797 if ((infd = accept (fileno (request->datafd), (struct sockaddr *) &cli_addr, | |
798 &cli_addr_len)) == -1) | |
799 { | |
800 request->logging_function (gftp_logging_error, request->user_data, | |
801 _("Cannot accept connection from server: %s\n"), | |
802 g_strerror (errno)); | |
803 gftp_disconnect (request); | |
804 return (-1); | |
805 } | |
806 | |
807 fclose (request->datafd); | |
808 | |
809 if ((request->datafd = fdopen (infd, "rb+")) == NULL) | |
810 { | |
811 request->logging_function (gftp_logging_error, request->user_data, | |
812 _("Cannot fdopen() socket: %s\n"), | |
813 g_strerror (errno)); | |
814 gftp_disconnect (request); | |
815 return (-2); | |
816 } | |
817 return (0); | |
818 } | |
819 | |
820 | |
821 static int | |
822 rfc959_send_command (gftp_request * request, const char *command) | |
823 { | |
824 g_return_val_if_fail (request != NULL, -2); | |
825 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
826 g_return_val_if_fail (command != NULL, -2); | |
827 g_return_val_if_fail (request->sockfd != NULL, -2); | |
828 | |
829 if (strncmp (command, "PASS", 4) == 0) | |
830 { | |
831 request->logging_function (gftp_logging_send, request->user_data, | |
832 "PASS xxxx\n"); | |
833 } | |
834 else if (strncmp (command, "ACCT", 4) == 0) | |
835 { | |
836 request->logging_function (gftp_logging_send, request->user_data, | |
837 "ACCT xxxx\n"); | |
838 } | |
839 else | |
840 { | |
841 request->logging_function (gftp_logging_send, request->user_data, "%s", | |
842 command); | |
843 } | |
844 | |
41 | 845 if (gftp_fwrite (request, command, strlen (command), |
846 request->sockfd_write) < 0) | |
40 | 847 return (-1); |
1 | 848 |
849 return (rfc959_read_response (request)); | |
850 } | |
851 | |
852 | |
853 static int | |
854 rfc959_read_response (gftp_request * request) | |
855 { | |
856 char tempstr[255], code[4]; | |
857 | |
858 g_return_val_if_fail (request != NULL, -2); | |
859 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
860 g_return_val_if_fail (request->sockfd != NULL, -2); | |
861 | |
862 *code = '\0'; | |
863 if (request->last_ftp_response) | |
864 { | |
865 g_free (request->last_ftp_response); | |
866 request->last_ftp_response = NULL; | |
867 } | |
868 | |
869 do | |
870 { | |
41 | 871 if (!gftp_fgets (request, tempstr, sizeof (tempstr), request->sockfd)) |
1 | 872 break; |
873 tempstr[strlen (tempstr) - 1] = '\0'; | |
874 if (tempstr[strlen (tempstr) - 1] == '\r') | |
875 tempstr[strlen (tempstr) - 1] = '\0'; | |
876 if (isdigit ((int) *tempstr) && isdigit ((int) *(tempstr + 1)) | |
877 && isdigit ((int) *(tempstr + 2))) | |
878 { | |
879 strncpy (code, tempstr, 3); | |
880 code[3] = ' '; | |
881 } | |
882 request->logging_function (gftp_logging_recv, request->user_data, | |
883 "%s\n", tempstr); | |
884 } | |
885 while (strncmp (code, tempstr, 4) != 0); | |
886 | |
887 if (ferror (request->sockfd)) | |
888 { | |
889 request->logging_function (gftp_logging_send, request->user_data, | |
890 "Error reading from socket: %s\n", | |
891 g_strerror (errno)); | |
892 gftp_disconnect (request); | |
893 return (-1); | |
894 } | |
895 | |
896 request->last_ftp_response = g_malloc (strlen (tempstr) + 1); | |
897 strcpy (request->last_ftp_response, tempstr); | |
898 | |
40 | 899 if (request->last_ftp_response[0] == '4' && |
900 request->last_ftp_response[1] == '2') | |
1 | 901 gftp_disconnect (request); |
902 | |
903 return (*request->last_ftp_response); | |
904 } | |
905 | |
906 | |
907 static int | |
908 rfc959_chdir (gftp_request * request, const char *directory) | |
909 { | |
910 char ret, *tempstr, *dir; | |
911 | |
912 g_return_val_if_fail (request != NULL, -2); | |
913 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
914 g_return_val_if_fail (directory != NULL, -2); | |
915 | |
916 if (strcmp (directory, "..") == 0) | |
917 ret = rfc959_send_command (request, "CDUP\r\n"); | |
918 else | |
919 { | |
920 tempstr = g_strconcat ("CWD ", directory, "\r\n", NULL); | |
921 ret = rfc959_send_command (request, tempstr); | |
922 g_free (tempstr); | |
923 } | |
924 | |
925 if (ret != '2') | |
926 return (-2); | |
927 | |
928 if (directory != request->directory) | |
929 { | |
930 if (request->directory) | |
931 { | |
932 g_free (request->directory); | |
933 request->directory = NULL; | |
934 } | |
935 | |
936 if (rfc959_send_command (request, "PWD\r\n") != '2') | |
937 return (-2); | |
938 | |
939 tempstr = strchr (request->last_ftp_response, '"'); | |
940 if (tempstr != NULL) | |
941 dir = tempstr + 1; | |
942 else | |
943 return (-2); | |
944 | |
945 tempstr = strchr (dir, '"'); | |
946 if (tempstr != NULL) | |
947 *tempstr = '\0'; | |
948 else | |
949 { | |
950 gftp_disconnect (request); | |
951 return (-2); | |
952 } | |
953 | |
954 request->directory = g_malloc (strlen (dir) + 1); | |
955 strcpy (request->directory, dir); | |
956 } | |
957 | |
958 return (0); | |
959 } | |
960 | |
961 | |
962 static int | |
963 rfc959_rmdir (gftp_request * request, const char *directory) | |
964 { | |
965 char *tempstr, ret; | |
966 | |
967 g_return_val_if_fail (request != NULL, -2); | |
968 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
969 g_return_val_if_fail (directory != NULL, -2); | |
970 g_return_val_if_fail (request->sockfd != NULL, -2); | |
971 | |
972 tempstr = g_strconcat ("RMD ", directory, "\r\n", NULL); | |
973 ret = rfc959_send_command (request, tempstr); | |
974 g_free (tempstr); | |
975 return (ret == '2' ? 0 : -2); | |
976 } | |
977 | |
978 | |
979 static int | |
980 rfc959_rmfile (gftp_request * request, const char *file) | |
981 { | |
982 char *tempstr, ret; | |
983 | |
984 g_return_val_if_fail (request != NULL, -2); | |
985 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
986 g_return_val_if_fail (file != NULL, -2); | |
987 g_return_val_if_fail (request->sockfd != NULL, -2); | |
988 | |
989 tempstr = g_strconcat ("DELE ", file, "\r\n", NULL); | |
990 ret = rfc959_send_command (request, tempstr); | |
991 g_free (tempstr); | |
992 return (ret == '2' ? 0 : -2); | |
993 } | |
994 | |
995 | |
996 static int | |
997 rfc959_mkdir (gftp_request * request, const char *directory) | |
998 { | |
999 char *tempstr, ret; | |
1000 | |
1001 g_return_val_if_fail (request != NULL, -2); | |
1002 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
1003 g_return_val_if_fail (directory != NULL, -2); | |
1004 g_return_val_if_fail (request->sockfd != NULL, -2); | |
1005 | |
1006 tempstr = g_strconcat ("MKD ", directory, "\r\n", NULL); | |
1007 ret = rfc959_send_command (request, tempstr); | |
1008 g_free (tempstr); | |
1009 return (ret == '2' ? 0 : -2); | |
1010 } | |
1011 | |
1012 | |
1013 static int | |
1014 rfc959_rename (gftp_request * request, const char *oldname, | |
1015 const char *newname) | |
1016 { | |
1017 char *tempstr, ret; | |
1018 | |
1019 g_return_val_if_fail (request != NULL, -2); | |
1020 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
1021 g_return_val_if_fail (oldname != NULL, -2); | |
1022 g_return_val_if_fail (newname != NULL, -2); | |
1023 g_return_val_if_fail (request->sockfd != NULL, -2); | |
1024 | |
1025 tempstr = g_strconcat ("RNFR ", oldname, "\r\n", NULL); | |
1026 ret = rfc959_send_command (request, tempstr); | |
1027 g_free (tempstr); | |
1028 if (ret != '3') | |
1029 return (-2); | |
1030 | |
1031 tempstr = g_strconcat ("RNTO ", newname, "\r\n", NULL); | |
1032 ret = rfc959_send_command (request, tempstr); | |
1033 g_free (tempstr); | |
1034 return (ret == '2' ? 0 : -2); | |
1035 } | |
1036 | |
1037 | |
1038 static int | |
1039 rfc959_chmod (gftp_request * request, const char *file, int mode) | |
1040 { | |
1041 char *tempstr, ret; | |
1042 | |
1043 g_return_val_if_fail (request != NULL, -2); | |
1044 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
1045 g_return_val_if_fail (file != NULL, -2); | |
1046 g_return_val_if_fail (request->sockfd != NULL, -2); | |
1047 | |
1048 tempstr = g_malloc (strlen (file) + (mode / 10) + 16); | |
1049 sprintf (tempstr, "SITE CHMOD %d %s\r\n", mode, file); | |
1050 ret = rfc959_send_command (request, tempstr); | |
1051 g_free (tempstr); | |
1052 return (ret == '2' ? 0 : -2); | |
1053 } | |
1054 | |
1055 | |
1056 static int | |
1057 rfc959_site (gftp_request * request, const char *command) | |
1058 { | |
1059 char *tempstr, ret; | |
1060 | |
1061 g_return_val_if_fail (request != NULL, -2); | |
1062 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, -2); | |
1063 g_return_val_if_fail (command != NULL, -2); | |
1064 g_return_val_if_fail (request->sockfd != NULL, -2); | |
1065 | |
1066 tempstr = g_strconcat ("SITE ", command, "\r\n", NULL); | |
1067 ret = rfc959_send_command (request, tempstr); | |
1068 g_free (tempstr); | |
1069 return (request->sockfd != NULL ? ret : -2); | |
1070 } | |
1071 | |
1072 | |
1073 static char * | |
1074 parse_ftp_proxy_string (gftp_request * request) | |
1075 { | |
1076 char *startpos, *endpos, *oldstr, *newstr, *newval, *tempport; | |
1077 | |
1078 g_return_val_if_fail (request != NULL, NULL); | |
1079 g_return_val_if_fail (request->protonum == GFTP_FTP_NUM, NULL); | |
1080 | |
1081 newstr = g_malloc (1); | |
1082 *newstr = '\0'; | |
1083 startpos = endpos = request->proxy_config; | |
1084 while (*endpos != '\0') | |
1085 { | |
1086 tempport = NULL; | |
1087 if (*endpos == '%' && tolower ((int) *(endpos + 1)) == 'p') | |
1088 { | |
1089 switch (tolower ((int) *(endpos + 2))) | |
1090 { | |
1091 case 'u': | |
1092 newval = request->proxy_username; | |
1093 break; | |
1094 case 'p': | |
1095 newval = request->proxy_password; | |
1096 break; | |
1097 case 'h': | |
1098 newval = request->proxy_hostname; | |
1099 break; | |
1100 case 'o': | |
1101 tempport = g_strdup_printf ("%d", request->proxy_port); | |
1102 newval = tempport; | |
1103 break; | |
1104 case 'a': | |
1105 newval = request->proxy_account; | |
1106 break; | |
1107 default: | |
1108 endpos++; | |
1109 continue; | |
1110 } | |
1111 } | |
1112 else if (*endpos == '%' && tolower ((int) *(endpos + 1)) == 'h') | |
1113 { | |
1114 switch (tolower ((int) *(endpos + 2))) | |
1115 { | |
1116 case 'u': | |
1117 newval = request->username; | |
1118 break; | |
1119 case 'p': | |
1120 newval = request->password; | |
1121 break; | |
1122 case 'h': | |
1123 newval = request->hostname; | |
1124 break; | |
1125 case 'o': | |
1126 tempport = g_strdup_printf ("%d", request->port); | |
1127 newval = tempport; | |
1128 break; | |
1129 case 'a': | |
1130 newval = request->account; | |
1131 break; | |
1132 default: | |
1133 endpos++; | |
1134 continue; | |
1135 } | |
1136 } | |
1137 else if (*endpos == '%' && tolower ((int) *(endpos + 1)) == 'n') | |
1138 { | |
1139 *endpos = '\0'; | |
1140 oldstr = newstr; | |
1141 newstr = g_strconcat (oldstr, startpos, "\r\n", NULL); | |
1142 g_free (oldstr); | |
1143 endpos += 2; | |
1144 startpos = endpos; | |
1145 continue; | |
1146 } | |
1147 else | |
1148 { | |
1149 endpos++; | |
1150 continue; | |
1151 } | |
1152 | |
1153 *endpos = '\0'; | |
1154 oldstr = newstr; | |
1155 if (!newval) | |
1156 newstr = g_strconcat (oldstr, startpos, NULL); | |
1157 else | |
1158 newstr = g_strconcat (oldstr, startpos, newval, NULL); | |
1159 if (tempport) | |
1160 { | |
1161 g_free (tempport); | |
1162 tempport = NULL; | |
1163 } | |
1164 g_free (oldstr); | |
1165 endpos += 3; | |
1166 startpos = endpos; | |
1167 } | |
1168 return (newstr); | |
1169 } | |
1170 |