// SPDX-License-Identifier: MIT

#include <OpenTransport.h>
#include <OpenTptInternet.h>
#include <stdio.h>
#include <string.h>
#include "net.h"
#include "util.h"
#include "dbuf.h"
#include "cJSON.h"
#include "ha.h"
#include "preferences.h"

#define FAIL_TO(label) { ret = -1; goto label; }

extern PrefHandle gPreferences;

short ha_get_entity_state(const char* id, struct entity_state* out)
{
	EndpointRef ep;
	struct dbuf respBuf;
	char* json_str;
	cJSON *json, *attrs, *brightness, *name;
	char tmpBuf[128];
	short ret = 0;
	
	snprintf(tmpBuf, sizeof(tmpBuf), "/api/states/%s", id);
	
	HLock((Handle)gPreferences);
	ep = net_connect((**gPreferences).server_name, (**gPreferences).port);
	
	if (!ep) FAIL_TO(noresp)
	
	respBuf = net_get(ep, tmpBuf, (**gPreferences).token);
	
	json_str = net_http_response_content((const char*)respBuf.buf);
	if (!json_str) FAIL_TO(nojson)
	
	json = cJSON_Parse(json_str);
	if (!json) FAIL_TO(nojson)
	
	attrs = cJSON_GetObjectItemCaseSensitive(json, "attributes");
	brightness = cJSON_GetObjectItemCaseSensitive(attrs, "brightness");
	name = cJSON_GetObjectItemCaseSensitive(attrs, "friendly_name");
	
	if (!cJSON_IsNull(name))
	{
		snprintf(out->name, 128, "%s", name->valuestring);
	}
	
	if (brightness && !cJSON_IsNull(brightness))
	{
		out->brightness = brightness->valueint;
		
		// Zigbee brightness range is 0x01-0xfe.
		// Just map 0xfe to 0xff, so at least the slider
		// looks full at 100%.
		if (out->brightness == 254)
			out->brightness = 255;
	} else {
		out->brightness = 0;
	}

	cJSON_Delete(json);
nojson:	
	db_destroy(&respBuf);
	OTCloseProvider(ep);
noresp:
	HUnlock((Handle)gPreferences);
	return ret;
}

short ha_set_entity_state(const char* id, struct entity_state *st)
{
	EndpointRef ep;
	struct dbuf respBuf;
	char tmpBuf[512];
	short ret = 0;
	
	snprintf(tmpBuf, sizeof(tmpBuf),
	  "{\"entity_id\": \"%s\", \"brightness\": %d}", id, st->brightness);
	
	HLock((Handle)gPreferences);
	ep = net_connect((**gPreferences).server_name, (**gPreferences).port);
	if (!ep) FAIL_TO(noresp)
	
	respBuf = net_post(ep, "/api/services/light/turn_on", (**gPreferences).token, tmpBuf);
	
	OTCloseProvider(ep);
	db_destroy(&respBuf);
noresp:
	HUnlock((Handle)gPreferences);
	return ret;
}

short ha_get_entities(list_t *ents)
{
	EndpointRef ep;
	struct dbuf respBuf;
	const char* json_str;
	cJSON *json, *entity;
	short ret = 0;
	
	list_init(ents);
	
	HLock((Handle)gPreferences);
	
	ep = net_connect((**gPreferences).server_name, (**gPreferences).port);
	if (!ep) FAIL_TO(noresp)
	
	respBuf = net_get(ep, "/api/states", (**gPreferences).token);
	
	json_str = net_http_response_content((const char*)respBuf.buf);
	if (!json_str) FAIL_TO(nojson)
	
	json = cJSON_Parse(json_str);
	
	if (!json) FAIL_TO(nojson)
	
	cJSON_ArrayForEach(entity, json)
	{
		cJSON* id = cJSON_GetObjectItem(entity, "entity_id");
		cJSON* attrs = cJSON_GetObjectItem(entity, "attributes");
		cJSON* name = cJSON_GetObjectItem(attrs, "friendly_name");
		
		if (!cJSON_IsString(id))
		{
			die("No entity id?");
		}
		if (strncmp(id->valuestring, "light.", 6) == 0)
		{
			struct entity* ent = xmalloc(sizeof(struct entity));
			strlcpy(ent->id, id->valuestring, 128);
			strlcpy(ent->state.name, name->valuestring, 128);
			list_add(ents, &ent->node);
			ret++;
		}
	}
	
	cJSON_Delete(json);
nojson:
	OTCloseProvider(ep);
	db_destroy(&respBuf);
noresp:
	HUnlock((Handle)gPreferences);
	return ret;
}

short ha_test_prefs()
{
	EndpointRef ep;
	struct dbuf respBuf;
	short ret = 0;
	const char* json_str;
	cJSON *json, *msg;
	
	HLock((Handle)gPreferences);
	
	ep = net_connect((**gPreferences).server_name, (**gPreferences).port);

	if (!ep) FAIL_TO(noresp)
	
	respBuf = net_get(ep, "/api/", (**gPreferences).token);
	json_str = net_http_response_content((const char*)respBuf.buf);
	if (!json_str) FAIL_TO(nojson)
	json = cJSON_Parse(json_str);
	if (!json) FAIL_TO(nojson);
	
	msg = cJSON_GetObjectItem(json, "message");
	if (strncmp(msg->valuestring, "API running.", 12) != 0)
		FAIL_TO(fail);
		
fail:
	cJSON_Delete(json);
nojson:
	OTCloseProvider(ep);
	db_destroy(&respBuf);
noresp:
	HUnlock((Handle)gPreferences);
	return ret;
}