From 7b1d9ae63eb001eafc0f7f4e4f87332e76753cd0 Mon Sep 17 00:00:00 2001
From: Mathieu Maret <mathieu.maret@gmail.com>
Date: Sat, 10 Sep 2022 22:48:37 +0200
Subject: [PATCH] Avoid some mqtt server connection

Do not check subscription when we do not subscribe
---
 WifiControlSensor/MQTT.ino   | 9 ++++++---
 WifiControlSensor/Teleinfo.h | 2 +-
 2 files changed, 7 insertions(+), 4 deletions(-)

diff --git a/WifiControlSensor/MQTT.ino b/WifiControlSensor/MQTT.ino
index 9542bc0..952f528 100644
--- a/WifiControlSensor/MQTT.ino
+++ b/WifiControlSensor/MQTT.ino
@@ -197,14 +197,17 @@ void MqttCheckIRQ() {
 
 }
 
-void MqttCheckSubscription() {
+void MqttCheckSubscription()
+{
+  if (mqtt->getSubscriptionCount() == 0)
+    return;
   if (MqttConnect() == 0) {
     Adafruit_MQTT_Subscribe *subscription;
     while ((subscription = mqtt->readSubscription(0))) {
       int gpio = getGpioFromSubscription(subscription, "/gpio/");
       if (gpio > 0 && findIndex(gpio, gpioControlled) >= 0) {
         SKETCH_DEBUG_PRINTF("Got Subscription for GPIO %d\n", gpio);
-        char *value = (char *) subscription->lastread;
+        char *value = (char *)subscription->lastread;
         SKETCH_DEBUG_PRINTF("Receive data: %s\n", value);
         MqttChangeGpioValue(gpio, atoi(value));
       }
@@ -212,7 +215,7 @@ void MqttCheckSubscription() {
       gpio = getGpioFromSubscription(subscription, "/pwm/");
       if (gpio > 0 && findIndex(gpio, pwmControlled) >= 0) {
         SKETCH_DEBUG_PRINTF("Got Subscription for PWM %d\n", gpio);
-        char *value = (char *) subscription->lastread;
+        char *value = (char *)subscription->lastread;
         SKETCH_DEBUG_PRINTF("Receive data: %s\n", value);
         MqttChangePWMValue(gpio, atoi(value));
       }
diff --git a/WifiControlSensor/Teleinfo.h b/WifiControlSensor/Teleinfo.h
index 576635f..23183c3 100644
--- a/WifiControlSensor/Teleinfo.h
+++ b/WifiControlSensor/Teleinfo.h
@@ -15,7 +15,7 @@ int TeleinfoSetup() {
 inline int TeleinfoProcess(std::vector<struct mqttInfo> &){
     return 0;
 };
-int TeleinfoProcess(float &iinst, float &papp, float &base){
+int TeleinfoProcess(float &, float &, float &){
     return 0;
 };
 #endif