BOSWatch/includes/multicastAlarm.py

#!/usr/bin/python
# -*- coding: utf-8 -*-

"""
multicastAlarm is the function to enable BOSwatch to work in networks that optimise the transmission of POCSAG telegrams

@author: Fabian Kessler

@requires: Configuration has to be set in the config.ini
"""

import logging # Global logger
import time    # timestamp for multicastAlarm

from includes import globalVars  # Global variables

multiList = []

def newEntrymultiList(data):
	"""
	add entry to multi alarm list and remove old entries

	@return:    nothing
	"""
	global multiList
	tmpmultiList = []
	timestamp = int(time.time())
	# multicastAlarm processing if enabled and delimiter RIC has been received
	if data['ric'] == globalVars.config.get("multicastAlarm", "multicastAlarm_delimiter_ric"):
		multiList = []
		logging.debug("multicastAlarm delimiter RIC received --> buffer cleared")
	else:
		multiList.append([typ, data['ric'], data['function'], data['functionChar'], data['msg'].strip(), data['description'], timestamp])
		logging.debug("Added %s to multiList", data['ric'])
		# check for old entries in multiList
		for i, _ in enumerate(multiList):
			# we have to remove entries older than timestamp - ignore time
			if int(multiList[i][6]) > timestamp-globalVars.config.getint("multicastAlarm", "multicastAlarm_ignore_time"):
				tmpmultiList.append(multiList[i])
	multiList = tmpmultiList


def multicastAlarmExec(typ, freq, data):
	"""
	call alarmHandler for every entry in multiList

	@return:    nothing
	"""
	logging.debug("data before update from multiList: %s", data)
	for i, _ in enumerate(multiList):
		#update data with values multiList
		data['ric'] =  multiList[i][1]
		data['function'] = multiList[i][2]
		data['functionChar'] = multiList[i][3]
		data['description'] = multiList[i][5]
		logging.debug("data after update from multiList: %s", data)
		try:
			from includes import alarmHandler
			alarmHandler.processAlarmHandler(typ, freq, data)
		except:
			logging.error("processing alarm failed")
			logging.debug("processing alarm failed", exc_info=True)