#include <stdio.h>
#include <sys/types.h>
#include <yaz/snprintf.h>
#include <stdlib.h>
#include <string.h>
#include <ctype.h>
#include <fcntl.h>
#include <errno.h>
#include <assert.h>
#include <yaz/yaz-util.h>
#include <yaz/comstack.h>
#include <yaz/nmem.h>
#include <yaz/mutex.h>
#include "ppmutex.h"
#include "session.h"
#include "http.h"
#include "parameters.h"

Data Structures
struct	http_buf

struct	http_server

struct	http_channel_observer_s

Macros
#define	MAX_HTTP_HEADER 4096

#define	HTTP_BUF_SIZE 4096

#define	CLOSESOCKET(x) close(x)

Functions
static void	proxy_io (IOCHAN i, int event)

static struct http_channel *	http_channel_create (http_server_t http_server, const char addr, struct conf_server server)

static void	http_channel_destroy (IOCHAN i)

static http_server_t	http_server_create (void)

static void	http_server_incref (http_server_t hs)

const char *	http_lookup_header (struct http_header header, const char name)

static struct http_buf *	http_buf_create (http_server_t hs)

static void	http_buf_destroy (http_server_t hs, struct http_buf *b)

static void	http_buf_destroy_queue (http_server_t hs, struct http_buf *b)

static struct http_buf *	http_buf_bybuf (http_server_t hs, char *b, int len)

static void	http_buf_enqueue (struct http_buf *queue, struct http_buf b)

static struct http_buf *	http_buf_bywrbuf (http_server_t hs, WRBUF wrbuf)

static void	http_buf_peek (struct http_buf b, char buf, int len)

static int	http_buf_size (struct http_buf *b)

static int	http_buf_read (http_server_t hs, struct http_buf *b, char buf, int len)

static void	urldecode (char i, char o)

void	urlencode (const char i, char o)

void	http_addheader (struct http_response r, const char name, const char *value)

const char *	http_argbyname (struct http_request r, const char name)

const char *	http_headerbyname (struct http_header h, const char name)

struct http_response *	http_create_response (struct http_channel *c)

static const char *	next_crlf (const char cp, size_t skipped)

static int	package_check (const char *buf, int sz)

static int	request_check (struct http_buf *queue)

struct http_response *	http_parse_response_buf (struct http_channel c, const char buf, int len)

static int	http_parse_arguments (struct http_request r, NMEM nmem, const char args)

struct http_request *	http_parse_request (struct http_channel c, struct http_buf *queue, int len)

static struct http_buf *	http_serialize_response (struct http_channel c, struct http_response r)

static struct http_buf *	http_serialize_request (struct http_request *r)

static int	http_weshouldproxy (struct http_request *rq)

struct http_header *	http_header_append (struct http_channel ch, struct http_header hp, const char name, const char value)

static int	is_inprogress (void)

static void	enable_nonblock (int sock)

static int	http_proxy (struct http_request *rq)

void	http_send_response (struct http_channel *ch)

static void	http_error (struct http_channel hc, int no, const char msg)

static void	http_io (IOCHAN i, int event)

static void	http_fire_observers (struct http_channel *c)

static void	http_destroy_observers (struct http_channel *c)

static void	http_accept (IOCHAN i, int event)

int	http_init (struct conf_server server, const char record_fname)

void	http_close_server (struct conf_server *server)

void	http_set_proxyaddr (const char host, struct conf_server server)

http_channel_observer_t	http_add_observer (struct http_channel c, void data, http_channel_destroy_t des)

void	http_remove_observer (http_channel_observer_t obs)

struct http_channel *	http_channel_observer_chan (http_channel_observer_t obs)

void	http_observer_set_data2 (http_channel_observer_t obs, void *data2)

void	http_server_destroy (http_server_t hs)

void	http_mutex_init (struct conf_server *server)