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

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

static const char* TAG = "YASPAM";

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

static TaskHandle_t dht22_handle;
static TaskHandle_t pms5003_handle;

#ifdef CONFIG_PMS5003_ENABLED
#include "pms5003.h"

void
read_from_pms5003()
{
  while (run_pms5003) {
    // TODO: actually collect some data
    ESP_LOGI(TAG, "Got PMS5003 data!");
    // TODO: Write the data out somewhere
    vTaskDelay(pdMS_TO_TICKS(CONFIG_PMS5003_PERIOD_POLL));
  }
}
#endif /* CONFIG_PMS5003_ENABLED */

#ifdef CONFIG_DHT22_ENABLED
#include "dht22.h"

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!");
    // TODO: Write the data out somewhere - into RAM maybe?
    vTaskDelay(pdMS_TO_TICKS(CONFIG_DHT22_PERIOD_POLL));
  }
}
#endif /* CONFIG DHT22_ENABLED */

void
app_main(void)
{
  esp_err_t ret = nvs_flash_init();
  if (ret == ESP_ERR_NVS_NO_FREE_PAGES ||
      ret == ESP_ERR_NVS_NEW_VERSION_FOUND) {
    ESP_ERROR_CHECK(nvs_flash_erase());
    ret = nvs_flash_init();
  }
  ESP_ERROR_CHECK(ret);

#ifdef CONFIG_DHT22_ENABLED
  xTaskCreate(read_from_dht22,
              "DHT22",
              4 * 1024, // honestly I have _no_ idea
              NULL,
              5,     // no idea either
              &dht22_handle);
  
#endif /* CONFIG_DHT22_ENABLED */

#ifdef CONFIG_PMS5003_ENABLED
  
  xTaskCreate(read_from_pms5003,
              "PMS5003",
              4 * 1024, // honestly I have _no_ idea
              NULL,
              5,     // no idea either
              &pms5003_handle);
  
#endif /* CONFIG_PMS5003_ENABLED */
}