Rivendellaudio/importers/rdcatch_copy.cpp

// rdcatch_copy.cpp
//
// An RDCatch event copier.
//
//   (C) Copyright 2002-2021 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 <stdlib.h>
#include <stdio.h>
#include <unistd.h>

#include <QCoreApplication>

#include <dbversion.h>
#include <rd.h>
#include <rdcmd_switch.h>
#include <rddb.h>
#include <rdescape_string.h>

#include "rdcatch_copy.h"

MainObject::MainObject(QObject *parent)
  : QObject(parent)
{
  bool found=false;
  QString src_hostname;
  QString dest_hostname;
  QString src_station;
  QString dest_station;
  QString sql;
  QSqlQuery *q;
  QSqlQuery *q1;

  //
  // Read Command Options
  //
  RDCmdSwitch *cmd=
    new RDCmdSwitch("rdcatch_copy",RDCATCH_COPY_USAGE);
  delete cmd;

  rd_config=new RDConfig(RD_CONF_FILE);
  rd_config->load();
  rd_config->setModuleName("rdcatch_copy");

  //
  // Read Switches
  //
  for(int i=1;i<qApp->arguments().size();i+=2) {
    found=false;
    if(QString(qApp->arguments().at(i))=="-h") {  // Source mySQL Hostname
      if((i+1)==qApp->arguments().size()) {
	fprintf(stderr,"rdcatch_copy: invalid argument\n");
	exit(256);
      }
      src_hostname=qApp->arguments().at(i+1);
      found=true;
    }
    if(QString(qApp->arguments().at(i))=="-s") {  // Source Rivendell Host
      if((i+1)==qApp->arguments().size()) {
	fprintf(stderr,"rdcatch_copy: invalid argument\n");
	exit(256);
      }
      src_station=qApp->arguments().at(i+1);
      found=true;
    }
    if(QString(qApp->arguments().at(i))=="-H") {  // Source mySQL Hostname
      if((i+1)==qApp->arguments().size()) {
	fprintf(stderr,"rdcatch_copy: invalid argument\n");
	exit(256);
      }
      dest_hostname=qApp->arguments().at(i+1);
      found=true;
    }
    if(QString(qApp->arguments().at(i))=="-S") {  // Source Rivendell Host
      if((i+1)==qApp->arguments().size()) {
	fprintf(stderr,"rdcatch_copy: invalid argument\n");
	exit(256);
      }
      dest_station=qApp->arguments().at(i+1);
      found=true;
    }
    if(!found) {
      fprintf(stderr,"rdcatch_copy: invalid argument\n");
      exit(256);
    }
  }

  if(src_hostname.isEmpty()) {
    fprintf(stderr,"rdcatch_copy: invalid source mySQL hostname\n");
    exit(256);
  }
  if(src_station.isEmpty()) {
    fprintf(stderr,"rdcatch_copy: invalid source Rivendell host\n");
    exit(256);
  }
  if(dest_hostname.isEmpty()) {
    fprintf(stderr,"rdcatch_copy: invalid destination mySQL hostname\n");
    exit(256);
  }
  if(dest_station.isEmpty()) {
    fprintf(stderr,"rdcatch_copy: invalid destination Rivendell host\n");
    exit(256);
  }

  //
  // Open Databases
  //
  src_db=QSqlDatabase::addDatabase("QMYSQL3");
  src_db.setDatabaseName(rd_config->mysqlDbname());
  src_db.setUserName(rd_config->mysqlUsername());
  src_db.setPassword(rd_config->mysqlPassword());
  src_db.setHostName(src_hostname);
  if(!src_db.open()) {
    fprintf(stderr,"rdcatch_copy: unable to connect to source mySQL server\n");
    src_db.removeDatabase(rd_config->mysqlDbname());
    exit(256);
  }

  if(src_hostname==dest_hostname) {
    if(src_station==dest_station) {
      fprintf(stderr,"rdcatch_copy: cannot copy a host configuration onto itself\n");
      exit(256);
    }
    else {
      dest_db=src_db;
    }
  }
  else {
    dest_db=QSqlDatabase::addDatabase("QMYSQL3");
    dest_db.setDatabaseName(rd_config->mysqlDbname());
    dest_db.setUserName(rd_config->mysqlUsername());
    dest_db.setPassword(rd_config->mysqlPassword());
    dest_db.setHostName(dest_hostname);
    if(!dest_db.open()) {
      fprintf(stderr,
	      "rdcatch_copy: unable to connect to destination mySQL server\n");
      exit(256);
    }
  }

  //
  // Check Database Versions
  //
  sql=QString("select `DB` from `VERSION`");
  q=new QSqlQuery(sql,src_db);
  if(!q->first()) {
    fprintf(stderr,
	    "rdcatch_copy: unable to read source database version\n");
    exit(256);
  }
  if(q->value(0).toInt()!=RD_VERSION_DATABASE) {
    fprintf(stderr,"rdcatch_copy: source database version mismatch\n");
    exit(256);
  }
  delete q;

  q=new QSqlQuery(sql,dest_db);
  if(!q->first()) {
    fprintf(stderr,
	    "rdcatch_copy: unable to read destination database version\n");
    exit(256);
  }
  if(q->value(0).toInt()!=RD_VERSION_DATABASE) {
    fprintf(stderr,"rdcatch_copy: destination database version mismatch\n");
    exit(256);
  }
  delete q;

  //
  // Check Rivendell Hosts
  //
  sql=QString("select `NAME` from `STATIONS` where ")+
    "NAME='"+RDEscapeString(src_station)+"'";
  q=new QSqlQuery(sql,src_db);
  if(!q->first()) {
    fprintf(stderr,
	    "rdcatch_copy: source Rivendell host doesn't exist\n");
    exit(256);
  }
  delete q;

  sql=QString("select `NAME` from `STATIONS` where ")+
    "`NAME`='"+RDEscapeString(dest_station)+"'";
  q=new QSqlQuery(sql,dest_db);
  if(!q->first()) {
    fprintf(stderr,
	    "rdcatch_copy: destination Rivendell host doesn't exist\n");
    exit(256);
  }
  delete q;

  //
  // Confirmation Prompt
  //
  printf("\n");
  printf("****** WARNING ******\n");
  printf(" This operation will OVERWRITE ALL RDCATCH EVENTS on the destination Host!");
  printf(" Press RETURN to continue, or CNTL-C to abort.");
  printf("\n");
  while(getchar()!=10);
  printf("Copying events...");
  fflush(stdout);

  //
  // Delete current destination entries
  //
  sql=QString("delete from `RECORDINGS` where ")+
    "`STATION_NAME`='"+RDEscapeString(dest_station)+"'";
  q=new QSqlQuery(sql,dest_db);
  delete q;

  //
  // Copy Entries
  //
  sql=QString("select ")+
    "`IS_ACTIVE`,"+         // 00
    "`TYPE`,"+              // 01
    "`CHANNEL`,"+           // 02
    "`CUT_NAME`,"+          // 03
    "`SUN`,"+               // 04
    "`MON`,"+               // 05
    "`TUE`,"+               // 06
    "`WED`,"+               // 07
    "`THU`,"+               // 08
    "`FRI`,"+               // 09
    "`SAT`,"+               // 10
    "`DESCRIPTION`,"+       // 11
    "`START_TYPE`,"+        // 12
    "`START_TIME`,"+        // 13
    "`START_LENGTH`,"+      // 14
    "`START_MATRIX`,"+      // 15
    "`START_LINE`,"+        // 16
    "`START_OFFSET`,"+      // 17
    "`END_TYPE`,"+          // 18
    "`END_TIME`,"+          // 19
    "`END_LENGTH`,"+        // 20
    "`END_MATRIX`,"+        // 21
    "`END_LINE`,"+          // 22
    "`LENGTH`,"+            // 23
    "`TRIM_THRESHOLD`,"+    // 24
    "`NORMALIZE_LEVEL`,"+   // 25
    "`STARTDATE_OFFSET`,"+  // 26
    "`ENDDATE_OFFSET`,"+    // 27
    "`FORMAT`,"+            // 28
    "`CHANNELS`,"+          // 29
    "`SAMPRATE`,"+          // 30
    "`BITRATE`,"+           // 31
    "`QUALITY`,"+           // 32
    "`MACRO_CART`,"+        // 33
    "`SWITCH_INPUT`,"+      // 34
    "`SWITCH_OUTPUT`,"+     // 35
    "`EXIT_CODE`,"+         // 36
    "`ONE_SHOT`,"+          // 37
    "`URL`,"+               // 38
    "`URL_USERNAME`,"+      // 39
    "`URL_PASSWORD` "+      // 40
    "from `RECORDINGS` where "+
    "`STATION_NAME`='"+RDEscapeString(src_station)+"'";
  q=new QSqlQuery(sql,src_db);
  while(q->next()) {
    sql=QString("insert into `RECORDINGS` set ")+
      "`IS_ACTIVE`='"+RDEscapeString(q->value(0).toString())+"',"+
      QString::asprintf("`TYPE`=%d,",q->value(1).toInt())+
      QString::asprintf("`CHANNEL`=%u,",q->value(2).toUInt())+
      "`CUT_NAME`='"+RDEscapeString(q->value(3).toString())+"',"+
      "`SUN`='"+RDEscapeString(q->value(4).toString())+"',"+
      "`MON`='"+RDEscapeString(q->value(5).toString())+"',"+
      "`TUE`='"+RDEscapeString(q->value(6).toString())+"',"+
      "`WED`='"+RDEscapeString(q->value(7).toString())+"',"+
      "`THU`='"+RDEscapeString(q->value(8).toString())+"',"+
      "`FRI`='"+RDEscapeString(q->value(9).toString())+"',"+
      "`SAT`='"+RDEscapeString(q->value(10).toString())+"',"+
      "`DESCRIPTION`='"+RDEscapeString(q->value(11).toString())+"',"+
      QString::asprintf("`START_TYPE`=%d,",q->value(12).toInt())+
      "`START_TIME`='"+RDEscapeString(q->value(13).toString())+"',"+
      QString::asprintf("`START_LENGTH`=%d,",q->value(14).toInt())+
      QString::asprintf("`START_MATRIX`=%d,",q->value(15).toInt())+
      QString::asprintf("`START_LINE`=%d,",q->value(16).toInt())+
      QString::asprintf("`START_OFFSET`=%d,",q->value(17).toInt())+
      QString::asprintf("`END_TYPE`=%d,",q->value(18).toInt())+
      "`END_TIME`='"+RDEscapeString(q->value(19).toString())+"',"+
      QString::asprintf("`END_LENGTH`=%d,",q->value(20).toInt())+
      QString::asprintf("`END_MATRIX`=%d,",q->value(21).toInt())+
      QString::asprintf("`END_LINE`=%d,",q->value(22).toInt())+
      QString::asprintf("`LENGTH`=%u,",q->value(23).toUInt())+
      QString::asprintf("`TRIM_THRESHOLD`=%d,",q->value(24).toInt())+
      QString::asprintf("`NORMALIZE_LEVEL`=%d,",q->value(25).toInt())+
      QString::asprintf("`STARTDATE_OFFSET`=%u,",q->value(26).toUInt())+
      QString::asprintf("`ENDDATE_OFFSET`=%u,",q->value(27).toUInt())+
      QString::asprintf("`FORMAT`=%d,",q->value(28).toInt())+
      QString::asprintf("`CHANNELS`=%d,",q->value(29).toInt())+
      QString::asprintf("`SAMPRATE`=%d,",q->value(30).toInt())+
      QString::asprintf("`BITRATE`=%d,",q->value(31).toInt())+
      QString::asprintf("`QUALITY`=%d,",q->value(32).toInt())+
      QString::asprintf("`MACRO_CART`=%d,",q->value(33).toInt())+
      QString::asprintf("`SWITCH_INPUT`=%d,",q->value(34).toInt())+
      QString::asprintf("`SWITCH_OUTPUT`=%d,",q->value(35).toInt())+
      QString::asprintf("`EXIT_CODE`=%d,",q->value(36).toInt())+
      "`ONE_SHOT`='"+RDEscapeString(q->value(37).toString())+"',"+
      "`URL`='"+RDEscapeString(q->value(38).toString())+"',"+
      "`URL_USERNAME`='"+RDEscapeString(q->value(39).toString())+"',"+
      "`URL_PASSWORD`='"+RDEscapeString(q->value(40).toString())+"',"+
      "`STATION_NAME`='"+RDEscapeString(dest_station)+"'";
    q1=new QSqlQuery(sql,dest_db);
    delete q1;
  }
  delete q;

  printf("done.\n");
  exit(0);
}


int main(int argc,char *argv[])
{
  QApplication a(argc,argv,false);
  new MainObject(NULL);
  return a.exec();
}