kai/pounder_test
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Updating miniconf to use updated API

Browse Source
This commit is contained in:
Ryan Summers 2021-04-29 12:11:35 +02:00
parent 7ddf2271f3
commit 5499fc6b47
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
miniconf.py
View File

@ -9,6 +9,7 @@ import argparse
import asyncio import asyncio
import json import json
import logging import logging
import sys
from gmqtt import Client as MqttClient from gmqtt import Client as MqttClient
@ -51,7 +52,8 @@ class Miniconf:
logger.warning('Unexpected response on topic: %s', topic) logger.warning('Unexpected response on topic: %s', topic)
return return
self.inflight[topic].set_result(payload.decode('ascii')) response = json.loads(payload)
self.inflight[topic].set_result((response['code'], response['msg']))
del self.inflight[topic] del self.inflight[topic]
async def command(self, path, value): async def command(self, path, value):
@ -62,7 +64,8 @@ class Miniconf:
value: The value to write to the path. value: The value to write to the path.
Returns: Returns:
The received response to the command. (code, msg) tuple as a response to the command. `code` is zero for success and `msg` is
a use-readable message indicating further information.
""" """
setting_topic = f'{self.prefix}/settings/{path}' setting_topic = f'{self.prefix}/settings/{path}'
response_topic = f'{self.prefix}/response/{path}' response_topic = f'{self.prefix}/response/{path}'
@ -107,12 +110,17 @@ def main():
async def configure_settings(): async def configure_settings():
interface = await Miniconf.create(args.prefix, args.broker) interface = await Miniconf.create(args.prefix, args.broker)
failures = 0
for kv in args.settings: for kv in args.settings:
path, value = kv.split("=", 1) path, value = kv.split("=", 1)
response = await interface.command(path, json.loads(value)) code, response = await interface.command(path, json.loads(value))
print(response) if code != 0:
failures += 1
logging.warning('%s update failed!', path)
loop.run_until_complete(configure_settings()) return failures
sys.exit(loop.run_until_complete(configure_settings()))
if __name__ == '__main__': if __name__ == '__main__':