/*
 * TTS - track your time.
 * Copyright (c) 2012-2014 Felicity Tarnell.
 *
 * Permission is granted to anyone to use this software for any purpose,
 * including commercial applications, and to alter it and redistribute it
 * freely. This software is provided 'as-is', without any express or implied
 * warranty.
 */

#include	<sys/types.h>
#include	<sys/select.h>

#include	<wchar.h>
#include	<ctype.h>
#include	<wctype.h>
#include	<fcntl.h>
#include	<time.h>
#include	<signal.h>
#include	<stdlib.h>
#include	<strings.h>
#include	<string.h>
#include	<pwd.h>
#include	<limits.h>
#include	<errno.h>
#include	<unistd.h>
#include	<locale.h>
#include	<stdarg.h>
#include	<inttypes.h>
#include	<math.h>

#include	"config.h"

#ifdef	HAVE_IOREGISTERFORSYSTEMPOWER
# define USE_DARWIN_POWER

# include	<mach/mach_port.h>
# include	<mach/mach_interface.h>
# include	<mach/mach_init.h>
# include	<mach/mach_error.h>

# include	<sys/event.h>

# include	<IOKit/pwr_mgt/IOPMLib.h>
# include	<IOKit/IOMessage.h>

# include	<alloca.h>
#endif

#include	"tailq.h"
#include	"tts.h"
#include	"entry.h"
#include	"wide.h"
#include	"tts_curses.h"
#include	"ui.h"
#include	"functions.h"
#include	"commands.h"
#include	"bindings.h"
#include	"str.h"
#include	"style.h"
#include	"variable.h"

volatile sig_atomic_t doexit;

time_t laststatus;

history_t *searchhist;
history_t *prompthist;

#define STATFILE ".rttts"
#define RCFILE ".ttsrc"

int load(void);
int save(void);
static time_t lastsave;
static char statfile[PATH_MAX + 1];

static int load_file(const char *);

int pagestart;
entry_t *curent;

int showinv = 0;

static wchar_t *macro_text, *macro_pos;

time_t itime = 0;

int show_billable = 0;
int delete_advance = 1;
int mark_advance = 1;
int bill_advance = 0;
int bill_increment = 0;
wchar_t *auto_nonbillable;

variable_t variables[] = {
	{ L"delete_advance",	VTYPE_BOOL,	&delete_advance },
	{ L"mark_advance",	VTYPE_BOOL,	&mark_advance },
	{ L"billable_advance",	VTYPE_BOOL,	&bill_advance },
	{ L"show_billable",	VTYPE_BOOL,	&show_billable },
	{ L"auto_non_billable",	VTYPE_STRING,	&auto_nonbillable },
	{ L"bill_increment",	VTYPE_INT,	&bill_increment },
	{ }
};

#ifdef USE_DARWIN_POWER
static IONotificationPortRef	port_ref;
static io_object_t		notifier;
static mach_port_t		ioport;
static io_connect_t		root_port;

static void  power_setup	(struct kevent *);
static void  power_handle	(struct kevent *);
static void  power_event	(void *, io_service_t, natural_t, void *);
static void  prompt_sleep	(time_t);

static void
power_setup(ev)
	struct kevent	*ev;
{
mach_port_t	pset;
int		ret;

	if ((ret = mach_port_allocate(mach_task_self(),
				       MACH_PORT_RIGHT_PORT_SET,
				       &pset)) != KERN_SUCCESS) {
		fprintf(stderr, "mach_port_allocate: %s [%x]\n",
			mach_error_string(ret), ret);
		exit(1);
	}

/* Register a handler for sleep and wake events */
	root_port = IORegisterForSystemPower(NULL, &port_ref, power_event,
			&notifier);
	ioport = IONotificationPortGetMachPort(port_ref);
	EV_SET(ev, pset, EVFILT_MACHPORT, EV_ADD, 0, 0, 0);

	if ((ret = mach_port_insert_member(mach_task_self(), ioport,
					   pset)) != KERN_SUCCESS) {
		fprintf(stderr, "mach_port_insert_member: %s [%x]\n",
			mach_error_string(ret), ret);
		exit(1);
	}
}

static void
power_handle(ev)
	struct kevent	*ev;
{
mach_msg_return_t	 ret;
void			*msg = alloca(ev->data);

/* Receive the message */
	memset(msg, 0, ev->data);
	ret = mach_msg(msg, MACH_RCV_MSG, 0, ev->data, ioport,
		       MACH_MSG_TIMEOUT_NONE, MACH_PORT_NULL);

	if (ret != MACH_MSG_SUCCESS) {
		fprintf(stderr, "mach_msg: %s [%x]\n",
			mach_error_string(ret), ret);
		exit(1);
	}

/* Give the message to IOKit to handle */
	IODispatchCalloutFromMessage(NULL, msg, port_ref);
}

static void
power_event(ref, service, msgtype, arg)
	void		*ref, *arg;
	io_service_t	 service;
	natural_t	 msgtype;
{
static time_t	sleep_started;

	switch (msgtype) {
	case kIOMessageSystemWillSleep:
		/* System is about to sleep; save the current time */
		time(&sleep_started);
		IOAllowPowerChange(root_port, (long) arg);
		break;

	case kIOMessageSystemHasPoweredOn:
		/* System has finished wake-up; calculate the sleep time and
		 * prompt the user.
		 */
		prompt_sleep(time(NULL) - sleep_started);
		break;
	}
}
#endif

static void
sigexit(sig)
{
	doexit = 1;
}

int
main(argc, argv)
	char	**argv;
{
struct passwd	*pw;
char		 rcfile[PATH_MAX + 1];
#ifdef	USE_DARWIN_POWER
int		 kq;
struct kevent	 evs[2], rev;
# define	STDIN_EV	0
# define	IOKIT_EV	1
#endif

	setlocale(LC_ALL, "");

#ifdef USE_DARWIN_POWER
	if ((kq = kqueue()) == -1) {
		perror("kqueue");
		return 1;
	}

	memset(evs, 0, sizeof(evs));

	EV_SET(&evs[STDIN_EV], STDIN_FILENO, EVFILT_READ, EV_ADD, 0, 0, 0);
	power_setup(&evs[IOKIT_EV]);

	if (kevent(kq, evs, 2, NULL, 0, NULL) == -1) {
		perror("kevent");
		return 1;
	}
#endif

	signal(SIGTERM, sigexit);
	signal(SIGINT, sigexit);

	searchhist = hist_new();
	prompthist = hist_new();

	if ((pw = getpwuid(getuid())) == NULL || !pw->pw_dir || !*pw->pw_dir) {
		fprintf(stderr, "Sorry, I can't find your home directory.");
		return 1;
	}

	snprintf(statfile, sizeof(statfile), "%s/%s", pw->pw_dir, STATFILE);
	snprintf(rcfile, sizeof(rcfile), "%s/%s", pw->pw_dir, RCFILE);

	ui_init();
	style_defaults();

	if (load_file(rcfile) == -1) {
		endwin();
		return 1;
	}

	bind_defaults();

	/*
	 * Make sure we can save (even if it's an empty file or nothing has
	 * changed) before the user starts entering entries.
	 */
	load();
	save();

	drawheader();
	drawstatus(L"");

	if (!TTS_TAILQ_EMPTY(&entries)) {
		curent = TTS_TAILQ_FIRST(&entries);
		while (!showinv && curent->en_flags.efl_invoiced)
			if ((curent = TTS_TAILQ_NEXT(curent, en_entries)) == NULL)
				break;
	}

	for (;;) {
	wint_t		 c;
	binding_t	*bi;
#ifdef	USE_DARWIN_POWER
	struct timespec	 timeout;
	int		 nev;
#else
	fd_set		 in_set;
	struct timeval	 timeout;
#endif

		if (doexit)
			break;

		drawheader();
		drawentries();
		wrefresh(listwin);

#ifdef	USE_DARWIN_POWER
		timeout.tv_sec = 0;
		timeout.tv_nsec = 500000000;

		if ((nev = kevent(kq, NULL, 0, &rev, 1, &timeout)) == -1) {
			if (doexit)
				break;
			if (errno == EINTR)
				continue;
			perror("kevent");
			return 1;
		}

		if (nev == 1 && (rev.filter == EVFILT_MACHPORT)) {
			power_handle(&rev);
			continue;
		}
#else
	/* Wait for input to be ready. */
		FD_ZERO(&in_set);
		FD_SET(STDIN_FILENO, &in_set);

		timeout.tv_sec = 0;
		timeout.tv_usec = 500000;

		if (select(STDIN_FILENO + 1, &in_set, NULL, NULL, &timeout) == -1) {
			if (doexit)
				break;
			if (errno == EINTR)
				continue;
		}
#endif

		while (input_char(stdscr, &c) != ERR) {
#ifdef KEY_RESIZE
			if (c == KEY_RESIZE)
				continue;
#endif

			drawstatus(L"");

			TTS_TAILQ_FOREACH(bi, &bindings, bi_entries) {
				if (bi->bi_code != c)
					continue;

				if (!macro_text && bi->bi_macro)
					input_macro(bi->bi_macro);
				else if (bi->bi_func)
					bi->bi_func->fn_hdl();

				goto next;
			}

			drawstatus(L"Unknown command.");
		next:	;
		}

		if (doexit)
			break;

		if (time(NULL) - laststatus >= 2)
			drawstatus(L"");

		if (time(NULL) - lastsave > 60)
			save();
	}

	save();
	endwin();
	return 0;
}

int
load()
{
FILE	*f;
char	 input[4096];
wchar_t	 line[4096];
entry_t	*en;

	TTS_TAILQ_FOREACH(en, &entries, en_entries)
		entry_free(en);

	if ((f = fopen(statfile, "r")) == NULL) {
		if (errno == ENOENT)
			return 0;

		errbox(L"Can't read %s: %s", statfile, strerror(errno));
		exit(1);
	}

	if (fgets(input, sizeof(input), f) == NULL) {
		errbox(L"Can't read %s: %s", statfile, strerror(errno));
		fclose(f);
		exit(1);
	}

	mbstowcs(line, input, wsizeof(line));

	if (wcscmp(line, L"#%RT/TTS V1\n")) {
		errbox(L"Can't read %s: invalid magic signature", statfile);
		fclose(f);
		exit(1);
	}

	while (fgets(input, sizeof(input), f)) {
	unsigned long	 cre, secs;
	wchar_t	 	 flags[10], desc[4096], *p;
	entry_t		*en;
	int		 i;

		mbstowcs(line, input, wsizeof(line));

		if (swscanf(line, L"#%%showinv %d\n", &i) == 1) {
			showinv = i ? 1 : 0;
			continue;
		}

		if (swscanf(line, L"%lu %lu %9l[in-] %4095l[^\n]\n",
				&cre, &secs, flags, desc) != 4) {
			errbox(L"Can't read %s: invalid entry format", statfile);
			fclose(f);
			exit(1);
		}

		en = entry_new(desc);
		en->en_created = cre;
		en->en_secs = secs;
		for (p = flags; *p; p++) {
			switch (*p) {
			case '-':
				break;

			case 'i':
				en->en_flags.efl_invoiced = 1;
				break;

			case 'n':
				en->en_flags.efl_nonbillable = 1;
				break;

			default:
				errbox(L"Can't read %s: invalid flag", statfile);
				fclose(f);
				exit(1);
			}
		}
	}

	if (ferror(f)) {
		errbox(L"Can't read %s: %s", statfile, strerror(errno));
		fclose(f);
		exit(1);
	}

	fclose(f);
	return 0;
}

int
save()
{
FILE	*f;
int	 fd;
char	 p[PATH_MAX + 1];
entry_t	*en;

	snprintf(p, sizeof(p), "%s_", statfile);

	if ((fd = open(p, O_WRONLY | O_CREAT, 0600)) == -1) {
		errbox(L"%s_: %s", statfile, strerror(errno));
		endwin();
		exit(1);
	}

	if ((f = fdopen(fd, "w")) == NULL) {
		errbox(L"%s: %s", p, strerror(errno));
		endwin();
		exit(1);
	}

	if (fwprintf(f, L"#%%RT/TTS V1\n") == -1) {
		fclose(f);
		unlink(p);

		errbox(L"%s: write error (header): %s", p, strerror(errno));
		endwin();
		exit(1);
	}

	if (fwprintf(f, L"#%%showinv %d\n", showinv) == -1) {
		fclose(f);
		unlink(p);

		errbox(L"%s: write error (showinv): %s", p, strerror(errno));
		endwin();
		exit(1);
	}

	TTS_TAILQ_FOREACH_REVERSE(en, &entries, entrylist, en_entries) {
	char	 flags[10], *fp = flags, wdesc[4096] = {};
	time_t	 n;

		wcstombs(wdesc, en->en_desc, sizeof(wdesc));

		memset(flags, 0, sizeof(flags));
		if (en->en_flags.efl_invoiced)
			*fp++ = 'i';
		if (en->en_flags.efl_nonbillable)
			*fp++ = 'n';

		n = en->en_secs;
		if (en->en_started)
			n += time(NULL) - en->en_started;

		if (fwprintf(f, L"%lu %lu %s %s\n",
				(unsigned long) en->en_created,
				(unsigned long) n,
				*flags ? flags : "-", wdesc) == -1) {
			errbox(L"%s: write error (entry): %s", p, strerror(errno));
			fclose(f);
			unlink(p);
			endwin();
			exit(1);
		}
	}

	if (fclose(f) == EOF) {
		unlink(p);
		errbox(L"%s: write error (closing): %s", p, strerror(errno));
		endwin();
		exit(1);
	}

	if (rename(p, statfile) == -1) {
		unlink(p);
		errbox(L"%s: rename: %s", statfile, strerror(errno));
		endwin();
		exit(1);
	}

	time(&lastsave);
	return 0;
}

history_t *
hist_new()
{
history_t	*hi;
	if ((hi = calloc(1, sizeof(*hi))) == NULL)
		return NULL;
	TTS_TAILQ_INIT(&hi->hi_ents);
	return hi;
}

void
hist_add(hi, text)
	history_t	*hi;
	const wchar_t	*text;
{
histent_t	*hent;

	if (!*text)
		return;

	if ((hent = calloc(1, sizeof(*hent))) == NULL)
		return;

	if ((hent->he_text = wcsdup(text)) == NULL) {
		free(hent);
		return;
	}

	TTS_TAILQ_INSERT_TAIL(&hi->hi_ents, hent, he_entries);

	if (hi->hi_nents == 50)
		TTS_TAILQ_REMOVE(&hi->hi_ents, TTS_TAILQ_FIRST(&hi->hi_ents), he_entries);
	else
		++hi->hi_nents;
}

variable_t *
find_variable(name)
	wchar_t const	*name;
{
variable_t	*v;
	for (v = variables; v->va_name; v++)
		if (wcscmp(name, v->va_name) == 0)
			return v;
	return NULL;
}

static char *curfile;
static int lineno, nerr;

void
cmderr(const wchar_t *msg, ...)
{
va_list	ap;

	va_start(ap, msg);
	vcmderr(msg, ap);
	va_end(ap);
}

void
vcmderr(msg, ap)
	const wchar_t	*msg;
	va_list		 ap;
{
	nerr++;

	if (curfile) {
	wchar_t	s[1024];
	char	t[1024];
		vswprintf(s, wsizeof(t), msg, ap);
		wcstombs(t, s, sizeof(t));

		if (in_curses) {
			endwin();
			in_curses = 0;
		}

		fprintf(stderr, "\"%s\", line %d: %s\n",
			curfile, lineno, t);
	} else {
		input_macro(NULL);
		vdrawstatus(msg, ap);
	}
}

/*
 * Load configuration commands from the file .name.  Expects to be called
 * inside curses mode; it will endwin() if an error occurs.
 *
 * Returns 0 on success, or -1 if any errors occur.
 */
int
load_file(name)
	const char	*name;
{
FILE	*s;
char	 input[1024];

	nerr = 0;

	if ((s = fopen(name, "r")) == NULL) {
		if (errno == ENOENT)
			return 0;

		fprintf(stderr, "%s: %s", name, strerror(errno));
		return -1;
	}

	curfile = strdup(name);

	while (fgets(input, sizeof(input), s)) {
	size_t		nargs;
	wchar_t		**args;
	command_t	*cmds;
	wchar_t		 line[1024];

		++lineno;

		mbstowcs(line, input, wsizeof(line));

		if (line[0] == '#')
			continue;

		nargs = tokenise(line, &args);
		if (nargs == 0) {
			tokfree(&args);
			continue;
		}

		if ((cmds = find_command(args[0])) == NULL) {
			cmderr(L"Unknown command \"%ls\".", args[0]);
			nerr++;
			tokfree(&args);
			continue;
		}

		cmds->cm_hdl(nargs, args);
		tokfree(&args);
	}

	fclose(s);
	free(curfile);
	curfile = NULL;

	if (nerr)
		return -1;

	return 0;
}

#ifdef	USE_DARWIN_POWER
static void
prompt_sleep(sleeptime)
	time_t	sleeptime;
{
/*
 * We woke from sleep.  If there's a running entry, prompt the user to
 * subtract the time spent sleeping, in case they forgot to turn off
 * the timer.
 */
wchar_t	 pr[128];
int	 h, m, s = 0;

/* Only prompt if an entry is running */
	if (!running)
		return;

/* Draw the prompt */
	s = sleeptime;

	h = s / (60 * 60);
	s %= (60 * 60);
	m = s / 60;
	s %= 60;

	swprintf(pr, wsizeof(pr),
		 L"Remove %02d:%02d:%02d time asleep from running entry?",
		 h, m, s);

	if (!yesno(pr))
		return;

/* 
 * This is a bit of a fudge, but it has the desired effect.  Alternatively
 * we could merge en_started into en_secs, then subtract that.
 */
	running->en_started += sleeptime;
}
#endif	/* USE_DARWIN_POWER */

void
input_macro(s)
	wchar_t	*s;
{
	free(macro_text);
	macro_text = macro_pos = NULL;

	if (!s)
		return;

	macro_text = macro_pos = wcsdup(s);
}

int
input_char(win, c)
	WINDOW	*win;
	wint_t	*c;
{
wchar_t	*pr, *s, *r;
	if (!macro_pos)
		return wget_wch(win, c);

	if (!*macro_pos) {
		input_macro(NULL);
		return wget_wch(win, c);
	}

	if (macro_pos[0] != '$' || macro_pos[1] != '[') {
		*c = *macro_pos++;
		return 0;
	}

/* Handle $[prompt string] escapes */
	pr = calloc(sizeof(wchar_t), wcslen(macro_pos) - 1);
	for (r = pr, s = macro_pos + 2; ; s++) {
		if (*s == '\0') {
			cmderr(L"Unterminated $[ prompt in macro");
			input_macro(NULL);
			return wget_wch(win, c);
		}

		if (*s == ']')
			break;

		*r++ = *s;
	}

	s++;

	macro_pos = NULL;
	r = prompt(pr, NULL, NULL);
	free(pr);

	pr = calloc(sizeof(wchar_t), wcslen(r) + wcslen(s) + 1);
	wcscpy(pr, r);
	wcscat(pr, s);
	free(macro_text);
	macro_text = macro_pos = pr;
	*c = *macro_pos++;
	return 0;
}