esp32-climate-thingsboard.ino

/*
Temp and humidity sensor connected to ThingsBoard

ArduinoJSON by Benoit Blanchon: 6.20.1
ArduinoHttpClient by Arduino: 0.5.0
DHT sensor library by begee_tokyo: 1.19
PubSubClient by Nick O'Leary: 2.8
ThingsBoard by ThingsBoard Team: 0.2.0

*/

 // Baud rate for serial output
#define SERIAL_BAUD    115200

#include <DHTesp.h>
#ifdef ESP32
  #include <WiFi.h>
#else
  #include <ESP8266WiFi.h>
#endif

#include <ThingsBoard.h>


// Which model of humidity/temp sensor?
#define DHTTYPE    DHT22 // DHT11, DHT22, DHT21

// ESP32 pin used to query the sensor
#define DHT_PIN    4

// See https://thingsboard.io/docs/getting-started-guides/helloworld/ 
// to understand how to obtain an access token
#define TOKEN     "x98xgy"
// A: x98xgy 
// B: 21asd7
// C: lkaskk
// D: 2sgg23
// E: 24lehs
// F: 890wkd
// G: 1rodx2
// H: q3qh1n
// I: daex3l
// J: 2bwa4z
// K: wpc89e
// L: en4mea
// M: sms2pt
// N: xvw0bc
// O: owooj1
// P: 92j3vp
// Q: 0iJh56
// R: t71lvv
// S: 28yu64
// T: 8hj509
// U: hnb7nz
// V: v92yyz
// W: 00op7s
// X: 265v6l
// Y: x3nxtx
// Z: l8yss2
// 000-Instructor: gho822

// ThingsBoard server instance.
#define THINGSBOARD_SERVER  "10.0.1.2" 

// WiFi access point
#define WIFI_AP_NAME        ""
// WiFi password
#define WIFI_PASSWORD       ""

// Initialize ThingsBoard client
WiFiClient espClient;

// Instantiate a ThingsBoard object
ThingsBoard tb(espClient);

// Get WiFi radio status
int status = WL_IDLE_STATUS;

// Instantiate a DHT object
DHTesp dht;

// Main application loop delay
int quant = 20;

// Period of sending a temperature/humidity data in milliseconds.
int send_delay = 2000;

// Time passed after temperature/humidity data was sent in milliseconds.
int send_passed = 0;

// Set up the application
void setup() {
  // Initialize serial for debugging
  Serial.begin(SERIAL_BAUD);

  pinMode(LED_BUILTIN, OUTPUT);

  WiFi.begin(WIFI_AP_NAME, WIFI_PASSWORD);
  
  InitWiFi();

  // Initialize temperature sensor
  dht.setup(DHT_PIN, DHTesp::DHTTYPE);
}


// Main application loop
void loop() {
  delay(quant);

  send_passed += quant;

  // Reconnect to WiFi if needed
  if (WiFi.status() != WL_CONNECTED) {
    InitWiFi();
    return;
  }

  // Reconnect to ThingsBoard, if needed
  if (!tb.connected()) {
    // Connect to the ThingsBoard
    Serial.print("Connecting to ");
    Serial.print(THINGSBOARD_SERVER);
    Serial.print(" with token ");
    Serial.println(TOKEN);
    if (!tb.connect(THINGSBOARD_SERVER, TOKEN)) {
      Serial.println("Failed!");
      return;
    }
  }

  // Check if it is time to send telemetry
  if (send_passed > send_delay) {
    Serial.print("Sending data ");

    // Uploads new telemetry to ThingsBoard using MQTT.
    // See https://thingsboard.io/docs/reference/mqtt-api/#telemetry-upload-api

    // Create a structure named "measurements" to hold humidity and temperature values
    TempAndHumidity measurements = dht.getTempAndHumidity();    

    if (isnan(measurements.humidity) || isnan(measurements.temperature)) {
      Serial.println("**Failed to read DHT sensor!**");
    } else {
      tb.sendTelemetryFloat("temperature", measurements.temperature);
      tb.sendTelemetryFloat("humidity", measurements.humidity);
      Serial.print(measurements.temperature);
      Serial.print("c / ");
      Serial.print(measurements.humidity);
      Serial.println("%).");
      blinkLED(1,250,0);
    }

    send_passed = 0;
  }

  // Process messages
  tb.loop();
}

void InitWiFi()
{
  Serial.println("");
  Serial.print("Connecting to AP as ");
  Serial.print(WiFi.macAddress());
  
  // Attempt to connect to WiFi network
  WiFi.begin(WIFI_AP_NAME, WIFI_PASSWORD);
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  
  blinkLED(3,120,120);

  Serial.println("");
  Serial.print("Connected to AP with IP address ");
  Serial.println(WiFi.localIP());
}

void blinkLED(int numberOfFlashes, int durationOn, int durationOff) {
  for(int i = 0; i < numberOfFlashes; i++){
    digitalWrite(LED_BUILTIN, HIGH);
    delay(durationOn);
    digitalWrite(LED_BUILTIN, LOW);
    delay(durationOff);
  }
}