Skip to content

Instantly share code, notes, and snippets.

@mpfeil

mpfeil/senseBox-PM.ino

Last active October 25, 2023 07:49
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save mpfeil/a6bebc8e77819f048431c60a5adc7f7d to your computer and use it in GitHub Desktop.
Save mpfeil/a6bebc8e77819f048431c60a5adc7f7d to your computer and use it in GitHub Desktop.
Download ZIP
senseBox:home V1 WiFi Sketch
Raw
senseBox-PM.ino
/*
senseBox:home - Citizen Sensingplatform
Version: wifi_1.4
Date: 2017-07-29
Homepage: https://www.sensebox.de https://www.opensensemap.org
Author: Institute for Geoinformatics, University of Muenster
Note: Sketch for senseBox:home WiFi with dust particle upgrade
Model: homeWifiFeinstaub
Email: support@sensebox.de
Code is in the public domain.
https://github.com/sensebox/node-sketch-templater
*/
/* ------------------------------------------------------------------------- */
/* ---------------------------------Metadata-------------------------------- */
/* ------------------------------------------------------------------------- */
/* SENSEBOX ID : */
/* SENSEBOX NAME: */
/* ------------------------------------------------------------------------- */
/* ------------------------------End of Metadata---------------------------- */
/* ------------------------------------------------------------------------- */
/* ------------------------------------------------------------------------- */
/* ------------------------------Configuration------------------------------ */
/* ------------------------------------------------------------------------- */
// Wifi Credentials
const char *ssid = "REPLACE_WITH_WIFI_NAME"; // your network SSID (name)
const char *pass = "REPLACE_WITH_WIFI_PASSWORD"; // your network password
// Interval of measuring and submitting values in seconds
const unsigned int postingInterval = 60e3;
// address of the server to send to
const char server[] PROGMEM = "ingress.opensensemap.org";
// senseBox ID
const char SENSEBOX_ID[] PROGMEM = "REPLACE_WITH_SENSEBOX_ID";
// Number of sensors
// Change this number if you add or remove sensors
// do not forget to remove or add the sensors on opensensemap.org
static const uint8_t NUM_SENSORS = 7;
// sensor IDs
// Temperatur
const char TEMPERSENSOR_ID[] PROGMEM = "REPLACE_WITH_TEMP_SENSOR_ID";
// rel. Luftfeuchte
const char RELLUFSENSOR_ID[] PROGMEM = "REPLACE_WITH_HUMIDITY_SENSOR_ID";
// Luftdruck
const char LUFTDRSENSOR_ID[] PROGMEM = "REPLACE_WITH_PRESSURE_SENSOR_ID";
// Beleuchtungsstärke
const char BELEUCSENSOR_ID[] PROGMEM = "REPLACE_WITH_LIGHT_SENSOR_ID";
// UV-Intensität
const char UVINTESENSOR_ID[] PROGMEM = "REPLACE_WITH_UV_SENSOR_ID";
// PM10
const char PM10SENSOR_ID[] PROGMEM = "REPLACE_WITH_PM10_SENSOR_ID";
// PM2.5
const char PM25SENSOR_ID[] PROGMEM = "REPLACE_WITH_PM25_SENSOR_ID";
// Uncomment the next line to get debugging messages printed on the Serial port
// Do not leave this enabled for long time use
// #define ENABLE_DEBUG
/* ------------------------------------------------------------------------- */
/* --------------------------End of Configuration--------------------------- */
/* ------------------------------------------------------------------------- */
#include "BMP280.h"
#include <HDC100X.h>
#include <Makerblog_TSL45315.h>
#include <SDS011-select-serial.h>
#include <SPI.h>
#include <VEML6070.h>
#include <WiFi101.h>
#include <Wire.h>
#include <avr/wdt.h>
#ifdef ENABLE_DEBUG
#define DEBUG(str) Serial.println(str)
#else
#define DEBUG(str)
#endif
WiFiClient client;
// Sensor Instances
SDS011 my_sds(Serial);
Makerblog_TSL45315 TSL = Makerblog_TSL45315(TSL45315_TIME_M4);
HDC100X HDC(0x43);
BMP280 BMP;
VEML6070 VEML;
typedef struct measurement {
const char *sensorId;
float value;
} measurement;
measurement measurements[NUM_SENSORS];
uint8_t num_measurements = 0;
// buffer for sprintf
char buffer[500];
void addMeasurement(const char *sensorId, float value) {
measurements[num_measurements].sensorId = sensorId;
measurements[num_measurements].value = value;
num_measurements++;
}
void writeMeasurementsToClient() {
// iterate throug the measurements array
for (uint8_t i = 0; i < num_measurements; i++) {
sprintf_P(buffer, PSTR("%S,"), measurements[i].sensorId);
// arduino sprintf just returns "?" for floats, use dtostrf
dtostrf(measurements[i].value, 9, 2, &buffer[strlen(buffer)]);
// transmit buffer to client
client.println(buffer);
DEBUG(buffer);
}
// reset num_measurements
num_measurements = 0;
}
void submitValues() {
if (WiFi.status() != WL_CONNECTED) {
WiFi.disconnect();
delay(1000); // wait 1s
WiFi.begin(ssid, pass);
delay(5000); // wait 5s
}
// close any connection before send a new request.
// This will free the socket on the WiFi shield
if (client.connected()) {
client.stop();
delay(1000);
}
bool connected = false;
char _server[strlen_P(server)];
strcpy_P(_server, server);
for (uint8_t timeout = 2; timeout != 0; timeout--) {
DEBUG(F("connecting..."));
connected = client.connect(_server, 80);
if (connected == true) {
DEBUG(F("Connection successful, transferring..."));
// construct the HTTP POST request:
sprintf_P(buffer,
PSTR("POST /boxes/%S/data HTTP/1.1\nAuthorization: REPLACE_WITH_AUTH_TOKEN\nHost: %S\nContent-Type: "
"text/csv\nConnection: close\nContent-Length: %i\n"),
SENSEBOX_ID, server, num_measurements * 36);
DEBUG(buffer);
// send the HTTP POST request:
client.println(buffer);
// send measurements
writeMeasurementsToClient();
// send empty line to end the request
client.println();
delay(100);
client.flush();
client.stop();
DEBUG("done!");
// reset number of measurements
num_measurements = 0;
break;
}
delay(1000);
}
if (connected == false) {
// Reset durchführen
Serial.println(F("connection failed. Restarting System."));
delay(5000);
cli();
wdt_enable(WDTO_60MS);
while (1)
;
}
}
void setup() {
// Initialize serial and wait for port to open:
Serial.begin(9600);
// Enable Wifi Shield
pinMode(4, INPUT);
digitalWrite(4, HIGH);
delay(2000);
// Check WiFi Shield status
if (WiFi.status() == WL_NO_SHIELD) {
Serial.println(F("WiFi shield not present"));
// don't continue:
while (true)
;
}
uint8_t status = WL_IDLE_STATUS;
// attempt to connect to Wifi network:
while (status != WL_CONNECTED) {
DEBUG(F("Attempting to connect to SSID: "));
DEBUG(ssid);
// Connect to WPA/WPA2 network. Change this line if using open or WEP
// network
status = WiFi.begin(ssid, pass);
// wait 10 seconds for connection:
DEBUG(F("Waiting 10 seconds for connection..."));
delay(10000);
DEBUG(F("done."));
}
// Sensor initialization
DEBUG(F("Initializing sensors..."));
VEML.begin();
delay(500);
HDC.begin(HDC100X_TEMP_HUMI, HDC100X_14BIT, HDC100X_14BIT, DISABLE);
TSL.begin();
BMP.begin();
BMP.setOversampling(4);
DEBUG(F("done!"));
DEBUG(F("Starting loop in 30 seconds."));
HDC.getTemp();
delay(30000);
}
void loop() {
// capture loop start timestamp
unsigned long start = millis();
// read measurements from sensors
addMeasurement(TEMPERSENSOR_ID, HDC.getTemp());
delay(200);
addMeasurement(RELLUFSENSOR_ID, HDC.getHumi());
double tempBaro, pressure;
char result;
result = BMP.startMeasurment();
if (result != 0) {
delay(result);
result = BMP.getTemperatureAndPressure(tempBaro, pressure);
addMeasurement(LUFTDRSENSOR_ID, pressure);
}
addMeasurement(BELEUCSENSOR_ID, TSL.readLux());
addMeasurement(UVINTESENSOR_ID, VEML.getUV());
uint8_t attempt = 0;
float pm10, pm25;
while (attempt < 5) {
bool error = my_sds.read(&pm25, &pm10);
if (!error) {
addMeasurement(PM10SENSOR_ID, pm10);
addMeasurement(PM25SENSOR_ID, pm25);
break;
}
attempt++;
}
submitValues();
// schedule next round of measurements
for (;;) {
unsigned long now = millis();
unsigned long elapsed = now - start;
if (elapsed >= postingInterval)
return;
}
}
Raw
senseBox.ino
/*
senseBox:home - Citizen Sensingplatform
Version: wifi_1.4
Date: 2017-07-29
Homepage: https://www.sensebox.de https://www.opensensemap.org
Author: Institute for Geoinformatics, University of Muenster
Note: Sketch for senseBox:home WiFi Edition
Model: homeWifi
Email: support@sensebox.de
Code is in the public domain.
https://github.com/sensebox/node-sketch-templater
*/
/* ------------------------------------------------------------------------- */
/* ---------------------------------Metadata-------------------------------- */
/* ------------------------------------------------------------------------- */
/* SENSEBOX ID : */
/* SENSEBOX NAME: */
/* ------------------------------------------------------------------------- */
/* ------------------------------End of Metadata---------------------------- */
/* ------------------------------------------------------------------------- */
/* ------------------------------------------------------------------------- */
/* ------------------------------Configuration------------------------------ */
/* ------------------------------------------------------------------------- */
// Wifi Credentials
const char *ssid = "REPLACE_WITH_WIFI_NAME"; // your network SSID (name)
const char *pass = "REPLACE_WITH_WIFI_PASSWORD"; // your network password
// Interval of measuring and submitting values in seconds
const unsigned int postingInterval = 60e3;
// address of the server to send to
const char server[] PROGMEM = "ingress.opensensemap.org";
// senseBox ID
const char SENSEBOX_ID[] PROGMEM = "REPLACE_WITH_SENSEBOX_ID";
// Number of sensors
// Change this number if you add or remove sensors
// do not forget to remove or add the sensors on opensensemap.org
static const uint8_t NUM_SENSORS = 5;
// sensor IDs
// Temperatur
const char TEMPERSENSOR_ID[] PROGMEM = "REPLACE_WITH_TEMP_SENSOR_ID";
// rel. Luftfeuchte
const char RELLUFSENSOR_ID[] PROGMEM = "REPLACE_WITH_HUMIDITY_SENSOR_ID";
// Luftdruck
const char LUFTDRSENSOR_ID[] PROGMEM = "REPLACE_WITH_PRESSURE_SENSOR_ID";
// Beleuchtungsstärke
const char BELEUCSENSOR_ID[] PROGMEM = "REPLACE_WITH_LIGHT_SENSOR_ID";
// UV-Intensität
const char UVINTESENSOR_ID[] PROGMEM = "REPLACE_WITH_UV_SENSOR_ID";
// Uncomment the next line to get debugging messages printed on the Serial port
// Do not leave this enabled for long time use
// #define ENABLE_DEBUG
/* ------------------------------------------------------------------------- */
/* --------------------------End of Configuration--------------------------- */
/* ------------------------------------------------------------------------- */
#include "BMP280.h"
#include <HDC100X.h>
#include <Makerblog_TSL45315.h>
#include <SPI.h>
#include <VEML6070.h>
#include <WiFi101.h>
#include <Wire.h>
#include <avr/wdt.h>
#ifdef ENABLE_DEBUG
#define DEBUG(str) Serial.println(str)
#else
#define DEBUG(str)
#endif
WiFiClient client;
// Sensor Instances
Makerblog_TSL45315 TSL = Makerblog_TSL45315(TSL45315_TIME_M4);
HDC100X HDC(0x43);
BMP280 BMP;
VEML6070 VEML;
typedef struct measurement {
const char *sensorId;
float value;
} measurement;
measurement measurements[NUM_SENSORS];
uint8_t num_measurements = 0;
// buffer for sprintf
char buffer[500];
void addMeasurement(const char *sensorId, float value) {
measurements[num_measurements].sensorId = sensorId;
measurements[num_measurements].value = value;
num_measurements++;
}
void writeMeasurementsToClient() {
// iterate throug the measurements array
for (uint8_t i = 0; i < num_measurements; i++) {
sprintf_P(buffer, PSTR("%S,"), measurements[i].sensorId);
// arduino sprintf just returns "?" for floats, use dtostrf
dtostrf(measurements[i].value, 9, 2, &buffer[strlen(buffer)]);
// transmit buffer to client
client.println(buffer);
DEBUG(buffer);
}
// reset num_measurements
num_measurements = 0;
}
void submitValues() {
if (WiFi.status() != WL_CONNECTED) {
WiFi.disconnect();
delay(1000); // wait 1s
WiFi.begin(ssid, pass);
delay(5000); // wait 5s
}
// close any connection before send a new request.
// This will free the socket on the WiFi shield
if (client.connected()) {
client.stop();
delay(1000);
}
bool connected = false;
char _server[strlen_P(server)];
strcpy_P(_server, server);
for (uint8_t timeout = 2; timeout != 0; timeout--) {
DEBUG(F("connecting..."));
connected = client.connect(_server, 80);
if (connected == true) {
DEBUG(F("Connection successful, transferring..."));
// construct the HTTP POST request:
sprintf_P(buffer,
PSTR("POST /boxes/%S/data HTTP/1.1\nAuthorization: REPLACE_WITH_AUTH_TOKEN\nHost: %S\nContent-Type: "
"text/csv\nConnection: close\nContent-Length: %i\n"),
SENSEBOX_ID, server, num_measurements * 36);
DEBUG(buffer);
// send the HTTP POST request:
client.println(buffer);
// send measurements
writeMeasurementsToClient();
// send empty line to end the request
client.println();
delay(100);
client.flush();
client.stop();
DEBUG("done!");
// reset number of measurements
num_measurements = 0;
break;
}
delay(1000);
}
if (connected == false) {
// Reset durchführen
Serial.println(F("connection failed. Restarting System."));
delay(5000);
cli();
wdt_enable(WDTO_60MS);
while (1)
;
}
}
void setup() {
// Initialize serial and wait for port to open:
Serial.begin(9600);
// Enable Wifi Shield
pinMode(4, INPUT);
digitalWrite(4, HIGH);
delay(2000);
// Check WiFi Shield status
if (WiFi.status() == WL_NO_SHIELD) {
Serial.println(F("WiFi shield not present"));
// don't continue:
while (true)
;
}
uint8_t status = WL_IDLE_STATUS;
// attempt to connect to Wifi network:
while (status != WL_CONNECTED) {
DEBUG(F("Attempting to connect to SSID: "));
DEBUG(ssid);
// Connect to WPA/WPA2 network. Change this line if using open or WEP
// network
status = WiFi.begin(ssid, pass);
// wait 10 seconds for connection:
DEBUG(F("Waiting 10 seconds for connection..."));
delay(10000);
DEBUG(F("done."));
}
// Sensor initialization
DEBUG(F("Initializing sensors..."));
VEML.begin();
delay(500);
HDC.begin(HDC100X_TEMP_HUMI, HDC100X_14BIT, HDC100X_14BIT, DISABLE);
TSL.begin();
BMP.begin();
BMP.setOversampling(4);
DEBUG(F("done!"));
DEBUG(F("Starting loop in 30 seconds."));
HDC.getTemp();
delay(30000);
}
void loop() {
// capture loop start timestamp
unsigned long start = millis();
// read measurements from sensors
addMeasurement(TEMPERSENSOR_ID, HDC.getTemp());
delay(200);
addMeasurement(RELLUFSENSOR_ID, HDC.getHumi());
double tempBaro, pressure;
char result;
result = BMP.startMeasurment();
if (result != 0) {
delay(result);
result = BMP.getTemperatureAndPressure(tempBaro, pressure);
addMeasurement(LUFTDRSENSOR_ID, pressure);
}
addMeasurement(BELEUCSENSOR_ID, TSL.readLux());
addMeasurement(UVINTESENSOR_ID, VEML.getUV());
submitValues();
// schedule next round of measurements
for (;;) {
unsigned long now = millis();
unsigned long elapsed = now - start;
if (elapsed >= postingInterval)
return;
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment