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

cli: do the json roundtrip for api usability

This commit is contained in:
Robert Jördens 2021-03-02 20:24:45 +01:00
parent ca6596c7b8
commit 4652dd4311
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
miniconf.py
View File

@ -7,6 +7,7 @@ Description: Provides an API for controlling Miniconf devices over MQTT.
""" """
import argparse import argparse
import asyncio import asyncio
import json
import logging import logging
from gmqtt import Client as MqttClient from gmqtt import Client as MqttClient
@ -70,6 +71,7 @@ class Miniconf:
raise NotImplementedError( raise NotImplementedError(
'Only one in-flight message per topic is supported') 'Only one in-flight message per topic is supported')
value = json.dumps(value)
logger.debug('Sending %s to "%s"', value, setting_topic) logger.debug('Sending %s to "%s"', value, setting_topic)
fut = asyncio.get_running_loop().create_future() fut = asyncio.get_running_loop().create_future()
self.inflight[response_topic] = fut self.inflight[response_topic] = fut
@ -98,14 +100,14 @@ def main():
args = parser.parse_args() args = parser.parse_args()
logging.basicConfig( logging.basicConfig(
format='%(asctime)s [%(levelname)s] %(message)s', format='%(asctime)s [%(levelname)s] %(name)s: %(message)s',
level=logging.WARN - 10*args.verbose) level=logging.WARN - 10*args.verbose)
loop = asyncio.get_event_loop() loop = asyncio.get_event_loop()
async def configure_settings(): async def configure_settings():
interface = await Miniconf.create(args.prefix, args.broker) interface = await Miniconf.create(args.prefix, args.broker)
response = await interface.command(args.path, args.value) response = await interface.command(args.path, json.loads(args.value))
logger.info(response) logger.info(response)
loop.run_until_complete(configure_settings()) loop.run_until_complete(configure_settings())