// Copyright (c) Athena Dev Teams - Licensed under GNU GPL
// For more information, see LICENCE in the main folder

#include "../common/plugin.h"

#ifdef WIN32
	#define WIN32_LEAN_AND_MEAN
	#include <windows.h>
#else
	#include <sys/types.h>
	#include <unistd.h>
	#include <poll.h>
	#include <string.h>
#endif
#include <stdio.h> // stdin, fgets

#ifdef WIN32

#define THREAD_FUNC_START(name) DWORD WINAPI thread_ ## name(LPVOID lpParameter) { (void)lpParameter; {
#define THREAD_FUNC_END(name) } ExitThread(0); return 0; }
#define THREAD_EXECUTE(name,errvar) \
	do{ \
		int _fail_ = (CreateThread(NULL,0,thread_ ## name,NULL,0,NULL) == NULL); \
		if( errvar ) \
			*errvar = _fail_; \
	}while(0)
#define sleep Sleep

#define pipe_create(p) ( CreatePipe(&p[PIPE_READ], &p[PIPE_WRITE], NULL, 1) != 0 )
#define pipe_read(p,data,len) do{ DWORD _b_; ReadFile(p[PIPE_READ], data, len, &_b_, NULL); }while(0)
#define pipe_write(p,data,len) do{ DWORD _b_; WriteFile(p[PIPE_WRITE], data, len, &_b_, NULL); }while(0)
#define pipe_close(p,side) CloseHandle(p[side])
typedef HANDLE PIPE[2];

#else

#define THREAD_FUNC_START(name) void thread_ ## name(void) {
#define THREAD_FUNC_END(name) _exit(0); }
#define THREAD_EXECUTE(name,errvar) \
	do{ \
		int pid = fork(); \
		if( pid == 0 ){ \
			thread_ ## name(); \
		} \
		if( errvar ) \
			*errvar = (pid == -1); \
	}while(0)

#define pipe_create(p) pipe(p)
#define pipe_read(p,data,len) read(p[PIPE_READ], data, len)
#define pipe_write(p,data,len) write(p[PIPE_WRITE], data, len)
#define pipe_close(p,side) close(p[side])
typedef int PIPE[2];

#endif

#define PIPE_READ 0
#define PIPE_WRITE 1
#define INPUT_BUFSIZE 4096

////// Plugin information ////////
//
PLUGIN_INFO = {
	"Console", // Name
	PLUGIN_ALL, // Target servers
	"0.1", // Version
	"1.03", // Minimum plugin engine version to run
	"Console parser" // Short description
};

////// Plugin event list //////////
// Format: <plugin function>,<event name>
// All registered functions to a event gets executed
// (In descending order) when its called.
// Multiple functions can be called by multiple events too,
// So it's up to your creativity ^^
//
PLUGIN_EVENTS_TABLE = {
	{ "console_init",  EVENT_PLUGIN_INIT },
	{ "console_final", EVENT_PLUGIN_FINAL },
	{ "console_start", EVENT_ATHENA_INIT },
	{ "console_stop",  EVENT_ATHENA_FINAL },
	{ NULL, NULL }
};

///// Variables /////

typedef int TimerFunc(int tid, unsigned int tick, int id, int data);
int (*add_timer_func_list)(TimerFunc func, char* name);
int (*add_timer_interval)(unsigned int tick, TimerFunc* func, int id, int data, int interval);
int (*delete_timer)(int tid, TimerFunc* func);
unsigned int (*gettick)(void);
int (*parse_console)(char* buf);

int tid;
PIPE data;
PIPE next;

//////// Plugin functions //////////

static int pipe_hasdata(PIPE p)
{
#ifdef WIN32
	return ( WaitForSingleObject(p[PIPE_READ],0) == WAIT_OBJECT_0 );
#else
	struct pollfd fds;
	fds.fd = p[PIPE_READ];
	fds.events = POLLRDNORM;
	return ( poll(&fds,1,0) > 0 );
#endif
}

int console_parsebuf(int tid, unsigned int tick, int id, int data_)
{
	//printf("console_parsebuf\n");
	//delete_timer(tid, console_parsebuf);
	if( pipe_hasdata(data) ){
		char buf[INPUT_BUFSIZE];
		size_t len;
		//printf("console_parsebuf pipe_hasdata\n");
		// receive string
		pipe_read(data, &len, sizeof(size_t));
		pipe_read(data, &buf, len);
		buf[len] = '\0';
		//printf("console_parsebuf buf='%s'\n", buf);
		// parse it
		parse_console(buf);
		//printf("console_parsebuf writing next\n");
		// send next state
		buf[0] = 'R';
		pipe_write(next, &buf, 1);
		//printf("console_parsebuf done with next\n");
	}
	return 0;
}

THREAD_FUNC_START(readinput)
	char buf[INPUT_BUFSIZE];
	char state = 'R';
	size_t len;

	//printf("thread_readinput START\n");
	pipe_close(data, PIPE_READ);
	pipe_close(next, PIPE_WRITE);
	buf[sizeof(buf)-1] = '\0';
	for( ; state != 'X'; )
	{
		//printf("thread_readinput getting data\n");
		buf[0] = '\0';
		fgets(buf, sizeof(buf)-1, stdin);
		len = strlen(buf);
		//printf("thread_readinput buf='%s'\n", buf);
		// send string
		pipe_write(data, &len, sizeof(size_t));
		pipe_write(data, buf, len);
		// receive next state
		pipe_read(next, &state, sizeof(char));
	}
	pipe_close(data, PIPE_WRITE);
	pipe_close(next, PIPE_READ);
	//printf("thread_readinput STOP (%d)\n", state);
THREAD_FUNC_END(readinput)

void console_start(void)
{
	int error = 0;
	//printf("console_start\n");
	if( pipe_create(data) ){
		//printf("console_start data pipe failed\n");
		return;
	}
	if( pipe_create(next) ){
		//printf("console_start next pipe failed\n");
		pipe_close(data, PIPE_READ);
		pipe_close(data, PIPE_WRITE);
		return;
	}
	THREAD_EXECUTE(readinput, &error);
	if( error ){
		//printf("console_start thread start error\n");
		pipe_close(data, PIPE_READ);
		pipe_close(next, PIPE_WRITE);
	} else {
		//printf("console_start thread started\n");
		//parse_console("help");
		add_timer_func_list(console_parsebuf,"console_parsebuf");
		tid = add_timer_interval(gettick(),console_parsebuf,0,0,1); // run once every cycle
	}
	pipe_close(data, PIPE_WRITE);
	pipe_close(next, PIPE_READ);
}

void console_stop(void)
{
	char c = 'X';
	//printf("console_stop\n");
	if( tid != -1 ){
		delete_timer(tid, console_parsebuf);
		pipe_write(next, &c, sizeof(char));
	}
	return;
}

void console_init(void)
{
	//printf("console_init\n");
	// import symbols
	IMPORT_SYMBOL(add_timer_interval, SYMBOL_ADD_TIMER_INTERVAL);
	IMPORT_SYMBOL(add_timer_func_list, SYMBOL_ADD_TIMER_FUNC_LIST);
	IMPORT_SYMBOL(delete_timer, SYMBOL_DELETE_TIMER);
	IMPORT_SYMBOL(gettick, SYMBOL_GETTICK);
	IMPORT_SYMBOL(parse_console, SYMBOL_PARSE_CONSOLE);
	//printf("%d -> add_timer_func_list=0x%x\n", SYMBOL_ADD_TIMER_FUNC_LIST, (int)add_timer_func_list);
	//printf("%d -> add_timer_interval=0x%x\n", SYMBOL_ADD_TIMER_INTERVAL, (int)add_timer_interval);
	//printf("%d -> delete_timer=0x%x\n", SYMBOL_DELETE_TIMER, (int)delete_timer);
	//printf("%d -> gettick=0x%x\n", SYMBOL_GETTICK, (int)gettick);
	//printf("%d -> parse_console=0x%x\n", SYMBOL_PARSE_CONSOLE, (int)parse_console);

	return;
}

void console_final(void)
{
	//printf("console_final\n");
	return;
}