tango-tfe/plugin/protocol/http/include/internal/http_common.h

#pragma once

extern "C"
{
#include <sys/queue.h>
}

#include <tfe_http.h>
#include <http_parser.h>

struct http_plugin
{
};

TAILQ_HEAD(hs_private_list, http_session_private);
struct http_session_private
{
	struct tfe_http_session hs_public;
	TAILQ_ENTRY(http_session_private) next;
	struct http_connection_private * hc_private;
	struct ht_frame_session_ctx * ht_frame;
};

struct http_connection_private
{
	/* ADDRESS */
	struct tfe_stream_addr * layer_addr;
	/* STREAM */
	struct tfe_stream * stream;
	/* SESSION LIST, REQUEST-RESPONSE PAIRS */
	struct hs_private_list hs_private_list;
	/* IS PREEMPTED */
	unsigned int is_preempted;
	/* SESSION ID COUNTER */
	unsigned int session_id_counter;
};

TAILQ_HEAD(http_header_private_list, http_header_private);
struct http_header_private
{
	TAILQ_ENTRY(http_header_private) next;
	struct http_field_name * field;
	char * value;
};

enum hf_private_status
{
	STATUS_INIT,
	STATUS_READING,
	STATUS_COMPLETE,
};

struct http_half_private
{
	/* PUBLIC STRUCTURE */
	struct tfe_http_half hf_public;
	/* SESSION OF THIS REQUEST/RESPONSE */
	struct http_session_private * session;
	/* HTTP PARSER */
	struct http_parser * parse_object;
	/* HTTP PARSER SETTING */
	struct http_parser_settings * parse_settings;
	/* CURSOR RELATED TO DELAYED DATA */
	size_t parse_cursor;
	/* HTTP PARSER'S ERRNO */
	enum http_errno parse_errno;
	/* HEADER K-V */
	struct http_header_private_list header_list;

	/* UNDERLAY BUFFER */
	int method_or_status;
	short major;
	short minor;

	struct evbuffer * evbuf_uri;
	char * underlay_uri;
	char * underlay_url;

	struct evbuffer * evbuf_header_field;
	struct evbuffer * evbuf_header_value;
	struct evbuffer * evbuf_body;

	enum hf_private_status status_header;
	enum hf_private_status status_body;
	enum hf_private_status status_message;
};

static inline struct http_half_private * to_hf_request_private(struct http_session_private * hs_private)
{
	struct tfe_http_half * hf_public = hs_private->hs_public.req;
	return container_of(hf_public, struct http_half_private, hf_public);
}

static inline struct http_half_private * to_hf_response_private(struct http_session_private * hs_private)
{
	struct tfe_http_half * hf_public = hs_private->hs_public.resp;
	return container_of(hf_public, struct http_half_private, hf_public);
}

static inline struct tfe_http_half * to_hf_public(struct http_half_private * hf_private)
{
	return &hf_private->hf_public;
}

static inline struct http_half_private * to_hf_private(struct tfe_http_half * hf_public)
{
	return container_of(hf_public, struct http_half_private, hf_public);
}

static inline const struct http_half_private * to_hf_private(const struct tfe_http_half * hf_public)
{
	return container_of(hf_public, struct http_half_private, hf_public);
}