mirror of
https://github.com/meshtastic/firmware.git
synced 2025-10-27 15:02:41 +00:00
b4dea63f44
Some checks are pending
CI / setup (all) (push) Waiting to run
CI / setup (check) (push) Waiting to run
CI / version (push) Waiting to run
CI / check (push) Blocked by required conditions
CI / build (push) Blocked by required conditions
CI / build-debian-src (push) Waiting to run
CI / package-pio-deps-native-tft (push) Waiting to run
CI / test-native (push) Waiting to run
CI / docker (alpine, native, linux/amd64) (push) Waiting to run
CI / docker (alpine, native, linux/arm64) (push) Waiting to run
CI / docker (alpine, native-tft, linux/amd64) (push) Waiting to run
CI / docker (debian, native, linux/amd64) (push) Waiting to run
CI / docker (debian, native, linux/arm/v7) (push) Waiting to run
CI / docker (debian, native, linux/arm64) (push) Waiting to run
CI / docker (debian, native-tft, linux/amd64) (push) Waiting to run
CI / gather-artifacts (esp32) (push) Blocked by required conditions
CI / gather-artifacts (esp32c3) (push) Blocked by required conditions
CI / gather-artifacts (esp32c6) (push) Blocked by required conditions
CI / gather-artifacts (esp32s3) (push) Blocked by required conditions
CI / gather-artifacts (nrf52840) (push) Blocked by required conditions
CI / gather-artifacts (rp2040) (push) Blocked by required conditions
CI / gather-artifacts (rp2350) (push) Blocked by required conditions
CI / gather-artifacts (stm32) (push) Blocked by required conditions
CI / release-artifacts (push) Blocked by required conditions
CI / release-firmware (esp32) (push) Blocked by required conditions
CI / release-firmware (esp32c3) (push) Blocked by required conditions
CI / release-firmware (esp32c6) (push) Blocked by required conditions
CI / release-firmware (esp32s3) (push) Blocked by required conditions
CI / release-firmware (nrf52840) (push) Blocked by required conditions
CI / release-firmware (rp2040) (push) Blocked by required conditions
CI / release-firmware (rp2350) (push) Blocked by required conditions
CI / release-firmware (stm32) (push) Blocked by required conditions
CI / publish-firmware (push) Blocked by required conditions
715 lines
26 KiB
C++
715 lines
26 KiB
C++
#include "configuration.h"
|
|
|
|
#if HAS_TELEMETRY && !MESHTASTIC_EXCLUDE_ENVIRONMENTAL_SENSOR
|
|
|
|
#include "../mesh/generated/meshtastic/telemetry.pb.h"
|
|
#include "Default.h"
|
|
#include "EnvironmentTelemetry.h"
|
|
#include "MeshService.h"
|
|
#include "NodeDB.h"
|
|
#include "PowerFSM.h"
|
|
#include "RTC.h"
|
|
#include "Router.h"
|
|
#include "UnitConversions.h"
|
|
#include "buzz.h"
|
|
#include "graphics/SharedUIDisplay.h"
|
|
#include "graphics/images.h"
|
|
#include "main.h"
|
|
#include "modules/ExternalNotificationModule.h"
|
|
#include "power.h"
|
|
#include "sleep.h"
|
|
#include "target_specific.h"
|
|
#include <OLEDDisplay.h>
|
|
|
|
#if !MESHTASTIC_EXCLUDE_ENVIRONMENTAL_SENSOR_EXTERNAL
|
|
|
|
// Sensors
|
|
#include "Sensor/CGRadSensSensor.h"
|
|
#include "Sensor/RCWL9620Sensor.h"
|
|
#include "Sensor/nullSensor.h"
|
|
|
|
namespace graphics
|
|
{
|
|
extern void drawCommonHeader(OLEDDisplay *display, int16_t x, int16_t y, const char *titleStr, bool force_no_invert,
|
|
bool show_date);
|
|
}
|
|
#if __has_include(<Adafruit_AHTX0.h>)
|
|
#include "Sensor/AHT10.h"
|
|
#endif
|
|
|
|
#if __has_include(<Adafruit_BME280.h>)
|
|
#include "Sensor/BME280Sensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<Adafruit_BMP085.h>)
|
|
#include "Sensor/BMP085Sensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<Adafruit_BMP280.h>)
|
|
#include "Sensor/BMP280Sensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<Adafruit_LTR390.h>)
|
|
#include "Sensor/LTR390UVSensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<bsec2.h>)
|
|
#include "Sensor/BME680Sensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<Adafruit_DPS310.h>)
|
|
#include "Sensor/DPS310Sensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<Adafruit_MCP9808.h>)
|
|
#include "Sensor/MCP9808Sensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<Adafruit_SHT31.h>)
|
|
#include "Sensor/SHT31Sensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<Adafruit_LPS2X.h>)
|
|
#include "Sensor/LPS22HBSensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<Adafruit_SHTC3.h>)
|
|
#include "Sensor/SHTC3Sensor.h"
|
|
#endif
|
|
|
|
#if __has_include("RAK12035_SoilMoisture.h") && defined(RAK_4631) && RAK_4631 == 1
|
|
#include "Sensor/RAK12035Sensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<Adafruit_VEML7700.h>)
|
|
#include "Sensor/VEML7700Sensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<Adafruit_TSL2591.h>)
|
|
#include "Sensor/TSL2591Sensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<ClosedCube_OPT3001.h>)
|
|
#include "Sensor/OPT3001Sensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<Adafruit_SHT4x.h>)
|
|
#include "Sensor/SHT4XSensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<SparkFun_MLX90632_Arduino_Library.h>)
|
|
#include "Sensor/MLX90632Sensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<DFRobot_LarkWeatherStation.h>)
|
|
#include "Sensor/DFRobotLarkSensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<DFRobot_RainfallSensor.h>)
|
|
#include "Sensor/DFRobotGravitySensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<SparkFun_Qwiic_Scale_NAU7802_Arduino_Library.h>)
|
|
#include "Sensor/NAU7802Sensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<Adafruit_BMP3XX.h>)
|
|
#include "Sensor/BMP3XXSensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<Adafruit_PCT2075.h>)
|
|
#include "Sensor/PCT2075Sensor.h"
|
|
#endif
|
|
|
|
#endif
|
|
#ifdef T1000X_SENSOR_EN
|
|
#include "Sensor/T1000xSensor.h"
|
|
#endif
|
|
|
|
#ifdef SENSECAP_INDICATOR
|
|
#include "Sensor/IndicatorSensor.h"
|
|
#endif
|
|
|
|
#if __has_include(<Adafruit_TSL2561_U.h>)
|
|
#include "Sensor/TSL2561Sensor.h"
|
|
#endif
|
|
|
|
#define FAILED_STATE_SENSOR_READ_MULTIPLIER 10
|
|
#define DISPLAY_RECEIVEID_MEASUREMENTS_ON_SCREEN true
|
|
|
|
#include "graphics/ScreenFonts.h"
|
|
#include <Throttle.h>
|
|
|
|
#include <forward_list>
|
|
|
|
static std::forward_list<TelemetrySensor *> sensors;
|
|
|
|
template <typename T> void addSensor(ScanI2C *i2cScanner, ScanI2C::DeviceType type)
|
|
{
|
|
ScanI2C::FoundDevice dev = i2cScanner->find(type);
|
|
if (dev.type != ScanI2C::DeviceType::NONE || type == ScanI2C::DeviceType::NONE) {
|
|
TelemetrySensor *sensor = new T();
|
|
#if WIRE_INTERFACES_COUNT > 1
|
|
TwoWire *bus = ScanI2CTwoWire::fetchI2CBus(dev.address);
|
|
if (dev.address.port != ScanI2C::I2CPort::WIRE1 && sensor->onlyWire1()) {
|
|
// This sensor only works on Wire (Wire1 is not supported)
|
|
delete sensor;
|
|
return;
|
|
}
|
|
#else
|
|
TwoWire *bus = &Wire;
|
|
#endif
|
|
if (sensor->initDevice(bus, &dev)) {
|
|
sensors.push_front(sensor);
|
|
return;
|
|
}
|
|
// destroy sensor
|
|
delete sensor;
|
|
}
|
|
}
|
|
|
|
void EnvironmentTelemetryModule::i2cScanFinished(ScanI2C *i2cScanner)
|
|
{
|
|
if (!moduleConfig.telemetry.environment_measurement_enabled && !ENVIRONMENTAL_TELEMETRY_MODULE_ENABLE) {
|
|
return;
|
|
}
|
|
LOG_INFO("Environment Telemetry adding I2C devices...");
|
|
|
|
// order by priority of metrics/values (low top, high bottom)
|
|
|
|
#if !MESHTASTIC_EXCLUDE_ENVIRONMENTAL_SENSOR
|
|
#ifdef T1000X_SENSOR_EN
|
|
// Not a real I2C device
|
|
addSensor<T1000xSensor>(i2cScanner, ScanI2C::DeviceType::NONE);
|
|
#else
|
|
#ifdef SENSECAP_INDICATOR
|
|
// Not a real I2C device, uses UART
|
|
addSensor<IndicatorSensor>(i2cScanner, ScanI2C::DeviceType::NONE);
|
|
#endif
|
|
addSensor<RCWL9620Sensor>(i2cScanner, ScanI2C::DeviceType::RCWL9620);
|
|
addSensor<CGRadSensSensor>(i2cScanner, ScanI2C::DeviceType::CGRADSENS);
|
|
#endif
|
|
#endif
|
|
|
|
#if !MESHTASTIC_EXCLUDE_ENVIRONMENTAL_SENSOR && !MESHTASTIC_EXCLUDE_ENVIRONMENTAL_SENSOR_EXTERNAL
|
|
#if __has_include(<DFRobot_LarkWeatherStation.h>)
|
|
addSensor<DFRobotLarkSensor>(i2cScanner, ScanI2C::DeviceType::DFROBOT_LARK);
|
|
#endif
|
|
#if __has_include(<DFRobot_RainfallSensor.h>)
|
|
addSensor<DFRobotGravitySensor>(i2cScanner, ScanI2C::DeviceType::DFROBOT_RAIN);
|
|
#endif
|
|
#if __has_include(<Adafruit_AHTX0.h>)
|
|
addSensor<AHT10Sensor>(i2cScanner, ScanI2C::DeviceType::AHT10);
|
|
#endif
|
|
#if __has_include(<Adafruit_BMP085.h>)
|
|
addSensor<BMP085Sensor>(i2cScanner, ScanI2C::DeviceType::BMP_085);
|
|
#endif
|
|
#if __has_include(<Adafruit_BME280.h>)
|
|
addSensor<BME280Sensor>(i2cScanner, ScanI2C::DeviceType::BME_280);
|
|
#endif
|
|
#if __has_include(<Adafruit_LTR390.h>)
|
|
addSensor<LTR390UVSensor>(i2cScanner, ScanI2C::DeviceType::LTR390UV);
|
|
#endif
|
|
#if __has_include(<bsec2.h>)
|
|
addSensor<BME680Sensor>(i2cScanner, ScanI2C::DeviceType::BME_680);
|
|
#endif
|
|
#if __has_include(<Adafruit_BMP280.h>)
|
|
addSensor<BMP280Sensor>(i2cScanner, ScanI2C::DeviceType::BMP_280);
|
|
#endif
|
|
#if __has_include(<Adafruit_DPS310.h>)
|
|
addSensor<DPS310Sensor>(i2cScanner, ScanI2C::DeviceType::DPS310);
|
|
#endif
|
|
#if __has_include(<Adafruit_MCP9808.h>)
|
|
addSensor<MCP9808Sensor>(i2cScanner, ScanI2C::DeviceType::MCP9808);
|
|
#endif
|
|
#if __has_include(<Adafruit_SHT31.h>)
|
|
addSensor<SHT31Sensor>(i2cScanner, ScanI2C::DeviceType::SHT31);
|
|
#endif
|
|
#if __has_include(<Adafruit_LPS2X.h>)
|
|
addSensor<LPS22HBSensor>(i2cScanner, ScanI2C::DeviceType::LPS22HB);
|
|
#endif
|
|
#if __has_include(<Adafruit_SHTC3.h>)
|
|
addSensor<SHTC3Sensor>(i2cScanner, ScanI2C::DeviceType::SHTC3);
|
|
#endif
|
|
#if __has_include("RAK12035_SoilMoisture.h") && defined(RAK_4631) && RAK_4631 == 1
|
|
addSensor<RAK12035Sensor>(i2cScanner, ScanI2C::DeviceType::RAK12035);
|
|
#endif
|
|
#if __has_include(<Adafruit_VEML7700.h>)
|
|
addSensor<VEML7700Sensor>(i2cScanner, ScanI2C::DeviceType::VEML7700);
|
|
#endif
|
|
#if __has_include(<Adafruit_TSL2591.h>)
|
|
addSensor<TSL2591Sensor>(i2cScanner, ScanI2C::DeviceType::TSL2591);
|
|
#endif
|
|
#if __has_include(<ClosedCube_OPT3001.h>)
|
|
addSensor<OPT3001Sensor>(i2cScanner, ScanI2C::DeviceType::OPT3001);
|
|
#endif
|
|
#if __has_include(<Adafruit_SHT4x.h>)
|
|
addSensor<SHT4XSensor>(i2cScanner, ScanI2C::DeviceType::SHT4X);
|
|
#endif
|
|
#if __has_include(<SparkFun_MLX90632_Arduino_Library.h>)
|
|
addSensor<MLX90632Sensor>(i2cScanner, ScanI2C::DeviceType::MLX90632);
|
|
#endif
|
|
|
|
#if __has_include(<Adafruit_BMP3XX.h>)
|
|
addSensor<BMP3XXSensor>(i2cScanner, ScanI2C::DeviceType::BMP_3XX);
|
|
#endif
|
|
#if __has_include(<Adafruit_PCT2075.h>)
|
|
addSensor<PCT2075Sensor>(i2cScanner, ScanI2C::DeviceType::PCT2075);
|
|
#endif
|
|
#if __has_include(<Adafruit_TSL2561_U.h>)
|
|
addSensor<TSL2561Sensor>(i2cScanner, ScanI2C::DeviceType::TSL2561);
|
|
#endif
|
|
#if __has_include(<SparkFun_Qwiic_Scale_NAU7802_Arduino_Library.h>)
|
|
addSensor<NAU7802Sensor>(i2cScanner, ScanI2C::DeviceType::NAU7802);
|
|
#endif
|
|
|
|
#endif
|
|
}
|
|
|
|
int32_t EnvironmentTelemetryModule::runOnce()
|
|
{
|
|
if (sleepOnNextExecution == true) {
|
|
sleepOnNextExecution = false;
|
|
uint32_t nightyNightMs = Default::getConfiguredOrDefaultMs(moduleConfig.telemetry.environment_update_interval,
|
|
default_telemetry_broadcast_interval_secs);
|
|
LOG_DEBUG("Sleep for %ims, then awake to send metrics again", nightyNightMs);
|
|
doDeepSleep(nightyNightMs, true, false);
|
|
}
|
|
|
|
uint32_t result = UINT32_MAX;
|
|
/*
|
|
Uncomment the preferences below if you want to use the module
|
|
without having to configure it from the PythonAPI or WebUI.
|
|
*/
|
|
|
|
// moduleConfig.telemetry.environment_measurement_enabled = 1;
|
|
// moduleConfig.telemetry.environment_screen_enabled = 1;
|
|
// moduleConfig.telemetry.environment_update_interval = 15;
|
|
|
|
if (!(moduleConfig.telemetry.environment_measurement_enabled || moduleConfig.telemetry.environment_screen_enabled ||
|
|
ENVIRONMENTAL_TELEMETRY_MODULE_ENABLE)) {
|
|
// If this module is not enabled, and the user doesn't want the display screen don't waste any OSThread time on it
|
|
return disable();
|
|
}
|
|
|
|
if (firstTime) {
|
|
// This is the first time the OSThread library has called this function, so do some setup
|
|
firstTime = 0;
|
|
|
|
if (moduleConfig.telemetry.environment_measurement_enabled || ENVIRONMENTAL_TELEMETRY_MODULE_ENABLE) {
|
|
LOG_INFO("Environment Telemetry: init");
|
|
|
|
// check if we have at least one sensor
|
|
if (!sensors.empty()) {
|
|
result = DEFAULT_SENSOR_MINIMUM_WAIT_TIME_BETWEEN_READS;
|
|
}
|
|
|
|
#ifdef T1000X_SENSOR_EN
|
|
#elif !MESHTASTIC_EXCLUDE_ENVIRONMENTAL_SENSOR_EXTERNAL
|
|
if (ina219Sensor.hasSensor())
|
|
result = ina219Sensor.runOnce();
|
|
if (ina260Sensor.hasSensor())
|
|
result = ina260Sensor.runOnce();
|
|
if (ina3221Sensor.hasSensor())
|
|
result = ina3221Sensor.runOnce();
|
|
if (max17048Sensor.hasSensor())
|
|
result = max17048Sensor.runOnce();
|
|
// this only works on the wismesh hub with the solar option. This is not an I2C sensor, so we don't need the
|
|
// sensormap here.
|
|
#ifdef HAS_RAKPROT
|
|
result = rak9154Sensor.runOnce();
|
|
#endif
|
|
#endif
|
|
}
|
|
// it's possible to have this module enabled, only for displaying values on the screen.
|
|
// therefore, we should only enable the sensor loop if measurement is also enabled
|
|
return result == UINT32_MAX ? disable() : setStartDelay();
|
|
} else {
|
|
// if we somehow got to a second run of this module with measurement disabled, then just wait forever
|
|
if (!moduleConfig.telemetry.environment_measurement_enabled && !ENVIRONMENTAL_TELEMETRY_MODULE_ENABLE) {
|
|
return disable();
|
|
}
|
|
|
|
for (TelemetrySensor *sensor : sensors) {
|
|
uint32_t delay = sensor->runOnce();
|
|
if (delay < result) {
|
|
result = delay;
|
|
}
|
|
}
|
|
|
|
if (((lastSentToMesh == 0) ||
|
|
!Throttle::isWithinTimespanMs(lastSentToMesh, Default::getConfiguredOrDefaultMsScaled(
|
|
moduleConfig.telemetry.environment_update_interval,
|
|
default_telemetry_broadcast_interval_secs, numOnlineNodes))) &&
|
|
airTime->isTxAllowedChannelUtil(config.device.role != meshtastic_Config_DeviceConfig_Role_SENSOR) &&
|
|
airTime->isTxAllowedAirUtil()) {
|
|
sendTelemetry();
|
|
lastSentToMesh = millis();
|
|
} else if (((lastSentToPhone == 0) || !Throttle::isWithinTimespanMs(lastSentToPhone, sendToPhoneIntervalMs)) &&
|
|
(service->isToPhoneQueueEmpty())) {
|
|
// Just send to phone when it's not our time to send to mesh yet
|
|
// Only send while queue is empty (phone assumed connected)
|
|
sendTelemetry(NODENUM_BROADCAST, true);
|
|
lastSentToPhone = millis();
|
|
}
|
|
}
|
|
return min(sendToPhoneIntervalMs, result);
|
|
}
|
|
|
|
bool EnvironmentTelemetryModule::wantUIFrame()
|
|
{
|
|
return moduleConfig.telemetry.environment_screen_enabled;
|
|
}
|
|
|
|
#if HAS_SCREEN
|
|
void EnvironmentTelemetryModule::drawFrame(OLEDDisplay *display, OLEDDisplayUiState *state, int16_t x, int16_t y)
|
|
{
|
|
// === Setup display ===
|
|
display->clear();
|
|
display->setFont(FONT_SMALL);
|
|
display->setTextAlignment(TEXT_ALIGN_LEFT);
|
|
int line = 1;
|
|
|
|
// === Set Title
|
|
const char *titleStr = (graphics::isHighResolution) ? "Environment" : "Env.";
|
|
|
|
// === Header ===
|
|
graphics::drawCommonHeader(display, x, y, titleStr);
|
|
|
|
// === Row spacing setup ===
|
|
const int rowHeight = FONT_HEIGHT_SMALL - 4;
|
|
int currentY = graphics::getTextPositions(display)[line++];
|
|
|
|
// === Show "No Telemetry" if no data available ===
|
|
if (!lastMeasurementPacket) {
|
|
display->drawString(x, currentY, "No Telemetry");
|
|
return;
|
|
}
|
|
|
|
// Decode the telemetry message from the latest received packet
|
|
const meshtastic_Data &p = lastMeasurementPacket->decoded;
|
|
meshtastic_Telemetry telemetry;
|
|
if (!pb_decode_from_bytes(p.payload.bytes, p.payload.size, &meshtastic_Telemetry_msg, &telemetry)) {
|
|
display->drawString(x, currentY, "No Telemetry");
|
|
return;
|
|
}
|
|
|
|
const auto &m = telemetry.variant.environment_metrics;
|
|
|
|
// Check if any telemetry field has valid data
|
|
bool hasAny = m.has_temperature || m.has_relative_humidity || m.barometric_pressure != 0 || m.iaq != 0 || m.voltage != 0 ||
|
|
m.current != 0 || m.lux != 0 || m.white_lux != 0 || m.weight != 0 || m.distance != 0 || m.radiation != 0;
|
|
|
|
if (!hasAny) {
|
|
display->drawString(x, currentY, "No Telemetry");
|
|
return;
|
|
}
|
|
|
|
// === First line: Show sender name + time since received (left), and first metric (right) ===
|
|
const char *sender = getSenderShortName(*lastMeasurementPacket);
|
|
uint32_t agoSecs = service->GetTimeSinceMeshPacket(lastMeasurementPacket);
|
|
String agoStr = (agoSecs > 864000) ? "?"
|
|
: (agoSecs > 3600) ? String(agoSecs / 3600) + "h"
|
|
: (agoSecs > 60) ? String(agoSecs / 60) + "m"
|
|
: String(agoSecs) + "s";
|
|
|
|
String leftStr = String(sender) + " (" + agoStr + ")";
|
|
display->drawString(x, currentY, leftStr); // Left side: who and when
|
|
|
|
// === Collect sensor readings as label strings (no icons) ===
|
|
std::vector<String> entries;
|
|
|
|
if (m.has_temperature) {
|
|
String tempStr = moduleConfig.telemetry.environment_display_fahrenheit
|
|
? "Tmp: " + String(UnitConversions::CelsiusToFahrenheit(m.temperature), 1) + "°F"
|
|
: "Tmp: " + String(m.temperature, 1) + "°C";
|
|
entries.push_back(tempStr);
|
|
}
|
|
if (m.has_relative_humidity)
|
|
entries.push_back("Hum: " + String(m.relative_humidity, 0) + "%");
|
|
if (m.barometric_pressure != 0)
|
|
entries.push_back("Prss: " + String(m.barometric_pressure, 0) + " hPa");
|
|
if (m.iaq != 0) {
|
|
String aqi = "IAQ: " + String(m.iaq);
|
|
const char *bannerMsg = nullptr; // Default: no banner
|
|
|
|
if (m.iaq <= 25)
|
|
aqi += " (Excellent)";
|
|
else if (m.iaq <= 50)
|
|
aqi += " (Good)";
|
|
else if (m.iaq <= 100)
|
|
aqi += " (Moderate)";
|
|
else if (m.iaq <= 150)
|
|
aqi += " (Poor)";
|
|
else if (m.iaq <= 200) {
|
|
aqi += " (Unhealthy)";
|
|
bannerMsg = "Unhealthy IAQ";
|
|
} else if (m.iaq <= 300) {
|
|
aqi += " (Very Unhealthy)";
|
|
bannerMsg = "Very Unhealthy IAQ";
|
|
} else {
|
|
aqi += " (Hazardous)";
|
|
bannerMsg = "Hazardous IAQ";
|
|
}
|
|
|
|
entries.push_back(aqi);
|
|
|
|
// === IAQ alert logic ===
|
|
static uint32_t lastAlertTime = 0;
|
|
uint32_t now = millis();
|
|
|
|
bool isOwnTelemetry = lastMeasurementPacket->from == nodeDB->getNodeNum();
|
|
bool isCooldownOver = (now - lastAlertTime > 60000);
|
|
|
|
if (isOwnTelemetry && bannerMsg && isCooldownOver) {
|
|
LOG_INFO("drawFrame: IAQ %d (own) — showing banner: %s", m.iaq, bannerMsg);
|
|
screen->showSimpleBanner(bannerMsg, 3000);
|
|
|
|
// Only buzz if IAQ is over 200
|
|
if (m.iaq > 200 && moduleConfig.external_notification.enabled && !externalNotificationModule->getMute()) {
|
|
playLongBeep();
|
|
}
|
|
|
|
lastAlertTime = now;
|
|
}
|
|
}
|
|
if (m.voltage != 0 || m.current != 0)
|
|
entries.push_back(String(m.voltage, 1) + "V / " + String(m.current, 0) + "mA");
|
|
if (m.lux != 0)
|
|
entries.push_back("Light: " + String(m.lux, 0) + "lx");
|
|
if (m.white_lux != 0)
|
|
entries.push_back("White: " + String(m.white_lux, 0) + "lx");
|
|
if (m.weight != 0)
|
|
entries.push_back("Weight: " + String(m.weight, 0) + "kg");
|
|
if (m.distance != 0)
|
|
entries.push_back("Level: " + String(m.distance, 0) + "mm");
|
|
if (m.radiation != 0)
|
|
entries.push_back("Rad: " + String(m.radiation, 2) + " µR/h");
|
|
|
|
// === Show first available metric on top-right of first line ===
|
|
if (!entries.empty()) {
|
|
String valueStr = entries.front();
|
|
int rightX = SCREEN_WIDTH - display->getStringWidth(valueStr);
|
|
display->drawString(rightX, currentY, valueStr);
|
|
entries.erase(entries.begin()); // Remove from queue
|
|
}
|
|
|
|
// === Advance to next line for remaining telemetry entries ===
|
|
currentY += rowHeight;
|
|
|
|
// === Draw remaining entries in 2-column format (left and right) ===
|
|
for (size_t i = 0; i < entries.size(); i += 2) {
|
|
// Left column
|
|
display->drawString(x, currentY, entries[i]);
|
|
|
|
// Right column if it exists
|
|
if (i + 1 < entries.size()) {
|
|
int rightX = SCREEN_WIDTH / 2;
|
|
display->drawString(rightX, currentY, entries[i + 1]);
|
|
}
|
|
|
|
currentY += rowHeight;
|
|
}
|
|
}
|
|
#endif
|
|
|
|
bool EnvironmentTelemetryModule::handleReceivedProtobuf(const meshtastic_MeshPacket &mp, meshtastic_Telemetry *t)
|
|
{
|
|
if (t->which_variant == meshtastic_Telemetry_environment_metrics_tag) {
|
|
#if defined(DEBUG_PORT) && !defined(DEBUG_MUTE)
|
|
const char *sender = getSenderShortName(mp);
|
|
|
|
LOG_INFO("(Received from %s): barometric_pressure=%f, current=%f, gas_resistance=%f, relative_humidity=%f, "
|
|
"temperature=%f",
|
|
sender, t->variant.environment_metrics.barometric_pressure, t->variant.environment_metrics.current,
|
|
t->variant.environment_metrics.gas_resistance, t->variant.environment_metrics.relative_humidity,
|
|
t->variant.environment_metrics.temperature);
|
|
LOG_INFO("(Received from %s): voltage=%f, IAQ=%d, distance=%f, lux=%f, white_lux=%f", sender,
|
|
t->variant.environment_metrics.voltage, t->variant.environment_metrics.iaq,
|
|
t->variant.environment_metrics.distance, t->variant.environment_metrics.lux,
|
|
t->variant.environment_metrics.white_lux);
|
|
|
|
LOG_INFO("(Received from %s): wind speed=%fm/s, direction=%d degrees, weight=%fkg", sender,
|
|
t->variant.environment_metrics.wind_speed, t->variant.environment_metrics.wind_direction,
|
|
t->variant.environment_metrics.weight);
|
|
|
|
LOG_INFO("(Received from %s): radiation=%fµR/h", sender, t->variant.environment_metrics.radiation);
|
|
|
|
#endif
|
|
// release previous packet before occupying a new spot
|
|
if (lastMeasurementPacket != nullptr)
|
|
packetPool.release(lastMeasurementPacket);
|
|
|
|
lastMeasurementPacket = packetPool.allocCopy(mp);
|
|
}
|
|
|
|
return false; // Let others look at this message also if they want
|
|
}
|
|
|
|
bool EnvironmentTelemetryModule::getEnvironmentTelemetry(meshtastic_Telemetry *m)
|
|
{
|
|
bool valid = true;
|
|
bool hasSensor = false;
|
|
m->time = getTime();
|
|
m->which_variant = meshtastic_Telemetry_environment_metrics_tag;
|
|
m->variant.environment_metrics = meshtastic_EnvironmentMetrics_init_zero;
|
|
|
|
for (TelemetrySensor *sensor : sensors) {
|
|
valid = valid && sensor->getMetrics(m);
|
|
hasSensor = true;
|
|
}
|
|
|
|
#ifndef T1000X_SENSOR_EN
|
|
if (ina219Sensor.hasSensor()) {
|
|
valid = valid && ina219Sensor.getMetrics(m);
|
|
hasSensor = true;
|
|
}
|
|
if (ina260Sensor.hasSensor()) {
|
|
valid = valid && ina260Sensor.getMetrics(m);
|
|
hasSensor = true;
|
|
}
|
|
if (ina3221Sensor.hasSensor()) {
|
|
valid = valid && ina3221Sensor.getMetrics(m);
|
|
hasSensor = true;
|
|
}
|
|
if (max17048Sensor.hasSensor()) {
|
|
valid = valid && max17048Sensor.getMetrics(m);
|
|
hasSensor = true;
|
|
}
|
|
#endif
|
|
#ifdef HAS_RAKPROT
|
|
valid = valid && rak9154Sensor.getMetrics(m);
|
|
hasSensor = true;
|
|
#endif
|
|
return valid && hasSensor;
|
|
}
|
|
|
|
meshtastic_MeshPacket *EnvironmentTelemetryModule::allocReply()
|
|
{
|
|
if (currentRequest) {
|
|
auto req = *currentRequest;
|
|
const auto &p = req.decoded;
|
|
meshtastic_Telemetry scratch;
|
|
meshtastic_Telemetry *decoded = NULL;
|
|
memset(&scratch, 0, sizeof(scratch));
|
|
if (pb_decode_from_bytes(p.payload.bytes, p.payload.size, &meshtastic_Telemetry_msg, &scratch)) {
|
|
decoded = &scratch;
|
|
} else {
|
|
LOG_ERROR("Error decoding EnvironmentTelemetry module!");
|
|
return NULL;
|
|
}
|
|
// Check for a request for environment metrics
|
|
if (decoded->which_variant == meshtastic_Telemetry_environment_metrics_tag) {
|
|
meshtastic_Telemetry m = meshtastic_Telemetry_init_zero;
|
|
if (getEnvironmentTelemetry(&m)) {
|
|
LOG_INFO("Environment telemetry reply to request");
|
|
return allocDataProtobuf(m);
|
|
} else {
|
|
return NULL;
|
|
}
|
|
}
|
|
}
|
|
return NULL;
|
|
}
|
|
|
|
bool EnvironmentTelemetryModule::sendTelemetry(NodeNum dest, bool phoneOnly)
|
|
{
|
|
meshtastic_Telemetry m = meshtastic_Telemetry_init_zero;
|
|
m.which_variant = meshtastic_Telemetry_environment_metrics_tag;
|
|
m.time = getTime();
|
|
|
|
if (getEnvironmentTelemetry(&m)) {
|
|
LOG_INFO("Send: barometric_pressure=%f, current=%f, gas_resistance=%f, relative_humidity=%f, temperature=%f",
|
|
m.variant.environment_metrics.barometric_pressure, m.variant.environment_metrics.current,
|
|
m.variant.environment_metrics.gas_resistance, m.variant.environment_metrics.relative_humidity,
|
|
m.variant.environment_metrics.temperature);
|
|
LOG_INFO("Send: voltage=%f, IAQ=%d, distance=%f, lux=%f", m.variant.environment_metrics.voltage,
|
|
m.variant.environment_metrics.iaq, m.variant.environment_metrics.distance, m.variant.environment_metrics.lux);
|
|
|
|
LOG_INFO("Send: wind speed=%fm/s, direction=%d degrees, weight=%fkg", m.variant.environment_metrics.wind_speed,
|
|
m.variant.environment_metrics.wind_direction, m.variant.environment_metrics.weight);
|
|
|
|
LOG_INFO("Send: radiation=%fµR/h", m.variant.environment_metrics.radiation);
|
|
|
|
LOG_INFO("Send: soil_temperature=%f, soil_moisture=%u", m.variant.environment_metrics.soil_temperature,
|
|
m.variant.environment_metrics.soil_moisture);
|
|
|
|
sensor_read_error_count = 0;
|
|
|
|
meshtastic_MeshPacket *p = allocDataProtobuf(m);
|
|
p->to = dest;
|
|
p->decoded.want_response = false;
|
|
if (config.device.role == meshtastic_Config_DeviceConfig_Role_SENSOR)
|
|
p->priority = meshtastic_MeshPacket_Priority_RELIABLE;
|
|
else
|
|
p->priority = meshtastic_MeshPacket_Priority_BACKGROUND;
|
|
// release previous packet before occupying a new spot
|
|
if (lastMeasurementPacket != nullptr)
|
|
packetPool.release(lastMeasurementPacket);
|
|
|
|
lastMeasurementPacket = packetPool.allocCopy(*p);
|
|
if (phoneOnly) {
|
|
LOG_INFO("Send packet to phone");
|
|
service->sendToPhone(p);
|
|
} else {
|
|
LOG_INFO("Send packet to mesh");
|
|
service->sendToMesh(p, RX_SRC_LOCAL, true);
|
|
|
|
if (config.device.role == meshtastic_Config_DeviceConfig_Role_SENSOR && config.power.is_power_saving) {
|
|
meshtastic_ClientNotification *notification = clientNotificationPool.allocZeroed();
|
|
notification->level = meshtastic_LogRecord_Level_INFO;
|
|
notification->time = getValidTime(RTCQualityFromNet);
|
|
sprintf(notification->message, "Sending telemetry and sleeping for %us interval in a moment",
|
|
Default::getConfiguredOrDefaultMs(moduleConfig.telemetry.environment_update_interval,
|
|
default_telemetry_broadcast_interval_secs) /
|
|
1000U);
|
|
service->sendClientNotification(notification);
|
|
sleepOnNextExecution = true;
|
|
LOG_DEBUG("Start next execution in 5s, then sleep");
|
|
setIntervalFromNow(FIVE_SECONDS_MS);
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
AdminMessageHandleResult EnvironmentTelemetryModule::handleAdminMessageForModule(const meshtastic_MeshPacket &mp,
|
|
meshtastic_AdminMessage *request,
|
|
meshtastic_AdminMessage *response)
|
|
{
|
|
AdminMessageHandleResult result = AdminMessageHandleResult::NOT_HANDLED;
|
|
#if !MESHTASTIC_EXCLUDE_ENVIRONMENTAL_SENSOR_EXTERNAL
|
|
|
|
for (TelemetrySensor *sensor : sensors) {
|
|
result = sensor->handleAdminMessage(mp, request, response);
|
|
if (result != AdminMessageHandleResult::NOT_HANDLED)
|
|
return result;
|
|
}
|
|
|
|
if (ina219Sensor.hasSensor()) {
|
|
result = ina219Sensor.handleAdminMessage(mp, request, response);
|
|
if (result != AdminMessageHandleResult::NOT_HANDLED)
|
|
return result;
|
|
}
|
|
if (ina260Sensor.hasSensor()) {
|
|
result = ina260Sensor.handleAdminMessage(mp, request, response);
|
|
if (result != AdminMessageHandleResult::NOT_HANDLED)
|
|
return result;
|
|
}
|
|
if (ina3221Sensor.hasSensor()) {
|
|
result = ina3221Sensor.handleAdminMessage(mp, request, response);
|
|
if (result != AdminMessageHandleResult::NOT_HANDLED)
|
|
return result;
|
|
}
|
|
if (max17048Sensor.hasSensor()) {
|
|
result = max17048Sensor.handleAdminMessage(mp, request, response);
|
|
if (result != AdminMessageHandleResult::NOT_HANDLED)
|
|
return result;
|
|
}
|
|
#endif
|
|
return result;
|
|
}
|
|
|
|
#endif
|