/*
 * HTTP handling functions.
 *
 * Copyright 2003 Ferenc Wagner
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library 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
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 *
 */
#include <winsock.h>
#include <stdio.h>

#include "winetest.h"

SOCKET
open_http (const char *ipnum)
{
    WSADATA wsad;
    struct sockaddr_in sa;
    SOCKET s;

    if (WSAStartup (MAKEWORD (2,2), &wsad)) return INVALID_SOCKET;

    s = socket (AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (s != INVALID_SOCKET) {
        sa.sin_family = AF_INET;
        sa.sin_port = htons (80);
        sa.sin_addr.s_addr = inet_addr (ipnum);
        if (!connect (s, (struct sockaddr*)&sa,
                      sizeof (struct sockaddr_in)))
            return s;
    }
    WSACleanup ();
    return INVALID_SOCKET;
}

int
close_http (SOCKET s)
{
    int ret;

    ret = closesocket (s);
    return (WSACleanup () || ret);
}

int
send_buf (SOCKET s, const char *buf, size_t length)
{
    int sent;

    while (length > 0) {
        sent = send (s, buf, length, 0);
        if (sent == SOCKET_ERROR) return 1;
        buf += sent;
        length -= sent;
    }
    return 0;
}

int
send_str (SOCKET s, const char *fmt, ...)
{
    va_list ap;
    char *p;
    int ret;
    size_t len;

    va_start (ap, fmt);
    p = vstrmake (&len, fmt, ap);
    va_end (ap);
    if (!p) return 1;
    ret = send_buf (s, p, len);
    free (p);
    return ret;
}

int
send_file (const char *name)
{
    SOCKET s;
    FILE *f;
    unsigned char buffer[8192];
    size_t bytes_read, total, filesize;
    char *str;
    int ret;

    /* RFC 2068 */
#define SEP "-"
    const char head[] = "POST /~wferi/cgi-bin/winetests.cgi HTTP/1.0\r\n"
        "Host: afavant\r\n"
        "User-Agent: Winetests Shell\r\n"
        "Content-Type: multipart/form-data; boundary=" SEP "\r\n"
        "Content-Length: %u\r\n\r\n";
    const char body1[] = "--" SEP "\r\n"
        "Content-Disposition: form-data; name=reportfile; filename=\"%s\"\r\n"
        "Content-Type: application/octet-stream\r\n\r\n";
    const char body2[] = "\r\n--" SEP "\r\n"
        "Content-Dispoition: form-data; name=submit\r\n\r\n"
        "Upload File\r\n"
        "--" SEP "--\r\n";

    s = open_http ("157.181.170.47");
    if (s == INVALID_SOCKET) {
        fprintf (stderr, "Can't open connection: %x.\n",
                 WSAGetLastError ());
        return 1;
    }

    f = fopen (name, "rb");
    if (!f) goto abort1;
    fseek (f, 0, SEEK_END);
    filesize = ftell (f);
    if (filesize > 1024*1024) goto abort2;
    fseek (f, 0, SEEK_SET);

    str = strmake (&total, body1, name);
    ret = send_str (s, head, filesize + total + sizeof body2 - 1) ||
        send_buf (s, str, total);
    free (str);
    if (ret) {
        fprintf (stderr, "Can't send header.\n");
        goto abort2;
    }

    while ((bytes_read = fread (buffer, 1, sizeof buffer, f)))
        if (send_buf (s, buffer, bytes_read)) {
            fprintf (stderr, "Can't send body.\n");
            goto abort2;
        }
    fclose (f);

    if (send_buf (s, body2, sizeof body2 - 1)) {
        fprintf (stderr, "Can't send trailer.\n");
        goto abort2;
    }

    total = 0;
    while ((bytes_read = recv (s, buffer + total,
                               sizeof buffer - total, 0))) {
        if ((signed)bytes_read == SOCKET_ERROR) {
            fprintf (stderr, "Error receiving response: %d.\n",
                     WSAGetLastError ());
            goto abort1;
        }
        total += bytes_read;
        if (total == sizeof buffer) {
            fprintf (stderr, "Buffer overflow.\n");
            goto abort1;
        }
    }
    if (close_http (s)) {
        fprintf (stderr, "Error closing connection.\n");
        return 1;
    }

    str = strmake (&bytes_read, "Received %s (%d bytes).\n",
                   name, filesize);
    ret = memcmp (str, buffer + total - bytes_read, bytes_read);
    free (str);
    return ret!=0;

 abort2:
    fclose (f);
 abort1:
    close_http (s);
    return 1;
}