Merge pull request #297 from brentru/add-pm25aqi

Add support for Adafruit PMSA003I Air Quality Breakout

Author: brentru

library.properties

@@ -1,10 +1,10 @@
 name=Adafruit WipperSnapper
-version=1.0.0-beta.43
+version=1.0.0-beta.44
 author=Adafruit
 maintainer=Adafruit <adafruitio@adafruit.com>
 sentence=Arduino client for Adafruit.io WipperSnapper
 paragraph=Arduino client for Adafruit.io WipperSnapper
 category=Communication
 url=https://github.com/adafruit/Adafruit_IO_Arduino
 architectures=*
-depends=Adafruit NeoPixel, Adafruit SPIFlash, ArduinoJson, Adafruit DotStar, Adafruit SleepyDog Library, Adafruit TinyUSB Library, Adafruit AHTX0, Adafruit BME280 Library, Adafruit DPS310, Adafruit SCD30, Sensirion I2C SCD4x, Adafruit MCP9808 Library, Adafruit MCP9600 Library, Adafruit TSL2591 Library, Adafruit SHT4x Library
+depends=Adafruit NeoPixel, Adafruit SPIFlash, ArduinoJson, Adafruit DotStar, Adafruit SleepyDog Library, Adafruit TinyUSB Library, Adafruit AHTX0, Adafruit BME280 Library, Adafruit DPS310, Adafruit SCD30, Sensirion I2C SCD4x, Adafruit MCP9808 Library, Adafruit MCP9600 Library, Adafruit TSL2591 Library, Adafruit SHT4x Library, Adafruit PM25 AQI Sensor

src/Wippersnapper.h

@@ -60,7 +60,7 @@
 #endif
 
 #define WS_VERSION                                                             \
-  "1.0.0-beta.43" ///< WipperSnapper app. version (semver-formatted)
+  "1.0.0-beta.44" ///< WipperSnapper app. version (semver-formatted)
 
 // Reserved Adafruit IO MQTT topics
 #define TOPIC_IO_THROTTLE "/throttle" ///< Adafruit IO Throttle MQTT Topic

src/components/i2c/WipperSnapper_I2C.cpp

@@ -304,6 +304,17 @@ bool WipperSnapper_Component_I2C::initI2CDevice(
     _sht4x->configureDriver(msgDeviceInitReq);
     drivers.push_back(_sht4x);
     WS_DEBUG_PRINTLN("SHT4X Initialized Successfully!");
+  } else if (strcmp("pmsa003i", msgDeviceInitReq->i2c_device_name) == 0) {
+    _pm25 = new WipperSnapper_I2C_Driver_PM25(this->_i2c, i2cAddress);
+    if (!_pm25->begin()) {
+      WS_DEBUG_PRINTLN("ERROR: Failed to initialize PM2.5 AQI Sensor!");
+      _busStatusResponse =
+          wippersnapper_i2c_v1_BusResponse_BUS_RESPONSE_DEVICE_INIT_FAIL;
+      return false;
+    }
+    _pm25->configureDriver(msgDeviceInitReq);
+    drivers.push_back(_pm25);
+    WS_DEBUG_PRINTLN("PM2.5 AQI Sensor Initialized Successfully!");
   } else {
     WS_DEBUG_PRINTLN("ERROR: I2C device type not found!")
     _busStatusResponse =
@@ -360,6 +371,18 @@ void WipperSnapper_Component_I2C::updateI2CDeviceProperties(
           drivers[i]->updateSensorLight(
               msgDeviceUpdateReq->i2c_device_properties[j].sensor_period);
           break;
+        case wippersnapper_i2c_v1_SensorType_SENSOR_TYPE_PM10_STD:
+          drivers[i]->updateSensorPM10_STD(
+              msgDeviceUpdateReq->i2c_device_properties[j].sensor_period);
+          break;
+        case wippersnapper_i2c_v1_SensorType_SENSOR_TYPE_PM25_STD:
+          drivers[i]->updateSensorPM25_STD(
+              msgDeviceUpdateReq->i2c_device_properties[j].sensor_period);
+          break;
+        case wippersnapper_i2c_v1_SensorType_SENSOR_TYPE_PM100_STD:
+          drivers[i]->updateSensorPM100_STD(
+              msgDeviceUpdateReq->i2c_device_properties[j].sensor_period);
+          break;
         default:
           _busStatusResponse =
               wippersnapper_i2c_v1_BusResponse_BUS_RESPONSE_UNSUPPORTED_SENSOR;
@@ -655,6 +678,75 @@ void WipperSnapper_Component_I2C::update() {
       }
     }
 
+    // PM10_STD sensor
+    curTime = millis();
+    if ((*iter)->sensorPM10_STDPeriod() != 0L &&
+        curTime - (*iter)->SensorPM10_STDPeriodPrv() >
+            (*iter)->sensorPM10_STDPeriod()) {
+      if ((*iter)->getEventPM10_STD(&event)) {
+        WS_DEBUG_PRINT("Sensor 0x");
+        WS_DEBUG_PRINTHEX((*iter)->getI2CAddress());
+        WS_DEBUG_PRINTLN("");
+        WS_DEBUG_PRINT("\tPM1.0: ");
+        WS_DEBUG_PRINT(event.data[0]);
+        WS_DEBUG_PRINTLN(" ppm");
+
+        // pack event data into msg
+        fillEventMessage(&msgi2cResponse, event.data[0],
+                         wippersnapper_i2c_v1_SensorType_SENSOR_TYPE_PM10_STD);
+
+        (*iter)->setSensorPM10_STDPeriodPrv(curTime);
+      } else {
+        WS_DEBUG_PRINTLN("ERROR: Failed to get PM1.0 sensor reading!");
+      }
+    }
+
+    // PM25_STD sensor
+    curTime = millis();
+    if ((*iter)->sensorPM25_STDPeriod() != 0L &&
+        curTime - (*iter)->SensorPM25_STDPeriodPrv() >
+            (*iter)->sensorPM25_STDPeriod()) {
+      if ((*iter)->getEventPM25_STD(&event)) {
+        WS_DEBUG_PRINT("Sensor 0x");
+        WS_DEBUG_PRINTHEX((*iter)->getI2CAddress());
+        WS_DEBUG_PRINTLN("");
+        WS_DEBUG_PRINT("\tPM2.5: ");
+        WS_DEBUG_PRINT(event.data[0]);
+        WS_DEBUG_PRINTLN(" ppm");
+
+        // pack event data into msg
+        fillEventMessage(&msgi2cResponse, event.data[0],
+                         wippersnapper_i2c_v1_SensorType_SENSOR_TYPE_PM25_STD);
+
+        (*iter)->setSensorPM25_STDPeriodPrv(curTime);
+      } else {
+        WS_DEBUG_PRINTLN("ERROR: Failed to get PM2.5 sensor reading!");
+      }
+    }
+
+    // PM100_STD sensor
+    curTime = millis();
+    if ((*iter)->sensorPM100_STDPeriod() != 0L &&
+        curTime - (*iter)->SensorPM100_STDPeriodPrv() >
+            (*iter)->sensorPM100_STDPeriod()) {
+      if ((*iter)->getEventPM100_STD(&event)) {
+        WS_DEBUG_PRINT("Sensor 0x");
+        WS_DEBUG_PRINTHEX((*iter)->getI2CAddress());
+        WS_DEBUG_PRINTLN("");
+        WS_DEBUG_PRINT("\tPM100: ");
+        WS_DEBUG_PRINT(event.data[0]);
+        WS_DEBUG_PRINTLN(" ppm");
+
+        // pack event data into msg
+        fillEventMessage(&msgi2cResponse, event.data[0],
+                         wippersnapper_i2c_v1_SensorType_SENSOR_TYPE_PM100_STD);
+
+        (*iter)->setSensorPM100_STDPeriodPrv(curTime);
+      } else {
+        WS_DEBUG_PRINTLN("ERROR: Failed to get PM10.0 sensor reading!");
+      }
+    }
+
     // Did this driver obtain data from sensors?
     if (msgi2cResponse.payload.resp_i2c_device_event.sensor_event_count == 0)
       continue;

src/components/i2c/WipperSnapper_I2C.h

@@ -25,6 +25,7 @@
 #include "drivers/WipperSnapper_I2C_Driver_DPS310.h"
 #include "drivers/WipperSnapper_I2C_Driver_MCP9601.h"
 #include "drivers/WipperSnapper_I2C_Driver_MCP9808.h"
+#include "drivers/WipperSnapper_I2C_Driver_PM25.h"
 #include "drivers/WipperSnapper_I2C_Driver_SCD30.h"
 #include "drivers/WipperSnapper_I2C_Driver_SCD40.h"
 #include "drivers/WipperSnapper_I2C_Driver_SHT4X.h"
@@ -81,6 +82,7 @@ class WipperSnapper_Component_I2C {
   WipperSnapper_I2C_Driver_MCP9601 *_mcp9601 = nullptr;
   WipperSnapper_I2C_Driver_TSL2591 *_tsl2591 = nullptr;
   WipperSnapper_I2C_Driver_SCD40 *_scd40 = nullptr;
+  WipperSnapper_I2C_Driver_PM25 *_pm25 = nullptr;
   WipperSnapper_I2C_Driver_SHT4X *_sht4x = nullptr;
 };
 extern Wippersnapper WS;