// rdvairplay.cpp
//
// Headless RDAirPlay
//
//   (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 <fcntl.h>
#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>

#include <qapplication.h>

#include <rdapplication.h>
#include <rdcheck_daemons.h>
#include <rdconf.h>
#include <rddbheartbeat.h>
#include <rdmixer.h>
#include <rdweb.h>

#include "rdvairplay.h"

MainObject::MainObject(QObject *parent)
  :QObject(parent)
{
  QString err_msg;

  //
  // Ensure Single Instance
  //
  air_lock=new RDInstanceLock(QString().sprintf("%s/.rdvairplaylock",
					       (const char *)RDHomeDir()));
  if(!air_lock->lock()) {
    fprintf(stderr,"rdvairplay: multiple instances not allowed\n");
    exit(1);
  }

  //
  // Ensure that system daemons are running
  //
  RDInitializeDaemons();

  //
  // Open the Database
  //
  rda=new RDApplication("rdvairplay","rdvairplay",RDVAIRPLAY_USAGE,this);
  if(!rda->open(&err_msg)) {
    fprintf(stderr,"rdvairplay: %s\n",(const char *)err_msg);
    exit(1);
  }

  //
  // Read Command Options
  //
  for(unsigned i=0;i<rda->cmdSwitch()->keys();i++) {
    if(!rda->cmdSwitch()->processed(i)) {
      fprintf(stderr,"rdvairplay: unknown command option \"%s\"\n",
	      (const char *)rda->cmdSwitch()->key(i));
      exit(2);
    }
  }

  //
  // CAE Connection
  //
  rda->cae()->connectHost();

  //
  // Set Audio Assignments
  //
  //  air_segue_length=rda->airplayConf()->segueLength()+1;
  RDSetMixerPorts(rda->config()->stationName(),rda->cae());

  //
  // RIPC Connection
  //
  //  connect(rda->ripc(),SIGNAL(connected(bool)),this,SLOT(ripcConnected(bool)));
  connect(rda,SIGNAL(userChanged()),this,SLOT(userData()));
  connect(rda->ripc(),SIGNAL(rmlReceived(RDMacro *)),
	  this,SLOT(rmlReceivedData(RDMacro *)));
  //  connect(rda->ripc(),SIGNAL(gpiStateChanged(int,int,bool)),
  //	  this,SLOT(gpiStateChangedData(int,int,bool)));
  rda->ripc()->
    connectHost("localhost",RIPCD_TCP_PORT,rda->config()->password());

  //
  // Macro Player
  //
  air_event_player=new RDEventPlayer(rda->ripc(),this);

  //
  // UDP Transmission Socket
  //
  air_nownext_socket=new QSocketDevice(QSocketDevice::Datagram);

  //
  // Log Machines
  //
  QSignalMapper *reload_mapper=new QSignalMapper(this);
  connect(reload_mapper,SIGNAL(mapped(int)),this,SLOT(logReloadedData(int)));
  QSignalMapper *rename_mapper=new QSignalMapper(this);
  //  connect(rename_mapper,SIGNAL(mapped(int)),this,SLOT(logRenamedData(int)));
  QString default_svcname=rda->airplayConf()->defaultSvc();
  for(int i=0;i<RD_RDVAIRPLAY_LOG_QUAN;i++) {
    air_logs[i]=new RDLogPlay(i,air_event_player,air_nownext_socket,"",
			     &air_plugin_hosts);
    air_logs[i]->setDefaultServiceName(default_svcname);
    air_logs[i]->setNowCart(rda->airplayConf()->logNowCart(i));
    air_logs[i]->setNextCart(rda->airplayConf()->logNextCart(i));
    reload_mapper->setMapping(air_logs[i],i);
    connect(air_logs[i],SIGNAL(reloaded()),reload_mapper,SLOT(map()));
    rename_mapper->setMapping(air_logs[i],i);
    connect(air_logs[i],SIGNAL(renamed()),rename_mapper,SLOT(map()));
    //    connect(air_logs[i],SIGNAL(refreshStatusChanged(bool)),
    //	    this,SLOT(refreshStatusChangedData(bool)));
    //    connect(air_logs[i],SIGNAL(channelStarted(int,int,int,int)),
    //	    this,SLOT(logChannelStartedData(int,int,int,int)));
    //    connect(air_logs[i],SIGNAL(channelStopped(int,int,int,int)),
    //	    this,SLOT(logChannelStoppedData(int,int,int,int)));
    int chans[2]={0,0};
    int ports[2]={0,0};
    QString start_rml[2]={"",""};
    QString stop_rml[2]={"",""};
    air_logs[i]->setChannels(chans,ports,start_rml,stop_rml);
  }
  //  connect(air_logs[0],SIGNAL(transportChanged()),
  //	  this,SLOT(transportChangedData()));
  
}


void MainObject::userData()
{
  printf("User connected!\n");
}


void MainObject::logReloadedData(int log)
{
}


void MainObject::SetAutoMode(int index)
{
  air_logs[index]->setOpMode(RDAirPlayConf::Auto);
  rda->log(RDConfig::LogInfo,
	   QString().sprintf("log machine %d mode set to AUTOMATIC",
			     index+RD_RDVAIRPLAY_LOG_BASE+1));
}


void MainObject::SetLiveAssistMode(int index)
{
  /*
  if(mach==0) {
    air_pie_counter->setOpMode(RDAirPlayConf::LiveAssist);
  }
  air_mode_display->setOpMode(mach,RDAirPlayConf::LiveAssist);
  air_op_mode[mach]=RDAirPlayConf::LiveAssist;
  rda->airplayConf()->setOpMode(mach,RDAirPlayConf::LiveAssist);
  */
  air_logs[index]->setOpMode(RDAirPlayConf::LiveAssist);
  /*
  air_log_list[mach]->setOpMode(RDAirPlayConf::LiveAssist);
  if(mach==0) {
    air_button_list->setOpMode(RDAirPlayConf::LiveAssist); 
    air_post_counter->setDisabled(true);
  }
  */
  rda->log(RDConfig::LogInfo,
	   QString().sprintf("log machine %d mode set to LIVE ASSIST",
			     index+RD_RDVAIRPLAY_LOG_BASE+1));
}


void MainObject::SetManualMode(int index)
{
  air_logs[index]->setOpMode(RDAirPlayConf::Manual);
  rda->log(RDConfig::LogInfo,
	   QString().sprintf("log machine %d mode set to MANUAL",
			     index+RD_RDVAIRPLAY_LOG_BASE+1));
}


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