#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <pthread.h>

#include "codybot.h"

// Array containing time at which !time have been run
static unsigned long time_usage[10];

// Pop the first item
static void TimeDecayUsage(void) {
	int cnt;
	for (cnt = 0; cnt < 9; cnt++)
		time_usage[cnt] = time_usage[cnt+1];

	time_usage[cnt] = 0;
}

// Return true if permitted, false if quota reached
static int TimeCheckUsage(void) {
	int cnt;
	for (cnt = 0; cnt < 10; cnt++) {
		// If there's available slot
		if (time_usage[cnt] == 0) {
			time_usage[cnt] = time(NULL);
			return 1;
		}
		// If usage is complete and first item dates from over 30 minutes
		else if (cnt == 9 && time_usage[0] < (time(NULL) - (60*30))) {
			TimeDecayUsage();
			time_usage[cnt] = time(NULL);
			return 1;
		}
	}

	return 0;
}

static void *TimeFunc(void *ptr) {
	struct raw_line *rawp = RawLineDup((struct raw_line *)ptr);
	char buf[4096];
	memset(buf, 0, 4096);

	if (!TimeCheckUsage()) {
		Msg("Time quota reached, maximum 10 times every 30 minutes.");
		RawLineFree(rawp);
		return NULL;
	}

	unsigned int cnt = 0;
	char city[128], *cp = rawp->text + strlen("!time ");
	memset(city, 0, 128);
	while (1) {
		if (*cp == '\n' || *cp == '\0' || cp - rawp->text >= 128)
			break;
		else if (cnt == 0 && *cp == ' ') {
			++cp;
			continue;
		}
		else if (*cp == '"' || *cp == '$' || *cp == '/' || *cp == '\\') {
			++cp;
			continue;
		}
		
		city[cnt] = *cp;
		++cnt;
		++cp;
	}
	RawLineFree(rawp);
	
	// Give the city to the api-fetcher program
	FILE *fp = fopen("api-fetch", "w");
	if (fp == NULL) {
		sprintf(buffer, "codybot error: Cannot open api-fetch: %s",
			strerror(errno));
		Msg(buffer);
		return NULL;
	}
	char str2[256];
	sprintf(str2, "t %s", city);
	fputs(str2, fp);
	fclose(fp);
	
	// Wait until it's ready
	fp = fopen("api-fetch", "r");
	if (fp == NULL) {
		sprintf(buffer, "codybot error: Cannot open api-fetch: %s",
			strerror(errno));
		Msg(buffer);
		return NULL;
	}
	char *str = malloc(1024);
	memset(str, 0, 1024);
	fgets(str, 1023, fp);
	fclose(fp);
	
	// Read and send results
	fp = fopen("cmd.output", "r");
	if (fp == NULL) {
		sprintf(buffer, "codybot error: Cannot open cmd.output: %s",
			strerror(errno));
		Msg(buffer);
		free(str);
		return NULL;
	}
	memset(str, 0, 1024);
	fgets(str, 1023, fp);
	fclose(fp);
	Msg(str);
	free(str);
	
	return NULL;
}

void Time(struct raw_line *rawp) {
	pthread_t thr;
	pthread_attr_t attr;

	pthread_attr_init(&attr);
	pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
	pthread_create(&thr, &attr, TimeFunc, (void *)rawp);
	pthread_detach(thr);
	pthread_attr_destroy(&attr);
}