[cli][supervise] added the *supervise* functions to insert data to supervisor

pyheatpump/cli.py

@@ -7,6 +7,10 @@ import sys
 import re
 import importlib
 from pprint import pprint
+import urllib
+import requests
+import json
+from datetime import datetime
 
 from pyheatpump.logger import logger_init
 from pyheatpump.models import *
@@ -129,3 +133,70 @@ def fetch():
 
     commit()
     logger.info('Successfully read all variables')
+
+
+@click.option('--since', is_flag=True)
+@cli.command()
+def supervise(since):
+    logger = logger_init()
+
+    from .config import config
+    from .models.heatpump import Heatpump
+
+    last_update = None
+    if since:
+        last_update = int(datetime.now().strftime('%s')) - config.getint('supervisor', 'interval')
+
+    h = Heatpump(config.get('heatpump','mac_address'), last_update)
+
+    base_url = {
+        'scheme':config.get('supervisor', 'scheme'),
+        'hostname':config.get('supervisor', 'host'),
+        'port':config.getint('supervisor', 'port')
+    }
+
+    build_url = lambda d: '{scheme}://{hostname}:{port}{path}'.format(**d)
+
+    if base_url['scheme'] == 'https':
+        certificate = config.get('supervisor', 'certificate')
+        if not os.path.isfile(certificate):
+            raise Exception(f'Certificate not found :{certificate}') 
+        print(certificate)
+    else:
+        certificate = None
+
+    post_url = {
+        **base_url,
+        **{'path': config.get('supervisor', 'post_path')}
+    }
+
+    logger.info(build_url(post_url))
+    try:
+        json.dumps(h.__dict__())
+    except Exception as e:
+        print(e)
+        sys.exit(1)
+
+    logger.debug(h.__dict__())
+
+    post_req = requests.post(
+        url=build_url(post_url),
+        json=h.__dict__(),
+        verify=False
+    )
+    if post_req.status_code == 200:
+        logger.info('POST to supervisor succeeded')
+
+    get_path = '/'.join((
+        config.get('supervisor', 'get_path'),
+        h.macformat
+    ))
+    get_url = {
+        **base_url,
+        **{'path': get_path}
+    }
+
+    get_req = requests.get(
+        url=build_url(get_url),
+        verify=False
+    )