@@ -42,6 +42,7 @@ def _handle(msg):
42
42
print "Got Thermostat at {0} last alive {1}" .format (uri , alive ['val' ])
43
43
44
44
self .client .subscribe ("{0}/signal/info" .format (uri ), _handle )
45
+ self .client .subscribe ("{0}/stages/info" .format (uri ), _handle )
45
46
46
47
@property
47
48
def cooling_setpoint (self , timeout = 30 ):
@@ -88,9 +89,9 @@ def temperature(self, timeout=30):
88
89
return read_self_timeout (self , 'temperature' , timeout )
89
90
90
91
91
- def write (self , state ):
92
+ def write (self , state , uri = 'state' ):
92
93
po = PayloadObject ((2 ,1 ,1 ,0 ), None , msgpack .packb (state ))
93
- self .client .publish ('{0}/slot/state ' .format (self ._uri ),payload_objects = (po ,))
94
+ self .client .publish ('{0}/slot/{1} ' .format (self ._uri , uri ),payload_objects = (po ,))
94
95
95
96
def set_heating_setpoint (self , value ):
96
97
self .write ({'heating_setpoint' : value })
@@ -108,8 +109,8 @@ def set_fan_mode(self, value):
108
109
self .write ({'fan_mode' : value })
109
110
110
111
def set_enabled_heat_stages (self , value ):
111
- self .write ({'enabled_heat_stages' : value })
112
+ self .write ({'enabled_heat_stages' : value }, 'stages' )
112
113
113
114
def set_enabled_cool_stages (self , value ):
114
- self .write ({'enabled_cool_stages' : value })
115
+ self .write ({'enabled_cool_stages' : value }, 'stages' )
115
116
0 commit comments