sensor.c

Go to the documentation of this file.

#include <stdint.h>

#include <linux/i2c-dev.h>

#include "../log.h"

#include "bme280.h"
#include "tsl4531.h"

#include "sensor.h"

int sensor_bus = -1;

const struct rl_sensor sensor_registry[SENSOR_REGISTRY_SIZE] = {
    {
        "TSL4531_left", TSL4531_I2C_ADDRESS_LEFT, TSL4531_CHANNEL_DEFAULT,
        RL_UNIT_LUX, RL_SCALE_NONE, &TSL4531_init, &TSL4531_close,
        &TSL4531_read, &TSL4531_getValue,
    },
    {
        "TSL4531_right", TSL4531_I2C_ADDRESS_RIGHT, TSL4531_CHANNEL_DEFAULT,
        RL_UNIT_LUX, RL_SCALE_NONE, &TSL4531_init, &TSL4531_close,
        &TSL4531_read, &TSL4531_getValue,
    },
    {
        "BME280_temp", BME280_I2C_ADDRESS_LEFT, BME280_CHANNEL_TEMPERATURE,
        RL_UNIT_DEG_C, RL_SCALE_MILLI, &BME280_init, &BME280_close,
        &BME280_read, &BME280_getValue,
    },
    {
        "BME280_rh", BME280_I2C_ADDRESS_LEFT, BME280_CHANNEL_HUMIDITY,
        RL_UNIT_INTEGER, RL_SCALE_MICRO, &BME280_init, &BME280_close,
        &BME280_read, &BME280_getValue,
    },
    {
        "BME280_press", BME280_I2C_ADDRESS_LEFT, BME280_CHANNEL_PRESSURE,
        RL_UNIT_PASCAL, RL_SCALE_MILLI, &BME280_init, &BME280_close,
        &BME280_read, &BME280_getValue,
    },
};

int Sensors_openBus(void) {
    int bus = open(I2C_BUS_FILENAME, O_RDWR);
    if (bus < 0) {
        rl_log(ERROR, "failed to open the I2C bus", bus);
    }
    return bus;
}

int Sensors_closeBus(int bus) {
    int result = close(bus);
    if (result < 0) {
        rl_log(ERROR, "failed to close the I2C bus", bus);
    }
    return result;
}

int Sensors_initSharedBus(void) {
    sensor_bus = Sensors_openBus();
    return sensor_bus;
}

int Sensors_getSharedBus(void) { return sensor_bus; }

int Sensors_initSharedComm(uint8_t device_address) {
    return ioctl(sensor_bus, I2C_SLAVE, device_address);
}

void Sensors_closeSharedBus(void) {
    Sensors_closeBus(sensor_bus);
    int sensor_bus = -1;
    (void)sensor_bus; // suppress unused warning
}

int Sensors_scan(int sensors_available[]) {

    // log message
    char message[MAX_MESSAGE_LENGTH] =
        "List of available ambient sensors:\n\t- ";

    // Scan for available sensors //
    int sensor_count = 0;

    // scan
    int mutli_channel_initialized = -1;
    for (int i = 0; i < SENSOR_REGISTRY_SIZE; i++) {
        // do not initialize multi channel sensors more than once
        int result = 0;
        if (sensor_registry[i].identifier != mutli_channel_initialized) {
            result = sensor_registry[i].init(sensor_registry[i].identifier);
        } else {
            result = SUCCESS;
        }

        if (result == SUCCESS) {
            // sensor available
            sensors_available[i] = sensor_registry[i].identifier;
            mutli_channel_initialized = sensor_registry[i].identifier;
            sensor_count++;

            // message
            strcat(message, sensor_registry[i].name);
            strcat(message, "\n\t- ");
        } else {
            // sensor not available
            sensors_available[i] = -1;
            mutli_channel_initialized = -1;
        }
    }

    // message & return
    if (sensor_count == 0) {
        rl_log(WARNING, "no ambient sensor found...");
    } else {
        message[strlen(message) - 3] = 0;
        rl_log(INFO, "%s", message);
        printf("\n\n%s\n", message);
    }
    return sensor_count;
}

void Sensors_close(int sensors_available[]) {
    int i;
    for (i = 0; i < SENSOR_REGISTRY_SIZE; i++) {
        if (sensors_available[i] >= 0) {
            sensor_registry[i].close(sensor_registry[i].identifier);
        }
    }
}