#include <string.h>
#include "util.h"
#include "curl.h"

const char*
get_apikey()
{
	return check_get_env("MINIFLUX_APIKEY");
}

const char *
get_url()
{
	return check_get_env("MINIFLUX_URL");
}

char *
get_endpoint(char* endpoint)
{
	char *url = calloc(sizeof(char), PATH_MAX);
	snprintf(url, PATH_MAX, "%s/v1/%s", get_url(), endpoint);
	return url;
}

bool
curl_init()
{
	curl = curl_easy_init();

	if (!curl) {
		fprintf(stderr, "Error in curl init\n");
		return false;
	}

	api_header = calloc(sizeof(char), MAX_URL);
	snprintf(api_header, sizeof(char) * MAX_URL, "X-Auth-Token: %s", get_apikey());

#ifdef DEBUG
	fprintf(stderr, "api: %s\n", api_header);
#endif

	return true;
}

size_t
parse_header_reply(
	char* ptr, size_t size, size_t nmemb, struct reply *userdata)
{
	size_t s = 0;
	if (sscanf(ptr, "Content-Length: %ld\n", &s) != 0) {
		userdata->size = s + 1;
#ifdef DEBUG
		printf("Len: %ld\n", s);
#endif
	}
	return size * nmemb;
}

size_t
parse_body_reply(
		char *ptr, size_t size, size_t nmemb, struct reply *userdata)
{
	if (userdata->size == 0) {
		return 0;
	}
	size_t realsize = size * nmemb;
	char *tmp = realloc(userdata->data, userdata->size);
	if (!tmp) {
		fprintf(stderr, "Not enough memory\n");
		return 0;
	} else {
		userdata->data = tmp;
	}
	
	strncat(userdata->data, ptr, realsize);
	return realsize;
}

struct feed *
get_remote_feeds()
{
	CURLcode res;
	struct curl_slist *header = NULL;

	char *url = get_endpoint("feeds");
	curl_easy_setopt(curl, CURLOPT_URL, url);
	free(url);
	header = curl_slist_append(header, api_header);
	curl_easy_setopt(curl, CURLOPT_HTTPHEADER, header);

	struct reply data = {0};
	data.size = 0;
	data.data = malloc(1);
	data.data[0] = '\0';
	curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, &parse_body_reply);
	curl_easy_setopt(curl, CURLOPT_WRITEDATA, &data);
	curl_easy_setopt(curl, CURLOPT_HEADERFUNCTION, &parse_header_reply);
	curl_easy_setopt(curl, CURLOPT_HEADERDATA, &data);


	res = curl_easy_perform(curl);
	if (res != CURLE_OK) {
		fprintf(stderr, "Curl failed: %s", curl_easy_strerror(res));
		return NULL;
	}

#ifdef DEBUG
	printf("%s\n", data.data);
#endif

	struct feed *feeds = calloc(sizeof(struct feed), 1);
	// TODO: populate feed;
	free(data.data);
	curl_slist_free_all(header);
	return feeds;
}

void
curl_clean()
{
	curl_easy_cleanup(curl);
	free(api_header);
}

size_t
print_reply(
		char *ptr, size_t size, size_t nmemb, void *null)
{
	printf("%s\n", ptr);
	return size * nmemb;
}

void
remote_add_feed(struct feed feed)
{
	char *json = calloc(sizeof(char), 4096);
	snprintf(json, 4096, "{ \"feed_url\": \"%s\", \"category_id\": 1 }", feed.url);
	char *url = get_endpoint("feeds");

	curl_easy_setopt(curl, CURLOPT_URL, url);
	curl_easy_setopt(curl, CURLOPT_POSTFIELDS, json);

	struct curl_slist *header = NULL;
	header = curl_slist_append(header, api_header);
	header = curl_slist_append(header, "Content-Type: application/json");
	curl_easy_setopt(curl, CURLOPT_HTTPHEADER, header);

	curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, &print_reply);
	curl_easy_setopt(curl, CURLOPT_WRITEDATA, NULL);

	curl_easy_perform(curl);
	free(url);
	free(json);
	curl_slist_free_all(header);
}

bool
create_category(char *title)
{
	char *json = calloc(sizeof(char), 4096);
	snprintf(json, 4096, "{ \"title\": \"%s\" }", title);
	char *url = get_endpoint("categories");
	curl_easy_setopt(curl, CURLOPT_URL, url);
	curl_easy_setopt(curl, CURLOPT_POSTFIELDS, json);
	struct curl_slist *header = NULL;
	header = curl_slist_append(header, api_header);
	curl_easy_setopt(curl, CURLOPT_HTTPHEADER, header);
	curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, &print_reply);
	curl_easy_setopt(curl, CURLOPT_WRITEDATA, NULL);

	curl_easy_perform(curl);
	free(url);
	free(json);
	curl_slist_free_all(header);

	return true;
}