publish.py

import ujson
from utime import time
from loadconf import CONFIG, FUSED_VALUES
import topics as tp


def publish_alarm(mess):
    CONFIG.client.publish(tp.get_alarm_topic(CONFIG.client_id), mess, True)
    CONFIG.set_curr_datetime()
    CONFIG.client.publish(tp.get_alarm_datetime_topic(CONFIG.client_id, mess), CONFIG.curr_datetime, True)
    if CONFIG.debug:
        print("{} published: {} at {}".format(tp.get_alarm_topic(CONFIG.client_id, ), mess, CONFIG.curr_datetime))


def publish_state_fused(nch_a, nch_c):
    CONFIG.set_curr_datetime()
    for nch in (nch_a, nch_c):
        topic = tp.get_state_topic(CONFIG.client_id, nch)
        mess = b"on" if CONFIG.info[FUSED_VALUES][nch] else b"off"
        CONFIG.client.publish(topic, mess, False)
        topic = tp.get_datetime_topic(CONFIG.client_id, nch, mess)
        CONFIG.client.publish(topic, CONFIG.curr_datetime, True)
        if CONFIG.debug:
            print("Channel {} published: {} at {}".format(nch, mess, CONFIG.curr_datetime))


def publish_state(nr):
    topic = tp.get_state_topic(CONFIG.client_id, nr)
    if nr <= 2:
        pin_val = CONFIG.info['sensor_pin{}'.format(nr)].value()  # cover and lock - sensor's value
    else:
        pin_val = CONFIG.info['relay_pin{}'.format(nr)].value()
    #
    mess = b"on" if pin_val else b"off"
    # start at
    if pin_val and nr > 2:
        CONFIG.info['at'] = time()
    #
    CONFIG.client.publish(topic, mess, True)
    topic = tp.get_datetime_topic(CONFIG.client_id, nr, mess)
    CONFIG.set_curr_datetime()
    CONFIG.client.publish(topic, CONFIG.curr_datetime, True)

    if CONFIG.debug:
        print("Channel {} pin_val = {} published: {} at {}".format(nr, str(pin_val), mess, CONFIG.curr_datetime))


def publish_debug_state():
    topic = tp.get_debug_state_topic(CONFIG.client_id)
    mess = b"on" if CONFIG.debug else b"off"
    CONFIG.client.publish(topic, mess, False)


def publish_config():
    topic = tp.get_info_topic(CONFIG.client_id)
    if CONFIG.debug:
        ls_mess = {'info': CONFIG.info, 'sensor_value': CONFIG.sensor_value, 'sensor_count': CONFIG.sensor_count}
        mess = ujson.dumps(ls_mess).encode('ascii')
        print(mess)
    else:
        mess = b''
        CONFIG.client.publish(topic, mess, True)


def publish_debug_info(gc):
    if CONFIG.debug:
        import stats_api
        a = stats_api.Handler()
        res = a.get()
    else:
        res = {'gc': {'mem_alloc': gc.mem_alloc(), 'mem_free': gc.mem_free()}}
    CONFIG.set_curr_datetime()
    res['datetime'] = CONFIG.curr_datetime
    res = ujson.dumps(res).encode('ascii')
    topic = tp.get_sensor_memory_topic(CONFIG.client_id)
    print("info: {}".format(res))
    CONFIG.client.publish(topic, res, True)


def publish_sensor_alarm(current_value, nr):
    res = b"ALARM" if current_value == 1 else b"OK"
    topic = tp.get_sensor_alarm_topic(CONFIG.client_id, nr)
    CONFIG.client.publish(topic, res, True)  # publish alarm sensor state
    topic = tp.get_sensor_alarm_datetime_topic(CONFIG.client_id, nr, res)
    CONFIG.set_curr_datetime()
    CONFIG.client.publish(topic, CONFIG.curr_datetime, True)  # publish alarm or ok sensor datetime state
    if CONFIG.debug:
        print("sa{}: {} at {}".format(nr, res, CONFIG.curr_datetime))