Swap SetpointVarCount and AnalogVarCount assignments for correct value tracking

Monitoring Client/module.php

@@ -9,8 +9,8 @@ class MonitoringClient extends IPSModule {
         $this->RegisterPropertyInteger("ParseNotifyCategoryID","0");
         $this->RegisterPropertyInteger("ParseAlarmCategoryID","0");
         $this->RegisterPropertyInteger("ParseAnalogCategoryID","0");
-        $this->RegisterPropertyInteger("ParseSetpointCategoryID","0");
-        $this->RegisterPropertyInteger("ParseSetpointCacheCategoryID","0");
+        $this->RegisterPropertyInteger("ParseSetpointCategoryID",-1);
+        $this->RegisterPropertyInteger("ParseSetpointCacheCategoryID",-1);
 
         $this->RegisterPropertyInteger("MqttCLientID","0");
         $this->RegisterPropertyInteger("Projectnumber","230001");
@@ -123,23 +123,28 @@ class MonitoringClient extends IPSModule {
     } // MQTT_Publish
 
     public function MqttSync($server_id, $topic, $payload, $retain, $ident, $source) {
-
+        IPS_LogMessage("Monitoring Client", "MQTT Sync called with Topic: " . $topic . " Payload: " . $payload. " Source: " . $source . " Ident: " . $ident);
         $cacheCat = $this->ReadPropertyInteger("ParseSetpointCacheCategoryID");
 
-        if ($cacheCat == 0){
+        if ($cacheCat < 1){
+            IPS_LogMessage("Monitoring Client", "No Cache Category defined for Setpoint Sync. Please define a Cache Category to use this feature.");
             return false;
         }
 
         if (IPS_CategoryExists($cacheCat) == false){
+            IPS_LogMessage("Monitoring Client", "Cache Category does not exist for Setpoint Sync.");
             return false;
         }
 
         if (IPS_VariableExists($source) == false){
+            IPS_LogMessage("Monitoring Client", "Source variable does not exist for Setpoint Sync.");
+
             return false;
         }
 
         // ensure server instance exists
         if(!IPS_InstanceExists($server_id)) {
+            IPS_LogMessage("Monitoring Client", "Server instance does not exist for Setpoint Sync.");
             return false;
         }
 
@@ -155,7 +160,9 @@ class MonitoringClient extends IPSModule {
             $ips_var_type = 0;
         } else { // unsupported
             return false;
+            IPS_LogMessage("Monitoring Client", "Unsupported data type for Setpoint Sync.");
         }
+        IPS_LogMessage("Monitoring Client", "Data type for Setpoint Sync determined as: " . $ips_var_type);
 
         $module_id = "{01C00ADD-D04E-452E-B66A-D253278743FE}" /* Module ID of MQTT Server Device */;
 
@@ -169,7 +176,7 @@ class MonitoringClient extends IPSModule {
                 IPS_SetParent($id, $cacheCat);
                 IPS_SetIdent($id, $ident);
                 // name object to help with debugging
-                IPS_SetName($id, "CS_" . $name);
+                IPS_SetName($id, "CS_" . $ident);
 
                 // configure temporary device
                 $config_arr = array(
@@ -186,6 +193,7 @@ class MonitoringClient extends IPSModule {
             // ensure the specified server instance is actually compatible
             if(!IPS_IsInstanceCompatible($id, $server_id)) {
                 return false;
+                IPS_LogMessage("Monitoring Client", "Device is not compatible with server instance for Setpoint Sync.");
             }
 
             $inst_config = IPS_GetInstance($id);
@@ -193,11 +201,17 @@ class MonitoringClient extends IPSModule {
                 IPS_DisconnectInstance($id);
                 if(!@IPS_ConnectInstance($id, $server_id)) {
                     return false;
+                    IPS_LogMessage("Monitoring Client", "Could not connect device to server instance for Setpoint Sync.");
                 }
             }
+            IPS_LogMessage("Monitoring Client", "Parentid was :".$id);
+            $id = IPS_GetChildrenIDs($id)[0];
+            IPS_LogMessage("Monitoring Client", "ID was :".$id);
 
-            $valSelf = $this->GetValue($id);
-            $valSource = $this->GetValue($source);
+            $valSelf = GetValue($id);
+            $valSource = GetValue($source);
+
+            IPS_LogMessage("Monitoring Client", "Self value: " . $valSelf . " Source value: " . $valSource);
 
             $varInfoSelf = IPS_GetVariable($id); 
             $changedtimeSelf = $varInfoSelf["VariableChanged"];
@@ -210,11 +224,13 @@ class MonitoringClient extends IPSModule {
                 //self is newer than source, so update source with self value
                 if ($changedtimeSelf > $changedtimeSource) {
                     RequestAction($source, $valSelf);
+                    IPS_LogMessage("Monitoring Client", "Source variable updated with self value for Setpoint Sync. Source: " . $source . " Value: " . $valSelf);
                 } 
 
                 //source is newer than self, so update self with source value
                 if ($changedtimeSource > $changedtimeSelf) {
                     RequestAction($id, $valSource);
+                    IPS_LogMessage("Monitoring Client", "Self variable updated with source value for Setpoint Sync. Self: " . $id . " Value: " . $valSource);
                 }
 
             }
@@ -235,10 +251,13 @@ class MonitoringClient extends IPSModule {
 
             $catIds[0]["id"] = $this->ReadPropertyInteger("ParseNotifyCategoryID");
             $catIds[0]["top"] = "Projekte". $projectyear."/P".$projectnumber. "/ISP" .$ispnumber. "/Notify/";
+            $catIds[0]["setpoint"] = false;
             $catIds[1]["id"] = $this->ReadPropertyInteger("ParseAlarmCategoryID");
             $catIds[1]["top"] = "Projekte". $projectyear."/P".$projectnumber. "/ISP" .$ispnumber. "/Alarm/";
+            $catIds[1]["setpoint"] = false;
             $catIds[2]["id"] = $this->ReadPropertyInteger("ParseAnalogCategoryID");
             $catIds[2]["top"] = "Projekte". $projectyear."/P".$projectnumber. "/ISP" .$ispnumber. "/Analog/";
+            $catIds[2]["setpoint"] = false;
             $catIds[3]["id"] = $this->ReadPropertyInteger("ParseSetpointCategoryID");
             $catIds[3]["top"] = "Projekte". $projectyear."/P".$projectnumber. "/ISP" .$ispnumber. "/Setpoint/";
             $catIds[3]["setpoint"] = true;
@@ -246,6 +265,8 @@ class MonitoringClient extends IPSModule {
 
             foreach ($catIds as $catId){
 
+                        $isSetpoint = isset($catId["setpoint"]) ? $catId["setpoint"] : false;
+
                         $catChilds = IPS_GetChildrenIDs($catId["id"]);
 
                         foreach ($catChilds as $catChild) {
@@ -273,13 +294,16 @@ class MonitoringClient extends IPSModule {
                                             $changedtime = $varInfo["VariableChanged"];
                                             $varname = IPS_GetName($childid);
                                             $topic = $catId["top"]. $parname."_".$varname;
+                                            $syncname = $parname."_".$varname;
                                             $payload = round(getvalue($childid), 2);
                                             $time = time();
 
                                             $isSetpoint = isset($catId["setpoint"]) ? $catId["setpoint"] : false;
                                             
                                             if ($isSetpoint == true){
-                                                $this->MqttSync($mqttId, $topic, $payload, false, $parname."_".$varname, $childid);
+                                                IPS_LogMessage("Monitoring Client", "Sync Setpoint: " . $topic . " mit Payload: " . $payload. " und Source: " . $childid . " und Ident: " . $syncname);
+                                                $this->MqttSync($mqttId, $topic, $payload, false, $syncname, $childid);
+                                                
                                             }else{
                                                 if($changedtime > $time - $updatetime){
                                                     $this->MqttPublish($mqttId, $topic, $payload, false);
@@ -311,7 +335,9 @@ class MonitoringClient extends IPSModule {
                                     $isSetpoint = isset($catId["setpoint"]) ? $catId["setpoint"] : false;
 
                                     if ($isSetpoint == true){
+                                        IPS_LogMessage("Monitoring Client", "Sync Setpoint: " . $topic . " mit Payload: " . $payload. " und Source: " . $childid . " und Ident: " . $syncname);
                                        $this->MqttSync($mqttId, $topic, $payload, false, $parname."_".$varname, $childid);
+
                                     }else{
                                        if($changedtime > $time - $updatetime){
                                         $this->MqttPublish($mqttId, $topic, $payload, false);

Monitoring Server Influx V1/module.php

@@ -345,7 +345,7 @@ class MonitoringServer extends IPSModule {
             } 
         }
 
-        SetValueInteger($this->GetIDForIdent("SetpointVarCount"),$numberofvalues);
+        SetValueInteger($this->GetIDForIdent("AnalogVarCount"),$numberofvalues);
         $numberofvalues = 0;
 
         if ($catSetpointId > 0){
@@ -367,7 +367,7 @@ class MonitoringServer extends IPSModule {
             } 
         }
 
-        SetValueInteger($this->GetIDForIdent("AnalogVarCount"),$numberofvalues);
+        SetValueInteger($this->GetIDForIdent("SetpointVarCount"),$numberofvalues);
         $numberofvalues = 0;
 
         if ($catNotifyId > 0){