#include <cJSON.h>
#include <macros.h>
#include <constants.h>
#include <endpoints/api_v1_schedules.h>
#include <logger.h>
#include <models/junction_tag.h>
#include <models/schedule.h>
#include <models/tag.h>

void
api_v1_schedules_POST(struct mg_connection *nc, struct http_message *hm, endpoint_args_t *args, endpoint_response_t *response)
{
    (void)args;
    (void)nc;
    cJSON *json = cJSON_ParseWithLength(hm->body.p, hm->body.len);

    if(json == NULL)
    {
        M_RESPONSE_400_NO_VALID_JSON(response);
        return;
    }

    cJSON *json_name = cJSON_GetObjectItemCaseSensitive(json, "name");
    if(!cJSON_IsString(json_name) || (json_name->valuestring == NULL))
    {
        M_RESPONSE_400_NO_NAME(response);
        return;
    }

    cJSON *json_periods = cJSON_GetObjectItemCaseSensitive(json, "periods");
    if(!cJSON_IsArray(json_periods))
    {
        cJSON_Delete(json);

        M_RESPONSE_TEXT_STATIC(LOGGER_DEBUG, response, 400, "the request does not contain periods");
        return;
    }

    cJSON *json_tag;
    cJSON *json_tags = cJSON_GetObjectItemCaseSensitive(json, "tags");
    cJSON_ArrayForEach(json_tag, json_tags)
    {
        if(!cJSON_IsString(json_tag) || (json_tag->valuestring == NULL))
        {
            cJSON_Delete(json);

            M_RESPONSE_TEXT_STATIC(LOGGER_DEBUG, response, 400, "the request contains at least one invalid tag");
            return;
        }
    }

    schedule_t *new_schedule = malloc(sizeof(schedule_t));

    new_schedule->id = 0;
    uuid_generate(new_schedule->uid);

    strncpy(new_schedule->name, json_name->valuestring, MAX_NAME_LENGTH);
    new_schedule->name[MAX_NAME_LENGTH] = '\0';

    int periods_count = cJSON_GetArraySize(json_periods);
    new_schedule->periods = malloc(sizeof(period_t) * periods_count);

    int periods_valid = 0;

    cJSON *json_period;
    cJSON_ArrayForEach(json_period, json_periods)
    {
        cJSON *json_period_start = cJSON_GetObjectItemCaseSensitive(json_period, "start");
        cJSON *json_period_end = cJSON_GetObjectItemCaseSensitive(json_period, "end");

        if(!cJSON_IsString(json_period_start) || (json_period_start->valuestring == NULL))
        {
            cJSON_Delete(json);
            schedule_free(new_schedule);

            M_RESPONSE_TEXT_STATIC(LOGGER_DEBUG, response, 400, "the request contains at least one period without a start");
            return;
        }
        if(!cJSON_IsString(json_period_end) || (json_period_end->valuestring == NULL))
        {
            cJSON_Delete(json);
            schedule_free(new_schedule);

            M_RESPONSE_TEXT_STATIC(LOGGER_DEBUG, response, 400, "the request contains at least one period without an end");
            return;
        }

        uint16_t start;
        uint16_t end;
        if(period_helper_parse_hhmm(json_period_start->valuestring, &start))
        {
            cJSON_Delete(json);
            schedule_free(new_schedule);

            M_RESPONSE_TEXT_STATIC(LOGGER_DEBUG, response, 400, "the request contains at least one period with an invalid start");
            return;
        }
        if(period_helper_parse_hhmm(json_period_end->valuestring, &end))
        {
            cJSON_Delete(json);
            schedule_free(new_schedule);

            M_RESPONSE_TEXT_STATIC(LOGGER_DEBUG, response, 400, "the request contains at least one period with an invalid end");
            return;
        }

        new_schedule->periods[periods_valid].start = start;
        new_schedule->periods[periods_valid].end = end;
        ++periods_valid;
    }

    new_schedule->periods_count = periods_valid;

    schedule_save(new_schedule);

    junction_tag_remove_for_schedule(new_schedule->id);

    json_tags = cJSON_GetObjectItemCaseSensitive(json, "tags");
    cJSON_ArrayForEach(json_tag, json_tags)
    {
        const char *tag = json_tag->valuestring;
        int tag_id = tag_get_id(tag);
        if(tag_id == 0)
        {
            tag_save(tag_id, tag);
            tag_id = tag_get_id(tag);
        }
        junction_tag_insert(tag_id, 0, new_schedule->id);
    }

    cJSON_Delete(json);
    json = schedule_to_json(new_schedule);

    endpoint_response_json(response, 201, json);
    cJSON_Delete(json);
    schedule_free(new_schedule);
}

void
api_v1_schedules_GET(struct mg_connection *nc, struct http_message *hm, endpoint_args_t *args, endpoint_response_t *response)
{
    (void)args;
    (void)hm;
    (void)nc;

    schedule_t** all_schedules = schedule_get_all();

    cJSON *json = cJSON_CreateArray();

    for(int i = 0; all_schedules[i] != NULL; ++i)
    {
        cJSON *json_schedule = schedule_to_json(all_schedules[i]);

        cJSON_AddItemToArray(json, json_schedule);
    }

    endpoint_response_json(response, 200, json);
    cJSON_Delete(json);
    schedule_free_list(all_schedules);
}