def customCallback()

in src/iot/subscribe.py [0:0]


def customCallback(deprecated_0, deprecated_1, message):
    payload_dict = json.loads(message.payload)

    alarm_ID = payload_dict['alarm_ID']
    camera_ID = payload_dict['camera_ID']

    if alarm_ID == CLIENT_ID:
        logger.info('Alert: worker without PPE caught on %s', camera_ID)
        play_controlled_alarm()
    else:
        logger.debug('Alert: worker without PPE caught on %s', camera_ID)