backend.when_sensor

Complexity

Total Complexity

4

Size/Duplication

Total Lines	25
Duplicated Lines	0 %

Importance

Changes

0

3 Functions

Rating	Name	Duplication	Size	Complexity
A	dosensor()	0	3	1
A	when_sensor()	0	8	2
A	main()	0	2	1

'''what to do when a sensor reading is broadcast'''
from helpers.queuehelper import QueueName
from backend.fcmapp import Component

SENSOR = Component('fullcycle')

def when_sensor(channel, method, properties, body):
    '''when there is a sensor reading'''
    try:
        print("[{0}] Received sensor reading".format(SENSOR.app.now()))
        message, sensorvalue = SENSOR.app.messagedecodesensor(body)
        dosensor(message, sensorvalue)
    except Exception as ex:
        SENSOR.app.logexception(ex)

def dosensor(message, sensorvalue):
    '''put the sensor in cache'''
    SENSOR.app.sensors.addknownsensor(sensorvalue)

def main():
    SENSOR.listeningqueue = SENSOR.app.listen_to_broadcast(QueueName.Q_SENSOR, when_sensor)

if __name__ == "__main__":
    main()