#include "mydefine.h"
#include "com.h"
#include "pub.h"
#include "net.h"
char oldname[20];//do_rnfr
int data_conn_sock;
char connuser[10];
char up_com[20];
char port_ip[50] ;//PORT命令处理完后记IP用的
int port_port ;// PORT 命令处理完后记port用的
int restflag;//记录do_rest
int pasv_cannsock;
void get_com(char buf[],char com[])
{
char temp[1024];
strcpy(temp,buf);
char *p=strchr(temp,' ');
if(p!=NULL)
{
*p='\0';
strcpy(com,temp);
}
else
{
char *p=strchr(temp,'\r');
if(p!=NULL)
{
*p='\0';
strcpy(com,temp);
}
}
}
void get_charm(char buf[],char charm[])
{
char tmp[1024];
strcpy(tmp,buf);
char *p =strchr(tmp,' ');
if ( p != NULL)
{
strcpy(charm,p+1);
p = strchr(charm,'\r');
if( p != NULL )
{
*p='\0';
}
}
}
void do_user(SESSION nowsession)
{
strcpy(connuser,nowsession.charm);//保存用户名
if(strcmp(connuser,"anonumous")==0)
{
strcpy(connuser,"ftp");
}
write_loop(connfd,"331 give me pass\r\n",strlen("331 give me pass\r\n"));
}
void do_pass(SESSION nowsession)
{
if(strcmp(connuser,"ftp")!=0)
{
int res=checkpass(connuser,nowsession.charm);
if(res!=0)//密码错
{
write_loop(connfd,"530 pass is error\r\n",strlen("530 pass is error\r\n"));
return;
}
}
write_loop(connfd,"230 Login successful\r\n",strlen("230 Login successful\r\n"));
//切换有效身份
egid_euid(connuser,0);
}
void do_syst(SESSION nowsession)
{
write_loop(connfd,"215 Linux\r\n",strlen("215 Linux\r\n"));
}
void do_pwd(SESSION nowsession)
{
char sdir[200]="";
sprintf(sdir,"257 \"%s\"\r\n",nowsession.dir);
write_loop(connfd,sdir,strlen(sdir));
}
void do_type(SESSION nowsession)
{
if(strcmp(nowsession.charm,"A")==0)
{
write_loop(connfd,"200 Switching to ASCII mode\r\n",strlen("200 Switching to ASCII mode\r\n"));
}
else
write_loop(connfd,"200 I\r\n",strlen("200 I\r\n"));
}
void do_pasv(SESSION nowsession)
{
struct sockaddr_in servaddr;
struct sockaddr_in tempaddr;
unsigned int port1,port2,pasv_port;
char pasv_ip[]="192.168.50.10";
char *p=pasv_ip;
while(*p != '\0')
{
if( *p == '.')
*p=',';
p++;
}
//1
pasv_cannsock = socket(PF_INET,SOCK_STREAM,0);
if(pasv_cannsock == -1)
ERR_EXIT("pasv socket");
//2
memset(&servaddr,0,sizeof(servaddr));
servaddr.sin_family = AF_INET;
servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
servaddr.sin_port = htons(0);
int opt = 1;
int ret = setsockopt(pasv_cannsock,SOL_SOCKET,SO_REUSEADDR,&opt,sizeof(opt));
if (ret == -1)
ERR_EXIT("setsockopt");
int res = bind(pasv_cannsock,(struct sockaddr *)&pasv_cannsock,sizeof(servaddr));
//if (res == -1)
//ERR_EXIT("pasv bind");
//3
res=listen(pasv_cannsock,10);
if (res == -1)
ERR_EXIT("pasv listen ");
//4
memset(&tempaddr,0,sizeof(tempaddr));
socklen_t addrlen=sizeof(tempaddr);
res = getsockname(pasv_cannsock,(struct sockaddr*)&tempaddr,(socklen_t *)&addrlen);
if (res == -1)
ERR_EXIT("pasv getsockname");
// printf("myip=%s port=%d\n",inet_ntoa(tempaddr.sin_addr),ntohs(tempaddr.sin_port));
pasv_port =ntohs(tempaddr.sin_port);
port1=pasv_port>>8;
port2=pasv_port&0xFF;
char buf[200];
memset(buf,0,sizeof(buf));
sprintf(buf,"227 Entering Passive Mode (%s,%d,%d)\r\n",pasv_ip,port1,port2);
write_loop(connfd,buf,strlen(buf));
strcpy(up_com,"PASV");
//printf("sssssssssssss\n");
}
void do_rest(SESSION nowsession)
{
restflag=atoi(nowsession.charm);
write_loop(connfd,"350 rest ok\r\n",strlen("350 rest ok\r\n"));
}
void do_stor(SESSION nowsession)
{
int fd;
if(restflag>0)
{
fd = open(nowsession.charm,O_WRONLY);
if(fd == -1)
{
printf(" stor open fail not directary!! ");
return;
}
lseek(fd,restflag,SEEK_SET);
restflag=0;
}
else
{
fd = open(nowsession.charm,O_CREAT|O_WRONLY,0666);
if(fd == -1)
{
printf(" stor open fail not directary!! ");
return;
}
}
data_conn_sock = test_port_pasv();
char buf[1024];
write_loop(connfd,"150 OK send to data\r\n",strlen("150 OK send to data\r\n"));
while(1)
{
memset(buf,0,sizeof(buf));
int n=read(data_conn_sock,buf,1024);
if(n<=0)
break;
write(fd,buf,n);
}
//write_loop(data_conn_sock,nowsession.charm,strlen(nowsession.charm));
write_loop(connfd,"226 File receive ok\r\n",strlen("226 File receive ok\r\n"));
if(strcmp(up_com,"PASV") == 0)
{
close (pasv_cannsock);
}
close (data_conn_sock);
}
void do_retr(SESSION nowsession)
{
int fd;
if(restflag>0)
{
fd = open(nowsession.charm,O_RDONLY);
if(fd == -1)
{
printf(" stor open fail not directary!! ");
return;
}
lseek(fd,restflag,SEEK_SET);
restflag=0;
}
else
{
fd = open(nowsession.charm,O_RDONLY,0666);
if(fd == -1)
{
printf(" stor open fail not directary!! ");
return;
}
}
data_conn_sock = test_port_pasv();
char buf[1024];
write_loop(connfd,"150 Opening BINARY mode data connection for myfle.txt\r\n",strlen("150 Opening BINARY mode data connection for myfle.txt\r\n"));
while(1)
{
memset(buf,0,sizeof(buf));
int n=read(fd,buf,1024);
if(n<=0)
break;
write(data_conn_sock,buf,n);
}
write_loop(connfd,"226 File send ok\r\n",strlen("226 File send ok\r\n"));
if(strcmp(up_com,"PASV") == 0)
{
close (pasv_cannsock);
}
close (data_conn_sock);
}
void do_dele(SESSION nowsession)
{
int res = remove(nowsession.charm);//inlink
write_loop(connfd,"250 Delete operation successful.\r\n",strlen("250 Delete operation successful.\r\n"));
}
void do_cwd(SESSION nowsession)
{
chdir(nowsession.charm);
write_loop(connfd,"250 directory successfully changed\r\n",strlen("250 directory successfully changed\r\n"));
}
void do_mkd(SESSION nowsession)
{
mkdir(nowsession.charm,0777);
write_loop(connfd,"257 \r\n",strlen("257 \r\n"));
}
void do_rmd(SESSION nowsession)
{
rmdir(nowsession.charm);
write_loop(connfd,"250 Remove directory successfully change\r\n",strlen("250 Remove directory successfully change\r\n"));
}
void do_port(SESSION nowsession)
{
//printf("do_port is unnunnnn\n");
write_loop(connfd,"200 PORT is ok\r\n",strlen("200 PORT is ok\r\n"));
char tmp[30];
strcpy(tmp,nowsession.charm);
int n1,n2,n3,n4,n5,n6;
sscanf(tmp,"%d,%d,%d,%d,%d,%d",&n1,&n2,&n3,&n4,&n5,&n6);
sprintf(port_ip,"%d.%d.%d.%d",n1,n2,n3,n4);
port_port = n5*256+n6;
strcpy(up_com,"PORT");
}
void do_list(SESSION nowsession)
{
data_conn_sock = test_port_pasv();
write_loop(connfd,"150 Start directory send\r\n",strlen("150 Start directory send\r\n"));
mylist(data_conn_sock,nowsession.dir);//connuser
write_loop(connfd,"226 Directory send ok\r\n",strlen("226 Directory send ok\r\n"));
if(strcmp(up_com,"PASV") == 0)
{
close (pasv_cannsock);
}
close (data_conn_sock);
//printf("do_list() is running!\n");
}
void do_cdup(SESSION nowsession)
{
chdir("../");
write_loop(connfd,"250 directory successfully change\r\n",strlen("250 directory successfully change\r\n"));
}
void do_site(SESSION nowsession)
{
char tmp[30];
char md[20];
char fil_name[20];
int n,m;
strcpy(tmp,nowsession.charm);
sscanf(tmp,"%s %d %s",md,&n,fil_name);
m=n%10+n/10%10*8+n/100*64;
chmod(fil_name,(mode_t)m);//
write_loop(connfd,"200 site mode success.\r\n",strlen("200 site mode success.\r\n"));
}
void do_rnfr(SESSION nowsession)
{
strcpy(oldname,nowsession.charm);
write_loop(connfd,"350 read for RETO\r\n",strlen("350 read for RETO\r\n"));
}
void do_rnto(SESSION nowsession)
{
rename(oldname, nowsession.charm);
write_loop(connfd,"250 rename ok\r\n",strlen("250 rename ok\r\n"));
}
void do_quit(SESSION nowsession)
{
write_loop(connfd,"221 Goodbye\r\n",strlen("221 Goodbye\r\n"));
}
COM_FUN mycomfun[]={
{"USER", do_user},
{"PAS
