Psion-fanatic/platypush
1
0
Fork 0
forked from platypush/platypush
Code Pull requests Activity

Revert "Support for custom timeout on MQTT message publish" (already implemented in the current logic)

Browse source
This commit is contained in:
Fabio Manganiello 2021-05-13 21:49:01 +02:00
parent eac26b9b22
commit 8f6404d0b1
2 changed files with 2 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
CHANGELOG.md
View file

@ -21,11 +21,6 @@ Given the high speed of development in the first phase, changes are being report
- `switch.switchbot` plugin renamed to `switchbot.bluetooth` plugin, while the new plugin - `switch.switchbot` plugin renamed to `switchbot.bluetooth` plugin, while the new plugin
that uses the Switchbot API is simply named `switchbot`. that uses the Switchbot API is simply named `switchbot`.
### Fixed
- Added new sleep and heart rate read permissions/scopes to the Google Fit integration required
by the new Fit's policies.
## [0.21.0] - 2021-05-06 ## [0.21.0] - 2021-05-06
### Added ### Added

4
platypush/plugins/zwave/mqtt.py
View file

@ -46,7 +46,7 @@ class ZwaveMqttPlugin(MqttPlugin, ZwaveBasePlugin):
""" """
def __init__(self, name: str, host: str = 'localhost', port: int = 1883, topic_prefix: str = 'zwave', def __init__(self, name: str, host: str = 'localhost', port: int = 1883, topic_prefix: str = 'zwave',
timeout: int = 60, tls_certfile: Optional[str] = None, tls_keyfile: Optional[str] = None, timeout: int = 10, tls_certfile: Optional[str] = None, tls_keyfile: Optional[str] = None,
tls_version: Optional[str] = None, tls_ciphers: Optional[str] = None, username: Optional[str] = None, tls_version: Optional[str] = None, tls_ciphers: Optional[str] = None, username: Optional[str] = None,
password: Optional[str] = None, **kwargs): password: Optional[str] = None, **kwargs):
""" """
@ -125,7 +125,7 @@ class ZwaveMqttPlugin(MqttPlugin, ZwaveBasePlugin):
payload = json.dumps({'args': args}) payload = json.dumps({'args': args})
ret = self._parse_response( ret = self._parse_response(
self.publish(topic=self._api_topic(api) + '/set', msg=payload, reply_topic=self._api_topic(api), self.publish(topic=self._api_topic(api) + '/set', msg=payload, reply_topic=self._api_topic(api),
**self._mqtt_args(**kwargs), timeout=self.timeout)) **self._mqtt_args(**kwargs)))
assert not ret or ret.get('success') is True, ret.get('message') assert not ret or ret.get('success') is True, ret.get('message')
return ret.get('result') return ret.get('result')