MQTT_DS18B20.ino

#include "./GLOBAL_VARS_MQTT_DS18B20.h"
#include "unspecialized_mqtt_doings.h"
#include "MqttLogging.h"
#include "desired_temp_MQTT_DS18B20.h"
#include "desired_speed_MQTT_DS18B20.h"
#include "received_temp_MQTT_DS18B20.h"
#include "fan_pwm_MQTT_DS18B20.h"
// #include "ventile_control_MQTT_DS18B20.h"
// #include "window_contact_MQTT_DS18B20.h"
#include "do_calculations_MQTT_DS18B20.h"


#if !defined(ARDUINO_D1_MINI32) && !defined(ARDUINO_LOLIN_S2_MINI) && !defined(ARDUINO_ESP8266_WEMOS_D1MINI)
#error "unsupported board type"
#error ARDUINO_BOARD
#else
#pragma message ARDUINO_BOARD is selected
#endif

#include "thermostat_preferences.h"

void onMqttConnect(bool sessionPresent) {
  Serial.print("Connected to MQTT - IP=");
  Serial.print(WiFi.localIP());
  Serial.print("- RSSI: ");
  Serial.print(WiFi.RSSI());
  Serial.print(" dB - Session present: ");
  Serial.println(sessionPresent);
  // todo not necessarily QOS 2, 1 or 0 are also ok... 
  uint16_t packetIdSub = mqttClient.subscribe((MQTT_PUB_DES_PREFIX MQTT_PUB_TEMP_SUFFIX).c_str(), 2);
  Serial.print("Subscribing desired temp at QoS 2, packetId: ");
  Serial.println(packetIdSub);
  // publishDesTemp(desired_temp); must be created by mqtt broker
  packetIdSub = mqttClient.subscribe((MQTT_PUB_DES_PREFIX MQTT_PUB_TEMPHYST_SUFFIX).c_str(), 2);
  Serial.print("Subscribing desired hyst at QoS 2, packetId: ");
  // publishTempHyst(temp_hyst); must be created by mqtt broker
  packetIdSub = mqttClient.subscribe((MQTT_PUB_DES_PREFIX MQTT_PUB_FANTHROTTLE_SUFFIX).c_str(), 2);
  Serial.print("Subscribing max fan speed at QoS 2, packetId: ");
  Serial.println(packetIdSub);
  packetIdSub = mqttClient.subscribe((MQTT_PUB_DEV_PREFIX +"/Preferences/MqttName").c_str(), 2);
  Serial.print("Subscribing desired device name, packetId: ");
  Serial.println(packetIdSub);
  packetIdSub = mqttClient.subscribe((MQTT_PUB_DEV_PREFIX +"/Preferences/Debug").c_str(), 2);
  Serial.print("Subscribing debug setting, packetId: ");
  Serial.println(packetIdSub);
  publishDesSpeed(PWM_THROTTLE);
  MQTTLogPrintf("Thermostat started %d Thermosensors found", numberOfDevices);
}

void onMqttDisconnect(AsyncMqttClientDisconnectReason reason) {
  Serial.println("Disconnected from MQTT.");
  // if (WiFi.isConnected()) {
  //  mqttReconnectTimer.once(2, connectToMqtt);
  // }
  return;
  }

void onMqttSubscribe(uint16_t packetId, uint8_t qos) {
  // Serial.println("Subscribe acknowledged.");
  // Serial.print("  packetId: ");
  // Serial.println(packetId);
  // Serial.print("  qos: ");
  // Serial.println(qos);
}

void onMqttUnsubscribe(uint16_t packetId) {
  // Serial.println("Unsubscribe acknowledged.");
  // Serial.print("  packetSerial Id: ");
  // Serial.println(packetId);
}

void onMqttPublish(uint16_t packetId) {
  // Serial.print("Publish acknowledged.");
  // Serial.print("  packetId: ");
  // Serial.println(packetId);
}

void onMqttMessage(char* topic, char* payload, AsyncMqttClientMessageProperties properties, size_t len, size_t index, size_t total) {

  char buffer[50];
  buffer[49]=buffer[len]='\0';
  for (int i=0;i<len && i<29;i++){
    buffer [i] = payload[i];   
  }

  /// Distinguish pathpayload
  
  testDesiredTemperature(buffer, topic);  
  testDesiredTempHyst(buffer, topic);
  testDesiredFanspeed(buffer,topic);
  testPreferences(buffer, topic);
}

void setup() {
  sensors.begin();
  Serial.begin(115200);
  delay(4000);
  Serial.println("*** SETUP ***");
  getPreferences();
#if defined(ARDUINO_D1_MINI32) || defined(ARDUINO_LOLIN_S2_MINI)
  // ledcSetup(0, 8000, 8); // pwm#, freq, resolution(bits)
  // ledcAttachPin(pwmGpio, 0);
  ledcAttachChannel(pwmGpio, 8000, 8, 0);
#endif
#if defined(ARDUINO_ESP8266_WEMOS_D1MINI)
  pinMode(pwmGpio, OUTPUT);
  analogWriteFreq(8000);
  analogWrite(pwmGpio,255); // raw write off!
#endif  
  pinMode(valveGpio, OUTPUT);
  pinMode(windowContact, INPUT); 
#if defined(ARDUINO_D1_MINI32) || defined(ARDUINO_LOLIN_S2_MINI)
  WiFi.onEvent(onWifiConnect,WiFiEvent_t::ARDUINO_EVENT_WIFI_STA_GOT_IP);
  WiFi.onEvent(onWifiDisconnect,WiFiEvent_t::ARDUINO_EVENT_WIFI_STA_DISCONNECTED);
#else  
  wifiConnectHandler = WiFi.onStationModeGotIP(onWifiConnect);
  wifiDisconnectHandler = WiFi.onStationModeDisconnected(onWifiDisconnect);
#endif

  mqttClient.onConnect(onMqttConnect);
  mqttClient.onDisconnect(onMqttDisconnect);
  mqttClient.onSubscribe(onMqttSubscribe);
  mqttClient.onUnsubscribe(onMqttUnsubscribe);
  mqttClient.onPublish(onMqttPublish);
   mqttClient.onMessage(onMqttMessage);
  mqttClient.setServer(MQTT_HOST, MQTT_PORT);
  
  // mqttClient.setKeepAlive(30);
  // If your broker requires authentication (username and password), set them below
  //mqttClient.setCredentials("REPlACE_WITH_YOUR_USE92:de:dc:42:f3:f8R", "REPLACE_WITH_YOUR_PASSWORD");
  connectToWifi();
  initTemperatureSensors();
  previousMillis = millis(); // avoid initial overrun?
}


uint8_t lastPwm=0; 

void SelftestPwm(){
   if (lastPwm != PWM_THROTTLE) {
    lastPwm = PWM_THROTTLE;
    setSpeed(PWM_THROTTLE);
    Serial.print("set PWM to ");
    Serial.println(PWM_THROTTLE);
   }

}


unsigned short usWifiDown=12;
void loop() {
  unsigned long currentMillis = millis();
  if (uiDebug == 1) {
    SelftestPwm();
    return;
  }

  
  // Every X number of seconds (interval = 10 seconds) 
  // it publishes a new MQTT message
  if (currentMillis - previousMillis >= interval) {
    // Save the last time a new reading was published
    previousMillis = currentMillis;
    // New temperature readings
    // if (!wifiStatus()) return;
    wifiStatus();

    getTemperatures();

    runTempControl();
#if 1
// try it again ... does not help ...
    if (WiFi.isConnected() && mqttClient.connected())
    {
      usWifiDown=12;  // 2 minutes @ 10 sec run interval
    }
    else
    {
      usWifiDown--;
      Serial.print(" Wifi Error count down ");
      Serial.println(usWifiDown);
      if (usWifiDown==0) // 2 Minuten expired
        ESP.restart();
    }
#endif    
  }
 
}