backend.when_monitor

Complexity

Total Complexity

9

Size/Duplication

Total Lines	42
Duplicated Lines	0 %

Importance

Changes

0

3 Functions

Rating	Name	Duplication	Size	Complexity
A	main()	0	7	3
A	when_monitor()	0	8	2
A	domonitor()	0	14	4

'''David Foderick, Skylake Software Inc.
'''
from helpers.queuehelper import QueueName, QueueEntries
from backend.fcmapp import Component

MONITOR = Component('monitor')

def when_monitor(channel, method, properties, body):
    '''when its time to monitor all the machines on schedule'''
    try:
        print("[{0}] Received monitor command".format(MONITOR.app.now()))
        entries = domonitor()
        MONITOR.app.enqueue(entries)
    except Exception as ex:
        MONITOR.app.logexception(ex)

def domonitor():
    '''queue workers to run the individual miner monitoring'''
    entries = QueueEntries()
    try:
        miners = MONITOR.app.allminers()
        print("{0} miners configured".format(len(miners)))

        for miner in miners:
            if not miner.is_manually_disabled():
                entries.add(QueueName.Q_MONITORMINER, MONITOR.app.messageencode(miner))
        print("waiting for next monitor event")
    except Exception as theex:
        MONITOR.app.logexception(theex)
    return entries

def main():
    if MONITOR.app.isrunnow or MONITOR.app.isdebug:
        domonitor()
        MONITOR.app.shutdown()
    else:
        MONITOR.listeningqueue = MONITOR.app.subscribe(QueueName.Q_MONITOR, when_monitor)
        MONITOR.app.listen(MONITOR.listeningqueue)

if __name__ == "__main__":
    main()