mirror of
https://github.com/ElvishArtisan/rivendell.git
synced 2025-04-24 17:37:53 +02:00
211 lines
7.3 KiB
Python
Executable File
211 lines
7.3 KiB
Python
Executable File
#!%PYTHON_BANGPATH%
|
|
|
|
# pypad_xcmd.py
|
|
#
|
|
# Send Now & Next updates to an RDS encoder supporting X-Command
|
|
#
|
|
# (C) Copyright 2019 Fred Gleason <fredg@paravelsystems.com>
|
|
#
|
|
# This program is free software; you can redistribute it and/or modify
|
|
# it under the terms of the GNU General Public License version 2 as
|
|
# published by the Free Software Foundation.
|
|
#
|
|
# This program is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU General Public
|
|
# License along with this program; if not, write to the Free Software
|
|
# Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
|
|
#
|
|
|
|
import os
|
|
import sys
|
|
import syslog
|
|
import socket
|
|
import configparser
|
|
import serial
|
|
import xml.etree.ElementTree as ET
|
|
import time
|
|
import pypad
|
|
|
|
|
|
def eprint(*args,**kwargs):
|
|
print(pypad_name+': ',file=sys.stderr,end='')
|
|
print(*args,file=sys.stderr)
|
|
syslog.syslog(syslog.LOG_ERR,*args)
|
|
|
|
def iprint(*args,**kwargs):
|
|
print(pypad_name+': ',file=sys.stdout,end='')
|
|
print(*args,file=sys.stdout)
|
|
syslog.syslog(syslog.LOG_INFO,*args)
|
|
|
|
def dprint(*args,**kwargs):
|
|
print(pypad_name+': ',file=sys.stdout,end='')
|
|
print(*args,file=sys.stdout)
|
|
syslog.syslog(syslog.LOG_DEBUG,*args)
|
|
|
|
def XcmdResponse():
|
|
resp_code={b'+':'Command processed successfully',b'!':'Unknown command',b'-':'Invalid argument',b'/':'Command processed partially'}
|
|
|
|
while(True):
|
|
try:
|
|
response=send_sock.recv(1)
|
|
if response==b'+': return True,response.decode('utf-8'),resp_code[response]
|
|
if response==b'!': return True,response.decode('utf-8'),resp_code[response]
|
|
if response==b'-': return True,response.decode('utf-8'),resp_code[response]
|
|
if response==b'/': return True,response.decode('utf-8'),resp_code[response]
|
|
|
|
except:
|
|
return False,'','Exception'
|
|
|
|
def ProcessPad(update):
|
|
n=1
|
|
while(True):
|
|
section='XCmd'+str(n)
|
|
try:
|
|
rds=ET.Element('rds')
|
|
item=ET.SubElement(rds,'item')
|
|
|
|
# Set destination code
|
|
dest=ET.SubElement(item,'dest')
|
|
try:
|
|
dest.text=update.config().get(section,'DestCode')
|
|
|
|
except configparser.NoOptionError:
|
|
dest.text='7'
|
|
|
|
if update.shouldBeProcessed(section) and update.hasPadType(pypad.TYPE_NOW):
|
|
radiotext=update.config().get(section,'RadioText')
|
|
|
|
# Use pypad string in USER_DEFINED field if available
|
|
try:
|
|
prefix=update.config().get(section,'UserDefinedPrefix').lower()
|
|
i=update.padField(pypad.TYPE_NOW,pypad.FIELD_USER_DEFINED).lower().find(prefix)
|
|
if i>-1:
|
|
radiotext=update.padField(pypad.TYPE_NOW,pypad.FIELD_USER_DEFINED)[i+len(prefix):].strip()
|
|
|
|
except configparser.NoOptionError:
|
|
pass
|
|
|
|
radiotext=radiotext.replace('%a','<artist>%a</artist>')
|
|
radiotext=radiotext.replace('%t','<title>%t</title>')
|
|
radiotext=radiotext.replace('%l','<album>%l</album>')
|
|
|
|
radiotext=update.resolvePadFields(radiotext,pypad.ESCAPE_NONE)
|
|
else:
|
|
try:
|
|
radiotext=update.config().get(section,'DefaultText')
|
|
|
|
except configparser.NoOptionError:
|
|
radiotext=''
|
|
|
|
if '%1' in radiotext:
|
|
if update.config().get(section,'StationNameShort'):
|
|
radiotext=radiotext.replace('%1','<short>'+update.config().get(section,'StationNameShort')+'</short>')
|
|
|
|
if '%2' in radiotext:
|
|
if update.config().get(section,'StationNameLong'):
|
|
radiotext=radiotext.replace('%2','<long>'+update.config().get(section,'StationNameLong')+'</long>')
|
|
|
|
if '%3' in radiotext:
|
|
if update.config().get(section,'URL'):
|
|
radiotext=radiotext.replace('%3','<page>'+update.config().get(section,'URL')+'</page>')
|
|
|
|
if '%4' in radiotext:
|
|
if update.config().get(section,'Phone'):
|
|
radiotext=radiotext.replace('%4','<phone>'+update.config().get(section,'Phone')+'</phone>')
|
|
|
|
if '%5' in radiotext:
|
|
if update.config().get(section,'SMS'):
|
|
radiotext=radiotext.replace('%5','<sms>'+update.config().get(section,'SMS')+'</sms>')
|
|
|
|
if '%6' in radiotext:
|
|
if update.config().get(section,'Email'):
|
|
radiotext=radiotext.replace('%6','<email>'+update.config().get(section,'Email')+'</email>')
|
|
|
|
text=ET.SubElement(item,'text')
|
|
text.text=radiotext
|
|
|
|
xcmd=b'XCMD='+ET.tostring(rds)+b"\r"
|
|
xcmd=xcmd.replace(b'<',b'<')
|
|
xcmd=xcmd.replace(b'>',b'>')
|
|
xcmd=xcmd.replace(b'&',b'&')
|
|
|
|
try:
|
|
#
|
|
# Use serial output
|
|
#
|
|
tty_dev=update.config().get(section,'Device')
|
|
speed=int(update.config().get(section,'Speed'))
|
|
parity=serial.PARITY_NONE
|
|
if int(update.config().get(section,'Parity'))==1:
|
|
parity=serial.PARITY_EVEN
|
|
if int(update.config().get(section,'Parity'))==2:
|
|
parity=serial.PARITY_ODD
|
|
bytesize=int(update.config().get(section,'WordSize'))
|
|
dev=serial.Serial(tty_dev,speed,parity=parity,bytesize=bytesize)
|
|
dev.write(xcmd.decode('utf-8'))
|
|
dev.close()
|
|
|
|
except configparser.NoOptionError:
|
|
#
|
|
# Create Send TCP Socket
|
|
#
|
|
send_sock=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
|
|
send_sock.settimeout(5)
|
|
|
|
encoder=(update.config().get(section,'IpAddress'),int(update.config().get(section,'TcpPort')))
|
|
iprint('Connecting to {}:{}'.format(*encoder))
|
|
iprint(xcmd.decode('utf-8'))
|
|
|
|
try:
|
|
send_sock.connect(encoder)
|
|
send_sock.sendall(xcmd)
|
|
ack,response,respstr=XcmdResponse()
|
|
if response:
|
|
iprint(respstr)
|
|
|
|
except OSError as e:
|
|
eprint("Socket error: {0}".format(e))
|
|
|
|
except IOError as e:
|
|
errno,strerror=e.args
|
|
eprint("I/O error({0}): {1}".format(errno,strerror))
|
|
|
|
iprint('Closing connection')
|
|
send_sock.close()
|
|
|
|
# Give the device time to process and close before sending another command
|
|
time.sleep(1)
|
|
|
|
n=n+1
|
|
except configparser.NoSectionError:
|
|
return
|
|
|
|
#
|
|
# 'Main' function
|
|
#
|
|
|
|
#
|
|
# Program Name
|
|
#
|
|
pypad_name=os.path.basename(__file__)
|
|
|
|
#
|
|
# Open Syslog
|
|
#
|
|
syslog.openlog(pypad_name,logoption=syslog.LOG_PID,facility=syslog.LOG_DAEMON)
|
|
|
|
rcvr=pypad.Receiver()
|
|
try:
|
|
rcvr.setConfigFile(sys.argv[3])
|
|
except IndexError:
|
|
eprint('pypad_xcmd.py: USAGE: cmd <hostname> <port> <config>')
|
|
sys.exit(1)
|
|
rcvr.setPadCallback(ProcessPad)
|
|
iprint('Started')
|
|
rcvr.start(sys.argv[1],int(sys.argv[2]))
|
|
iprint('Stopped')
|