/*
	Copyright (C) 2006 by Jonas Kramer
	Published under the terms of the GNU General Public License (GPL).
*/

#define _GNU_SOURCE

#include <stdio.h>
#include <termios.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <stdlib.h>
#include <fcntl.h>
#include <sys/time.h>
#include <signal.h>
#include <stdarg.h>
#include <ctype.h>
#include <time.h>
#include <assert.h>

#include "service.h"
#include "hash.h"
#include "interface.h"
#include "autoban.h"
#include "settings.h"
#include "http.h"
#include "split.h"
#include "bookmark.h"
#include "radio.h"
#include "md5.h"
#include "submit.h"
#include "readline.h"
#include "xmlrpc.h"
#include "recommend.h"
#include "util.h"
#include "tag.h"

#include "globals.h"

extern time_t pausetime;

void unlinknp(void);

struct hash track;

char * shellescape(const char *);

void interface(int interactive) {
	if(interactive) {
		int key, result;
		char customkey[8] = { 0 }, * marked = NULL;
		
		canon(0);
		fflush(stderr);
		if((key = fetchkey(1000000)) == -1)
			return;

		if(key == 27) {
			int ch;
			while((ch = fetchkey(100000)) != -1 && !strchr("ABCDEFGHMPQRSZojmk~", ch));
			return;
		}

		switch(key) {
			case 'l':
				puts(rate("L") ? "Loved." : "Sorry, failed.");
				break;

			case 'U':
				puts(rate("U") ? "Unloved." : "Sorry, failed.");
				break;

			case 'B':
				puts(rate("B") ? "Banned." : "Sorry, failed.");
				fflush(stdout);
				enable(INTERRUPTED);
				kill(playfork, SIGUSR1);
				break;

			case 'n':
				rate("S");
				break;

			case 'q':
				if(haskey(& rc, "delay-change")) {
					delayquit = !delayquit;
					if(delayquit)
						fputs("Going to quit soon.\n", stderr);
					else
						fputs("Delayed quit cancelled.\n", stderr);
				}
				break;

			case 'Q':
				quit();

			case 'i':
				if(playfork) {
					const char * path = rcpath("i-template");
					if(path && !access(path, R_OK)) {
						char ** template = slurp(path);
						if(template != NULL) {
							unsigned n = 0;
							while(template[n]) {
								puts(meta(template[n], M_COLORED, & track));
								free(template[n++]);
							}
							free(template);
						}
					}
					else {
						puts(meta("Track:    \"%t\" (%T)", M_COLORED, & track));
						puts(meta("Artist:   \"%a\" (%A)", M_COLORED, & track));
						puts(meta("Album:    \"%l\" (%L)", M_COLORED, & track));
						puts(meta("Station:  %s", M_COLORED, & track));
					}
				}
				break;

			case 'r':
				radioprompt("radio url> ");
				break;

			case 'd':
				toggle(DISCOVERY);
				printf("Discovery mode %s.\n", enabled(DISCOVERY) ? "enabled" : "disabled");
				if(playfork) {
					printf(
						"%u track(s) left to play/skip until change comes into affect.\n",
						playlist.left
					);
				}
				break;

			case 'A':
				printf(meta("Really ban all tracks by artist %a? [yN]", M_COLORED, & track));
				fflush(stdout);
				if(fetchkey(5000000) != 'y')
					puts("\nAbort.");
				else if(autoban(value(& track, "creator"))) {
					printf("\n%s banned.\n", meta("%a", M_COLORED, & track));
					rate("B");
				}
				fflush(stdout);
				break;

			case 'a':
				result = xmlrpc(
					"addTrackToUserPlaylist", "ss",
					value(& track, "creator"),
					value(& track, "title")
				);
				
				puts(result ? "Added to playlist." : "Sorry, failed.");
				break;

			case 'P':
				toggle(RTP);
				printf("%s RTP.\n", enabled(RTP) ? "Enabled" : "Disabled");
				break;

			case 'f':
				if(playfork) {
					station(meta("lastfm://artist/%a/fans", 0, & track));
				}
				break;
				
			case 's':
				if(playfork) {
					station(meta("lastfm://artist/%a/similarartists", 0, & track));
				}
				break;

			case 'h':
				printmarks();
				break;

			case 'H':
				if(playfork && currentStation) {
					puts("What number do you want to bookmark this stream as? [0-9]");
					fflush(stdout);
					key = fetchkey(5000000);
					setmark(currentStation, key - 0x30);
				}
				break;

			case 'S':
				if(playfork) {
					enable(STOPPED);
					kill(playfork, SIGUSR1);
				}
				break;

			case 'T':
				if(playfork)
					tag(track);
				break;

			case 'p':
				if(playfork) {
					if(pausetime) {
						kill(playfork, SIGCONT);
					}
					else {
						time(& pausetime);
						kill(playfork, SIGSTOP);
					}
				}
				break;

			case 'R':
				if(playfork) {
					recommend(track);
				}
				break;

			case '+':
				if(volume < MAX_VOLUME)
					volume += 1;
				if(playpipe != 0)
					write(playpipe, &key, 1);
				break;

			case '-':
				if(volume > 0)
					volume -= 1;
				if(playpipe != 0)
					write(playpipe, &key, 1);
				break;

			case 'u':
				preview(playlist);
				break;

			case 'E':
				expand(& playlist);
				break;

			case '?':
				fputs(
					"a = add the track to the playlist | A = autoban artist\n"
					"B = ban Track                     | d = discovery mode\n"
					"E = manually expand playlist      | f = fan Station\n"
					"h = list bookmarks                | H = bookmark current radio\n"
					"i = current track information     | l = love track\n"
					"n = skip track                    | p = pause\n"
					"P = enable/disable RTP            | Q = quit\n"
					"r = change radio station          | R = recommend track/artist/album\n"
					"S = stop                          | s = similiar artist\n"
					"T = tag track/artist/album        | u = show upcoming tracks in playlist\n"
					"U = unlove track                  | + = increase volume\n"
					"- = decrease volume               | C = reload configuration\n",
					stderr
				);
				break;

			case '0':
			case '1':
			case '2':
			case '3':
			case '4':
			case '5':
			case '6':
			case '7':
			case '8':
			case '9':
				if((marked = getmark(key - 0x30))) {
					station(marked);
					free(marked);
				} else {
					puts("Bookmark not defined.");
				}
				break;

			case 'C': /* Reload configuration. */
				settings(rcpath("shell-fm.rc"), 0);
				break;

			default:
				snprintf(customkey, sizeof(customkey), "key0x%02X", key & 0xFF);
				if(haskey(& rc, customkey))
					run(meta(value(& rc, customkey), M_SHELLESC, & track));
		}
	}
}

int fetchkey(unsigned nsec) {
	fd_set fdset;
	struct timeval tv;

	FD_ZERO(& fdset);
	FD_SET(fileno(stdin), & fdset);

	tv.tv_usec = nsec % 1000000;
	tv.tv_sec = nsec / 1000000;

	if(select(fileno(stdin) + 1, & fdset, NULL, NULL, & tv) > 0) {
		char ch = -1;
		if(read(fileno(stdin), & ch, sizeof(char)) == sizeof(char))
			return ch;
	}

	return -1;
}


#define remn (sizeof(string) - length - 1)
const char * meta(const char * fmt, int flags, struct hash * track) {
	static char string[4096];
	unsigned length = 0, x = 0;

	/* Switch off coloring when in batch mode */
	if(batch)
		flags &= ~M_COLORED;

	if(!fmt)
		return NULL;

	memset(string, 0, sizeof(string));

	while(fmt[x] && remn > 0) {
		if(fmt[x] != '%')
			string[length++] = fmt[x++];
		else if(fmt[++x]) {
			if(fmt[x] == '%') {
				string[length++] = fmt[x++];
			}
			else {
				char * val = NULL;
				const char * trackKey = NULL;
				char taggingItem = 0;
				const char * color = NULL;

				switch(fmt[x]) {
					case 'a':
						trackKey = "creator";
						break;
					case 't':
						trackKey = "title";
						break;
					case 'l':
						trackKey = "album";
						break;
					case 'A':
						trackKey = "artistpage";
						break;
					case 'T':
						trackKey = "trackpage";
						break;
					case 'L':
						trackKey = "albumpage";
						break;
					case 'd':
						trackKey = "duration";
						break;
					case 's':
						trackKey = "station";
						break;
					case 'S':
						trackKey = "stationURL";
						break;
					case 'R':
						trackKey = "remain";
						break;
					case 'I':
						trackKey = "image";
						break;
					case 'Z':
						// artist tags
						taggingItem = 'a';
						break;
					case 'D':
						// album tags
						taggingItem = 'l';
						break;
					case 'z':
						// track tags
						taggingItem = 't';
						break;
				}
				if(trackKey) {
					val = strdup(value(track, trackKey));
				} else if(taggingItem) {
					val = oldtags(taggingItem, * track);
					if(!val) {
						val = strdup("");
					}
				}

				if(flags & M_COLORED) {
					char colorkey[64] = { 0 };
					snprintf(colorkey, sizeof(colorkey), "%c-color", fmt[x]);
					color = value(& rc, colorkey);

					if(color) {
						/* Strip leading spaces from end of color (Author: Ondrej Novy) */
						char * color_st = strdup(color);
						size_t len = strlen(color_st) - 1;

						assert(color_st != NULL);

						while(isspace(color_st[len]) && len > 0) {
							color_st[len] = 0;
							len--;
						}
						length += snprintf(string + length, remn, "\x1B[%sm", color_st);
						free(color_st);
					}
				}

				if((flags & M_RELAXPATH) && val) {
					unsigned n;
					size_t l = strlen(val);

					for(n = 0; n < l; ++n) {
						if(val[n] == '/')
							val[n] = '|';
					}
				}

				if(flags & M_SHELLESC) {
					char * escaped = shellescape(val);
					free(val);
					val = escaped;
				}

				length = strlen(strncat(string, val ? val : "(unknown)", remn));

				free(val);

				if(color)
					length = strlen(strncat(string, "\x1B[0m", remn));

				++x;
			}
		}
	}

	return string;
}
#undef remn


void run(const char * cmd) {
	if(!fork()) {
        _exit(system(cmd));
	}
}


int rate(const char * rating) {
	if(playfork && rating != NULL) {

		if(rating[0] != 'U')
			set(& track, "rating", rating);

		switch(rating[0]) {
			case 'B':
				kill(playfork, SIGUSR1);
				enable(INTERRUPTED);
				return xmlrpc(
					"banTrack",
					"ss",
					value(& track, "creator"),
					value(& track, "title")
				);

			case 'L':
				return xmlrpc(
					"loveTrack",
					"ss",
					value(& track, "creator"),
					value(& track, "title")
				);

			case 'U':
				return xmlrpc(
					"unLoveTrack",
					"ss",
					value(& track, "creator"),
					value(& track, "title")
				);

			case 'S':
				enable(INTERRUPTED);
				kill(playfork, SIGUSR1);
				return !0;
		}
	}

	return 0;
}


char * shellescape(const char * string) {
	char * escaped;
	unsigned length = 0, n, size;

	assert(string != NULL);

	size = strlen(string) * 2 + 1;
	escaped = malloc(size);
	memset(escaped, 0, size);

	assert(string != NULL);

	for(n = 0; n < strlen(string); ++n) {
		if(!isalnum(string[n]))
			escaped[length++] = '\\';

		escaped[length++] = string[n];
		escaped[length] = 0;
	}

	return escaped;
}


void quit() {
	unlink(rcpath("session"));
	unlinknp();
	exit(EXIT_SUCCESS);
}

void unlinknp(void) {
	/* Remove now-playing file. */
	if(haskey(& rc, "np-file")) {
		const char * np = value(& rc, "np-file");
		if(np != NULL)
			unlink(np);
	}
}