xref: /freebsd/lib/libfetch/ftp.c (revision 5cd33c40d768a40f55b897f3789ce3f509334193)
14ca1ab94SDag-Erling Smørgrav /*-
24ca1ab94SDag-Erling Smørgrav  * Copyright (c) 1998 Dag-Erling Co�dan Sm�rgrav
34ca1ab94SDag-Erling Smørgrav  * All rights reserved.
44ca1ab94SDag-Erling Smørgrav  *
54ca1ab94SDag-Erling Smørgrav  * Redistribution and use in source and binary forms, with or without
64ca1ab94SDag-Erling Smørgrav  * modification, are permitted provided that the following conditions
74ca1ab94SDag-Erling Smørgrav  * are met:
84ca1ab94SDag-Erling Smørgrav  * 1. Redistributions of source code must retain the above copyright
94ca1ab94SDag-Erling Smørgrav  *    notice, this list of conditions and the following disclaimer
104ca1ab94SDag-Erling Smørgrav  *    in this position and unchanged.
114ca1ab94SDag-Erling Smørgrav  * 2. Redistributions in binary form must reproduce the above copyright
124ca1ab94SDag-Erling Smørgrav  *    notice, this list of conditions and the following disclaimer in the
134ca1ab94SDag-Erling Smørgrav  *    documentation and/or other materials provided with the distribution.
144ca1ab94SDag-Erling Smørgrav  * 3. The name of the author may not be used to endorse or promote products
154ca1ab94SDag-Erling Smørgrav  *    derived from this software without specific prior written permission
164ca1ab94SDag-Erling Smørgrav  *
174ca1ab94SDag-Erling Smørgrav  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
184ca1ab94SDag-Erling Smørgrav  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
194ca1ab94SDag-Erling Smørgrav  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
204ca1ab94SDag-Erling Smørgrav  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
214ca1ab94SDag-Erling Smørgrav  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
224ca1ab94SDag-Erling Smørgrav  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
234ca1ab94SDag-Erling Smørgrav  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
244ca1ab94SDag-Erling Smørgrav  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
254ca1ab94SDag-Erling Smørgrav  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
264ca1ab94SDag-Erling Smørgrav  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
274ca1ab94SDag-Erling Smørgrav  *
287f3dea24SPeter Wemm  * $FreeBSD$
294ca1ab94SDag-Erling Smørgrav  */
304ca1ab94SDag-Erling Smørgrav 
314ca1ab94SDag-Erling Smørgrav /*
328e3986eaSDag-Erling Smørgrav  * Portions of this code were taken from or based on ftpio.c:
334ca1ab94SDag-Erling Smørgrav  *
344ca1ab94SDag-Erling Smørgrav  * ----------------------------------------------------------------------------
354ca1ab94SDag-Erling Smørgrav  * "THE BEER-WARE LICENSE" (Revision 42):
364ca1ab94SDag-Erling Smørgrav  * <phk@login.dknet.dk> wrote this file.  As long as you retain this notice you
374ca1ab94SDag-Erling Smørgrav  * can do whatever you want with this stuff. If we meet some day, and you think
384ca1ab94SDag-Erling Smørgrav  * this stuff is worth it, you can buy me a beer in return.   Poul-Henning Kamp
394ca1ab94SDag-Erling Smørgrav  * ----------------------------------------------------------------------------
404ca1ab94SDag-Erling Smørgrav  *
414ca1ab94SDag-Erling Smørgrav  * Major Changelog:
424ca1ab94SDag-Erling Smørgrav  *
434ca1ab94SDag-Erling Smørgrav  * Dag-Erling Co�dan Sm�rgrav
444ca1ab94SDag-Erling Smørgrav  * 9 Jun 1998
454ca1ab94SDag-Erling Smørgrav  *
464ca1ab94SDag-Erling Smørgrav  * Incorporated into libfetch
474ca1ab94SDag-Erling Smørgrav  *
484ca1ab94SDag-Erling Smørgrav  * Jordan K. Hubbard
494ca1ab94SDag-Erling Smørgrav  * 17 Jan 1996
504ca1ab94SDag-Erling Smørgrav  *
514ca1ab94SDag-Erling Smørgrav  * Turned inside out. Now returns xfers as new file ids, not as a special
524ca1ab94SDag-Erling Smørgrav  * `state' of FTP_t
534ca1ab94SDag-Erling Smørgrav  *
544ca1ab94SDag-Erling Smørgrav  * $ftpioId: ftpio.c,v 1.30 1998/04/11 07:28:53 phk Exp $
554ca1ab94SDag-Erling Smørgrav  *
564ca1ab94SDag-Erling Smørgrav  */
574ca1ab94SDag-Erling Smørgrav 
580fba3a00SDag-Erling Smørgrav #include <sys/param.h>
594ca1ab94SDag-Erling Smørgrav #include <sys/socket.h>
604ca1ab94SDag-Erling Smørgrav #include <netinet/in.h>
614ca1ab94SDag-Erling Smørgrav 
624ca1ab94SDag-Erling Smørgrav #include <ctype.h>
63fc6e9e65SDag-Erling Smørgrav #include <errno.h>
6432425dafSDag-Erling Smørgrav #include <netdb.h>
65346298f0SDag-Erling Smørgrav #include <stdarg.h>
664ca1ab94SDag-Erling Smørgrav #include <stdio.h>
678e3986eaSDag-Erling Smørgrav #include <stdlib.h>
684ca1ab94SDag-Erling Smørgrav #include <string.h>
695aea254fSDag-Erling Smørgrav #include <time.h>
708e3986eaSDag-Erling Smørgrav #include <unistd.h>
714ca1ab94SDag-Erling Smørgrav 
724ca1ab94SDag-Erling Smørgrav #include "fetch.h"
73842a95ccSDag-Erling Smørgrav #include "common.h"
740fba3a00SDag-Erling Smørgrav #include "ftperr.h"
754ca1ab94SDag-Erling Smørgrav 
764ca1ab94SDag-Erling Smørgrav #define FTP_ANONYMOUS_USER	"ftp"
774ca1ab94SDag-Erling Smørgrav #define FTP_ANONYMOUS_PASSWORD	"ftp"
78346298f0SDag-Erling Smørgrav #define FTP_DEFAULT_PORT 21
79346298f0SDag-Erling Smørgrav 
80346298f0SDag-Erling Smørgrav #define FTP_OPEN_DATA_CONNECTION	150
81346298f0SDag-Erling Smørgrav #define FTP_OK				200
825aea254fSDag-Erling Smørgrav #define FTP_FILE_STATUS			213
833b7a6740SDag-Erling Smørgrav #define FTP_SERVICE_READY		220
84346298f0SDag-Erling Smørgrav #define FTP_PASSIVE_MODE		227
8528c645cfSHajimu UMEMOTO #define FTP_LPASSIVE_MODE		228
8628c645cfSHajimu UMEMOTO #define FTP_EPASSIVE_MODE		229
87346298f0SDag-Erling Smørgrav #define FTP_LOGGED_IN			230
88346298f0SDag-Erling Smørgrav #define FTP_FILE_ACTION_OK		250
89346298f0SDag-Erling Smørgrav #define FTP_NEED_PASSWORD		331
90346298f0SDag-Erling Smørgrav #define FTP_NEED_ACCOUNT		332
9132425dafSDag-Erling Smørgrav #define FTP_FILE_OK			350
92fc6e9e65SDag-Erling Smørgrav #define FTP_SYNTAX_ERROR		500
935cd33c40SDag-Erling Smørgrav #define FTP_PROTOCOL_ERROR		999
944ca1ab94SDag-Erling Smørgrav 
95d8acd8dcSDag-Erling Smørgrav static struct url cached_host;
96fc6e9e65SDag-Erling Smørgrav static int cached_socket;
974ca1ab94SDag-Erling Smørgrav 
98fc6e9e65SDag-Erling Smørgrav static char *last_reply;
99fc6e9e65SDag-Erling Smørgrav static size_t lr_size, lr_length;
100fc6e9e65SDag-Erling Smørgrav static int last_code;
101fc6e9e65SDag-Erling Smørgrav 
102fc6e9e65SDag-Erling Smørgrav #define isftpreply(foo) (isdigit(foo[0]) && isdigit(foo[1]) \
1036efb30c8SDag-Erling Smørgrav 			 && isdigit(foo[2]) \
1046efb30c8SDag-Erling Smørgrav                          && (foo[3] == ' ' || foo[3] == '\0'))
105fc6e9e65SDag-Erling Smørgrav #define isftpinfo(foo) (isdigit(foo[0]) && isdigit(foo[1]) \
106fc6e9e65SDag-Erling Smørgrav 			&& isdigit(foo[2]) && foo[3] == '-')
1074ca1ab94SDag-Erling Smørgrav 
10828c645cfSHajimu UMEMOTO /* translate IPv4 mapped IPv6 address to IPv4 address */
10928c645cfSHajimu UMEMOTO static void
11028c645cfSHajimu UMEMOTO unmappedaddr(struct sockaddr_in6 *sin6)
11128c645cfSHajimu UMEMOTO {
11228c645cfSHajimu UMEMOTO     struct sockaddr_in *sin4;
11328c645cfSHajimu UMEMOTO     u_int32_t addr;
11428c645cfSHajimu UMEMOTO     int port;
11528c645cfSHajimu UMEMOTO 
11628c645cfSHajimu UMEMOTO     if (sin6->sin6_family != AF_INET6 ||
11728c645cfSHajimu UMEMOTO 	!IN6_IS_ADDR_V4MAPPED(&sin6->sin6_addr))
11828c645cfSHajimu UMEMOTO 	return;
11928c645cfSHajimu UMEMOTO     sin4 = (struct sockaddr_in *)sin6;
12028c645cfSHajimu UMEMOTO     addr = *(u_int32_t *)&sin6->sin6_addr.s6_addr[12];
12128c645cfSHajimu UMEMOTO     port = sin6->sin6_port;
12228c645cfSHajimu UMEMOTO     memset(sin4, 0, sizeof(struct sockaddr_in));
12328c645cfSHajimu UMEMOTO     sin4->sin_addr.s_addr = addr;
12428c645cfSHajimu UMEMOTO     sin4->sin_port = port;
12528c645cfSHajimu UMEMOTO     sin4->sin_family = AF_INET;
12628c645cfSHajimu UMEMOTO     sin4->sin_len = sizeof(struct sockaddr_in);
12728c645cfSHajimu UMEMOTO }
12828c645cfSHajimu UMEMOTO 
1294ca1ab94SDag-Erling Smørgrav /*
130fc6e9e65SDag-Erling Smørgrav  * Get server response
1318e3986eaSDag-Erling Smørgrav  */
1328e3986eaSDag-Erling Smørgrav static int
133fc6e9e65SDag-Erling Smørgrav _ftp_chkerr(int cd)
1348e3986eaSDag-Erling Smørgrav {
135fc6e9e65SDag-Erling Smørgrav     if (_fetch_getln(cd, &last_reply, &lr_size, &lr_length) == -1) {
136842a95ccSDag-Erling Smørgrav 	_fetch_syserr();
1378e3986eaSDag-Erling Smørgrav 	return -1;
1388e3986eaSDag-Erling Smørgrav     }
139eac7a1e0SDag-Erling Smørgrav     if (isftpinfo(last_reply)) {
140eac7a1e0SDag-Erling Smørgrav 	while (!isftpreply(last_reply)) {
141eac7a1e0SDag-Erling Smørgrav 	    if (_fetch_getln(cd, &last_reply, &lr_size, &lr_length) == -1) {
142eac7a1e0SDag-Erling Smørgrav 		_fetch_syserr();
143eac7a1e0SDag-Erling Smørgrav 		return -1;
144eac7a1e0SDag-Erling Smørgrav 	    }
145eac7a1e0SDag-Erling Smørgrav 	}
146eac7a1e0SDag-Erling Smørgrav     }
147346298f0SDag-Erling Smørgrav 
148fc6e9e65SDag-Erling Smørgrav     while (lr_length && isspace(last_reply[lr_length-1]))
149fc6e9e65SDag-Erling Smørgrav 	lr_length--;
150fc6e9e65SDag-Erling Smørgrav     last_reply[lr_length] = 0;
151fc6e9e65SDag-Erling Smørgrav 
152fc6e9e65SDag-Erling Smørgrav     if (!isftpreply(last_reply)) {
1535cd33c40SDag-Erling Smørgrav 	_ftp_seterr(FTP_PROTOCOL_ERROR);
1548e3986eaSDag-Erling Smørgrav 	return -1;
1558e3986eaSDag-Erling Smørgrav     }
1568e3986eaSDag-Erling Smørgrav 
157fc6e9e65SDag-Erling Smørgrav     last_code = (last_reply[0] - '0') * 100
158fc6e9e65SDag-Erling Smørgrav 	+ (last_reply[1] - '0') * 10
159fc6e9e65SDag-Erling Smørgrav 	+ (last_reply[2] - '0');
160fc6e9e65SDag-Erling Smørgrav 
161fc6e9e65SDag-Erling Smørgrav     return last_code;
1628e3986eaSDag-Erling Smørgrav }
1638e3986eaSDag-Erling Smørgrav 
1648e3986eaSDag-Erling Smørgrav /*
165346298f0SDag-Erling Smørgrav  * Send a command and check reply
1664ca1ab94SDag-Erling Smørgrav  */
1674ca1ab94SDag-Erling Smørgrav static int
168fc6e9e65SDag-Erling Smørgrav _ftp_cmd(int cd, char *fmt, ...)
1694ca1ab94SDag-Erling Smørgrav {
170346298f0SDag-Erling Smørgrav     va_list ap;
171e137bcebSDag-Erling Smørgrav     size_t len;
172fc6e9e65SDag-Erling Smørgrav     char *msg;
173fc6e9e65SDag-Erling Smørgrav     int r;
1748e3986eaSDag-Erling Smørgrav 
175346298f0SDag-Erling Smørgrav     va_start(ap, fmt);
176e137bcebSDag-Erling Smørgrav     len = vasprintf(&msg, fmt, ap);
177346298f0SDag-Erling Smørgrav     va_end(ap);
178346298f0SDag-Erling Smørgrav 
179fc6e9e65SDag-Erling Smørgrav     if (msg == NULL) {
180fc6e9e65SDag-Erling Smørgrav 	errno = ENOMEM;
181fc6e9e65SDag-Erling Smørgrav 	_fetch_syserr();
182fc6e9e65SDag-Erling Smørgrav 	return -1;
183fc6e9e65SDag-Erling Smørgrav     }
184e137bcebSDag-Erling Smørgrav 
185e137bcebSDag-Erling Smørgrav     r = _fetch_putln(cd, msg, len);
186fc6e9e65SDag-Erling Smørgrav     free(msg);
187e137bcebSDag-Erling Smørgrav 
188fc6e9e65SDag-Erling Smørgrav     if (r == -1) {
189fc6e9e65SDag-Erling Smørgrav 	_fetch_syserr();
190fc6e9e65SDag-Erling Smørgrav 	return -1;
191fc6e9e65SDag-Erling Smørgrav     }
192fc6e9e65SDag-Erling Smørgrav 
193fc6e9e65SDag-Erling Smørgrav     return _ftp_chkerr(cd);
1944ca1ab94SDag-Erling Smørgrav }
1954ca1ab94SDag-Erling Smørgrav 
1964ca1ab94SDag-Erling Smørgrav /*
197f62e5228SDag-Erling Smørgrav  * Transfer file
1984ca1ab94SDag-Erling Smørgrav  */
1994ca1ab94SDag-Erling Smørgrav static FILE *
20032425dafSDag-Erling Smørgrav _ftp_transfer(int cd, char *oper, char *file,
20132425dafSDag-Erling Smørgrav 	      char *mode, off_t offset, char *flags)
2024ca1ab94SDag-Erling Smørgrav {
20328c645cfSHajimu UMEMOTO     struct sockaddr_storage sin;
20428c645cfSHajimu UMEMOTO     struct sockaddr_in6 *sin6;
20528c645cfSHajimu UMEMOTO     struct sockaddr_in *sin4;
206f5f109a0SDag-Erling Smørgrav     int pasv, high, verbose;
207f5f109a0SDag-Erling Smørgrav     int e, sd = -1;
208f5f109a0SDag-Erling Smørgrav     socklen_t l;
209346298f0SDag-Erling Smørgrav     char *s;
210346298f0SDag-Erling Smørgrav     FILE *df;
2118e3986eaSDag-Erling Smørgrav 
212f5f109a0SDag-Erling Smørgrav     /* check flags */
213f5f109a0SDag-Erling Smørgrav     pasv = (flags && strchr(flags, 'p'));
214f5f109a0SDag-Erling Smørgrav     high = (flags && strchr(flags, 'h'));
215f5f109a0SDag-Erling Smørgrav     verbose = (flags && strchr(flags, 'v'));
216f5f109a0SDag-Erling Smørgrav 
217d02e84a6SDag-Erling Smørgrav     /* passive mode */
218d02e84a6SDag-Erling Smørgrav     if (!pasv && (s = getenv("FTP_PASSIVE_MODE")) != NULL)
219d02e84a6SDag-Erling Smørgrav 	pasv = (strncasecmp(s, "no", 2) != 0);
220d02e84a6SDag-Erling Smørgrav 
2214ca1ab94SDag-Erling Smørgrav     /* change directory */
222346298f0SDag-Erling Smørgrav     if (((s = strrchr(file, '/')) != NULL) && (s != file)) {
223346298f0SDag-Erling Smørgrav 	*s = 0;
224f5f109a0SDag-Erling Smørgrav 	if (verbose)
225f5f109a0SDag-Erling Smørgrav 	    _fetch_info("changing directory to %s", file);
226fc6e9e65SDag-Erling Smørgrav 	if ((e = _ftp_cmd(cd, "CWD %s", file)) != FTP_FILE_ACTION_OK) {
227346298f0SDag-Erling Smørgrav 	    *s = '/';
228fc6e9e65SDag-Erling Smørgrav 	    if (e != -1)
2295aea254fSDag-Erling Smørgrav 		_ftp_seterr(e);
2304ca1ab94SDag-Erling Smørgrav 	    return NULL;
2314ca1ab94SDag-Erling Smørgrav 	}
232346298f0SDag-Erling Smørgrav 	*s++ = '/';
2334ca1ab94SDag-Erling Smørgrav     } else {
234f5f109a0SDag-Erling Smørgrav 	if (verbose)
235f5f109a0SDag-Erling Smørgrav 	    _fetch_info("changing directory to /");
236fc6e9e65SDag-Erling Smørgrav 	if ((e = _ftp_cmd(cd, "CWD /")) != FTP_FILE_ACTION_OK) {
237fc6e9e65SDag-Erling Smørgrav 	    if (e != -1)
2385aea254fSDag-Erling Smørgrav 		_ftp_seterr(e);
2394ca1ab94SDag-Erling Smørgrav 	    return NULL;
2404ca1ab94SDag-Erling Smørgrav 	}
2415aea254fSDag-Erling Smørgrav     }
2424ca1ab94SDag-Erling Smørgrav 
243346298f0SDag-Erling Smørgrav     /* s now points to file name */
244346298f0SDag-Erling Smørgrav 
24528c645cfSHajimu UMEMOTO     /* find our own address, bind, and listen */
24628c645cfSHajimu UMEMOTO     l = sizeof sin;
24728c645cfSHajimu UMEMOTO     if (getsockname(cd, (struct sockaddr *)&sin, &l) == -1)
24828c645cfSHajimu UMEMOTO 	goto sysouch;
24928c645cfSHajimu UMEMOTO     if (sin.ss_family == AF_INET6)
25028c645cfSHajimu UMEMOTO 	unmappedaddr((struct sockaddr_in6 *)&sin);
25128c645cfSHajimu UMEMOTO 
252346298f0SDag-Erling Smørgrav     /* open data socket */
25328c645cfSHajimu UMEMOTO     if ((sd = socket(sin.ss_family, SOCK_STREAM, IPPROTO_TCP)) == -1) {
254842a95ccSDag-Erling Smørgrav 	_fetch_syserr();
255346298f0SDag-Erling Smørgrav 	return NULL;
256346298f0SDag-Erling Smørgrav     }
257346298f0SDag-Erling Smørgrav 
258346298f0SDag-Erling Smørgrav     if (pasv) {
25928c645cfSHajimu UMEMOTO 	u_char addr[64];
260346298f0SDag-Erling Smørgrav 	char *ln, *p;
261346298f0SDag-Erling Smørgrav 	int i;
26228c645cfSHajimu UMEMOTO 	int port;
263346298f0SDag-Erling Smørgrav 
264346298f0SDag-Erling Smørgrav 	/* send PASV command */
265f5f109a0SDag-Erling Smørgrav 	if (verbose)
266f5f109a0SDag-Erling Smørgrav 	    _fetch_info("setting passive mode");
26728c645cfSHajimu UMEMOTO 	switch (sin.ss_family) {
26828c645cfSHajimu UMEMOTO 	case AF_INET:
269fc6e9e65SDag-Erling Smørgrav 	    if ((e = _ftp_cmd(cd, "PASV")) != FTP_PASSIVE_MODE)
270346298f0SDag-Erling Smørgrav 		goto ouch;
27128c645cfSHajimu UMEMOTO 	    break;
27228c645cfSHajimu UMEMOTO 	case AF_INET6:
27328c645cfSHajimu UMEMOTO 	    if ((e = _ftp_cmd(cd, "EPSV")) != FTP_EPASSIVE_MODE) {
27428c645cfSHajimu UMEMOTO 		if (e == -1)
27528c645cfSHajimu UMEMOTO 		    goto ouch;
27628c645cfSHajimu UMEMOTO 		if ((e = _ftp_cmd(cd, "LPSV")) != FTP_LPASSIVE_MODE)
27728c645cfSHajimu UMEMOTO 		    goto ouch;
27828c645cfSHajimu UMEMOTO 	    }
27928c645cfSHajimu UMEMOTO 	    break;
28028c645cfSHajimu UMEMOTO 	default:
2815cd33c40SDag-Erling Smørgrav 	    e = FTP_PROTOCOL_ERROR; /* XXX: error code should be prepared */
28228c645cfSHajimu UMEMOTO 	    goto ouch;
28328c645cfSHajimu UMEMOTO 	}
284346298f0SDag-Erling Smørgrav 
285f5f109a0SDag-Erling Smørgrav 	/*
286f5f109a0SDag-Erling Smørgrav 	 * Find address and port number. The reply to the PASV command
287f5f109a0SDag-Erling Smørgrav          * is IMHO the one and only weak point in the FTP protocol.
288f5f109a0SDag-Erling Smørgrav 	 */
289fc6e9e65SDag-Erling Smørgrav 	ln = last_reply;
290fa5dce6cSHajimu UMEMOTO       	switch (e) {
291fa5dce6cSHajimu UMEMOTO 	case FTP_PASSIVE_MODE:
292fa5dce6cSHajimu UMEMOTO 	case FTP_LPASSIVE_MODE:
29351e3d46eSDag-Erling Smørgrav 	    for (p = ln + 3; *p && !isdigit(*p); p++)
294346298f0SDag-Erling Smørgrav 		/* nothing */ ;
29528c645cfSHajimu UMEMOTO 	    if (!*p) {
2965cd33c40SDag-Erling Smørgrav 		e = FTP_PROTOCOL_ERROR;
2976efb30c8SDag-Erling Smørgrav 		goto ouch;
298346298f0SDag-Erling Smørgrav 	    }
29928c645cfSHajimu UMEMOTO 	    l = (e == FTP_PASSIVE_MODE ? 6 : 21);
30028c645cfSHajimu UMEMOTO 	    for (i = 0; *p && i < l; i++, p++)
30128c645cfSHajimu UMEMOTO 		addr[i] = strtol(p, &p, 10);
30228c645cfSHajimu UMEMOTO 	    if (i < l) {
3035cd33c40SDag-Erling Smørgrav 		e = FTP_PROTOCOL_ERROR;
30428c645cfSHajimu UMEMOTO 		goto ouch;
30528c645cfSHajimu UMEMOTO 	    }
30628c645cfSHajimu UMEMOTO 	    break;
30728c645cfSHajimu UMEMOTO 	case FTP_EPASSIVE_MODE:
308fa5dce6cSHajimu UMEMOTO 	    for (p = ln + 3; *p && *p != '('; p++)
309fa5dce6cSHajimu UMEMOTO 		/* nothing */ ;
310fa5dce6cSHajimu UMEMOTO 	    if (!*p) {
3115cd33c40SDag-Erling Smørgrav 		e = FTP_PROTOCOL_ERROR;
312fa5dce6cSHajimu UMEMOTO 		goto ouch;
313fa5dce6cSHajimu UMEMOTO 	    }
314fa5dce6cSHajimu UMEMOTO 	    ++p;
31528c645cfSHajimu UMEMOTO 	    if (sscanf(p, "%c%c%c%d%c", &addr[0], &addr[1], &addr[2],
31628c645cfSHajimu UMEMOTO 		       &port, &addr[3]) != 5 ||
31728c645cfSHajimu UMEMOTO 		addr[0] != addr[1] ||
31828c645cfSHajimu UMEMOTO 		addr[0] != addr[2] || addr[0] != addr[3]) {
3195cd33c40SDag-Erling Smørgrav 		e = FTP_PROTOCOL_ERROR;
32028c645cfSHajimu UMEMOTO 		goto ouch;
32128c645cfSHajimu UMEMOTO 	    }
32228c645cfSHajimu UMEMOTO 	    break;
32328c645cfSHajimu UMEMOTO 	}
324346298f0SDag-Erling Smørgrav 
32532425dafSDag-Erling Smørgrav 	/* seek to required offset */
32632425dafSDag-Erling Smørgrav 	if (offset)
32732425dafSDag-Erling Smørgrav 	    if (_ftp_cmd(cd, "REST %lu", (u_long)offset) != FTP_FILE_OK)
32832425dafSDag-Erling Smørgrav 		goto sysouch;
32932425dafSDag-Erling Smørgrav 
330346298f0SDag-Erling Smørgrav 	/* construct sockaddr for data socket */
33132425dafSDag-Erling Smørgrav 	l = sizeof sin;
332fc6e9e65SDag-Erling Smørgrav 	if (getpeername(cd, (struct sockaddr *)&sin, &l) == -1)
333346298f0SDag-Erling Smørgrav 	    goto sysouch;
33428c645cfSHajimu UMEMOTO 	if (sin.ss_family == AF_INET6)
33528c645cfSHajimu UMEMOTO 	    unmappedaddr((struct sockaddr_in6 *)&sin);
33628c645cfSHajimu UMEMOTO 	switch (sin.ss_family) {
33728c645cfSHajimu UMEMOTO 	case AF_INET6:
33828c645cfSHajimu UMEMOTO 	    sin6 = (struct sockaddr_in6 *)&sin;
33928c645cfSHajimu UMEMOTO 	    if (e == FTP_EPASSIVE_MODE)
34028c645cfSHajimu UMEMOTO 		sin6->sin6_port = htons(port);
34128c645cfSHajimu UMEMOTO 	    else {
34228c645cfSHajimu UMEMOTO 		bcopy(addr + 2, (char *)&sin6->sin6_addr, 16);
34328c645cfSHajimu UMEMOTO 		bcopy(addr + 19, (char *)&sin6->sin6_port, 2);
34428c645cfSHajimu UMEMOTO 	    }
34528c645cfSHajimu UMEMOTO 	    break;
34628c645cfSHajimu UMEMOTO 	case AF_INET:
34728c645cfSHajimu UMEMOTO 	    sin4 = (struct sockaddr_in *)&sin;
34828c645cfSHajimu UMEMOTO 	    if (e == FTP_EPASSIVE_MODE)
34928c645cfSHajimu UMEMOTO 		sin4->sin_port = htons(port);
35028c645cfSHajimu UMEMOTO 	    else {
35128c645cfSHajimu UMEMOTO 		bcopy(addr, (char *)&sin4->sin_addr, 4);
35228c645cfSHajimu UMEMOTO 		bcopy(addr + 4, (char *)&sin4->sin_port, 2);
35328c645cfSHajimu UMEMOTO 	    }
35428c645cfSHajimu UMEMOTO 	    break;
35528c645cfSHajimu UMEMOTO 	default:
3565cd33c40SDag-Erling Smørgrav 	    e = FTP_PROTOCOL_ERROR; /* XXX: error code should be prepared */
35728c645cfSHajimu UMEMOTO 	    break;
35828c645cfSHajimu UMEMOTO 	}
359346298f0SDag-Erling Smørgrav 
360346298f0SDag-Erling Smørgrav 	/* connect to data port */
361f5f109a0SDag-Erling Smørgrav 	if (verbose)
362f5f109a0SDag-Erling Smørgrav 	    _fetch_info("opening data connection");
36328c645cfSHajimu UMEMOTO 	if (connect(sd, (struct sockaddr *)&sin, sin.ss_len) == -1)
364346298f0SDag-Erling Smørgrav 	    goto sysouch;
365346298f0SDag-Erling Smørgrav 
366346298f0SDag-Erling Smørgrav 	/* make the server initiate the transfer */
367f5f109a0SDag-Erling Smørgrav 	if (verbose)
368def5f54cSDag-Erling Smørgrav 	    _fetch_info("initiating transfer");
369fc6e9e65SDag-Erling Smørgrav 	e = _ftp_cmd(cd, "%s %s", oper, s);
3705aea254fSDag-Erling Smørgrav 	if (e != FTP_OPEN_DATA_CONNECTION)
371346298f0SDag-Erling Smørgrav 	    goto ouch;
372346298f0SDag-Erling Smørgrav 
373346298f0SDag-Erling Smørgrav     } else {
374346298f0SDag-Erling Smørgrav 	u_int32_t a;
375346298f0SDag-Erling Smørgrav 	u_short p;
376f5f109a0SDag-Erling Smørgrav 	int arg, d;
37728c645cfSHajimu UMEMOTO 	char *ap;
37828c645cfSHajimu UMEMOTO 	char hname[INET6_ADDRSTRLEN];
379346298f0SDag-Erling Smørgrav 
38028c645cfSHajimu UMEMOTO 	switch (sin.ss_family) {
38128c645cfSHajimu UMEMOTO 	case AF_INET6:
38228c645cfSHajimu UMEMOTO 	    ((struct sockaddr_in6 *)&sin)->sin6_port = 0;
38328c645cfSHajimu UMEMOTO #ifdef IPV6_PORTRANGE
38428c645cfSHajimu UMEMOTO 	    arg = high ? IPV6_PORTRANGE_HIGH : IPV6_PORTRANGE_DEFAULT;
38528c645cfSHajimu UMEMOTO 	    if (setsockopt(sd, IPPROTO_IPV6, IPV6_PORTRANGE,
38628c645cfSHajimu UMEMOTO 			   (char *)&arg, sizeof(arg)) == -1)
387346298f0SDag-Erling Smørgrav 		goto sysouch;
38828c645cfSHajimu UMEMOTO #endif
38928c645cfSHajimu UMEMOTO 	    break;
39028c645cfSHajimu UMEMOTO 	case AF_INET:
39128c645cfSHajimu UMEMOTO 	    ((struct sockaddr_in *)&sin)->sin_port = 0;
392f5f109a0SDag-Erling Smørgrav 	    arg = high ? IP_PORTRANGE_HIGH : IP_PORTRANGE_DEFAULT;
393f5f109a0SDag-Erling Smørgrav 	    if (setsockopt(sd, IPPROTO_IP, IP_PORTRANGE,
39432425dafSDag-Erling Smørgrav 			   (char *)&arg, sizeof arg) == -1)
395f5f109a0SDag-Erling Smørgrav 		goto sysouch;
39628c645cfSHajimu UMEMOTO 	    break;
39728c645cfSHajimu UMEMOTO 	}
398f5f109a0SDag-Erling Smørgrav 	if (verbose)
399f5f109a0SDag-Erling Smørgrav 	    _fetch_info("binding data socket");
40028c645cfSHajimu UMEMOTO 	if (bind(sd, (struct sockaddr *)&sin, sin.ss_len) == -1)
401346298f0SDag-Erling Smørgrav 	    goto sysouch;
402ecc91352SDag-Erling Smørgrav 	if (listen(sd, 1) == -1)
403346298f0SDag-Erling Smørgrav 	    goto sysouch;
404346298f0SDag-Erling Smørgrav 
405346298f0SDag-Erling Smørgrav 	/* find what port we're on and tell the server */
406ecc91352SDag-Erling Smørgrav 	if (getsockname(sd, (struct sockaddr *)&sin, &l) == -1)
407346298f0SDag-Erling Smørgrav 	    goto sysouch;
40828c645cfSHajimu UMEMOTO 	switch (sin.ss_family) {
40928c645cfSHajimu UMEMOTO 	case AF_INET:
41028c645cfSHajimu UMEMOTO 	    sin4 = (struct sockaddr_in *)&sin;
41128c645cfSHajimu UMEMOTO 	    a = ntohl(sin4->sin_addr.s_addr);
41228c645cfSHajimu UMEMOTO 	    p = ntohs(sin4->sin_port);
413fc6e9e65SDag-Erling Smørgrav 	    e = _ftp_cmd(cd, "PORT %d,%d,%d,%d,%d,%d",
4145aea254fSDag-Erling Smørgrav 			 (a >> 24) & 0xff, (a >> 16) & 0xff,
4155aea254fSDag-Erling Smørgrav 			 (a >> 8) & 0xff, a & 0xff,
4165aea254fSDag-Erling Smørgrav 			 (p >> 8) & 0xff, p & 0xff);
41728c645cfSHajimu UMEMOTO 	    break;
41828c645cfSHajimu UMEMOTO 	case AF_INET6:
41928c645cfSHajimu UMEMOTO #define UC(b)	(((int)b)&0xff)
42028c645cfSHajimu UMEMOTO 	    e = -1;
42128c645cfSHajimu UMEMOTO 	    sin6 = (struct sockaddr_in6 *)&sin;
42228c645cfSHajimu UMEMOTO 	    if (getnameinfo((struct sockaddr *)&sin, sin.ss_len,
42328c645cfSHajimu UMEMOTO 			    hname, sizeof(hname),
42428c645cfSHajimu UMEMOTO 			    NULL, 0, NI_NUMERICHOST) == 0) {
42528c645cfSHajimu UMEMOTO 		e = _ftp_cmd(cd, "EPRT |%d|%s|%d|", 2, hname,
42628c645cfSHajimu UMEMOTO 			     htons(sin6->sin6_port));
42728c645cfSHajimu UMEMOTO 		if (e == -1)
42828c645cfSHajimu UMEMOTO 		    goto ouch;
42928c645cfSHajimu UMEMOTO 	    }
43028c645cfSHajimu UMEMOTO 	    if (e != FTP_OK) {
43128c645cfSHajimu UMEMOTO 		ap = (char *)&sin6->sin6_addr;
43228c645cfSHajimu UMEMOTO 		e = _ftp_cmd(cd,
43328c645cfSHajimu UMEMOTO      "LPRT %d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d",
43428c645cfSHajimu UMEMOTO 			     6, 16,
43528c645cfSHajimu UMEMOTO 			     UC(ap[0]), UC(ap[1]), UC(ap[2]), UC(ap[3]),
43628c645cfSHajimu UMEMOTO 			     UC(ap[4]), UC(ap[5]), UC(ap[6]), UC(ap[7]),
43728c645cfSHajimu UMEMOTO 			     UC(ap[8]), UC(ap[9]), UC(ap[10]), UC(ap[11]),
43828c645cfSHajimu UMEMOTO 			     UC(ap[12]), UC(ap[13]), UC(ap[14]), UC(ap[15]),
43928c645cfSHajimu UMEMOTO 			     2,
44028c645cfSHajimu UMEMOTO 			     (ntohs(sin6->sin6_port) >> 8) & 0xff,
44128c645cfSHajimu UMEMOTO 			     ntohs(sin6->sin6_port)        & 0xff);
44228c645cfSHajimu UMEMOTO 	    }
44328c645cfSHajimu UMEMOTO 	    break;
44428c645cfSHajimu UMEMOTO 	default:
4455cd33c40SDag-Erling Smørgrav 	    e = FTP_PROTOCOL_ERROR; /* XXX: error code should be prepared */
44628c645cfSHajimu UMEMOTO 	    goto ouch;
44728c645cfSHajimu UMEMOTO 	}
4485aea254fSDag-Erling Smørgrav 	if (e != FTP_OK)
449346298f0SDag-Erling Smørgrav 	    goto ouch;
450346298f0SDag-Erling Smørgrav 
451893980adSDag-Erling Smørgrav 	/* seek to required offset */
452893980adSDag-Erling Smørgrav 	if (offset)
453893980adSDag-Erling Smørgrav 	    if (_ftp_cmd(cd, "REST %lu", (u_long)offset) != FTP_FILE_OK)
454893980adSDag-Erling Smørgrav 		goto sysouch;
455893980adSDag-Erling Smørgrav 
456346298f0SDag-Erling Smørgrav 	/* make the server initiate the transfer */
457f5f109a0SDag-Erling Smørgrav 	if (verbose)
458f5f109a0SDag-Erling Smørgrav 	    _fetch_info("initiating transfer");
459fc6e9e65SDag-Erling Smørgrav 	e = _ftp_cmd(cd, "%s %s", oper, s);
4605aea254fSDag-Erling Smørgrav 	if (e != FTP_OPEN_DATA_CONNECTION)
461346298f0SDag-Erling Smørgrav 	    goto ouch;
462346298f0SDag-Erling Smørgrav 
463346298f0SDag-Erling Smørgrav 	/* accept the incoming connection and go to town */
464ecc91352SDag-Erling Smørgrav 	if ((d = accept(sd, NULL, NULL)) == -1)
465346298f0SDag-Erling Smørgrav 	    goto sysouch;
466346298f0SDag-Erling Smørgrav 	close(sd);
467346298f0SDag-Erling Smørgrav 	sd = d;
468346298f0SDag-Erling Smørgrav     }
469346298f0SDag-Erling Smørgrav 
470f62e5228SDag-Erling Smørgrav     if ((df = fdopen(sd, mode)) == NULL)
471346298f0SDag-Erling Smørgrav 	goto sysouch;
472346298f0SDag-Erling Smørgrav     return df;
473346298f0SDag-Erling Smørgrav 
474346298f0SDag-Erling Smørgrav sysouch:
475842a95ccSDag-Erling Smørgrav     _fetch_syserr();
47628c645cfSHajimu UMEMOTO     if (sd >= 0)
4775aea254fSDag-Erling Smørgrav 	close(sd);
4785aea254fSDag-Erling Smørgrav     return NULL;
4795aea254fSDag-Erling Smørgrav 
480346298f0SDag-Erling Smørgrav ouch:
481fc6e9e65SDag-Erling Smørgrav     if (e != -1)
4825aea254fSDag-Erling Smørgrav 	_ftp_seterr(e);
48328c645cfSHajimu UMEMOTO     if (sd >= 0)
484346298f0SDag-Erling Smørgrav 	close(sd);
4854ca1ab94SDag-Erling Smørgrav     return NULL;
4864ca1ab94SDag-Erling Smørgrav }
4874ca1ab94SDag-Erling Smørgrav 
4888e3986eaSDag-Erling Smørgrav /*
4898e3986eaSDag-Erling Smørgrav  * Log on to FTP server
4904ca1ab94SDag-Erling Smørgrav  */
491fc6e9e65SDag-Erling Smørgrav static int
492f5f109a0SDag-Erling Smørgrav _ftp_connect(char *host, int port, char *user, char *pwd, char *flags)
4938e3986eaSDag-Erling Smørgrav {
49432425dafSDag-Erling Smørgrav     int cd, e, pp = 0, direct, verbose;
49528c645cfSHajimu UMEMOTO #ifdef INET6
49628c645cfSHajimu UMEMOTO     int af = AF_UNSPEC;
49728c645cfSHajimu UMEMOTO #else
49828c645cfSHajimu UMEMOTO     int af = AF_INET;
49928c645cfSHajimu UMEMOTO #endif
500f62e5228SDag-Erling Smørgrav     char *p, *q;
5014ab587f4SHajimu UMEMOTO     const char *logname;
5024ab587f4SHajimu UMEMOTO     char localhost[MAXHOSTNAMELEN];
5034ab587f4SHajimu UMEMOTO     char pbuf[MAXHOSTNAMELEN + MAXLOGNAME + 1];
5048e3986eaSDag-Erling Smørgrav 
505f5f109a0SDag-Erling Smørgrav     direct = (flags && strchr(flags, 'd'));
506f5f109a0SDag-Erling Smørgrav     verbose = (flags && strchr(flags, 'v'));
50728c645cfSHajimu UMEMOTO     if ((flags && strchr(flags, '4')))
50828c645cfSHajimu UMEMOTO 	af = AF_INET;
50928c645cfSHajimu UMEMOTO     else if ((flags && strchr(flags, '6')))
51028c645cfSHajimu UMEMOTO 	af = AF_INET6;
511f5f109a0SDag-Erling Smørgrav 
512f62e5228SDag-Erling Smørgrav     /* check for proxy */
513f5f109a0SDag-Erling Smørgrav     if (!direct && (p = getenv("FTP_PROXY")) != NULL) {
51428c645cfSHajimu UMEMOTO 	char c = 0;
51528c645cfSHajimu UMEMOTO 
51628c645cfSHajimu UMEMOTO #ifdef INET6
51728c645cfSHajimu UMEMOTO 	if (*p != '[' || (q = strchr(p + 1, ']')) == NULL ||
51828c645cfSHajimu UMEMOTO 	    (*++q != '\0' && *q != ':'))
51928c645cfSHajimu UMEMOTO #endif
52028c645cfSHajimu UMEMOTO 	    q = strchr(p, ':');
52128c645cfSHajimu UMEMOTO 	if (q != NULL && *q == ':') {
52232425dafSDag-Erling Smørgrav 	    if (strspn(q+1, "0123456789") != strlen(q+1) || strlen(q+1) > 5) {
52332425dafSDag-Erling Smørgrav 		/* XXX we should emit some kind of warning */
52432425dafSDag-Erling Smørgrav 	    }
525f62e5228SDag-Erling Smørgrav 	    pp = atoi(q+1);
52632425dafSDag-Erling Smørgrav 	    if (pp < 1 || pp > 65535) {
52732425dafSDag-Erling Smørgrav 		/* XXX we should emit some kind of warning */
52832425dafSDag-Erling Smørgrav 	    }
52932425dafSDag-Erling Smørgrav 	}
53032425dafSDag-Erling Smørgrav 	if (!pp) {
53132425dafSDag-Erling Smørgrav 	    struct servent *se;
53232425dafSDag-Erling Smørgrav 
53332425dafSDag-Erling Smørgrav 	    if ((se = getservbyname("ftp", "tcp")) != NULL)
53432425dafSDag-Erling Smørgrav 		pp = ntohs(se->s_port);
53532425dafSDag-Erling Smørgrav 	    else
53632425dafSDag-Erling Smørgrav 		pp = FTP_DEFAULT_PORT;
537f62e5228SDag-Erling Smørgrav 	}
53828c645cfSHajimu UMEMOTO 	if (q) {
53928c645cfSHajimu UMEMOTO #ifdef INET6
54028c645cfSHajimu UMEMOTO 	    if (q > p && *p == '[' && *(q - 1) == ']') {
54128c645cfSHajimu UMEMOTO 		p++;
54228c645cfSHajimu UMEMOTO 		q--;
54328c645cfSHajimu UMEMOTO 	    }
54428c645cfSHajimu UMEMOTO #endif
54528c645cfSHajimu UMEMOTO 	    c = *q;
546f62e5228SDag-Erling Smørgrav 	    *q = 0;
54728c645cfSHajimu UMEMOTO 	}
54828c645cfSHajimu UMEMOTO 	cd = _fetch_connect(p, pp, af, verbose);
549f62e5228SDag-Erling Smørgrav 	if (q)
55028c645cfSHajimu UMEMOTO 	    *q = c;
551f62e5228SDag-Erling Smørgrav     } else {
552f62e5228SDag-Erling Smørgrav 	/* no proxy, go straight to target */
55328c645cfSHajimu UMEMOTO 	cd = _fetch_connect(host, port, af, verbose);
554f5f109a0SDag-Erling Smørgrav 	p = NULL;
555f62e5228SDag-Erling Smørgrav     }
556f62e5228SDag-Erling Smørgrav 
557f62e5228SDag-Erling Smørgrav     /* check connection */
558fc6e9e65SDag-Erling Smørgrav     if (cd == -1) {
559842a95ccSDag-Erling Smørgrav 	_fetch_syserr();
5608e3986eaSDag-Erling Smørgrav 	return NULL;
5618e3986eaSDag-Erling Smørgrav     }
562f62e5228SDag-Erling Smørgrav 
5638e3986eaSDag-Erling Smørgrav     /* expect welcome message */
564fc6e9e65SDag-Erling Smørgrav     if ((e = _ftp_chkerr(cd)) != FTP_SERVICE_READY)
5658e3986eaSDag-Erling Smørgrav 	goto fouch;
5668e3986eaSDag-Erling Smørgrav 
5678e3986eaSDag-Erling Smørgrav     /* send user name and password */
568f62e5228SDag-Erling Smørgrav     if (!user || !*user)
569f62e5228SDag-Erling Smørgrav 	user = FTP_ANONYMOUS_USER;
570fc6e9e65SDag-Erling Smørgrav     e = p ? _ftp_cmd(cd, "USER %s@%s@%d", user, host, port)
571fc6e9e65SDag-Erling Smørgrav 	  : _ftp_cmd(cd, "USER %s", user);
572f62e5228SDag-Erling Smørgrav 
573f62e5228SDag-Erling Smørgrav     /* did the server request a password? */
574f62e5228SDag-Erling Smørgrav     if (e == FTP_NEED_PASSWORD) {
575f62e5228SDag-Erling Smørgrav 	if (!pwd || !*pwd)
5764ab587f4SHajimu UMEMOTO 	    pwd = getenv("FTP_PASSWORD");
5774ab587f4SHajimu UMEMOTO 	if (!pwd || !*pwd) {
5784ab587f4SHajimu UMEMOTO 	    if ((logname = getlogin()) == 0)
5794ab587f4SHajimu UMEMOTO 		logname = FTP_ANONYMOUS_PASSWORD;
5804ab587f4SHajimu UMEMOTO 	    gethostname(localhost, sizeof localhost);
5814ab587f4SHajimu UMEMOTO 	    snprintf(pbuf, sizeof pbuf, "%s@%s", logname, localhost);
5824ab587f4SHajimu UMEMOTO 	    pwd = pbuf;
5834ab587f4SHajimu UMEMOTO 	}
584fc6e9e65SDag-Erling Smørgrav 	e = _ftp_cmd(cd, "PASS %s", pwd);
585f62e5228SDag-Erling Smørgrav     }
586f62e5228SDag-Erling Smørgrav 
587f62e5228SDag-Erling Smørgrav     /* did the server request an account? */
5885aea254fSDag-Erling Smørgrav     if (e == FTP_NEED_ACCOUNT)
5893b7a6740SDag-Erling Smørgrav 	goto fouch;
590f62e5228SDag-Erling Smørgrav 
591f62e5228SDag-Erling Smørgrav     /* we should be done by now */
5925aea254fSDag-Erling Smørgrav     if (e != FTP_LOGGED_IN)
5938e3986eaSDag-Erling Smørgrav 	goto fouch;
5948e3986eaSDag-Erling Smørgrav 
5958e3986eaSDag-Erling Smørgrav     /* might as well select mode and type at once */
5968e3986eaSDag-Erling Smørgrav #ifdef FTP_FORCE_STREAM_MODE
597fc6e9e65SDag-Erling Smørgrav     if ((e = _ftp_cmd(cd, "MODE S")) != FTP_OK) /* default is S */
5985aea254fSDag-Erling Smørgrav 	goto fouch;
5998e3986eaSDag-Erling Smørgrav #endif
600fc6e9e65SDag-Erling Smørgrav     if ((e = _ftp_cmd(cd, "TYPE I")) != FTP_OK) /* default is A */
6015aea254fSDag-Erling Smørgrav 	goto fouch;
6028e3986eaSDag-Erling Smørgrav 
6038e3986eaSDag-Erling Smørgrav     /* done */
604fc6e9e65SDag-Erling Smørgrav     return cd;
6058e3986eaSDag-Erling Smørgrav 
6068e3986eaSDag-Erling Smørgrav fouch:
607fc6e9e65SDag-Erling Smørgrav     if (e != -1)
6085aea254fSDag-Erling Smørgrav 	_ftp_seterr(e);
609fc6e9e65SDag-Erling Smørgrav     close(cd);
6108e3986eaSDag-Erling Smørgrav     return NULL;
6118e3986eaSDag-Erling Smørgrav }
6128e3986eaSDag-Erling Smørgrav 
6138e3986eaSDag-Erling Smørgrav /*
6148e3986eaSDag-Erling Smørgrav  * Disconnect from server
6158e3986eaSDag-Erling Smørgrav  */
6168e3986eaSDag-Erling Smørgrav static void
617fc6e9e65SDag-Erling Smørgrav _ftp_disconnect(int cd)
6188e3986eaSDag-Erling Smørgrav {
619fc6e9e65SDag-Erling Smørgrav     (void)_ftp_cmd(cd, "QUIT");
620fc6e9e65SDag-Erling Smørgrav     close(cd);
6218e3986eaSDag-Erling Smørgrav }
6228e3986eaSDag-Erling Smørgrav 
6238e3986eaSDag-Erling Smørgrav /*
6248e3986eaSDag-Erling Smørgrav  * Check if we're already connected
6258e3986eaSDag-Erling Smørgrav  */
6268e3986eaSDag-Erling Smørgrav static int
627d8acd8dcSDag-Erling Smørgrav _ftp_isconnected(struct url *url)
6288e3986eaSDag-Erling Smørgrav {
6298e3986eaSDag-Erling Smørgrav     return (cached_socket
6308e3986eaSDag-Erling Smørgrav 	    && (strcmp(url->host, cached_host.host) == 0)
6318e3986eaSDag-Erling Smørgrav 	    && (strcmp(url->user, cached_host.user) == 0)
6328e3986eaSDag-Erling Smørgrav 	    && (strcmp(url->pwd, cached_host.pwd) == 0)
6338e3986eaSDag-Erling Smørgrav 	    && (url->port == cached_host.port));
6348e3986eaSDag-Erling Smørgrav }
6358e3986eaSDag-Erling Smørgrav 
636f62e5228SDag-Erling Smørgrav /*
6375aea254fSDag-Erling Smørgrav  * Check the cache, reconnect if no luck
638f62e5228SDag-Erling Smørgrav  */
639fc6e9e65SDag-Erling Smørgrav static int
6405aea254fSDag-Erling Smørgrav _ftp_cached_connect(struct url *url, char *flags)
6414ca1ab94SDag-Erling Smørgrav {
642fc6e9e65SDag-Erling Smørgrav     int e, cd;
6435aea254fSDag-Erling Smørgrav 
644fc6e9e65SDag-Erling Smørgrav     cd = -1;
6458e3986eaSDag-Erling Smørgrav 
6468e3986eaSDag-Erling Smørgrav     /* set default port */
64732425dafSDag-Erling Smørgrav     if (!url->port) {
64832425dafSDag-Erling Smørgrav 	struct servent *se;
64932425dafSDag-Erling Smørgrav 
65032425dafSDag-Erling Smørgrav 	if ((se = getservbyname("ftp", "tcp")) != NULL)
65132425dafSDag-Erling Smørgrav 	    url->port = ntohs(se->s_port);
65232425dafSDag-Erling Smørgrav 	else
653346298f0SDag-Erling Smørgrav 	    url->port = FTP_DEFAULT_PORT;
65432425dafSDag-Erling Smørgrav     }
6558e3986eaSDag-Erling Smørgrav 
6563b7a6740SDag-Erling Smørgrav     /* try to use previously cached connection */
657fc6e9e65SDag-Erling Smørgrav     if (_ftp_isconnected(url)) {
658fc6e9e65SDag-Erling Smørgrav 	e = _ftp_cmd(cached_socket, "NOOP");
659fc6e9e65SDag-Erling Smørgrav 	if (e == FTP_OK || e == FTP_SYNTAX_ERROR)
660fc6e9e65SDag-Erling Smørgrav 	    cd = cached_socket;
661fc6e9e65SDag-Erling Smørgrav     }
6624ca1ab94SDag-Erling Smørgrav 
6638e3986eaSDag-Erling Smørgrav     /* connect to server */
664fc6e9e65SDag-Erling Smørgrav     if (cd == -1) {
665fc6e9e65SDag-Erling Smørgrav 	cd = _ftp_connect(url->host, url->port, url->user, url->pwd, flags);
666fc6e9e65SDag-Erling Smørgrav 	if (cd == -1)
667fc6e9e65SDag-Erling Smørgrav 	    return -1;
6688e3986eaSDag-Erling Smørgrav 	if (cached_socket)
6698e3986eaSDag-Erling Smørgrav 	    _ftp_disconnect(cached_socket);
670fc6e9e65SDag-Erling Smørgrav 	cached_socket = cd;
67132425dafSDag-Erling Smørgrav 	memcpy(&cached_host, url, sizeof *url);
6728e3986eaSDag-Erling Smørgrav     }
6738e3986eaSDag-Erling Smørgrav 
674fc6e9e65SDag-Erling Smørgrav     return cd;
6758e3986eaSDag-Erling Smørgrav }
6768e3986eaSDag-Erling Smørgrav 
6778e3986eaSDag-Erling Smørgrav /*
6785aea254fSDag-Erling Smørgrav  * Get file
6798e3986eaSDag-Erling Smørgrav  */
6804ca1ab94SDag-Erling Smørgrav FILE *
681d8acd8dcSDag-Erling Smørgrav fetchGetFTP(struct url *url, char *flags)
682f62e5228SDag-Erling Smørgrav {
683fc6e9e65SDag-Erling Smørgrav     int cd;
6845aea254fSDag-Erling Smørgrav 
6855aea254fSDag-Erling Smørgrav     /* connect to server */
686fc6e9e65SDag-Erling Smørgrav     if ((cd = _ftp_cached_connect(url, flags)) == NULL)
6875aea254fSDag-Erling Smørgrav 	return NULL;
6885aea254fSDag-Erling Smørgrav 
6895aea254fSDag-Erling Smørgrav     /* initiate the transfer */
69032425dafSDag-Erling Smørgrav     return _ftp_transfer(cd, "RETR", url->doc, "r", url->offset, flags);
691f62e5228SDag-Erling Smørgrav }
692f62e5228SDag-Erling Smørgrav 
6935aea254fSDag-Erling Smørgrav /*
6945aea254fSDag-Erling Smørgrav  * Put file
6955aea254fSDag-Erling Smørgrav  */
696f62e5228SDag-Erling Smørgrav FILE *
697d8acd8dcSDag-Erling Smørgrav fetchPutFTP(struct url *url, char *flags)
6984ca1ab94SDag-Erling Smørgrav {
699fc6e9e65SDag-Erling Smørgrav     int cd;
7005aea254fSDag-Erling Smørgrav 
7015aea254fSDag-Erling Smørgrav     /* connect to server */
702fc6e9e65SDag-Erling Smørgrav     if ((cd = _ftp_cached_connect(url, flags)) == NULL)
7035aea254fSDag-Erling Smørgrav 	return NULL;
7045aea254fSDag-Erling Smørgrav 
7055aea254fSDag-Erling Smørgrav     /* initiate the transfer */
706fc6e9e65SDag-Erling Smørgrav     return _ftp_transfer(cd, (flags && strchr(flags, 'a')) ? "APPE" : "STOR",
70732425dafSDag-Erling Smørgrav 			 url->doc, "w", url->offset, flags);
7088e3986eaSDag-Erling Smørgrav }
709d8acd8dcSDag-Erling Smørgrav 
7105aea254fSDag-Erling Smørgrav /*
7115aea254fSDag-Erling Smørgrav  * Get file stats
7125aea254fSDag-Erling Smørgrav  */
713d8acd8dcSDag-Erling Smørgrav int
714d8acd8dcSDag-Erling Smørgrav fetchStatFTP(struct url *url, struct url_stat *us, char *flags)
715d8acd8dcSDag-Erling Smørgrav {
7165aea254fSDag-Erling Smørgrav     char *ln, *s;
7175aea254fSDag-Erling Smørgrav     struct tm tm;
7185aea254fSDag-Erling Smørgrav     time_t t;
719fc6e9e65SDag-Erling Smørgrav     int e, cd;
7205aea254fSDag-Erling Smørgrav 
7210669702cSDag-Erling Smørgrav     us->size = -1;
7220669702cSDag-Erling Smørgrav     us->atime = us->mtime = 0;
7230669702cSDag-Erling Smørgrav 
7245aea254fSDag-Erling Smørgrav     /* connect to server */
725fc6e9e65SDag-Erling Smørgrav     if ((cd = _ftp_cached_connect(url, flags)) == NULL)
7265aea254fSDag-Erling Smørgrav 	return -1;
7275aea254fSDag-Erling Smørgrav 
7285aea254fSDag-Erling Smørgrav     /* change directory */
7295aea254fSDag-Erling Smørgrav     if (((s = strrchr(url->doc, '/')) != NULL) && (s != url->doc)) {
7305aea254fSDag-Erling Smørgrav 	*s = 0;
731fc6e9e65SDag-Erling Smørgrav 	if ((e = _ftp_cmd(cd, "CWD %s", url->doc)) != FTP_FILE_ACTION_OK) {
7325aea254fSDag-Erling Smørgrav 	    *s = '/';
7335aea254fSDag-Erling Smørgrav 	    goto ouch;
7345aea254fSDag-Erling Smørgrav 	}
7355aea254fSDag-Erling Smørgrav 	*s++ = '/';
7365aea254fSDag-Erling Smørgrav     } else {
737fc6e9e65SDag-Erling Smørgrav 	if ((e = _ftp_cmd(cd, "CWD /")) != FTP_FILE_ACTION_OK)
7385aea254fSDag-Erling Smørgrav 	    goto ouch;
7395aea254fSDag-Erling Smørgrav     }
7405aea254fSDag-Erling Smørgrav 
7415aea254fSDag-Erling Smørgrav     /* s now points to file name */
7425aea254fSDag-Erling Smørgrav 
743fc6e9e65SDag-Erling Smørgrav     if (_ftp_cmd(cd, "SIZE %s", s) != FTP_FILE_STATUS)
7445aea254fSDag-Erling Smørgrav 	goto ouch;
745fc6e9e65SDag-Erling Smørgrav     for (ln = last_reply + 4; *ln && isspace(*ln); ln++)
7465aea254fSDag-Erling Smørgrav 	/* nothing */ ;
7475aea254fSDag-Erling Smørgrav     for (us->size = 0; *ln && isdigit(*ln); ln++)
7485aea254fSDag-Erling Smørgrav 	us->size = us->size * 10 + *ln - '0';
7495aea254fSDag-Erling Smørgrav     if (*ln && !isspace(*ln)) {
7505cd33c40SDag-Erling Smørgrav 	_ftp_seterr(FTP_PROTOCOL_ERROR);
7515aea254fSDag-Erling Smørgrav 	return -1;
7525aea254fSDag-Erling Smørgrav     }
75389474d12SDag-Erling Smørgrav     DEBUG(fprintf(stderr, "size: [\033[1m%lld\033[m]\n", us->size));
7545aea254fSDag-Erling Smørgrav 
755fc6e9e65SDag-Erling Smørgrav     if ((e = _ftp_cmd(cd, "MDTM %s", s)) != FTP_FILE_STATUS)
7565aea254fSDag-Erling Smørgrav 	goto ouch;
757fc6e9e65SDag-Erling Smørgrav     for (ln = last_reply + 4; *ln && isspace(*ln); ln++)
7585aea254fSDag-Erling Smørgrav 	/* nothing */ ;
7595cd33c40SDag-Erling Smørgrav     e = FTP_PROTOCOL_ERROR;
76089474d12SDag-Erling Smørgrav     switch (strspn(ln, "0123456789")) {
76189474d12SDag-Erling Smørgrav     case 14:
76289474d12SDag-Erling Smørgrav 	break;
76389474d12SDag-Erling Smørgrav     case 15:
76489474d12SDag-Erling Smørgrav 	ln++;
76589474d12SDag-Erling Smørgrav 	ln[0] = '2';
76689474d12SDag-Erling Smørgrav 	ln[1] = '0';
76789474d12SDag-Erling Smørgrav 	break;
76889474d12SDag-Erling Smørgrav     default:
76989474d12SDag-Erling Smørgrav 	goto ouch;
77089474d12SDag-Erling Smørgrav     }
77189474d12SDag-Erling Smørgrav     if (sscanf(ln, "%04d%02d%02d%02d%02d%02d",
7725aea254fSDag-Erling Smørgrav 	       &tm.tm_year, &tm.tm_mon, &tm.tm_mday,
77389474d12SDag-Erling Smørgrav 	       &tm.tm_hour, &tm.tm_min, &tm.tm_sec) != 6)
77489474d12SDag-Erling Smørgrav 	goto ouch;
7755aea254fSDag-Erling Smørgrav     tm.tm_mon--;
7765aea254fSDag-Erling Smørgrav     tm.tm_year -= 1900;
7775aea254fSDag-Erling Smørgrav     tm.tm_isdst = -1;
77889474d12SDag-Erling Smørgrav     t = timegm(&tm);
7795d32c97cSDag-Erling Smørgrav     if (t == (time_t)-1)
7805d32c97cSDag-Erling Smørgrav 	t = time(NULL);
7815d32c97cSDag-Erling Smørgrav     us->mtime = t;
7825d32c97cSDag-Erling Smørgrav     us->atime = t;
78389474d12SDag-Erling Smørgrav     DEBUG(fprintf(stderr, "last modified: [\033[1m%04d-%02d-%02d "
78489474d12SDag-Erling Smørgrav 		  "%02d:%02d:%02d\033[m]\n",
78589474d12SDag-Erling Smørgrav 		  tm.tm_year + 1900, tm.tm_mon + 1, tm.tm_mday,
78689474d12SDag-Erling Smørgrav 		  tm.tm_hour, tm.tm_min, tm.tm_sec));
7875aea254fSDag-Erling Smørgrav     return 0;
7885aea254fSDag-Erling Smørgrav 
7895aea254fSDag-Erling Smørgrav ouch:
790fc6e9e65SDag-Erling Smørgrav     if (e != -1)
7915aea254fSDag-Erling Smørgrav 	_ftp_seterr(e);
792d8acd8dcSDag-Erling Smørgrav     return -1;
793d8acd8dcSDag-Erling Smørgrav }
794ce71b736SDag-Erling Smørgrav 
795ce71b736SDag-Erling Smørgrav /*
796ce71b736SDag-Erling Smørgrav  * List a directory
797ce71b736SDag-Erling Smørgrav  */
798ce71b736SDag-Erling Smørgrav extern void warnx(char *, ...);
799ce71b736SDag-Erling Smørgrav struct url_ent *
800ce71b736SDag-Erling Smørgrav fetchListFTP(struct url *url, char *flags)
801ce71b736SDag-Erling Smørgrav {
802def5f54cSDag-Erling Smørgrav     warnx("fetchListFTP(): not implemented");
803ce71b736SDag-Erling Smørgrav     return NULL;
804ce71b736SDag-Erling Smørgrav }
805