home *** CD-ROM | disk | FTP | other *** search
- /* FTP Server state machine - see RFC 959 */
-
- #define LINELEN 128 /* Length of command buffer */
-
- #include <stdio.h>
- #include <stdlib.h>
- #include <string.h>
- #include <ctype.h>
- #include <time.h>
- #include "global.h"
- #include "mbuf.h"
- #include "netuser.h"
- #include "timer.h"
- #include "tcp.h"
- #include "ftp.h"
- #include "misc.h"
- #include "arc.h"
-
- static void ftpscs(struct tcb *, char, char);
- static void ftpscr(struct tcb *, int16);
- static void ftpcommand(struct ftp *);
- static int pport(struct socket *, char *);
- static void ftplogin(struct ftp *, char *);
-
-
- /* Command table */
- static char *commands[] = {
- "user",
- #define USER_CMD 0
- "acct",
- #define ACCT_CMD 1
- "pass",
- #define PASS_CMD 2
- "type",
- #define TYPE_CMD 3
- "list",
- #define LIST_CMD 4
- "cwd",
- #define CWD_CMD 5
- "dele",
- #define DELE_CMD 6
- "name",
- #define NAME_CMD 7
- "quit",
- #define QUIT_CMD 8
- "retr",
- #define RETR_CMD 9
- "stor",
- #define STOR_CMD 10
- "port",
- #define PORT_CMD 11
- "nlst",
- #define NLST_CMD 12
- "pwd",
- #define PWD_CMD 13
- "xpwd", /* For compatibility with 4.2BSD */
- #define XPWD_CMD 14
- "mkd ",
- #define MKD_CMD 15
- "xmkd", /* For compatibility with 4.2BSD */
- #define XMKD_CMD 16
- "xrmd", /* For compatibility with 4.2BSD */
- #define XRMD_CMD 17
- "rmd ",
- #define RMD_CMD 18
- "stru",
- #define STRU_CMD 19
- "mode",
- #define MODE_CMD 20
- NULLCHAR
- };
-
- /* Response messages */
- static char banner[] = "220 %s FTP server ready at %s\r\n";
- static char badcmd[] = "500 Unknown command\r\n";
- static char unsupp[] = "500 Unsupported command or option\r\n";
- static char givepass[] = "331 Enter PASS command\r\n";
- static char logged[] = "230 Logged in\r\n";
- static char loggeda[] = "230 Logged in as anonymous, restrictions apply\r\n";
- static char typeok[] = "200 Type OK\r\n";
- static char only8[] = "501 Only logical bytesize 8 supported\r\n";
- static char deleok[] = "250 File deleted\r\n";
- static char mkdok[] = "200 MKD ok\r\n";
- static char delefail[] = "550 Delete failed\r\n";
- static char pwdmsg[] = "257 \"%s\" is current directory\r\n";
- static char badtype[] = "501 Unknown type \"%s\"\r\n";
- static char badport[] = "501 Bad port syntax\r\n";
- static char unimp[] = "502 Command not yet implemented\r\n";
- static char bye[] = "221 Goodbye!\r\n";
- static char nodir[] = "553 Can't read directory \"%s\"\r\n";
- static char cantopen[] = "550 Can't read file \"%s\"\r\n";
- static char sending[] = "150 Opening data connection for %s %s\r\n";
- static char cantmake[] = "553 Can't create \"%s\"\r\n";
- static char portok[] = "200 Port command okay\r\n";
- static char rxok[] = "226 File received OK\r\n";
- static char txok[] = "226 File sent OK\r\n";
- static char noperm[] = "550 Permission denied\r\n";
- static char noconn[] = "425 Data connection reset\r\n";
- static char notlog[] = "530 Please log in with USER and PASS\r\n";
- static char okay[] = "200 Ok\r\n";
-
- static struct tcb *ftp_tcb;
-
- /* Start up FTP service */
- int ftp1(int argc, char **argv)
- {
- struct socket lsocket;
-
- argc = argc;
- argv = argv;
-
- lsocket.address = ip_addr;
- lsocket.port = FTP_PORT;
-
- ftp_tcb = open_tcp(&lsocket,NULLSOCK,TCP_SERVER,0,(void(*)())ftpscr,NULLVFP,(void(*)())ftpscs,0,(char *)NULL);
- return(0);
- }
-
- /* Shut down FTP server */
- int ftp0(void)
- {
- if(ftp_tcb != NULLTCB)
- close_tcp(ftp_tcb);
- return(0);
- }
- /* FTP Server Control channel State change upcall handler */
- static void ftpscs(struct tcb *tcb, char old, char new)
- {
- extern char hostname[];
- struct ftp *ftp;
- time_t t;
- char *cp,*cp1;
-
- old = old;
-
- switch(new){
- /* Setting QUICKSTART piggybacks the server's banner on the SYN/ACK segment;
- * leaving it unset waits for the three-way handshake to complete before
- * sending the banner. Piggybacking unfortunately breaks some old TCPs,
- * so its use is not (yet) recommended.
- */
- #ifdef QUICKSTART
- case SYN_RECEIVED:
- #else
- case ESTABLISHED:
- #endif
- if((ftp = ftp_create(LINELEN)) == NULLFTP){
- /* No space, kill connection */
- close_tcp(tcb);
- return;
- }
- ftp->control = tcb; /* Downward link */
- tcb->user = (char *)ftp; /* Upward link */
-
- /* Set default data port */
- ftp->port.address = tcb->conn.remote.address;
- ftp->port.port = FTPD_PORT;
-
- /* Note current directory */
- time(&t);
- cp = ctime(&t);
- if((cp1 = strchr(cp,'\n')) != NULLCHAR)
- *cp1 = '\0';
- tprintf(ftp->control,banner,hostname,cp);
- break;
- case CLOSE_WAIT:
- close_tcp(tcb);
- break;
- case CLOSED:
- if((ftp = (struct ftp *)tcb->user) != NULLFTP)
- ftp_delete(ftp);
- /* Check if server is being shut down */
- if(tcb == ftp_tcb)
- ftp_tcb = NULLTCB;
- del_tcp(tcb);
- break;
- }
- }
-
- /* FTP Server Control channel Receiver upcall handler */
- static void ftpscr(struct tcb *tcb, int16 cnt)
- {
- register struct ftp *ftp;
- char c;
- struct mbuf *bp;
-
- cnt = cnt;
-
- if((ftp = (struct ftp *)tcb->user) == NULLFTP){
- /* Unknown connection, just kill it */
- close_tcp(tcb);
- return;
- }
- switch(ftp->state){
- case COMMAND_STATE:
- /* Assemble an input line in the session buffer. Return if incomplete */
- recv_tcp(tcb,&bp,0);
- while(pullup(&bp,&c,1) == 1){
- switch(c){
- case '\r': /* Strip cr's */
- continue;
- case '\n': /* Complete line; process it */
- ftp->buf[ftp->cnt] = '\0';
- ftpcommand(ftp);
- ftp->cnt = 0;
- break;
- default: /* Assemble line */
- if(ftp->cnt != LINELEN-1)
- ftp->buf[ftp->cnt++] = c;
- break;
- }
- }
- /* else no linefeed present yet to terminate command */
- break;
- case SENDING_FILE_STATE:
- case SENDING_DATA_STATE:
- case RECEIVING_STATE:
- /* Leave commands pending on receive queue until
- * present command is done
- */
- break;
- }
- }
-
- /* FTP server data channel connection state change upcall handler */
- void ftpsds(struct tcb *tcb, char old, char new)
- {
- register struct ftp *ftp;
-
- if((ftp = (struct ftp *)tcb->user) == NULLFTP){
- /* Unknown connection. Kill it */
- del_tcp(tcb);
- } else if((old == FINWAIT1 || old == CLOSING) && (ftp->state == SENDING_FILE_STATE || ftp->state == SENDING_DATA_STATE)){
- /* We've received an ack of our FIN while sending; we're done */
- ftp->state = COMMAND_STATE;
- tprintf(ftp->control,txok);
- /* Kick command parser if something is waiting */
- if(ftp->control->rcvcnt != 0)
- ftpscr(ftp->control,ftp->control->rcvcnt);
- } else if(ftp->state == RECEIVING_STATE && new == CLOSE_WAIT){
- /* FIN received on incoming file */
- close_tcp(tcb);
- if(ftp->fp != stdout)
- fclose(ftp->fp);
- ftp->fp = NULLFILE;
- ftp->state = COMMAND_STATE;
- tprintf(ftp->control,rxok);
- /* Kick command parser if something is waiting */
- if(ftp->control->rcvcnt != 0)
- ftpscr(ftp->control,ftp->control->rcvcnt);
- } else if(new == CLOSED){
- if(tcb->reason != NORMAL){
- /* Data connection was reset, complain about it */
- tprintf(ftp->control,noconn);
- /* And clean up */
- if(ftp->fp != NULLFILE && ftp->fp != stdout)
- fclose(ftp->fp);
- ftp->fp = NULLFILE;
- ftp->state = COMMAND_STATE;
- /* Kick command parser if something is waiting */
- if(ftp->control->rcvcnt != 0)
- ftpscr(ftp->control,ftp->control->rcvcnt);
- }
- /* Clear only if another transfer hasn't already started */
- if(ftp->data == tcb)
- ftp->data = NULLTCB;
- del_tcp(tcb);
- }
- }
-
- /* Parse and execute ftp commands */
- static void ftpcommand(register struct ftp *ftp)
- {
- char *cmd,*arg,*cp,**cmdp,*file;
- char *mode;
- struct socket dport;
- int i;
-
- cmd = ftp->buf;
- if(ftp->cnt == 0){
- /* Can't be a legal FTP command */
- tprintf(ftp->control,badcmd);
- return;
- }
- cmd = ftp->buf;
-
- /* Translate entire buffer to lower case */
- for(cp = cmd;*cp != '\0';cp++)
- *cp = tolower(*cp);
-
- /* Find command in table; if not present, return syntax error */
- for(cmdp = commands;*cmdp != NULLCHAR;cmdp++)
- if(strncmp(*cmdp,cmd,strlen(*cmdp)) == 0)
- break;
- if(*cmdp == NULLCHAR){
- tprintf(ftp->control,badcmd);
- return;
- }
- /* Allow only USER, PASS and QUIT before logging in */
- if(ftp->cd == NULLCHAR || ftp->path[0] == NULLCHAR){
- switch(cmdp-commands){
- case USER_CMD:
- case PASS_CMD:
- case QUIT_CMD:
- break;
- default:
- tprintf(ftp->control,notlog);
- return;
- }
- }
- arg = &cmd[strlen(*cmdp)];
- while(*arg == ' ')
- arg++;
-
- /* Execute specific command */
- switch(cmdp-commands){
- case USER_CMD:
- if((ftp->username = malloc((unsigned)strlen(arg)+1)) == NULLCHAR){
- close_tcp(ftp->control);
- break;
- }
- strcpy(ftp->username,arg);
- tprintf(ftp->control,givepass);
- /* erase all user info from possible previous session */
- for(i = 0; i < MAXPATH; i++){
- if(ftp->path[i] != NULLCHAR){
- free(ftp->path[i]);
- ftp->path[i] = NULLCHAR;
- }
- ftp->perms[i] = 0;
- }
- if(ftp->cd != NULLCHAR){
- free(ftp->cd);
- ftp->cd = NULLCHAR;
- }
- break;
- case TYPE_CMD:
- switch(arg[0]){
- case 'A':
- case 'a': /* Ascii */
- ftp->type = ASCII_TYPE;
- tprintf(ftp->control,typeok);
- break;
- case 'l':
- case 'L':
- while(*arg != ' ' && *arg != '\0')
- arg++;
- if(*arg == '\0' || *++arg != '8'){
- tprintf(ftp->control,only8);
- break;
- } /* Note fall-thru */
- case 'B':
- case 'b': /* Binary */
- case 'I':
- case 'i': /* Image */
- ftp->type = IMAGE_TYPE;
- tprintf(ftp->control,typeok);
- break;
- default: /* Invalid */
- tprintf(ftp->control,badtype,arg);
- break;
- }
- break;
- case QUIT_CMD:
- tprintf(ftp->control,bye);
- close_tcp(ftp->control);
- break;
- case RETR_CMD:
- /* Disk operation; return ACK now */
- tcp_output(ftp->control);
- file = pathname(ftp->cd,arg);
- if(ftp->type == IMAGE_TYPE)
- mode = "rb";
- else
- mode = "r";
- if(!permcheck(ftp,RETR_CMD,file)){
- tprintf(ftp->control,noperm);
- } else if((ftp->fp = fopen(file,mode)) == NULLFILE){
- tprintf(ftp->control,cantopen,file);
- } else {
- dport.address = ip_addr;
- dport.port = FTPD_PORT;
- ftp->state = SENDING_FILE_STATE;
- tprintf(ftp->control,sending,"RETR",arg);
- ftp->data = open_tcp(&dport,&ftp->port,TCP_ACTIVE,
- 0,NULLVFP,(void(*)())ftpdt,(void(*)())ftpsds,ftp->control->tos,(char *)ftp);
- }
- free(file);
- break;
- case STOR_CMD:
- /* Disk operation; return ACK now */
- tcp_output(ftp->control);
- file = pathname(ftp->cd,arg);
- if(ftp->type == IMAGE_TYPE)
- mode = "wb";
- else
- mode = "w";
- if(!permcheck(ftp,STOR_CMD,file)){
- tprintf(ftp->control,noperm);
- free(file);
- break;
- } else if((ftp->fp = fopen(file,mode)) == NULLFILE){
- tprintf(ftp->control,cantmake,file);
- } else {
- dport.address = ip_addr;
- dport.port = FTPD_PORT;
- ftp->state = RECEIVING_STATE;
- tprintf(ftp->control,sending,"STOR",arg);
- ftp->data = open_tcp(&dport,&ftp->port,TCP_ACTIVE,
- 0,(void(*)())ftpdr,NULLVFP,(void(*)())ftpsds,ftp->control->tos,(char *)ftp);
- }
- free(file);
- break;
- case PORT_CMD:
- if(pport(&ftp->port,arg) == -1){
- tprintf(ftp->control,badport);
- } else {
- tprintf(ftp->control,portok);
- }
- break;
- case LIST_CMD:
- /* Disk operation; return ACK now */
- tcp_output(ftp->control);
- file = pathname(ftp->cd,arg);
- if(!permcheck(ftp,RETR_CMD,file)){
- tprintf(ftp->control,noperm);
- } else if((ftp->p = dir(file,1)) == NULLCHAR){
- tprintf(ftp->control,nodir,file);
- } else {
- dport.address = ip_addr;
- dport.port = FTPD_PORT;
- ftp->state = SENDING_DATA_STATE;
- ftp->cp = ftp->p;
- tprintf(ftp->control,sending,"LIST",file);
- ftp->data = open_tcp(&dport,&ftp->port,TCP_ACTIVE,
- 0,NULLVFP,(void(*)())ftpdt,(void(*)())ftpsds,ftp->control->tos,(char *)ftp);
- }
- free(file);
- break;
- case NLST_CMD:
- /* Disk operation; return ACK now */
- tcp_output(ftp->control);
- file = pathname(ftp->cd,arg);
- if(!permcheck(ftp,RETR_CMD,file)){
- tprintf(ftp->control,noperm);
- } else if((ftp->p = dir(file,0)) == NULLCHAR){
- tprintf(ftp->control,nodir,file);
- } else {
- dport.address = ip_addr;
- dport.port = FTPD_PORT;
- ftp->state = SENDING_DATA_STATE;
- ftp->cp = ftp->p;
- tprintf(ftp->control,sending,"NLST",file);
- ftp->data = open_tcp(&dport,&ftp->port,TCP_ACTIVE,
- 0,NULLVFP,(void(*)())ftpdt,(void(*)())ftpsds,ftp->control->tos,(char *)ftp);
- }
- free(file);
- break;
- case CWD_CMD:
- tcp_output(ftp->control); /* Disk operation; return ACK now */
-
- file = pathname(ftp->cd,arg);
- if(!permcheck(ftp,RETR_CMD,file)){
- tprintf(ftp->control,noperm);
- free(file);
- } else if(access(file,0) == 0){ /* See if it exists */
- /* Succeeded, record in control block */
- free(ftp->cd);
- ftp->cd = file;
- tprintf(ftp->control,pwdmsg,file);
- } else {
- /* Failed, don't change anything */
- tprintf(ftp->control,nodir,file);
- free(file);
- }
- break;
- case XPWD_CMD:
- case PWD_CMD:
- tprintf(ftp->control,pwdmsg,ftp->cd);
- break;
- case ACCT_CMD:
- tprintf(ftp->control,unimp);
- break;
- case DELE_CMD:
- file = pathname(ftp->cd,arg);
- if(!permcheck(ftp,DELE_CMD,file)){
- tprintf(ftp->control,noperm);
- } else if(remove(file) == 0){
- tprintf(ftp->control,deleok);
- } else {
- tprintf(ftp->control,delefail);
- }
- free(file);
- break;
- case PASS_CMD:
- tcp_output(ftp->control); /* Send the ack now */
- ftplogin(ftp,arg);
- break;
- case XMKD_CMD:
- case MKD_CMD:
- file = pathname(ftp->cd,arg);
- if(!permcheck(ftp,MKD_CMD,file)){
- tprintf(ftp->control,noperm);
- } else if(mkdir(file) == 0){
- tprintf(ftp->control,mkdok);
- } else {
- tprintf(ftp->control,cantmake);
- }
- free(file);
- break;
- case XRMD_CMD:
- case RMD_CMD:
- file = pathname(ftp->cd,arg);
- if(!permcheck(ftp,RMD_CMD,file)){
- tprintf(ftp->control,noperm);
- } else if(rmdir(file) == 0){
- tprintf(ftp->control,deleok);
- } else {
- tprintf(ftp->control,delefail);
- }
- free(file);
- break;
- case STRU_CMD:
- if(tolower(arg[0]) != 'f')
- tprintf(ftp->control,unsupp);
- else
- tprintf(ftp->control,okay);
- break;
- case MODE_CMD:
- if(tolower(arg[0]) != 's')
- tprintf(ftp->control,unsupp);
- else
- tprintf(ftp->control,okay);
- break;
- }
- }
- static int pport(struct socket *sock, char *arg)
- {
- int32 n;
- int i;
-
- n = 0;
- for(i=0;i<4;i++){
- n = atoi(arg) + (n << 8);
- if((arg = strchr(arg,',')) == NULLCHAR)
- return -1;
- arg++;
- }
- sock->address = n;
- n = atoi(arg);
- if((arg = strchr(arg,',')) == NULLCHAR)
- return -1;
- arg++;
- n = atoi(arg) + (n << 8);
- sock->port = (int16)n;
- return 0;
- }
- /* Attempt to log in the user whose name is in ftp->username and password
- * in pass
- */
- static void ftplogin(struct ftp *ftp, char *pass)
- {
- char buf[80];
- FILE *fp;
- char *user;
- char *password;
- char *root;
- char *permissions;
- int anony = 0;
- int i;
-
- if ((fp = fopen(userfile,"r")) == NULLFILE){
- /* Userfile doesn't exist */
- tprintf(ftp->control, noperm);
- return;
- }
- while (fgets(buf, sizeof(buf), fp) != NULLCHAR){
- if (buf[0] == '#')
- continue; /* Comment */
- if ((user = strtok(buf," \n\t")) == NULLCHAR)
- continue;
- if (strcmp(ftp->username, user) == 0)
- break; /* Found user name */
- }
- if (feof(fp)){
- /* User name not found in file or is incomplete */
- fclose(fp);
- tprintf(ftp->control,noperm);
- return;
- }
- fclose(fp);
-
- if ((password = strtok(NULLCHAR," \n\t")) == NULLCHAR){
- /* Password required, non given */
- tprintf(ftp->control, noperm);
- return;
- }
-
- if (strcmp(password, "*") == 0)
- anony = 1; /* User ID is password-free */
-
- if (!anony && strcmp(password, pass) != 0){
- /* Password required, but wrong one given */
- tprintf(ftp->control, noperm);
- return;
- }
-
- root = strtok(NULLCHAR, " \n\t");
-
- for(i = 0; i < MAXPATH; i++){
- if((permissions = strtok(NULLCHAR, " \n\t")) == NULLCHAR){
- /* Permission field missing, assume end of line */
- break;
- }
- ftp->path[i] = malloc((unsigned)strlen(root) + 1);
- strcpy(ftp->path[i], root);
- ftp->perms[i] = atoi(permissions);
- if((root = strtok(NULLCHAR, " \n\t")) == NULLCHAR){
- /* No next path field, so assume end of line */
- break;
- }
- }
-
- /* Set up current directory and LAST specified path prefix */
- for (i = MAXPATH - 1; i >= 0; i--)
- if (ftp->perms[i])
- break;
-
- ftp->cd = malloc((unsigned)strlen(ftp->path[i]) + 1);
- strcpy(ftp->cd, ftp->path[i]);
-
- if (!anony)
- tprintf(ftp->control, logged);
- else
- tprintf(ftp->control, loggeda);
- }
-
- /* Illegal characters in a RISC OS filename */
- char badchars[] = "\"[]:|<>+=;,";
-
- /* Return 1 if the file operation is allowed, 0 otherwise */
- int permcheck(struct ftp *ftp, int op, char *file)
- {
- char *cp;
- int i;
-
- if(file == NULLCHAR || ftp->path[0] == NULLCHAR)
- return 0; /* Probably hasn't logged in yet */
- /* Check for characters illegal in RISC OS file names */
- for(cp = badchars;*cp != '\0';cp++){
- if(strchr(file,*cp) != NULLCHAR)
- return 0;
- }
- /* The target file must be under the users allowed path */
- for(i = 0; i < MAXPATH; i++)
- if(ftp->path[i] != NULLCHAR &&
- strncmp(file, ftp->path[i], strlen(ftp->path[i])) == 0)
- break;
-
- if (i == MAXPATH)
- return 0;
-
- switch(op){
- case RETR_CMD:
- /* User must have permission to read files */
- if(ftp->perms[i] & FTP_READ)
- return 1;
- return 0;
- case DELE_CMD:
- case RMD_CMD:
- /* User must have permission to (over)write files */
- if(ftp->perms[i] & FTP_WRITE)
- return 1;
- return 0;
- case STOR_CMD:
- case MKD_CMD:
- /* User must have permission to (over)write files, or permission
- * to create them if the file doesn't already exist
- */
- if(ftp->perms[i] & FTP_WRITE)
- return 1;
- if(access(file,2) == -1 && (ftp->perms[i] & FTP_CREATE))
- return 1;
- return 0;
- }
- return 0; /* "can't happen" -- keep lint happy */
- }
-