magicka/utils/mnetftpc/mnetftpc.c

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <ctype.h>
#include <ftplib.h>
#include <dirent.h>
#include <unistd.h>
#include <sys/stat.h>

int imhub = 0;
int hubnode = 0;
char *baseindir = NULL;
char *baseoutdir = NULL;
char *ftphost = NULL;
char *ftpusername = NULL;
char *ftppassword = NULL;
char **filenames;
int file_count = 0;


size_t trimwhitespace(char *out, size_t len, const char *str) {
    if(len == 0)
        return 0;

    const char *end;
    size_t out_size;

    // Trim leading space
    while(isspace((unsigned char)*str)) str++;

    if(*str == 0) {
        *out = 0;
        return 1;
    }

    // Trim trailing space
    end = str + strlen(str) - 1;
    while(end > str && isspace((unsigned char)*end)) end--;
    end++;

    // Set output size to minimum of trimmed string length and buffer size minus 1
    out_size = (end - str) < len-1 ? (end - str) : len-1;

    // Copy trimmed string and add null terminator
    memcpy(out, str, out_size);
    out[out_size] = 0;

    return out_size;
}

int parse_config_file(char *filename) {
    FILE *fptr;
    char buffer[256];
    char bufferw[256];
    char *ptr;

    fptr = fopen(filename, "r");
    if (!fptr) {
        return 0;
    }

    fgets(buffer, 256, fptr);
    while (!feof(fptr)) {
        if (buffer[0] != ';') {
            if (buffer[strlen(buffer) - 1] == '\n'){
                buffer[strlen(buffer) - 1] = '\0';
                if (strncasecmp(buffer, "IMHUB", 5) == 0) {
                    trimwhitespace(bufferw, 256, &buffer[6]);
                    if (strcasecmp(bufferw, "TRUE") == 0) {
                        imhub = 1;
                    }
                } else if (strncasecmp(buffer, "UPLINK", 6) == 0) {
                    trimwhitespace(bufferw, 256, &buffer[7]);
                    hubnode = atoi(bufferw);
                } else if (strncasecmp(buffer, "FTPHOST", 7) == 0) {
                    trimwhitespace(bufferw, 256, &buffer[8]);
                    ftphost = strdup(bufferw);
                } else if (strncasecmp(buffer, "FTPUSER", 7) == 0) {
                    trimwhitespace(bufferw, 256, &buffer[8]);
                    ftpusername = strdup(bufferw);
                } else if (strncasecmp(buffer, "FTPPASS", 7) == 0) {
                    trimwhitespace(bufferw, 256, &buffer[8]);
                    ftppassword = strdup(bufferw);                    
                } else if (strncasecmp(buffer, "INDIR", 5) == 0) {
                    trimwhitespace(bufferw, 256, &buffer[6]);
                    baseindir = strdup(bufferw);
                } else if (strncasecmp(buffer, "OUTDIR", 6) == 0) {
                    trimwhitespace(bufferw, 256, &buffer[7]);
                    baseoutdir = strdup(bufferw);
                } 
            } else {
                fclose(fptr);
                return 0;
            }
        }
        fgets(buffer, 256, fptr);
    }

    fclose(fptr);
    return 1;
}

int main(int argc, char **argv) {
    netbuf *nb;
    netbuf *nd;
    char buffer[PATH_MAX];
    int len;
    int i;
    DIR *outdir;
    struct dirent *dent;
    struct stat s;


    if (argc < 2) {
        fprintf(stderr, "Usage ./mnetftpc mnet.cfg\n");
        return -1;
    }

    if (!parse_config_file(argv[1])) {
        fprintf(stderr, "Error parsing config file: %s\n", argv[1]);
        return -1;
    }

    if (baseoutdir == NULL) {
        fprintf(stderr, "OUTDIR must be defined\n");
        return -1;        
    }

    if (baseindir == NULL) {
        fprintf(stderr, "INDIR must be defined\n");
        return -1;        
    }

    if (ftphost == NULL) {
        fprintf(stderr, "FTPHOST must be defined\n");
        return -1;        
    }

    if (ftpusername == NULL) {
        fprintf(stderr, "FTPUSER must be defined\n");
        return -1;        
    }

    if (ftppassword == NULL) {
        fprintf(stderr, "FTPPASS must be defined\n");
        return -1;        
    }            

    FtpInit();
    if (FtpConnect(ftphost, &nb)) {
        if (FtpLogin(ftpusername, ftppassword, nb)) {
            // logged in...
            // receive files in in
            if (FtpChdir("in", nb)) {
                if (FtpAccess("/in", FTPLIB_DIR, FTPLIB_ASCII, nb, &nd)) {
                    len = FtpRead(buffer, PATH_MAX-1, nd);
                    while(len != -1 && len != 0) {
                        buffer[len-1] = '\0';
                        if (strcmp(buffer, "..") != 0 && strcmp(buffer, ".") != 0) {
                            if (file_count == 0) {
                                filenames = (char **)malloc(sizeof(char *));
                            } else {
                                filenames = (char **)realloc(filenames, sizeof(char *) * (file_count + 1));
                            }
                            filenames[file_count] = strdup(buffer);
                            file_count++;
                        }

                        len = FtpRead(buffer, PATH_MAX-1, nd);
                    }
                    
                    FtpClose(nd);

                    for (i=0;i<file_count;i++) {
                        snprintf(buffer, PATH_MAX, "%s/%s", baseindir,filenames[i]);
                        if (FtpGet(buffer, filenames[i], FTPLIB_BINARY, nb)) {
                            fprintf(stdout, "Received %s\n", filenames[i]);
                            FtpDelete(filenames[i], nb);
                        }
                    }
                    for (i=0;i<file_count;i++) {
                        free(filenames[i]);
                    }
                    free(filenames);
                }
            }            
            if (FtpChdir("/out", nb)) {
                snprintf(buffer, PATH_MAX, "%s/%d", baseoutdir, hubnode);
                outdir = opendir(buffer);
                if (!outdir) {
                    fprintf(stderr, "Error opening inbound directory!\n");
                    return -1;
                }

                while ((dent = readdir(outdir)) != NULL) {
                    snprintf(buffer, PATH_MAX, "%s/%d/%s", baseoutdir, hubnode, dent->d_name);
                    if (stat(buffer, &s) == 0 && !S_ISDIR(s.st_mode)) {
                        if (FtpPut(buffer, dent->d_name, FTPLIB_BINARY, nb)) {
                            fprintf(stdout, "Sent %s\n", dent->d_name);
                            unlink(buffer);
                            rewinddir(outdir);
                        }
                    }
                }
                closedir(outdir);
            }
            
        } else {
            fprintf(stderr, "Unable to authenticate with FTP server\n");    
        }
        FtpQuit(nb);
    } else {
        fprintf(stderr, "Unable to connect to FTP server\n");
    }
    return 0;
}