pommi/python-itho-wpu
1
0
Fork 0
mirror of https://github.com/pommi/python-itho-wpu.git synced 2024-11-21 13:52:15 +01:00
Code Releases Activity

chore(itho-wpu): rename wpu.get -> wpu.call

Browse Source
This commit is contained in:
Pim van den Berg 2023-09-10 18:53:32 +02:00
parent a11df838f8
commit f0c350971f
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
itho-wpu.py
View File

@ -92,13 +92,13 @@ class IthoWPU:
self._q = queue.Queue() self._q = queue.Queue()
self.no_cache = no_cache self.no_cache = no_cache
self.cache = IthoWPUCache() self.cache = IthoWPUCache()
self.nodeid = self.get("getnodeid") self.nodeid = self.call("getnodeid")
self.datatype = self.get("getdatatype") self.datatype = self.call("getdatatype")
self.heatpump_db = db.sqlite("heatpump.sqlite") self.heatpump_db = db.sqlite("heatpump.sqlite")
def get(self, action, identifier=None, datatype=None, value=None, check=True): def call(self, action, identifier=None, datatype=None, value=None, check=True):
if not self.no_cache: if not self.no_cache:
response = self.cache.get(action.replace("get", "")) response = self.cache.call(action.replace("get", ""))
if response is not None: if response is not None:
logger.debug(f"Response (from cache): {response}") logger.debug(f"Response (from cache): {response}")
return response return response
@ -245,7 +245,7 @@ class IthoWPUCache:
logger.debug(f"Writing to local cache: {json.dumps(self._cache_data)}") logger.debug(f"Writing to local cache: {json.dumps(self._cache_data)}")
json.dump(self._cache_data, cache_file) json.dump(self._cache_data, cache_file)
def get(self, action): def call(self, action):
if action not in ["nodeid", "serial", "datatype"]: if action not in ["nodeid", "serial", "datatype"]:
logger.debug(f"Cache for '{action}' is not supported") logger.debug(f"Cache for '{action}' is not supported")
return None return None
@ -388,14 +388,14 @@ def process_setting(response, wpu):
def process_settings(wpu, args): def process_settings(wpu, args):
settings = wpu.get_settings() settings = wpu.get_settings()
for setting in settings: for setting in settings:
response = wpu.get("getsetting", int(setting["id"])) response = wpu.call("getsetting", int(setting["id"]))
if response is not None: if response is not None:
process_response("getsetting", response, args, wpu) process_response("getsetting", response, args, wpu)
def process_setsetting(wpu, args): def process_setsetting(wpu, args):
logger.info("Current setting:") logger.info("Current setting:")
response = wpu.get("getsetting", int(args.id)) response = wpu.call("getsetting", int(args.id))
if response is None: if response is None:
return return
process_response("getsetting", response, args, wpu) process_response("getsetting", response, args, wpu)
@ -433,7 +433,7 @@ def process_setsetting(wpu, args):
logger.error("Aborted") logger.error("Aborted")
return return
response = wpu.get("setsetting", args.id, None, normalized_value) response = wpu.call("setsetting", args.id, None, normalized_value)
if response is None: if response is None:
return return
process_response("getsetting", response, args, wpu) process_response("getsetting", response, args, wpu)
@ -463,7 +463,7 @@ def process_manual(response, wpu):
def process_setmanual(wpu, args): def process_setmanual(wpu, args):
logger.info("Current manual operation:") logger.info("Current manual operation:")
response = wpu.get("getmanual", int(args.id)) response = wpu.call("getmanual", int(args.id))
if response is None: if response is None:
return return
process_response("getmanual", response, args, wpu) process_response("getmanual", response, args, wpu)
@ -498,7 +498,7 @@ def process_setmanual(wpu, args):
logger.error("Aborted") logger.error("Aborted")
return return
response = wpu.get("setmanual", args.id, int(datatype, 0), normalized_value, args.check) response = wpu.call("setmanual", args.id, int(datatype, 0), normalized_value, args.check)
def format_datatype(name, m, dt): def format_datatype(name, m, dt):
@ -599,7 +599,7 @@ def main():
process_setmanual(wpu, args) process_setmanual(wpu, args)
return return
response = wpu.get(args.action, args.id) response = wpu.call(args.action, args.id)
if response is not None: if response is not None:
process_response(args.action, response, args, wpu) process_response(args.action, response, args, wpu)