esp8266-meteo/main/meteo_task.c

/**
 * TODO file description
 */

#include <stdio.h>
#include <FreeRTOS.h>
#include <task.h>
#include <math.h>
#include <driver/hw_timer.h>
#include "meteo_task.h"
#include "ds18b20.h"
#include "dht.h"
#include "driver/gpio.h"
#include "driver/i2c.h"
#include "circbuf.h"
#include "bmp280.h"

static volatile uint32_t timestamp = 0;

#define RPS_BUFFER_LEN (60*10)
static volatile uint16_t history[RPS_BUFFER_LEN] = {};
static CircBuf rps_cb;

static volatile float rpm_average = 0;
static volatile float rpm_gust = 0;

static volatile uint16_t cycle_count = 0;

void calculate_wind();

static void gpio_isr_handler(void *arg)
{
    if (cycle_count < 0xFFFF) {
        cycle_count++;
    }
}

void hw_timer_callback1s(void *arg)
{
    timestamp++;

    // FIXME use a freertos queue and pass this to a thread!
    if (cbuf_full(&rps_cb)) {
        cbuf_pop_back(&rps_cb, NULL);
    }
    cbuf_push(&rps_cb, (void *) &cycle_count);
    cycle_count = 0;

    calculate_wind();
}

void calculate_wind()
{
    // Wind speed is average from 10 minutes
    // Gust is max 3-second average anywhere within the 10 minutes

    float max_gust = 0;

    uint32_t tenmin_sum = 0;
    uint32_t numsecs = cbuf_count(&rps_cb);
    uint16_t threesec1 = 0, threesec2 = 0;
    for (size_t i = 0; i < numsecs; i++) {
        uint16_t *slot = cbuf_ptr_nth(&rps_cb, i);
        if (!slot) {
            continue;
        }

        uint16_t slotval = *slot;
        tenmin_sum += (uint32_t) slotval;

        // gust is max avg from 3 seconds within the 10 minutes
        uint32_t gust_sum = (uint32_t) threesec1 + (uint32_t) threesec2 + (uint32_t) slotval;
        threesec1 = threesec2;
        threesec2 = slotval;

        float gust_avg = (float) gust_sum * (float) 20.0f;
        if (gust_avg > max_gust) {
            max_gust = gust_avg;
        }
    }
    rpm_gust = max_gust;
    rpm_average = ((float) tenmin_sum / (float) numsecs) * 60.0f;
}


void meteo_task(void *pvParameters)
{
    cbuf_init(&rps_cb, (void *) history, RPS_BUFFER_LEN, 2); // uint16 fields

    // Try to unfuck GPIOs
    PIN_FUNC_SELECT(PERIPHS_IO_MUX_MTDI_U, FUNC_GPIO12);
    PIN_FUNC_SELECT(PERIPHS_IO_MUX_MTCK_U, FUNC_GPIO13);
    PIN_FUNC_SELECT(PERIPHS_IO_MUX_MTMS_U, FUNC_GPIO14);
    PIN_FUNC_SELECT(PERIPHS_IO_MUX_MTDO_U, FUNC_GPIO15);

    // start timer used for timebase
    ESP_ERROR_CHECK(hw_timer_init(hw_timer_callback1s, NULL));
    ESP_ERROR_CHECK(hw_timer_alarm_us(1000000, true)); // 1s timer

    gpio_config_t io_conf;
    io_conf.intr_type = GPIO_INTR_POSEDGE;
    io_conf.mode = GPIO_MODE_INPUT;
    io_conf.pin_bit_mask = 1 << 14;
    io_conf.pull_down_en = 1;
    io_conf.pull_up_en = 0;
    ESP_ERROR_CHECK(gpio_config(&io_conf));
    ESP_ERROR_CHECK(gpio_install_isr_service(0));
    ESP_ERROR_CHECK(gpio_isr_handler_add(14, gpio_isr_handler, NULL));

    /* I2C driver & peri setup */
    int i2c_master_port = I2C_NUM_0;
    i2c_config_t conf;
    conf.mode = I2C_MODE_MASTER;
    conf.sda_io_num = 4;
    conf.sda_pullup_en = 1;
    conf.scl_io_num = 5;
    conf.scl_pullup_en = 1;
    conf.clk_stretch_tick = 300; // 300 ticks, Clock stretch is about 210us, you can make changes according to the actual situation.
    ESP_ERROR_CHECK(i2c_driver_install(i2c_master_port, conf.mode));
    ESP_ERROR_CHECK(i2c_param_config(i2c_master_port, &conf));


    bmp280_params_t bmp_conf;
    bmp280_init_default_params(&bmp_conf);

    bmp280_t bmp_dev = {
            .i2c_dev = {
                    .addr = BMP280_I2C_ADDRESS_0,
                    .i2c_num = I2C_NUM_0,
            }
    };
    bmp280_init(&bmp_dev, &bmp_conf);

    vTaskDelay(pdMS_TO_TICKS(500));

    float dht_hum, dht_temp, ds_temp, bmp_temp, bmp_hum, bmp_press;
    while (1) {
        dht_hum = 0;
        dht_temp = 0;
        ds_temp = 0;
        bmp_temp = 0;
        bmp_press = 0;

        // this works ...
        ds_temp = ds18b20_measure_and_read(0, DS18B20_ANY);
        if (ds_temp != ds_temp) {
            printf("DS failed\n");
        }

        if (!dht_read_float_data(DHT_TYPE_DHT22, 12, &dht_hum, &dht_temp)) {
            dht_hum = dht_temp = NAN;
            printf("DHT failed\n");
        }

        if(!bmp280_read_float(&bmp_dev, &bmp_temp, &bmp_press, &bmp_hum)) {
            printf("BMP failed\n");
        }

        printf("Dallas: %.2f °C, ** DHT %.2f °C, %.1f %%r.H, ** WIND avg %.1f, gust %.1f RPM, ** BMP %.2f °C, %f Pa \n",
               ds_temp, dht_temp, dht_hum,
               rpm_average, rpm_gust,
               bmp_temp, bmp_press);

        vTaskDelay(pdMS_TO_TICKS(500));
    }

    vTaskDelete(NULL);
}