eswyft/homekit
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

pio, mqtt: multiple fixes

Browse Source
This commit is contained in:
Evgeny Zinoviev 2023-10-05 01:36:24 +03:00
parent 69adc549d3
commit 17b4476467
6 changed files with 17 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
include/pio/libs/mqtt/homekit/mqtt/mqtt.cpp
View File

@ -119,7 +119,7 @@ void Mqtt::reconnect() {
void Mqtt::disconnect() {
// TODO test how this works???
reconnectTimer.detach();
client.disconnect();
client.disconnect(true);
}
void Mqtt::loop() {

2
include/pio/libs/mqtt/library.json
View File

@ -1,6 +1,6 @@
{
"name": "homekit_mqtt",
"version": "1.0.11",
"version": "1.0.12",
"build": {
"flags": "-I../../include"
}

2
include/pio/libs/temphum/library.json
View File

@ -1,6 +1,6 @@
{
"name": "homekit_temphum",
"version": "1.0.3",
"version": "1.0.4",
"build": {
"flags": "-I../../include"
}

7
include/py/homekit/mqtt/_config.py
View File

@ -109,7 +109,12 @@ class MqttNodesConfig(ConfigUnit):
'legacy_topics': {'type': 'boolean'}
}
},
'password': {'type': 'string'}
'password': {'type': 'string'},
'defines': {
'type': 'dict',
'keysrules': {'type': 'string'},
'valuesrules': {'type': ['string', 'integer']}
}
}
}
}

2
include/py/homekit/mqtt/module/ota.py
View File

@ -74,4 +74,4 @@ class MqttOtaModule(MqttModule):
if not self._initialized:
self._ota_request = (filename, qos)
else:
self.do_push_ota(filename, qos)
self.do_push_ota(self._mqtt_node_ref.secret, filename, qos)

7
include/py/homekit/pio/products.py
View File

@ -41,6 +41,11 @@ def platformio_ini(product_config: dict,
if node_id not in MqttNodesConfig().get_nodes().keys():
raise ValueError(f'node id "{node_id}" is not specified in the config!')
try:
node_defines = MqttNodesConfig().get_node(node_id)['defines']
except KeyError:
node_defines = None
# defines
defines = {
**product_config['common_defines'],
@ -66,6 +71,8 @@ def platformio_ini(product_config: dict,
if build_specific_defines:
for k, v in build_specific_defines.items():
defines[k] = v
if node_defines:
defines = {**defines, **node_defines}
defines = OrderedDict(sorted(defines.items(), key=lambda t: t[0]))
# libs