ref: c06e464ec45dd5880850fa60c850498861c514d3
dir: /sys/src/cmd/ip/ftpd.c/
#include <u.h>
#include <libc.h>
#include <bio.h>
#include <auth.h>
#include <ip.h>
#include <libsec.h>
#include <String.h>
#include "glob.h"
enum
{
/* telnet control character */
Iac= 255,
/* representation types */
Tascii= 0,
Timage= 1,
/* transmission modes */
Mstream= 0,
Mblock= 1,
Mpage= 2,
/* file structure */
Sfile= 0,
Sblock= 1,
Scompressed= 2,
/* read/write buffer size */
Nbuf= 4096,
/* maximum ms we'll wait for a command */
Maxwait= 1000*60*30, /* inactive for 30 minutes, we hang up */
Maxpath= 512,
};
int abortcmd(char*);
int appendcmd(char*);
int cdupcmd(char*);
int cwdcmd(char*);
int delcmd(char*);
int helpcmd(char*);
int listcmd(char*);
int mdtmcmd(char*);
int mkdircmd(char*);
int modecmd(char*);
int namelistcmd(char*);
int nopcmd(char*);
int optscmd(char*);
int passcmd(char*);
int pasvcmd(char*);
int portcmd(char*);
int pwdcmd(char*);
int quitcmd(char*);
int rnfrcmd(char*);
int rntocmd(char*);
int reply(char*, ...);
int restartcmd(char*);
int retrievecmd(char*);
int sitecmd(char*);
int sizecmd(char*);
int storecmd(char*);
int storeucmd(char*);
int structcmd(char*);
int systemcmd(char*);
int typecmd(char*);
int usercmd(char*);
int dialdata(void);
char* abspath(char*);
int crlfwrite(int, char*, int);
int sodoff(void);
int accessok(char*);
typedef struct Cmd Cmd;
struct Cmd
{
char *name;
int (*f)(char*);
int needlogin;
};
Cmd cmdtab[] =
{
{ "abor", abortcmd, 0, },
{ "appe", appendcmd, 1, },
{ "cdup", cdupcmd, 1, },
{ "cwd", cwdcmd, 1, },
{ "dele", delcmd, 1, },
{ "help", helpcmd, 0, },
{ "list", listcmd, 1, },
{ "mdtm", mdtmcmd, 1, },
{ "mkd", mkdircmd, 1, },
{ "mode", modecmd, 0, },
{ "nlst", namelistcmd, 1, },
{ "noop", nopcmd, 0, },
{ "opts", optscmd, 0, },
{ "pass", passcmd, 0, },
{ "pasv", pasvcmd, 1, },
{ "pwd", pwdcmd, 0, },
{ "port", portcmd, 1, },
{ "quit", quitcmd, 0, },
{ "rest", restartcmd, 1, },
{ "retr", retrievecmd, 1, },
{ "rmd", delcmd, 1, },
{ "rnfr", rnfrcmd, 1, },
{ "rnto", rntocmd, 1, },
{ "site", sitecmd, 1, },
{ "size", sizecmd, 1, },
{ "stor", storecmd, 1, },
{ "stou", storeucmd, 1, },
{ "stru", structcmd, 1, },
{ "syst", systemcmd, 0, },
{ "type", typecmd, 0, },
{ "user", usercmd, 0, },
{ 0, 0, 0 },
};
#define NONENS "/lib/namespace.ftp" /* default ns for none */
char user[Maxpath]; /* logged in user */
char curdir[Maxpath]; /* current directory path */
Chalstate *ch;
int loggedin;
int type; /* transmission type */
int mode; /* transmission mode */
int structure; /* file structure */
char data[64]; /* data address */
int pid; /* transfer process */
int encryption; /* encryption state */
int isnone, anon_ok, anon_only, anon_everybody;
char cputype[Maxpath]; /* the environment variable of the same name */
char bindir[Maxpath]; /* bin directory for this architecture */
char mailaddr[Maxpath];
char *namespace = NONENS;
int debug;
NetConnInfo *nci;
int createperm = 0660;
int isnoworld;
vlong offset; /* from restart command */
ulong id;
typedef struct Passive Passive;
struct Passive
{
int inuse;
char adir[40];
int afd;
int port;
uchar ipaddr[IPaddrlen];
} passive;
#define FTPLOG "ftp"
void
logit(char *fmt, ...)
{
char buf[8192];
va_list arg;
va_start(arg, fmt);
vseprint(buf, buf+sizeof(buf), fmt, arg);
va_end(arg);
syslog(0, FTPLOG, "%s.%s %s", nci->rsys, nci->rserv, buf);
}
static void
usage(void)
{
syslog(0, "ftp", "usage: %s [-aAde] [-n nsfile]", argv0);
fprint(2, "usage: %s [-aAde] [-n nsfile]\n", argv0);
exits("usage");
}
/*
* read commands from the control stream and dispatch
*/
void
main(int argc, char **argv)
{
char *cmd;
char *arg;
char *p;
Cmd *t;
Biobuf in;
int i;
ARGBEGIN{
case 'a': /* anonymous OK */
anon_ok = 1;
break;
case 'A':
anon_ok = 1;
anon_only = 1;
break;
case 'd':
debug++;
break;
case 'e':
anon_ok = 1;
anon_everybody = 1;
break;
case 'n':
namespace = EARGF(usage());
break;
default:
usage();
}ARGEND
/* open log file before doing a newns */
syslog(0, FTPLOG, nil);
/* find out who is calling */
if(argc < 1)
nci = getnetconninfo(nil, 0);
else
nci = getnetconninfo(argv[argc-1], 0);
if(nci == nil)
sysfatal("ftpd needs a network address");
strcpy(mailaddr, "?");
id = getpid();
/* figure out which binaries to bind in later (only for none) */
arg = getenv("cputype");
if(arg)
strecpy(cputype, cputype+sizeof cputype, arg);
else
strcpy(cputype, "mips");
/* shurely /%s/bin */
snprint(bindir, sizeof(bindir), "/bin/%s/bin", cputype);
Binit(&in, 0, OREAD);
reply("220 Plan 9 FTP server ready");
alarm(Maxwait);
while(cmd = Brdline(&in, '\n')){
alarm(0);
/*
* strip out trailing cr's & lf and delimit with null
*/
i = Blinelen(&in)-1;
cmd[i] = 0;
if(debug)
logit("%s", cmd);
while(i > 0 && cmd[i-1] == '\r')
cmd[--i] = 0;
/*
* hack for GatorFTP+, look for a 0x10 used as a delimiter
*/
p = strchr(cmd, 0x10);
if(p)
*p = 0;
/*
* get rid of telnet control sequences (we don't need them)
*/
while(*cmd && (uchar)*cmd == Iac){
cmd++;
if(*cmd)
cmd++;
}
/*
* parse the message (command arg)
*/
arg = strchr(cmd, ' ');
if(arg){
*arg++ = 0;
while(*arg == ' ')
arg++;
}
/*
* ignore blank commands
*/
if(*cmd == 0)
continue;
/*
* lookup the command and do it
*/
for(p = cmd; *p; p++)
*p = tolower(*p);
for(t = cmdtab; t->name; t++)
if(strcmp(cmd, t->name) == 0){
if(t->needlogin && !loggedin)
sodoff();
else if((*t->f)(arg) < 0)
exits(0);
break;
}
if(t->f != restartcmd){
/*
* the file offset is set to zero following
* all commands except the restart command
*/
offset = 0;
}
if(t->name == 0){
/*
* the OOB bytes preceding an abort from UCB machines
* comes out as something unrecognizable instead of
* IAC's. Certainly a Plan 9 bug but I can't find it.
* This is a major hack to avoid the problem. -- presotto
*/
i = strlen(cmd);
if(i > 4 && strcmp(cmd+i-4, "abor") == 0){
abortcmd(0);
} else{
logit("%s (%s) command not implemented", cmd, arg?arg:"");
reply("502 %s command not implemented", cmd);
}
}
alarm(Maxwait);
}
if(pid)
postnote(PNPROC, pid, "kill");
}
/*
* reply to a command
*/
int
reply(char *fmt, ...)
{
va_list arg;
char buf[8192], *s;
va_start(arg, fmt);
s = vseprint(buf, buf+sizeof(buf)-3, fmt, arg);
va_end(arg);
if(debug){
*s = 0;
logit("%s", buf);
}
*s++ = '\r';
*s++ = '\n';
write(1, buf, s - buf);
return 0;
}
int
sodoff(void)
{
return reply("530 Sod off, service requires login");
}
/*
* run a command in a separate process
*/
int
asproc(void (*f)(char*, int), char *arg, int arg2)
{
int i;
if(pid){
/* wait for previous command to finish */
for(;;){
i = waitpid();
if(i == pid || i < 0)
break;
}
}
switch(pid = rfork(RFFDG|RFPROC|RFNOTEG)){
case -1:
return reply("450 Out of processes: %r");
case 0:
(*f)(arg, arg2);
exits(0);
default:
break;
}
return 0;
}
/*
* run a command to filter a tail
*/
int
transfer(char *cmd, char *a1, char *a2, char *a3, int image)
{
int n, dfd, fd, bytes, eofs, pid;
int pfd[2];
char buf[Nbuf], *p;
Waitmsg *w;
reply("150 Opening data connection for %s (%s)", cmd, data);
dfd = dialdata();
if(dfd < 0)
return reply("425 Error opening data connection: %r");
if(pipe(pfd) < 0)
return reply("520 Internal Error: %r");
bytes = 0;
switch(pid = rfork(RFFDG|RFPROC|RFNAMEG)){
case -1:
return reply("450 Out of processes: %r");
case 0:
logit("running %s %s %s %s pid %d",
cmd, a1?a1:"", a2?a2:"" , a3?a3:"",getpid());
close(pfd[1]);
close(dfd);
dup(pfd[0], 1);
dup(pfd[0], 2);
if(isnone){
fd = open("#s/boot", ORDWR);
if(fd < 0
|| bind("#/", "/", MAFTER) < 0
|| amount(fd, "/bin", MREPL, "") < 0
|| bind("#c", "/dev", MAFTER) < 0
|| bind(bindir, "/bin", MREPL) < 0)
exits("building name space");
close(fd);
}
execl(cmd, cmd, a1, a2, a3, nil);
exits(cmd);
default:
close(pfd[0]);
eofs = 0;
while((n = read(pfd[1], buf, sizeof buf)) >= 0){
if(n == 0){
if(eofs++ > 5)
break;
else
continue;
}
eofs = 0;
p = buf;
if(offset > 0){
if(n > offset){
p = buf+offset;
n -= offset;
offset = 0;
} else {
offset -= n;
continue;
}
}
if(!image)
n = crlfwrite(dfd, p, n);
else
n = write(dfd, p, n);
if(n < 0){
postnote(PNPROC, pid, "kill");
bytes = -1;
break;
}
bytes += n;
}
close(pfd[1]);
close(dfd);
break;
}
/* wait for this command to finish */
for(;;){
w = wait();
if(w == nil || w->pid == pid)
break;
free(w);
}
if(w != nil && w->msg != nil && w->msg[0] != 0){
bytes = -1;
logit("%s", w->msg);
logit("%s %s %s %s failed %s", cmd, a1?a1:"", a2?a2:"" , a3?a3:"", w->msg);
}
free(w);
reply("226 Transfer complete");
return bytes;
}
int
optscmd(char *arg)
{
char *p;
if(arg == 0 || *arg == 0){
reply("501 Syntax error in parameters or arguments");
return 0;
}
if(p = strchr(arg, ' '))
*p = 0;
if(cistrcmp(arg, "UTF-8") == 0 || cistrcmp(arg, "UTF8") == 0){
reply("200 Command okay");
return 0;
}
reply("502 %s option not implemented", arg);
return 0;
}
/*
* just reply OK
*/
int
nopcmd(char *arg)
{
USED(arg);
reply("510 Plan 9 FTP daemon still alive");
return 0;
}
/*
* login as user
*/
int
loginuser(char *user, char *nsfile, int gotoslash)
{
logit("login %s %s %s %s", user, mailaddr, nci->rsys, nsfile);
if(nsfile != nil && newns(user, nsfile) < 0){
logit("namespace file %s does not exist", nsfile);
return reply("530 Not logged in: login out of service");
}
getwd(curdir, sizeof(curdir));
if(gotoslash){
chdir("/");
strcpy(curdir, "/");
}
putenv("service", "ftp");
loggedin = 1;
if(debug == 0)
reply("230- If you have problems, send mail to 'postmaster'.");
return reply("230 Logged in");
}
static void
slowdown(void)
{
static ulong pause;
if (pause) {
sleep(pause); /* deter guessers */
if (pause < (1UL << 20))
pause *= 2;
} else
pause = 1000;
}
/*
* get a user id, reply with a challenge. The users 'anonymous'
* and 'ftp' are equivalent to 'none'. The user 'none' requires
* no challenge.
*/
int
usercmd(char *name)
{
slowdown();
logit("user %s %s", name, nci->rsys);
if(loggedin)
return reply("530 Already logged in as %s", user);
if(name == 0 || *name == 0)
return reply("530 user command needs user name");
isnoworld = 0;
if(*name == ':'){
debug = 1;
name++;
}
strncpy(user, name, sizeof(user));
if(debug)
logit("debugging");
user[sizeof(user)-1] = 0;
if(strcmp(user, "anonymous") == 0 || strcmp(user, "ftp") == 0)
strcpy(user, "none");
else if(anon_everybody)
strcpy(user,"none");
if(strcmp(user, "Administrator") == 0 || strcmp(user, "admin") == 0)
return reply("530 go away, script kiddie");
else if(strcmp(user, "*none") == 0){
if(!anon_ok)
return reply("530 Not logged in: anonymous disallowed");
return loginuser("none", namespace, 1);
}
else if(strcmp(user, "none") == 0){
if(!anon_ok)
return reply("530 Not logged in: anonymous disallowed");
return reply("331 Send email address as password");
}
else if(anon_only)
return reply("530 Not logged in: anonymous access only");
isnoworld = noworld(name);
if(isnoworld)
return reply("331 OK");
/* consult the auth server */
if(ch)
auth_freechal(ch);
if((ch = auth_challenge("proto=p9cr role=server user=%q", user)) == nil)
return reply("421 %r");
return reply("331 encrypt challenge, %s, as a password", ch->chal);
}
/*
* get a password, set up user if it works.
*/
int
passcmd(char *response)
{
char namefile[128];
AuthInfo *ai;
if(response == nil)
response = "";
if(strcmp(user, "none") == 0 || strcmp(user, "*none") == 0){
/* for none, accept anything as a password */
isnone = 1;
strncpy(mailaddr, response, sizeof(mailaddr)-1);
return loginuser("none", namespace, 1);
}
if(isnoworld){
/* noworld gets a password in the clear */
if(login(user, response, "/lib/namespace.noworld") < 0)
return reply("530 Not logged in");
createperm = 0664;
/* login has already setup the namespace */
return loginuser(user, nil, 0);
} else {
/* for everyone else, do challenge response */
if(ch == nil)
return reply("531 Send user id before encrypted challenge");
ch->resp = response;
ch->nresp = strlen(response);
ai = auth_response(ch);
if(ai == nil || auth_chuid(ai, nil) < 0) {
slowdown();
return reply("530 Not logged in: %r");
}
auth_freechal(ch);
ch = nil;
/* if the user has specified a namespace for ftp, use it */
snprint(namefile, sizeof(namefile), "/usr/%s/lib/namespace.ftp", user);
strcpy(mailaddr, user);
createperm = 0660;
if(access(namefile, 0) == 0)
return loginuser(user, namefile, 0);
else
return loginuser(user, "/lib/namespace", 0);
}
}
/*
* print working directory
*/
int
pwdcmd(char *arg)
{
if(arg)
return reply("550 Pwd takes no argument");
return reply("257 \"%s\" is the current directory", curdir);
}
/*
* chdir
*/
int
cwdcmd(char *dir)
{
char *rp;
char buf[Maxpath];
/* shell cd semantics */
if(dir == 0 || *dir == 0){
if(isnone)
rp = "/";
else {
snprint(buf, sizeof buf, "/usr/%s", user);
rp = buf;
}
if(accessok(rp) == 0)
rp = nil;
} else
rp = abspath(dir);
if(rp == nil)
return reply("550 Permission denied");
if(chdir(rp) < 0)
return reply("550 Cwd failed: %r");
strcpy(curdir, rp);
return reply("250 directory changed to %s", curdir);
}
/*
* chdir ..
*/
int
cdupcmd(char *dp)
{
USED(dp);
return cwdcmd("..");
}
int
quitcmd(char *arg)
{
USED(arg);
reply("200 Bye");
if(pid)
postnote(PNPROC, pid, "kill");
return -1;
}
int
typecmd(char *arg)
{
int c;
char *x;
x = arg;
if(arg == 0)
return reply("501 Type command needs arguments");
while(c = *arg++){
switch(tolower(c)){
case 'a':
type = Tascii;
break;
case 'i':
case 'l':
type = Timage;
break;
case '8':
case ' ':
case 'n':
case 't':
case 'c':
break;
default:
return reply("501 Unimplemented type %s", x);
}
}
return reply("200 Type %s", type==Tascii ? "Ascii" : "Image");
}
int
modecmd(char *arg)
{
if(arg == 0)
return reply("501 Mode command needs arguments");
while(*arg){
switch(tolower(*arg)){
case 's':
mode = Mstream;
break;
default:
return reply("501 Unimplemented mode %c", *arg);
}
arg++;
}
return reply("200 Stream mode");
}
int
structcmd(char *arg)
{
if(arg == 0)
return reply("501 Struct command needs arguments");
for(; *arg; arg++){
switch(tolower(*arg)){
case 'f':
structure = Sfile;
break;
default:
return reply("501 Unimplemented structure %c", *arg);
}
}
return reply("200 File structure");
}
int
portcmd(char *arg)
{
char *field[7];
int n;
if(arg == 0)
return reply("501 Port command needs arguments");
n = getfields(arg, field, 7, 0, ", ");
if(n != 6)
return reply("501 Incorrect port specification");
snprint(data, sizeof data, "tcp!%.3s.%.3s.%.3s.%.3s!%d", field[0], field[1], field[2],
field[3], atoi(field[4])*256 + atoi(field[5]));
return reply("200 Data port is %s", data);
}
int
mountnet(void)
{
int rv;
rv = 0;
if(bind("#/", "/", MAFTER) < 0){
logit("can't bind #/ to /: %r");
return reply("500 can't bind #/ to /: %r");
}
if(bind(nci->spec, "/net", MBEFORE) < 0){
logit("can't bind %s to /net: %r", nci->spec);
rv = reply("500 can't bind %s to /net: %r", nci->spec);
unmount("#/", "/");
}
return rv;
}
void
unmountnet(void)
{
unmount(0, "/net");
unmount("#/", "/");
}
int
pasvcmd(char *arg)
{
NetConnInfo *nnci;
Passive *p;
USED(arg);
p = &passive;
if(p->inuse){
close(p->afd);
p->inuse = 0;
}
if(mountnet() < 0)
return 0;
p->afd = announce("tcp!*!0", passive.adir);
if(p->afd < 0){
unmountnet();
return reply("500 No free ports");
}
nnci = getnetconninfo(p->adir, -1);
unmountnet();
/* parse the local address */
if(debug)
logit("local sys is %s", nci->lsys);
parseip(p->ipaddr, nci->lsys);
if(ipcmp(p->ipaddr, v4prefix) == 0 || ipcmp(p->ipaddr, IPnoaddr) == 0)
parseip(p->ipaddr, nci->lsys);
p->port = atoi(nnci->lserv);
freenetconninfo(nnci);
p->inuse = 1;
return reply("227 Entering Passive Mode (%d,%d,%d,%d,%d,%d)",
p->ipaddr[IPv4off+0], p->ipaddr[IPv4off+1], p->ipaddr[IPv4off+2], p->ipaddr[IPv4off+3],
p->port>>8, p->port&0xff);
}
enum
{
Narg=32,
};
int Cflag, rflag, tflag, Rflag;
int maxnamelen;
int col;
char*
mode2asc(int m)
{
static char asc[12];
char *p;
strcpy(asc, "----------");
if(DMDIR & m)
asc[0] = 'd';
if(DMAPPEND & m)
asc[0] = 'a';
else if(DMEXCL & m)
asc[3] = 'l';
for(p = asc+1; p < asc + 10; p += 3, m<<=3){
if(m & 0400)
p[0] = 'r';
if(m & 0200)
p[1] = 'w';
if(m & 0100)
p[2] = 'x';
}
return asc;
}
void
listfile(Biobufhdr *b, char *name, int lflag, char *dname)
{
char ts[32];
int n, links, pad;
long now;
char *x;
Dir *d;
x = abspath(name);
if(x == nil)
return;
d = dirstat(x);
if(d == nil)
return;
if(isnone){
if(strncmp(x, "/incoming/", sizeof("/incoming/")-1) != 0)
d->mode &= ~0222;
d->uid = "none";
d->gid = "none";
}
strcpy(ts, ctime(d->mtime));
ts[16] = 0;
now = time(0);
if(now - d->mtime > 6*30*24*60*60)
memmove(ts+11, ts+23, 5);
if(lflag){
/* Unix style long listing */
if(DMDIR&d->mode){
links = 2;
d->length = 512;
} else
links = 1;
Bprint(b, "%s %3d %-8s %-8s %7lld %s ",
mode2asc(d->mode), links,
d->uid, d->gid, d->length, ts+4);
}
if(Cflag && maxnamelen < 40){
n = strlen(name);
pad = ((col+maxnamelen)/(maxnamelen+1))*(maxnamelen+1);
if(pad+maxnamelen+1 < 60){
Bprint(b, "%*s", pad-col+n, name);
col = pad+n;
}
else{
Bprint(b, "\r\n%s", name);
col = n;
}
}
else{
if(dname)
Bprint(b, "%s/", dname);
Bprint(b, "%s\r\n", name);
}
free(d);
}
int
dircomp(void *va, void *vb)
{
int rv;
Dir *a, *b;
a = va;
b = vb;
if(tflag)
rv = b->mtime - a->mtime;
else
rv = strcmp(a->name, b->name);
return (rflag?-1:1)*rv;
}
void
listdir(char *name, Biobufhdr *b, int lflag, int *printname, Globlist *gl)
{
Dir *p;
int fd, n, i, l;
char *dname;
uvlong total;
col = 0;
fd = open(name, OREAD);
if(fd < 0){
Bprint(b, "can't read %s: %r\r\n", name);
return;
}
dname = 0;
if(*printname){
if(Rflag || lflag)
Bprint(b, "\r\n%s:\r\n", name);
else
dname = name;
}
n = dirreadall(fd, &p);
close(fd);
if(Cflag){
for(i = 0; i < n; i++){
l = strlen(p[i].name);
if(l > maxnamelen)
maxnamelen = l;
}
}
/* Unix style total line */
if(lflag){
total = 0;
for(i = 0; i < n; i++){
if(p[i].qid.type & QTDIR)
total += 512;
else
total += p[i].length;
}
Bprint(b, "total %ulld\r\n", total/512);
}
qsort(p, n, sizeof(Dir), dircomp);
for(i = 0; i < n; i++){
if(Rflag && (p[i].qid.type & QTDIR)){
*printname = 1;
globadd(gl, name, p[i].name);
}
listfile(b, p[i].name, lflag, dname);
}
free(p);
}
void
list(char *arg, int lflag)
{
Dir *d;
Globlist *gl;
Glob *g;
int dfd, printname;
int i, n, argc;
char *alist[Narg];
char **argv;
Biobufhdr bh;
uchar buf[512];
char *p, *s;
if(arg == 0)
arg = "";
if(debug)
logit("ls %s (. = %s)", arg, curdir);
/* process arguments, understand /bin/ls -l option */
argv = alist;
argv[0] = "/bin/ls";
argc = getfields(arg, argv+1, Narg-2, 1, " \t") + 1;
argv[argc] = 0;
rflag = 0;
tflag = 0;
Rflag = 0;
Cflag = 0;
col = 0;
ARGBEGIN{
case 'l':
lflag++;
break;
case 'R':
Rflag++;
break;
case 'C':
Cflag++;
break;
case 'r':
rflag++;
break;
case 't':
tflag++;
break;
}ARGEND;
if(Cflag)
lflag = 0;
dfd = dialdata();
if(dfd < 0){
reply("425 Error opening data connection: %r");
return;
}
reply("150 Opened data connection (%s)", data);
Binits(&bh, dfd, OWRITE, buf, sizeof(buf));
if(argc == 0){
argc = 1;
argv = alist;
argv[0] = ".";
}
for(i = 0; i < argc; i++){
chdir(curdir);
gl = glob(argv[i]);
if(gl == nil)
continue;
printname = gl->first != nil && gl->first->next != nil;
maxnamelen = 8;
if(Cflag)
for(g = gl->first; g; g = g->next)
if(g->glob && (n = strlen(s_to_c(g->glob))) > maxnamelen)
maxnamelen = n;
while(s = globiter(gl)){
if(debug)
logit("glob %s", s);
p = abspath(s);
if(p == nil){
free(s);
continue;
}
d = dirstat(p);
if(d == nil){
free(s);
continue;
}
if(d->qid.type & QTDIR)
listdir(s, &bh, lflag, &printname, gl);
else
listfile(&bh, s, lflag, 0);
free(s);
free(d);
}
globlistfree(gl);
}
if(Cflag)
Bprint(&bh, "\r\n");
Bflush(&bh);
close(dfd);
reply("226 Transfer complete (list %s)", arg);
}
int
namelistcmd(char *arg)
{
return asproc(list, arg, 0);
}
int
listcmd(char *arg)
{
return asproc(list, arg, 1);
}
/*
* fuse compatability
*/
int
oksiteuser(void)
{
char buf[64];
int fd, n;
fd = open("#c/user", OREAD);
if(fd < 0)
return 1;
n = read(fd, buf, sizeof buf - 1);
if(n > 0){
buf[n] = 0;
if(strcmp(buf, "none") == 0)
n = -1;
}
close(fd);
return n > 0;
}
int
sitecmd(char *arg)
{
char *f[4];
int nf, r;
Dir *d;
if(arg == 0)
return reply("501 bad site command");
nf = tokenize(arg, f, nelem(f));
if(nf != 3 || cistrcmp(f[0], "chmod") != 0)
return reply("501 bad site command");
if(!oksiteuser())
return reply("550 Permission denied");
d = dirstat(f[2]);
if(d == nil)
return reply("501 site chmod: file does not exist");
d->mode &= ~0777;
d->mode |= strtoul(f[1], 0, 8) & 0777;
r = dirwstat(f[2], d);
free(d);
if(r < 0)
return reply("550 Permission denied %r");
return reply("200 very well, then");
}
/*
* return the size of the file
*/
int
sizecmd(char *arg)
{
Dir *d;
int rv;
if(arg == 0)
return reply("501 Size command requires pathname");
arg = abspath(arg);
d = dirstat(arg);
if(d == nil)
return reply("501 %r accessing %s", arg);
rv = reply("213 %lld", d->length);
free(d);
return rv;
}
/*
* return the modify time of the file
*/
int
mdtmcmd(char *arg)
{
Dir *d;
Tm *t;
int rv;
if(arg == 0)
return reply("501 Mdtm command requires pathname");
if(arg == 0)
return reply("550 Permission denied");
d = dirstat(arg);
if(d == nil)
return reply("501 %r accessing %s", arg);
t = gmtime(d->mtime);
rv = reply("213 %4.4d%2.2d%2.2d%2.2d%2.2d%2.2d",
t->year+1900, t->mon+1, t->mday,
t->hour, t->min, t->sec);
free(d);
return rv;
}
/*
* set an offset to start reading a file from
* only lasts for one command
*/
int
restartcmd(char *arg)
{
if(arg == 0)
return reply("501 Restart command requires offset");
offset = atoll(arg);
if(offset < 0){
offset = 0;
return reply("501 Bad offset");
}
return reply("350 Restarting at %lld. Send STORE or RETRIEVE", offset);
}
/*
* send a file to the user
*/
int
crlfwrite(int fd, char *p, int n)
{
char *ep, *np;
char buf[2*Nbuf];
for(np = buf, ep = p + n; p < ep; p++){
if(*p == '\n')
*np++ = '\r';
*np++ = *p;
}
if(write(fd, buf, np - buf) == np - buf)
return n;
else
return -1;
}
void
retrievedir(char *arg)
{
int n;
char *p;
String *file;
if(type != Timage){
reply("550 This file requires type binary/image");
return;
}
file = s_copy(arg);
p = strrchr(s_to_c(file), '/');
if(p != s_to_c(file)){
*p++ = 0;
chdir(s_to_c(file));
} else {
chdir("/");
p = s_to_c(file)+1;
}
n = transfer("/bin/tar", "c", p, 0, 1);
if(n < 0)
logit("get %s failed", arg);
else
logit("get %s OK %d", arg, n);
s_free(file);
}
void
retrieve(char *arg, int arg2)
{
int dfd, fd, n, i, bytes;
Dir *d;
char buf[Nbuf];
char *p, *ep;
USED(arg2);
p = strchr(arg, '\r');
if(p){
logit("cr in file name", arg);
*p = 0;
}
fd = open(arg, OREAD);
if(fd == -1){
n = strlen(arg);
if(n > 4 && strcmp(arg+n-4, ".tar") == 0){
*(arg+n-4) = 0;
d = dirstat(arg);
if(d != nil){
if(d->qid.type & QTDIR){
retrievedir(arg);
free(d);
return;
}
free(d);
}
}
logit("get %s failed", arg);
reply("550 Error opening %s: %r", arg);
return;
}
if(offset != 0)
if(seek(fd, offset, 0) < 0){
reply("550 %s: seek to %lld failed", arg, offset);
close(fd);
return;
}
d = dirfstat(fd);
if(d != nil){
if(d->qid.type & QTDIR){
reply("550 %s: not a plain file.", arg);
close(fd);
free(d);
return;
}
free(d);
}
n = read(fd, buf, sizeof(buf));
if(n < 0){
logit("get %s failed", arg, mailaddr, nci->rsys);
reply("550 Error reading %s: %r", arg);
close(fd);
return;
}
if(type != Timage)
for(p = buf, ep = &buf[n]; p < ep; p++)
if(*p & 0x80){
close(fd);
reply("550 This file requires type binary/image");
return;
}
reply("150 Opening data connection for %s (%s)", arg, data);
dfd = dialdata();
if(dfd < 0){
reply("425 Error opening data connection: %r");
close(fd);
return;
}
bytes = 0;
do {
switch(type){
case Timage:
i = write(dfd, buf, n);
break;
default:
i = crlfwrite(dfd, buf, n);
break;
}
if(i != n){
close(fd);
close(dfd);
logit("get %s %r to data connection after %d", arg, bytes);
reply("550 Error writing to data connection: %r");
return;
}
bytes += n;
} while((n = read(fd, buf, sizeof(buf))) > 0);
if(n < 0)
logit("get %s %r after %d", arg, bytes);
close(fd);
close(dfd);
reply("226 Transfer complete");
logit("get %s OK %d", arg, bytes);
}
int
retrievecmd(char *arg)
{
if(arg == 0)
return reply("501 Retrieve command requires an argument");
arg = abspath(arg);
if(arg == 0)
return reply("550 Permission denied");
return asproc(retrieve, arg, 0);
}
/*
* get a file from the user
*/
int
lfwrite(int fd, char *p, int n)
{
char *ep, *np;
char buf[Nbuf];
for(np = buf, ep = p + n; p < ep; p++){
if(*p != '\r')
*np++ = *p;
}
if(write(fd, buf, np - buf) == np - buf)
return n;
else
return -1;
}
void
store(char *arg, int fd)
{
int dfd, n, i;
char buf[Nbuf];
reply("150 Opening data connection for %s (%s)", arg, data);
dfd = dialdata();
if(dfd < 0){
reply("425 Error opening data connection: %r");
close(fd);
return;
}
while((n = read(dfd, buf, sizeof(buf))) > 0){
switch(type){
case Timage:
i = write(fd, buf, n);
break;
default:
i = lfwrite(fd, buf, n);
break;
}
if(i != n){
close(fd);
close(dfd);
reply("550 Error writing file");
return;
}
}
close(fd);
close(dfd);
logit("put %s OK", arg);
reply("226 Transfer complete");
}
int
storecmd(char *arg)
{
int fd, rv;
if(arg == 0)
return reply("501 Store command requires an argument");
arg = abspath(arg);
if(arg == 0)
return reply("550 Permission denied");
if(isnone && strncmp(arg, "/incoming/", sizeof("/incoming/")-1))
return reply("550 Permission denied");
if(offset){
fd = open(arg, OWRITE);
if(fd == -1)
return reply("550 Error opening %s: %r", arg);
if(seek(fd, offset, 0) == -1)
return reply("550 Error seeking %s to %d: %r",
arg, offset);
} else {
fd = create(arg, OWRITE, createperm);
if(fd == -1)
return reply("550 Error creating %s: %r", arg);
}
rv = asproc(store, arg, fd);
close(fd);
return rv;
}
int
appendcmd(char *arg)
{
int fd, rv;
if(arg == 0)
return reply("501 Append command requires an argument");
if(isnone)
return reply("550 Permission denied");
arg = abspath(arg);
if(arg == 0)
return reply("550 Error creating %s: Permission denied", arg);
fd = open(arg, OWRITE);
if(fd == -1){
fd = create(arg, OWRITE, createperm);
if(fd == -1)
return reply("550 Error creating %s: %r", arg);
}
seek(fd, 0, 2);
rv = asproc(store, arg, fd);
close(fd);
return rv;
}
int
storeucmd(char *arg)
{
int fd, rv;
char name[Maxpath];
USED(arg);
if(isnone)
return reply("550 Permission denied");
strncpy(name, "ftpXXXXXXXXXXX", sizeof name);
mktemp(name);
fd = create(name, OWRITE, createperm);
if(fd == -1)
return reply("550 Error creating %s: %r", name);
rv = asproc(store, name, fd);
close(fd);
return rv;
}
int
mkdircmd(char *name)
{
int fd;
if(name == 0)
return reply("501 Mkdir command requires an argument");
if(isnone)
return reply("550 Permission denied");
name = abspath(name);
if(name == 0)
return reply("550 Permission denied");
fd = create(name, OREAD, DMDIR|0775);
if(fd < 0)
return reply("550 Can't create %s: %r", name);
close(fd);
return reply("226 %s created", name);
}
int
delcmd(char *name)
{
if(name == 0)
return reply("501 Rmdir/delete command requires an argument");
if(isnone)
return reply("550 Permission denied");
name = abspath(name);
if(name == 0)
return reply("550 Permission denied");
if(remove(name) < 0)
return reply("550 Can't remove %s: %r", name);
else
return reply("226 %s removed", name);
}
/*
* kill off the last transfer (if the process still exists)
*/
int
abortcmd(char *arg)
{
USED(arg);
logit("abort pid %d", pid);
if(pid){
if(postnote(PNPROC, pid, "kill") == 0)
reply("426 Command aborted");
else
logit("postnote pid %d %r", pid);
}
return reply("226 Abort processed");
}
int
systemcmd(char *arg)
{
USED(arg);
return reply("215 UNIX Type: L8 Version: Plan 9");
}
int
helpcmd(char *arg)
{
int i;
char buf[80];
char *p, *e;
USED(arg);
reply("214- the following commands are implemented:");
buf[0] = 0;
p = buf;
e = buf+sizeof buf;
for(i = 0; cmdtab[i].name; i++){
if((i%8) == 0){
reply("214-%s", buf);
p = buf;
}
p = seprint(p, e, " %-5.5s", cmdtab[i].name);
}
if(p != buf)
reply("214-%s", buf);
reply("214 ");
return 0;
}
/*
* renaming a file takes two commands
*/
static String *filepath;
int
rnfrcmd(char *from)
{
if(isnone)
return reply("550 Permission denied");
if(from == 0)
return reply("501 Rename command requires an argument");
from = abspath(from);
if(from == 0)
return reply("550 Permission denied");
if(filepath == nil)
filepath = s_copy(from);
else{
s_reset(filepath);
s_append(filepath, from);
}
return reply("350 Rename %s to ...", s_to_c(filepath));
}
int
rntocmd(char *to)
{
int r;
Dir nd;
char *fp, *tp;
if(isnone)
return reply("550 Permission denied");
if(to == 0)
return reply("501 Rename command requires an argument");
to = abspath(to);
if(to == 0)
return reply("550 Permission denied");
if(filepath == nil || *(s_to_c(filepath)) == 0)
return reply("503 Rnto must be preceeded by an rnfr");
tp = strrchr(to, '/');
fp = strrchr(s_to_c(filepath), '/');
if((tp && fp == 0) || (fp && tp == 0)
|| (fp && tp && (fp-s_to_c(filepath) != tp-to || memcmp(s_to_c(filepath), to, tp-to))))
return reply("550 Rename can't change directory");
if(tp)
to = tp+1;
nulldir(&nd);
nd.name = to;
if(dirwstat(s_to_c(filepath), &nd) < 0)
r = reply("550 Can't rename %s to %s: %r\n", s_to_c(filepath), to);
else
r = reply("250 %s now %s", s_to_c(filepath), to);
s_reset(filepath);
return r;
}
/*
* to dial out we need the network file system in our
* name space.
*/
int
dialdata(void)
{
int fd, cfd;
char ldir[40];
char err[ERRMAX];
if(mountnet() < 0)
return -1;
if(!passive.inuse)
fd = dial(data, "20", 0, 0);
else {
fd = -1;
alarm(5*60*1000);
cfd = listen(passive.adir, ldir);
alarm(0);
if(cfd >= 0){
fd = accept(cfd, ldir);
close(cfd);
}
}
err[0] = 0;
errstr(err, sizeof err);
if(fd < 0)
logit("can't dial %s: %s", data, err);
unmountnet();
errstr(err, sizeof err);
return fd;
}
int
postnote(int group, int pid, char *note)
{
char file[128];
int f, r;
/*
* Use #p because /proc may not be in the namespace.
*/
switch(group) {
case PNPROC:
sprint(file, "#p/%d/note", pid);
break;
case PNGROUP:
sprint(file, "#p/%d/notepg", pid);
break;
default:
return -1;
}
f = open(file, OWRITE);
if(f < 0)
return -1;
r = strlen(note);
if(write(f, note, r) != r) {
close(f);
return -1;
}
close(f);
return 0;
}
/*
* to circumscribe the accessible files we have to eliminate ..'s
* and resolve all names from the root. We also remove any /bin/rc
* special characters to avoid later problems with executed commands.
*/
char *special = "`;| ";
char*
abspath(char *origpath)
{
char *p, *sp, *path;
static String *rpath;
if(rpath == nil)
rpath = s_new();
else
s_reset(rpath);
if(origpath == nil)
s_append(rpath, curdir);
else{
if(*origpath != '/'){
s_append(rpath, curdir);
s_append(rpath, "/");
}
s_append(rpath, origpath);
}
path = s_to_c(rpath);
for(sp = special; *sp; sp++){
p = strchr(path, *sp);
if(p)
*p = 0;
}
cleanname(s_to_c(rpath));
rpath->ptr = rpath->base+strlen(rpath->base);
if(!accessok(s_to_c(rpath)))
return nil;
return s_to_c(rpath);
}
typedef struct Path Path;
struct Path {
Path *next;
String *path;
int inuse;
int ok;
};
enum
{
Maxlevel = 16,
Maxperlevel= 8,
};
Path *pathlevel[Maxlevel];
Path*
unlinkpath(char *path, int level)
{
String *s;
Path **l, *p;
int n;
n = 0;
for(l = &pathlevel[level]; *l; l = &(*l)->next){
p = *l;
/* hit */
if(strcmp(s_to_c(p->path), path) == 0){
*l = p->next;
p->next = nil;
return p;
}
/* reuse */
if(++n >= Maxperlevel){
*l = p->next;
s = p->path;
s_reset(p->path);
memset(p, 0, sizeof *p);
p->path = s_append(s, path);
return p;
}
}
/* allocate */
p = mallocz(sizeof *p, 1);
p->path = s_copy(path);
return p;
}
void
linkpath(Path *p, int level)
{
p->next = pathlevel[level];
pathlevel[level] = p;
p->inuse = 1;
}
void
addpath(Path *p, int level, int ok)
{
p->ok = ok;
p->next = pathlevel[level];
pathlevel[level] = p;
}
int
_accessok(String *s, int level)
{
Path *p;
char *cp;
int lvl, offset;
static char httplogin[] = "/.httplogin";
if(level < 0)
return 1;
lvl = level;
if(lvl >= Maxlevel)
lvl = Maxlevel - 1;
p = unlinkpath(s_to_c(s), lvl);
if(p->inuse){
/* move to front */
linkpath(p, lvl);
return p->ok;
}
cp = strrchr(s_to_c(s), '/');
if(cp == nil)
offset = 0;
else
offset = cp - s_to_c(s);
s_append(s, httplogin);
if(access(s_to_c(s), AEXIST) == 0){
addpath(p, lvl, 0);
return 0;
}
/*
* There's no way to shorten a String without
* knowing the implementation.
*/
s->ptr = s->base+offset;
s_terminate(s);
addpath(p, lvl, _accessok(s, level-1));
return p->ok;
}
/*
* check for a subdirectory containing .httplogin
* at each level of the path.
*/
int
accessok(char *path)
{
int level, r;
char *p;
String *npath;
npath = s_copy(path);
p = s_to_c(npath)+1;
for(level = 1; level < Maxlevel; level++){
p = strchr(p, '/');
if(p == nil)
break;
p++;
}
r = _accessok(npath, level-1);
s_free(npath);
return r;
}