# monitor.py  27/09/2015  D.J.Whale
#
# Monitor settings of Energine MiHome plugs

import time
import pprint
from energenie import OpenHEMS, radio

def trace(msg):
    print(str(msg))


#----- TIMER ------------------------------------------------------------------

class Timer():
    def __init__(self, ratesec=1):
        self.rate = ratesec
        self.nexttick = time.time()


    def check(self):
        """Maintain the timer and see if it is time for the next tick"""
        now = time.time()

        if now >= self.nexttick:
            # asynchronous tick, might drift, but won't stack up if late
            self.nexttick = now + self.rate
            return True

        return False


#----- TEST APPLICATION -------------------------------------------------------

class ENERGENIE():
    MFRID                            = 0x04
    PRODUCTID_C1_MONITOR             = 0x01
    PRODUCTID_R1_MONITOR_AND_CONTROL = 0x02
    CRYPT_PID                        = 242
    CRYPT_PIP                        = 0x0100


MONITOR_MESSAGE = {
    "header": {
        "mfrid":       ENERGENIE.MFRID,
        "productid":   ENERGENIE.PRODUCTID_C1_MONITOR,
        "encryptPIP":  ENERGENIE.CRYPT_PIP,
        "sensorid":    0xFFFFFF # energenie broadcast
    },
    "recs": [
        {
            "wr":      True, # monitor only will ignore this
            "paramid": OpenHEMS.PARAM_SWITCH_STATE,
            "typeid":  OpenHEMS.Value.UINT,
            "length":  1,
            "value":   0
        }
    ]
}


def showMessage(msg):
    """Show the message in a friendly format"""
    #pprint.pprint(msg)

    # HEADER
    header    = msg["header"]
    mfrid     = header["mfrid"]
    productid = header["productid"]
    sensorid  = header["sensorid"]
    print("mfrid:%s prodid:%s sensorid:%s" % (hex(mfrid), hex(productid), hex(sensorid)))

    # RECORDS
    for rec in msg["recs"]:
        wr        = rec["wr"]
        if wr == True:
            write = "write"
        else:
            write = "read "

        paramid   = rec["paramid"]
        paramname = rec["paramname"]
        paramunit = rec["paramunit"]
        value     = rec["value"]
        print("%s %s %s = %s" % (write, paramname, paramunit, str(value)))


def monitor():
    """Send monitor poke messages and capture any responses"""

    sendMonitorTimer = Timer(9)   # every 9 secs
    #pollReceiveTimer = Timer(0.1) # 10 times per sec
    radio.receiver()

    while True:
        # See if there is a payload, and if there is, process it
        #if pollReceiveTimer.check():
        if radio.isReceiveWaiting():
            trace("receiving payload")
            payload = radio.receive()
            decoded = OpenHEMS.decode(payload)
            showMessage(decoded)

        # If it is time to send a monitor message, send it
        if sendMonitorTimer.check():
            trace("sending monitor message")
            payload = OpenHEMS.encode(MONITOR_MESSAGE)
            radio.transmitter()
            radio.transmit(payload)
            radio.receiver() # Keep in receiver mode as much as possible


if __name__ == "__main__":

    radio.init()
    OpenHEMS.init(ENERGENIE.CRYPT_PID)

    try:
        monitor()

    finally:
        radio.finished()

# END