Autres/Rivendellaudio
1
0
Fork 0
mirror of https://github.com/ElvishArtisan/rivendell.git synced 2025-11-26 15:20:29 +01:00
Code Issues Projects Releases Wiki Activity

2021-08-26 Fred Gleason <fredg@paravelsystems.com>

Browse Source 
* Added support for [NowGroups] and [NextGroups] sections in
	PyPAD script configurations.

Signed-off-by: Fred Gleason <fredg@paraelsystems.com>
This commit is contained in:
Fred Gleason
2021-08-26 15:02:10 -04:00
parent 11687ddbbb
commit ad7a755ba7
22 changed files with 445 additions and 569 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
apis/pypad/api/pypad.py
View File

@@ -772,6 +772,8 @@ class Receiver(object):
self.__timer_callback=None
self.__timer_interval=None
self.__config_parser=None
self.__active_now_groups=[]
self.__active_next_groups=[]
def __pypad_Process(self,pad):
self.__pad_callback(pad)
@@ -850,9 +852,26 @@ class Receiver(object):
self.__config_parser.read_file(fp)
fp.close()
# Build lists of active groups
if self.__config_parser.has_section('NowGroups'):
self.__active_now_groups=self.__loadGroups('NowGroups')
if self.__config_parser.has_section('NextGroups'):
self.__active_next_groups=self.__loadGroups('NextGroups')
return self.__config_parser
def __loadGroups(self,section):
grp_list=[]
grp_num=1
line='Group'+str(grp_num)
while(self.__config_parser.has_option(section,line)):
grp_list.append(self.__config_parser.get(section,line))
grp_num=grp_num+1
line='Group'+str(grp_num)
return grp_list
def start(self,hostname,port):
"""
Connect to a Rivendell system and begin processing PAD events.
@@ -906,12 +925,13 @@ class Receiver(object):
linebytes=line.decode('utf-8','replace')
msg+=linebytes
if linebytes=='\r\n':
self.__pypad_Process(Update(json.loads(msg),self.__config_parser,rd_config))
jdata=json.loads(msg)
if (not self.__active_now_groups and not self.__active_next_groups) or (jdata['padUpdate'] is not None and jdata['padUpdate']['now'] is not None and jdata['padUpdate']['now']['groupName'] in self.__active_now_groups) or (jdata['padUpdate'] is not None and jdata['padUpdate']['next'] is not None and jdata['padUpdate']['next']['groupName'] in self.__active_next_groups):
self.__pypad_Process(Update(jdata,self.__config_parser,rd_config))
msg=""
line=bytes()
if self.__timer_interval!=None:
timeout=(deadline-datetime.datetime.now()).total_seconds()
def SigHandler(signo,stack):
sys.exit(0)