mirror of
https://github.com/ElvishArtisan/rivendell.git
synced 2025-11-04 08:04:12 +01:00
604 lines
15 KiB
C++
604 lines
15 KiB
C++
// local_macros.cpp
|
|
//
|
|
// Local RML Macros for rdvairplayd(8)
|
|
//
|
|
// (C) Copyright 2002-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.
|
|
//
|
|
|
|
#include <stdio.h>
|
|
#include <syslog.h>
|
|
|
|
#include <rdapplication.h>
|
|
#include <rddb.h>
|
|
#include <rdescape_string.h>
|
|
#include <rdmacro.h>
|
|
|
|
#include "rdvairplayd.h"
|
|
|
|
void MainObject::rmlReceivedData(RDMacro *rml)
|
|
{
|
|
QString logname;
|
|
int fade;
|
|
RDLogLine *logline=NULL;
|
|
int index=-1;
|
|
bool all_logs=false;
|
|
int start;
|
|
int end;
|
|
int next_line;
|
|
|
|
if(rml->role()!=RDMacro::Cmd) {
|
|
return;
|
|
}
|
|
|
|
switch(rml->command()) {
|
|
case RDMacro::LL: // Load Log
|
|
if((rml->argQuantity()<1)||(rml->argQuantity()>3)) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if((index=LogMachineIndex(rml->arg(0).toInt()))<0) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if(rml->argQuantity()==1) { // Clear Log
|
|
air_logs[index]->clear();
|
|
rda->syslog(LOG_INFO,"unloaded log machine %d",rml->arg(0).toInt());
|
|
}
|
|
else { // Load Log
|
|
logname=rml->arg(1);
|
|
if(!RDLog::exists(logname)) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
air_logs[index]->setLogName(logname);
|
|
air_logs[index]->load();
|
|
rda->syslog(LOG_INFO,"loaded log \"%s\" into log machine %d",
|
|
(const char *)logname.toUtf8(),
|
|
rml->arg(0).toInt());
|
|
}
|
|
if(rml->argQuantity()==3) { // Start Log
|
|
if(rml->arg(2).toInt()<air_logs[index]->size()) {
|
|
if(rml->arg(2).toInt()>=0) { // Unconditional start
|
|
if(air_logs[index]->play(rml->arg(2).toInt(),RDLogLine::StartMacro)) {
|
|
rda->syslog(LOG_INFO,"started log machine %d at line %d",
|
|
rml->arg(0).toInt(),rml->arg(2).toInt());
|
|
}
|
|
else {
|
|
rda->syslog(LOG_WARNING,"log machine %d failed to start",
|
|
rml->arg(0).toInt());
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
}
|
|
if(rml->arg(2).toInt()==-2) { // Start if trans type allows
|
|
// Find first non-running event
|
|
bool found=false;
|
|
for(int i=0;i<air_logs[index]->size();i++) {
|
|
if((logline=air_logs[index]->logLine(i))!=NULL) {
|
|
if(logline->status()==RDLogLine::Scheduled) {
|
|
found=true;
|
|
i=air_logs[index]->size();
|
|
}
|
|
}
|
|
}
|
|
if(found) {
|
|
switch(logline->transType()) {
|
|
case RDLogLine::Play:
|
|
case RDLogLine::Segue:
|
|
if(air_logs[index]->play(0,RDLogLine::StartMacro)) {
|
|
rda->syslog(LOG_INFO,"started log machine %d at line 0",
|
|
rml->arg(0).toInt());
|
|
}
|
|
else {
|
|
rda->syslog(LOG_WARNING,"log machine %d failed to start",
|
|
rml->arg(0).toInt());
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
break;
|
|
|
|
case RDLogLine::Stop:
|
|
case RDLogLine::NoTrans:
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(true);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
break;
|
|
|
|
case RDMacro::AL: // Append Log
|
|
if(rml->argQuantity()!=2) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if((index=LogMachineIndex(rml->arg(0).toInt()))<0) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
logname=rml->arg(1);
|
|
if(!RDLog::exists(logname)) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
air_logs[index]->append(logname);
|
|
rda->syslog(LOG_INFO,"appended log \"%s\" into log machine %d",
|
|
(const char *)logname.toUtf8(),rml->arg(0).toInt());
|
|
break;
|
|
|
|
case RDMacro::MN: // Make Next
|
|
if(rml->argQuantity()!=2) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if((index=LogMachineIndex(rml->arg(0).toInt()))<0) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if((rml->arg(1).toInt()<0)||
|
|
(rml->arg(1).toInt()>=air_logs[index]->size())) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
air_logs[index]->makeNext(rml->arg(1).toInt());
|
|
rda->syslog(LOG_INFO,"made line %d next in log machine %d",
|
|
rml->arg(1).toInt(),rml->arg(0).toInt());
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(true);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
break;
|
|
|
|
case RDMacro::PL: // Start
|
|
if(rml->argQuantity()!=2) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if((index=LogMachineIndex(rml->arg(0).toInt()))<0) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if((rml->arg(1).toInt()<0)||
|
|
(rml->arg(1).toInt()>=air_logs[index]->size())) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if(!air_logs[index]->running()) {
|
|
if(air_logs[index]->play(rml->arg(1).toInt(),RDLogLine::StartMacro)) {
|
|
rda->syslog(LOG_INFO,"started log machine %d at line %d",
|
|
rml->arg(0).toInt(),rml->arg(2).toInt());
|
|
}
|
|
else {
|
|
rda->syslog(LOG_WARNING,"log machine %d failed to start",
|
|
rml->arg(0).toInt());
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
}
|
|
rda->syslog(LOG_INFO,"started log machine %d at line %d",
|
|
rml->arg(0).toInt(),rml->arg(1).toInt());
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(true);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
break;
|
|
|
|
case RDMacro::PM: // Set Mode
|
|
if((rml->argQuantity()!=1)&&(rml->argQuantity()!=2)) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if(rml->argQuantity()==2) {
|
|
if((index=LogMachineIndex(rml->arg(1).toInt()))<0) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
}
|
|
start=0;
|
|
end=RD_RDVAIRPLAY_LOG_QUAN;
|
|
if(index>=0) {
|
|
start=index;
|
|
end=index+1;
|
|
}
|
|
switch((RDAirPlayConf::OpMode)rml->arg(0).toInt()) {
|
|
case RDAirPlayConf::LiveAssist:
|
|
for(int i=start;i<end;i++) {
|
|
SetLiveAssistMode(i);
|
|
}
|
|
break;
|
|
|
|
case RDAirPlayConf::Manual:
|
|
for(int i=start;i<end;i++) {
|
|
SetManualMode(i);
|
|
}
|
|
break;
|
|
|
|
case RDAirPlayConf::Auto:
|
|
for(int i=start;i<end;i++) {
|
|
SetAutoMode(i);
|
|
}
|
|
break;
|
|
|
|
default:
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
return;
|
|
}
|
|
}
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(true);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
break;
|
|
|
|
case RDMacro::PN: // Start Next
|
|
if((rml->argQuantity()<1)||(rml->argQuantity()>3)) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if((index=LogMachineIndex(rml->arg(0).toInt()))<0) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if(rml->argQuantity()>=2) {
|
|
if((rml->arg(1).toInt()<1)||(rml->arg(1).toInt()>2)) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if(rml->argQuantity()==3) {
|
|
if((rml->arg(2).toInt()<0)||(rml->arg(2).toInt()>1)) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
next_line=air_logs[index]->nextLine();
|
|
if(air_logs[index]->nextLine()>=0) {
|
|
if(rml->argQuantity()==1) {
|
|
if(!air_logs[index]->
|
|
play(air_logs[index]->nextLine(),RDLogLine::StartMacro)) {
|
|
rda->syslog(LOG_WARNING,"log machine %d failed to start",
|
|
rml->arg(0).toInt());
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
}
|
|
else {
|
|
if(rml->argQuantity()==2) {
|
|
if(!air_logs[index]->play(air_logs[index]->nextLine(),
|
|
RDLogLine::StartMacro,
|
|
rml->arg(1).toInt()-1)) {
|
|
rda->syslog(LOG_WARNING,"log machine %d failed to start",
|
|
rml->arg(0).toInt());
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
}
|
|
else {
|
|
if(!air_logs[index]->
|
|
play(air_logs[index]->nextLine(),RDLogLine::StartMacro,
|
|
rml->arg(1).toInt()-1,rml->arg(2).toInt())) {
|
|
rda->syslog(LOG_WARNING,"log machine %d failed to start",
|
|
rml->arg(0).toInt());
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
rda->syslog(LOG_INFO,"started log machine %d at line %d",
|
|
rml->arg(0).toInt(),next_line);
|
|
}
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(true);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
break;
|
|
|
|
case RDMacro::PS: // Stop
|
|
if((rml->argQuantity()<1)||(rml->argQuantity()>3)) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
index=LogMachineIndex(rml->arg(0).toInt(),&all_logs);
|
|
if((index<0)&(!all_logs)) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
fade=0;
|
|
if(rml->argQuantity()>1) {
|
|
fade=rml->arg(1).toInt();
|
|
}
|
|
if(all_logs) {
|
|
for(int i=0;i<RD_RDVAIRPLAY_LOG_QUAN;i++) {
|
|
air_logs[i]->stop(true,0,fade);
|
|
}
|
|
rda->syslog(LOG_INFO,"stopped all logs");
|
|
}
|
|
else {
|
|
if(rml->argQuantity()==3) {
|
|
air_logs[index]->stop(false,rml->arg(2).toInt(),fade);
|
|
}
|
|
else {
|
|
air_logs[index]->stop(true,0,fade);
|
|
}
|
|
rda->syslog(LOG_INFO,"stopped log machine %d",rml->arg(0).toInt());
|
|
break;
|
|
}
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(true);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
break;
|
|
|
|
case RDMacro::MD: // Duck Machine
|
|
if(rml->argQuantity()<3 || rml->argQuantity()>4) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
index=LogMachineIndex(rml->arg(0).toInt(),&all_logs);
|
|
if((index<0)&&(!all_logs)) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if(all_logs) {
|
|
for(int i=0;i<RD_RDVAIRPLAY_LOG_QUAN;i++) {
|
|
air_logs[i]->duckVolume(rml->arg(1).toInt()*100,rml->arg(2).toInt());
|
|
}
|
|
rda->syslog(LOG_INFO,"set volumne of all log machines to %d dBFS",
|
|
rml->arg(1).toInt());
|
|
}
|
|
else {
|
|
if(rml->argQuantity()==3) {
|
|
air_logs[index]->
|
|
duckVolume(rml->arg(1).toInt()*100,rml->arg(2).toInt());
|
|
}
|
|
else {
|
|
air_logs[index]->duckVolume(rml->arg(1).toInt()*100,
|
|
rml->arg(2).toInt(),rml->arg(3).toInt());
|
|
}
|
|
rda->syslog(LOG_INFO,"set volumne of log machine %d to %d dBFS",
|
|
rml->arg(0).toInt(),
|
|
rml->arg(1).toInt());
|
|
break;
|
|
}
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(true);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
break;
|
|
|
|
case RDMacro::PX: // Add Next
|
|
if(rml->argQuantity()!=2) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
index=LogMachineIndex(rml->arg(0).toInt());
|
|
if((index<0)||(rml->arg(1).toUInt()>999999)) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
next_line=air_logs[index]->nextLine();
|
|
if(air_logs[index]->nextLine()>=0) {
|
|
air_logs[index]->insert(air_logs[index]->nextLine(),
|
|
rml->arg(1).toUInt(),RDLogLine::Play);
|
|
rda->syslog(LOG_INFO,"inserted cart %06u at line %d on log machine %d",
|
|
rml->arg(1).toUInt(),next_line,rml->arg(0).toInt());
|
|
}
|
|
else {
|
|
air_logs[index]->insert(air_logs[index]->size(),
|
|
rml->arg(1).toUInt(),RDLogLine::Play);
|
|
air_logs[index]->makeNext(air_logs[index]->size()-1);
|
|
rda->syslog(LOG_INFO,"inserted cart %06u at line %d on log machine %d",
|
|
rml->arg(1).toUInt(),air_logs[index]->size()-1,
|
|
rml->arg(0).toInt());
|
|
}
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(true);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
break;
|
|
|
|
case RDMacro::RL: // Refresh Log
|
|
if(rml->argQuantity()!=1) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if((index=LogMachineIndex(rml->arg(0).toInt()))<0) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if(!air_logs[index]->refresh()) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
else {
|
|
rda->syslog(LOG_INFO,"refreshed log machine %d",rml->arg(0).toInt());
|
|
}
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(true);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
break;
|
|
|
|
case RDMacro::SN: // Set default Now & Next Cart
|
|
if(rml->argQuantity()!=3) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if((rml->arg(0).lower()!="now")&&
|
|
(rml->arg(0).lower()!="next")) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if((index=LogMachineIndex(rml->arg(1).toInt()))<0) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if(rml->arg(2).toUInt()>999999) {
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(false);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
return;
|
|
}
|
|
if(rml->arg(0).lower()=="now") {
|
|
air_logs[index]->setNowCart(rml->arg(2).toUInt());
|
|
rda->syslog(LOG_INFO,"set default \"now\" cart to %06u on log machine %d",
|
|
rml->arg(2).toUInt(),rml->arg(1).toInt());
|
|
}
|
|
else {
|
|
air_logs[index]->setNextCart(rml->arg(2).toUInt());
|
|
rda->syslog(LOG_INFO,
|
|
"set default \"next\" cart to %06u on log machine %d",
|
|
rml->arg(2).toUInt(),rml->arg(1).toInt());
|
|
}
|
|
if(rml->echoRequested()) {
|
|
rml->acknowledge(true);
|
|
rda->ripc()->sendRml(rml);
|
|
}
|
|
break;
|
|
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
|
|
int MainObject::LogMachineIndex(int log_mach,bool *all) const
|
|
{
|
|
if((log_mach<=RD_RDVAIRPLAY_LOG_BASE)||
|
|
(log_mach>RD_RDVAIRPLAY_LOG_BASE+RD_RDVAIRPLAY_LOG_QUAN)) {
|
|
return -1;
|
|
}
|
|
if(all!=NULL) {
|
|
*all=log_mach-RD_RDVAIRPLAY_LOG_BASE==0;
|
|
}
|
|
return log_mach-RD_RDVAIRPLAY_LOG_BASE-1;
|
|
}
|