tags/REL-1.1/ftpappend.c

/*

    libftp 1.0 (stable): this is an FTP library to simplify the work to a Developer
    who want to work with FTP servers (RFC 959).
    Copyright (C) 2007/2008  omnipresent - omnipresent[at]email.it

    This program is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.

    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program.  If not, see <http://www.gnu.org/licenses/>

*/

#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/time.h>
#include <time.h>
#include <sys/socket.h>
#include <sys/stat.h>
#include <netinet/in.h>
#include <netdb.h>
#include <fcntl.h>

#include "ftp_main.h"


/*** 
     ftp_append:
        - int sck        => Socket Descriptor
        - char *FileName => The file name that you want to upload
        - char *target   => Target file name on server.
        - int verbose    => Verbose?
           . 0 Do not Print
           . 1 Print
        - ret            => Success?
           . 0 Success
           .-1 Error
***/

#define DATA_CONNECTION_ERROR   -3
#define WRONG_DATA_P            -3
#define USR_TOO_LONG            -2

time_t res_append;

int ftp_append (int sck, char *FileName, char *target, int verbose)
{
    char *buffer;
    int n = 0;
    int flags;
    time_t start, end;
    int sock;
    FILE *fd;
    int con_err = 0;
    char buff[4096];
    int n_bytes;
    int n_send;

    extern int data_port;
    extern struct sockaddr_in ftp_connection;

    if( target == NULL ) target = FileName;
    
    buffer = (char *)malloc(4092*sizeof(char));
        
    if (buffer == NULL) {
        printf("Unable to alloc 4092 bytes to buffer (ftp_append)\n");
        return -1;
    }
        

    if (data_port == 0) {

        free(buffer);

        return WRONG_DATA_P;
    }

        
    if (strlen(FileName) > 1024) {

        free(buffer);

        return USR_TOO_LONG;

    }

    if (access(FileName, F_OK) != 0) {
        if (verbose) {
            printf("--[ Error: File Name '%s' not here\n", FileName);
        }
                
        free(buffer);
                

        return 1;

    }

    sprintf(buffer, "APPE %s\r\n", target);
        
    if (write(sck, buffer, strlen(buffer)) == -1) {

        if (verbose) {

            if (errno == EBADF) {
                fprintf(stderr, "Socket Descriptor Not Valid!\n");
                free(buffer);

                return -1;

            } else if (errno == EIO) {

                fprintf(stderr, "I/O Error!\n");
                free(buffer);
                return -1;

            } else if (errno == EINTR) {

                fprintf(stderr, "Signal Interrupted The write() Function\n");
                free(buffer);
                
                return -1;
            }

        } else {

            if (errno == EBADF) {
                free(buffer);
                
                return -1;

            } else if (errno == EIO) {
                free(buffer);

                return -1;

            } else if (errno == EINTR) {
                free(buffer);
                
                return -1;

            }
        
        }

        free(buffer);
                
        return -1;

    }

    sock = socket(AF_INET, SOCK_STREAM, 0);
    if (sock == -1) {
        free(buffer);
        if (verbose) {
            perror("Socket");
        }
        return -1;
    }

    ftp_connection.sin_port = htons(data_port);

    if ( (con_err = connect(sock, (struct sockaddr *)&ftp_connection, sizeof(struct sockaddr)) ) != 0)  {
        
        data_port = 0;
        n = recv(sck, buffer, 1024, 0);
        memset(buffer, 0x0, 1024);
        free(buffer);

        if (verbose)
            printf("[-] Data Connection error (APPE)\n");

        return DATA_CONNECTION_ERROR;
    }

    if ( (flags=fcntl(sock, F_GETFL,0)) < 0) {
        printf("--[ fcntl get flags error.\n");
        exit(1);
    }

    flags |= O_NONBLOCK;

    if ( fcntl (sock, F_SETFL, flags ) < 0 ) {
        printf("--[ Non Blocking Socket Error.\n");
        exit(1);
    } 

    buff[4095] = '\0';

    fd = fopen(FileName, "rb");
                
    if (fd == NULL) {

        if (verbose) {
            printf("--[ Error: Unable to open '%s' in ftp_append\n", FileName);
        }

        return -1;

    }

    while (!feof(fd)) {

        n_bytes = fread(buff, sizeof(char), 4094, fd);
        n_send = send(sock, buff, n_bytes, 0);
        usleep(150);
        memset(buff, 0x0, n_send);
                
    }

    fclose(fd);
    close(sock);

        
    time(&start);

    while (1) {

        sleep(1);
        n = recv(sck, buffer, 4092, MSG_DONTWAIT);
        if (n == 0)
            break;

        if (n < 0) {

            if ( (errno == ESPIPE) || (errno == EAGAIN) ) {
                break;
            }

            if (verbose) {
                printf("--[ Error: Error in ftp_append() while putting on the file\n");
            }

            free(buffer);
                        
            return -1;
                
        }

        buffer[n] = '\0';

        n = 0;
        memset(buffer, 0x0, 4092);

    }

    memset(buffer, 0x0, 4092);

    time(&end);

    res_append = (int)(end - start);
        
    free(buffer);


    return 0;
}