/**
 * Powder Toy - HTTP Library
 *
 * Copyright (c) 2008 - 2010 Stanislaw Skowronek.
 * Copyright (c) 2010 Simon Robertshaw
 *
 * 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 2 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, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02111-1301  USA
 */


#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#ifndef MACOSX
#include <malloc.h>
#endif
#include <time.h>
#ifdef WIN32
#define _WIN32_WINNT 0x0501
//#include <iphlpapi.h>
#include <winsock2.h>
#include <ws2tcpip.h>
#else
#include <sys/types.h>
#include <unistd.h>
#include <errno.h>
#include <fcntl.h>
#include <signal.h>
#include <sys/socket.h>
#include <netdb.h>
#endif

#include "defines.h"
#include "http.h"
#include "md5.h"

#ifdef WIN32
#define PERROR SOCKET_ERROR
#define PERRNO WSAGetLastError()
#define PEAGAIN WSAEWOULDBLOCK
#define PEINTR WSAEINTR
#define PEINPROGRESS WSAEINPROGRESS
#define PEALREADY WSAEALREADY
#define PCLOSE closesocket
#else
#define PERROR -1
#define PERRNO errno
#define PEAGAIN EAGAIN
#define PEINTR EINTR
#define PEINPROGRESS EINPROGRESS
#define PEALREADY EALREADY
#define PCLOSE close
#endif

static int http_up = 0;
static long http_timeout = 15;
static int http_use_proxy = 0;
static struct sockaddr_in http_proxy;

static char *mystrdup(char *s)
{
    char *x;
    if(s)
    {
        x = malloc(strlen(s)+1);
        strcpy(x, s);
        return x;
    }
    return s;
}

static int splituri(char *uri, char **host, char **path)
{
    char *p=uri,*q,*x,*y;
    if(!strncmp(p, "http://", 7))
        p += 7;
    q = strchr(p, '/');
    if(!q)
        q = p + strlen(p);
    x = malloc(q-p+1);
    if(*q)
        y = mystrdup(q);
    else
        y = mystrdup("/");
    strncpy(x, p, q-p);
    x[q-p] = 0;
    if(q==p || x[q-p-1]==':')
    {
        free(x);
        free(y);
        return 1;
    }
    *host = x;
    *path = y;
    return 0;
}

static char *getserv(char *host)
{
    char *q, *x = mystrdup(host);
    q = strchr(x, ':');
    if(q)
        *q = 0;
    return x;
}

static char *getport(char *host)
{
    char *p, *q;
    q = strchr(host, ':');
    if(q)
        p = mystrdup(q+1);
    else
        p = mystrdup("80");
    return p;
}

static int resolve(char *dns, char *srv, struct sockaddr_in *addr)
{
    struct addrinfo hnt, *res = 0;
    if(http_use_proxy)
    {
        memcpy(addr, &http_proxy, sizeof(struct sockaddr_in));
        return 0;
    }
    memset(&hnt, 0, sizeof(hnt));
    hnt.ai_family = AF_INET;
    hnt.ai_socktype = SOCK_STREAM;
    if(getaddrinfo(dns, srv, &hnt, &res))
        return 1;
    if(res)
    {
        if(res->ai_family != AF_INET)
        {
            freeaddrinfo(res);
            return 1;
        }
        memcpy(addr, res->ai_addr, res->ai_addrlen);
        freeaddrinfo(res);
        return 0;
    }
    return 1;
}

void http_init(char *proxy)
{
    char *host, *port;
#ifdef WIN32
    WSADATA wsadata;
    if(!WSAStartup(MAKEWORD(2,2), &wsadata))
        http_up = 1;
#else
    signal(SIGPIPE, SIG_IGN);
    http_up = 1;
#endif
    if(proxy)
    {
        host = getserv(proxy);
        port = getport(proxy);
        if(resolve(host, port, &http_proxy))
            http_up = 0;
        else
            http_use_proxy = 1;
        free(host);
        free(port);
    }
}

void http_done(void)
{
#ifdef WIN32
    WSACleanup();
#endif
    http_up = 0;
}

#define CHUNK 4096

#define HTS_STRT 0
#define HTS_RSLV 1
#define HTS_CONN 2
#define HTS_IDLE 3
#define HTS_XMIT 4
#define HTS_RECV 5
#define HTS_DONE 6
struct http_ctx
{
    int state;
    time_t last;
    int keep;
    int ret;
    char *host, *path;
    char *thdr;
    int thlen;
    char *txd;
    int txdl;
    struct sockaddr_in addr;
    char *tbuf;
    int tlen, tptr;
    char *hbuf;
    int hlen, hptr;
    char *rbuf;
    int rlen, rptr;
    int chunked, chunkhdr, rxtogo, contlen, cclose;
    int fd;
    char *fdhost;
};
void *http_async_req_start(void *ctx, char *uri, char *data, int dlen, int keep)
{
    struct http_ctx *cx = ctx;
    if(!ctx)
    {
        ctx = calloc(1, sizeof(struct http_ctx));
        cx = ctx;
        cx->fd = PERROR;
    }

    if(!cx->hbuf)
    {
        cx->hbuf = malloc(256);
        cx->hlen = 256;
    }

    if(!http_up)
    {
        cx->ret = 604;
        cx->state = HTS_DONE;
        return ctx;
    }

    if(cx->state!=HTS_STRT && cx->state!=HTS_IDLE)
    {
        fprintf(stderr, "HTTP: unclean request restart state.\n");
        exit(1);
    }

    cx->keep = keep;
    cx->ret = 600;
    if(splituri(uri, &cx->host, &cx->path))
    {
        cx->ret = 601;
        cx->state = HTS_DONE;
        return ctx;
    }
    if(http_use_proxy)
    {
        free(cx->path);
        cx->path = mystrdup(uri);
    }
    if(cx->fdhost && strcmp(cx->host, cx->fdhost))
    {
        free(cx->fdhost);
        cx->fdhost = NULL;
        PCLOSE(cx->fd);
        cx->fd = PERROR;
        cx->state = HTS_STRT;
    }
    if(data)
    {
        if(!dlen)
            dlen = strlen(data);
        cx->txd = malloc(dlen);
        memcpy(cx->txd, data, dlen);
        cx->txdl = dlen;
    }
    else
        cx->txdl = 0;

    cx->contlen = 0;
    cx->chunked = 0;
    cx->chunkhdr = 0;
    cx->rxtogo = 0;
    cx->cclose = 0;

    cx->tptr = 0;
    cx->tlen = 0;

    cx->last = time(NULL);

    return ctx;
}

void http_async_add_header(void *ctx, char *name, char *data)
{
    struct http_ctx *cx = ctx;
    cx->thdr = realloc(cx->thdr, cx->thlen + strlen(name) + strlen(data) + 4);
    cx->thlen += sprintf(cx->thdr+cx->thlen, "%s: %s\n", name, data);
}

static void process_header(struct http_ctx *cx, char *str)
{
    char *p;
    if(cx->chunkhdr)
    {
        p = strchr(str, ';');
        if(p)
            *p = 0;
        cx->rxtogo = strtoul(str, NULL, 16);
        cx->chunkhdr = 0;
        if(!cx->rxtogo)
            cx->chunked = 0;
    }
    if(!str[0])
    {
        cx->rxtogo = cx->contlen;
        cx->chunkhdr = cx->chunked;
        if(!cx->contlen && !cx->chunked && cx->ret!=100)
            cx->state = HTS_DONE;
        return;
    }
    if(!strncmp(str, "HTTP/", 5))
    {
        p = strchr(str, ' ');
        if(!p)
        {
            cx->ret = 603;
            cx->state = HTS_DONE;
            return;
        }
        p++;
        cx->ret = atoi(p);
        return;
    }
    if(!strncmp(str, "Content-Length: ", 16))
    {
        cx->contlen = atoi(str+16);
        return;
    }
    if(!strcmp(str, "Transfer-Encoding: chunked"))
    {
        cx->chunked = 1;
        return;
    }
    if(!strcmp(str, "Connection: close"))
    {
        cx->cclose = 1;
        return;
    }
}

static void process_byte(struct http_ctx *cx, char ch)
{
    if(cx->rxtogo)
    {
        cx->rxtogo--;

        if(!cx->rbuf)
        {
            cx->rbuf = malloc(256);
            cx->rlen = 256;
        }
        if(cx->rptr >= cx->rlen-1)
        {
            cx->rlen *= 2;
            cx->rbuf = realloc(cx->rbuf, cx->rlen);
        }
        cx->rbuf[cx->rptr++] = ch;

        if(!cx->rxtogo && !cx->chunked)
            cx->state = HTS_DONE;
    }
    else
    {
        if(ch == '\n')
        {
            cx->hbuf[cx->hptr] = 0;
            process_header(cx, cx->hbuf);
            cx->hptr = 0;
        }
        else if(ch != '\r')
        {
            if(cx->hptr >= cx->hlen-1)
            {
                cx->hlen *= 2;
                cx->hbuf = realloc(cx->hbuf, cx->hlen);
            }
            cx->hbuf[cx->hptr++] = ch;
        }
    }
}

int http_async_req_status(void *ctx)
{
    struct http_ctx *cx = ctx;
    char *dns,*srv,buf[CHUNK];
    int tmp, i;
    time_t now = time(NULL);
#ifdef WIN32
    unsigned long tmp2;
#endif

    switch(cx->state)
    {
    case HTS_STRT:
        dns = getserv(cx->host);
        srv = getport(cx->host);
        if(resolve(dns, srv, &cx->addr))
        {
            free(dns);
            free(srv);
            cx->state = HTS_DONE;
            cx->ret = 602;
            return 1;
        }
        free(dns);
        free(srv);
        cx->state = HTS_RSLV;
        return 0;
    case HTS_RSLV:
        cx->state = HTS_CONN;
        cx->last = now;
        return 0;
    case HTS_CONN:
        if(cx->fd == PERROR)
        {
            cx->fd = socket(AF_INET, SOCK_STREAM, 0);
            if(cx->fd == PERROR)
                goto fail;
            cx->fdhost = mystrdup(cx->host);
#ifdef WIN32
            tmp2 = 1;
            if(ioctlsocket(cx->fd, FIONBIO, &tmp2) == SOCKET_ERROR)
                goto fail;
#else
            tmp = fcntl(cx->fd, F_GETFL);
            if(tmp < 0)
                goto fail;
            if(fcntl(cx->fd, F_SETFL, tmp|O_NONBLOCK) < 0)
                goto fail;
#endif
        }
        if(!connect(cx->fd, (struct sockaddr *)&cx->addr, sizeof(cx->addr)))
            cx->state = HTS_IDLE;
#ifdef WIN32
        else if(PERRNO==WSAEISCONN)
            cx->state = HTS_IDLE;
#endif
#ifdef MACOSX
        else if(PERRNO==EISCONN)
            cx->state = HTS_IDLE;
#endif
        else if(PERRNO!=PEINPROGRESS && PERRNO!=PEALREADY
#ifdef WIN32
                && PERRNO!=PEAGAIN && PERRNO!=WSAEINVAL
#endif
               )
            goto fail;
        if(now-cx->last>http_timeout)
            goto timeout;
        return 0;
    case HTS_IDLE:
        if(cx->txdl)
        {
            // generate POST
            cx->tbuf = malloc(strlen(cx->host) + strlen(cx->path) + 121 + cx->txdl + cx->thlen);
            cx->tptr = 0;
            cx->tlen = 0;
            cx->tlen += sprintf(cx->tbuf+cx->tlen, "POST %s HTTP/1.1\n", cx->path);
            cx->tlen += sprintf(cx->tbuf+cx->tlen, "Host: %s\n", cx->host);
            if(!cx->keep)
                cx->tlen += sprintf(cx->tbuf+cx->tlen, "Connection: close\n");
            if(cx->thdr)
            {
                memcpy(cx->tbuf+cx->tlen, cx->thdr, cx->thlen);
                cx->tlen += cx->thlen;
                free(cx->thdr);
                cx->thdr = NULL;
                cx->thlen = 0;
            }
            cx->tlen += sprintf(cx->tbuf+cx->tlen, "Content-Length: %d\n", cx->txdl);
#ifdef BETA
            cx->tlen += sprintf(cx->tbuf+cx->tlen, "X-Powder-Version: %s%dB%d\n", IDENT_VERSION, SAVE_VERSION, MINOR_VERSION);
#else
            cx->tlen += sprintf(cx->tbuf+cx->tlen, "X-Powder-Version: %s%dS%d\n", IDENT_VERSION, SAVE_VERSION, MINOR_VERSION);
#endif
            cx->tlen += sprintf(cx->tbuf+cx->tlen, "\n");
            memcpy(cx->tbuf+cx->tlen, cx->txd, cx->txdl);
            cx->tlen += cx->txdl;
            free(cx->txd);
            cx->txd = NULL;
            cx->txdl = 0;
        }
        else
        {
            // generate GET
            cx->tbuf = malloc(strlen(cx->host) + strlen(cx->path) + 89 + cx->thlen);
            cx->tptr = 0;
            cx->tlen = 0;
            cx->tlen += sprintf(cx->tbuf+cx->tlen, "GET %s HTTP/1.1\n", cx->path);
            cx->tlen += sprintf(cx->tbuf+cx->tlen, "Host: %s\n", cx->host);
            if(cx->thdr)
            {
                memcpy(cx->tbuf+cx->tlen, cx->thdr, cx->thlen);
                cx->tlen += cx->thlen;
                free(cx->thdr);
                cx->thdr = NULL;
                cx->thlen = 0;
            }
            if(!cx->keep)
                cx->tlen += sprintf(cx->tbuf+cx->tlen, "Connection: close\n");
#ifdef BETA
            cx->tlen += sprintf(cx->tbuf+cx->tlen, "X-Powder-Version: %s%dB%d\n", IDENT_VERSION, SAVE_VERSION, MINOR_VERSION);
#else
            cx->tlen += sprintf(cx->tbuf+cx->tlen, "X-Powder-Version: %s%dS%d\n", IDENT_VERSION, SAVE_VERSION, MINOR_VERSION);
#endif
            cx->tlen += sprintf(cx->tbuf+cx->tlen, "\n");
        }
        cx->state = HTS_XMIT;
        cx->last = now;
        return 0;
    case HTS_XMIT:
        tmp = send(cx->fd, cx->tbuf+cx->tptr, cx->tlen-cx->tptr, 0);
        if(tmp==PERROR && PERRNO!=PEAGAIN && PERRNO!=PEINTR)
            goto fail;
        if(tmp!=PERROR)
        {
            cx->tptr += tmp;
            if(cx->tptr == cx->tlen)
            {
                cx->tptr = 0;
                cx->tlen = 0;
                if(cx->tbuf)
                    free(cx->tbuf);
                cx->state = HTS_RECV;
            }
            cx->last = now;
        }
        if(now-cx->last>http_timeout)
            goto timeout;
        return 0;
    case HTS_RECV:
        tmp = recv(cx->fd, buf, CHUNK, 0);
        if(tmp==PERROR && PERRNO!=PEAGAIN && PERRNO!=PEINTR)
            goto fail;
        if(tmp!=PERROR)
        {
            for(i=0; i<tmp; i++)
            {
                process_byte(cx, buf[i]);
                if(cx->state == HTS_DONE)
                    return 1;
            }
            cx->last = now;
        }
        if(now-cx->last>http_timeout)
            goto timeout;
        return 0;
    case HTS_DONE:
        return 1;
    }
    return 0;

fail:
    cx->ret = 600;
    cx->state = HTS_DONE;
    return 1;

timeout:
    cx->ret = 605;
    cx->state = HTS_DONE;
    return 1;
}

char *http_async_req_stop(void *ctx, int *ret, int *len)
{
    struct http_ctx *cx = ctx;
    char *rxd;

    if(cx->state != HTS_DONE)
        while(!http_async_req_status(ctx)) ;

    if(cx->host)
    {
        free(cx->host);
        cx->host = NULL;
    }
    if(cx->path)
    {
        free(cx->path);
        cx->path = NULL;
    }
    if(cx->txd)
    {
        free(cx->txd);
        cx->txd = NULL;
        cx->txdl = 0;
    }
    if(cx->hbuf)
    {
        free(cx->hbuf);
        cx->hbuf = NULL;
    }
    if(cx->thdr)
    {
        free(cx->thdr);
        cx->thdr = NULL;
        cx->thlen = 0;
    }

    if(ret)
        *ret = cx->ret;
    if(len)
        *len = cx->rptr;
    if(cx->rbuf)
        cx->rbuf[cx->rptr] = 0;
    rxd = cx->rbuf;
    cx->rbuf = NULL;
    cx->rlen = 0;
    cx->rptr = 0;
    cx->contlen = 0;

    if(!cx->keep)
        http_async_req_close(ctx);
    else if(cx->cclose)
    {
        PCLOSE(cx->fd);
        cx->fd = PERROR;
        if(cx->fdhost)
        {
            free(cx->fdhost);
            cx->fdhost = NULL;
        }
        cx->state = HTS_STRT;
    }
    else
        cx->state = HTS_IDLE;

    return rxd;
}

void http_async_get_length(void *ctx, int *total, int *done)
{
    struct http_ctx *cx = ctx;
    if(done)
        *done = cx->rptr;
    if(total)
        *total = cx->contlen;
}

void http_async_req_close(void *ctx)
{
    struct http_ctx *cx = ctx;
    void *tmp;
    if(cx->host)
    {
        cx->keep = 1;
        tmp = http_async_req_stop(ctx, NULL, NULL);
        if(tmp)
            free(tmp);
    }
    if(cx->fdhost)
        free(cx->fdhost);
    PCLOSE(cx->fd);
    free(ctx);
}

char *http_simple_get(char *uri, int *ret, int *len)
{
    void *ctx = http_async_req_start(NULL, uri, NULL, 0, 0);
    if(!ctx)
    {
        if(ret)
            *ret = 600;
        if(len)
            *len = 0;
        return NULL;
    }
    return http_async_req_stop(ctx, ret, len);
}
static char hex[] = "0123456789abcdef";
void http_auth_headers(void *ctx, char *user, char *pass)
{
    char *tmp;
    int i;
    unsigned char hash[16];
    unsigned int m;
    struct md5_context md5;

    if(user)
    {
        http_async_add_header(ctx, "X-Auth-User", user);
        if(pass)
        {
            md5_init(&md5);
            md5_update(&md5, (unsigned char *)user, strlen(user));
            md5_update(&md5, (unsigned char *)"-", 1);
            m = 0;

            md5_update(&md5, (unsigned char *)pass, strlen(pass));
            md5_final(hash, &md5);
            tmp = malloc(33);
            for(i=0; i<16; i++)
            {
                tmp[i*2] = hex[hash[i]>>4];
                tmp[i*2+1] = hex[hash[i]&15];
            }
            tmp[32] = 0;
            http_async_add_header(ctx, "X-Auth-Hash", tmp);
            free(tmp);
        }
    }
}
char *http_auth_get(char *uri, char *user, char *pass, int *ret, int *len)
{
    void *ctx = http_async_req_start(NULL, uri, NULL, 0, 0);

    if(!ctx)
    {
        if(ret)
            *ret = 600;
        if(len)
            *len = 0;
        return NULL;
    }
    return http_async_req_stop(ctx, ret, len);
}

char *http_simple_post(char *uri, char *data, int dlen, int *ret, int *len)
{
    void *ctx = http_async_req_start(NULL, uri, data, dlen, 0);
    if(!ctx)
    {
        if(ret)
            *ret = 600;
        if(len)
            *len = 0;
        return NULL;
    }
    return http_async_req_stop(ctx, ret, len);
}

char *http_ret_text(int ret)
{
    switch(ret)
    {
    case 100:
        return "Continue";
    case 101:
        return "Switching Protocols";
    case 102:
        return "Processing";

    case 200:
        return "OK";
    case 201:
        return "Created";
    case 202:
        return "Accepted";
    case 203:
        return "Non-Authoritative Information";
    case 204:
        return "No Content";
    case 205:
        return "Reset Content";
    case 206:
        return "Partial Content";
    case 207:
        return "Multi-Status";

    case 300:
        return "Multiple Choices";
    case 301:
        return "Moved Permanently";
    case 302:
        return "Found";
    case 303:
        return "See Other";
    case 304:
        return "Not Modified";
    case 305:
        return "Use Proxy";
    case 306:
        return "Switch Proxy";
    case 307:
        return "Temporary Redirect";

    case 400:
        return "Bad Request";
    case 401:
        return "Unauthorized";
    case 402:
        return "Payment Required";
    case 403:
        return "Forbidden";
    case 404:
        return "Not Found";
    case 405:
        return "Method Not Allowed";
    case 406:
        return "Not Acceptable";
    case 407:
        return "Proxy Authentication Required";
    case 408:
        return "Request Timeout";
    case 409:
        return "Conflict";
    case 410:
        return "Gone";
    case 411:
        return "Length Required";
    case 412:
        return "Precondition Failed";
    case 413:
        return "Request Entity Too Large";
    case 414:
        return "Request URI Too Long";
    case 415:
        return "Unsupported Media Type";
    case 416:
        return "Requested Range Not Satisfiable";
    case 417:
        return "Expectation Failed";
    case 422:
        return "Unprocessable Entity";
    case 423:
        return "Locked";
    case 424:
        return "Failed Dependency";
    case 425:
        return "Unordered Collection";
    case 426:
        return "Upgrade Required";

    case 500:
        return "Internal Server Error";
    case 501:
        return "Not Implemented";
    case 502:
        return "Bad Gateway";
    case 503:
        return "Service Unavailable";
    case 504:
        return "Gateway Timeout";
    case 505:
        return "HTTP Version Not Supported";
    case 506:
        return "Variant Also Negotiates";
    case 507:
        return "Insufficient Storage";
    case 509:
        return "Bandwidth Limit Exceeded";
    case 510:
        return "Not Extended";

    case 600:
        return "Internal Client Error";
    case 601:
        return "Unsupported Protocol";
    case 602:
        return "Server Not Found";
    case 603:
        return "Malformed Response";
    case 604:
        return "Network Not Available";
    case 605:
        return "Request Timed Out";
    default:
        return "Unknown Status Code";
    }
}
char *http_multipart_post(char *uri, char **names, char **parts, int *plens, char *user, char *pass, int *ret, int *len)
{
    void *ctx;
    char *data = NULL, *tmp, *p;
    int dlen = 0, i, j;
    unsigned char hash[16];
    unsigned char boundary[32], ch;
    int blen = 0;
    unsigned int map[62], m;
    struct md5_context md5;
    //struct md5_context md52;
    int own_plen = 0;

    if(names)
    {
        if(!plens)
        {
            own_plen = 1;
            for(i=0; names[i]; i++) ;
            plens = calloc(i, sizeof(int));
            for(i=0; names[i]; i++)
                plens[i] = strlen(parts[i]);
        }

retry:
        if(blen >= 31)
            goto fail;
        memset(map, 0, 62*sizeof(int));
        for(i=0; names[i]; i++)
        {
            for(j=0; j<plens[i]-blen; j++)
                if(!blen || !memcmp(parts[i]+j, boundary, blen))
                {
                    ch = parts[i][j+blen];
                    if(ch>='0' && ch<='9')
                        map[ch-'0']++;
                    else if(ch>='A' && ch<='Z')
                        map[ch-'A'+10]++;
                    else if(ch>='a' && ch<='z')
                        map[ch-'a'+36]++;
                }
        }
        m = ~0;
        j = 61;
        for(i=0; i<62; i++)
            if(map[i]<m)
            {
                m = map[i];
                j = i;
            }
        if(j<10)
            boundary[blen] = '0'+j;
        else if(j<36)
            boundary[blen] = 'A'+(j-10);
        else
            boundary[blen] = 'a'+(j-36);
        blen++;
        if(map[j])
            goto retry;
        boundary[blen] = 0;

        for(i=0; names[i]; i++)
            dlen += blen+strlen(names[i])+plens[i]+128;
        dlen += blen+8;
        data = malloc(dlen);
        dlen = 0;
        for(i=0; names[i]; i++)
        {
            dlen += sprintf(data+dlen, "--%s\r\n", boundary);
            dlen += sprintf(data+dlen, "Content-transfer-encoding: binary\r\n");
            if(strchr(names[i], ':'))
            {
                tmp = mystrdup(names[i]);
                p = strchr(tmp, ':');
                *p = 0;
                dlen += sprintf(data+dlen, "content-disposition: form-data; name=\"%s\"; ", tmp);
                free(tmp);
                p = strchr(names[i], ':');
                dlen += sprintf(data+dlen, "filename=\"%s\"\r\n\r\n", p+1);
            }
            else
                dlen += sprintf(data+dlen, "content-disposition: form-data; name=\"%s\"\r\n\r\n", names[i]);
            memcpy(data+dlen, parts[i], plens[i]);
            dlen += plens[i];
            dlen += sprintf(data+dlen, "\r\n");
        }
        dlen += sprintf(data+dlen, "--%s--\r\n", boundary);
    }

    ctx = http_async_req_start(NULL, uri, data, dlen, 0);
    if(!ctx)
        goto fail;

    if(user)
    {
        http_async_add_header(ctx, "X-Auth-User", user);
        if(pass)
        {
            md5_init(&md5);
            md5_update(&md5, (unsigned char *)user, strlen(user));
            md5_update(&md5, (unsigned char *)"-", 1);
            m = 0;
            if(names)
            {
                for(i=0; names[i]; i++)
                {
                    //md5_update(&md5, (unsigned char *)parts[i], plens[i]); //WHY?
                    //md5_update(&md5, (unsigned char *)"-", 1);
                    p = strchr(names[i], ':');
                    if(p)
                        m += (p - names[i]) + 1;
                    else
                        m += strlen(names[i])+1;
                }

                tmp = malloc(m);
                m = 0;
                for(i=0; names[i]; i++)
                {
                    p = strchr(names[i], ':');
                    if(m)
                    {
                        tmp[m] = ' ';
                        m ++;
                    }
                    if(p)
                    {
                        memcpy(tmp+m, names[i], p-names[i]);
                        m += p - names[i];
                    }
                    else
                    {
                        strcpy(tmp+m, names[i]);
                        m += strlen(names[i]);
                    }
                }
                tmp[m] = 0;
                http_async_add_header(ctx, "X-Auth-Objects", tmp);
                free(tmp);
            }

            md5_update(&md5, (unsigned char *)pass, strlen(pass));
            md5_final(hash, &md5);
            tmp = malloc(33);
            for(i=0; i<16; i++)
            {
                tmp[i*2] = hex[hash[i]>>4];
                tmp[i*2+1] = hex[hash[i]&15];
            }
            tmp[32] = 0;
            http_async_add_header(ctx, "X-Auth-Hash", tmp);
            free(tmp);
        }
    }

    if(data)
    {
        tmp = malloc(32+strlen((char *)boundary));
        sprintf(tmp, "multipart/form-data, boundary=%s", boundary);
        http_async_add_header(ctx, "Content-type", tmp);
        free(tmp);
        free(data);
    }

    if(own_plen)
        free(plens);
    return http_async_req_stop(ctx, ret, len);

fail:
    if(data)
        free(data);
    if(own_plen)
        free(plens);
    if(ret)
        *ret = 600;
    if(len)
        *len = 0;
    return NULL;
}