add writeonly writemode

Author: HotNoob

classes/protocol_settings.py

@@ -137,6 +137,8 @@ class WriteMode(Enum):
     ''' READ AND WRITE '''
 
     #todo, write only
+    WRITEONLY = 0x03
+    ''' WRITE ONLY'''
 
     @classmethod
     def fromString(cls, name : str):
@@ -155,7 +157,8 @@ def fromString(cls, name : str):
             "R/W"    : "WRITE",
             "RW"    : "WRITE",
             "W"     : "WRITE",
-            "YES"   : "WRITE"
+            "YES"   : "WRITE",
+            "WO"    : "WRITEONLY"
         }
 
         if name in alias:
@@ -635,6 +638,9 @@ def calculate_registry_ranges(self, map : list[registry_map_entry], max_register
                 if register.register >= start and register.register < end:
                     if register.write_mode == WriteMode.READDISABLED: ##register is disabled; skip
                         continue
+                    if register.write_mode == WriteMode.WRITEONLY: ##Write Only; skip
+                        continue
+                
                     registers.append(register.register)
 
             if registers: #not empty

classes/transports/mqtt.py

@@ -194,7 +194,7 @@ def init_bridge(self, from_transport : transport_base):
             self.__write_topics = {}
             #subscribe to write topics
             for entry in from_transport.protocolSettings.get_registry_map(Registry_Type.HOLDING):
-                if entry.write_mode == WriteMode.WRITE:
+                if entry.write_mode == WriteMode.WRITE or entry.write_mode == WriteMode.WRITEONLY:
                     #__write_topics
                     topic : str = self.base_topic + "/write/" + entry.variable_name.lower().replace(' ', '_')
                     self.__write_topics[topic] = entry
@@ -230,6 +230,7 @@ def mqtt_discovery(self, from_transport : transport_base):
             if item.write_mode == WriteMode.READDISABLED: #disabled
                 continue
 
+
             clean_name = item.variable_name.lower().replace(' ', '_')
 
             if False:
@@ -250,8 +251,8 @@ def mqtt_discovery(self, from_transport : transport_base):
             disc_payload['unique_id'] = "hotnoob_" + from_transport.device_serial_number + "_"+clean_name
 
             writePrefix = ""
-            if from_transport.write_enabled and item.write_mode == WriteMode.WRITE:
-                writePrefix = "" #home assistant doesnt like write prefix
+            if from_transport.write_enabled and ( item.write_mode == WriteMode.WRITE or item.write_mode == WriteMode.WRITEONLY ):
+                writePrefix = "" #home assistant doesnt like write prefix   
 
             disc_payload['state_topic'] = self.base_topic + '/' +from_transport.device_identifier + writePrefix+ "/"+clean_name
 
@@ -264,6 +265,10 @@ def mqtt_discovery(self, from_transport : transport_base):
             self.client.publish(discovery_topic,
                                        json.dumps(disc_payload),qos=1, retain=True)
 
+            #send WO message to indicate topic is write only
+            if item.write_mode == WriteMode.WRITEONLY:
+                self.client.publish(disc_payload['state_topic'], "WRITEONLY")
+            
             time.sleep(0.07) #slow down for better reliability
 
         self.client.publish(disc_payload['availability_topic'],"online",qos=0, retain=True)