/**
 * Author: Arthur Roberts (c) 2023
 *
 * License: GPLv3+
 */

#include <stdbool.h>
#include <stdio.h>
#include "freertos/FreeRTOS.h"
//#include "freertos/projdefs.h"
#include "freertos/task.h"
#include "dht22.h"
#include "esp_log.h"
#include "esp_wifi.h"
#include "portmacro.h"

static const char *TAG = "YASPAM";

static EventGroupHandle_t s_monitor_event_group;

static volatile bool run_dht = true;
static volatile bool run_pms5003 = true;
static volatile bool run_data_collection = true;

#ifdef CONFIG_DHT22_DATA_GPIO
  #define SENSOR_DHT22_BIT (1 << 0)
#else
  #define SENSOR_DHT22_BIT 0
#endif /* CONFIG_DHT22_DATA_GPIO */

#ifdef CONFIG_PMS5003_ENABLED
  #define SENSOR_PMS5003_BIT (1 << 1)
#else
  #define SENSOR_PMS5003_BIT 0
#endif /* CONFIG_PMS5003_ENABLED */

#define SENSOR_PMS5003_BIT (1 << 1)

#define SENSOR_ALL SENSOR_DHT22_BIT | SENSOR_PMS5003_BIT


// TODO - figure out how to continually call this, maybe make a task for it?
void save_measurements() {
  while (run_data_collection) {
    EventBits_t bits = xEventGroupWaitBits(
        s_monitor_event_group,
        SENSOR_ALL,
        pdFALSE,
        pdFALSE,
        portMAX_DELAY);
    if (bits & SENSOR_DHT22_BIT) {
      deci_percent rh = dht22_relative_humidity();
      deci_degrees_c temp = dht22_temperature();
      // TODO - think about how to actually store this somewhere (for pushing and/or pulling)
      //  and what sort of structures I could use
      ESP_LOGI(TAG, "Saved DHT data");
      xEventGroupClearBits(s_monitor_event_group, SENSOR_DHT22_BIT);
    }
    if (bits & SENSOR_PMS5003_BIT) {
      ESP_LOGI(TAG, "Saved PMS data");
      // TODO
      xEventGroupClearBits(s_monitor_event_group, SENSOR_PMS5003_BIT);
    }
  }
}

void read_from_pms5003() {
  while (run_pms5003) {
      // TODO - actually collect some data
      ESP_LOGI(TAG, "Got PMS5003 data! Setting PMS bit now!");
      xEventGroupSetBitsFromISR(s_monitor_event_group, SENSOR_PMS5003_BIT);
      vTaskDelay(pdMS_TO_TICKS(100)); // TODO: make this a config check
  }
}

void read_from_dht22() {
  while (run_dht) {
      // Data reading is based on time, so need to block interrups etc
      portDISABLE_INTERRUPTS();
      int ret = dht22_read();
      portENABLE_INTERRUPTS();
      ESP_LOGI(TAG, "Got DHT22 data! Setting DHT bit now!");
      xEventGroupSetBitsFromISR(s_monitor_event_group, SENSOR_DHT22_BIT);
      vTaskDelay(pdMS_TO_TICKS(3000)); // TODO: make this a config check
  }
}


void app_main(void) {
  s_monitor_event_group = xEventGroupCreate();

  xTaskCreate(read_from_dht22,
	      "DHT22",
	      1024, // honestly I have _no_ idea
	      NULL,
	      5, // no idea either
	      NULL); // will probably change this so that I can cancel the delay

  xTaskCreate(read_from_pms5003,
     "PMS5003",
     1024, // honestly I have _no_ idea
     NULL,
     5, // no idea either
     NULL); // will probably change this so that I can cancel the delay

  xTaskCreate(save_measurements,
     "save_measurements",
     4*1024, // honestly I have _no_ idea
     NULL,
     5, // no idea either
     NULL); // will probably change this so that I can cancel the delay
}