2018-12-17 Fred Gleason <fredg@paravelsystems.com>

* Renamed the RD_RLM2_CLIENT_TCP_PORT define to RD_PAD_CLIENT_TCP_PORT.
	* Renamed the  RD_RLM_SOURCE_UNIX_ADDRESS define to
	 RD_PAD_SOURCE_UNIX_ADDRESS.
	* Added a RD_PYPAD_SCRIPT_DIR define.
	* Added an 'RDNotification::PypadType' value to the
	'RDNotification::Type' enumeration.
	* Added 'PypadOwner=' and 'PypadGroup=' directives to the
	'[Identity]' section of rd.conf(5).
	* Added an rdpadengined(8) service.
	* Added a 'PYPAD_INSTANCES.IS_RUNNING' field to the database.
	* Added a 'PYPAD_INSTANCES.EXIT_CODE' field to the database.
	* Added a 'PYPAD_INSTANCES.ERROR_TEXT' field to the database.
	* Incremented the database version to 304.

rdpadengined/Makefile.am

@@ -0,0 +1,48 @@
+## Makefile.am
+##
+## Rivendell PyPAD Script Host
+##
+## (C) Copyright 2018 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.
+##
+##
+## Use automake to process this into a Makefile.in
+
+AM_CPPFLAGS = -Wall -DPREFIX=\"$(prefix)\" -I$(top_srcdir)/lib @QT4_CFLAGS@ -I/usr/include/Qt3Support
+LIBS = -L$(top_srcdir)/lib -L$(top_srcdir)/rdhpi
+MOC = @QT_MOC@
+
+# The dependency for qt's Meta Object Compiler (moc)
+moc_%.cpp:	%.h
+	$(MOC) $< -o $@
+
+
+sbin_PROGRAMS = rdpadengined
+
+dist_rdpadengined_SOURCES = rdpadengined.cpp rdpadengined.h
+
+nodist_rdpadengined_SOURCES = moc_rdpadengined.cpp
+
+rdpadengined_LDADD = @LIB_RDLIBS@ @LIBVORBIS@ @QT4_LIBS@ -lQt3Support
+
+CLEANFILES = *~\
+             *.idb\
+             *ilk\
+             *.obj\
+             *.pdb\
+             moc_*
+
+MAINTAINERCLEANFILES = *~\
+                       Makefile.in

rdpadengined/rdpadengined.cpp

@@ -0,0 +1,285 @@
+// rdpadengined.cpp
+//
+// Rivendell PAD Consolidation Server
+//
+//   (C) Copyright 2018 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 <errno.h>
+#include <signal.h>
+#include <stdio.h>
+
+#include <qcoreapplication.h>
+#include <qstringlist.h>
+
+#include <rdapplication.h>
+#include <rdconf.h>
+#include <rdescape_string.h>
+#include <rdpaths.h>
+
+#include "rdpadengined.h"
+
+bool global_pad_exiting=false;
+
+void SigHandler(int signo)
+{
+  switch(signo) {
+  case SIGINT:
+  case SIGTERM:
+    global_pad_exiting=true;
+    break;
+  }
+}
+
+
+MainObject::MainObject(QObject *parent)
+  : QObject(parent)
+{
+  QString err_msg;
+
+  //
+  // Open the Database
+  //
+  rda=new RDApplication("rdpadengined","rdpadengined",RDPADENGINED_USAGE,this);
+  if(!rda->open(&err_msg)) {
+    fprintf(stderr,"rdpadengined: %s\n",(const char *)err_msg);
+    exit(1);
+  }
+
+  //
+  // Shed root permissions
+  //
+  if(getuid()==0) {
+    if(setgid(rda->config()->pypadGid())!=0) {
+      fprintf(stderr,"rdpadengined: unable to set GID to %d [%s]\n",
+	      rda->config()->pypadGid(),strerror(errno));
+      exit(1);
+    }
+    if(setuid(rda->config()->pypadUid())!=0) {
+      fprintf(stderr,"rdpadengined: unable to set UID to %d [%s]\n",
+	      rda->config()->pypadUid(),strerror(errno));
+      exit(1);
+    }
+  }
+
+  //
+  // Read Command Options
+  //
+  for(unsigned i=0;i<rda->cmdSwitch()->keys();i++) {
+    if(!rda->cmdSwitch()->processed(i)) {
+      fprintf(stderr,"rdpadengined: unknown command option \"%s\"\n",
+	      (const char *)rda->cmdSwitch()->key(i));
+      exit(2);
+    }
+  }
+
+  //
+  // RIPCD Connection
+  //
+  connect(rda->ripc(),SIGNAL(connected(bool)),
+	  this,SLOT(ripcConnectedData(bool)));
+  connect(rda->ripc(),SIGNAL(notificationReceived(RDNotification *)),
+	  this,SLOT(notificationReceivedData(RDNotification *)));
+  rda->
+    ripc()->connectHost("localhost",RIPCD_TCP_PORT,rda->config()->password());
+
+  //
+  // Exit Timer
+  //
+  pad_exit_timer=new QTimer(this);
+  connect(pad_exit_timer,SIGNAL(timeout()),this,SLOT(exitData()));
+  pad_exit_timer->start(100);
+
+  ::signal(SIGINT,SigHandler);
+  ::signal(SIGTERM,SigHandler);
+}
+
+
+void MainObject::ripcConnectedData(bool state)
+{
+  QStringList args;
+  QString sql;
+  RDSqlQuery *q;
+
+  //
+  // Clear DB Records
+  //
+  sql=QString("update PYPAD_INSTANCES set ")+
+    "IS_RUNNING=\"N\","+
+    "EXIT_CODE=0,"+
+    "ERROR_TEXT=null "+
+    "where STATION_NAME=\""+RDEscapeString(rda->station()->name())+"\"";
+  RDSqlQuery::apply(sql);
+
+  //
+  // Start Scripts
+  //
+  sql=QString("select ")+
+    "ID,"           // 00
+    "SCRIPT_PATH "  // 01
+    "from PYPAD_INSTANCES where "+
+    "STATION_NAME=\""+RDEscapeString(rda->station()->name())+"\"";
+  q=new RDSqlQuery(sql);
+  while(q->next()) {
+    StartScript(q->value(0).toUInt(),q->value(1).toString());
+  }
+  delete q;
+}
+
+
+void MainObject::notificationReceivedData(RDNotification *notify)
+{
+  QString sql;
+  RDSqlQuery *q;
+
+ if(notify->type()==RDNotification::PypadType) {
+    int id=notify->id().toUInt();
+    sql=QString("select SCRIPT_PATH from PYPAD_INSTANCES where ")+
+      QString().sprintf("ID=%u && ",id)+
+      "STATION_NAME=\""+RDEscapeString(rda->station()->name())+"\"";
+    q=new RDSqlQuery(sql);
+    while(q->next()) {
+      switch(notify->action()) {
+      case RDNotification::AddAction:
+	StartScript(id,q->value(0).toString());
+	break;
+
+      case RDNotification::DeleteAction:
+	pad_instances.value(id)->setPrivateData((void *)true);  // No Restart
+	KillScript(id);
+	break;
+
+      case RDNotification::ModifyAction:
+	KillScript(id);
+	break;
+
+      case RDNotification::NoAction:
+      case RDNotification::LastAction:
+	break;
+      }
+    }
+    delete q;
+  }
+}
+
+
+void MainObject::instanceStartedData(int id)
+{
+  SetRunStatus(id,true);
+}
+
+
+void MainObject::instanceFinishedData(int id)
+{
+  RDProcess *proc=pad_instances.value(id);
+
+  if(proc->process()->exitStatus()!=QProcess::NormalExit) {
+    fprintf(stderr,"rdpadengined: process %d crashed\n",id);
+    SetRunStatus(id,false,-1,proc->process()->readAllStandardError());
+    proc->deleteLater();
+    pad_instances.remove(id);
+    return;
+  }
+  if(proc->process()->exitCode()==0) {
+    SetRunStatus(id,false);
+    bool no_restart=(bool)proc->privateData();
+    QString script_path=proc->arguments().at(0);
+    proc->deleteLater();
+    pad_instances.remove(id);
+    if(!no_restart) {
+      StartScript(id,script_path);
+    }
+  }
+  else {
+    if(!global_pad_exiting) {
+      SetRunStatus(id,false,proc->process()->exitCode(),
+		   proc->process()->readAllStandardError());
+    }
+  }
+}
+
+
+void MainObject::exitData()
+{
+  if(global_pad_exiting) {
+    //
+    // Shut down all instances
+    //
+    for(QMap<unsigned,RDProcess *>::const_iterator it=pad_instances.begin();
+	it!=pad_instances.end();it++) {
+      it.value()->setPrivateData((void *)true);  // No Restart
+      it.value()->process()->terminate();
+    }
+
+    //
+    // Update Database
+    //
+    QString sql=QString("update PYPAD_INSTANCES set ")+
+      "IS_RUNNING=\"N\" where "+
+      "STATION_NAME=\""+RDEscapeString(rda->station()->name())+"\"";
+    RDSqlQuery::apply(sql);
+    exit(0);
+  }
+}
+
+
+void MainObject::StartScript(unsigned id,const QString &script_path)
+{
+  RDProcess *proc=new RDProcess(id,this);
+  pad_instances[id]=proc;
+  connect(proc,SIGNAL(started(int)),this,SLOT(instanceStartedData(int)));
+  connect(proc,SIGNAL(finished(int)),this,SLOT(instanceFinishedData(int)));
+  QStringList args;
+  args.push_back(script_path);
+  args.push_back("localhost");
+  args.push_back(QString().sprintf("%u",RD_PAD_CLIENT_TCP_PORT));
+  args.push_back(QString().sprintf("$%u",id));
+  pad_instances.value(id)->start(RD_PYPAD_PYTHON_PATH,args);
+  syslog(LOG_NOTICE,"starting: %s %s",(const char *)proc->program().toUtf8(),
+	 (const char *)proc->arguments().join(" ").toUtf8());
+}
+
+
+void MainObject::KillScript(unsigned id)
+{
+  pad_instances.value(id)->process()->terminate();
+}
+
+
+void MainObject::SetRunStatus(unsigned id,bool state,int exit_code,
+			      const QString &err_text) const
+{
+  QString sql=QString("update PYPAD_INSTANCES set ")+
+    "IS_RUNNING=\""+RDYesNo(state)+"\","+
+    QString().sprintf("EXIT_CODE=%u,",exit_code);
+  if(err_text.isNull()) {
+    sql+="ERROR_TEXT=null ";
+  }
+  else {
+    sql+="ERROR_TEXT=\""+RDEscapeString(err_text)+"\" ";
+  }
+  sql+=QString().sprintf("where ID=%u",id);
+  RDSqlQuery::apply(sql);
+}
+
+
+int main(int argc,char *argv[])
+{
+  QCoreApplication a(argc,argv);
+
+  new MainObject();
+  return a.exec();
+}

rdpadengined/rdpadengined.h

@@ -0,0 +1,58 @@
+// rdpadengined.h
+//
+// Rivendell PAD Consolidation Server
+//
+//   (C) Copyright 2018 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.
+//
+
+#ifndef RDPADENGINED_H
+#define RDPADENGINED_H
+
+#include <qmap.h>
+#include <qobject.h>
+#include <qprocess.h>
+#include <qtimer.h>
+
+#include <rdnotification.h>
+#include <rdprocess.h>
+
+#define RDPADENGINED_USAGE "\n\n"
+
+
+class MainObject : public QObject
+{
+  Q_OBJECT
+ public:
+  MainObject(QObject *parent=0);
+
+ private slots:
+  void ripcConnectedData(bool state);
+  void notificationReceivedData(RDNotification *notify);
+  void instanceStartedData(int id);
+  void instanceFinishedData(int id);
+  void exitData();
+
+ private:
+  void StartScript(unsigned id,const QString &script_path);
+  void KillScript(unsigned id);
+  void SetRunStatus(unsigned id,bool state,int exit_code=0,
+		    const QString &err_text=QString()) const;
+  QMap<unsigned,RDProcess *> pad_instances;
+  QTimer *pad_exit_timer;
+};
+
+
+#endif  // RDPADENGINED_H