//

// Copyright (c) 2005-2009 Nokia Corporation and/or its subsidiary(-ies).

// All rights reserved.

// This component and the accompanying materials are made available

// under the terms of "Eclipse Public License v1.0"

// which accompanies this distribution, and is available

// at the URL "http://www.eclipse.org/legal/epl-v10.html".

//

// Initial Contributors:

// Nokia Corporation - initial contribution.

//

// Contributors:

//

// Description:

//

/*

 * Copyright (c) 1985, 1988, 1990, 1992, 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. All advertising materials mentioning features or use of this software

 *    must display the following acknowledgement:

 *	This product includes software developed by the University of

 *	California, Berkeley and its contributors.

 * 4. 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.

 */

/*

 * FTP server.

 */

#include <netinet/net_types.h>

#include <sys/param.h>

#include <sys/stat.h>

#include <sys/socket.h>

#include <sys/mman.h>

#include <netinet/in.h>

#define	FTP_NAMES

#include <arpa/ftp.h>

#include <ctype.h>

#include <dirent.h>

#include <fcntl.h>

#include <glob.h>

#include <limits.h> /* for CHAR_BIT */

#include <netdb.h>

#include <pwd.h>

#include <setjmp.h>

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <unistd.h>

#include <utmp.h>

#include <spawn.h>

#include "pathnames.h"

#include "extern.h"

// Symbian includes

#include <f32file.h>

#include <in_iface.h>

static char version[]="v1.0.1000";

extern	off_t restart_point;

extern	char cbuf[];

struct	sockaddr_in server_addr;

struct	sockaddr_in ctrl_addr;

struct	sockaddr_in data_source;

struct	sockaddr_in data_dest;

struct	sockaddr_in his_addr;

struct	sockaddr_in pasv_addr;

in_addr server_in_addr;

int	daemon_mode = 0;

int	data;

jmp_buf	errcatch, urgcatch;

int	logged_in;

struct	passwd *pw;

int	debug = 0;

int	timeout = 900;    /* timeout after 15 minutes of inactivity */

int	maxtimeout = 7200;/* don't allow idle time to be set beyond 2 hours */

int	logging = 0;

int	replicate = 0;

int	high_data_ports = 0;

int	anon_only = 0;

int	multihome = 0;

int guest;

int	stats;

int	statfd = -1;

int	portcheck = 1;

int	dochroot;

int	type;

int	form;

int	stru;			/* avoid C keyword */

int	mode;

int	doutmp = 0;		/* update utmp file */

int	usedefault = 1;		/* for data transfers */

int	pdata = -1;		/* for passive mode */

int port = 21;    /* default FTP port */

//sig_atomic_t transflag;

int transflag;

off_t	file_size;

off_t	byte_count;

#if !defined(CMASK) || CMASK == 0

#undef CMASK

#define CMASK 027

#endif

int	defumask = CMASK;		/* default umask value */

char	tmpline[7];

char	hostname[]="Symbian"; 

char*	remotehost=hostname; 

char*	dhostname=hostname;

char	*guestpw;

static char ttyline[20];

char	*tty = ttyline;		/* for klogin */

static struct utmp utmp;	/* for utmp */

TDriveNumber drive;

char	*ident = NULL;

int root = 1;

FILE* logFile;

/*

 * Timeout intervals for retrying connections

 * to hosts that don't accept PORT cmds.  This

 * is a kludge, but given the problems with TCP...

 */

#define	SWAITMAX	90	/* wait at most 90 seconds */

#define	SWAITINT	5	/* interval between retries */

int	swaitmax = SWAITMAX;

int	swaitint = SWAITINT;

#ifdef HASSETPROCTITLE

char	proctitle[BUFSIZ];	/* initial part of title */

#endif /* HASSETPROCTITLE */

#define LOG(message) \

	if (logging/* > 1*/) { \

	    fprintf(logFile, "LOG_INFO %s\r\n", message); \

		fflush(logFile); }

#define LOGCMD(cmd, file) \

	if (logging/* > 1*/) { \

	    fprintf(logFile, "LOG_INFO %s %s\r\n", cmd, file); \

		fflush(logFile); }

#define LOGCMD2(cmd, file1, file2) \

	 if (logging/* > 1*/) { \

	 	fprintf(logFile, "LOG_INFO %s %s %s\r\n", cmd, file1, file2); \

		fflush(logFile); }

#define LOGBYTES(cmd, file, cnt) \

	if (logging/* > 1*/) { \

		if (cnt == (off_t)-1) \

		    fprintf(logFile, "LOG_INFO %s %s\r\n", cmd, file); \

		else \

		    fprintf(logFile, "LOG_INFO %s %s = %qd bytes\r\n", cmd, file, (quad_t)(cnt)); \

		fflush(logFile) ; \

	}

static void	 ack __P((const char *));

static FILE	*dataconn __P((const char *, off_t, const char *));

static void	 dolog __P((struct sockaddr_in *));

static void	 end_login __P((void));

static FILE	*getdatasock __P((const char *));

static int	guniquefd __P((const char *, char **));

static int	 receive_data __P((FILE *, FILE *));

static void	 replydirname __P((const char *, const char *));

static void	 send_data __P((FILE *, FILE *, off_t, off_t, int));

#if defined(TCPWRAPPERS)

static int	 check_host __P((struct sockaddr_in *));

#endif

in_addr getServerAddress();

TDriveNumber getSystemDrive();

void logxfer __P((const char *, off_t, time_t));

#define MAXUSERNAME 64

char * username[MAXUSERNAME];

char * userhome[MAXPATHLEN];

#undef IP_PORTRANGE

int

main(int argc, char *argv[], char **envp)

{

	int ch, on = 1;

	socklen_t addrlen;

	char *cp, line[LINE_MAX];

	FILE *fd;

	const char *argstr = "RAdDhlMSt:T:u:UvP:";

	tzset();	/* in case no timezone database in ~ftp */

	/* set this here so klogin can use it... */

	(void)snprintf(ttyline, sizeof(ttyline), "ftp%d", getpid());

	while ((ch = getopt(argc, argv, argstr)) != -1) {

		switch (ch) {

		case 'A':

			anon_only = 1;

			break;

		case 'd':

			debug = 1;

			break;

		case 'D':

			for(int i=1 /*no name*/; i<argc; i++)

				{

				for(unsigned int j=0;j<strlen(argv[i]); j++)

					if(argv[i][j]=='D')

						{ 

						//Daemon token found, change it to allow replication to new background processes

						argv[i][j]='R';

						}

				}

			posix_spawn(NULL,argv[0],NULL,NULL,argv,envp);

			exit(0);

			break;

		case 'R':

			replicate = 1;

			break;

		case 'P':

			port = atoi(optarg);

			break;

		case 'h':

			high_data_ports = 1;

			break;

		case 'l':

			logging++;	/* > 1 == extra logging */

			break;

		case 'M':

			multihome = 1;

			break;

		case 'S':

			stats = 1;

			break;

		case 't':

			timeout = atoi(optarg);

			if (maxtimeout < timeout)

				maxtimeout = timeout;

			break;

		case 'T':

			maxtimeout = atoi(optarg);

			if (timeout > maxtimeout)

				timeout = maxtimeout;

			break;

		case 'u':

		    {

			long val = 0;

			val = strtol(optarg, &optarg, 8);

			if (*optarg != '\0' || val < 0 || (val & ~ACCESSPERMS))

				printf("bad value for -u");

			else

				defumask = val;

			break;

		    }

		case 'U':

			doutmp = 1;

			break;

		case 'v':

			debug = 1;

			break;

		default:

			printf("unknown flag -%c ignored", optopt);

			scanf("");

			break;

		}

	}

	(void) freopen(_PATH_DEVNULL, "w", stderr);

	/*

	 * LOG_NDELAY sets up the logging connection immediately,

	 * necessary for anonymous ftp's that chroot and can't do it later.

	 */

#ifndef LOG_FTP

#define LOG_FTP LOG_DAEMON

#endif

		int ctl_sock, fd2;

		server_in_addr = getServerAddress();

		/*

		 * Open a socket, bind it to the FTP port, and start

		 * listening.

		 */

		ctl_sock = socket(AF_INET, SOCK_STREAM, 0);

		if (ctl_sock < 0) {

            User::Panic(_L("socket error"),0);

			LOG("socket error");

			exit(1);

		}

		setsockopt(ctl_sock, SOL_SOCKET, SO_REUSEADDR, (char *)&on, sizeof(on));

		server_addr.sin_family = 0;

		server_addr.sin_addr.s_addr = INADDR_ANY;

		server_addr.sin_port = port; 

		if (bind(ctl_sock, (struct sockaddr *)&server_addr,

			 sizeof(server_addr))) {

			 User::Panic(_L("bind error"),0);

            LOG("bind error");

			exit(1);

		}

		if (listen(ctl_sock, 32) < 0) {

		    User::Panic(_L("listen error"),0);

			LOG("listen error");

			exit(1);

		}

			addrlen = sizeof(his_addr);

			fd2 = accept(ctl_sock, (struct sockaddr *)&his_addr,

				    &addrlen);

			(void) dup2(fd2, 0);

			(void) dup2(fd2, 1);

			close(ctl_sock);

			close(fd2);

	drive = getSystemDrive();

	if(logging)

	{

		char logFileName[MAXPATHLEN];

		char driveLetter = 'A'+drive;

		sprintf(logFileName,"%c:\\ftpd_%d.log",driveLetter,getpid());

		logFile = fopen(logFileName,"w");

		fprintf(logFile, "** Log file for the FTP instance with PID %d **\r\n",getpid());

		fflush(logFile);

	}

	addrlen = sizeof(ctrl_addr);

	if (getsockname(0, (struct sockaddr *)&ctrl_addr, &addrlen) < 0) {

		User::Panic(_L("getsockname error"),0);

		exit(1);

	}

	//clone to accept new connections

	if(replicate)

		posix_spawn(NULL,argv[0],NULL,NULL,argv,envp);

	data_source.sin_port = htons(ntohs(ctrl_addr.sin_port) - 1);

	dolog(&his_addr);

	/*

	 * Set up default state

	 */

	data = -1;

	type = TYPE_A;

	form = FORM_N;

	stru = STRU_F;

	mode = MODE_S;

	tmpline[0] = '\0';

	/* If logins are disabled, print out the message. */

	if ((fd = fopen(_PATH_NOLOGIN,"r")) != NULL) {

		while (fgets(line, sizeof(line), fd) != NULL) {

			if ((cp = strchr(line, '\n')) != NULL)

				*cp = '\0';

			lreply(530, "%s", line);

		}

		(void) fflush(stdout);

		(void) fclose(fd);

		reply(530, "System not available.");

		exit(0);

	}

	if ((fd = fopen(_PATH_FTPWELCOME, "r")) != NULL) {

		while (fgets(line, sizeof(line), fd) != NULL) {

			if ((cp = strchr(line, '\n')) != NULL)

				*cp = '\0';

			lreply(220, "%s", line);

		}

		(void) fflush(stdout);

		(void) fclose(fd);

		/* reply(220,) must follow */

	}

	reply(220, "%s FTP server (%s) ready.",

			hostname, version);

	(void) setjmp(errcatch);

	for (;;)

		(void) yyparse();

	/* NOTREACHED */

}

static int login_attempts;	/* number of failed login attempts */

static int askpasswd;		/* had user command, ask for passwd */

static char curname[16];	/* current USER name */

/*

 * USER command.

 * Sets global passwd pointer pw if named account exists and is acceptable;

 * sets askpasswd if a PASS command is expected.  If logged in previously,

 * need to reset state.  If name is "ftp" or "anonymous", the name is not in

 * _PATH_FTPUSERS, and ftp account exists, set guest and pw, then just return.

 * If account doesn't exist, ask for passwd anyway.  Otherwise, check user

 * requesting login privileges.  Disallow anyone who does not have a standard

 * shell as returned by getusershell().  Disallow anyone mentioned in the file

 * _PATH_FTPUSERS to allow people such as root and uucp to be avoided.

 */

void user(char *name)

{

	//const char *cp, *shell;

	if (logged_in) {

		if (guest) {

			reply(530, "Can't change user from guest login.");

			return;

		} else if (dochroot) {

			reply(530, "Can't change user from chroot user.");

			return;

		}

		end_login();

	}

	guest = 0;

	// check password

	pw = (passwd *)malloc(sizeof(pw));

	strcpy((char*)username,name);

	pw->pw_name = (char*)username;

	strcpy((char*)userhome,"/");

	pw->pw_dir = (char*)userhome;

	if (logging) {

		strncpy(curname, name, sizeof(curname)-1);

		curname[sizeof(curname)-1] = '\0';

	}

	if (strcmp(name, "ftp") == 0 || strcmp(name, "anonymous") == 0) 

		reply(331,"Guest login ok, type your name as password.");

	else

		reply(331, "Password required for %s.", name);

	askpasswd = 1;

	/*

	 * Delay before reading passwd after first failed

	 * attempt to slow down passwd-guessing programs.

	 */

	if (login_attempts)

		sleep((unsigned) login_attempts);

}

/*

 * Terminate login as previous user, if any, resetting state;

 * used when USER command is given or login fails.

 */

static void end_login(void)

{

	(void) seteuid((uid_t)0);

	if (logged_in) {

		if (doutmp)

			logout(utmp.ut_line);

	}

	pw = NULL;

	logged_in = 0;

	guest = 0;

	dochroot = 0;

}

void pass(char *passwd)

{

	int rval;

	FILE *fd;

	if (logged_in || askpasswd == 0) {

		reply(503, "Login with USER first.");

		return;

	}

	askpasswd = 0;

	if (!guest) {		/* "ftp" is only account allowed no password */