/***************************************************************************
 * 
 * Based heavily on:
 * Globus Developers Tutorial: GridFTP Example - Simple Authenticated Put
 *
 * Original code found at:
 * http://www-unix.globus.org/mail_archive/discuss/2002/10/msg00631.html
 *
 * Copyright (c) 2002-2003 Northwestern University
 *
 * Permission is hereby granted, free of charge, to any person obtaining
 * a copy of this software and associated documentation files (the
 * "Software"), to deal in the Software without restriction, including
 * without limitation the rights to use, copy, modify, merge, publish,
 * distribute, sublicense, and/or sell copies of the Software, and to
 * permit persons to whom the Software is furnished to do so, subject to
 * the following conditions:
 *
 * The above copyright notice and this permission notice shall be included
 * in all copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
 * OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
 * IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY
 * CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,
 * TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
 * SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 *
 ***************************************************************************/
#include <stdio.h>

#ifdef _LARGE_FILE_API
#undef _LARGE_FILE_API
#endif

#include "globus_ftp_client.h"

static globus_mutex_t lock;
static globus_cond_t cond;
static globus_bool_t done;

#define MAX_BUFFER_SIZE 2048

static void done_cb(void *user_arg,
                    globus_ftp_client_handle_t *handle,
                    globus_object_t *err)
{
    if(err)
    {
        fprintf(stderr, "%s", globus_object_printable_to_string(err));
    }
    globus_mutex_lock(&lock);
    done = GLOBUS_TRUE;
    globus_cond_signal(&cond);
    globus_mutex_unlock(&lock);
    return;
}

static void data_cb(void *user_arg,
                    globus_ftp_client_handle_t *handle,
                    globus_object_t *err,
                    globus_byte_t *buffer,
                    globus_size_t length,
                    globus_off_t offset,
                    globus_bool_t eof)
{
    FILE *fd = (FILE *)user_arg;
    if (err)
    {
        fprintf(stderr,"%s",globus_object_printable_to_string(err));
    }
    else
    {
        globus_assert(fd);
        if (!eof)
        {
            int rc = fread(buffer, 1, MAX_BUFFER_SIZE, fd);
            if (ferror(fd) != 0)
            {
                printf("Read error in function data_cb; errno = %d\n",errno);
                return;
            } 
            globus_ftp_client_register_write(handle,buffer,rc,
                                             (offset + length),
                                             (feof(fd) != 0),
                                             data_cb,(void *) fd);
        }
        else
        {
            fclose(fd);
        }
    }
    return;
}

int main(int argc, char **argv)
{
    globus_result_t result;
    globus_ftp_client_handle_t handle;
    globus_byte_t buffer[MAX_BUFFER_SIZE];
    char *src = (char *)0;
    char *dst = (char *)0;
    FILE *fd = (FILE *)0;

    if (argc != 3)
    {
        printf("Usage: gftp_put <local-file> <destination-url>\n");
        return 1;
    }
    else
    {
        src = argv[1];
        dst = argv[2];
    }

    fd = fopen(src,"r");
    if (fd == (FILE *)0)
    {
        printf("Error opening local file: %s\n",src);
        return 1;
    }

    globus_module_activate(GLOBUS_FTP_CLIENT_MODULE);
    globus_mutex_init(&lock, GLOBUS_NULL);
    globus_cond_init(&cond, GLOBUS_NULL);
    globus_ftp_client_handle_init(&handle,  GLOBUS_NULL);

    done = GLOBUS_FALSE;
    
    result = globus_ftp_client_put(&handle,dst,GLOBUS_NULL,GLOBUS_NULL,
                                   done_cb,0);
    if (result != GLOBUS_SUCCESS)
    {
        globus_object_t *err = globus_error_get(result);
        fprintf(stderr,"%s",globus_object_printable_to_string(err));
        done = GLOBUS_TRUE;
    }
    else
    {
        int rc = 0;

        memset(buffer,0,MAX_BUFFER_SIZE);
        rc = fread(buffer, 1, MAX_BUFFER_SIZE, fd);

        globus_ftp_client_register_write(&handle,buffer,rc,0,
                                         (feof(fd) != 0),data_cb,
                                         (void *)fd);
    }

    globus_mutex_lock(&lock);
    while(!done)
    {
        globus_cond_wait(&cond, &lock);
    }
    globus_mutex_unlock(&lock);

    globus_ftp_client_handle_destroy(&handle);
    globus_module_deactivate_all();

    return 0;

}