ee0aef00c4
Implement -x xferbufsize set the socket send and receive buffer size, as per 'xferbuf' in interactive mode. Patch from Nicholas Mills (via private mail), with minor adjustment by me.
1065 lines
24 KiB
C
1065 lines
24 KiB
C
/* $NetBSD: main.c,v 1.123 2015/04/23 23:31:23 lukem Exp $ */
|
|
|
|
/*-
|
|
* Copyright (c) 1996-2015 The NetBSD Foundation, Inc.
|
|
* All rights reserved.
|
|
*
|
|
* This code is derived from software contributed to The NetBSD Foundation
|
|
* by Luke Mewburn.
|
|
*
|
|
* Redistribution and use in source and binary forms, with or without
|
|
* modification, are permitted provided that the following conditions
|
|
* are met:
|
|
* 1. Redistributions of source code must retain the above copyright
|
|
* notice, this list of conditions and the following disclaimer.
|
|
* 2. Redistributions in binary form must reproduce the above copyright
|
|
* notice, this list of conditions and the following disclaimer in the
|
|
* documentation and/or other materials provided with the distribution.
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
|
|
* ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
|
|
* TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
|
|
* PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
|
|
* BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
|
|
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
|
|
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
|
|
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
|
|
* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
|
|
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
|
|
* POSSIBILITY OF SUCH DAMAGE.
|
|
*/
|
|
|
|
/*
|
|
* Copyright (c) 1985, 1989, 1993, 1994
|
|
* The Regents of the University of California. All rights reserved.
|
|
*
|
|
* Redistribution and use in source and binary forms, with or without
|
|
* modification, are permitted provided that the following conditions
|
|
* are met:
|
|
* 1. Redistributions of source code must retain the above copyright
|
|
* notice, this list of conditions and the following disclaimer.
|
|
* 2. Redistributions in binary form must reproduce the above copyright
|
|
* notice, this list of conditions and the following disclaimer in the
|
|
* documentation and/or other materials provided with the distribution.
|
|
* 3. Neither the name of the University nor the names of its contributors
|
|
* may be used to endorse or promote products derived from this software
|
|
* without specific prior written permission.
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
|
|
* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
|
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
|
|
* ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
|
|
* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
|
|
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
|
|
* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
|
|
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
|
|
* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
|
|
* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
|
|
* SUCH DAMAGE.
|
|
*/
|
|
|
|
/*
|
|
* Copyright (C) 1997 and 1998 WIDE Project.
|
|
* All rights reserved.
|
|
*
|
|
* Redistribution and use in source and binary forms, with or without
|
|
* modification, are permitted provided that the following conditions
|
|
* are met:
|
|
* 1. Redistributions of source code must retain the above copyright
|
|
* notice, this list of conditions and the following disclaimer.
|
|
* 2. Redistributions in binary form must reproduce the above copyright
|
|
* notice, this list of conditions and the following disclaimer in the
|
|
* documentation and/or other materials provided with the distribution.
|
|
* 3. Neither the name of the project nor the names of its contributors
|
|
* may be used to endorse or promote products derived from this software
|
|
* without specific prior written permission.
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED BY THE PROJECT AND CONTRIBUTORS ``AS IS'' AND
|
|
* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
|
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
|
|
* ARE DISCLAIMED. IN NO EVENT SHALL THE PROJECT OR CONTRIBUTORS BE LIABLE
|
|
* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
|
|
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
|
|
* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
|
|
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
|
|
* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
|
|
* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
|
|
* SUCH DAMAGE.
|
|
*/
|
|
|
|
#include <sys/cdefs.h>
|
|
#ifndef lint
|
|
__COPYRIGHT("@(#) Copyright (c) 1985, 1989, 1993, 1994\
|
|
The Regents of the University of California. All rights reserved.\
|
|
Copyright 1996-2015 The NetBSD Foundation, Inc. All rights reserved");
|
|
#endif /* not lint */
|
|
|
|
#ifndef lint
|
|
#if 0
|
|
static char sccsid[] = "@(#)main.c 8.6 (Berkeley) 10/9/94";
|
|
#else
|
|
__RCSID("$NetBSD: main.c,v 1.123 2015/04/23 23:31:23 lukem Exp $");
|
|
#endif
|
|
#endif /* not lint */
|
|
|
|
/*
|
|
* FTP User Program -- Command Interface.
|
|
*/
|
|
#include <sys/types.h>
|
|
#include <sys/socket.h>
|
|
|
|
#include <err.h>
|
|
#include <errno.h>
|
|
#include <netdb.h>
|
|
#include <paths.h>
|
|
#include <pwd.h>
|
|
#include <signal.h>
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#include <time.h>
|
|
#include <unistd.h>
|
|
#include <locale.h>
|
|
|
|
#define GLOBAL /* force GLOBAL decls in ftp_var.h to be declared */
|
|
#include "ftp_var.h"
|
|
|
|
#define FTP_PROXY "ftp_proxy" /* env var with FTP proxy location */
|
|
#define HTTP_PROXY "http_proxy" /* env var with HTTP proxy location */
|
|
#define HTTPS_PROXY "https_proxy" /* env var with HTTPS proxy location */
|
|
#define NO_PROXY "no_proxy" /* env var with list of non-proxied
|
|
* hosts, comma or space separated */
|
|
|
|
__dead static void usage(void);
|
|
static void setupoption(const char *, const char *, const char *);
|
|
|
|
int
|
|
main(int volatile argc, char **volatile argv)
|
|
{
|
|
int ch, rval;
|
|
struct passwd *pw;
|
|
char *cp, *ep, *anonpass, *upload_path, *src_addr;
|
|
const char *anonuser;
|
|
int dumbterm, isupload;
|
|
size_t len;
|
|
|
|
tzset();
|
|
setlocale(LC_ALL, "");
|
|
setprogname(argv[0]);
|
|
|
|
sigint_raised = 0;
|
|
|
|
ftpport = "ftp";
|
|
httpport = "http";
|
|
#ifdef WITH_SSL
|
|
httpsport = "https";
|
|
#endif
|
|
gateport = NULL;
|
|
cp = getenv("FTPSERVERPORT");
|
|
if (cp != NULL)
|
|
gateport = cp;
|
|
else
|
|
gateport = "ftpgate";
|
|
doglob = 1;
|
|
interactive = 1;
|
|
autologin = 1;
|
|
passivemode = 1;
|
|
activefallback = 1;
|
|
preserve = 1;
|
|
verbose = 0;
|
|
progress = 0;
|
|
gatemode = 0;
|
|
data = -1;
|
|
outfile = NULL;
|
|
restartautofetch = 0;
|
|
#ifndef NO_EDITCOMPLETE
|
|
editing = 0;
|
|
el = NULL;
|
|
hist = NULL;
|
|
#endif
|
|
bytes = 0;
|
|
mark = HASHBYTES;
|
|
rate_get = 0;
|
|
rate_get_incr = DEFAULTINCR;
|
|
rate_put = 0;
|
|
rate_put_incr = DEFAULTINCR;
|
|
#ifdef INET6
|
|
epsv4 = 1;
|
|
epsv6 = 1;
|
|
#else
|
|
epsv4 = 0;
|
|
epsv6 = 0;
|
|
#endif
|
|
epsv4bad = 0;
|
|
epsv6bad = 0;
|
|
src_addr = NULL;
|
|
upload_path = NULL;
|
|
isupload = 0;
|
|
reply_callback = NULL;
|
|
#ifdef INET6
|
|
family = AF_UNSPEC;
|
|
#else
|
|
family = AF_INET; /* force AF_INET if no INET6 support */
|
|
#endif
|
|
|
|
netrc[0] = '\0';
|
|
cp = getenv("NETRC");
|
|
if (cp != NULL && strlcpy(netrc, cp, sizeof(netrc)) >= sizeof(netrc))
|
|
errx(1, "$NETRC `%s': %s", cp, strerror(ENAMETOOLONG));
|
|
|
|
marg_sl = ftp_sl_init();
|
|
if ((tmpdir = getenv("TMPDIR")) == NULL)
|
|
tmpdir = _PATH_TMP;
|
|
|
|
/* Set default operation mode based on FTPMODE environment variable */
|
|
if ((cp = getenv("FTPMODE")) != NULL) {
|
|
if (strcasecmp(cp, "passive") == 0) {
|
|
passivemode = 1;
|
|
activefallback = 0;
|
|
} else if (strcasecmp(cp, "active") == 0) {
|
|
passivemode = 0;
|
|
activefallback = 0;
|
|
} else if (strcasecmp(cp, "gate") == 0) {
|
|
gatemode = 1;
|
|
} else if (strcasecmp(cp, "auto") == 0) {
|
|
passivemode = 1;
|
|
activefallback = 1;
|
|
} else
|
|
warnx("Unknown $FTPMODE `%s'; using defaults", cp);
|
|
}
|
|
|
|
if (strcmp(getprogname(), "pftp") == 0) {
|
|
passivemode = 1;
|
|
activefallback = 0;
|
|
} else if (strcmp(getprogname(), "gate-ftp") == 0)
|
|
gatemode = 1;
|
|
|
|
gateserver = getenv("FTPSERVER");
|
|
if (gateserver == NULL || *gateserver == '\0')
|
|
gateserver = GATE_SERVER;
|
|
if (gatemode) {
|
|
if (*gateserver == '\0') {
|
|
warnx(
|
|
"Neither $FTPSERVER nor GATE_SERVER is defined; disabling gate-ftp");
|
|
gatemode = 0;
|
|
}
|
|
}
|
|
|
|
cp = getenv("TERM");
|
|
if (cp == NULL || strcmp(cp, "dumb") == 0)
|
|
dumbterm = 1;
|
|
else
|
|
dumbterm = 0;
|
|
fromatty = isatty(fileno(stdin));
|
|
ttyout = stdout;
|
|
if (isatty(fileno(ttyout))) {
|
|
verbose = 1; /* verbose if to a tty */
|
|
if (! dumbterm) {
|
|
#ifndef NO_EDITCOMPLETE
|
|
if (fromatty) /* editing mode on if tty is usable */
|
|
editing = 1;
|
|
#endif
|
|
#ifndef NO_PROGRESS
|
|
if (foregroundproc())
|
|
progress = 1; /* progress bar on if fg */
|
|
#endif
|
|
}
|
|
}
|
|
|
|
while ((ch = getopt(argc, argv, "46AadefginN:o:pP:q:r:Rs:tT:u:vVx:")) != -1) {
|
|
switch (ch) {
|
|
case '4':
|
|
family = AF_INET;
|
|
break;
|
|
|
|
case '6':
|
|
#ifdef INET6
|
|
family = AF_INET6;
|
|
#else
|
|
warnx("INET6 support is not available; ignoring -6");
|
|
#endif
|
|
break;
|
|
|
|
case 'A':
|
|
activefallback = 0;
|
|
passivemode = 0;
|
|
break;
|
|
|
|
case 'a':
|
|
anonftp = 1;
|
|
break;
|
|
|
|
case 'd':
|
|
options |= SO_DEBUG;
|
|
ftp_debug++;
|
|
break;
|
|
|
|
case 'e':
|
|
#ifndef NO_EDITCOMPLETE
|
|
editing = 0;
|
|
#endif
|
|
break;
|
|
|
|
case 'f':
|
|
flushcache = 1;
|
|
break;
|
|
|
|
case 'g':
|
|
doglob = 0;
|
|
break;
|
|
|
|
case 'i':
|
|
interactive = 0;
|
|
break;
|
|
|
|
case 'n':
|
|
autologin = 0;
|
|
break;
|
|
|
|
case 'N':
|
|
if (strlcpy(netrc, optarg, sizeof(netrc))
|
|
>= sizeof(netrc))
|
|
errx(1, "%s: %s", optarg,
|
|
strerror(ENAMETOOLONG));
|
|
break;
|
|
|
|
case 'o':
|
|
outfile = optarg;
|
|
if (strcmp(outfile, "-") == 0)
|
|
ttyout = stderr;
|
|
break;
|
|
|
|
case 'p':
|
|
passivemode = 1;
|
|
activefallback = 0;
|
|
break;
|
|
|
|
case 'P':
|
|
ftpport = optarg;
|
|
break;
|
|
|
|
case 'q':
|
|
quit_time = strtol(optarg, &ep, 10);
|
|
if (quit_time < 1 || *ep != '\0')
|
|
errx(1, "Bad quit value: %s", optarg);
|
|
break;
|
|
|
|
case 'r':
|
|
retry_connect = strtol(optarg, &ep, 10);
|
|
if (retry_connect < 1 || *ep != '\0')
|
|
errx(1, "Bad retry value: %s", optarg);
|
|
break;
|
|
|
|
case 'R':
|
|
restartautofetch = 1;
|
|
break;
|
|
|
|
case 's':
|
|
src_addr = optarg;
|
|
break;
|
|
|
|
case 't':
|
|
trace = 1;
|
|
break;
|
|
|
|
case 'T':
|
|
{
|
|
int targc;
|
|
char *targv[6], *oac;
|
|
char cmdbuf[MAX_C_NAME];
|
|
|
|
/* look for `dir,max[,incr]' */
|
|
targc = 0;
|
|
(void)strlcpy(cmdbuf, "-T", sizeof(cmdbuf));
|
|
targv[targc++] = cmdbuf;
|
|
oac = ftp_strdup(optarg);
|
|
|
|
while ((cp = strsep(&oac, ",")) != NULL) {
|
|
if (*cp == '\0') {
|
|
warnx("Bad throttle value `%s'",
|
|
optarg);
|
|
usage();
|
|
/* NOTREACHED */
|
|
}
|
|
targv[targc++] = cp;
|
|
if (targc >= 5)
|
|
break;
|
|
}
|
|
if (parserate(targc, targv, 1) == -1)
|
|
usage();
|
|
free(oac);
|
|
break;
|
|
}
|
|
|
|
case 'u':
|
|
{
|
|
isupload = 1;
|
|
interactive = 0;
|
|
upload_path = ftp_strdup(optarg);
|
|
|
|
break;
|
|
}
|
|
|
|
case 'v':
|
|
progress = verbose = 1;
|
|
break;
|
|
|
|
case 'V':
|
|
progress = verbose = 0;
|
|
break;
|
|
|
|
case 'x':
|
|
sndbuf_size = strsuftoi(optarg);
|
|
if (sndbuf_size < 1)
|
|
errx(1, "Bad xferbuf value: %s", optarg);
|
|
rcvbuf_size = sndbuf_size;
|
|
break;
|
|
|
|
default:
|
|
usage();
|
|
}
|
|
}
|
|
/* set line buffering on ttyout */
|
|
setvbuf(ttyout, NULL, _IOLBF, 0);
|
|
argc -= optind;
|
|
argv += optind;
|
|
|
|
cpend = 0; /* no pending replies */
|
|
proxy = 0; /* proxy not active */
|
|
crflag = 1; /* strip c.r. on ascii gets */
|
|
sendport = -1; /* not using ports */
|
|
|
|
if (src_addr != NULL) {
|
|
struct addrinfo hints;
|
|
int error;
|
|
|
|
memset(&hints, 0, sizeof(hints));
|
|
hints.ai_family = family;
|
|
hints.ai_socktype = SOCK_STREAM;
|
|
hints.ai_flags = AI_PASSIVE;
|
|
error = getaddrinfo(src_addr, NULL, &hints, &bindai);
|
|
if (error) {
|
|
errx(1, "Can't lookup `%s': %s", src_addr,
|
|
(error == EAI_SYSTEM) ? strerror(errno)
|
|
: gai_strerror(error));
|
|
}
|
|
}
|
|
|
|
/*
|
|
* Cache the user name and home directory.
|
|
*/
|
|
localhome = NULL;
|
|
localname = NULL;
|
|
anonuser = "anonymous";
|
|
cp = getenv("HOME");
|
|
if (! EMPTYSTRING(cp))
|
|
localhome = ftp_strdup(cp);
|
|
pw = NULL;
|
|
cp = getlogin();
|
|
if (cp != NULL)
|
|
pw = getpwnam(cp);
|
|
if (pw == NULL)
|
|
pw = getpwuid(getuid());
|
|
if (pw != NULL) {
|
|
if (localhome == NULL && !EMPTYSTRING(pw->pw_dir))
|
|
localhome = ftp_strdup(pw->pw_dir);
|
|
localname = ftp_strdup(pw->pw_name);
|
|
anonuser = localname;
|
|
}
|
|
if (netrc[0] == '\0' && localhome != NULL) {
|
|
if (strlcpy(netrc, localhome, sizeof(netrc)) >= sizeof(netrc) ||
|
|
strlcat(netrc, "/.netrc", sizeof(netrc)) >= sizeof(netrc)) {
|
|
warnx("%s/.netrc: %s", localhome,
|
|
strerror(ENAMETOOLONG));
|
|
netrc[0] = '\0';
|
|
}
|
|
}
|
|
if (localhome == NULL)
|
|
localhome = ftp_strdup("/");
|
|
|
|
/*
|
|
* Every anonymous FTP server I've encountered will accept the
|
|
* string "username@", and will append the hostname itself. We
|
|
* do this by default since many servers are picky about not
|
|
* having a FQDN in the anonymous password.
|
|
* - thorpej@NetBSD.org
|
|
*/
|
|
len = strlen(anonuser) + 2;
|
|
anonpass = ftp_malloc(len);
|
|
(void)strlcpy(anonpass, anonuser, len);
|
|
(void)strlcat(anonpass, "@", len);
|
|
|
|
/*
|
|
* set all the defaults for options defined in
|
|
* struct option optiontab[] declared in cmdtab.c
|
|
*/
|
|
setupoption("anonpass", getenv("FTPANONPASS"), anonpass);
|
|
setupoption("ftp_proxy", getenv(FTP_PROXY), "");
|
|
setupoption("http_proxy", getenv(HTTP_PROXY), "");
|
|
setupoption("https_proxy", getenv(HTTPS_PROXY), "");
|
|
setupoption("no_proxy", getenv(NO_PROXY), "");
|
|
setupoption("pager", getenv("PAGER"), DEFAULTPAGER);
|
|
setupoption("prompt", getenv("FTPPROMPT"), DEFAULTPROMPT);
|
|
setupoption("rprompt", getenv("FTPRPROMPT"), DEFAULTRPROMPT);
|
|
|
|
free(anonpass);
|
|
|
|
setttywidth(0);
|
|
#ifdef SIGINFO
|
|
(void)xsignal(SIGINFO, psummary);
|
|
#endif
|
|
(void)xsignal(SIGQUIT, psummary);
|
|
(void)xsignal(SIGUSR1, crankrate);
|
|
(void)xsignal(SIGUSR2, crankrate);
|
|
(void)xsignal(SIGWINCH, setttywidth);
|
|
|
|
if (argc > 0) {
|
|
if (isupload) {
|
|
rval = auto_put(argc, argv, upload_path);
|
|
sigint_or_rval_exit:
|
|
if (sigint_raised) {
|
|
(void)xsignal(SIGINT, SIG_DFL);
|
|
raise(SIGINT);
|
|
}
|
|
exit(rval);
|
|
} else if (strchr(argv[0], ':') != NULL
|
|
&& ! isipv6addr(argv[0])) {
|
|
rval = auto_fetch(argc, argv);
|
|
if (rval >= 0) /* -1 == connected and cd-ed */
|
|
goto sigint_or_rval_exit;
|
|
} else {
|
|
char *xargv[4], *uuser, *host;
|
|
char cmdbuf[MAXPATHLEN];
|
|
|
|
if ((rval = sigsetjmp(toplevel, 1)))
|
|
goto sigint_or_rval_exit;
|
|
(void)xsignal(SIGINT, intr);
|
|
(void)xsignal(SIGPIPE, lostpeer);
|
|
uuser = NULL;
|
|
host = argv[0];
|
|
cp = strchr(host, '@');
|
|
if (cp) {
|
|
*cp = '\0';
|
|
uuser = host;
|
|
host = cp + 1;
|
|
}
|
|
(void)strlcpy(cmdbuf, getprogname(), sizeof(cmdbuf));
|
|
xargv[0] = cmdbuf;
|
|
xargv[1] = host;
|
|
xargv[2] = argv[1];
|
|
xargv[3] = NULL;
|
|
do {
|
|
int oautologin;
|
|
|
|
oautologin = autologin;
|
|
if (uuser != NULL) {
|
|
anonftp = 0;
|
|
autologin = 0;
|
|
}
|
|
setpeer(argc+1, xargv);
|
|
autologin = oautologin;
|
|
if (connected == 1 && uuser != NULL)
|
|
(void)ftp_login(host, uuser, NULL);
|
|
if (!retry_connect)
|
|
break;
|
|
if (!connected) {
|
|
macnum = 0;
|
|
fprintf(ttyout,
|
|
"Retrying in %d seconds...\n",
|
|
retry_connect);
|
|
sleep(retry_connect);
|
|
}
|
|
} while (!connected);
|
|
retry_connect = 0; /* connected, stop hiding msgs */
|
|
}
|
|
}
|
|
if (isupload)
|
|
usage();
|
|
|
|
#ifndef NO_EDITCOMPLETE
|
|
controlediting();
|
|
#endif /* !NO_EDITCOMPLETE */
|
|
|
|
(void)sigsetjmp(toplevel, 1);
|
|
(void)xsignal(SIGINT, intr);
|
|
(void)xsignal(SIGPIPE, lostpeer);
|
|
for (;;)
|
|
cmdscanner();
|
|
}
|
|
|
|
/*
|
|
* Generate a prompt
|
|
*/
|
|
char *
|
|
prompt(void)
|
|
{
|
|
static char **promptopt;
|
|
static char buf[MAXPATHLEN];
|
|
|
|
if (promptopt == NULL) {
|
|
struct option *o;
|
|
|
|
o = getoption("prompt");
|
|
if (o == NULL)
|
|
errx(1, "prompt: no such option `prompt'");
|
|
promptopt = &(o->value);
|
|
}
|
|
formatbuf(buf, sizeof(buf), *promptopt ? *promptopt : DEFAULTPROMPT);
|
|
return (buf);
|
|
}
|
|
|
|
/*
|
|
* Generate an rprompt
|
|
*/
|
|
char *
|
|
rprompt(void)
|
|
{
|
|
static char **rpromptopt;
|
|
static char buf[MAXPATHLEN];
|
|
|
|
if (rpromptopt == NULL) {
|
|
struct option *o;
|
|
|
|
o = getoption("rprompt");
|
|
if (o == NULL)
|
|
errx(1, "rprompt: no such option `rprompt'");
|
|
rpromptopt = &(o->value);
|
|
}
|
|
formatbuf(buf, sizeof(buf), *rpromptopt ? *rpromptopt : DEFAULTRPROMPT);
|
|
return (buf);
|
|
}
|
|
|
|
/*
|
|
* Command parser.
|
|
*/
|
|
void
|
|
cmdscanner(void)
|
|
{
|
|
struct cmd *c;
|
|
char *p;
|
|
#ifndef NO_EDITCOMPLETE
|
|
int ch;
|
|
size_t num;
|
|
#endif
|
|
int len;
|
|
char cmdbuf[MAX_C_NAME];
|
|
|
|
for (;;) {
|
|
#ifndef NO_EDITCOMPLETE
|
|
if (!editing) {
|
|
#endif /* !NO_EDITCOMPLETE */
|
|
if (fromatty) {
|
|
fputs(prompt(), ttyout);
|
|
p = rprompt();
|
|
if (*p)
|
|
fprintf(ttyout, "%s ", p);
|
|
}
|
|
(void)fflush(ttyout);
|
|
len = get_line(stdin, line, sizeof(line), NULL);
|
|
switch (len) {
|
|
case -1: /* EOF */
|
|
case -2: /* error */
|
|
if (fromatty)
|
|
putc('\n', ttyout);
|
|
quit(0, NULL);
|
|
/* NOTREACHED */
|
|
case -3: /* too long; try again */
|
|
fputs("Sorry, input line is too long.\n",
|
|
ttyout);
|
|
continue;
|
|
case 0: /* empty; try again */
|
|
continue;
|
|
default: /* all ok */
|
|
break;
|
|
}
|
|
#ifndef NO_EDITCOMPLETE
|
|
} else {
|
|
const char *buf;
|
|
HistEvent ev;
|
|
cursor_pos = NULL;
|
|
|
|
buf = el_gets(el, &ch);
|
|
num = ch;
|
|
if (buf == NULL || num == 0) {
|
|
if (fromatty)
|
|
putc('\n', ttyout);
|
|
quit(0, NULL);
|
|
}
|
|
if (num >= sizeof(line)) {
|
|
fputs("Sorry, input line is too long.\n",
|
|
ttyout);
|
|
break;
|
|
}
|
|
memcpy(line, buf, num);
|
|
if (line[--num] == '\n') {
|
|
line[num] = '\0';
|
|
if (num == 0)
|
|
break;
|
|
}
|
|
history(hist, &ev, H_ENTER, buf);
|
|
}
|
|
#endif /* !NO_EDITCOMPLETE */
|
|
|
|
makeargv();
|
|
if (margc == 0)
|
|
continue;
|
|
c = getcmd(margv[0]);
|
|
if (c == (struct cmd *)-1) {
|
|
fputs("?Ambiguous command.\n", ttyout);
|
|
continue;
|
|
}
|
|
if (c == NULL) {
|
|
#if !defined(NO_EDITCOMPLETE)
|
|
/*
|
|
* attempt to el_parse() unknown commands.
|
|
* any command containing a ':' would be parsed
|
|
* as "[prog:]cmd ...", and will result in a
|
|
* false positive if prog != "ftp", so treat
|
|
* such commands as invalid.
|
|
*/
|
|
if (strchr(margv[0], ':') != NULL ||
|
|
!editing ||
|
|
el_parse(el, margc, (void *)margv) != 0)
|
|
#endif /* !NO_EDITCOMPLETE */
|
|
fputs("?Invalid command.\n", ttyout);
|
|
continue;
|
|
}
|
|
if (c->c_conn && !connected) {
|
|
fputs("Not connected.\n", ttyout);
|
|
continue;
|
|
}
|
|
confirmrest = 0;
|
|
(void)strlcpy(cmdbuf, c->c_name, sizeof(cmdbuf));
|
|
margv[0] = cmdbuf;
|
|
(*c->c_handler)(margc, margv);
|
|
if (bell && c->c_bell)
|
|
(void)putc('\007', ttyout);
|
|
if (c->c_handler != help)
|
|
break;
|
|
}
|
|
(void)xsignal(SIGINT, intr);
|
|
(void)xsignal(SIGPIPE, lostpeer);
|
|
}
|
|
|
|
struct cmd *
|
|
getcmd(const char *name)
|
|
{
|
|
const char *p, *q;
|
|
struct cmd *c, *found;
|
|
int nmatches, longest;
|
|
|
|
if (name == NULL)
|
|
return (0);
|
|
|
|
longest = 0;
|
|
nmatches = 0;
|
|
found = 0;
|
|
for (c = cmdtab; (p = c->c_name) != NULL; c++) {
|
|
for (q = name; *q == *p++; q++)
|
|
if (*q == 0) /* exact match? */
|
|
return (c);
|
|
if (!*q) { /* the name was a prefix */
|
|
if (q - name > longest) {
|
|
longest = q - name;
|
|
nmatches = 1;
|
|
found = c;
|
|
} else if (q - name == longest)
|
|
nmatches++;
|
|
}
|
|
}
|
|
if (nmatches > 1)
|
|
return ((struct cmd *)-1);
|
|
return (found);
|
|
}
|
|
|
|
/*
|
|
* Slice a string up into argc/argv.
|
|
*/
|
|
|
|
int slrflag;
|
|
|
|
void
|
|
makeargv(void)
|
|
{
|
|
char *argp;
|
|
|
|
stringbase = line; /* scan from first of buffer */
|
|
argbase = argbuf; /* store from first of buffer */
|
|
slrflag = 0;
|
|
marg_sl->sl_cur = 0; /* reset to start of marg_sl */
|
|
for (margc = 0; ; margc++) {
|
|
argp = slurpstring();
|
|
ftp_sl_add(marg_sl, argp);
|
|
if (argp == NULL)
|
|
break;
|
|
}
|
|
#ifndef NO_EDITCOMPLETE
|
|
if (cursor_pos == line) {
|
|
cursor_argc = 0;
|
|
cursor_argo = 0;
|
|
} else if (cursor_pos != NULL) {
|
|
cursor_argc = margc;
|
|
cursor_argo = strlen(margv[margc-1]);
|
|
}
|
|
#endif /* !NO_EDITCOMPLETE */
|
|
}
|
|
|
|
#ifdef NO_EDITCOMPLETE
|
|
#define INC_CHKCURSOR(x) (x)++
|
|
#else /* !NO_EDITCOMPLETE */
|
|
#define INC_CHKCURSOR(x) { (x)++ ; \
|
|
if (x == cursor_pos) { \
|
|
cursor_argc = margc; \
|
|
cursor_argo = ap-argbase; \
|
|
cursor_pos = NULL; \
|
|
} }
|
|
|
|
#endif /* !NO_EDITCOMPLETE */
|
|
|
|
/*
|
|
* Parse string into argbuf;
|
|
* implemented with FSM to
|
|
* handle quoting and strings
|
|
*/
|
|
char *
|
|
slurpstring(void)
|
|
{
|
|
static char bangstr[2] = { '!', '\0' };
|
|
static char dollarstr[2] = { '$', '\0' };
|
|
int got_one = 0;
|
|
char *sb = stringbase;
|
|
char *ap = argbase;
|
|
char *tmp = argbase; /* will return this if token found */
|
|
|
|
if (*sb == '!' || *sb == '$') { /* recognize ! as a token for shell */
|
|
switch (slrflag) { /* and $ as token for macro invoke */
|
|
case 0:
|
|
slrflag++;
|
|
INC_CHKCURSOR(stringbase);
|
|
return ((*sb == '!') ? bangstr : dollarstr);
|
|
/* NOTREACHED */
|
|
case 1:
|
|
slrflag++;
|
|
altarg = stringbase;
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
S0:
|
|
switch (*sb) {
|
|
|
|
case '\0':
|
|
goto OUT;
|
|
|
|
case ' ':
|
|
case '\t':
|
|
INC_CHKCURSOR(sb);
|
|
goto S0;
|
|
|
|
default:
|
|
switch (slrflag) {
|
|
case 0:
|
|
slrflag++;
|
|
break;
|
|
case 1:
|
|
slrflag++;
|
|
altarg = sb;
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
goto S1;
|
|
}
|
|
|
|
S1:
|
|
switch (*sb) {
|
|
|
|
case ' ':
|
|
case '\t':
|
|
case '\0':
|
|
goto OUT; /* end of token */
|
|
|
|
case '\\':
|
|
INC_CHKCURSOR(sb);
|
|
goto S2; /* slurp next character */
|
|
|
|
case '"':
|
|
INC_CHKCURSOR(sb);
|
|
goto S3; /* slurp quoted string */
|
|
|
|
default:
|
|
*ap = *sb; /* add character to token */
|
|
ap++;
|
|
INC_CHKCURSOR(sb);
|
|
got_one = 1;
|
|
goto S1;
|
|
}
|
|
|
|
S2:
|
|
switch (*sb) {
|
|
|
|
case '\0':
|
|
goto OUT;
|
|
|
|
default:
|
|
*ap = *sb;
|
|
ap++;
|
|
INC_CHKCURSOR(sb);
|
|
got_one = 1;
|
|
goto S1;
|
|
}
|
|
|
|
S3:
|
|
switch (*sb) {
|
|
|
|
case '\0':
|
|
goto OUT;
|
|
|
|
case '"':
|
|
INC_CHKCURSOR(sb);
|
|
goto S1;
|
|
|
|
default:
|
|
*ap = *sb;
|
|
ap++;
|
|
INC_CHKCURSOR(sb);
|
|
got_one = 1;
|
|
goto S3;
|
|
}
|
|
|
|
OUT:
|
|
if (got_one)
|
|
*ap++ = '\0';
|
|
argbase = ap; /* update storage pointer */
|
|
stringbase = sb; /* update scan pointer */
|
|
if (got_one) {
|
|
return (tmp);
|
|
}
|
|
switch (slrflag) {
|
|
case 0:
|
|
slrflag++;
|
|
break;
|
|
case 1:
|
|
slrflag++;
|
|
altarg = NULL;
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
return (NULL);
|
|
}
|
|
|
|
/*
|
|
* Help/usage command.
|
|
* Call each command handler with argc == 0 and argv[0] == name.
|
|
*/
|
|
void
|
|
help(int argc, char *argv[])
|
|
{
|
|
struct cmd *c;
|
|
char *nargv[1], *cmd;
|
|
const char *p;
|
|
int isusage;
|
|
|
|
cmd = argv[0];
|
|
isusage = (strcmp(cmd, "usage") == 0);
|
|
if (argc == 0 || (isusage && argc == 1)) {
|
|
UPRINTF("usage: %s [command [...]]\n", cmd);
|
|
return;
|
|
}
|
|
if (argc == 1) {
|
|
StringList *buf;
|
|
|
|
buf = ftp_sl_init();
|
|
fprintf(ttyout,
|
|
"%sommands may be abbreviated. Commands are:\n\n",
|
|
proxy ? "Proxy c" : "C");
|
|
for (c = cmdtab; (p = c->c_name) != NULL; c++)
|
|
if (!proxy || c->c_proxy)
|
|
ftp_sl_add(buf, ftp_strdup(p));
|
|
list_vertical(buf);
|
|
sl_free(buf, 1);
|
|
return;
|
|
}
|
|
|
|
#define HELPINDENT ((int) sizeof("disconnect"))
|
|
|
|
while (--argc > 0) {
|
|
char *arg;
|
|
char cmdbuf[MAX_C_NAME];
|
|
|
|
arg = *++argv;
|
|
c = getcmd(arg);
|
|
if (c == (struct cmd *)-1)
|
|
fprintf(ttyout, "?Ambiguous %s command `%s'\n",
|
|
cmd, arg);
|
|
else if (c == NULL)
|
|
fprintf(ttyout, "?Invalid %s command `%s'\n",
|
|
cmd, arg);
|
|
else {
|
|
if (isusage) {
|
|
(void)strlcpy(cmdbuf, c->c_name, sizeof(cmdbuf));
|
|
nargv[0] = cmdbuf;
|
|
(*c->c_handler)(0, nargv);
|
|
} else
|
|
fprintf(ttyout, "%-*s\t%s\n", HELPINDENT,
|
|
c->c_name, c->c_help);
|
|
}
|
|
}
|
|
}
|
|
|
|
struct option *
|
|
getoption(const char *name)
|
|
{
|
|
const char *p;
|
|
struct option *c;
|
|
|
|
if (name == NULL)
|
|
return (NULL);
|
|
for (c = optiontab; (p = c->name) != NULL; c++) {
|
|
if (strcasecmp(p, name) == 0)
|
|
return (c);
|
|
}
|
|
return (NULL);
|
|
}
|
|
|
|
char *
|
|
getoptionvalue(const char *name)
|
|
{
|
|
struct option *c;
|
|
|
|
if (name == NULL)
|
|
errx(1, "getoptionvalue: invoked with NULL name");
|
|
c = getoption(name);
|
|
if (c != NULL)
|
|
return (c->value);
|
|
errx(1, "getoptionvalue: invoked with unknown option `%s'", name);
|
|
/* NOTREACHED */
|
|
}
|
|
|
|
static void
|
|
setupoption(const char *name, const char *value, const char *defaultvalue)
|
|
{
|
|
set_option(name, value ? value : defaultvalue, 0);
|
|
}
|
|
|
|
void
|
|
usage(void)
|
|
{
|
|
const char *progname = getprogname();
|
|
|
|
(void)fprintf(stderr,
|
|
"usage: %s [-46AadefginpRtVv] [-N netrc] [-o outfile] [-P port] [-q quittime]\n"
|
|
" [-r retry] [-s srcaddr] [-T dir,max[,inc]] [-x xferbufsize]\n"
|
|
" [[user@]host [port]] [host:path[/]] [file:///file]\n"
|
|
" [ftp://[user[:pass]@]host[:port]/path[/]]\n"
|
|
" [http://[user[:pass]@]host[:port]/path] [...]\n"
|
|
#ifdef WITH_SSL
|
|
" [https://[user[:pass]@]host[:port]/path] [...]\n"
|
|
#endif
|
|
" %s -u URL file [...]\n", progname, progname);
|
|
exit(1);
|
|
}
|