Small correction of mqtt data publication. Improved input data processing.

Author: Serhiy-Krasovskyy

src/config/constants.ts

@@ -21,6 +21,7 @@ export class Constants {
     public static ApmDefaultEnvironment = 'development';
     public static ProductionEnvironment = 'production';
     public static MaxVoltage = 400;
+    public static MaxAmperage = 40;
     public static SerialDataTimeout = 20000; // 20 seconds
     public static CacheOneDay = Intervals.OneDay;
 }

src/modules/collect-data/collect-data.service.ts

@@ -341,6 +341,13 @@ export class CollectDataService {
             );
             return;
         }
+        if (sensorData.amperage > Constants.MaxAmperage) {
+            this.logger.error(
+                `[${CollectDataService.name}].${this.processSensorData.name} => ` +
+                    `Amperage is too high: ${sensorData.amperage}A`,
+            );
+            return;
+        }
         this.sensorsDataSubject.next(sensorData);
         await this.dataService.processVoltageAmperageData(sensorData);
         // await this.dataService.processVoltageData(sensorData);

src/modules/mqtt/mqtt-client.service.ts

@@ -60,7 +60,13 @@ export class MqttClientService {
                 Current: Math.round(sensorsData.amperage * 10) / 10,
                 Voltage: Math.round(sensorsData.voltage),
                 Power:
-                    Math.round(((sensorsData.voltage * sensorsData.amperage) / 1000) * 100) / 100,
+                    Math.round(
+                        ((sensorsData.voltage *
+                            sensorsData.amperage *
+                            this.config.powerCoefficient) /
+                            1000) *
+                            100,
+                    ) / 100,
             };
             this.mqttConnectionService.publish('tele/tasmota/STATE', JSON.stringify(data), options);
         }