/*	$Id: http.c,v 1.17 2016/12/02 12:38:29 kristaps Exp $ */
/*
 * Copyright (c) 2016 Kristaps Dzonsons <kristaps@bsd.lv>
 *
 * Permission to use, copy, modify, and distribute this software for any
 * purpose with or without fee is hereby granted, provided that the above
 * copyright notice and this permission notice appear in all copies.
 *
 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHORS DISCLAIM ALL WARRANTIES
 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHORS BE LIABLE FOR
 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 */
#ifdef HAVE_CONFIG_H
# include "config.h"
#endif

#include <sys/socket.h>
#ifndef __VMS
#include <sys/param.h>
#endif
#include <arpa/inet.h>
#if TLS_API < 20160801
# include <sys/stat.h>
# include <sys/mman.h>
#endif

#include <assert.h>
#include <ctype.h>
#include <err.h>
#if TLS_API < 20160801
# include <fcntl.h>
#endif
#include <limits.h>
#include <netdb.h>
#include <stdio.h>
#ifndef __VMS
#include <stdint.h>
#else
#include <inttypes.h>
#endif
#include <stdlib.h>
#include <string.h>
#ifndef __VMS
#include <tls.h>
#else
#include "libtls/tls.h"
#endif
#include <unistd.h>

#include "http.h"
#include "extern.h"

#ifndef WCMEIDIOM
#ifndef DEFAULT_CA_FILE
# define DEFAULT_CA_FILE "/etc/ssl/cert.pem"
#endif
#else
# undef DEFAULT_CA_FILE
# define DEFAULT_CA_FILE "WCME_CACERT"
#endif

/*
 * A buffer for transferring HTTP/S data.
 */
struct	httpxfer {
	char		*hbuf;    /* header transfer buffer */
	size_t		 hbufsz;  /* header buffer size */
	int		 headok;  /* header has been parsed */
	char		*bbuf;    /* body transfer buffer */
	size_t		 bbufsz;  /* body buffer size */
	int		 bodyok;  /* body has been parsed */
	char		*headbuf; /* lookaside buffer for headers */
	struct httphead	*head;    /* parsed headers */
	size_t		 headsz;  /* number of headers */
};

/*
 * An HTTP/S connection object.
 */
struct	http {
	int		   fd;     /* connected socket */
	short		   port;   /* port number */
	struct source	   src;    /* endpoint (raw) host */
	char		  *path;   /* path to request */
	char		  *host;   /* name of endpoint host */
	struct tls	  *ctx;    /* if TLS */
	writefp		   writer; /* write function */
	readfp		   reader; /* read function */
};

struct	httpcfg {
	struct tls_config *tlscfg;
};

static ssize_t
dosysread(char *buf, size_t sz, const struct http *http)
{
	ssize_t	 rc;

	rc = read(http->fd, buf, sz);
	if (rc < 0)
		warn("%s: read", http->src.ip);
	return (rc);
}

static ssize_t
dosyswrite(const void *buf, size_t sz, const struct http *http)
{
	ssize_t	 rc;

	rc = write(http->fd, buf, sz);
	if (rc < 0)
		warn("%s: write", http->src.ip);
	return(rc);
}

#if defined(TLS_READ_AGAIN) && defined(TLS_WRITE_AGAIN)
/*
 * Old-style libtls calls.
 * These changed between 5.8 and 5.9.
 */
static ssize_t
dotlsread(char *buf, size_t sz, const struct http *http)
{
	size_t	out, tot = 0;
	int	rc;

	for (;;) {
		out = 0;
		rc = tls_read(http->ctx, buf, sz, &out);
		if (out > 0) {
			buf += out;
			assert(sz >= out);
			sz -= out;
			tot += out;
		}
		if (TLS_READ_AGAIN == rc)
			continue;
		else if (0 == out || 0 == sz || 0 == rc)
			break;
		warnx("%s: tls_read: %s", 
			http->src.ip, tls_error(http->ctx));
		return(-1);
	} 

	return(tot);
}

static ssize_t
dotlswrite(const void *buf, size_t sz, const struct http *http)
{
	size_t	 out, tot = 0;
	int	 rc;

	for (;;) {
		out = 0;
		rc = tls_write(http->ctx, buf, sz, &out);
		if (out > 0) {
			buf += out;
			assert(sz >= out);
			sz -= out;
			tot += out;
		}
		if (TLS_WRITE_AGAIN == rc) 
			continue;
		else if (0 == out || 0 == rc || 0 == rc)
			break;
		warnx("%s: tls_write: %s", 
			http->src.ip, tls_error(http->ctx));
		return(-1);
	} 

	return(tot);
}
#else
/*
 * New-style libtls calls.
 */
static ssize_t
dotlsread(char *buf, size_t sz, const struct http *http)
{
	ssize_t	 rc;
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) dotlsread() %d", __LINE__, sz);
#endif
	do {
		rc = tls_read(http->ctx, buf, sz);
	} while (TLS_WANT_POLLIN == rc || TLS_WANT_POLLOUT == rc);

	if (rc < 0)
		warnx("%s: tls_read: %s",
			http->src.ip,
			tls_error(http->ctx));
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) dotlsread() %d |%.*s|",
                __LINE__, rc, rc, exctrl(buf,rc));
#endif
	return (rc);
}

static ssize_t
dotlswrite(const void *buf, size_t sz, const struct http *http)
{
	ssize_t	 rc;
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) dotlswrite() %d", __LINE__, sz);
#endif

	do {
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) dotlswrite() %d", __LINE__, sz);
#endif
		rc = tls_write(http->ctx, buf, sz);
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) dotlswrite() %d", __LINE__, rc);
#endif
	} while (TLS_WANT_POLLIN == rc || TLS_WANT_POLLOUT == rc);

	if (rc < 0)
		warnx("%s: tls_write: %s",
			http->src.ip,
			tls_error(http->ctx));

#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) dotlswrite() %d", __LINE__, rc);
#endif
	return (rc);
}
#endif

/*
 * Free the resources of an http_init() object.
 */
void
http_uninit(struct httpcfg *p)
{

	if (NULL == p)
		return;
	if (NULL != p->tlscfg)
		tls_config_free(p->tlscfg);
	free(p);
}

/*
 * Work around the "lazy-loading" problem in earlier versions of libtls.
 * In these systems, using tls_config_set_ca_file() would only cause the
 * file location to be copied.
 * It would then be used after the pledge and/or chroot.
 * We work around this by loading the file directly.
 */
#if TLS_API < 20160801
static int
http_config_set_ca_file(struct httpcfg *p)
{
	int	 	 fd, rc = 0;
	struct stat	 st;
	void		*buf;

#ifndef __VMS
	if (-1 == (fd = open(DEFAULT_CA_FILE, O_RDONLY, 0))) {
		warn("%s", DEFAULT_CA_FILE);
		return(0);
	} else if (-1 == fstat(fd, &st)) {
		warn("%s", DEFAULT_CA_FILE);
		close(fd);
		return(0);
	}
#else
        /* potentially protected (certainly for WASD) */
        UtilSysPrv();
	if (-1 == (fd = open(DEFAULT_CA_FILE, O_RDONLY, 0))) {
                UtilMereMortal();
		warn("%s", DEFAULT_CA_FILE);
		return(0);
	} else if (-1 == fstat(fd, &st)) {
                UtilMereMortal();
		warn("%s", DEFAULT_CA_FILE);
		close(fd);
		return(0);
	}
        UtilMereMortal();
#endif /* __VMS */
	buf = mmap(NULL, st.st_size, PROT_READ, MAP_SHARED, fd, 0);
	if (MAP_FAILED == buf) {
		warn("%s", DEFAULT_CA_FILE);
		close(fd);
		return(0);
	}
	if (-1 == tls_config_set_ca_mem(p->tlscfg, buf, st.st_size))
		warn("%s: tls_config_set_ca_file", DEFAULT_CA_FILE);
	else
		rc = 1;
	munmap(buf, st.st_size);
	close(fd);
	return(rc);
}
#endif

/*
 * This function allocates a configuration shared among multiple
 * connections.
 * It will generally be called once, then used in a series of
 * connections.
 * Returns the configuration object or NULL on errors.
 * A returned object must be freed with http_deinit().
 */
struct httpcfg *
http_init(void)
{
	struct httpcfg	*p;
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_init()", __LINE__);
#endif

	/* Can be called more than once. */

	if (-1 == tls_init()) {
		warn("tls_init");
		return (NULL);
	}

	if (NULL == (p = malloc(sizeof(struct httpcfg)))) {
		warn("calloc");
		return (NULL);
	} else if (NULL == (p->tlscfg = tls_config_new())) {
		warn("tls_config_new");
		goto err;
	}

	tls_config_set_protocols(p->tlscfg, TLS_PROTOCOLS_ALL);

#if TLS_API < 20160801
	if ( ! http_config_set_ca_file(p))
		goto err;
#else
#ifndef __VMS
	if (-1 == tls_config_set_ca_file(p->tlscfg, DEFAULT_CA_FILE)) {
		warn("tls_config_set_ca_file: %s", 
			tls_config_error(p->tlscfg));
		goto err;
	}
#else
        /* potentially protected (certainly for WASD) */
        UtilSysPrv();
	if (-1 == tls_config_set_ca_file(p->tlscfg, DEFAULT_CA_FILE)) {
                UtilMereMortal();
                warn("tls_config_set_ca_file: %s", 
                        tls_config_error(p->tlscfg));
                goto err;
	}
        UtilMereMortal();
#endif /* __VMS */
#endif

#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_init()", __LINE__);
#endif
	if (-1 == tls_config_set_ciphers(p->tlscfg, "compat")) {
#if TLS_API < 20160801
		warn("tls_config_set_ciphers");
#else
		warn("tls_config_set_ciphers: %s", 
			tls_config_error(p->tlscfg));
#endif
		goto err;
	}

#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_init()", __LINE__);
#endif
	return (p);
 err:
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_init()", __LINE__);
#endif
	http_uninit(p);
	return (NULL);
}

static ssize_t
http_read(char *buf, size_t sz, const struct http *http)
{
	ssize_t	 ssz, xfer;
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_read() %d", __LINE__, sz);
#endif

	xfer = 0;
	do {
		if ((ssz = http->reader(buf, sz, http)) < 0)
			return (-1);
		if (0 == ssz)
			break;
		xfer += ssz;
		sz -= ssz;
		buf += ssz;
	} while (ssz > 0 && sz > 0);

#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_read() %d", __LINE__, xfer);
#endif
	return (xfer);
}

static int
http_write(const char *buf, size_t sz, const struct http *http)
{
	ssize_t	 ssz, xfer;

#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_write() %d", __LINE__, sz);
#endif
	xfer = sz;
	while (sz > 0) {
		if ((ssz = http->writer(buf, sz, http)) < 0)
			return (-1);
		sz -= ssz;
		buf += (size_t)ssz;
	}

#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_write() %d", __LINE__, xfer);
#endif
	return (xfer);
}

/*
 * Between 5.8 and 5.9, libtls changed its semantics.
 * In the old way, tls_close() will close the underlying file
 * descriptors.
 * In the new way, it won't.
 * Also account for the TLS_READ_AGAIN invocation versus the new
 * TLS_WANT_POLLIN.
 */
void
http_disconnect(struct http *http)
{
	int	 rc;
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_disconnect()", __LINE__);
#endif

	if (NULL != http->ctx) {
#if defined(TLS_READ_AGAIN) && defined(TLS_WRITE_AGAIN)
		/* Old-style. */
		do {
			rc = tls_close(http->ctx);
		} while (TLS_READ_AGAIN == rc || TLS_WRITE_AGAIN == rc);
		if (rc < 0)
			warnx("%s: tls_close: %s",
				http->src.ip, tls_error(http->ctx));
#else
		/* New-style. */
		do {
			rc = tls_close(http->ctx);
		} while (TLS_WANT_POLLIN == rc || TLS_WANT_POLLOUT == rc);
		if (rc < 0)
			warnx("%s: tls_close: %s",
				http->src.ip, tls_error(http->ctx));
		if (-1 == close(http->fd))
			warn("%s: close", http->src.ip);
#endif
		tls_free(http->ctx);
	} else if (-1 != http->fd) {
		/* Non-TLS connection. */
		if (-1 == close(http->fd))
			warn("%s: close", http->src.ip);
	}

#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_disconnect()", __LINE__);
#endif
	http->fd = -1;
	http->ctx = NULL;
}

void
http_free(struct http *http)
{

	if (NULL == http)
		return;
	http_disconnect(http);
	free(http->host);
	free(http->path);
	free(http->src.ip);
	free(http);
}

struct http *
http_alloc(struct httpcfg *cfg, 
	const struct source *addrs, size_t addrsz,
	const char *host, short port, const char *path)
{
	struct sockaddr_storage ss;
	int		 family, fd, c;
	socklen_t	 len;
	size_t		 cur, i = 0;
	struct http	*http;

	/* Do this while we still have addresses to connect. */
again:
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_alloc() %s:%d", __LINE__, host, port);
#endif
	if (i == addrsz)
		return (NULL);
	cur = i++;

	/* Convert to PF_INET or PF_INET6 address from string. */

	memset(&ss, 0, sizeof(struct sockaddr_storage));

	if (4 == addrs[cur].family) {
		family = PF_INET;
		((struct sockaddr_in *)&ss)->sin_family = AF_INET;
		((struct sockaddr_in *)&ss)->sin_port = htons(port);
		c = inet_pton(AF_INET, addrs[cur].ip,
			&((struct sockaddr_in *)&ss)->sin_addr);
		len = sizeof(struct sockaddr_in);
	} else if (6 == addrs[cur].family) {
		family = PF_INET6;
		((struct sockaddr_in6 *)&ss)->sin6_family = AF_INET6;
		((struct sockaddr_in6 *)&ss)->sin6_port = htons(port);
		c = inet_pton(AF_INET6, addrs[cur].ip,
			&((struct sockaddr_in6 *)&ss)->sin6_addr);
		len = sizeof(struct sockaddr_in6);
	} else {
		warnx("%s: unknown family", addrs[cur].ip);
		goto again;
	}

	if (c < 0) {
		warn("%s: inet_ntop", addrs[cur].ip);
		goto again;
	} else if (0 == c) {
		warnx("%s: inet_ntop", addrs[cur].ip);
		goto again;
	}

	/* Create socket and connect. */

	fd = socket(family, SOCK_STREAM, 0);
	if (-1 == fd) {
		warn("%s: socket", addrs[cur].ip);
		goto again;
	} else if (-1 == connect(fd, (struct sockaddr *)&ss, len)) {
#ifndef WCMEIDIOM
		warn("%s: connect", addrs[cur].ip);
#endif
		close(fd);
		goto again;
	}

	/* Allocate the communicator. */
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_alloc()", __LINE__);
#endif

	http = calloc(1, sizeof(struct http));
	if (NULL == http) {
		warn("calloc");
		close(fd);
		return (NULL);
	}
	http->fd = fd;
	http->port = port;
	http->src.family = addrs[cur].family;
	http->src.ip = strdup(addrs[cur].ip);
	http->host = strdup(host);
	http->path = strdup(path);
	if (NULL == http->src.ip ||
	    NULL == http->host ||
	    NULL == http->path) {
		warn("strdup");
		goto err;
	}

	/* If necessary, do our TLS setup. */
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_alloc()", __LINE__);
#endif

	if (443 != port) {
		http->writer = dosyswrite;
		http->reader = dosysread;
		return (http);
	}

	http->writer = dotlswrite;
	http->reader = dotlsread;

	if (NULL == (http->ctx = tls_client())) {
		warn("tls_client");
		goto err;
	} else if (-1 == tls_configure(http->ctx, cfg->tlscfg)) {
		warnx("%s: tls_configure: %s",
			http->src.ip, tls_error(http->ctx));
		goto err;
	}

#ifndef __VMS
	if (0 != tls_connect_socket
	     (http->ctx, http->fd, http->host)) {
		warnx("%s: tls_connect_socket: %s, %s",
			http->src.ip, http->host,
			tls_error(http->ctx));
		goto err;
	}
#else
        UtilSysPrv();
	if (0 != tls_connect_socket
	     (http->ctx, http->fd, http->host)) {
                UtilMereMortal();
		warnx("%s: tls_connect_socket: %s, %s",
			http->src.ip, http->host,
			tls_error(http->ctx));
		goto err;
	}
        UtilMereMortal();
#endif

	return (http);
err:
	http_free(http);
	return (NULL);
}

struct httpxfer *
http_open(const struct http *http, const void *p, size_t psz)
{
	char		*req;
	int		 c;
	struct httpxfer	*trans;
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_open()", __LINE__);
#endif

	if (NULL == p) {
		c = asprintf(&req,
			"GET %s HTTP/1.0\r\n"
			"Host: %s\r\n"
			"\r\n",
			http->path, http->host);
	} else {
		c = asprintf(&req,
			"POST %s HTTP/1.0\r\n"
			"Host: %s\r\n"
#ifndef __VMS
			"Content-Length: %zu\r\n"
#else
			"Content-Length: %u\r\n"
#endif
			"\r\n",
			http->path, http->host, psz);
	}
	if (-1 == c) {
		warn("asprintf");
		return (NULL);
	} else if ( ! http_write(req, c, http)) {
		free(req);
		return (NULL);
	} else if (NULL != p && ! http_write(p, psz, http)) {
		free(req);
		return (NULL);
	}

	free(req);

	trans = calloc(1, sizeof(struct httpxfer));
	if (NULL == trans)
		warn("calloc");
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_open()", __LINE__);
#endif
	return (trans);
}

void
http_close(struct httpxfer *x)
{

	if (NULL == x)
		return;
	free(x->hbuf);
	free(x->bbuf);
	free(x->headbuf);
	free(x->head);
	free(x);
}

/*
 * Read the HTTP body from the wire.
 * If invoked multiple times, this will return the same pointer with the
 * same data (or NULL, if the original invocation returned NULL).
 * Returns NULL if read or allocation errors occur.
 * You must not free the returned pointer.
 */
char *
http_body_read(const struct http *http,
	struct httpxfer *trans, size_t *sz)
{
	char		 buf[BUFSIZ];
	ssize_t		 ssz;
	void		*pp;
	size_t		 szp;
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_body_read()", __LINE__);
#endif

	if (NULL == sz)
		sz = &szp;

	/* Have we already parsed this? */

	if (trans->bodyok > 0) {
		*sz = trans->bbufsz;
		return (trans->bbuf);
	} else if (trans->bodyok < 0)
		return (NULL);

	*sz = 0;
	trans->bodyok = -1;

	do {
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_body_read()", __LINE__);
#endif
		/* If less than sizeof(buf), at EOF. */
		if ((ssz = http_read(buf, sizeof(buf), http)) < 0)
			return (NULL);
		else if (0 == ssz)
			break;
		pp = realloc(trans->bbuf, trans->bbufsz + ssz);
		if (NULL == pp) {
			warn("realloc");
			return (NULL);
		}
		trans->bbuf = pp;
		memcpy(trans->bbuf + trans->bbufsz, buf, ssz);
		trans->bbufsz += ssz;
	} while (sizeof(buf) == ssz);

	trans->bodyok = 1;
	*sz = trans->bbufsz;
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_body_read()", __LINE__);
#endif
	return (trans->bbuf);
}

struct httphead *
http_head_get(const char *v, struct httphead *h, size_t hsz)
{
	size_t	 i;

	for (i = 0; i < hsz; i++) {
		if (strcmp(h[i].key, v))
			continue;
		return (&h[i]);
	}
	return (NULL);
}

/*
 * Look through the headers and determine our HTTP code.
 * This will return -1 on failure, otherwise the code.
 */
int
http_head_status(const struct http *http,
	struct httphead *h, size_t sz)
{
	int		 rc;
	unsigned int	 code;
	struct httphead *st;

	if (NULL == (st = http_head_get("Status", h, sz))) {
		warnx("%s: no status header", http->src.ip);
		return (-1);
	}

	rc = sscanf(st->val, "%*s %u %*s", &code);
	if (rc < 0) {
		warn("sscanf");
		return (-1);
	} else if (1 != rc) {
		warnx("%s: cannot convert status header",
			http->src.ip);
		return (-1);
	}
	return (code);
}

/*
 * Parse headers from the transfer.
 * Malformed headers are skipped.
 * A special "Status" header is added for the HTTP status line.
 * This can only happen once http_head_read has been called with
 * success.
 * This can be invoked multiple times: it will only parse the headers
 * once and after that it will just return the cache.
 * You must not free the returned pointer.
 * If the original header parse failed, or if memory allocation fails
 * internally, this returns NULL.
 */
struct httphead *
http_head_parse(const struct http *http,
	struct httpxfer *trans, size_t *sz)
{
	size_t		 hsz, szp;
	struct httphead	*h;
	char		*cp, *ep, *ccp, *buf;

	if (NULL == sz)
		sz = &szp;

	/*
	 * If we've already parsed the headers, return the
	 * previously-parsed buffer now.
	 * If we have errors on the stream, return NULL now.
	 */

	if (NULL != trans->head) {
		*sz = trans->headsz;
		return (trans->head);
	} else if (trans->headok <= 0)
		return (NULL);

	if (NULL == (buf = strdup(trans->hbuf))) {
		warn("strdup");
		return (NULL);
	}
	hsz = 0;
	cp = buf;

	do {
		if (NULL != (cp = strstr(cp, "\r\n")))
			cp += 2;
		hsz++;
	} while (NULL != cp);

	/*
	 * Allocate headers, then step through the data buffer, parsing
	 * out headers as we have them.
	 * We know at this point that the buffer is nil-terminated in
	 * the usual way.
	 */

	h = calloc(hsz, sizeof(struct httphead));
	if (NULL == h) {
		warn("calloc");
		free(buf);
		return (NULL);
	}

	*sz = hsz;
	hsz = 0;
	cp = buf;

	do {
		if (NULL != (ep = strstr(cp, "\r\n"))) {
			*ep = '\0';
			ep += 2;
		}
		if (0 == hsz) {
			h[hsz].key = "Status";
			h[hsz++].val = cp;
			continue;
		}

		/* Skip bad headers. */
		if (NULL == (ccp = strchr(cp, ':'))) {
			warnx("%s: header without separator",
				http->src.ip);
			continue;
		}

		*ccp++ = '\0';
		while (isspace((int)*ccp))
			ccp++;
		h[hsz].key = cp;
		h[hsz++].val = ccp;
	} while (NULL != (cp = ep));

	trans->headbuf = buf;
	trans->head = h;
	trans->headsz = hsz;
	return (h);
}

/*
 * Read the HTTP headers from the wire.
 * If invoked multiple times, this will return the same pointer with the
 * same data (or NULL, if the original invocation returned NULL).
 * Returns NULL if read or allocation errors occur.
 * You must not free the returned pointer.
 */
char *
http_head_read(const struct http *http,
	struct httpxfer *trans, size_t *sz)
{
	char		 buf[BUFSIZ];
	ssize_t		 ssz;
	char		*ep;
	void		*pp;
	size_t		 szp;
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_head_read()", __LINE__);
#endif

	if (NULL == sz)
		sz = &szp;

	/* Have we already parsed this? */

	if (trans->headok > 0) {
		*sz = trans->hbufsz;
		return (trans->hbuf);
	} else if (trans->headok < 0)
		return (NULL);

	*sz = 0;
	ep = NULL;
	trans->headok = -1;

	/*
	 * Begin by reading by BUFSIZ blocks until we reach the header
	 * termination marker (two CRLFs).
	 * We might read into our body, but that's ok: we'll copy out
	 * the body parts into our body buffer afterward.
	 */

	do {
		/* If less than sizeof(buf), at EOF. */
		if ((ssz = http_read(buf, sizeof(buf), http)) < 0)
			return (NULL);
		else if (0 == ssz)
			break;
		pp = realloc(trans->hbuf, trans->hbufsz + ssz);
		if (NULL == pp) {
			warn("realloc");
			return (NULL);
		}
		trans->hbuf = pp;
		memcpy(trans->hbuf + trans->hbufsz, buf, ssz);
		trans->hbufsz += ssz;
		/* Search for end of headers marker. */
		ep = memmem(trans->hbuf, trans->hbufsz, "\r\n\r\n", 4);
	} while (NULL == ep && sizeof(buf) == ssz);

	if (NULL == ep) {
		warnx("%s: partial transfer", http->src.ip);
		return (NULL);
	}
	*ep = '\0';

	/*
	 * The header data is invalid if it has any binary characters in
	 * it: check that now.
	 * This is important because we want to guarantee that all
	 * header keys and pairs are properly nil-terminated.
	 */

	if (strlen(trans->hbuf) != (uintptr_t)(ep - trans->hbuf)) {
		warnx("%s: binary data in header", http->src.ip);
		return (NULL);
	}

	/*
	 * Copy remaining buffer into body buffer.
	 */

	ep += 4;
	trans->bbufsz = (trans->hbuf + trans->hbufsz) - ep;
	trans->bbuf = malloc(trans->bbufsz);
	if (NULL == trans->bbuf) {
		warn("malloc");
		return (NULL);
	}
	memcpy(trans->bbuf, ep, trans->bbufsz);

	trans->headok = 1;
	*sz = trans->hbufsz;
	return (trans->hbuf);
}

void
http_get_free(struct httpget *g)
{

	if (NULL == g)
		return;
	http_close(g->xfer);
	http_free(g->http);
	free(g);
}

struct httpget *
http_get(struct httpcfg *cfg,
	const struct source *addrs, size_t addrsz,
	const char *domain, short port, const char *path,
	const void *post, size_t postsz)
{
	struct http	*h;
	struct httpxfer	*x;
	struct httpget	*g;
	struct httphead	*head;
	size_t		 headsz, bodsz, headrsz;
	int		 code;
	char		*bod, *headr;
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_get()", __LINE__);
#endif

	h = http_alloc(cfg, addrs, addrsz, domain, port, path);
	if (NULL == h)
		return (NULL);

	if (NULL == (x = http_open(h, post, postsz))) {
		http_free(h);
		return (NULL);
	} else if (NULL == (headr = http_head_read(h, x, &headrsz))) {
		http_close(x);
		http_free(h);
		return (NULL);
	} else if (NULL == (bod = http_body_read(h, x, &bodsz))) {
		http_close(x);
		http_free(h);
		return (NULL);
	}

	http_disconnect(h);

	if (NULL == (head = http_head_parse(h, x, &headsz))) {
		http_close(x);
		http_free(h);
		return (NULL);
	} else if ((code = http_head_status(h, head, headsz)) < 0) {
		http_close(x);
		http_free(h);
		return (NULL);
	}

	if (NULL == (g = calloc(1, sizeof(struct httpget)))) {
		warn("calloc");
		http_close(x);
		http_free(h);
		return (NULL);
	}

	g->headpart = headr;
	g->headpartsz = headrsz;
	g->bodypart = bod;
	g->bodypartsz = bodsz;
	g->head = head;
	g->headsz = headsz;
	g->code = code;
	g->xfer = x;
	g->http = h;
#ifdef WCMEDBGHTTP
        doddbg ("(http:%d) http_get()", __LINE__);
#endif
	return (g);
}

#if 0
int
main(void)
{
	struct httpget	*g;
	struct httphead	*httph;
	size_t		 i, httphsz;
	struct source	 addrs[2];
	size_t		 addrsz;

#if 0
	addrs[0].ip = "127.0.0.1";
	addrs[0].family = 4;
	addrsz = 1;
#else
	addrs[0].ip = "2a00:1450:400a:806::2004";
	addrs[0].family = 6;
	addrs[1].ip = "193.135.3.123";
	addrs[1].family = 4;
	addrsz = 2;
#endif

#if 0
	g = http_get(addrs, addrsz, "localhost", 80, "/index.html");
#else
	g = http_get(addrs, addrsz, "www.google.ch", 80, "/index.html",
		     NULL, 0);
#endif

	if (NULL == g)
		errx(EXIT_FAILURE, "http_get");

	httph = http_head_parse(g->http, g->xfer, &httphsz);
	warnx("code: %d", g->code);

	for (i = 0; i < httphsz; i++)
		warnx("head: [%s]=[%s]", httph[i].key, httph[i].val);

	http_get_free(g);
	return (EXIT_SUCCESS);
}
#endif