#ifndef PROTO_H
#define PROTO_H

#include "CedarType.h"

#include "Mayaqua/MayaType.h"
#include "Mayaqua/Network.h"

#define PROTO_OPTION_TOGGLE_NAME "Enabled"

// OpenVPN sends 2 bytes, thus this is the buffer size.
// If another protocol requires more bytes to be detected, the buffer size must be increased.
#define PROTO_CHECK_BUFFER_SIZE	2

#define PROTO_TCP_BUFFER_SIZE	(128 * 1024)

typedef enum PROTO_MODE
{
	PROTO_MODE_UNKNOWN,
	PROTO_MODE_TCP,
	PROTO_MODE_UDP
} PROTO_MODE;

typedef enum PROTO_OPTION_VALUE
{
	PROTO_OPTION_UNKNOWN,
	PROTO_OPTION_STRING,
	PROTO_OPTION_BOOL,
	PROTO_OPTION_UINT32
} PROTO_OPTION_VALUE;

typedef struct PROTO
{
	CEDAR *Cedar;
	LIST *Containers;
	HASH_LIST *Sessions;
	UDPLISTENER *UdpListener;
} PROTO;

struct PROTO_OPTION
{
	char *Name;
	PROTO_OPTION_VALUE Type;
	union
	{
		bool Bool;
		char *String;
		UINT UInt32;
	};
};

typedef struct PROTO_IMPL
{
	const char *(*Name)();
	const PROTO_OPTION *(*Options)();
	char *(*OptionStringValue)(const char *name);
	bool (*Init)(void **param, const LIST *options, CEDAR *cedar, INTERRUPT_MANAGER *im, SOCK_EVENT *se, const char *cipher, const char *hostname);
	void (*Free)(void *param);
	bool (*IsPacketForMe)(const PROTO_MODE mode, const void *data, const UINT size);
	bool (*ProcessData)(void *param, TCP_RAW_DATA *in, FIFO *out);
	bool (*ProcessDatagrams)(void *param, LIST *in, LIST *out);
} PROTO_IMPL;

typedef struct PROTO_CONTAINER
{
	const char *Name;
	LIST *Options;
	const PROTO_IMPL *Impl;
} PROTO_CONTAINER;

typedef struct PROTO_SESSION
{
	void *Param;
	const PROTO *Proto;
	const PROTO_IMPL *Impl;
	IP SrcIp;
	USHORT SrcPort;
	IP DstIp;
	USHORT DstPort;
	LIST *DatagramsIn;
	LIST *DatagramsOut;
	SOCK_EVENT *SockEvent;
	INTERRUPT_MANAGER *InterruptManager;
	THREAD *Thread;
	LOCK *Lock;
	volatile bool Halt;
} PROTO_SESSION;

void ProtoLog(const PROTO *proto, const PROTO_SESSION *session, const char *name, ...);

int ProtoOptionCompare(void *p1, void *p2);
int ProtoContainerCompare(void *p1, void *p2);
int ProtoSessionCompare(void *p1, void *p2);

UINT ProtoSessionHash(void *p);

bool ProtoEnabled(const PROTO *proto, const char *name);

PROTO *ProtoNew(CEDAR *cedar);
void ProtoDelete(PROTO *proto);

PROTO_CONTAINER *ProtoContainerNew(const PROTO_IMPL *impl);
void ProtoContainerDelete(PROTO_CONTAINER *container);

const PROTO_CONTAINER *ProtoDetect(const PROTO *proto, const PROTO_MODE mode, const UCHAR *data, const UINT size);

PROTO_SESSION *ProtoSessionNew(const PROTO *proto, const PROTO_CONTAINER *container, const IP *src_ip, const USHORT src_port, const IP *dst_ip, const USHORT dst_port);
void ProtoSessionDelete(PROTO_SESSION *session);

bool ProtoSetListenIP(PROTO *proto, const IP *ip);
bool ProtoSetUdpPorts(PROTO *proto, const LIST *ports);

bool ProtoHandleConnection(PROTO *proto, SOCK *sock, const char *protocol);
void ProtoHandleDatagrams(UDPLISTENER *listener, LIST *datagrams);
void ProtoSessionThread(THREAD *thread, void *param);

#endif